Lines Matching refs:port
176 // is a message port, add it to that list. This is a bit of an odd case
499 "Transfer list contains source port"));
646 Debug(this, "Created message port");
659 Debug(this, "Closing message port, data set = %d", static_cast<int>(!!data_));
692 MessagePort* port = new MessagePort(env, context, instance);
693 CHECK_NOT_NULL(port);
694 if (port->IsHandleClosing()) {
701 port->Detach();
702 port->data_ = std::move(data);
707 Mutex::ScopedLock lock(port->data_->mutex_);
708 port->data_->owner_ = port;
711 port->TriggerAsync();
713 sibling_group->Entangle(port->data_.get());
715 return port;
771 // However, the message port may be transferred while it is processing
879 // Per spec, we need to both check if transfer list has the source port, and
1007 MessagePort* port = Unwrap<MessagePort>(args.This());
1011 if (port == nullptr || port->IsHandleClosing()) {
1017 Maybe<bool> res = port->PostMessage(env, context, args[0], transfer_list);
1036 MessagePort* port;
1037 ASSIGN_OR_RETURN_UNWRAP(&port, args.This());
1038 if (!port->data_) {
1041 port->Start();
1045 MessagePort* port;
1047 ASSIGN_OR_RETURN_UNWRAP(&port, args[0].As<Object>());
1048 if (!port->data_) {
1051 port->Stop();
1061 MessagePort* port;
1062 ASSIGN_OR_RETURN_UNWRAP(&port, args[0].As<Object>());
1063 port->OnMessage(MessageProcessingMode::kForceReadMessages);
1071 "The \"port\" argument must be a MessagePort instance");
1073 MessagePort* port = Unwrap<MessagePort>(args[0].As<Object>());
1074 if (port == nullptr) {
1075 // Return 'no messages' for a closed port.
1081 MaybeLocal<Value> payload = port->ReceiveMessage(
1082 port->object()->GetCreationContext().ToLocalChecked(),
1093 "The \"port\" argument must be a MessagePort instance");
1095 MessagePort* port = Unwrap<MessagePort>(args[0].As<Object>());
1096 if (port == nullptr || port->IsHandleClosing()) {
1111 if (!port->IsDetached())
1112 data = port->Detach();
1384 for (MessagePortData* port : ports_) {
1385 if (port == source)
1389 if (port == transferable.get()) {
1391 *error = "The target port was posted to itself, and the "
1397 port->AddToIncomingQueue(message);
1403 void SiblingGroup::Entangle(MessagePortData* port) {
1404 Entangle({ port });
1423 // If this is an anonymous group and there's another port, close it.
1471 MessagePort* port =
1473 if (port != nullptr) {
1474 args.GetReturnValue().Set(port->object());