Commit 36cdebc4 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent d61e9df9
...@@ -663,8 +663,10 @@ tuple</*rxq*/chan<rxPkt>, error> WatchLink::_sendReq(IContext *ctx, const string ...@@ -663,8 +663,10 @@ tuple</*rxq*/chan<rxPkt>, error> WatchLink::_sendReq(IContext *ctx, const string
} }
// recvReq receives client <- server request. // recvReq receives client <- server request.
static error _parsePinReq(PinReq *pin, const rxPkt *pkt);
error WatchLink::recvReq(IContext *ctx, PinReq *prx) { error WatchLink::recvReq(IContext *ctx, PinReq *prx) {
WatchLink& wlink = *this; WatchLink& wlink = *this;
// XXX err ctx?
rxPkt pkt; rxPkt pkt;
int _ = select({ int _ = select({
...@@ -681,12 +683,11 @@ error WatchLink::recvReq(IContext *ctx, PinReq *prx) { ...@@ -681,12 +683,11 @@ error WatchLink::recvReq(IContext *ctx, PinReq *prx) {
#endif #endif
pkt.to_string(); pkt.to_string();
err = _parsePinReq(prx, &pkt); return _parsePinReq(prx, &pkt);
return err;
} }
// _parsePinReq parses message into PinReq according to wcfs invalidation protocol. // _parsePinReq parses message into PinReq according to wcfs invalidation protocol.
error _parsePinReq(PinReq *pin, const rxPkt *pkt) { static error _parsePinReq(PinReq *pin, const rxPkt *pkt) {
// XXX err ctx "bad pin" // XXX err ctx "bad pin"
pin->stream = pkt->stream; pin->stream = pkt->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