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

KJTsanaktsidis · KJTsanaktsidis · commit a2f5680644fc · 2025-06-12T15:38:30.000-07:00
diff --git a/sdk/src/logs/batch_log_record_processor.cc b/sdk/src/logs/batch_log_record_processor.cc
@@ -135,6 +135,8 @@ 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
`@@ -135,6 +135,8 @@ bool BatchLogRecordProcessor::ForceFlush(std::chrono::microseconds timeout) noex`
`135`	`135`	`if (synchronization_data_->force_flush_pending_sequence.load(std::memory_order_acquire) >`
`136`	`136`	`synchronization_data_->force_flush_notified_sequence.load(std::memory_order_acquire))`
`137`	`137`	`{`
	`138`	`+ synchronization_data_->is_force_wakeup_background_worker.store(true,`
	`139`	`+ std::memory_order_release);`
`138`	`140`	`synchronization_data_->cv.notify_all();`
`139`	`141`	`}`
`140`	`142`