| Index: runtime/vm/message.h
|
| ===================================================================
|
| --- runtime/vm/message.h (revision 5107)
|
| +++ runtime/vm/message.h (working copy)
|
| @@ -78,13 +78,17 @@
|
| // not block.
|
| Message* DequeueNoWait();
|
|
|
| + // Gets the next message of the specified priority or greater from
|
| + // the message queue if available. Will not block.
|
| + Message* DequeueNoWaitWithPriority(Message::Priority min_priority);
|
| +
|
| void Flush(Dart_Port port);
|
| void FlushAll();
|
|
|
| private:
|
| friend class MessageQueueTestPeer;
|
|
|
| - Message* DequeueNoWaitHoldsLock();
|
| + Message* DequeueNoWaitHoldsLock(Message::Priority min_priority);
|
|
|
| Monitor monitor_;
|
| Message* head_[Message::kNumPriorities];
|
|
|