X-Git-Url: https://main.carlh.net/gitweb/?a=blobdiff_plain;f=src%2Flib%2Fencode_server.h;h=f93d667467a0a4fe439651fe540d7dd3107e68fe;hb=53d0a9a844841fe10b2720543c032a687c548108;hp=6e24a19849827cdde20c276e79d331b8a2cd1ab5;hpb=7bc2134d658778e04f1756c255e604b4ab5a5831;p=dcpomatic.git diff --git a/src/lib/encode_server.h b/src/lib/encode_server.h index 6e24a1984..f93d66746 100644 --- a/src/lib/encode_server.h +++ b/src/lib/encode_server.h @@ -28,16 +28,17 @@ */ -#include "server.h" +#include "cross.h" #include "exception_store.h" -#include +#include "server.h" #include +#include #include #include -class Socket; class Log; +class Socket; /** @class EncodeServer @@ -50,10 +51,10 @@ public: EncodeServer (bool verbose, int num_threads); ~EncodeServer (); - void run (); + void run () override; private: - void handle (std::shared_ptr); + void handle (std::shared_ptr) override; void worker_thread (); int process (std::shared_ptr socket, struct timeval &, struct timeval &); void broadcast_thread (); @@ -65,6 +66,7 @@ private: boost::condition _empty_condition; bool _verbose; int _num_threads; + Waker _waker; struct Broadcast {