| Index: runtime/vm/isolate.cc
|
| ===================================================================
|
| --- runtime/vm/isolate.cc (revision 35287)
|
| +++ runtime/vm/isolate.cc (working copy)
|
| @@ -121,16 +121,16 @@
|
| // overcount when other things (gc, compilation) are active.
|
| TIMERSCOPE(isolate_, time_dart_execution);
|
|
|
| - // If the message is in band we lookup the receive port to dispatch to. If
|
| - // the receive port is closed, we drop the message without deserializing it.
|
| - Object& receive_port = Object::Handle();
|
| + // If the message is in band we lookup the handler to dispatch to. If the
|
| + // receive port was closed, we drop the message without deserializing it.
|
| + Object& msg_handler = Object::Handle();
|
| if (!message->IsOOB()) {
|
| - receive_port = DartLibraryCalls::LookupReceivePort(message->dest_port());
|
| - if (receive_port.IsError()) {
|
| + msg_handler = DartLibraryCalls::LookupHandler(message->dest_port());
|
| + if (msg_handler.IsError()) {
|
| return ProcessUnhandledException(Object::null_instance(),
|
| - Error::Cast(receive_port));
|
| + Error::Cast(msg_handler));
|
| }
|
| - if (receive_port.IsNull()) {
|
| + if (msg_handler.IsNull()) {
|
| delete message;
|
| return true;
|
| }
|
| @@ -162,7 +162,7 @@
|
| Service::HandleIsolateMessage(isolate_, msg);
|
| } else {
|
| const Object& result = Object::Handle(
|
| - DartLibraryCalls::HandleMessage(receive_port, msg));
|
| + DartLibraryCalls::HandleMessage(msg_handler, msg));
|
| if (result.IsError()) {
|
| success = ProcessUnhandledException(msg, Error::Cast(result));
|
| } else {
|
|
|