format

Author: zhanglistar

lib/ConsumerImpl.cc

@@ -670,7 +670,8 @@ void ConsumerImpl::messageReceived(const ClientConnectionPtr& cnx, const proto::
         // Trigger message listener callback in a separate thread
         if (listenerExecutor_) {
             while (numOfMessageReceived--) {
-                listenerExecutor_->postWork(std::bind(&ConsumerImpl::internalListener, get_shared_this_ptr()));
+                listenerExecutor_->postWork(
+                    std::bind(&ConsumerImpl::internalListener, get_shared_this_ptr()));
             }
         }
     }

tests/ReaderTest.cc

@@ -964,8 +964,7 @@ TEST(ReaderTest, testReaderWithZeroMessageListenerThreads) {
     clientConf.setMessageListenerThreads(0);
     Client client(serviceUrl, clientConf);
 
-    const std::string topicName =
-        "testReaderWithZeroMessageListenerThreads-" + std::to_string(time(nullptr));
+    const std::string topicName = "testReaderWithZeroMessageListenerThreads-" + std::to_string(time(nullptr));
 
     Producer producer;
     ASSERT_EQ(ResultOk, client.createProducer(topicName, producer));

tests/RetryableOperationCacheTest.cc

@@ -89,7 +89,8 @@ TEST(ExecutorServiceProviderTest, ZeroThreadsReturnsValidExecutor) {
     ExecutorServiceProviderPtr provider = std::make_shared<ExecutorServiceProvider>(0);
     for (int i = 0; i < 3; i++) {
         ExecutorServicePtr executor = provider->get();
-        ASSERT_NE(executor, nullptr) << "get() must not return null when created with 0 threads (clamped to 1)";
+        ASSERT_NE(executor, nullptr)
+            << "get() must not return null when created with 0 threads (clamped to 1)";
     }
     provider->close();
 }