Home
last modified time | relevance | path

Searched defs:Connection (Results 1 – 25 of 842) sorted by relevance

12345678910>>...34

/aosp_15_r20/external/rust/crates/quiche/src/h3/
Dffi.rs87 quic_conn: &mut Connection, config: &mut h3::Config, in quiche_h3_conn_new_with_transport()
88 ) -> *mut h3::Connection { in quiche_h3_conn_new_with_transport()
98 conn: &h3::Connection, in quiche_h3_for_each_setting()
121 conn: &mut h3::Connection, quic_conn: &mut Connection, in quiche_h3_conn_poll()
203 conn: &h3::Connection, in quiche_h3_extended_connect_enabled_by_peer()
224 conn: &mut h3::Connection, quic_conn: &mut Connection, in quiche_h3_send_request()
238 conn: &mut h3::Connection, quic_conn: &mut Connection, stream_id: u64, in quiche_h3_send_response()
252 conn: &mut h3::Connection, quic_conn: &mut Connection, stream_id: u64, in quiche_h3_send_response_with_priority()
272 conn: &mut h3::Connection, quic_conn: &mut Connection, stream_id: u64, in quiche_h3_send_body()
290 conn: &mut h3::Connection, quic_conn: &mut Connection, stream_id: u64, in quiche_h3_recv_body()
[all …]
Dmod.rs829 pub struct Connection { struct
837 local_settings: ConnectionSettings, argument
838 peer_settings: ConnectionSettings, argument
861 impl Connection { implementation
864 ) -> Result<Connection> { in new()
941 conn: &mut super::Connection, config: &Config, in with_transport()
942 ) -> Result<Connection> { in with_transport()
992 &mut self, conn: &mut super::Connection, headers: &[T], fin: bool, in send_request()
1045 &mut self, conn: &mut super::Connection, stream_id: u64, headers: &[T], in send_response()
1072 &mut self, conn: &mut super::Connection, stream_id: u64, headers: &[T], in send_response_with_priority()
[all …]
/aosp_15_r20/external/rust/android-crates-io/crates/quiche/src/h3/
Dffi.rs87 quic_conn: &mut Connection, config: &mut h3::Config, in quiche_h3_conn_new_with_transport()
88 ) -> *mut h3::Connection { in quiche_h3_conn_new_with_transport()
98 conn: &h3::Connection, in quiche_h3_for_each_setting()
121 conn: &mut h3::Connection, quic_conn: &mut Connection, in quiche_h3_conn_poll()
203 conn: &h3::Connection, in quiche_h3_extended_connect_enabled_by_peer()
224 conn: &mut h3::Connection, quic_conn: &mut Connection, in quiche_h3_send_request()
238 conn: &mut h3::Connection, quic_conn: &mut Connection, stream_id: u64, in quiche_h3_send_response()
252 conn: &mut h3::Connection, quic_conn: &mut Connection, stream_id: u64, in quiche_h3_send_response_with_priority()
272 conn: &mut h3::Connection, quic_conn: &mut Connection, stream_id: u64, in quiche_h3_send_body()
290 conn: &mut h3::Connection, quic_conn: &mut Connection, stream_id: u64, in quiche_h3_recv_body()
[all …]
Dmod.rs829 pub struct Connection { struct
837 local_settings: ConnectionSettings, argument
838 peer_settings: ConnectionSettings, argument
861 impl Connection { argument
864 ) -> Result<Connection> { in new()
941 conn: &mut super::Connection, config: &Config, in with_transport()
942 ) -> Result<Connection> { in with_transport()
992 &mut self, conn: &mut super::Connection, headers: &[T], fin: bool, in send_request()
1045 &mut self, conn: &mut super::Connection, stream_id: u64, headers: &[T], in send_response()
1072 &mut self, conn: &mut super::Connection, stream_id: u64, headers: &[T], in send_response_with_priority()
[all …]
/aosp_15_r20/trusty/user/base/lib/tipc/rust/src/
Dservice.rs166 Connection(D::Connection), enumerator
382 type Connection; typedef
396 ) -> Result<ConnectResult<Self::Connection>>; in on_connect()
407 connection: &Self::Connection, in on_message()
413 fn on_disconnect(&self, _connection: &Self::Connection) {} in on_disconnect()
419 type Connection; typedef
430 ) -> Result<ConnectResult<Self::Connection>>; in on_connect()
444 connection: &Self::Connection, in on_message()
450 fn on_disconnect(&self, _connection: &Self::Connection) {} in on_disconnect()
459 type Connection = <Self as Service>::Connection; typedef
[all …]
/aosp_15_r20/external/python/bumble/bumble/profiles/
Dhap.py269 def on_connection(connection: Connection) -> None:
316 def on_incoming_paired_connection(self, connection: Connection):
338 self, __connection__: Optional[Connection]
347 self, connection: Optional[Connection], value: bytes
356 self, connection: Optional[Connection], value: bytes
387 self, connection: Connection, presets: List[PresetRecord]
440 async def _preset_changed_operation(self, connection: Connection) -> None:
474 self, connection: Optional[Connection], value: bytes
503 async def notify_active_preset_for_connection(self, connection: Connection) -> None:
525 self, connection: Optional[Connection], value: bytes
[all …]
Daics.py151 async def notify_subscribers_via_connection(self, connection: Connection) -> None:
157 def on_read(self, _connection: Optional[Connection]) -> bytes:
189 def on_read(self, _connection: Optional[Connection]) -> bytes:
202 async def on_write(self, connection: Optional[Connection], value: bytes) -> None:
224 self, connection: Connection, gain_settings_operand: int
249 async def _unmute(self, connection: Connection):
265 async def _mute(self, connection: Connection, change_counter_operand: int) -> None:
284 async def _set_manual_gain_mode(self, connection: Connection) -> None:
299 async def _set_automatic_gain_mode(self, connection: Connection) -> None:
331 def on_read(self, _connection: Optional[Connection]) -> bytes:
[all …]
/aosp_15_r20/external/rust/android-crates-io/crates/quiche/src/
Dffi.rs459 ) -> *mut Connection { in quiche_accept()
486 ) -> *mut Connection { in quiche_connect()
561 ) -> *mut Connection { in quiche_conn_new_with_tls()
595 conn: &mut Connection, path: *const c_char, in quiche_conn_set_keylog_path()
617 pub extern fn quiche_conn_set_keylog_fd(conn: &mut Connection, fd: c_int) { in quiche_conn_set_keylog_fd()
627 conn: &mut Connection, path: *const c_char, log_title: *const c_char, in quiche_conn_set_qlog_path()
658 conn: &mut Connection, fd: c_int, log_title: *const c_char, in quiche_conn_set_qlog_fd()
676 conn: &mut Connection, buf: *const u8, buf_len: size_t, in quiche_conn_set_session()
706 conn: &mut Connection, buf: *mut u8, buf_len: size_t, info: &RecvInfo, in quiche_conn_recv()
733 conn: &mut Connection, out: *mut u8, out_len: size_t, out_info: &mut SendInfo, in quiche_conn_send()
[all …]
Dlib.rs1208 pub struct Connection { struct
1212 /// Connection Identifiers. argument
1213 ids: cid::ConnectionIdentifiers, argument
1216 trace_id: String,
1219 pkt_num_spaces: [packet::PktNumSpace; packet::Epoch::count()],
1222 peer_transport_params: TransportParams,
1225 local_transport_params: TransportParams,
1228 handshake: tls::Handshake,
1234 session: Option<Vec<u8>>,
1237 recovery_config: recovery::RecoveryConfig,
[all …]
/aosp_15_r20/external/rust/crates/quiche/src/
Dffi.rs459 ) -> *mut Connection { in quiche_accept()
486 ) -> *mut Connection { in quiche_connect()
561 ) -> *mut Connection { in quiche_conn_new_with_tls()
595 conn: &mut Connection, path: *const c_char, in quiche_conn_set_keylog_path()
617 pub extern fn quiche_conn_set_keylog_fd(conn: &mut Connection, fd: c_int) { in quiche_conn_set_keylog_fd()
627 conn: &mut Connection, path: *const c_char, log_title: *const c_char, in quiche_conn_set_qlog_path()
658 conn: &mut Connection, fd: c_int, log_title: *const c_char, in quiche_conn_set_qlog_fd()
676 conn: &mut Connection, buf: *const u8, buf_len: size_t, in quiche_conn_set_session()
706 conn: &mut Connection, buf: *mut u8, buf_len: size_t, info: &RecvInfo, in quiche_conn_recv()
733 conn: &mut Connection, out: *mut u8, out_len: size_t, out_info: &mut SendInfo, in quiche_conn_send()
[all …]
Dlib.rs1208 pub struct Connection { struct
1212 /// Connection Identifiers. argument
1213 ids: cid::ConnectionIdentifiers, argument
1216 trace_id: String,
1219 pkt_num_spaces: [packet::PktNumSpace; packet::Epoch::count()],
1222 peer_transport_params: TransportParams,
1225 local_transport_params: TransportParams,
1228 handshake: tls::Handshake,
1234 session: Option<Vec<u8>>,
1237 recovery_config: recovery::RecoveryConfig,
[all …]
/aosp_15_r20/external/python/bumble/bumble/
Dl2cap.py766 connection: Connection,
1073 connection: Connection,
1541 def next_identifier(self, connection: Connection) -> int:
1672 def on_pdu(self, connection: Connection, cid: int, pdu: bytes) -> None:
1694 self, connection: Connection, cid: int, control_frame: L2CAP_Control_Frame
1704 self, connection: Connection, cid: int, control_frame: L2CAP_Control_Frame
1743 self, _connection: Connection, _cid: int, packet
1748 self, connection: Connection, cid: int, request
1802 self, connection: Connection, cid: int, response
1819 self, connection: Connection, cid: int, request
[all …]
Dgatt_server.py308 self, connection: Optional[Connection], characteristic: Characteristic
322 connection: Connection,
352 def send_response(self, connection: Connection, response: ATT_PDU) -> None:
360 connection: Connection,
403 connection: Connection,
505 def on_disconnection(self, connection: Connection) -> None:
513 def on_gatt_pdu(self, connection: Connection, att_pdu: ATT_PDU) -> None:
555 def on_att_request(self, connection: Connection, pdu: ATT_PDU) -> None:
/aosp_15_r20/prebuilts/rust/linux-x86/1.80.1/lib/rustlib/src/rust/library/std/src/os/xous/
H A Dffi.rs16 connection: Connection, in lend_mut_impl()
58 connection: Connection, in lend_mut()
68 connection: Connection, in try_lend_mut()
78 connection: Connection, in lend_impl()
122 connection: Connection, in lend()
132 connection: Connection, in try_lend()
141 fn scalar_impl(connection: Connection, args: [usize; 5], blocking: bool) -> Result<(), Error> { in scalar_impl()
176 pub(crate) fn scalar(connection: Connection, args: [usize; 5]) -> Result<(), Error> { in scalar()
180 pub(crate) fn try_scalar(connection: Connection, args: [usize; 5]) -> Result<(), Error> { in try_scalar()
185 connection: Connection, in blocking_scalar_impl()
[all …]
/aosp_15_r20/prebuilts/rust/linux-musl-x86/1.80.1/lib/rustlib/src/rust/library/std/src/os/xous/
H A Dffi.rs16 connection: Connection, in lend_mut_impl()
58 connection: Connection, in lend_mut()
68 connection: Connection, in try_lend_mut()
78 connection: Connection, in lend_impl()
122 connection: Connection, in lend()
132 connection: Connection, in try_lend()
141 fn scalar_impl(connection: Connection, args: [usize; 5], blocking: bool) -> Result<(), Error> { in scalar_impl()
176 pub(crate) fn scalar(connection: Connection, args: [usize; 5]) -> Result<(), Error> { in scalar()
180 pub(crate) fn try_scalar(connection: Connection, args: [usize; 5]) -> Result<(), Error> { in try_scalar()
185 connection: Connection, in blocking_scalar_impl()
[all …]
/aosp_15_r20/prebuilts/rust/linux-musl-x86/1.81.0/lib/rustlib/src/rust/library/std/src/os/xous/
H A Dffi.rs16 connection: Connection, in lend_mut_impl()
58 connection: Connection, in lend_mut()
68 connection: Connection, in try_lend_mut()
78 connection: Connection, in lend_impl()
122 connection: Connection, in lend()
132 connection: Connection, in try_lend()
141 fn scalar_impl(connection: Connection, args: [usize; 5], blocking: bool) -> Result<(), Error> { in scalar_impl()
176 pub(crate) fn scalar(connection: Connection, args: [usize; 5]) -> Result<(), Error> { in scalar()
180 pub(crate) fn try_scalar(connection: Connection, args: [usize; 5]) -> Result<(), Error> { in try_scalar()
185 connection: Connection, in blocking_scalar_impl()
[all …]
/aosp_15_r20/prebuilts/rust/linux-x86/1.81.0.u1/lib/rustlib/src/rust/library/std/src/os/xous/
H A Dffi.rs16 connection: Connection, in lend_mut_impl()
58 connection: Connection, in lend_mut()
68 connection: Connection, in try_lend_mut()
78 connection: Connection, in lend_impl()
122 connection: Connection, in lend()
132 connection: Connection, in try_lend()
141 fn scalar_impl(connection: Connection, args: [usize; 5], blocking: bool) -> Result<(), Error> { in scalar_impl()
176 pub(crate) fn scalar(connection: Connection, args: [usize; 5]) -> Result<(), Error> { in scalar()
180 pub(crate) fn try_scalar(connection: Connection, args: [usize; 5]) -> Result<(), Error> { in try_scalar()
185 connection: Connection, in blocking_scalar_impl()
[all …]
/aosp_15_r20/prebuilts/rust/linux-x86/1.81.0/lib/rustlib/src/rust/library/std/src/os/xous/
H A Dffi.rs16 connection: Connection, in lend_mut_impl()
58 connection: Connection, in lend_mut()
68 connection: Connection, in try_lend_mut()
78 connection: Connection, in lend_impl()
122 connection: Connection, in lend()
132 connection: Connection, in try_lend()
141 fn scalar_impl(connection: Connection, args: [usize; 5], blocking: bool) -> Result<(), Error> { in scalar_impl()
176 pub(crate) fn scalar(connection: Connection, args: [usize; 5]) -> Result<(), Error> { in scalar()
180 pub(crate) fn try_scalar(connection: Connection, args: [usize; 5]) -> Result<(), Error> { in try_scalar()
185 connection: Connection, in blocking_scalar_impl()
[all …]
/aosp_15_r20/external/rust/android-crates-io/crates/tonic/src/transport/service/
Dconnection.rs27 pub(crate) struct Connection { struct
31 impl Connection { implementation
102 impl Service<Request> for Connection { implementation
116 impl Load for Connection { implementation
124 impl fmt::Debug for Connection { implementation
/aosp_15_r20/external/rust/android-crates-io/crates/virtio-drivers/src/device/socket/
Dconnectionmanager.rs58 struct Connection { struct
59 info: ConnectionInfo, argument
66 impl Connection { argument
309 connections: &mut [Connection], in get_connection()
312 ) -> core::result::Result<(usize, &mut Connection), SocketError> { in get_connection()
324 connections: &'a mut [Connection], in get_connection_for_event()
327 ) -> Option<(usize, &'a mut Connection)> { in get_connection_for_event()
/aosp_15_r20/trusty/user/app/secretkeeper/
Dlib.rs121 type Connection = (); typedef
129 ) -> tipc::Result<ConnectResult<Self::Connection>> { in on_connect()
136 _connection: &Self::Connection, in on_message()
155 type Connection = (); typedef
163 ) -> tipc::Result<ConnectResult<Self::Connection>> { in on_connect()
170 _connection: &Self::Connection, in on_message()
188 type Connection = (); typedef
196 ) -> tipc::Result<ConnectResult<Self::Connection>> { in on_connect()
203 _connection: &Self::Connection, in on_message()
/aosp_15_r20/packages/modules/adb/
Dtransport_benchmark.cpp66 client->SetReadCallback([](Connection*, std::unique_ptr<apacket>) -> bool { return true; }); in BM_Connection_Unidirectional() argument
67 … server->SetReadCallback([&received_bytes](Connection*, std::unique_ptr<apacket> packet) -> bool { in BM_Connection_Unidirectional() argument
73 [](Connection*, const std::string& error) { LOG(INFO) << "client closed: " << error; }); in BM_Connection_Unidirectional() argument
75 [](Connection*, const std::string& error) { LOG(INFO) << "server closed: " << error; }); in BM_Connection_Unidirectional() argument
124 … client->SetReadCallback([&received_bytes](Connection*, std::unique_ptr<apacket> packet) -> bool { in BM_Connection_Echo() argument
147 [](Connection*, const std::string& error) { LOG(INFO) << "client closed: " << error; }); in BM_Connection_Echo() argument
149 [](Connection*, const std::string& error) { LOG(INFO) << "server closed: " << error; }); in BM_Connection_Echo() argument
Dtransport.h110 struct Connection { struct
114 void SetTransport(atransport* transport) { transport_ = transport; } in SetTransport()
141 static std::unique_ptr<Connection> FromFd(unique_fd fd); argument
148 struct BlockingConnection { argument
/aosp_15_r20/external/rust/android-crates-io/crates/h2/src/proto/
Dconnection.rs19 pub(crate) struct Connection<T, P, B: Buf = Bytes> struct
26 inner: ConnectionInner<P, B>, argument
29 // Extracted part of `Connection` which does not depend on `T`. Reduces the amount of duplicated argument
100 impl<T, P, B> Connection<T, P, B> implementation
556 impl<T, B> Connection<T, client::Peer, B> impl
566 impl<T, B> Connection<T, server::Peer, B> implementation
601 impl<T, P, B> Drop for Connection<T, P, B> implementation
/aosp_15_r20/external/rust/android-crates-io/crates/rusqlite/src/
Dlib.rs323 pub struct Connection { struct
324 db: RefCell<InnerConnection>, argument
328 unsafe impl Send for Connection {} argument
330 impl Drop for Connection { implementation
337 impl Connection { implementation
391 pub fn open<P: AsRef<Path>>(path: P) -> Result<Connection> { in open()
417 pub fn open_with_flags<P: AsRef<Path>>(path: P, flags: OpenFlags) -> Result<Connection> { in open_with_flags()
440 ) -> Result<Connection> { in open_with_flags_and_vfs()
458 pub fn open_in_memory_with_flags(flags: OpenFlags) -> Result<Connection> { in open_in_memory_with_flags()
473 pub fn open_in_memory_with_flags_and_vfs(flags: OpenFlags, vfs: &str) -> Result<Connection> { in open_in_memory_with_flags_and_vfs()
[all …]

12345678910>>...34