From 350027d53050fea0d494bfe684c6cc647f84f0a3 Mon Sep 17 00:00:00 2001
From: Kirill Smelkov <kirr@nexedi.com>
Date: Mon, 28 Oct 2019 17:55:14 +0300
Subject: [PATCH] .

---
 wcfs/internal/wcfs_virtmem.cpp | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/wcfs/internal/wcfs_virtmem.cpp b/wcfs/internal/wcfs_virtmem.cpp
index 99d4c76..00a4fe0 100644
--- a/wcfs/internal/wcfs_virtmem.cpp
+++ b/wcfs/internal/wcfs_virtmem.cpp
@@ -483,7 +483,7 @@ error WatchLink::_serveRX(IContext *ctx) {    // XXX error -> where ?
 
         if (stream == 0) { // control/fatal message from wcfs
             // XXX print -> receive somewhere?   XXX -> recvCtl ?
-            print("C: watch  : rx fatal: %r" % msg);
+            printf("C: watch  : rx fatal: %r\n" % msg);
             wlink.fatalv.append(msg);
             continue;
         }
@@ -499,6 +499,7 @@ error WatchLink::_serveRX(IContext *ctx) {    // XXX error -> where ?
             if (!ok) {
                 // wcfs sent reply on unexpected stream
                 // XXX log + dowmn.
+                printf("wcfs sent reply on unexpected stream\n");
                 continue;
             }
             int _ = select({
@@ -513,8 +514,10 @@ error WatchLink::_serveRX(IContext *ctx) {    // XXX error -> where ?
                 if (wlink._accepted.has(stream)) {
                     wlink._rxmu.unlock();
                     // XXX log + down
+                    printf("wcfs sent request on already used stream\n");
                     continue;
                 }
+                // XXX clear _accepted not to leak memory after reply is sent?
                 wlink._accepted.insert(stream);
             wlink._rxmu.unlock();
             int _ = select({
-- 
2.30.9