.

wcfs/wcfs_test.py

@@ -1356,6 +1356,28 @@ def test_wcfs_watch_robust():
             " head/at (@%s); …" % (h(zf._p_oid), h(atpast), h(t.head)))
     wl.close()
 
+# verify that watch file @at when it did not existed -> error
+@xfail  # check that file exists @at
+@func
+def test_wcfs_watch_before_create():
+    t = tDB(); zf = t.zfile
+    defer(t.close)
+
+    at1 = t.commit(zf, {2:'c1'})
+    zf2 = t.root['zfile2'] = ZBigFile(blksize)  # zf2 created @at2
+    at2 = t.commit()
+    at3 = t.commit(zf2, {1:'β3'})
+
+    # force wcfs to access/know zf2
+    f2 = t.open(zf2)
+    f2.assertData(['','β3'])
+
+    wl = t.openwatch()
+    assert wl.sendReq(timeout(), b"watch %s @%s" % (h(zf2._p_oid), h(at1))) == \
+        "error setup watch f<%s> @%s: " % (h(zf2._p_oid), h(at1)) + \
+        "file does not exist at that database state"
+    wl.close()
+
 
 # verify that wcfs kills slow/faulty client who does not reply to pin in time.
 @xfail  # protection against faulty/slow clients