.

wcfs/wcfs.go

@@ -1538,6 +1538,13 @@ func (wlink *WatchLink) _serve() (err error) {
 			err = err2
 		}
 
+		// unregister all watches created on this wlink
+		// XXX locking
+		for _, w := range wlink.byfile {
+			delete(w.file.watches, w)
+		}
+		wlink.byfile = nil
+
 		// write to peer if it was logical error on client side
 		// then .sk.tx to wakeup rx on client side
 		if err != nil {