no log

Author: zhanglistar

lib/BatchMessageContainer.cc

@@ -30,11 +30,7 @@ namespace pulsar {
 BatchMessageContainer::BatchMessageContainer(const ProducerImpl& producer)
     : BatchMessageContainerBase(producer) {}
 
-BatchMessageContainer::~BatchMessageContainer() {
-    LOG_DEBUG(*this << " destructed");
-    LOG_DEBUG("[numberOfBatchesSent = " << numberOfBatchesSent_
-                                        << "] [averageBatchSize_ = " << averageBatchSize_ << "]");
-}
+BatchMessageContainer::~BatchMessageContainer() {}
 
 bool BatchMessageContainer::add(const Message& msg, const SendCallback& callback) {
     LOG_DEBUG("Before add: " << *this << " [message = " << msg << "]");

lib/BatchMessageKeyBasedContainer.cc

@@ -40,11 +40,7 @@ inline std::string getKey(const Message& msg) {
 BatchMessageKeyBasedContainer::BatchMessageKeyBasedContainer(const ProducerImpl& producer)
     : BatchMessageContainerBase(producer) {}
 
-BatchMessageKeyBasedContainer::~BatchMessageKeyBasedContainer() {
-    LOG_DEBUG(*this << " destructed");
-    LOG_INFO("[numberOfBatchesSent = " << numberOfBatchesSent_
-                                       << "] [averageBatchSize_ = " << averageBatchSize_ << "]");
-}
+BatchMessageKeyBasedContainer::~BatchMessageKeyBasedContainer() {}
 
 bool BatchMessageKeyBasedContainer::isFirstMessageToAdd(const Message& msg) const {
     auto it = batches_.find(getKey(msg));

lib/ConsumerImpl.cc

@@ -180,18 +180,14 @@ ConsumerImpl::ConsumerImpl(const ClientImplPtr& client, const std::string& topic
 }
 
 ConsumerImpl::~ConsumerImpl() {
-    LOG_DEBUG(consumerStr_ << "~ConsumerImpl");
+    auto client = client_.lock();
     if (state_ == Ready) {
         // this could happen at least in this condition:
         //      consumer seek, caused reconnection, if consumer close happened before connection ready,
         //      then consumer will not send closeConsumer to Broker side, and caused a leak of consumer in
         //      broker.
-        auto client = client_.lock();
         if (client) {
             LOG_WARN(consumerStr_ << "Destroyed consumer which was not properly closed");
-        } else {
-            LOG_DEBUG(consumerStr_
-                      << "Destroyed consumer which was not properly closed (client already destroyed)");
         }
 
         ClientConnectionPtr cnx = getCnx().lock();
@@ -200,12 +196,12 @@ ConsumerImpl::~ConsumerImpl() {
             cnx->sendRequestWithId(Commands::newCloseConsumer(consumerId_, requestId), requestId,
                                    "CLOSE_CONSUMER");
             cnx->removeConsumer(consumerId_);
-            LOG_DEBUG(consumerStr_ << "Closed consumer for race condition: " << consumerId_);
+            if (client) {
+                LOG_DEBUG(consumerStr_ << "Closed consumer for race condition: " << consumerId_);
+            }
         } else {
             if (client) {
                 LOG_WARN(consumerStr_ << "Client is destroyed and cannot send the CloseConsumer command");
-            } else {
-                LOG_DEBUG(consumerStr_ << "Client is destroyed and cannot send the CloseConsumer command");
             }
         }
     }

lib/ProducerImpl.cc

@@ -114,16 +114,12 @@ ProducerImpl::ProducerImpl(const ClientImplPtr& client, const TopicName& topicNa
 }
 
 ProducerImpl::~ProducerImpl() {
-    LOG_DEBUG(producerStr_ << "~ProducerImpl");
+    auto client = client_.lock();
     internalShutdown();
-    printStats();
-    if (state_ == Ready || state_ == Pending) {
-        auto client = client_.lock();
-        if (client) {
+    if (client) {
+        printStats();
+        if (state_ == Ready || state_ == Pending) {
             LOG_WARN(producerStr_ << "Destroyed producer which was not properly closed");
-        } else {
-            LOG_DEBUG(producerStr_
-                      << "Destroyed producer which was not properly closed (client already destroyed)");
         }
     }
 }