.

wcfs/internal/wcfs_virtmem.cpp

@@ -289,17 +289,18 @@ void Conn::_pinner(IContext *ctx) {
 
     // XXX panic/exc -> log.CRITICAL
 
+    PinReq req;
+    error  err;
+
     while (1) {
-        // XXX -> recv inplace into on-stack req ?
+        err = wconn._wlink->recvReq(ctx, &req);
+        if (err != nil) {
             // XXX -> err, handle EOF, abort on *
-        PinReq *req = wconn._wlink->recvReq(ctx);
-        if (req == NULL)
-            return  // XXX ok? (EOF - when wcfs closes wlink)
+            return; // XXX ok? (EOF - when wcfs closes wlink)
+        }
 
         // we received request to pin/unpin file block. handle it
-        wconn._pin1(req);
-
-        // XXX free req?
+        wconn._pin1(&req);
     }
 }
 
@@ -666,20 +667,21 @@ error WatchLink::recvReq(IContext *ctx, PinReq *rx) {
     WatchLink& wlink = *this;
 
     rxPkt pkt;
-    _ = select(
+    int _ = select({
         ctx->done().recvs(),            // 0
         wlink._acceptq.recvs(&pkt),     // 1
-    )
+    });
     if (_ == 0)
-        return ctx.err();
+        return ctx->err();
 
     rx = _rx
     if rx is None:  // XXX recheck _serveRX vs EOF signalling
         return rx
 
     rx.stream = pkt.stream;
-    pkt.to_sting();
+    pkt.to_string();
     stream, msg = rx
+    // XXX -> _parsePinReq
     return PinReq(wlink, stream, msg)
 }