Commit 9c9597bd authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent 003f8c75
......@@ -275,6 +275,8 @@ pair</*reply*/string, error> _WatchLink::sendReq(context::Context ctx, const str
if (err != nil)
return make_pair("", E(err));
// XXX new err ctx wlink: sendReq .%d: recvReply
int _ = select({
ctx->done().recvs(), // 0
rxq.recvs(&rx, &ok), // 1
......@@ -283,7 +285,7 @@ pair</*reply*/string, error> _WatchLink::sendReq(context::Context ctx, const str
return make_pair("", E(ctx->err()));
if (!ok)
return make_pair("", E(io::ErrUnexpectedEOF)); // XXX error ok?
return make_pair("", E(io::ErrUnexpectedEOF));
string reply = rx.to_string();
return make_pair(reply, nil);
}
......
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