Home
last modified time | relevance | path

Searched refs:ports_ (Results 1 – 2 of 2) sorted by relevance

/third_party/node/src/
Dnode_messaging.h150 size_t size() const { return ports_.size(); } in size()
155 std::set<MessagePortData*> ports_; variable
Dnode_messaging.cc1366 if (ports_.find(source) == ports_.end()) { in Dispatch()
1384 for (MessagePortData* port : ports_) { in Dispatch()
1410 ports_.insert(data); in Entangle()
1419 ports_.erase(data); in Disentangle()
1425 (*(ports_.begin()))->AddToIncomingQueue(std::make_shared<Message>()); in Disentangle()