Commit 58b5b848 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent fe325da1
...@@ -557,7 +557,6 @@ type WatchLink struct { ...@@ -557,7 +557,6 @@ type WatchLink struct {
// established watchs. // established watchs.
// XXX in-progress - where? -> nowhere; here only established watches are added // XXX in-progress - where? -> nowhere; here only established watches are added
// XXX locking? // XXX locking?
// XXX -> watchTab?
fileTab map[zodb.Oid]*Watch // {} foid -> Watch fileTab map[zodb.Oid]*Watch // {} foid -> Watch
// IO // IO
...@@ -1273,7 +1272,7 @@ func (w *Watch) pin(ctx context.Context, blk int64, rev zodb.Tid) (err error) { ...@@ -1273,7 +1272,7 @@ func (w *Watch) pin(ctx context.Context, blk int64, rev zodb.Tid) (err error) {
return nil return nil
} }
// setupWatch sets up new Watch when client sends `watch <file> @<at>`. // setupWatch sets up a Watch when client sends `watch <file> @<at>`.
func (wlink *WatchLink) setupWatch(ctx context.Context, foid zodb.Oid, at zodb.Tid) (err error) { func (wlink *WatchLink) setupWatch(ctx context.Context, foid zodb.Oid, at zodb.Tid) (err error) {
defer xerr.Contextf(&err, "setup watch f<%s> @%s", foid, at) defer xerr.Contextf(&err, "setup watch f<%s> @%s", foid, at)
// XXX locking // XXX locking
......
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