Lines Matching defs:message
101 // Identifying the index in the message's BaseObject array is sufficient.
175 // If we gather a list of all message ports, and this transferred object
176 // is a message port, add it to that list. This is a bit of an odd case
277 void ThrowDataCloneException(Local<Context> context, Local<String> message) {
279 Local<Value> argv[] = {message,
299 void ThrowDataCloneError(Local<String> message) override {
300 ThrowDataCloneException(context_, message);
442 // Verify that we're not silently overwriting an existing message.
583 void MessagePortData::AddToIncomingQueue(std::shared_ptr<Message> message) {
586 incoming_messages_.emplace_back(std::move(message));
589 Debug(owner_, "Adding message to incoming queue");
646 Debug(this, "Created message port");
659 Debug(this, "Closing message port, data set = %d", static_cast<int>(!!data_));
723 // Get the head of the message queue.
726 Debug(this, "MessagePort has message");
733 // - We are not intending to receive messages, and the message we would
734 // receive is not the final "close" message.
771 // However, the message port may be transferred while it is processing
797 // Catch any exceptions from parsing the message itself (not from
880 // serialize the input message, even if the MessagePort is closed or detached.
903 std::shared_ptr<Message> message,
910 return group_->Dispatch(this, message, error);
1009 // want to serialize the message to ensure spec-compliant behavior w.r.t.
1300 // the end of the stream, after the main message has been read.
1360 std::shared_ptr<Message> message,
1378 if (size() > 2 && message->has_transferables()) {
1388 for (const auto& transferable : message->transferables()) {
1397 port->AddToIncomingQueue(message);