fix: BatchLogRecordProcessor::ForceFlush is not waking up bg thread

KJTsanaktsidis · KJTsanaktsidis · commit 4f4fe70be6b4 · 2025-05-29T01:22:09.000-07:00
diff --git a/sdk/src/logs/batch_log_record_processor.cc b/sdk/src/logs/batch_log_record_processor.cc
@@ -136,6 +136,7 @@ bool BatchLogRecordProcessor::ForceFlush(std::chrono::microseconds timeout) noex
     if (synchronization_data_->force_flush_pending_sequence.load(std::memory_order_acquire) >
         synchronization_data_->force_flush_notified_sequence.load(std::memory_order_acquire))
     {
+      synchronization_data_->is_force_wakeup_background_worker.store(true, std::memory_order_release);
       synchronization_data_->cv.notify_all();
     }
 

Original file line number	Diff line number	Diff line change
`@@ -136,6 +136,7 @@ bool BatchLogRecordProcessor::ForceFlush(std::chrono::microseconds timeout) noex`
`136`	`136`	`if (synchronization_data_->force_flush_pending_sequence.load(std::memory_order_acquire) >`
`137`	`137`	`synchronization_data_->force_flush_notified_sequence.load(std::memory_order_acquire))`
`138`	`138`	`{`
	`139`	`+ synchronization_data_->is_force_wakeup_background_worker.store(true, std::memory_order_release);`
`139`	`140`	`synchronization_data_->cv.notify_all();`
`140`	`141`	`}`
`141`	`142`