Rearrange encoder threading.

[dcpomatic.git] / src / lib / encode_server.h

diff --git a/src/lib/encode_server.h b/src/lib/encode_server.h
index f93d667467a0a4fe439651fe540d7dd3107e68fe..8059abd0f6d5bfe1c3ab04763ffe62ce5fa97051 100644 (file)
--- a/src/lib/encode_server.h
+++ b/src/lib/encode_server.h
@@ -32,6 +32,7 @@
 #include "exception_store.h"
 #include "server.h"
 #include <boost/asio.hpp>
+#include <boost/atomic.hpp>
 #include <boost/thread.hpp>
 #include <boost/thread/condition.hpp>
 #include <string>
@@ -53,6 +54,10 @@ public:
 
        void run () override;
 
+       int frames_encoded() const {
+               return _frames_encoded;
+       }
+
 private:
        void handle (std::shared_ptr<Socket>) override;
        void worker_thread ();
@@ -67,6 +72,7 @@ private:
        bool _verbose;
        int _num_threads;
        Waker _waker;
+       boost::atomic<int> _frames_encoded;
 
        struct Broadcast {