Lines Matching refs:MessagePortData
569 MessagePortData::MessagePortData(MessagePort* owner)
573 MessagePortData::~MessagePortData() {
578 void MessagePortData::MemoryInfo(MemoryTracker* tracker) const {
583 void MessagePortData::AddToIncomingQueue(std::shared_ptr<Message> message) {
594 void MessagePortData::Entangle(MessagePortData* a, MessagePortData* b) {
599 void MessagePortData::Disentangle() {
616 data_(new MessagePortData(this)) {
682 std::unique_ptr<MessagePortData> data,
688 // the MessagePortData to it.
709 // If the existing MessagePortData object had pending messages, this is
843 std::unique_ptr<MessagePortData> MessagePort::Detach() {
861 BaseObjectPtr<BaseObject> MessagePortData::Deserialize(
867 static_unique_pointer_cast<MessagePortData>(std::move(self))) };
902 Maybe<bool> MessagePortData::Dispatch(
907 *error = "MessagePortData is not entangled.";
1110 std::unique_ptr<MessagePortData> data;
1122 MessagePortData::Entangle(a->data_.get(), b->data_.get());
1125 void MessagePort::Entangle(MessagePort* a, MessagePortData* b) {
1126 MessagePortData::Entangle(a->data_.get(), b);
1359 MessagePortData* source,
1365 // The source MessagePortData is not part of this group.
1384 for (MessagePortData* port : ports_) {
1403 void SiblingGroup::Entangle(MessagePortData* port) {
1407 void SiblingGroup::Entangle(std::initializer_list<MessagePortData*> ports) {
1409 for (MessagePortData* data : ports) {
1416 void SiblingGroup::Disentangle(MessagePortData* data) {