Home
last modified time | relevance | path

Searched refs:endpoint_id (Results 1 – 25 of 39) sorted by relevance

12

/external/openscreen/osp/impl/
Dmessage_demuxer.cc80 uint64_t endpoint_id, in MessageWatch() argument
84 endpoint_id_(endpoint_id), in MessageWatch()
129 uint64_t endpoint_id, in WatchMessageType() argument
132 auto callbacks_entry = message_callbacks_.find(endpoint_id); in WatchMessageType()
136 .emplace(endpoint_id, std::map<msgs::Type, MessageCallback*>{}) in WatchMessageType()
142 auto endpoint_entry = buffers_.find(endpoint_id); in WatchMessageType()
149 HandleStreamBufferLoop(endpoint_id, buffer.first, callbacks_entry, in WatchMessageType()
154 return MessageWatch(this, false, endpoint_id, message_type); in WatchMessageType()
164 auto endpoint_id = endpoint_buffers.first; in SetDefaultMessageTypeWatch() local
171 auto callbacks_entry = message_callbacks_.find(endpoint_id); in SetDefaultMessageTypeWatch()
[all …]
/external/openscreen/osp/impl/quic/
Dquic_server.cc75 for (uint64_t endpoint_id : delete_connections_) { in Cleanup() local
76 auto it = connections_.find(endpoint_id); in Cleanup()
90 uint64_t endpoint_id) { in CreateProtocolConnection() argument
94 auto connection_entry = connections_.find(endpoint_id); in CreateProtocolConnection()
100 connection_entry->second.delegate.get(), endpoint_id); in CreateProtocolConnection()
107 auto connection_entry = connections_.find(connection->endpoint_id()); in OnConnectionDestroyed()
124 uint64_t endpoint_id = next_endpoint_id_++; in OnCryptoHandshakeComplete() local
125 endpoint_map_[endpoint] = endpoint_id; in OnCryptoHandshakeComplete()
126 connections_.emplace(endpoint_id, std::move(connection_data)); in OnCryptoHandshakeComplete()
127 return endpoint_id; in OnCryptoHandshakeComplete()
[all …]
Dquic_client.cc58 for (uint64_t endpoint_id : delete_connections_) { in Cleanup() local
59 auto it = connections_.find(endpoint_id); in Cleanup()
89 uint64_t endpoint_id) { in CreateProtocolConnection() argument
92 auto connection_entry = connections_.find(endpoint_id); in CreateProtocolConnection()
97 connection_entry->second.delegate.get(), endpoint_id); in CreateProtocolConnection()
104 auto connection_entry = connections_.find(connection->endpoint_id()); in OnConnectionDestroyed()
121 uint64_t endpoint_id = next_endpoint_id_++; in OnCryptoHandshakeComplete() local
122 endpoint_map_[endpoint] = endpoint_id; in OnCryptoHandshakeComplete()
123 connections_.emplace(endpoint_id, std::move(connection_data)); in OnCryptoHandshakeComplete()
129 endpoint_id); in OnCryptoHandshakeComplete()
[all …]
Dquic_server_unittest.cc106 uint64_t endpoint_id, uint64_t connection_id, in SendTestMessage()
149 server_->CreateProtocolConnection(connection1->endpoint_id()); in TEST_F()
196 uint64_t endpoint_id = connection->endpoint_id(); in TEST_F() local
197 EXPECT_EQ(1u, server_->endpoint_request_ids()->GetNextRequestId(endpoint_id)); in TEST_F()
198 EXPECT_EQ(3u, server_->endpoint_request_ids()->GetNextRequestId(endpoint_id)); in TEST_F()
203 EXPECT_EQ(5u, server_->endpoint_request_ids()->GetNextRequestId(endpoint_id)); in TEST_F()
206 EXPECT_EQ(1u, server_->endpoint_request_ids()->GetNextRequestId(endpoint_id)); in TEST_F()
Dquic_client_unittest.cc103 uint64_t endpoint_id, uint64_t connection_id, in SendTestMessage()
192 connection2 = client_->CreateProtocolConnection(connection1->endpoint_id()); in TEST_F()
223 connection2 = client_->CreateProtocolConnection(connection1->endpoint_id()); in TEST_F()
257 const uint64_t endpoint_id = connection->endpoint_id(); in TEST_F() local
258 EXPECT_EQ(0u, client_->endpoint_request_ids()->GetNextRequestId(endpoint_id)); in TEST_F()
259 EXPECT_EQ(2u, client_->endpoint_request_ids()->GetNextRequestId(endpoint_id)); in TEST_F()
264 EXPECT_EQ(4u, client_->endpoint_request_ids()->GetNextRequestId(endpoint_id)); in TEST_F()
267 EXPECT_EQ(0u, client_->endpoint_request_ids()->GetNextRequestId(endpoint_id)); in TEST_F()
Dquic_client.h56 uint64_t endpoint_id) override;
66 void OnConnectionClosed(uint64_t endpoint_id,
68 void OnDataReceived(uint64_t endpoint_id,
94 uint64_t endpoint_id);
Dquic_service_common.cc20 uint64_t endpoint_id) { in FromExisting() argument
21 OSP_VLOG << "QUIC stream created for endpoint " << endpoint_id; in FromExisting()
23 auto pc = std::make_unique<QuicProtocolConnection>(owner, endpoint_id, in FromExisting()
31 uint64_t endpoint_id, in QuicProtocolConnection() argument
33 : ProtocolConnection(endpoint_id, connection_id), owner_(owner) {} in QuicProtocolConnection()
Dquic_service_common.h35 uint64_t endpoint_id);
38 uint64_t endpoint_id,
80 virtual void OnConnectionClosed(uint64_t endpoint_id,
82 virtual void OnDataReceived(uint64_t endpoint_id,
Dquic_server.h50 uint64_t endpoint_id) override;
60 void OnConnectionClosed(uint64_t endpoint_id,
62 void OnDataReceived(uint64_t endpoint_id,
/external/openscreen/osp/impl/presentation/
Dpresentation_receiver.cc103 ErrorOr<size_t> Receiver::OnStreamMessage(uint64_t endpoint_id, in OnStreamMessage() argument
133 response, GetProtocolConnection(endpoint_id).get()); in OnStreamMessage()
159 response, GetProtocolConnection(endpoint_id).get()); in OnStreamMessage()
174 /* .endpoint_id = */ endpoint_id}; in OnStreamMessage()
179 endpoint_id, request.headers); in OnStreamMessage()
189 response, GetProtocolConnection(endpoint_id).get()); in OnStreamMessage()
225 response, GetProtocolConnection(endpoint_id).get()); in OnStreamMessage()
242 this->GetNextConnectionId(), endpoint_id}); in OnStreamMessage()
244 request.request_id, presentation_id, endpoint_id); in OnStreamMessage()
257 response, GetProtocolConnection(endpoint_id).get()); in OnStreamMessage()
[all …]
Dpresentation_controller.cc78 uint64_t endpoint_id) override;
85 uint64_t endpoint_id) override;
91 uint64_t endpoint_id) override;
97 uint64_t endpoint_id) override;
166 uint64_t endpoint_id) { in OnMatchedResponse() argument
185 controller_->OpenConnection(response->connection_id, endpoint_id, service_id_, in OnMatchedResponse()
189 ->CreateProtocolConnection(endpoint_id)); in OnMatchedResponse()
219 uint64_t endpoint_id) { in OnMatchedResponse() argument
241 ->CreateProtocolConnection(endpoint_id); in OnMatchedResponse()
242 request->connection->OnConnected(response->connection_id, endpoint_id, in OnMatchedResponse()
[all …]
Dpresentation_common.cc13 uint64_t endpoint_id) { in GetProtocolConnection() argument
16 ->CreateProtocolConnection(endpoint_id); in GetProtocolConnection()
Durl_availability_requester.cc43 uint64_t GetNextRequestId(const uint64_t endpoint_id) { in GetNextRequestId() argument
47 ->GetNextRequestId(endpoint_id); in GetNextRequestId()
210 const uint64_t request_id = GetNextRequestId(endpoint_id); in RequestUrlAvailabilities()
240 endpoint_id, msgs::Type::kPresentationUrlAvailabilityEvent, this); in SendRequest()
244 endpoint_id, msgs::Type::kPresentationUrlAvailabilityResponse, this); in SendRequest()
328 const uint64_t new_request_id = GetNextRequestId(endpoint_id); in RemoveUnobservedRequests()
393 endpoint_id = connection->endpoint_id(); in OnConnectionOpened()
426 uint64_t endpoint_id, in OnStreamMessage() argument
/external/openscreen/osp/public/
Dmessage_demuxer.h36 virtual ErrorOr<size_t> OnStreamMessage(uint64_t endpoint_id,
49 uint64_t endpoint_id,
72 MessageWatch WatchMessageType(uint64_t endpoint_id,
84 void OnStreamData(uint64_t endpoint_id,
95 void StopWatchingMessageType(uint64_t endpoint_id, msgs::Type message_type);
99 uint64_t endpoint_id,
106 uint64_t endpoint_id,
Dendpoint_request_ids.cc13 uint64_t EndpointRequestIds::GetNextRequestId(uint64_t endpoint_id) { in GetNextRequestId() argument
14 uint64_t& next_request_id = request_ids_by_endpoint_id_[endpoint_id]; in GetNextRequestId()
20 void EndpointRequestIds::ResetRequestId(uint64_t endpoint_id) { in ResetRequestId() argument
23 request_ids_by_endpoint_id_.erase(endpoint_id); in ResetRequestId()
Drequest_response_handler.h66 uint64_t endpoint_id) = 0;
98 request_msg->request_id = GetNextRequestId(connection_->endpoint_id()); in WriteMessage()
144 request_msg->request_id = GetNextRequestId(connection_->endpoint_id()); in SetConnection()
160 ErrorOr<size_t> OnStreamMessage(uint64_t endpoint_id, in OnStreamMessage() argument
182 connection_->endpoint_id()); in OnStreamMessage()
205 ->WatchMessageType(connection_->endpoint_id(), in EnsureResponseWatch()
210 uint64_t GetNextRequestId(uint64_t endpoint_id) { in GetNextRequestId() argument
214 ->GetNextRequestId(endpoint_id); in GetNextRequestId()
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()
Dprotocol_connection.cc10 ProtocolConnection::ProtocolConnection(uint64_t endpoint_id, uint64_t id) in ProtocolConnection() argument
11 : endpoint_id_(endpoint_id), id_(id) {} in ProtocolConnection()
Dendpoint_request_ids.h31 uint64_t GetNextRequestId(uint64_t endpoint_id);
32 void ResetRequestId(uint64_t endpoint_id);
Dprotocol_connection.h50 ProtocolConnection(uint64_t endpoint_id, uint64_t connection_id);
81 uint64_t endpoint_id() const { return endpoint_id_; } in endpoint_id() function
/external/crosvm/devices/src/usb/xhci/
Dtransfer_ring_controller.rs30 endpoint_id: u8, field
45 self.endpoint_id, in handle_transfer_descriptor()
72 endpoint_id: u8, in new()
75 format!("transfer ring slot_{} ep_{}", slot_id, endpoint_id), in new()
83 endpoint_id, in new()
Dxhci_transfer.rs168 endpoint_id: u8, in create_transfer()
174 if endpoint_id == 0 { in create_transfer()
176 } else if (endpoint_id % 2) == 0 { in create_transfer()
190 endpoint_id, in create_transfer()
236 endpoint_id: u8, field
253 self.slot_id, self.endpoint_id, self.transfer_dir, self.transfer_trbs in fmt()
272 self.endpoint_id / 2 in get_endpoint_number()
349 self.endpoint_id, in on_transfer_complete()
365 self.endpoint_id, in on_transfer_complete()
378 self.endpoint_id, in on_transfer_complete()
[all …]
Ddevice_slot.rs81 fn valid_endpoint_id(endpoint_id: u8) -> bool { in valid_endpoint_id()
82 endpoint_id < DCI_INDEX_END && endpoint_id > 0 in valid_endpoint_id()
209 endpoint_id: u8, in stop_endpoint()
212 self.slots[slot_id as usize - 1].stop_endpoint(self.fail_handle.clone(), endpoint_id, cb) in stop_endpoint()
621 endpoint_id: u8, in stop_endpoint()
624 if !valid_endpoint_id(endpoint_id) { in stop_endpoint()
628 let index = endpoint_id - 1; in stop_endpoint()
649 pub fn set_tr_dequeue_ptr(&self, endpoint_id: u8, ptr: u64) -> Result<TrbCompletionCode> { in set_tr_dequeue_ptr()
650 if !valid_endpoint_id(endpoint_id) { in set_tr_dequeue_ptr()
654 let index = (endpoint_id - 1) as usize; in set_tr_dequeue_ptr()
/external/openscreen/osp/public/presentation/
Dpresentation_receiver.h95 ErrorOr<size_t> OnStreamMessage(uint64_t endpoint_id,
109 uint64_t endpoint_id; member
113 uint64_t endpoint_id; member
Dpresentation_connection.h132 uint64_t endpoint_id() const { in endpoint_id() function
160 uint64_t endpoint_id,
194 ErrorOr<size_t> OnStreamMessage(uint64_t endpoint_id,

12