Home
last modified time | relevance | path

Searched refs:virtual_conn (Results 1 – 12 of 12) sorted by relevance

/external/openscreen/cast/common/channel/
Dconnection_namespace_handler.cc167 VirtualConnection virtual_conn{std::move(message.destination_id()), in HandleConnect() local
170 if (!vc_policy_->IsConnectionAllowed(virtual_conn)) { in HandleConnect()
171 SendClose(std::move(virtual_conn)); in HandleConnect()
182 SendClose(std::move(virtual_conn)); in HandleConnect()
224 OSP_DVLOG << "Connection opened: " << virtual_conn.local_id << ", " in HandleConnect()
225 << virtual_conn.peer_id << ", " << virtual_conn.socket_id; in HandleConnect()
231 SendConnectedResponse(virtual_conn, negotiated_version.value()); in HandleConnect()
234 vc_router_->AddConnection(std::move(virtual_conn), std::move(data)); in HandleConnect()
276 void ConnectionNamespaceHandler::SendConnect(VirtualConnection virtual_conn) { in SendConnect() argument
278 MakeConnectMessage(virtual_conn.local_id, virtual_conn.peer_id); in SendConnect()
[all …]
Dconnection_namespace_handler.h42 const VirtualConnection& virtual_conn) const = 0;
78 void SendConnect(VirtualConnection virtual_conn);
79 void SendClose(VirtualConnection virtual_conn);
80 void SendConnectedResponse(const VirtualConnection& virtual_conn,
Dvirtual_connection_router.cc140 Error VirtualConnectionRouter::Send(VirtualConnection virtual_conn, in Send() argument
142 if (virtual_conn.peer_id == kBroadcastId) { in Send()
143 return BroadcastFromLocalPeer(std::move(virtual_conn.local_id), in Send()
148 !GetConnectionData(virtual_conn)) { in Send()
151 auto it = sockets_.find(virtual_conn.socket_id); in Send()
155 message.set_source_id(std::move(virtual_conn.local_id)); in Send()
156 message.set_destination_id(std::move(virtual_conn.peer_id)); in Send()
Dconnection_namespace_handler_unittest.cc41 (const VirtualConnection& virtual_conn),
96 Invoke([](const VirtualConnection& virtual_conn) { return true; })); in SetUp() argument
166 Invoke([](const VirtualConnection& virtual_conn) { return false; })); in TEST_F() argument
Dvirtual_connection_router.h97 Error Send(VirtualConnection virtual_conn,
Dvirtual_connection_router_unittest.cc408 const VirtualConnection& virtual_conn) const final { in TEST_F()
/external/openscreen/cast/receiver/channel/
Ddevice_auth_namespace_handler.cc83 const VirtualConnection virtual_conn{ in OnMessage() local
94 router->Send(virtual_conn, GenerateErrorMessage( in OnMessage()
108 router->Send(virtual_conn, GenerateErrorMessage(AuthError::INTERNAL_ERROR)); in OnMessage()
138 router->Send(virtual_conn, GenerateErrorMessage(AuthError::INTERNAL_ERROR)); in OnMessage()
154 router->Send(virtual_conn, std::move(response)); in OnMessage()
/external/openscreen/cast/sender/
Dcast_platform_client.cc73 VirtualConnection virtual_conn{sender_id_, kPlatformReceiverId, socket_id}; in RequestAppAvailability() local
74 if (!virtual_conn_router_->GetConnectionData(virtual_conn)) { in RequestAppAvailability()
75 virtual_conn_router_->AddConnection(virtual_conn, in RequestAppAvailability()
79 virtual_conn_router_->Send(std::move(virtual_conn), in RequestAppAvailability()
/external/openscreen/cast/receiver/
Dapplication_agent.cc177 const VirtualConnection& virtual_conn) const { in IsConnectionAllowed()
178 if (virtual_conn.local_id == kPlatformReceiverId) { in IsConnectionAllowed()
186 return virtual_conn.local_id == message_port_.client_sender_id(); in IsConnectionAllowed()
Dapplication_agent.h119 bool IsConnectionAllowed(const VirtualConnection& virtual_conn) const final;
/external/openscreen/cast/standalone_sender/
Dlooping_file_cast_agent.h120 const VirtualConnection& virtual_conn) const override;
Dlooping_file_cast_agent.cc142 const VirtualConnection& virtual_conn) const { in IsConnectionAllowed()