Home
last modified time | relevance | path

Searched refs:connection_id (Results 1 – 25 of 45) sorted by relevance

12

/external/openscreen/osp/impl/quic/
Dquic_service_common.cc32 uint64_t connection_id) in QuicProtocolConnection() argument
33 : ProtocolConnection(endpoint_id, connection_id), owner_(owner) {} in QuicProtocolConnection()
62 connection_id(protocol_connection->id()), in ServiceStreamPair()
99 uint64_t connection_id) { in OnCryptoHandshakeComplete() argument
100 endpoint_id_ = parent_->OnCryptoHandshakeComplete(this, connection_id); in OnCryptoHandshakeComplete()
106 uint64_t connection_id, in OnIncomingStream() argument
115 void ServiceConnectionDelegate::OnConnectionClosed(uint64_t connection_id) { in OnConnectionClosed() argument
117 parent_->OnConnectionClosed(endpoint_id_, connection_id); in OnConnectionClosed()
121 uint64_t connection_id, in NextStreamDelegate() argument
136 parent_->OnDataReceived(endpoint_id_, stream_pair.connection_id, in OnReceived()
[all …]
Dquic_service_common.h39 uint64_t connection_id);
64 uint64_t connection_id; member
77 uint64_t connection_id) = 0;
81 uint64_t connection_id) = 0;
83 uint64_t connection_id,
105 void OnCryptoHandshakeComplete(uint64_t connection_id) override;
106 void OnIncomingStream(uint64_t connection_id,
108 void OnConnectionClosed(uint64_t connection_id) override;
109 QuicStream::Delegate* NextStreamDelegate(uint64_t connection_id,
Dquic_connection.h47 virtual void OnCryptoHandshakeComplete(uint64_t connection_id) = 0;
51 virtual void OnIncomingStream(uint64_t connection_id,
60 virtual void OnConnectionClosed(uint64_t connection_id) = 0;
64 virtual QuicStream::Delegate* NextStreamDelegate(uint64_t connection_id,
Dquic_server.h57 uint64_t connection_id) override;
61 uint64_t connection_id) override;
63 uint64_t connection_id,
Dquic_connection_impl.cc132 delegate_->OnCryptoHandshakeComplete(session_->connection_id()); in OnCryptoHandshakeComplete()
138 delegate_->NextStreamDelegate(session_->connection_id(), stream->id()), in OnIncomingStream()
141 delegate_->OnIncomingStream(session_->connection_id(), in OnIncomingStream()
151 delegate_->OnConnectionClosed(session_->connection_id()); in OnConnectionClosed()
Dquic_client.h63 uint64_t connection_id) override;
67 uint64_t connection_id) override;
69 uint64_t connection_id,
Dquic_server.cc116 uint64_t connection_id) { in OnCryptoHandshakeComplete() argument
137 uint64_t connection_id) { in OnConnectionClosed() argument
151 uint64_t connection_id, in OnDataReceived() argument
155 demuxer_->OnStreamData(endpoint_id, connection_id, data, data_size); in OnDataReceived()
Dquic_server_unittest.cc93 message.connection_id = 7; in SendTestMessage()
106 uint64_t endpoint_id, uint64_t connection_id, in SendTestMessage()
119 EXPECT_EQ(received_message.connection_id, message.connection_id); in SendTestMessage()
Dquic_client.cc113 uint64_t connection_id) { in OnCryptoHandshakeComplete() argument
146 uint64_t connection_id) { in OnConnectionClosed() argument
161 uint64_t connection_id, in OnDataReceived() argument
164 demuxer_->OnStreamData(endpoint_id, connection_id, data, data_size); in OnDataReceived()
Dquic_client_unittest.cc89 message.connection_id = 7; in SendTestMessage()
103 uint64_t endpoint_id, uint64_t connection_id, in SendTestMessage()
116 EXPECT_EQ(received_message.connection_id, message.connection_id); in SendTestMessage()
/external/openscreen/osp/impl/presentation/
Dpresentation_connection.cc60 uint64_t connection_id, in OnConnected() argument
66 connection_id_ = connection_id; in OnConnected()
111 cbor_message.connection_id = connection_id_.value(); in SendString()
127 cbor_message.connection_id = connection_id_.value(); in SendBinary()
168 connections_.emplace(connection->connection_id(), connection); in AddConnection()
174 auto entry = connections_.find(connection->connection_id()); in RemoveConnection()
185 uint64_t connection_id, in OnStreamMessage() argument
200 Connection* connection = GetConnection(message.connection_id); in OnStreamMessage()
233 Connection* connection = GetConnection(request.connection_id); in OnStreamMessage()
268 Connection* connection = GetConnection(event.connection_id); in OnStreamMessage()
[all …]
Dpresentation_receiver.cc104 uint64_t connection_id, in OnStreamMessage() argument
405 response.connection_id = connection->connection_id(); in OnPresentationStarted()
409 connection->OnConnected(initiation_response.connection_id, in OnPresentationStarted()
435 connection_response.value()->connection_id, in OnConnectionCreated()
447 response.connection_id = connection->connection_id(); in OnConnectionCreated()
467 event.connection_id = connection->connection_id(); in CloseConnection()
Dpresentation_controller.cc185 controller_->OpenConnection(response->connection_id, endpoint_id, service_id_, in OnMatchedResponse()
242 request->connection->OnConnected(response->connection_id, endpoint_id, in OnMatchedResponse()
279 << request->request.connection_id << ": " << error; in OnError()
519 OSP_DCHECK(connection_manager_->GetConnection(connection->connection_id())) in ReconnectConnection()
545 << connection->connection_id(); in CloseConnection()
549 request.request.connection_id = connection->connection_id(); in CloseConnection()
621 uint64_t connection_id,
650 uint64_t connection_id, in OnStreamMessage() argument
697 uint64_t connection_id, in OpenConnection() argument
703 connection->OnConnected(connection_id, endpoint_id, in OpenConnection()
Dpresentation_connection_unittest.cc103 const uint64_t connection_id = 13; in TEST_F() local
168 controller.OnConnected(connection_id, receiver_endpoint_id, in TEST_F()
170 receiver.OnConnected(connection_id, controller_endpoint_id, in TEST_F()
Dpresentation_receiver_unittest.cc199 EXPECT_EQ(connection.connection_id(), response.connection_id); in TEST_F()
/external/openscreen/osp/impl/
Dmessage_demuxer.cc170 auto connection_id = stream_map.first; in SetDefaultMessageTypeWatch() local
172 HandleStreamBufferLoop(endpoint_id, connection_id, callbacks_entry, in SetDefaultMessageTypeWatch()
181 uint64_t connection_id, in OnStreamData() argument
184 OSP_VLOG << __func__ << ": [" << endpoint_id << ", " << connection_id in OnStreamData()
188 stream_map.erase(connection_id); in OnStreamData()
193 std::vector<uint8_t>& buffer = stream_map[connection_id]; in OnStreamData()
197 HandleStreamBufferLoop(endpoint_id, connection_id, callbacks_entry, &buffer); in OnStreamData()
200 stream_map.erase(connection_id); in OnStreamData()
216 uint64_t connection_id, in HandleStreamBufferLoop() argument
225 result = HandleStreamBuffer(endpoint_id, connection_id, in HandleStreamBufferLoop()
[all …]
/external/autotest/server/site_tests/network_WiFi_ConnectionIdentifier/
Dnetwork_WiFi_ConnectionIdentifier.py55 connection_id = self._get_service_connection_id(ssid)
57 expected_connection_id != connection_id):
60 expected_connection_id, connection_id))
61 return connection_id
/external/openscreen/osp/public/
Dmessage_demuxer.h37 uint64_t connection_id,
85 uint64_t connection_id,
100 uint64_t connection_id,
107 uint64_t connection_id,
Dmessage_demuxer_unittest.cc77 uint64_t endpoint_id, uint64_t connection_id, in TEST_F()
111 uint64_t endpoint_id, uint64_t connection_id, in TEST_F()
140 uint64_t endpoint_id, uint64_t connection_id, in TEST_F()
175 uint64_t endpoint_id, uint64_t connection_id, in TEST_F()
191 uint64_t endpoint_id, uint64_t connection_id, in TEST_F() argument
211 uint64_t endpoint_id, uint64_t connection_id, in TEST_F() argument
241 uint64_t endpoint_id, uint64_t connection_id, in TEST_F()
252 uint64_t endpoint_id, uint64_t connection_id, in TEST_F() argument
290 uint64_t endpoint_id, uint64_t connection_id, in TEST_F()
322 uint64_t endpoint_id, uint64_t connection_id, in TEST_F()
/external/openscreen/osp/public/presentation/
Dpresentation_connection.h136 uint64_t connection_id() const { in connection_id() function
159 void OnConnected(uint64_t connection_id,
195 uint64_t connection_id,
201 Connection* GetConnection(uint64_t connection_id);
Dpresentation_receiver.h96 uint64_t connection_id,
108 uint64_t connection_id; member
/external/openscreen/osp/msgs/
Dmessages_unittest.cc147 message.connection_id = 1234; in TEST()
161 EXPECT_EQ(message.connection_id, decoded_message.connection_id); in TEST()
169 message.connection_id = 1234; in TEST()
183 EXPECT_EQ(message.connection_id, decoded_message.connection_id); in TEST()
/external/kernel-headers/original/uapi/linux/caif/
Dcaif_socket.h152 __u32 connection_id; member
156 __u32 connection_id; member
/external/openscreen/osp/impl/quic/testing/
Dfake_quic_connection.cc49 uint64_t connection_id, in FakeQuicConnection() argument
53 connection_id_(connection_id) {} in FakeQuicConnection()
/external/openscreen/osp/public/testing/
Dmessage_demuxer_test_support.h21 uint64_t connection_id,

12