OLD | NEW |
1 // Copyright (c) 2011, the Dart project authors. Please see the AUTHORS file | 1 // Copyright (c) 2011, the Dart project authors. Please see the AUTHORS file |
2 // for details. All rights reserved. Use of this source code is governed by a | 2 // for details. All rights reserved. Use of this source code is governed by a |
3 // BSD-style license that can be found in the LICENSE file. | 3 // BSD-style license that can be found in the LICENSE file. |
4 | 4 |
5 #include "vm/message_handler.h" | 5 #include "vm/message_handler.h" |
6 | 6 |
7 #include "vm/dart.h" | 7 #include "vm/dart.h" |
8 #include "vm/lockers.h" | 8 #include "vm/lockers.h" |
9 #include "vm/port.h" | 9 #include "vm/port.h" |
10 #include "vm/thread_interrupter.h" | 10 #include "vm/thread_interrupter.h" |
(...skipping 103 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
114 } | 114 } |
115 | 115 |
116 saved_priority = message->priority(); | 116 saved_priority = message->priority(); |
117 if (message->IsOOB()) { | 117 if (message->IsOOB()) { |
118 oob_queue_->Enqueue(message, before_events); | 118 oob_queue_->Enqueue(message, before_events); |
119 } else { | 119 } else { |
120 queue_->Enqueue(message, before_events); | 120 queue_->Enqueue(message, before_events); |
121 } | 121 } |
122 message = NULL; // Do not access message. May have been deleted. | 122 message = NULL; // Do not access message. May have been deleted. |
123 | 123 |
124 if (pool_ != NULL && task_ == NULL) { | 124 if ((pool_ != NULL) && (task_ == NULL)) { |
125 task_ = new MessageHandlerTask(this); | 125 task_ = new MessageHandlerTask(this); |
126 pool_->Run(task_); | 126 pool_->Run(task_); |
127 } | 127 } |
128 } | 128 } |
129 // Invoke any custom message notification. | 129 // Invoke any custom message notification. |
130 MessageNotify(saved_priority); | 130 MessageNotify(saved_priority); |
131 } | 131 } |
132 | 132 |
133 | 133 |
134 Message* MessageHandler::DequeueMessage(Message::Priority min_priority) { | 134 Message* MessageHandler::DequeueMessage(Message::Priority min_priority) { |
(...skipping 236 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
371 | 371 |
372 | 372 |
373 void MessageHandler::AcquireQueues(AcquiredQueues* acquired_queues) { | 373 void MessageHandler::AcquireQueues(AcquiredQueues* acquired_queues) { |
374 ASSERT(acquired_queues != NULL); | 374 ASSERT(acquired_queues != NULL); |
375 // No double dipping. | 375 // No double dipping. |
376 ASSERT(acquired_queues->handler_ == NULL); | 376 ASSERT(acquired_queues->handler_ == NULL); |
377 acquired_queues->Reset(this); | 377 acquired_queues->Reset(this); |
378 } | 378 } |
379 | 379 |
380 } // namespace dart | 380 } // namespace dart |
OLD | NEW |