| /aosp_15_r20/bootable/libbootloader/gbl/libfastboot/src/ |
| H A D | lib.rs | 135 pub fn new_and_handshake(tcp_stream: &'a mut T) -> Result<Self> { in new_and_handshake()
137 block_on(tcp_stream.write_exact(TCP_HANDSHAKE_MESSAGE))?; in new_and_handshake()
138 block_on(tcp_stream.read_exact(&mut handshake[..]))?; in new_and_handshake()
140 true => Ok(Self(tcp_stream)), in new_and_handshake()
1012 tcp_stream: &mut impl TcpStream, in run_tcp_session()
1015 run(&mut TcpTransport::new_and_handshake(tcp_stream)?, fb_impl).await in run_tcp_session()
1668 let mut tcp_stream: TestTcpStream = Default::default(); in test_fastboot_tcp() localVariable
1669 tcp_stream.add_input(TCP_HANDSHAKE_MESSAGE); in test_fastboot_tcp()
1671 tcp_stream.add_length_prefixed_input(b"getvar:max-download-size"); in test_fastboot_tcp()
1672 tcp_stream.add_length_prefixed_input( in test_fastboot_tcp()
[all …]
|
| /aosp_15_r20/external/python/bumble/rust/src/cli/l2cap/ |
| D | server_bridge.rs | 136 let tcp_stream = match TcpStream::connect(format!("{tcp_host}:{tcp_port}")).await { in proxy_data_between_l2cap_and_tcp() localVariable
159 match tcp_stream { in proxy_data_between_l2cap_and_tcp()
171 Some(tcp_stream) => { in proxy_data_between_l2cap_and_tcp()
172 let (tcp_reader, tcp_writer) = tcp_stream.into_split(); in proxy_data_between_l2cap_and_tcp()
|
| D | client_bridge.rs | 89 while let Ok((tcp_stream, addr)) = listener.accept().await { in start()
94 tcp_stream, in start()
110 tcp_stream: TcpStream, in proxy_data_between_tcp_and_l2cap()
165 let (tcp_reader, tcp_writer) = tcp_stream.into_split(); in proxy_data_between_tcp_and_l2cap()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/mio/src/net/tcp/ |
| D | stream.rs | 384 fn from(tcp_stream: TcpStream) -> Self { in from()
385 tcp_stream.inner.into_inner().into() in from()
438 fn from(tcp_stream: TcpStream) -> Self { in from()
439 tcp_stream.inner.into_inner().into() in from()
|
| /aosp_15_r20/tools/netsim/rust/http-proxy/src/ |
| H A D | manager.rs | 99 Ok(tcp_stream) => into_raw_descriptor(tcp_stream), in try_connect()
|
| /aosp_15_r20/packages/modules/Virtualization/libs/libforwarder/src/ |
| D | stream.rs | 72 let tcp_stream = TcpStream::connect(sockaddr) in connect() localVariable
74 Ok(tcp_stream.into()) in connect()
|
| /aosp_15_r20/prebuilts/rust/linux-x86/1.81.0.u1/lib/rustlib/src/rust/library/std/src/os/windows/io/ |
| H A D | socket.rs | 326 fn from(tcp_stream: crate::net::TcpStream) -> OwnedSocket { in from()
327 unsafe { OwnedSocket::from_raw_socket(tcp_stream.into_raw_socket()) } in from()
|
| /aosp_15_r20/prebuilts/rust/linux-x86/1.80.1/lib/rustlib/src/rust/library/std/src/os/windows/io/ |
| H A D | socket.rs | 324 fn from(tcp_stream: crate::net::TcpStream) -> OwnedSocket { in from()
325 unsafe { OwnedSocket::from_raw_socket(tcp_stream.into_raw_socket()) } in from()
|
| /aosp_15_r20/prebuilts/rust/linux-musl-x86/1.81.0/lib/rustlib/src/rust/library/std/src/os/windows/io/ |
| H A D | socket.rs | 326 fn from(tcp_stream: crate::net::TcpStream) -> OwnedSocket { in from()
327 unsafe { OwnedSocket::from_raw_socket(tcp_stream.into_raw_socket()) } in from()
|
| /aosp_15_r20/prebuilts/rust/linux-x86/1.81.0/lib/rustlib/src/rust/library/std/src/os/windows/io/ |
| H A D | socket.rs | 326 fn from(tcp_stream: crate::net::TcpStream) -> OwnedSocket { in from()
327 unsafe { OwnedSocket::from_raw_socket(tcp_stream.into_raw_socket()) } in from()
|
| /aosp_15_r20/prebuilts/rust/linux-musl-x86/1.80.1/lib/rustlib/src/rust/library/std/src/os/windows/io/ |
| H A D | socket.rs | 324 fn from(tcp_stream: crate::net::TcpStream) -> OwnedSocket { in from()
325 unsafe { OwnedSocket::from_raw_socket(tcp_stream.into_raw_socket()) } in from()
|
| /aosp_15_r20/prebuilts/rust/linux-x86/1.81.0.u1/lib/rustlib/src/rust/library/std/src/os/fd/ |
| H A D | owned.rs | 341 fn from(tcp_stream: crate::net::TcpStream) -> OwnedFd { in from()
342 tcp_stream.into_inner().into_socket().into_inner().into_inner().into() in from()
|
| /aosp_15_r20/prebuilts/rust/linux-x86/1.81.0/lib/rustlib/src/rust/library/std/src/os/fd/ |
| H A D | owned.rs | 341 fn from(tcp_stream: crate::net::TcpStream) -> OwnedFd { in from()
342 tcp_stream.into_inner().into_socket().into_inner().into_inner().into() in from()
|
| /aosp_15_r20/prebuilts/rust/linux-x86/1.80.1/lib/rustlib/src/rust/library/std/src/os/fd/ |
| H A D | owned.rs | 329 fn from(tcp_stream: crate::net::TcpStream) -> OwnedFd { in from()
330 tcp_stream.into_inner().into_socket().into_inner().into_inner().into() in from()
|
| /aosp_15_r20/prebuilts/rust/linux-musl-x86/1.81.0/lib/rustlib/src/rust/library/std/src/os/fd/ |
| H A D | owned.rs | 341 fn from(tcp_stream: crate::net::TcpStream) -> OwnedFd { in from()
342 tcp_stream.into_inner().into_socket().into_inner().into_inner().into() in from()
|
| /aosp_15_r20/prebuilts/rust/linux-musl-x86/1.80.1/lib/rustlib/src/rust/library/std/src/os/fd/ |
| H A D | owned.rs | 329 fn from(tcp_stream: crate::net::TcpStream) -> OwnedFd { in from()
330 tcp_stream.into_inner().into_socket().into_inner().into_inner().into() in from()
|
| /aosp_15_r20/packages/modules/Virtualization/android/forwarder_host/src/ |
| D | forwarder_host.rs | 330 let (tcp_stream, _) = listener.accept().map_err(Error::TcpAccept)?; in create_forwarder_session()
365 Ok(ForwarderSession::new(tcp_stream.into(), vsock_stream.into())) in create_forwarder_session()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/tokio/ |
| D | Cargo.toml | 585 name = "tcp_stream"
586 path = "tests/tcp_stream.rs"
|