Commit 350027d5 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 9c3e0f4b
......@@ -483,7 +483,7 @@ error WatchLink::_serveRX(IContext *ctx) { // XXX error -> where ?
if (stream == 0) { // control/fatal message from wcfs
// XXX print -> receive somewhere? XXX -> recvCtl ?
print("C: watch : rx fatal: %r" % msg);
printf("C: watch : rx fatal: %r\n" % msg);
wlink.fatalv.append(msg);
continue;
}
......@@ -499,6 +499,7 @@ error WatchLink::_serveRX(IContext *ctx) { // XXX error -> where ?
if (!ok) {
// wcfs sent reply on unexpected stream
// XXX log + dowmn.
printf("wcfs sent reply on unexpected stream\n");
continue;
}
int _ = select({
......@@ -513,8 +514,10 @@ error WatchLink::_serveRX(IContext *ctx) { // XXX error -> where ?
if (wlink._accepted.has(stream)) {
wlink._rxmu.unlock();
// XXX log + down
printf("wcfs sent request on already used stream\n");
continue;
}
// XXX clear _accepted not to leak memory after reply is sent?
wlink._accepted.insert(stream);
wlink._rxmu.unlock();
int _ = select({
......
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