fix: resolve race condition in ES buffer write

BoyChai · Jan 21, 2025 · eb70008 · eb70008
1 parent b148743
commit eb70008
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/output/elasticsearch.go b/output/elasticsearch.go
@@ -145,9 +145,9 @@ func (e *Elasticsearch) WriteRecord(record *evtx.EventRecord) error {
 	}
 
 	// 将数据加入缓存
+	bufferLock.Lock()
 	recordBuffer = append(recordBuffer, data)
 
-	bufferLock.Lock()
 	// 当缓存达到一定大小时，执行批量写入
 	if len(recordBuffer) >= bufferLimit {
 		go e.do()