src/lib/j2k_sync_encoder_thread.cc

   1 #include "dcp_video.h"
   2 #include "dcpomatic_log.h"
   3 #include "j2k_encoder.h"
   4 #include "j2k_sync_encoder_thread.h"
   5 #include "scope_guard.h"
   6
   7
   8 J2KSyncEncoderThread::J2KSyncEncoderThread(J2KEncoder& encoder)
   9         : J2KEncoderThread(encoder)
  10 {
  11
  12 }
  13
  14
  15 void
  16 J2KSyncEncoderThread::run()
  17 try
  18 {
  19         log_thread_start();
  20
  21         while (true) {
  22                 LOG_TIMING("encoder-sleep thread=%1", thread_id());
  23                 auto frame = _encoder.pop();
  24
  25                 ScopeGuard frame_guard([this, &frame]() {
  26                         boost::this_thread::disable_interruption dis;
  27                         _encoder.retry(frame);
  28                 });
  29
  30                 LOG_TIMING("encoder-pop thread=%1 frame=%2 eyes=%3", thread_id(), frame.index(), static_cast<int>(frame.eyes()));
  31
  32                 auto encoded = encode(frame);
  33
  34                 if (encoded) {
  35                         boost::this_thread::disable_interruption dis;
  36                         frame_guard.cancel();
  37                         _encoder.write(encoded, frame.index(), frame.eyes());
  38                 }
  39         }
  40 } catch (boost::thread_interrupted& e) {
  41 } catch (...) {
  42         store_current();
  43 }
  44