+
+ typedef struct {
+ u_int8_t* buf_;
+ u_int32_t len_;
+ proto::socket* sock_;
+ Semaphore* sem_;
+ } SocketsElement;
+ std::list<SocketsElement> sockets_;
+
+ void recv_thread(std::list<SocketsElement>::iterator it);
+ typedef struct {
+ u_int32_t len_;
+ PacketSourceEndpoint remote_;
+ std::list<SocketsElement>::iterator it_;
+ } ThreadResult;
+ std::queue<ThreadResult> thread_result_queue_;
+ Mutex thread_result_mutex_;
+ Semaphore thread_result_sem_;