Searched refs:msg_queue_ (Results 1 – 4 of 4) sorted by relevance
154 server_->msg_queue_->Post(RTC_FROM_HERE, this, MSG_ID_ADDRESS_BOUND); in Bind()203 if (server_->msg_queue_) { in Close()204 server_->msg_queue_->Clear(this, MSG_ID_CONNECT, &msgs); in Close()225 if (server_->msg_queue_) { in Close()226 server_->msg_queue_->Clear(this); in Close()282 server_->msg_queue_->Get(&msg); in RecvFrom()283 server_->msg_queue_->Dispatch(&msg); in RecvFrom()304 server_->msg_queue_->Clear(this, MSG_ID_SIGNALREADEVENT); in RecvFrom()305 server_->msg_queue_->Post(RTC_FROM_HERE, this, MSG_ID_SIGNALREADEVENT); in RecvFrom()529 msg_queue_(nullptr), in VirtualSocketServer()[all …]
141 Thread* queue() { return msg_queue_; } in queue()165 Thread* msg_queue_; variable
237 void OnMessageQueueDestroyed() { msg_queue_ = nullptr; } in OnMessageQueueDestroyed()272 Thread* msg_queue_; variable
361 : server_(server), msg_queue_(nullptr) {} in NATSocketServer()392 msg_queue_ = queue; in SetMessageQueue()