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/object.h" | 9 #include "vm/object.h" |
10 #include "vm/object_store.h" | 10 #include "vm/object_store.h" |
(...skipping 439 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
450 live_ports_--; | 450 live_ports_--; |
451 } | 451 } |
452 | 452 |
453 | 453 |
454 void MessageHandler::PausedOnStart(bool paused) { | 454 void MessageHandler::PausedOnStart(bool paused) { |
455 MonitorLocker ml(&monitor_); | 455 MonitorLocker ml(&monitor_); |
456 PausedOnStartLocked(&ml, paused); | 456 PausedOnStartLocked(&ml, paused); |
457 } | 457 } |
458 | 458 |
459 | 459 |
| 460 void MessageHandler::DebugDump() { |
| 461 PortMap::DebugDumpForMessageHandler(this); |
| 462 } |
| 463 |
| 464 |
460 void MessageHandler::PausedOnStartLocked(MonitorLocker* ml, bool paused) { | 465 void MessageHandler::PausedOnStartLocked(MonitorLocker* ml, bool paused) { |
461 if (paused) { | 466 if (paused) { |
462 ASSERT(!is_paused_on_start_); | 467 ASSERT(!is_paused_on_start_); |
463 is_paused_on_start_ = true; | 468 is_paused_on_start_ = true; |
464 paused_timestamp_ = OS::GetCurrentTimeMillis(); | 469 paused_timestamp_ = OS::GetCurrentTimeMillis(); |
465 } else { | 470 } else { |
466 ASSERT(is_paused_on_start_); | 471 ASSERT(is_paused_on_start_); |
467 is_paused_on_start_ = false; | 472 is_paused_on_start_ = false; |
468 paused_timestamp_ = -1; | 473 paused_timestamp_ = -1; |
469 } | 474 } |
(...skipping 55 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
525 handler_->oob_message_handling_allowed_ = false; | 530 handler_->oob_message_handling_allowed_ = false; |
526 } | 531 } |
527 | 532 |
528 | 533 |
529 MessageHandler::AcquiredQueues::~AcquiredQueues() { | 534 MessageHandler::AcquiredQueues::~AcquiredQueues() { |
530 ASSERT(handler_ != NULL); | 535 ASSERT(handler_ != NULL); |
531 handler_->oob_message_handling_allowed_ = true; | 536 handler_->oob_message_handling_allowed_ = true; |
532 } | 537 } |
533 | 538 |
534 } // namespace dart | 539 } // namespace dart |
OLD | NEW |