HomeSort by relevance Sort by last modified time
    Searched full:incoming_messages_ (Results 1 - 3 of 3) sorted by null

  /external/libmojo/mojo/edk/system/
node_controller.h 325 // Guards |incoming_messages_| and |incoming_messages_task_posted_|.
327 std::queue<ports::ScopedMessage> incoming_messages_; member in class:mojo::edk::NodeController
331 // Flag to fast-path checking |incoming_messages_|.
node_controller.cc 732 if (incoming_messages_.empty()) {
740 std::swap(messages, incoming_messages_);
841 schedule_pump_task = incoming_messages_.empty() && io_task_runner_ &&
844 incoming_messages_.emplace(std::move(message));
    [all...]
  /external/libmojo/mojo/edk/system/ports/
ports_unittest.cc 110 (incoming_messages_.empty() || (block_on_event_ && blocked_));
195 incoming_messages_.emplace(std::move(message));
269 while (!incoming_messages_.empty()) {
271 GetEventHeader(*incoming_messages_.front())->type ==
279 ScopedMessage message = std::move(incoming_messages_.front());
280 incoming_messages_.pop();
312 std::queue<ScopedMessage> incoming_messages_; member in class:mojo::edk::ports::test::__anon25164::TestNode
    [all...]

Completed in 1187 milliseconds