d_nbActiveChannels

Signed-off-by: Emelia Lei <[email protected]>

Author: emelialei88

src/groups/mqb/mqbnet/mqbnet_tcpsessionfactory.cpp

@@ -643,8 +643,6 @@ void TCPSessionFactory::initialConnectionComplete(
         inserted = d_channels.insert(toInsert);
         info     = inserted.first->second;
 
-        ++d_nbActiveChannels;
-
         if (info->d_monitor.isHearbeatEnabled() &&
             d_heartbeatSchedulerActive) {
             // Enable/Disable heartbeating under the lock
@@ -776,6 +774,9 @@ void TCPSessionFactory::channelStateCallback(
                     bmqsys::Time::highResolutionTimer();
             }  // close mutex lock guard // UNLOCK
 
+            // Keep track of active channels, for logging purposes
+            ++d_nbActiveChannels;
+
             handleInitialConnection(channel, context);
         }
     } break;
@@ -832,8 +833,6 @@ void TCPSessionFactory::onClose(const InitialConnectionContext* context_p,
             channelInfo = it->second;
             d_channels.erase(it);
 
-            --d_nbActiveChannels;
-
             // Synchronously remove from heartbeat monitored channels
             if (channelInfo->d_monitor.isHearbeatEnabled() &&
                 d_heartbeatSchedulerActive) {