Re-add mutex that was taken away in

[dcpomatic.git] / src / lib / j2k_encoder.cc

diff --git a/src/lib/j2k_encoder.cc b/src/lib/j2k_encoder.cc
index 18bb27645ea72e209d0054323dd235570fe4bd45..c000f8599cfa89a0b3aa70320ac6b805bcda9c43 100644 (file)
--- a/src/lib/j2k_encoder.cc
+++ b/src/lib/j2k_encoder.cc
@@ -178,7 +178,11 @@ J2KEncoder::encode (shared_ptr<PlayerVideo> pv, DCPTime time)
 {
        _waker.nudge ();
 
-       size_t threads = _threads->size();
+       size_t threads = 0;
+       {
+               boost::mutex::scoped_lock lm (_threads_mutex);
+               threads = _threads->size();
+       }
 
        boost::mutex::scoped_lock queue_lock (_queue_mutex);
 
@@ -240,6 +244,7 @@ void
 J2KEncoder::terminate_threads ()
 {
        boost::this_thread::disable_interruption dis;
+       boost::mutex::scoped_lock lm (_threads_mutex);
 
        if (!_threads) {
                return;
@@ -370,6 +375,8 @@ J2KEncoder::servers_list_changed ()
        terminate_threads ();
        _threads.reset (new boost::thread_group());
 
+       boost::mutex::scoped_lock lm (_threads_mutex);
+
        /* XXX: could re-use threads */
 
        if (!Config::instance()->only_servers_encode ()) {