refactor

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

Author: joker-star-l

plugins/out_doris/doris.c

@@ -43,15 +43,15 @@
 #include <fluent-bit/flb_callback.h>
 
 #ifdef FLB_SYSTEM_WINDOWS
-#include <winnt.h>
+#include <windows.h>
 #endif
 
 static inline void sync_fetch_and_add(size_t *dest, size_t value) {
 #ifdef FLB_SYSTEM_WINDOWS
     #ifdef _WIN64
-        InterlockedAdd64((LONG64 *) dest, (LONG64) value);
+        InterlockedAdd64((LONG64 volatile *) dest, (LONG64) value);
     #else
-        InterlockedAdd((LONG *) dest, (LONG) value);
+        InterlockedAdd((LONG volatile *) dest, (LONG) value);
     #endif
 #else
     __sync_fetch_and_add(dest, value);

plugins/out_doris/doris_conf.c

@@ -28,18 +28,18 @@
 #include "doris_conf.h"
 
 #ifdef FLB_SYSTEM_WINDOWS
-#include <winnt.h>
+#include <windows.h>
 #endif
 
-static inline void atomic_store(volatile int *dest, int val) {
+static inline void atomic_store(int *dest, int val) {
 #ifdef FLB_SYSTEM_WINDOWS
     InterlockedExchange((LONG volatile *) dest, (LONG) val);
 #else
     __atomic_store_n(dest, val, __ATOMIC_RELEASE);
 #endif
 }
 
-static inline int atomic_load(volatile int *dest) {
+static inline int atomic_load(int *dest) {
 #ifdef FLB_SYSTEM_WINDOWS
     return (int) InterlockedCompareExchange((LONG volatile *) dest, 0, 0);
 #else
@@ -166,7 +166,7 @@ struct flb_out_doris *flb_doris_conf_create(struct flb_output_instance *ins,
     }
 
     /* url: /api/{database}/{table}/_stream_load */
-    snprintf(ctx->uri, sizeof(ctx->uri) - 1, "/api/%s/%s/_stream_load", ctx->database, ctx->table);
+    snprintf(ctx->uri, sizeof(ctx->uri), "/api/%s/%s/_stream_load", ctx->database, ctx->table);
 
     /* label prefix */
     ctx->add_label = 1;