opt

Author: xy720

be/src/agent/task_worker_pool.cpp

@@ -1192,10 +1192,9 @@ void report_tablet_callback(StorageEngine& engine, const ClusterInfo* cluster_in
         // receives this report, it is possible to delete the new tablet.
         LOG(WARNING) << "report version " << report_version << " change to " << s_report_version;
         DorisMetrics::instance()->report_all_tablets_requests_skip->increment(1);
+        int64_t expected = 0;
         int64_t current_time = time(nullptr);
-        if (s_tablet_report_failure_start_time.load() == 0) {
-            s_tablet_report_failure_start_time.store(current_time);
-        }
+        s_tablet_report_failure_start_time.compare_exchange_strong(expected, current_time);
         DorisMetrics::instance()->tablet_report_continuous_failure_duration_s->set_value(
                 current_time - s_tablet_report_failure_start_time);
         return;
@@ -1237,10 +1236,9 @@ void report_tablet_callback(StorageEngine& engine, const ClusterInfo* cluster_in
     report_tablet_total << 1;
     if (!succ) [[unlikely]] {
         report_tablet_failed << 1;
+        int64_t expected = 0;
         int64_t current_time = time(nullptr);
-        if (s_tablet_report_failure_start_time.load() == 0) {
-            s_tablet_report_failure_start_time.store(current_time);
-        }
+        s_tablet_report_failure_start_time.compare_exchange_strong(expected, current_time);
         DorisMetrics::instance()->tablet_report_continuous_failure_duration_s->set_value(
                 current_time - s_tablet_report_failure_start_time);
     } else {