diff options
| author | Carl Hetherington <cth@carlh.net> | 2012-10-01 22:40:09 +0100 |
|---|---|---|
| committer | Carl Hetherington <cth@carlh.net> | 2012-10-01 22:40:09 +0100 |
| commit | e1e7827d75df6ea11b6bfd2aabd3eb3fb1f2e701 (patch) | |
| tree | 2770556b7584905023f5ff7c7de2028c1b9c279f /src/lib/j2k_wav_encoder.cc | |
| parent | 11307dfbddc463592f65cb0d24131bf5206c3617 (diff) | |
Some more debug logging.
Diffstat (limited to 'src/lib/j2k_wav_encoder.cc')
| -rw-r--r-- | src/lib/j2k_wav_encoder.cc | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/src/lib/j2k_wav_encoder.cc b/src/lib/j2k_wav_encoder.cc index 9ae01c774..4deedc388 100644 --- a/src/lib/j2k_wav_encoder.cc +++ b/src/lib/j2k_wav_encoder.cc @@ -108,7 +108,9 @@ J2KWAVEncoder::process_video (shared_ptr<Image> yuv, int frame) /* Wait until the queue has gone down a bit */ while (_queue.size() >= _worker_threads.size() * 2 && !_process_end) { + _log->microsecond_log ("Decoder sleeps", Log::TIMING); _worker_condition.wait (lock); + _log->microsecond_log ("Decoder wakes", Log::TIMING); } if (_process_end) { @@ -118,6 +120,7 @@ J2KWAVEncoder::process_video (shared_ptr<Image> yuv, int frame) /* Only do the processing if we don't already have a file for this frame */ if (!boost::filesystem::exists (_opt->frame_out_path (frame, false))) { pair<string, string> const s = Filter::ffmpeg_strings (_fs->filters); + _log->microsecond_log ("Adding to queue of " + boost::lexical_cast<string> (_queue.size ()), Log::TIMING); _queue.push_back (boost::shared_ptr<DCPVideoFrame> ( new DCPVideoFrame ( yuv, _opt->out_size, _opt->padding, _fs->scaler, frame, _fs->frames_per_second, s.second, @@ -144,7 +147,9 @@ J2KWAVEncoder::encoder_thread (ServerDescription* server) while (1) { boost::mutex::scoped_lock lock (_worker_mutex); while (_queue.empty () && !_process_end) { + _log->microsecond_log ("Encoder thread sleeps", Log::TIMING); _worker_condition.wait (lock); + _log->microsecond_log ("Encoder thread wakes", Log::TIMING); } if (_process_end) { @@ -152,6 +157,7 @@ J2KWAVEncoder::encoder_thread (ServerDescription* server) } boost::shared_ptr<DCPVideoFrame> vf = _queue.front (); + _log->microsecond_log ("Encoder thread wakes with queue of " + boost::lexical_cast<string> (_queue.size ()), Log::TIMING); _queue.pop_front (); lock.unlock (); @@ -183,7 +189,9 @@ J2KWAVEncoder::encoder_thread (ServerDescription* server) } else { try { + _log->microsecond_log ("Encoder thread begins local encode of " + lexical_cast<string> (vf->frame ()), Log::TIMING); encoded = vf->encode_locally (); + _log->microsecond_log ("Encoder thread finishes local encode of " + lexical_cast<string> (vf->frame ()), Log::TIMING); } catch (std::exception& e) { stringstream s; s << "Local encode failed " << e.what() << "."; |