Lines Matching defs:message_queue_
168 message_queue_.push_back(IPC::Message(*msg));
173 size_t queued_messages() const { return message_queue_.size(); }
178 if (message_queue_.empty()) {
184 if (ResourceHostMsg_RequestResource::ID != message_queue_[0].type() ||
185 !ResourceHostMsg_RequestResource::Read(&message_queue_[0], ¶ms)) {
191 message_queue_.erase(message_queue_.begin());
196 ASSERT_FALSE(message_queue_.empty());
198 ASSERT_EQ(ResourceHostMsg_FollowRedirect::ID, message_queue_[0].type());
200 &message_queue_[0], &args));
202 message_queue_.erase(message_queue_.begin());
206 ASSERT_FALSE(message_queue_.empty());
208 ASSERT_EQ(ResourceHostMsg_DataReceived_ACK::ID, message_queue_[0].type());
210 &message_queue_[0], &args));
212 message_queue_.erase(message_queue_.begin());
216 ASSERT_FALSE(message_queue_.empty());
218 ASSERT_EQ(ResourceHostMsg_DataDownloaded_ACK::ID, message_queue_[0].type());
220 &message_queue_[0], &args));
222 message_queue_.erase(message_queue_.begin());
226 ASSERT_FALSE(message_queue_.empty());
229 message_queue_[0].type());
231 &message_queue_[0], &args));
233 message_queue_.erase(message_queue_.begin());
237 ASSERT_FALSE(message_queue_.empty());
239 ASSERT_EQ(ResourceHostMsg_CancelRequest::ID, message_queue_[0].type());
241 &message_queue_[0], &args));
243 message_queue_.erase(message_queue_.begin());
345 std::vector<IPC::Message> message_queue_;