merged https://github.com/open-telemetry/opentelemetry-cpp/pull/3448/files

malkia · malkia · commit 9af3ba3ff55a · 2025-06-10T09:58:33.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,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
`@@ -135,6 +135,7 @@ 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, std::memory_order_release);`
`138`	`139`	`synchronization_data_->cv.notify_all();`
`139`	`140`	`}`
`140`	`141`