Searched refs:msg_queue_ (Results 1 – 4 of 4) sorted by relevance
158 server_->msg_queue_->Post(this, MSG_ID_ADDRESS_BOUND); in Bind()207 if (server_->msg_queue_) { in Close()208 server_->msg_queue_->Clear(this, MSG_ID_CONNECT, &msgs); in Close()229 if (server_->msg_queue_) { in Close()230 server_->msg_queue_->Clear(this); in Close()280 server_->msg_queue_->Get(&msg); in RecvFrom()281 server_->msg_queue_->Dispatch(&msg); in RecvFrom()503 : server_(ss), server_owned_(false), msg_queue_(NULL), stop_on_idle_(false), in VirtualSocketServer()574 msg_queue_ = msg_queue; in SetMessageQueue()575 if (msg_queue_) { in SetMessageQueue()[all …]
128 MessageQueue* queue() { return msg_queue_; } in queue()154 MessageQueue* msg_queue_; variable
199 void OnMessageQueueDestroyed() { msg_queue_ = NULL; } in OnMessageQueueDestroyed()227 MessageQueue* msg_queue_; variable
338 : server_(server), msg_queue_(NULL) { in NATSocketServer()377 msg_queue_ = queue; in SetMessageQueue()