message_queue_ 37 content/browser/shared_worker/shared_worker_service_impl_unittest.cc if (!message_queue_) { message_queue_ 41 content/browser/shared_worker/shared_worker_service_impl_unittest.cc message_queue_->push_back(message); message_queue_ 46 content/browser/shared_worker/shared_worker_service_impl_unittest.cc message_queue_ = NULL; message_queue_ 52 content/browser/shared_worker/shared_worker_service_impl_unittest.cc ScopedVector<IPC::Message>* message_queue_; message_queue_ 69 content/browser/shared_worker/shared_worker_service_impl_unittest.cc if (!message_queue_) { message_queue_ 73 content/browser/shared_worker/shared_worker_service_impl_unittest.cc message_queue_->push_back(message); message_queue_ 78 content/browser/shared_worker/shared_worker_service_impl_unittest.cc message_queue_ = NULL; message_queue_ 84 content/browser/shared_worker/shared_worker_service_impl_unittest.cc ScopedVector<IPC::Message>* message_queue_; message_queue_ 106 content/child/resource_dispatcher_unittest.cc message_queue_.push_back(IPC::Message(*msg)); message_queue_ 114 content/child/resource_dispatcher_unittest.cc while (!message_queue_.empty()) { message_queue_ 118 content/child/resource_dispatcher_unittest.cc &message_queue_[0], &request_id, &request)); message_queue_ 145 content/child/resource_dispatcher_unittest.cc message_queue_.erase(message_queue_.begin()); message_queue_ 150 content/child/resource_dispatcher_unittest.cc &message_queue_[0], &request_ack)); message_queue_ 154 content/child/resource_dispatcher_unittest.cc message_queue_.erase(message_queue_.begin()); message_queue_ 185 content/child/resource_dispatcher_unittest.cc std::vector<IPC::Message> message_queue_; message_queue_ 46 content/child/webmessageportchannel_impl.cc while (!message_queue_.empty()) { message_queue_ 48 content/child/webmessageportchannel_impl.cc message_queue_.front().ports; message_queue_ 52 content/child/webmessageportchannel_impl.cc message_queue_.pop(); message_queue_ 129 content/child/webmessageportchannel_impl.cc if (message_queue_.empty()) message_queue_ 132 content/child/webmessageportchannel_impl.cc *message = message_queue_.front().message; message_queue_ 134 content/child/webmessageportchannel_impl.cc message_queue_.front().ports; message_queue_ 141 content/child/webmessageportchannel_impl.cc message_queue_.pop(); message_queue_ 231 content/child/webmessageportchannel_impl.cc bool was_empty = message_queue_.empty(); message_queue_ 232 content/child/webmessageportchannel_impl.cc message_queue_.push(msg); message_queue_ 242 content/child/webmessageportchannel_impl.cc queued_messages.reserve(message_queue_.size()); message_queue_ 243 content/child/webmessageportchannel_impl.cc while (!message_queue_.empty()) { message_queue_ 244 content/child/webmessageportchannel_impl.cc base::string16 message = message_queue_.front().message; message_queue_ 246 content/child/webmessageportchannel_impl.cc message_queue_.front().ports; message_queue_ 253 content/child/webmessageportchannel_impl.cc message_queue_.pop(); message_queue_ 82 content/child/webmessageportchannel_impl.h MessageQueue message_queue_; message_queue_ 659 content/public/test/browser_test_utils.cc message_queue_.push(dom_op_details->json); message_queue_ 665 content/public/test/browser_test_utils.cc message_queue_ = std::queue<std::string>(); message_queue_ 670 content/public/test/browser_test_utils.cc if (message_queue_.empty()) { message_queue_ 676 content/public/test/browser_test_utils.cc if (message_queue_.empty()) message_queue_ 678 content/public/test/browser_test_utils.cc *message = message_queue_.front(); message_queue_ 679 content/public/test/browser_test_utils.cc message_queue_.pop(); message_queue_ 290 content/public/test/browser_test_utils.h std::queue<std::string> message_queue_; message_queue_ 70 ipc/ipc_sync_channel.cc message_queue_.push_back(QueuedMessage(new Message(msg), context)); message_queue_ 106 ipc/ipc_sync_channel.cc it = message_queue_.begin(); message_queue_ 109 ipc/ipc_sync_channel.cc for (; it != message_queue_.end(); it++) { message_queue_ 115 ipc/ipc_sync_channel.cc it = message_queue_.erase(it); message_queue_ 134 ipc/ipc_sync_channel.cc SyncMessageQueue::iterator iter = message_queue_.begin(); message_queue_ 135 ipc/ipc_sync_channel.cc while (iter != message_queue_.end()) { message_queue_ 138 ipc/ipc_sync_channel.cc iter = message_queue_.erase(iter); message_queue_ 205 ipc/ipc_sync_channel.cc SyncMessageQueue message_queue_; message_queue_ 23 mojo/system/local_message_pipe_endpoint.cc DCHECK(message_queue_.IsEmpty()); // Should be implied by not being open. message_queue_ 33 mojo/system/local_message_pipe_endpoint.cc message_queue_.Clear(); message_queue_ 58 mojo/system/local_message_pipe_endpoint.cc bool was_empty = message_queue_.IsEmpty(); message_queue_ 59 mojo/system/local_message_pipe_endpoint.cc message_queue_.AddMessage(message.Pass()); message_queue_ 82 mojo/system/local_message_pipe_endpoint.cc if (message_queue_.IsEmpty()) { message_queue_ 90 mojo/system/local_message_pipe_endpoint.cc MessageInTransit* message = message_queue_.PeekMessage(); message_queue_ 120 mojo/system/local_message_pipe_endpoint.cc message_queue_.DiscardMessage(); message_queue_ 123 mojo/system/local_message_pipe_endpoint.cc if (message_queue_.IsEmpty()) { message_queue_ 158 mojo/system/local_message_pipe_endpoint.cc if (!message_queue_.IsEmpty()) message_queue_ 167 mojo/system/local_message_pipe_endpoint.cc if (!message_queue_.IsEmpty() || is_peer_open_) message_queue_ 45 mojo/system/local_message_pipe_endpoint.h MessageInTransitQueue* message_queue() { return &message_queue_; } message_queue_ 55 mojo/system/local_message_pipe_endpoint.h MessageInTransitQueue message_queue_; message_queue_ 37 mojo/system/raw_channel.cc STLDeleteElements(&message_queue_); message_queue_ 47 mojo/system/raw_channel.cc MessageInTransit* message = message_queue_.front(); message_queue_ 86 mojo/system/raw_channel.cc if (message_queue_.empty()) message_queue_ 89 mojo/system/raw_channel.cc MessageInTransit* message = message_queue_.front(); message_queue_ 140 mojo/system/raw_channel.cc LOG_IF(WARNING, !write_buffer_->message_queue_.empty()) message_queue_ 165 mojo/system/raw_channel.cc if (!write_buffer_->message_queue_.empty()) { message_queue_ 166 mojo/system/raw_channel.cc write_buffer_->message_queue_.push_back(message.release()); message_queue_ 170 mojo/system/raw_channel.cc write_buffer_->message_queue_.push_front(message.release()); message_queue_ 196 mojo/system/raw_channel.cc return write_buffer_->message_queue_.empty(); message_queue_ 314 mojo/system/raw_channel.cc DCHECK_EQ(write_stopped_, write_buffer_->message_queue_.empty()); message_queue_ 338 mojo/system/raw_channel.cc DCHECK(!write_buffer_->message_queue_.empty()); message_queue_ 347 mojo/system/raw_channel.cc delete write_buffer_->message_queue_.front(); message_queue_ 348 mojo/system/raw_channel.cc write_buffer_->message_queue_.pop_front(); message_queue_ 352 mojo/system/raw_channel.cc if (write_buffer_->message_queue_.empty()) message_queue_ 361 mojo/system/raw_channel.cc STLDeleteElements(&write_buffer_->message_queue_); message_queue_ 144 mojo/system/raw_channel.h std::deque<MessageInTransit*> message_queue_;