summaryrefslogtreecommitdiff
path: root/src/lib/remote_j2k_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/remote_j2k_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/remote_j2k_encoder_thread.cc')
-rw-r--r--src/lib/remote_j2k_encoder_thread.cc12
1 files changed, 4 insertions, 8 deletions
diff --git a/src/lib/remote_j2k_encoder_thread.cc b/src/lib/remote_j2k_encoder_thread.cc
index 49d80953d..2abaf94ba 100644
--- a/src/lib/remote_j2k_encoder_thread.cc
+++ b/src/lib/remote_j2k_encoder_thread.cc
@@ -61,22 +61,18 @@ RemoteJ2KEncoderThread::encode(DCPVideo const& frame)
}
} catch (std::exception& e) {
LOG_ERROR(
- N_("Remote encode of %1 on %2 failed (%3); thread sleeping for %4s"),
+ N_("Remote encode of %1 on %2 failed (%3)"),
frame.index(), _server.host_name(), e.what(), _remote_backoff
);
} catch (...) {
LOG_ERROR(
- N_("Remote encode of %1 on %2 failed; thread sleeping for %4s"),
+ N_("Remote encode of %1 on %2 failed"),
frame.index(), _server.host_name(), _remote_backoff
);
}
- if (!encoded) {
- if (_remote_backoff < 60) {
- /* back off more */
- _remote_backoff += 10;
- }
- boost::this_thread::sleep(boost::posix_time::seconds(_remote_backoff));
+ if (!encoded && _remote_backoff < 60) {
+ _remote_backoff += 10;
}
return encoded;