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 ()

virtual const char *	name () const

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

virtual Isolate *	isolate () 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 MessageStatus	HandleMessage (std::unique_ptr< Message > message)=0

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.

489 : msg_(CStringUniquePtr(nullptr)), owner_(owner) {}

dart::CStringUniquePtr

CAllocUniquePtr< char > CStringUniquePtr

Definition: utils.h:31

◆ ~SendAndExitMessagesHandler()

dart::SendAndExitMessagesHandler::~SendAndExitMessagesHandler ( )

inline

Definition at line 493 of file heap_test.cc.

493{ PortMap::ClosePorts(this); }

dart::PortMap::ClosePorts

static void ClosePorts(MessageHandler *handler)

Definition: port.cc:128

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.

530{ return owner_; }

◆ msg()

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

inline

Definition at line 528 of file heap_test.cc.

528{ return msg_.get(); }

◆ name()

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

inlinevirtual

Reimplemented from dart::MessageHandler.

Definition at line 491 of file heap_test.cc.

491{ 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

Public Member Functions

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ SendAndExitMessagesHandler()

◆ ~SendAndExitMessagesHandler()

Member Function Documentation

◆ HandleMessage()

◆ isolate()

◆ msg()

◆ name()