Lines Matching refs:msg_queue_
190 if (server_->msg_queue_) {
191 server_->msg_queue_->Clear(this, MSG_ID_CONNECT, &msgs);
212 if (server_->msg_queue_) {
213 server_->msg_queue_->Clear(this);
261 server_->msg_queue_->Get(&msg);
262 server_->msg_queue_->Dispatch(&msg);
539 : server_(ss), server_owned_(false), msg_queue_(NULL), stop_on_idle_(false),
610 msg_queue_ = msg_queue;
611 if (msg_queue_) {
612 msg_queue_->SignalQueueDestroyed.connect(this,
618 ASSERT(msg_queue_ == Thread::Current());
630 ASSERT(msg_queue_ == Thread::Current());
632 while (!msg_queue_->empty()) {
634 if (msg_queue_->Get(&msg, kForever)) {
635 msg_queue_->Dispatch(&msg);
639 return !msg_queue_->IsQuitting();
751 msg_queue_->PostDelayed(delay, remote, MSG_ID_CONNECT,
755 msg_queue_->PostDelayed(delay, socket, MSG_ID_DISCONNECT);
763 msg_queue_->Post(socket, MSG_ID_DISCONNECT);
900 msg_queue_->PostAt(ts, recipient, MSG_ID_PACKET, p);
