fix format

Signed-off-by: ohadvano <[email protected]>
ohadvano · Feb 26, 2024 · 1f6e6b4 · 1f6e6b4
1 parent 7b4d309
commit 1f6e6b4
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 9 deletions.
diff --git a/test/common/tcp/async_tcp_client_impl_test.cc b/test/common/tcp/async_tcp_client_impl_test.cc
@@ -273,7 +273,7 @@ TEST_F(AsyncTcpClientImplTest, ReconnectAfterClientDisconnected) {
   expectCreateConnection();
 
   EXPECT_EQ(2UL, cluster_manager_.thread_local_cluster_.cluster_.info_->traffic_stats_
-                    ->upstream_cx_total_.value());
+                     ->upstream_cx_total_.value());
 }
 
 } // namespace Tcp

diff --git a/test/integration/filters/test_network_async_tcp_filter.cc b/test/integration/filters/test_network_async_tcp_filter.cc
@@ -129,8 +129,8 @@ class TestNetworkAsyncTcpFilter : public Network::ReadFilter {
       ENVOY_LOG_MISC(debug, "tcp client test filter upstream callback onEvent: {}",
                      static_cast<int>(event));
 
-      if (event == Network::ConnectionEvent::RemoteClose
-          || event == Network::ConnectionEvent::LocalClose) {
+      if (event == Network::ConnectionEvent::RemoteClose ||
+          event == Network::ConnectionEvent::LocalClose) {
         parent_.require_reconnect_ = true;
       }
 

diff --git a/test/integration/tcp_async_client_integration_test.cc b/test/integration/tcp_async_client_integration_test.cc
@@ -125,9 +125,8 @@ TEST_P(TcpAsyncClientIntegrationTest, Reconnect) {
   test_server_->waitForGaugeEq("cluster.cluster_0.upstream_cx_active", 1);
   FakeRawConnectionPtr fake_upstream_connection;
   ASSERT_TRUE(fake_upstreams_[0]->waitForRawConnection(fake_upstream_connection));
-  ASSERT_TRUE(fake_upstream_connection->waitForData([&](const std::string& data) -> bool {
-    return data == "hello1";
-  }));
+  ASSERT_TRUE(fake_upstream_connection->waitForData(
+      [&](const std::string& data) -> bool { return data == "hello1"; }));
   ASSERT_TRUE(fake_upstream_connection->close());
   test_server_->waitForGaugeEq("cluster.cluster_0.upstream_cx_active", 0);
 
@@ -137,9 +136,8 @@ TEST_P(TcpAsyncClientIntegrationTest, Reconnect) {
   test_server_->waitForGaugeEq("cluster.cluster_0.upstream_cx_active", 1);
   FakeRawConnectionPtr fake_upstream_connection2;
   ASSERT_TRUE(fake_upstreams_[0]->waitForRawConnection(fake_upstream_connection2));
-  ASSERT_TRUE(fake_upstream_connection2->waitForData([&](const std::string& data) -> bool {
-    return data == "hello2";
-  }));
+  ASSERT_TRUE(fake_upstream_connection2->waitForData(
+      [&](const std::string& data) -> bool { return data == "hello2"; }));
 
   tcp_client->close();
   test_server_->waitForGaugeEq("cluster.cluster_0.upstream_cx_active", 0);