client fix Channel reconnect

src/client.cpp

@@ -94,6 +94,17 @@ void Channel::createOperations()
     }
 }
 
+void Channel::disconnect(const std::shared_ptr<Channel>& self)
+{
+    self->state = Channel::Searching;
+    self->sid = 0xdeadbeef; // spoil
+    context->searchBuckets[context->currentBucket].push_back(self);
+
+    log_debug_printf(io, "Server %s detach channel '%s' to re-search\n",
+                     conn ? conn->peerName.c_str() : "<disconnected>",
+                     self->name.c_str());
+
+}
 
 OperationBase::OperationBase(operation_t op, const std::shared_ptr<Channel>& chan)
     :Operation(op)

src/clientconn.cpp

@@ -128,12 +128,21 @@ void Connection::cleanup()
         if(!chan)
             continue;
 
-        chan->state = Channel::Searching;
-        chan->sid = 0xdeadbeef; // spoil
-        self = std::move(chan->conn);
-        context->searchBuckets[context->currentBucket].push_back(chan);
+        chan->disconnect(chan);
+    }
+    for(auto& pair : chanBySID) {
+        auto chan = pair.second.lock();
+        if(!chan)
+            continue;
 
-        log_debug_printf(io, "Server %s detach channel '%s' to re-search\n", peerName.c_str(), chan->name.c_str());
+        chan->disconnect(chan);
+    }
+    for(auto& pair : creatingByCID) {
+        auto chan = pair.second.lock();
+        if(!chan)
+            continue;
+
+        chan->disconnect(chan);
     }
 
     auto ops = std::move(opByIOID);

src/clientimpl.h

@@ -53,11 +53,11 @@ struct Connection : public ConnBase, public std::enable_shared_from_this<Connect
 
     bool ready = false;
 
-    // channels to be created on this Connection
+    // channels to be created on this Connection (in state==Connecting
     std::list<std::weak_ptr<Channel>> pending;
 
-    std::map<uint32_t, std::weak_ptr<Channel>> creatingByCID,
-                                               chanBySID;
+    std::map<uint32_t, std::weak_ptr<Channel>> creatingByCID, // in state==Creating
+                                               chanBySID;     // in state==Active
 
     // entries always have matching entry in a Channel::opByIOID
     std::map<uint32_t, RequestInfo> opByIOID;
@@ -130,6 +130,7 @@ struct Channel {
     ~Channel();
 
     void createOperations();
+    void disconnect(const std::shared_ptr<Channel>& self);
 
     static
     std::shared_ptr<Channel> build(const std::shared_ptr<Context::Pvt>& context, const std::string &name);