fix pipeline w/ queueSize=1

Maybe not so useful, but shouldn't stall
2020-04-17 11:36:37 -07:00
parent 76a5861c5c
commit c32d1ae0e2
2 changed files with 7 additions and 4 deletions
@@ -222,8 +222,8 @@ struct SubscriptionImpl : public OperationBase, public Subscription
        }
        conn->enqueueTxBody(CMD_MONITOR);

-        log_debug_printf(io, "Server %s channel '%s' monitor INIT\n",
-                         conn->peerName.c_str(), chan->name.c_str());
+        log_debug_printf(io, "Server %s channel '%s' monitor INIT%s\n",
+                         conn->peerName.c_str(), chan->name.c_str(), pipeline?" pipeline":"");

        state = Creating;