diff options
| author | Carl Hetherington <cth@carlh.net> | 2025-03-20 00:31:22 +0100 |
|---|---|---|
| committer | Carl Hetherington <cth@carlh.net> | 2025-03-22 13:29:58 +0100 |
| commit | e32e6654b983bf4928b6f27a627b1e6305188cf6 (patch) | |
| tree | 28da2444bfe057fce97522df3eb7fa136eebf901 /src/lib/remote_j2k_encoder_thread.cc | |
| parent | 650f919fdda3632262ddbf98d1a37a5e98eaedda (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.cc | 12 |
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; |
