Commit 8c3fceaa authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent dacd44cc
...@@ -199,7 +199,6 @@ error _WatchLink::_serveRX(context::Context ctx) { ...@@ -199,7 +199,6 @@ error _WatchLink::_serveRX(context::Context ctx) {
log::Errorf("%s: .%lu: wcfs sent request on already used stream", v(wlink), pkt.stream); log::Errorf("%s: .%lu: wcfs sent request on already used stream", v(wlink), pkt.stream);
return ErrLinkDown; // XXX correct error return ErrLinkDown; // XXX correct error
} }
// XXX clear _accepted not to leak memory after reply is sent
wlink._accepted.insert(pkt.stream); wlink._accepted.insert(pkt.stream);
wlink._rxmu.unlock(); wlink._rxmu.unlock();
int _ = select({ int _ = select({
...@@ -235,7 +234,7 @@ error _WatchLink::recvReq(context::Context ctx, PinReq *prx) { ...@@ -235,7 +234,7 @@ error _WatchLink::recvReq(context::Context ctx, PinReq *prx) {
return E(_parsePinReq(prx, &pkt)); return E(_parsePinReq(prx, &pkt));
} }
// replyReq sends reply to client <- server request received by recvReq. // replyReq sends reply to client <- server request received via recvReq.
error _WatchLink::replyReq(context::Context ctx, const PinReq *req, const string& answer) { error _WatchLink::replyReq(context::Context ctx, const PinReq *req, const string& answer) {
_WatchLink& wlink = *this; _WatchLink& wlink = *this;
xerr::Contextf E("%s: replyReq .%d", v(wlink), req->stream); xerr::Contextf E("%s: replyReq .%d", v(wlink), req->stream);
......
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