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(); |