Public Member Functions | |
ClientHandler (boost::asio::io_service &io_service) | |
void | readerThread () |
void | start () |
void | stop () |
void | waitUntilDone () |
void | writerThread () |
~ClientHandler () | |
Public Attributes | |
megatree::BlockingQueue< Message > | incoming_queue |
bool | keep_running |
megatree::BlockingQueue< Message > | outgoing_queue |
boost::thread | reader_thread |
tcp::socket | socket |
boost::thread | writer_thread |
Definition at line 21 of file streaming_server.cpp.
ClientHandler::ClientHandler | ( | boost::asio::io_service & | io_service | ) | [inline] |
Definition at line 24 of file streaming_server.cpp.
ClientHandler::~ClientHandler | ( | ) | [inline] |
Definition at line 28 of file streaming_server.cpp.
void ClientHandler::readerThread | ( | ) | [inline] |
Definition at line 67 of file streaming_server.cpp.
void ClientHandler::start | ( | ) | [inline] |
Definition at line 35 of file streaming_server.cpp.
void ClientHandler::stop | ( | ) | [inline] |
Definition at line 42 of file streaming_server.cpp.
void ClientHandler::waitUntilDone | ( | ) | [inline] |
Definition at line 49 of file streaming_server.cpp.
void ClientHandler::writerThread | ( | ) | [inline] |
Definition at line 102 of file streaming_server.cpp.
Definition at line 130 of file streaming_server.cpp.
Definition at line 127 of file streaming_server.cpp.
Definition at line 130 of file streaming_server.cpp.
boost::thread ClientHandler::reader_thread |
Definition at line 128 of file streaming_server.cpp.
tcp::socket ClientHandler::socket |
Definition at line 126 of file streaming_server.cpp.
boost::thread ClientHandler::writer_thread |
Definition at line 128 of file streaming_server.cpp.