Commit b1c009f9 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 39bd6496
...@@ -89,6 +89,8 @@ class Conn(object): ...@@ -89,6 +89,8 @@ class Conn(object):
# WatchLink represents /head/watch link opened on wcfs. # WatchLink represents /head/watch link opened on wcfs.
# #
# .sendReq()/.recvReq() provides raw IO in terms of wcfs invalidation protocol messages. # .sendReq()/.recvReq() provides raw IO in terms of wcfs invalidation protocol messages.
#
# XXX safe/not-safe to access from multiple threads?
class WatchLink(object): class WatchLink(object):
def __init__(wlink, wc): def __init__(wlink, wc):
...@@ -125,6 +127,7 @@ class WatchLink(object): ...@@ -125,6 +127,7 @@ class WatchLink(object):
wlink._serveWG.go(wlink._serveRX) wlink._serveWG.go(wlink._serveRX)
# this tWatchLink currently watches the following files at particular state. # this tWatchLink currently watches the following files at particular state.
# XXX back -> tWatchLink ?
wlink._watching = {} # {} foid -> tWatch wlink._watching = {} # {} foid -> tWatch
# ---- WatchLink message IO ---- # ---- WatchLink message IO ----
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment