dart::ApiMessageSerializer Class Reference

Inheritance diagram for dart::ApiMessageSerializer:

Public Member Functions
	ApiMessageSerializer (Zone *zone)
	~ApiMessageSerializer ()
bool	MarkObjectId (Dart_CObject *object, intptr_t id)
void	SetObjectId (Dart_CObject *object, intptr_t id)
intptr_t	GetObjectId (Dart_CObject *object) const
DART_NOINLINE void	AddBaseObject (Dart_CObject *base_object)
DART_NOINLINE intptr_t	AssignRef (Dart_CObject *object)
void	ForwardRef (Dart_CObject *old, Dart_CObject *nue)
void	Push (Dart_CObject *object)
bool	Trace (Dart_CObject *object)
void	AddBaseObjects ()
bool	Serialize (Dart_CObject *root)
void	WriteRef (Dart_CObject *object)
bool	Fail (const char *message)
Public Member Functions inherited from dart::BaseSerializer
	BaseSerializer (Thread *thread, Zone *zone)
	~BaseSerializer ()
template<typename T >
void	Write (T value)
void	WriteUnsigned (intptr_t value)
void	WriteWordWith32BitWrites (uword value)
void	WriteBytes (const void *addr, intptr_t len)
void	WriteAscii (const String &str)
MessageSerializationCluster *	NewClusterForClass (intptr_t cid, bool is_canonical)
void	WriteCluster (MessageSerializationCluster *cluster)
std::unique_ptr< Message >	Finish (Dart_Port dest_port, Message::Priority priority)
Zone *	zone () const
MessageFinalizableData *	finalizable_data () const
intptr_t	next_ref_index () const
Public Member Functions inherited from dart::StackResource
	StackResource (ThreadState *thread)
virtual	~StackResource ()
ThreadState *	thread () const

Additional Inherited Members
Static Public Member Functions inherited from dart::StackResource
static void	Unwind (ThreadState *thread)
static void	UnwindAbove (ThreadState *thread, StackResource *new_top)
Protected Attributes inherited from dart::BaseSerializer
Zone *const	zone_
MallocWriteStream	stream_
MessageFinalizableData *	finalizable_data_
GrowableArray< MessageSerializationCluster * >	clusters_
intptr_t	num_base_objects_
intptr_t	num_written_objects_
intptr_t	next_ref_index_

Detailed Description

Definition at line 282 of file message_snapshot.cc.

Constructor & Destructor Documentation

ApiMessageSerializer()

dart::ApiMessageSerializer::ApiMessageSerializer ( Zone *  zone )

explicit

Definition at line 2719 of file message_snapshot.cc.

    : BaseSerializer(nullptr, zone), forward_table_(), stack_(zone, 0) {}

~ApiMessageSerializer()

dart::ApiMessageSerializer::~ApiMessageSerializer

(

)

Definition at line 2722 of file message_snapshot.cc.

{}

Member Function Documentation

AddBaseObject()

DART_NOINLINE void dart::ApiMessageSerializer::AddBaseObject ( Dart_CObject *  base_object )

inline

Definition at line 304 of file message_snapshot.cc.

                                                              {
    AssignRef(base_object);
    num_base_objects_++;
  }

AddBaseObjects()

void dart::ApiMessageSerializer::AddBaseObjects

(

)

Definition at line 3240 of file message_snapshot.cc.

                                          {
  AddBaseObject(PredefinedCObjects::cobj_null());
  AddBaseObject(&cobj_sentinel);
  AddBaseObject(&cobj_transition_sentinel);
  AddBaseObject(PredefinedCObjects::cobj_empty_array());
  AddBaseObject(&cobj_dynamic_type);
  AddBaseObject(&cobj_void_type);
  AddBaseObject(&cobj_empty_type_arguments);
  AddBaseObject(&cobj_true);
  AddBaseObject(&cobj_false);
}

AssignRef()

DART_NOINLINE intptr_t dart::ApiMessageSerializer::AssignRef ( Dart_CObject *  object )

inline

Definition at line 308 of file message_snapshot.cc.

                                                         {
    SetObjectId(object, next_ref_index_);
    return next_ref_index_++;
  }

Fail()

bool dart::ApiMessageSerializer::Fail ( const char *  message )

inline

Definition at line 332 of file message_snapshot.cc.

                                 {
    exception_message_ = message;
    return false;
  }

ForwardRef()

void dart::ApiMessageSerializer::ForwardRef ( Dart_CObject *  old, Dart_CObject *  nue  )

inline

Definition at line 312 of file message_snapshot.cc.

                                                        {
    intptr_t id = GetObjectId(nue);
    ASSERT(id != WeakTable::kNoValue);
    SetObjectId(old, id);
    num_written_objects_--;
  }

GetObjectId()

intptr_t dart::ApiMessageSerializer::GetObjectId ( Dart_CObject *  object ) const

inline

Definition at line 299 of file message_snapshot.cc.

                                                   {
    return forward_table_.GetValueExclusive(
        static_cast<ObjectPtr>(reinterpret_cast<uword>(object)));
  }

MarkObjectId()

bool dart::ApiMessageSerializer::MarkObjectId ( Dart_CObject *  object, intptr_t  id  )

inline

Definition at line 287 of file message_snapshot.cc.

                                                       {
    ASSERT(id != WeakTable::kNoValue);
    return forward_table_.MarkValueExclusive(
        static_cast<ObjectPtr>(reinterpret_cast<uword>(object)), id);
  }

Push()

void dart::ApiMessageSerializer::Push

(

Dart_CObject *

object

)

Definition at line 2731 of file message_snapshot.cc.

                                                    {
  if (MarkObjectId(object, kUnallocatedReference)) {
    stack_.Add(object);
    num_written_objects_++;
  }
}

Serialize()

bool dart::ApiMessageSerializer::Serialize

(

Dart_CObject *

root

)

Definition at line 3302 of file message_snapshot.cc.

                                                       {
  AddBaseObjects();
 
  Push(root);
 
  // Strong references only.
  while (stack_.length() > 0) {
    if (!Trace(stack_.RemoveLast())) {
      return false;
    }
  }
 
  intptr_t num_objects = num_base_objects_ + num_written_objects_;
  WriteUnsigned(num_base_objects_);
  WriteUnsigned(num_objects);
 
  for (intptr_t i = 0; i < static_cast<intptr_t>(MessagePhase::kNumPhases);
       i++) {
    intptr_t num_clusters = 0;
    for (MessageSerializationCluster* cluster : clusters_) {
      if (static_cast<intptr_t>(cluster->phase()) != i) continue;
      num_clusters++;
    }
    WriteUnsigned(num_clusters);
    for (MessageSerializationCluster* cluster : clusters_) {
      if (static_cast<intptr_t>(cluster->phase()) != i) continue;
      WriteCluster(cluster);
      cluster->WriteNodesApi(this);
    }
    for (MessageSerializationCluster* cluster : clusters_) {
      if (static_cast<intptr_t>(cluster->phase()) != i) continue;
      cluster->WriteEdgesApi(this);
    }
  }
 
  // We should have assigned a ref to every object we pushed.
  ASSERT((next_ref_index_ - 1) == num_objects);
 
  WriteRef(root);
  return true;
}

SetObjectId()

void dart::ApiMessageSerializer::SetObjectId ( Dart_CObject *  object, intptr_t  id  )

inline

Definition at line 293 of file message_snapshot.cc.

                                                      {
    ASSERT(id != WeakTable::kNoValue);
    forward_table_.SetValueExclusive(
        static_cast<ObjectPtr>(reinterpret_cast<uword>(object)), id);
  }

Trace()

bool dart::ApiMessageSerializer::Trace

(

Dart_CObject *

object

)

Definition at line 2819 of file message_snapshot.cc.

                                                     {
  const bool is_canonical = false;
  intptr_t cid;
  switch (object->type) {
    case Dart_CObject_kNull:
      ForwardRef(object, PredefinedCObjects::cobj_null());
      return true;
    case Dart_CObject_kBool:
      ForwardRef(object, object->value.as_bool ? &cobj_true : &cobj_false);
      return true;
    case Dart_CObject_kInt32:
      cid = Smi::IsValid(object->value.as_int32) ? kSmiCid : kMintCid;
      break;
    case Dart_CObject_kInt64:
      cid = Smi::IsValid(object->value.as_int64) ? kSmiCid : kMintCid;
      break;
    case Dart_CObject_kDouble:
      cid = kDoubleCid;
      break;
    case Dart_CObject_kString: {
      RELEASE_ASSERT(object->value.as_string != nullptr);
      const uint8_t* utf8_str =
          reinterpret_cast<const uint8_t*>(object->value.as_string);
      intptr_t utf8_len = strlen(object->value.as_string);
      if (!Utf8::IsValid(utf8_str, utf8_len)) {
        return Fail("invalid utf8");
      }
      Utf8::Type type = Utf8::kLatin1;
      intptr_t len = Utf8::CodeUnitCount(utf8_str, utf8_len, &type);
      if (len > String::kMaxElements) {
        return Fail("invalid string length");
      }
      cid = type == Utf8::kLatin1 ? kOneByteStringCid : kTwoByteStringCid;
      break;
    }
    case Dart_CObject_kArray:
      cid = kArrayCid;
      if (!Array::IsValidLength(object->value.as_array.length)) {
        return Fail("invalid array length");
      }
      break;
    case Dart_CObject_kTypedData:
      switch (object->value.as_typed_data.type) {
        case Dart_TypedData_kInt8:
          cid = kTypedDataInt8ArrayCid;
          break;
        case Dart_TypedData_kUint8:
          cid = kTypedDataUint8ArrayCid;
          break;
        case Dart_TypedData_kUint8Clamped:
          cid = kTypedDataUint8ClampedArrayCid;
          break;
        case Dart_TypedData_kInt16:
          cid = kTypedDataInt16ArrayCid;
          break;
        case Dart_TypedData_kUint16:
          cid = kTypedDataUint16ArrayCid;
          break;
        case Dart_TypedData_kInt32:
          cid = kTypedDataInt32ArrayCid;
          break;
        case Dart_TypedData_kUint32:
          cid = kTypedDataUint32ArrayCid;
          break;
        case Dart_TypedData_kInt64:
          cid = kTypedDataInt64ArrayCid;
          break;
        case Dart_TypedData_kUint64:
          cid = kTypedDataUint64ArrayCid;
          break;
        case Dart_TypedData_kFloat32:
          cid = kTypedDataFloat32ArrayCid;
          break;
        case Dart_TypedData_kFloat64:
          cid = kTypedDataFloat64ArrayCid;
          break;
        case Dart_TypedData_kInt32x4:
          cid = kTypedDataInt32x4ArrayCid;
          break;
        case Dart_TypedData_kFloat32x4:
          cid = kTypedDataFloat32x4ArrayCid;
          break;
        case Dart_TypedData_kFloat64x2:
          cid = kTypedDataFloat64x2ArrayCid;
          break;
        default:
          return Fail("invalid TypedData type");
      }
      {
        intptr_t len = object->value.as_typed_data.length;
        if (len < 0 || len > TypedData::MaxElements(cid)) {
          return Fail("invalid typeddata length");
        }
      }
      break;
    case Dart_CObject_kExternalTypedData:
      switch (object->value.as_external_typed_data.type) {
        case Dart_TypedData_kInt8:
          cid = kExternalTypedDataInt8ArrayCid;
          break;
        case Dart_TypedData_kUint8:
          cid = kExternalTypedDataUint8ArrayCid;
          break;
        case Dart_TypedData_kUint8Clamped:
          cid = kExternalTypedDataUint8ClampedArrayCid;
          break;
        case Dart_TypedData_kInt16:
          cid = kExternalTypedDataInt16ArrayCid;
          break;
        case Dart_TypedData_kUint16:
          cid = kExternalTypedDataUint16ArrayCid;
          break;
        case Dart_TypedData_kInt32:
          cid = kExternalTypedDataInt32ArrayCid;
          break;
        case Dart_TypedData_kUint32:
          cid = kExternalTypedDataUint32ArrayCid;
          break;
        case Dart_TypedData_kInt64:
          cid = kExternalTypedDataInt64ArrayCid;
          break;
        case Dart_TypedData_kUint64:
          cid = kExternalTypedDataUint64ArrayCid;
          break;
        case Dart_TypedData_kFloat32:
          cid = kExternalTypedDataFloat32ArrayCid;
          break;
        case Dart_TypedData_kFloat64:
          cid = kExternalTypedDataFloat64ArrayCid;
          break;
        case Dart_TypedData_kInt32x4:
          cid = kExternalTypedDataInt32x4ArrayCid;
          break;
        case Dart_TypedData_kFloat32x4:
          cid = kExternalTypedDataFloat32x4ArrayCid;
          break;
        case Dart_TypedData_kFloat64x2:
          cid = kExternalTypedDataFloat64x2ArrayCid;
          break;
        default:
          return Fail("invalid TypedData type");
      }
      {
        intptr_t len = object->value.as_typed_data.length;
        if (len < 0 || len > ExternalTypedData::MaxElements(cid)) {
          return Fail("invalid typeddata length");
        }
      }
      break;
    case Dart_CObject_kUnmodifiableExternalTypedData:
      switch (object->value.as_external_typed_data.type) {
        case Dart_TypedData_kInt8:
          cid = kUnmodifiableTypedDataInt8ArrayViewCid;
          break;
        case Dart_TypedData_kUint8:
          cid = kUnmodifiableTypedDataUint8ArrayViewCid;
          break;
        case Dart_TypedData_kUint8Clamped:
          cid = kUnmodifiableTypedDataUint8ClampedArrayViewCid;
          break;
        case Dart_TypedData_kInt16:
          cid = kUnmodifiableTypedDataInt16ArrayViewCid;
          break;
        case Dart_TypedData_kUint16:
          cid = kUnmodifiableTypedDataUint16ArrayViewCid;
          break;
        case Dart_TypedData_kInt32:
          cid = kUnmodifiableTypedDataInt32ArrayViewCid;
          break;
        case Dart_TypedData_kUint32:
          cid = kUnmodifiableTypedDataUint32ArrayViewCid;
          break;
        case Dart_TypedData_kInt64:
          cid = kUnmodifiableTypedDataInt64ArrayViewCid;
          break;
        case Dart_TypedData_kUint64:
          cid = kUnmodifiableTypedDataUint64ArrayViewCid;
          break;
        case Dart_TypedData_kFloat32:
          cid = kUnmodifiableTypedDataFloat32ArrayViewCid;
          break;
        case Dart_TypedData_kFloat64:
          cid = kUnmodifiableTypedDataFloat64ArrayViewCid;
          break;
        case Dart_TypedData_kInt32x4:
          cid = kUnmodifiableTypedDataInt32x4ArrayViewCid;
          break;
        case Dart_TypedData_kFloat32x4:
          cid = kUnmodifiableTypedDataFloat32x4ArrayViewCid;
          break;
        case Dart_TypedData_kFloat64x2:
          cid = kUnmodifiableTypedDataFloat64x2ArrayViewCid;
          break;
        default:
          return Fail("invalid TypedData type");
      }
      {
        intptr_t len = object->value.as_typed_data.length;
        if (len < 0 || len > TypedData::MaxElements(
                                 cid - kTypedDataCidRemainderUnmodifiable +
                                 kTypedDataCidRemainderInternal)) {
          return Fail("invalid typeddata length");
        }
      }
      break;
    case Dart_CObject_kSendPort:
      cid = kSendPortCid;
      break;
    case Dart_CObject_kCapability:
      cid = kCapabilityCid;
      break;
    case Dart_CObject_kNativePointer:
      cid = kNativePointer;
      break;
    default:
      return Fail("invalid Dart_CObject type");
  }
 
  MessageSerializationCluster* cluster = nullptr;
  for (MessageSerializationCluster* c : clusters_) {
    if (c->cid() == cid) {
      cluster = c;
      break;
    }
  }
  if (cluster == nullptr) {
    cluster = NewClusterForClass(cid, is_canonical);
    clusters_.Add(cluster);
  }
 
  cluster->TraceApi(this, object);
  return true;
}

WriteRef()

void dart::ApiMessageSerializer::WriteRef ( Dart_CObject *  object )

inline

Definition at line 326 of file message_snapshot.cc.

                                      {
    intptr_t index = GetObjectId(object);
    ASSERT(index != WeakTable::kNoValue);
    WriteUnsigned(index);
  }

---

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

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