Home
last modified time | relevance | path

Searched refs:message_port_ (Results 1 – 18 of 18) sorted by relevance

/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/openscreen/src/cast/streaming/
H A Dreceiver_session_unittest.cc302 std::unique_ptr<SimpleMessagePort> message_port_; member in openscreen::cast::ReceiverSessionTest
334 message_port_->ReceiveMessage(kValidOfferMessage); in TEST_F()
391 message_port_->ReceiveMessage(kValidOfferMessage); in TEST_F()
419 message_port_->ReceiveMessage(kValidOfferMessage); in TEST_F()
474 message_port_->ReceiveMessage(kNoAudioOfferMessage); in TEST_F()
511 message_port_->ReceiveMessage(kNoVideoOfferMessage); in TEST_F()
589 message_port_->ReceiveMessage(kUnknownTypeMessage); in TEST_F()
594 message_port_->ReceiveMessage(kInvalidTypeMessage); in TEST_F()
612 message_port_->ReceiveMessage(kNoAudioOfferMessage); in TEST_F()
613 message_port_->ReceiveMessage(kValidOfferMessage); in TEST_F()
[all …]
H A Dsender_session_unittest.cc140 message_port_ = std::make_unique<SimpleMessagePort>(); in SetUp()
202 std::unique_ptr<SimpleMessagePort> message_port_; member in openscreen::cast::SenderSessionTest
252 const auto& messages = message_port_->posted_messages(); in TEST_F()
266 const auto& messages = message_port_->posted_messages(); in TEST_F()
280 const auto& messages = message_port_->posted_messages(); in TEST_F()
293 const auto& messages = message_port_->posted_messages(); in TEST_F()
335 message_port_->ReceiveMessage(answer); in TEST_F()
352 message_port_->ReceiveMessage(kMalformedAnswerMessage); in TEST_F()
380 message_port_->ReceiveMessage(kMissingAnswerMessage); in TEST_F()
398 message_port_->ReceiveMessage(kUnknownTypeMessage); in TEST_F()
[all …]
H A Dsession_messager.cc20 : message_port_(message_port), error_callback_(std::move(cb)) { in SessionMessager()
21 OSP_DCHECK(message_port_); in SessionMessager()
22 message_port_->SetClient(this, source_id); in SessionMessager()
26 message_port_->ResetClient(); in ~SessionMessager()
57 message_port_->PostMessage(message.sender_id, message.message_namespace, in SendMessage()
H A Dsession_messager.h69 MessagePort* const message_port_; variable
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/blink/renderer/core/streams/
H A Dtransferable_streams.cc303 message_port_(port), in CrossRealmTransformWritable()
316 visitor->Trace(message_port_); in Trace()
460 writable_->message_port_->close(); in Run()
504 writable_->message_port_->close(); in Run()
538 message_port_->setOnmessage( in CreateWritableStream()
542 message_port_->setOnmessageerror( in CreateWritableStream()
635 visitor->Trace(message_port_); in Trace()
750 message_port_->setOnmessage( in CreateReadableStream()
754 message_port_->setOnmessageerror( in CreateReadableStream()
808 message_port_->close(); in HandleMessage()
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/openscreen/src/cast/receiver/
H A Dapplication_agent.cc55 message_port_(&router_) { in ApplicationAgent()
127 if (message_port_.GetSocketId() == ToCastSocketId(socket) && in OnMessage()
128 !message_port_.client_sender_id().empty() && in OnMessage()
130 message_port_.OnMessage(router, socket, std::move(message)); in OnMessage()
186 if (message_port_.GetSocketId() == ToCastSocketId(socket)) { in OnClose()
193 if (message_port_.GetSocketId() == ToCastSocketId(socket)) { in OnError()
314 message_port_.SetSocket({}); in SwitchToApplication()
321 message_port_.SetSocket(socket->GetWeakPtr()); in SwitchToApplication()
328 message_port_.SetSocket({}); in SwitchToApplication()
334 if (fallback_app->Launch(app_id, {}, &message_port_)) { in SwitchToApplication()
[all …]
H A Dapplication_agent.h166 CastSocketMessagePort message_port_; variable
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/blink/renderer/core/streams/
H A Dtransferable_streams.cc430 message_port_(port), in CrossRealmTransformWritable()
443 visitor->Trace(message_port_); in Trace()
570 writable_->message_port_->close(); in Run()
621 message_port_->setOnmessage( in CreateWritableStream()
623 message_port_->setOnmessageerror( in CreateWritableStream()
685 message_port_(port), in CrossRealmTransformReadable()
698 visitor->Trace(message_port_); in Trace()
792 message_port_->setOnmessage( in CreateReadableStream()
794 message_port_->setOnmessageerror( in CreateReadableStream()
834 message_port_->close(); in HandleMessage()
[all …]
/dports/www/chromium-legacy/chromium-88.0.4324.182/components/cast/api_bindings/
H A Dscoped_api_binding.cc46 message_port_ = std::move(port); in OnPortConnected()
47 message_port_->SetReceiver(this); in OnPortConnected()
55 if (!message_port_->CanPostMessage()) { in SendMessage()
61 if (!message_port_->PostMessage(data_utf8.as_string())) { in SendMessage()
H A Dscoped_api_binding.h87 std::unique_ptr<cast_api_bindings::MessagePort> message_port_; variable
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/openscreen/src/cast/standalone_sender/
H A Dlooping_file_cast_agent.cc29 message_port_ = in LoopingFileCastAgent()
77 message_port_->SetSocket(socket->GetWeakPtr()); in OnConnected()
128 message_port_.get()); in CreateAndStartSession()
147 router_->CloseSocket(message_port_->GetSocketId()); in StopCurrentSession()
148 message_port_->SetSocket(nullptr); in StopCurrentSession()
H A Dlooping_file_cast_agent.h100 SerialDeletePtr<CastSocketMessagePort> message_port_; variable
/dports/www/chromium-legacy/chromium-88.0.4324.182/fuchsia/cast_streaming/
H A Dcast_message_port_impl.cc100 : message_port_(std::move(message_port)) { in CastMessagePortImpl()
102 message_port_->SetReceiver(this); in CastMessagePortImpl()
111 if (message_port_) in MaybeClose()
112 message_port_.reset(); in MaybeClose()
184 if (!message_port_) in PostMessage()
189 message_port_->PostMessage( in PostMessage()
H A Dcast_message_port_impl.h49 std::unique_ptr<cast_api_bindings::MessagePort> message_port_; variable
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/openscreen/src/cast/streaming/
H A Dreceiver_session.cc105 message_port_(message_port), in ReceiverSession()
109 OSP_DCHECK(message_port_); in ReceiverSession()
112 message_port_->SetClient(this); in ReceiverSession()
117 message_port_->SetClient(nullptr); in ~ReceiverSession()
294 message_port_->PostMessage(message->sender_id, message->message_namespace, in SendMessage()
H A Dreceiver_session.h152 MessagePort* const message_port_; variable
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/openscreen/src/cast/standalone_receiver/
H A Dcast_agent.cc95 std::make_unique<ReceiverSocketFactory>(this, &message_port_); in Start()
124 message_port_.SetSocket(std::move(socket)); in OnConnected()
128 controller_.get(), environment_.get(), &message_port_, in OnConnected()
H A Dcast_agent.h67 CastSocketMessagePort message_port_; variable