Searched refs:MessagePortData (Results 1 – 4 of 4) sorted by relevance
17 class MessagePortData; variable140 MessagePortData* source,144 void Entangle(MessagePortData* data);145 void Entangle(std::initializer_list<MessagePortData*> data);146 void Disentangle(MessagePortData* data);155 std::set<MessagePortData*> ports_;168 class MessagePortData : public TransferData {170 explicit MessagePortData(MessagePort* owner);171 ~MessagePortData() override;173 MessagePortData(MessagePortData&& other) = delete;[all …]
569 MessagePortData::MessagePortData(MessagePort* owner) in MessagePortData() function in node::worker::MessagePortData573 MessagePortData::~MessagePortData() { in ~MessagePortData()578 void MessagePortData::MemoryInfo(MemoryTracker* tracker) const { in MemoryInfo()583 void MessagePortData::AddToIncomingQueue(std::shared_ptr<Message> message) { in AddToIncomingQueue()594 void MessagePortData::Entangle(MessagePortData* a, MessagePortData* b) { in Entangle()599 void MessagePortData::Disentangle() { in Disentangle()616 data_(new MessagePortData(this)) { in MessagePort()682 std::unique_ptr<MessagePortData> data, in New()843 std::unique_ptr<MessagePortData> MessagePort::Detach() { in Detach()861 BaseObjectPtr<BaseObject> MessagePortData::Deserialize( in Deserialize()[all …]
114 std::unique_ptr<MessagePortData> child_port_data_;
74 child_port_data_ = std::make_unique<MessagePortData>(nullptr); in Worker()381 std::unique_ptr<MessagePortData> data; in CreateEnvMessagePort()