.

wcfs/wcfs_test.py

@@ -1273,13 +1273,24 @@ def test_wcfs_inv_watch_robust():
     t.change(zf, {2:'c1'}); at1 = t.commit()
     t.change(zf, {2:'c2'}); at2 = t.commit()
 
+    # file not yet opened on wcfs
+    wl = t.openwatch()
+    assert wl.sendReq(timeout(), b"watch %s @%s" % (h(zf._p_oid), h(at1))) == \
+        "error setup watch f<%s> @%s: " % (h(zf._p_oid), h(at1)) + \
+        "file not yet known to wcfs or is not a ZBigFile"
+    wl.close()
+
     # closeTX/bye cancels blocked pin handlers
+    f = t.open(zf)
+    f.assertBlk(2, 'c2')
+    f.assertCache([0,0,1])
+
     wl = t.openwatch()
     wg = sync.WorkGroup(timeout())
     def _(ctx):
         assert wl.sendReq(ctx, b"watch %s @%s" % (h(zf._p_oid), h(at1))) == \
-                "error setup watch f<%s> @%s: pin #%d @%s: context canceled" %   \
-                (h(zf._p_oid), h(at1), 2, h(at1))
+                "error setup watch f<%s> @%s: " % (h(zf._p_oid), h(at1)) + \
+                "pin #%d @%s: context canceled" % (2, h(at1))
     wg.go(_)
     def _(ctx):
         req = wl.recvReq(ctx)