format

Author: xy720

be/src/agent/utils.cpp

@@ -122,8 +122,7 @@ Status MasterServerClient::finish_task(const TFinishTaskRequest& request, TMaste
 Status MasterServerClient::report(const TReportRequest& request, TMasterResult* result) {
 #ifdef BE_TEST
     if (config::enable_debug_points &&
-                DebugPoints::instance()->is_enable(
-                        "MasterServerClient::report.fail")) [[unlikely]] {
+        DebugPoints::instance()->is_enable("MasterServerClient::report.fail")) [[unlikely]] {
         return Status::InternalError("debug report fail");
     }
     result->status.__set_status_code(TStatusCode::OK);

be/test/agent/task_worker_pool_test.cpp

@@ -150,7 +150,8 @@ TEST(TaskWorkerPoolTest, ReportTabletCallbackWithDebugPoint) {
                 "WorkPoolReportTablet.report_tablet_callback.skip"));
         report_tablet_callback(ExecEnv::GetInstance()->storage_engine().to_local(), &cluster_info);
         EXPECT_EQ(DorisMetrics::instance()->report_all_tablets_requests_skip->value(), 1);
-        EXPECT_EQ(DorisMetrics::instance()->tablet_report_continuous_failure_duration_s->value(), 0);
+        EXPECT_EQ(DorisMetrics::instance()->tablet_report_continuous_failure_duration_s->value(),
+                  0);
         // debug point report_tablet_callback.skip is removed
         DebugPoints::instance()->remove("WorkPoolReportTablet.report_tablet_callback.skip");
         EXPECT_FALSE(DebugPoints::instance()->is_enable(
@@ -162,18 +163,21 @@ TEST(TaskWorkerPoolTest, ReportTabletCallbackWithDebugPoint) {
         DebugPoints::instance()->add("MasterServerClient::report.fail");
         EXPECT_TRUE(DebugPoints::instance()->is_enable("MasterServerClient::report.fail"));
         report_tablet_callback(ExecEnv::GetInstance()->storage_engine().to_local(), &cluster_info);
-        EXPECT_GT(DorisMetrics::instance()->tablet_report_continuous_failure_duration_s->value(), 0);
+        EXPECT_GT(DorisMetrics::instance()->tablet_report_continuous_failure_duration_s->value(),
+                  0);
         std::this_thread::sleep_for(std::chrono::seconds(1));
         report_tablet_callback(ExecEnv::GetInstance()->storage_engine().to_local(), &cluster_info);
-        EXPECT_GT(DorisMetrics::instance()->tablet_report_continuous_failure_duration_s->value(), 0);
+        EXPECT_GT(DorisMetrics::instance()->tablet_report_continuous_failure_duration_s->value(),
+                  0);
         // debug point report.fail is removed
         DebugPoints::instance()->remove("MasterServerClient::report.fail");
         EXPECT_FALSE(DebugPoints::instance()->is_enable("MasterServerClient::report.fail"));
     }
 
     {
         report_tablet_callback(ExecEnv::GetInstance()->storage_engine().to_local(), &cluster_info);
-        EXPECT_EQ(DorisMetrics::instance()->tablet_report_continuous_failure_duration_s->value(), 0);
+        EXPECT_EQ(DorisMetrics::instance()->tablet_report_continuous_failure_duration_s->value(),
+                  0);
     }
 
     config::enable_debug_points = original_enable_debug_points;

be/test/cloud/cloud_task_worker_pool_test.cpp

@@ -43,7 +43,8 @@ TEST(CloudTaskWorkerPoolTest, ReportTabletCallbackWithDebugPoint) {
                 "WorkPoolCloudReportTablet.report_tablet_callback.skip"));
         report_tablet_callback(ExecEnv::GetInstance()->storage_engine().to_cloud(), &cluster_info);
         EXPECT_EQ(DorisMetrics::instance()->report_all_tablets_requests_skip->value(), 1);
-        EXPECT_EQ(DorisMetrics::instance()->tablet_report_continuous_failure_duration_s->value(), 0);
+        EXPECT_EQ(DorisMetrics::instance()->tablet_report_continuous_failure_duration_s->value(),
+                  0);
         // debug point report_tablet_callback.skip is removed
         DebugPoints::instance()->remove("WorkPoolCloudReportTablet.report_tablet_callback.skip");
         EXPECT_FALSE(DebugPoints::instance()->is_enable(
@@ -55,18 +56,21 @@ TEST(CloudTaskWorkerPoolTest, ReportTabletCallbackWithDebugPoint) {
         DebugPoints::instance()->add("MasterServerClient::report.fail");
         EXPECT_TRUE(DebugPoints::instance()->is_enable("MasterServerClient::report.fail"));
         report_tablet_callback(ExecEnv::GetInstance()->storage_engine().to_cloud(), &cluster_info);
-        EXPECT_GT(DorisMetrics::instance()->tablet_report_continuous_failure_duration_s->value(), 0);
+        EXPECT_GT(DorisMetrics::instance()->tablet_report_continuous_failure_duration_s->value(),
+                  0);
         std::this_thread::sleep_for(std::chrono::seconds(1));
         report_tablet_callback(ExecEnv::GetInstance()->storage_engine().to_cloud(), &cluster_info);
-        EXPECT_GT(DorisMetrics::instance()->tablet_report_continuous_failure_duration_s->value(), 0);
+        EXPECT_GT(DorisMetrics::instance()->tablet_report_continuous_failure_duration_s->value(),
+                  0);
         // debug point report.fail is removed
         DebugPoints::instance()->remove("MasterServerClient::report.fail");
         EXPECT_FALSE(DebugPoints::instance()->is_enable("MasterServerClient::report.fail"));
     }
 
     {
         report_tablet_callback(ExecEnv::GetInstance()->storage_engine().to_cloud(), &cluster_info);
-        EXPECT_EQ(DorisMetrics::instance()->tablet_report_continuous_failure_duration_s->value(), 0);
+        EXPECT_EQ(DorisMetrics::instance()->tablet_report_continuous_failure_duration_s->value(),
+                  0);
     }
 
     config::enable_debug_points = original_enable_debug_points;