dart::SendAndExitMessagesHandler Class Reference

Inheritance diagram for dart::SendAndExitMessagesHandler:

Public Member Functions
	SendAndExitMessagesHandler (Isolate *owner)
const char *	name () const
	~SendAndExitMessagesHandler ()
MessageStatus	HandleMessage (std::unique_ptr< Message > message)
const char *	msg () const
virtual Isolate *	isolate () const
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 ()
virtual bool	KeepAliveLocked ()
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 ()
virtual bool	IsCurrentIsolate () const
void	PostMessage (std::unique_ptr< Message > message, bool before_events=false)
void	ClosePort (Dart_Port port)
void	CloseAllPorts ()
virtual void	MessageNotify (Message::Priority priority)
virtual void	NotifyPauseOnStart ()
virtual void	NotifyPauseOnExit ()
Thread *	thread () const

Detailed Description

Definition at line 486 of file heap_test.cc.

Constructor & Destructor Documentation

SendAndExitMessagesHandler()

dart::SendAndExitMessagesHandler::SendAndExitMessagesHandler ( Isolate *  owner )

inlineexplicit

Definition at line 488 of file heap_test.cc.

      : msg_(Utils::CreateCStringUniquePtr(nullptr)), owner_(owner) {}

~SendAndExitMessagesHandler()

dart::SendAndExitMessagesHandler::~SendAndExitMessagesHandler ( )

inline

Definition at line 493 of file heap_test.cc.

{ PortMap::ClosePorts(this); }

Member Function Documentation

HandleMessage()

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

inlinevirtual

Implements dart::MessageHandler.

Definition at line 495 of file heap_test.cc.

                                                              {
    // Parse the message.
    Object& response_obj = Object::Handle();
    if (message->IsRaw()) {
      response_obj = message->raw_obj();
    } else if (message->IsPersistentHandle()) {
      PersistentHandle* handle = message->persistent_handle();
      // Object is in the receiving isolate's heap.
      EXPECT(isolate()->group()->heap()->Contains(
          UntaggedObject::ToAddr(handle->ptr())));
      response_obj = handle->ptr();
      isolate()->group()->api_state()->FreePersistentHandle(handle);
    } else {
      Thread* thread = Thread::Current();
      response_obj = ReadMessage(thread, message.get());
    }
    if (response_obj.IsString()) {
      String& response = String::Handle();
      response ^= response_obj.ptr();
      msg_.reset(Utils::StrDup(response.ToCString()));
    } else {
      ASSERT(response_obj.IsArray());
      Array& response_array = Array::Handle();
      response_array ^= response_obj.ptr();
      ASSERT(response_array.Length() == 1);
      ExternalTypedData& response = ExternalTypedData::Handle();
      response ^= response_array.At(0);
      msg_.reset(Utils::StrDup(reinterpret_cast<char*>(response.DataAddr(0))));
    }
 
    return kOK;
  }

isolate()

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

inlinevirtual

Reimplemented from dart::MessageHandler.

Definition at line 530 of file heap_test.cc.

{ return owner_; }

msg()

const char * dart::SendAndExitMessagesHandler::msg ( ) const

inline

Definition at line 528 of file heap_test.cc.

{ return msg_.get(); }

name()

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

inlinevirtual

Reimplemented from dart::MessageHandler.

Definition at line 491 of file heap_test.cc.

{ return "merge-isolates-heaps-handler"; }

---

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

• third_party/dart-lang/sdk/runtime/vm/heap/heap_test.cc