Commit 3526986d authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent e9bc20ab
...@@ -1832,7 +1832,7 @@ func (wlink *WatchLink) _serve() (err error) { ...@@ -1832,7 +1832,7 @@ func (wlink *WatchLink) _serve() (err error) {
return err return err
} }
fmt.Printf("S: wlink %d: rx: %q\n", wlink.id, l) //fmt.Printf("S: wlink%d: rx: %q\n", wlink.id, l)
stream, msg, err := parseWatchFrame(l) stream, msg, err := parseWatchFrame(l)
if err != nil { if err != nil {
...@@ -1935,7 +1935,7 @@ func (wlink *WatchLink) send(ctx context.Context, stream uint64, msg string) err ...@@ -1935,7 +1935,7 @@ func (wlink *WatchLink) send(ctx context.Context, stream uint64, msg string) err
defer wlink.txMu.Unlock() defer wlink.txMu.Unlock()
pkt := []byte(fmt.Sprintf("%d %s\n", stream, msg)) pkt := []byte(fmt.Sprintf("%d %s\n", stream, msg))
fmt.Printf("S: wlink %d: tx: %q\n", wlink.id, pkt) //fmt.Printf("S: wlink%d: tx: %q\n", wlink.id, pkt)
_, err := wlink.sk.Write(ctx, pkt) _, err := wlink.sk.Write(ctx, pkt)
if err != nil { if err != nil {
return err return err
......
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