| Index: runtime/vm/message_handler_test.cc
|
| diff --git a/runtime/vm/message_handler_test.cc b/runtime/vm/message_handler_test.cc
|
| index 81325117bb00ee7ce3e022c5c72c8042298f5726..7bfcb9aa557d851cfc658a40d22ac262e16ceb32 100644
|
| --- a/runtime/vm/message_handler_test.cc
|
| +++ b/runtime/vm/message_handler_test.cc
|
| @@ -158,11 +158,25 @@ UNIT_TEST_CASE(MessageHandler_HasOOBMessages) {
|
| Message* message = new Message(1, NULL, 0, Message::kNormalPriority);
|
| handler_peer.PostMessage(message);
|
| EXPECT(!handler.HasOOBMessages());
|
| + {
|
| + // Acquire ownership of message handler queues, verify one regular message.
|
| + MessageHandler::AcquiredQueues aq;
|
| + handler.AcquireQueues(&aq);
|
| + EXPECT(aq.queue()->Length() == 1);
|
| + }
|
|
|
| // Post an oob message.
|
| message = new Message(1, NULL, 0, Message::kOOBPriority);
|
| handler_peer.PostMessage(message);
|
| EXPECT(handler.HasOOBMessages());
|
| + {
|
| + // Acquire ownership of message handler queues, verify one regular and one
|
| + // OOB message.
|
| + MessageHandler::AcquiredQueues aq;
|
| + handler.AcquireQueues(&aq);
|
| + EXPECT(aq.queue()->Length() == 1);
|
| + EXPECT(aq.oob_queue()->Length() == 1);
|
| + }
|
|
|
| // Delete all pending messages.
|
| handler_peer.CloseAllPorts();
|
|
|