Searched refs:queued_messages (Results 1 – 4 of 4) sorted by relevance
31 QueuedMessages queued_messages; member91 DCHECK(message_ports_[message_port_id].queued_messages.empty()); in Destroy()153 entangled_port.queued_messages.push_back( in PostMessageTo()197 const QueuedMessages& queued_messages) { in SendQueuedMessages() argument207 port.queued_messages.insert(port.queued_messages.begin(), in SendQueuedMessages()208 queued_messages.begin(), in SendQueuedMessages()209 queued_messages.end()); in SendQueuedMessages()223 for (QueuedMessages::iterator iter = port.queued_messages.begin(); in SendQueuedMessagesIfPossible()224 iter != port.queued_messages.end(); ++iter) { in SendQueuedMessagesIfPossible()227 port.queued_messages.clear(); in SendQueuedMessagesIfPossible()
39 const QueuedMessages& queued_messages);
111 std::vector<IPC::Message*> queued_messages = queued_messages_; in SendQueuedMessages() local113 for (size_t i = 0; i < queued_messages.size(); ++i) { in SendQueuedMessages()114 queued_messages[i]->set_routing_id(route_id_); in SendQueuedMessages()115 Send(queued_messages[i]); in SendQueuedMessages()
227 std::vector<QueuedMessage> queued_messages; in OnMessagesQueued() local231 queued_messages.reserve(message_queue_.size()); in OnMessagesQueued()241 queued_messages.push_back(std::make_pair(message, port_ids)); in OnMessagesQueued()247 message_port_id_, queued_messages)); in OnMessagesQueued()