.

wcfs/wcfs_test.py

@@ -729,10 +729,19 @@ class tWatchLink(wcfs.WatchLink):
         t.tdb = tdb
         tdb._wlinks.add(t)
 
+        # this tWatchLink currently watches the following files at particular state.
+        t._watching = {}    # {} foid -> tWatch
+
     def close(t):
         t.tdb._wlinks.remove(t)
         super(tWatchLink, t).close()
 
+        # disable all established watches
+        for w in t._watching.values():
+            w.at     = z64
+            w.pinned = {}
+        t._watching = {}
+
 # XXX just wrap req.at with tAt inpace
 """
     # recvReq is the same as WatchLink.recvReq but returns tSrvReq instead of PinReq.