Commit 66dc4f18 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 487daf51
......@@ -1492,17 +1492,17 @@ func (wlink *WatchLink) _serveRX() (err error) {
}
// client-initiated watch request
err = wlink.handleSetupWatch(stream, msg)
err = wlink.handleWatch(stream, msg)
if err != nil {
panic(err) // XXX
}
}
}
// handleSetupWatch handles watch request from client.
// handleWatch handles watch request from client.
//
// returned error comes without full error prefix.
func (wlink *WatchLink) handleSetupWatch(stream uint64, msg string) (err error) {
func (wlink *WatchLink) handleWatch(stream uint64, msg string) (err error) {
defer xerr.Contextf(&err, "%d", stream)
foid, at, err := parseWatch(msg)
......
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