Home
last modified time | relevance | path

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

/wasmtime-44.0.1/crates/test-programs/src/bin/
H A Dp2_tcp_sockopts.rs20 assert!(sock.send_buffer_size().unwrap() > 0); in test_tcp_sockopt_defaults()
106 assert_eq!(sock.send_buffer_size().unwrap(), 0x10000); in test_tcp_sockopt_readback()
146 assert_eq!(accepted_client.send_buffer_size().unwrap(), 0x10000); in test_tcp_sockopt_inheritance()
171 assert_eq!(accepted_client.send_buffer_size().unwrap(), 0x10000); in test_tcp_sockopt_inheritance()
212 assert_eq!(accepted_client.send_buffer_size().unwrap(), 0x10000); in test_tcp_sockopt_after_listen()
H A Dp2_udp_states.rs26 assert!(matches!(sock.send_buffer_size(), Ok(_))); in test_udp_unbound_state_invariants()
53 assert!(matches!(sock.send_buffer_size(), Ok(_))); in test_udp_bound_state_invariants()
79 assert!(matches!(sock.send_buffer_size(), Ok(_))); in test_udp_connected_state_invariants()
H A Dp2_udp_sockopts.rs11 assert!(sock.send_buffer_size().unwrap() > 0); in test_udp_sockopt_defaults()
48 assert_eq!(sock.send_buffer_size().unwrap(), 0x10000); in test_udp_sockopt_readback()
H A Dp2_tcp_states.rs52 assert!(matches!(sock.send_buffer_size(), Ok(_))); in test_tcp_unbound_state_invariants()
103 assert!(matches!(sock.send_buffer_size(), Ok(_))); in test_tcp_bound_state_invariants()
161 assert!(matches!(sock.send_buffer_size(), Ok(_))); in test_tcp_listening_state_invariants()
212 assert!(matches!(sock.send_buffer_size(), Ok(_))); in test_tcp_connected_state_invariants()
H A Dp2_tcp_streams.rs88 let small_buffer_size = client.socket.send_buffer_size().unwrap(); in test_tcp_shutdown_should_not_lose_data()
/wasmtime-44.0.1/crates/wasi/src/sockets/
H A Dtcp.rs5 is_valid_unicast_address, receive_buffer_size, send_buffer_size, set_keep_alive_count,
653 pub(crate) fn send_buffer_size(&self) -> Result<u64, ErrorCode> { in send_buffer_size() method
655 let n = send_buffer_size(fd)?; in send_buffer_size()
822 send_buffer_size: AtomicUsize, field
841 self.0.send_buffer_size.store(value, Relaxed); in set_send_buffer_size()
855 let send_buffer_size = self.0.send_buffer_size.load(Relaxed); in apply() localVariable
856 if send_buffer_size > 0 { in apply()
858 _ = sockopt::set_socket_send_buffer_size(&stream, send_buffer_size); in apply()
H A Dudp.rs4 receive_buffer_size, send_buffer_size, set_receive_buffer_size, set_send_buffer_size,
314 pub(crate) fn send_buffer_size(&self) -> Result<u64, ErrorCode> { in send_buffer_size() method
315 let n = send_buffer_size(&self.socket)?; in send_buffer_size()
H A Dutil.rs270 pub fn send_buffer_size(fd: impl AsFd) -> Result<u64, ErrorCode> { in send_buffer_size() function
/wasmtime-44.0.1/crates/wasi/src/p2/host/
H A Dtcp.rs232 fn send_buffer_size(&mut self, this: Resource<TcpSocket>) -> SocketResult<u64> { in send_buffer_size() method
234 Ok(socket.send_buffer_size()?) in send_buffer_size()
469 fn send_buffer_size(&mut self, self_: Resource<TcpSocket>) -> Result<u64, SocketError> { in send_buffer_size() method
470 AsyncHostTcpSocket::send_buffer_size(self, self_) in send_buffer_size()
H A Dudp.rs145 fn send_buffer_size(&mut self, this: Resource<udp::UdpSocket>) -> SocketResult<u64> { in send_buffer_size() method
147 Ok(socket.send_buffer_size()?) in send_buffer_size()
508 fn send_buffer_size(&mut self, self_: Resource<UdpSocket>) -> Result<u64, SocketError> { in send_buffer_size() method
509 AsyncHostUdpSocket::send_buffer_size(self, self_) in send_buffer_size()
/wasmtime-44.0.1/crates/wasi/src/p3/sockets/host/types/
H A Dudp.rs162 Ok(sock.send_buffer_size()?) in get_send_buffer_size()
H A Dtcp.rs494 Ok(sock.send_buffer_size()?) in get_send_buffer_size()