Searched refs:msg_queue_ (Results 1 – 4 of 4) sorted by relevance
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()278 server_->msg_queue_->Get(&msg); in RecvFrom()279 server_->msg_queue_->Dispatch(&msg); in RecvFrom()556 : server_(ss), server_owned_(false), msg_queue_(NULL), stop_on_idle_(false), in VirtualSocketServer()627 msg_queue_ = msg_queue; in SetMessageQueue()628 if (msg_queue_) { in SetMessageQueue()629 msg_queue_->SignalQueueDestroyed.connect(this, in SetMessageQueue()[all …]
140 MessageQueue* queue() { return msg_queue_; } in queue()155 msg_queue_ = queue; in SetMessageQueue()171 MessageQueue* msg_queue_; variable
197 void OnMessageQueueDestroyed() { msg_queue_ = NULL; } in OnMessageQueueDestroyed()225 MessageQueue* msg_queue_; variable
353 : server_(server), msg_queue_(NULL) { in NATSocketServer()