summaryrefslogtreecommitdiff
path: root/src/lib/j2k_sync_encoder_thread.cc
diff options
context:
space:
mode:
authorCarl Hetherington <cth@carlh.net>2025-03-20 00:31:22 +0100
committerCarl Hetherington <cth@carlh.net>2025-03-22 13:29:58 +0100
commite32e6654b983bf4928b6f27a627b1e6305188cf6 (patch)
tree28da2444bfe057fce97522df3eb7fa136eebf901 /src/lib/j2k_sync_encoder_thread.cc
parent650f919fdda3632262ddbf98d1a37a5e98eaedda (diff)
Move remote backoff sleep to before we pop a frame from the queue.
Otherwise in the case of failure it can take a while for the frame to become available again for a functioning thread to encode.
Diffstat (limited to 'src/lib/j2k_sync_encoder_thread.cc')
-rw-r--r--src/lib/j2k_sync_encoder_thread.cc7
1 files changed, 7 insertions, 0 deletions
diff --git a/src/lib/j2k_sync_encoder_thread.cc b/src/lib/j2k_sync_encoder_thread.cc
index ef6834f60..158c12b11 100644
--- a/src/lib/j2k_sync_encoder_thread.cc
+++ b/src/lib/j2k_sync_encoder_thread.cc
@@ -25,6 +25,8 @@
#include "j2k_sync_encoder_thread.h"
#include <dcp/scope_guard.h>
+#include "i18n.h"
+
J2KSyncEncoderThread::J2KSyncEncoderThread(J2KEncoder& encoder)
: J2KEncoderThread(encoder)
@@ -40,6 +42,11 @@ try
log_thread_start();
while (true) {
+ if (auto wait = backoff()) {
+ LOG_ERROR(N_("Encoder thread sleeping (due to backoff) for %1s"), wait);
+ boost::this_thread::sleep(boost::posix_time::seconds(wait));
+ }
+
LOG_TIMING("encoder-sleep thread=%1", thread_id());
auto frame = _encoder.pop();