dart::IsolateMessageHandler Class Reference

Inheritance diagram for dart::IsolateMessageHandler:

Public Member Functions
	IsolateMessageHandler (Isolate *isolate)
	~IsolateMessageHandler ()
const char *	name () const
void	MessageNotify (Message::Priority priority)
MessageStatus	HandleMessage (std::unique_ptr< Message > message)
void	NotifyPauseOnStart ()
void	NotifyPauseOnExit ()
bool	IsCurrentIsolate () const
virtual Isolate *	isolate () const
virtual IsolateGroup *	isolate_group () const
virtual bool	KeepAliveLocked ()
Public Member Functions inherited from dart::MessageHandler
virtual	~MessageHandler ()
bool	Run (ThreadPool *pool, StartCallback start_callback, EndCallback end_callback, CallbackData data)
MessageStatus	HandleNextMessage ()
MessageStatus	HandleOOBMessages ()
MessageStatus	PauseAndHandleAllMessages (int64_t timeout_millis)
bool	HasOOBMessages ()
bool	HasMessages ()
void	RequestDeletion ()
bool	paused () const
void	increment_paused ()
void	decrement_paused ()
void	DebugDump ()
bool	should_pause_on_start () const
void	set_should_pause_on_start (bool should_pause_on_start)
bool	is_paused_on_start () const
bool	should_pause_on_exit () const
void	set_should_pause_on_exit (bool should_pause_on_exit)
bool	is_paused_on_exit () const
int64_t	paused_timestamp () const
bool	ShouldPauseOnStart (MessageStatus status) const
bool	ShouldPauseOnExit (MessageStatus status) const
void	PausedOnStart (bool paused)
void	PausedOnExit (bool paused)

Additional Inherited Members
Public Types inherited from dart::MessageHandler
enum	MessageStatus { kOK , kError , kShutdown }
typedef uword	CallbackData
typedef MessageStatus(*	StartCallback) (CallbackData data)
typedef void(*	EndCallback) (CallbackData data)
Static Public Member Functions inherited from dart::MessageHandler
static const char *	MessageStatusString (MessageStatus status)
Protected Member Functions inherited from dart::MessageHandler
	MessageHandler ()
void	PostMessage (std::unique_ptr< Message > message, bool before_events=false)
void	ClosePort (Dart_Port port)
void	CloseAllPorts ()
Thread *	thread () const

Detailed Description

Definition at line 1040 of file isolate.cc.

Constructor & Destructor Documentation

IsolateMessageHandler()

dart::IsolateMessageHandler::IsolateMessageHandler ( Isolate *  isolate )

explicit

Definition at line 1078 of file isolate.cc.

    : isolate_(isolate) {}

~IsolateMessageHandler()

dart::IsolateMessageHandler::~IsolateMessageHandler

(

)

Definition at line 1081 of file isolate.cc.

{}

Member Function Documentation

HandleMessage()

MessageHandler::MessageStatus dart::IsolateMessageHandler::HandleMessage ( std::unique_ptr< Message >  message )

virtual

Implements dart::MessageHandler.

Definition at line 1324 of file isolate.cc.

                                    {
  ASSERT(IsCurrentIsolate());
  Thread* thread = Thread::Current();
  StackZone stack_zone(thread);
  Zone* zone = stack_zone.GetZone();
  HandleScope handle_scope(thread);
#if defined(SUPPORT_TIMELINE)
  TimelineBeginEndScope tbes(
      thread, Timeline::GetIsolateStream(),
      message->IsOOB() ? "HandleOOBMessage" : "HandleMessage");
  tbes.SetNumArguments(1);
  tbes.CopyArgument(0, "isolateName", I->name());
#endif
 
  // Parse the message.
  Object& msg_obj = Object::Handle(zone, ReadMessage(thread, message.get()));
  if (msg_obj.IsError()) {
    // An error occurred while reading the message.
    return ProcessUnhandledException(Error::Cast(msg_obj));
  }
  if (!msg_obj.IsNull() && !msg_obj.IsInstance()) {
    // TODO(turnidge): We need to decide what an isolate does with
    // malformed messages.  If they (eventually) come from a remote
    // machine, then it might make sense to drop the message entirely.
    // In the case that the message originated locally, which is
    // always true for now, then this should never occur.
    UNREACHABLE();
  }
  Instance& msg = Instance::Handle(zone);
  msg ^= msg_obj.ptr();  // Can't use Instance::Cast because may be null.
 
  MessageStatus status = kOK;
  if (message->IsOOB()) {
    // OOB messages are expected to be fixed length arrays where the first
    // element is a Smi describing the OOB destination. Messages that do not
    // confirm to this layout are silently ignored.
    if (msg.IsArray()) {
      const Array& oob_msg = Array::Cast(msg);
      if (oob_msg.Length() > 0) {
        const Object& oob_tag = Object::Handle(zone, oob_msg.At(0));
        if (oob_tag.IsSmi()) {
          switch (Smi::Cast(oob_tag).Value()) {
            case Message::kServiceOOBMsg: {
#ifndef PRODUCT
              const Error& error =
                  Error::Handle(Service::HandleIsolateMessage(I, oob_msg));
              if (!error.IsNull()) {
                status = ProcessUnhandledException(error);
              }
#else
              UNREACHABLE();
#endif
              break;
            }
            case Message::kIsolateLibOOBMsg: {
              const Error& error = Error::Handle(HandleLibMessage(oob_msg));
              if (!error.IsNull()) {
                status = ProcessUnhandledException(error);
              }
              break;
            }
#if defined(DEBUG)
            // Malformed OOB messages are silently ignored in release builds.
            default: {
              UNREACHABLE();
              break;
            }
#endif  // defined(DEBUG)
          }
        }
      }
    }
  } else if (message->IsFinalizerInvocationRequest()) {
    const Object& msg_handler = Object::Handle(
        zone,
        DartLibraryCalls::HandleFinalizerMessage(FinalizerBase::Cast(msg)));
    if (msg_handler.IsError()) {
      status = ProcessUnhandledException(Error::Cast(msg_handler));
    } else {
      // The handler closure which was used to successfully handle the message.
    }
  } else if (message->dest_port() == Message::kIllegalPort) {
    // Check whether this is a delayed OOB message which needed handling as
    // part of the regular message dispatch. All other messages are dropped on
    // the floor.
    if (msg.IsArray()) {
      const Array& msg_arr = Array::Cast(msg);
      if (msg_arr.Length() > 0) {
        const Object& oob_tag = Object::Handle(zone, msg_arr.At(0));
        if (oob_tag.IsSmi() &&
            (Smi::Cast(oob_tag).Value() == Message::kDelayedIsolateLibOOBMsg)) {
          const Error& error = Error::Handle(HandleLibMessage(msg_arr));
          if (!error.IsNull()) {
            status = ProcessUnhandledException(error);
          }
        }
      }
    }
  } else {
    const Object& msg_handler = Object::Handle(
        zone, DartLibraryCalls::HandleMessage(message->dest_port(), msg));
    if (msg_handler.IsError()) {
      status = ProcessUnhandledException(Error::Cast(msg_handler));
    } else if (msg_handler.IsNull()) {
      // If the port has been closed then the message will be dropped at this
      // point. Make sure to post to the delivery failure port in that case.
    } else {
      // The handler closure which was used to successfully handle the message.
    }
  }
  return status;
}

IsCurrentIsolate()

bool dart::IsolateMessageHandler::IsCurrentIsolate ( ) const

virtual

Reimplemented from dart::MessageHandler.

Definition at line 1478 of file isolate.cc.

                                                   {
  return (I == Isolate::Current());
}

isolate()

virtual Isolate * dart::IsolateMessageHandler::isolate ( ) const

inlinevirtual

Reimplemented from dart::MessageHandler.

Definition at line 1058 of file isolate.cc.

{ return isolate_; }

isolate_group()

virtual IsolateGroup * dart::IsolateMessageHandler::isolate_group ( ) const

inlinevirtual

Definition at line 1059 of file isolate.cc.

{ return isolate_->group(); }

KeepAliveLocked()

virtual bool dart::IsolateMessageHandler::KeepAliveLocked ( )

inlinevirtual

Reimplemented from dart::MessageHandler.

Definition at line 1061 of file isolate.cc.

                                 {
    // If the message handler was asked to shutdown we shut down.
    if (!MessageHandler::KeepAliveLocked()) return false;
    // Otherwise we only stay alive as long as there's active receive ports, or
    // there are FFI callbacks keeping the isolate alive.
    return isolate_->HasLivePorts() || isolate_->HasOpenNativeCallables();
  }

MessageNotify()

void dart::IsolateMessageHandler::MessageNotify ( Message::Priority  priority )

virtual

Reimplemented from dart::MessageHandler.

Definition at line 1308 of file isolate.cc.

                                                                  {
  if (priority >= Message::kOOBPriority) {
    // Handle out of band messages even if the mutator thread is busy.
    I->ScheduleInterrupts(Thread::kMessageInterrupt);
  }
  Dart_MessageNotifyCallback callback = I->message_notify_callback();
  if (callback != nullptr) {
    // Allow the embedder to handle message notification.
    (*callback)(Api::CastIsolate(I));
  }
}

name()

const char * dart::IsolateMessageHandler::name ( ) const

virtual

Reimplemented from dart::MessageHandler.

Definition at line 1083 of file isolate.cc.

                                              {
  return isolate_->name();
}

NotifyPauseOnExit()

void dart::IsolateMessageHandler::NotifyPauseOnExit ( )

virtual

Reimplemented from dart::MessageHandler.

Definition at line 1455 of file isolate.cc.

                                              {
  if (Isolate::IsSystemIsolate(I)) {
    return;
  }
  if (Service::debug_stream.enabled() || FLAG_warn_on_pause_with_no_debugger) {
    StartIsolateScope start_isolate(I);
    StackZone zone(T);
    HandleScope handle_scope(T);
    ServiceEvent pause_event(I, ServiceEvent::kPauseExit);
    Service::HandleEvent(&pause_event);
  } else if (FLAG_trace_service) {
    OS::PrintErr("vm-service: Dropping event of type PauseExit (%s)\n",
                 I->name());
  }
}

NotifyPauseOnStart()

void dart::IsolateMessageHandler::NotifyPauseOnStart ( )

virtual

Reimplemented from dart::MessageHandler.

Definition at line 1439 of file isolate.cc.

                                               {
  if (Isolate::IsSystemIsolate(I)) {
    return;
  }
  if (Service::debug_stream.enabled() || FLAG_warn_on_pause_with_no_debugger) {
    StartIsolateScope start_isolate(I);
    StackZone zone(T);
    HandleScope handle_scope(T);
    ServiceEvent pause_event(I, ServiceEvent::kPauseStart);
    Service::HandleEvent(&pause_event);
  } else if (FLAG_trace_service) {
    OS::PrintErr("vm-service: Dropping event of type PauseStart (%s)\n",
                 I->name());
  }
}

---

The documentation for this class was generated from the following file:

• third_party/dart-lang/sdk/runtime/vm/isolate.cc