/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/openscreen/src/cast/streaming/ |
H A D | receiver_session_unittest.cc | 302 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 D | sender_session_unittest.cc | 140 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 D | session_messager.cc | 20 : 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 D | session_messager.h | 69 MessagePort* const message_port_; variable
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/blink/renderer/core/streams/ |
H A D | transferable_streams.cc | 303 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 D | application_agent.cc | 55 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 D | application_agent.h | 166 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 D | transferable_streams.cc | 430 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 D | scoped_api_binding.cc | 46 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 D | scoped_api_binding.h | 87 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 D | looping_file_cast_agent.cc | 29 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 D | looping_file_cast_agent.h | 100 SerialDeletePtr<CastSocketMessagePort> message_port_; variable
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/fuchsia/cast_streaming/ |
H A D | cast_message_port_impl.cc | 100 : 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 D | cast_message_port_impl.h | 49 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 D | receiver_session.cc | 105 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 D | receiver_session.h | 152 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 D | cast_agent.cc | 95 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 D | cast_agent.h | 67 CastSocketMessagePort message_port_; variable
|