{
boost::mutex::scoped_lock lock (_mutex);
- Waker waker;
- waker.nudge ();
+ _waker.nudge ();
/* Wait until the queue has gone down a bit */
while (_queue.size() >= _worker_threads.size() * 2 && !_terminate) {
*/
-#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
boost::condition _empty_condition;
bool _verbose;
int _num_threads;
+ Waker _waker;
struct Broadcast {