*/
-#include "server.h"
+#include "cross.h"
#include "exception_store.h"
-#include <boost/thread.hpp>
+#include "server.h"
#include <boost/asio.hpp>
+#include <boost/thread.hpp>
#include <boost/thread/condition.hpp>
#include <string>
-class Socket;
class Log;
+class Socket;
/** @class EncodeServer
EncodeServer (bool verbose, int num_threads);
~EncodeServer ();
- void run ();
+ void run () override;
private:
- void handle (std::shared_ptr<Socket>);
+ void handle (std::shared_ptr<Socket>) override;
void worker_thread ();
int process (std::shared_ptr<Socket> socket, struct timeval &, struct timeval &);
void broadcast_thread ();
boost::condition _empty_condition;
bool _verbose;
int _num_threads;
+ Waker _waker;
struct Broadcast {