refactor: atomic add

Signed-off-by: composer <[email protected]>

Author: joker-star-l

plugins/out_doris/doris.c

@@ -46,6 +46,14 @@
 #include <winnt.h>
 #endif
 
+static inline void sync_fetch_and_add(size_t *dest, size_t value) {
+#ifdef FLB_SYSTEM_WINDOWS
+    InterlockedAdd(dest, value);
+#else
+    __sync_fetch_and_add(dest, value);
+#endif
+}
+
 static int cb_doris_init(struct flb_output_instance *ins,
                          struct flb_config *config, void *data)
 {
@@ -317,11 +325,7 @@ static void cb_doris_flush(struct flb_event_chunk *event_chunk,
 
     if (ret != FLB_OK) {
         if (ret == FLB_ERROR && ctx->log_progress_interval > 0) {
-#ifdef FLB_SYSTEM_WINDOWS
-            InterlockedAdd(&ctx->reporter->failed_rows, event_chunk->total_events);
-#else
-            __sync_fetch_and_add(&ctx->reporter->failed_rows, event_chunk->total_events);
-#endif
+            sync_fetch_and_add(&ctx->reporter->failed_rows, event_chunk->total_events);
         }
         FLB_OUTPUT_RETURN(ret);
     }
@@ -337,19 +341,10 @@ static void cb_doris_flush(struct flb_event_chunk *event_chunk,
     flb_sds_destroy(out_body);
 
     if (ret == FLB_OK && ctx->log_progress_interval > 0) {
-#ifdef FLB_SYSTEM_WINDOWS
-        InterlockedAdd(&ctx->reporter->total_bytes, out_size);
-        InterlockedAdd(&ctx->reporter->total_rows, event_chunk->total_events);
-#else
-        __sync_fetch_and_add(&ctx->reporter->total_bytes, out_size);
-        __sync_fetch_and_add(&ctx->reporter->total_rows, event_chunk->total_events);
-#endif
+        sync_fetch_and_add(&ctx->reporter->total_bytes, out_size);
+        sync_fetch_and_add(&ctx->reporter->total_rows, event_chunk->total_events);
     } else if (ret == FLB_ERROR && ctx->log_progress_interval > 0) {
-#ifdef FLB_SYSTEM_WINDOWS
-        InterlockedAdd(&ctx->reporter->failed_rows, event_chunk->total_events);
-#else
-        __sync_fetch_and_add(&ctx->reporter->failed_rows, event_chunk->total_events);
-#endif
+        sync_fetch_and_add(&ctx->reporter->failed_rows, event_chunk->total_events);
     }
     FLB_OUTPUT_RETURN(ret);
 }