Commit 868f88cd authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 9052d96a
...@@ -668,18 +668,16 @@ error WatchLink::recvReq(IContext *ctx, PinReq *prx) { ...@@ -668,18 +668,16 @@ error WatchLink::recvReq(IContext *ctx, PinReq *prx) {
// XXX err ctx? // XXX err ctx?
rxPkt pkt; rxPkt pkt;
bool ok;
int _ = select({ int _ = select({
ctx->done().recvs(), // 0 ctx->done().recvs(), // 0
wlink._acceptq.recvs(&pkt), // 1 wlink._acceptq.recvs(&pkt, &ok), // 1
}); });
if (_ == 0) if (_ == 0)
return ctx->err(); return ctx->err();
// XXX recheck _serveRX vs EOF signalling if (!ok)
#if 0 return io::EOF_;
if rx is None:
return rx
#endif
pkt.to_string(); pkt.to_string();
return _parsePinReq(prx, &pkt); return _parsePinReq(prx, &pkt);
......
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