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()
576     msg_queue_->SignalQueueDestroyed.connect(this,  in SetMessageQueue()
582   ASSERT(msg_queue_ == Thread::Current());  in Wait()
594   ASSERT(msg_queue_ == Thread::Current());  in ProcessMessagesUntilIdle()
596   while (!msg_queue_->empty()) {  in ProcessMessagesUntilIdle()
598     if (msg_queue_->Get(&msg, Thread::kForever)) {  in ProcessMessagesUntilIdle()
599       msg_queue_->Dispatch(&msg);  in ProcessMessagesUntilIdle()
603   return !msg_queue_->IsQuitting();  in ProcessMessagesUntilIdle()
744     msg_queue_->PostDelayed(delay, remote, MSG_ID_CONNECT,  in Connect()
748     msg_queue_->PostDelayed(delay, socket, MSG_ID_DISCONNECT);  in Connect()
756     msg_queue_->Post(socket, MSG_ID_DISCONNECT);  in Disconnect()
904   msg_queue_->PostAt(ts, recipient, MSG_ID_PACKET, p);  in AddPacketToNetwork()