| /wasmtime-44.0.1/crates/wasi/src/p3/sockets/host/types/ |
| H A D | udp.rs | 14 socket: &'a Resource<UdpSocket>, in get_socket()
17 .get(socket) in get_socket()
24 socket: &'a Resource<UdpSocket>, in get_socket_mut()
27 .get_mut(socket) in get_socket_mut()
35 socket: Resource<UdpSocket>, in send()
78 let socket = get_socket_mut(self.table, &socket)?; in bind() localVariable
80 socket.finish_bind()?; in bind()
93 let socket = get_socket_mut(self.table, &socket)?; in connect() localVariable
101 .push(socket) in create()
107 let socket = get_socket_mut(self.table, &socket)?; in disconnect() localVariable
[all …]
|
| H A D | tcp.rs | 31 .get(socket) in get_socket()
41 .get_mut(socket) in get_socket_mut()
85 let socket = table in poll_produce() localVariable
86 .push(socket) in poll_produce()
256 let socket = get_socket_mut(store.get().table, &socket)?; in connect() localVariable
257 let socket = socket.start_connect(&remote_address)?; in connect() localVariable
265 let socket = get_socket_mut(store.get().table, &socket)?; in connect() localVariable
276 let socket = get_socket_mut(store.get().table, &socket)?; in listen() localVariable
299 let socket = get_socket_mut(store.get().table, &socket)?; in send() localVariable
323 let socket = get_socket_mut(store.get().table, &socket)?; in receive() localVariable
[all …]
|
| /wasmtime-44.0.1/crates/wasi/src/sockets/ |
| H A D | udp.rs | 45 socket: Arc<tokio::net::UdpSocket>, field
85 socket: Arc::new(socket), in new()
214 if socket.is_ok() in send_p3()
229 match socket? { in send_p3()
230 Mode::Send(socket) => send(&socket, &buf).await, in send_p3()
231 Mode::SendTo(socket, addr) => send_to(&socket, &buf, addr).await, in send_p3()
251 let socket = socket?; in receive_p3() localVariable
273 .socket in local_address()
284 .socket in remote_address()
325 &self.socket in socket()
[all …]
|
| H A D | tcp.rs | 164 let socket = match family { in new() localVariable
167 let socket = tokio::net::TcpSocket::new_v6()?; in new() localVariable
168 sockopt::set_ipv6_v6only(&socket, true)?; in new()
169 socket in new()
241 TcpState::Default(socket) in as_std_view()
242 | TcpState::BindStarted(socket) in as_std_view()
243 | TcpState::Bound(socket) in as_std_view()
244 | TcpState::ListenStarted(socket) => Ok(socket.as_socketlike_view()), in as_std_view()
279 TcpState::BindStarted(socket) => { in finish_bind()
280 self.tcp_state = TcpState::Bound(socket); in finish_bind()
[all …]
|
| H A D | util.rs | 337 socket: &tokio::net::TcpSocket, in tcp_bind()
348 _ = sockopt::set_socket_reuseaddr(&socket, true); in tcp_bind()
352 socket in tcp_bind()
377 let socket = cap_std::net::UdpSocket::new(family, Blocking::No)?; in udp_socket() localVariable
378 Ok(socket) in udp_socket()
|
| /wasmtime-44.0.1/crates/wasi/src/p2/host/ |
| H A D | tcp.rs | 39 socket.finish_bind()?; in finish_bind()
59 let future = socket in start_connect()
73 let result = socket in finish_connect()
76 socket.finish_connect(result)?; in finish_connect()
86 socket.start_listen_p2()?; in start_listen()
92 socket.finish_listen_p2()?; in finish_listen()
129 Ok(socket.is_listening()) in is_listening()
197 Ok(socket.keep_alive_count()?) in keep_alive_count()
208 Ok(socket.hop_limit()?) in hop_limit()
213 socket.set_hop_limit(value)?; in set_hop_limit()
[all …]
|
| H A D | udp.rs | 32 socket.bind(local_address)?; in start_bind()
65 if !socket.is_bound() { in stream()
75 } else if socket.is_connected() { in stream()
76 socket.disconnect()?; in stream()
80 inner: socket.socket().clone(), in stream()
84 inner: socket.socket().clone(), in stream()
99 Ok(socket.local_address()?.into()) in local_address()
112 Ok(socket.address_family().into()) in address_family()
117 Ok(socket.unicast_hop_limit()?) in unicast_hop_limit()
132 Ok(socket.receive_buffer_size()?) in receive_buffer_size()
[all …]
|
| H A D | udp_create_socket.rs | 12 let socket = UdpSocket::new(self.ctx, address_family.into())?; in create_udp_socket() localVariable
13 let socket = self.table.push(socket)?; in create_udp_socket() localVariable
14 Ok(socket) in create_udp_socket()
|
| H A D | tcp_create_socket.rs | 11 let socket = TcpSocket::new(self.ctx, address_family.into())?; in create_tcp_socket() localVariable
12 let socket = self.table.push(socket)?; in create_tcp_socket() localVariable
13 Ok(socket) in create_tcp_socket()
|
| /wasmtime-44.0.1/crates/wasi/src/p3/wit/deps/ |
| H A D | sockets.wit | 104 record ipv4-socket-address {
112 record ipv6-socket-address {
124 variant ip-socket-address {
125 ipv4(ipv4-socket-address),
126 ipv6(ipv6-socket-address),
129 /// A TCP socket resource.
147 /// socket:
162 resource tcp-socket {
163 /// Create a new TCP socket.
537 /// A UDP socket handle.
[all …]
|
| /wasmtime-44.0.1/crates/wasi-http/src/p3/wit/deps/ |
| H A D | sockets.wit | 104 record ipv4-socket-address {
112 record ipv6-socket-address {
124 variant ip-socket-address {
125 ipv4(ipv4-socket-address),
126 ipv6(ipv6-socket-address),
129 /// A TCP socket resource.
147 /// socket:
162 resource tcp-socket {
163 /// Create a new TCP socket.
537 /// A UDP socket handle.
[all …]
|
| /wasmtime-44.0.1/crates/debugger/wit/deps/ |
| H A D | sockets.wit | 65 new-socket-limit,
110 record ipv4-socket-address {
118 record ipv6-socket-address {
130 variant ip-socket-address {
131 ipv4(ipv4-socket-address),
237 /// A TCP socket resource.
259 resource tcp-socket {
591 use tcp.{tcp-socket};
654 /// A UDP socket handle.
656 resource udp-socket {
[all …]
|
| H A D | cli.wit | 186 import wasi:sockets/udp-create-socket@0.2.6;
190 import wasi:sockets/tcp-create-socket@0.2.6;
245 import wasi:sockets/udp-create-socket@0.2.6;
249 import wasi:sockets/tcp-create-socket@0.2.6;
|
| /wasmtime-44.0.1/crates/wasi/src/p2/wit/deps/ |
| H A D | sockets.wit | 65 new-socket-limit,
110 record ipv4-socket-address {
118 record ipv6-socket-address {
130 variant ip-socket-address {
131 ipv4(ipv4-socket-address),
237 /// A TCP socket resource.
259 resource tcp-socket {
591 use tcp.{tcp-socket};
654 /// A UDP socket handle.
656 resource udp-socket {
[all …]
|
| H A D | cli.wit | 186 import wasi:sockets/udp-create-socket@0.2.6;
190 import wasi:sockets/tcp-create-socket@0.2.6;
245 import wasi:sockets/udp-create-socket@0.2.6;
249 import wasi:sockets/tcp-create-socket@0.2.6;
|
| /wasmtime-44.0.1/crates/wasi-http/wit/deps/ |
| H A D | sockets.wit | 65 new-socket-limit,
110 record ipv4-socket-address {
118 record ipv6-socket-address {
130 variant ip-socket-address {
131 ipv4(ipv4-socket-address),
237 /// A TCP socket resource.
259 resource tcp-socket {
591 use tcp.{tcp-socket};
654 /// A UDP socket handle.
656 resource udp-socket {
[all …]
|
| H A D | cli.wit | 186 import wasi:sockets/udp-create-socket@0.2.6;
190 import wasi:sockets/tcp-create-socket@0.2.6;
245 import wasi:sockets/udp-create-socket@0.2.6;
249 import wasi:sockets/tcp-create-socket@0.2.6;
|
| /wasmtime-44.0.1/crates/test-programs/src/bin/ |
| H A D | p2_tcp_streams.rs | 13 server.socket.shutdown(ShutdownType::Both).unwrap(); in test_tcp_input_stream_should_be_closed_by_remote_shutdown()
44 client.socket.shutdown(ShutdownType::Receive).unwrap(); in test_tcp_input_stream_should_be_closed_by_local_shutdown()
66 client.socket.shutdown(ShutdownType::Send).unwrap(); in test_tcp_output_stream_should_be_closed_by_local_shutdown()
87 client.socket.set_send_buffer_size(1024).unwrap(); in test_tcp_shutdown_should_not_lose_data()
88 let small_buffer_size = client.socket.send_buffer_size().unwrap(); in test_tcp_shutdown_should_not_lose_data()
101 client.socket.shutdown(ShutdownType::Send).unwrap(); in test_tcp_shutdown_should_not_lose_data()
132 socket: TcpSocket, field
150 socket: accepted_socket, in setup()
155 socket: client_socket, in setup()
|
| H A D | p2_cli_hostcall_fuel.rs | 131 let socket = in udp_socket() localVariable
135 socket in udp_socket()
144 socket.finish_bind().unwrap(); in udp_socket()
145 socket in udp_socket()
149 let socket = udp_socket(); in udp_send_many() localVariable
150 let (_incoming, outgoing) = socket.stream(None).unwrap(); in udp_send_many()
165 let socket = udp_socket(); in udp_send_big() localVariable
166 let (_incoming, outgoing) = socket.stream(None).unwrap(); in udp_send_big()
273 let (socket, input, output) = server.accept().unwrap(); in read_tcp_big()
275 drop(socket); in read_tcp_big()
|
| H A D | p2_tls_sample_application.rs | 16 let socket = TcpSocket::new(ip.family()).unwrap(); in test_tls_sample_application() localVariable
17 let (tcp_input, tcp_output) = socket in test_tls_sample_application()
35 socket.shutdown(ShutdownType::Both)?; in test_tls_sample_application()
53 let socket = TcpSocket::new(ip.family()).unwrap(); in test_tls_invalid_certificate() localVariable
54 let (tcp_input, tcp_output) = socket in test_tls_invalid_certificate()
|
| H A D | p3_sockets_tcp_streams.rs | 128 let (mut reader, future) = client.socket.receive(); in test_tcp_receive_once()
146 let future = client.socket.send(send_rx); in test_tcp_send_once()
163 socket: server_socket, in test_tcp_stream_lifetimes()
170 socket: client_socket, in test_tcp_stream_lifetimes()
221 client.socket.set_send_buffer_size(1024).unwrap(); in test_tcp_read_cancellation()
303 socket: TcpSocket, field
310 fn new(socket: TcpSocket) -> Self { in new()
312 let send_result = socket.send(send_rx); in new()
313 let (receive_stream, receive_result) = socket.receive(); in new()
315 socket, in new()
|
| /wasmtime-44.0.1/crates/wasi-common/src/sync/ |
| H A D | mod.rs | 116 socket: impl Into<Socket>, in preopened_socket()
118 let socket: Socket = socket.into(); in preopened_socket() localVariable
119 let file: Box<dyn WasiFile> = socket.into(); in preopened_socket()
|
| H A D | net.rs | 318 pub fn from_cap_std(socket: cap_std::net::TcpStream) -> Self { in from_cap_std()
319 TcpStream(socket) in from_cap_std()
330 pub fn from_cap_std(socket: cap_std::os::unix::net::UnixStream) -> Self { in from_cap_std()
331 UnixStream(socket) in from_cap_std()
|
| /wasmtime-44.0.1/crates/wasi-common/src/tokio/ |
| H A D | mod.rs | 98 socket: impl Into<Socket>, in preopened_socket()
100 let socket: Socket = socket.into(); in preopened_socket() localVariable
101 let file: Box<dyn WasiFile> = socket.into(); in preopened_socket()
|
| /wasmtime-44.0.1/crates/wiggle/tests/ |
| H A D | typenames.witx | 146 ;;; The socket is not connected.
154 ;;; Not a socket.
156 ;;; Not supported, or operation not supported on socket.
174 ;;; Protocol wrong type for socket.
341 ;;; The file descriptor or file refers to a datagram socket.
343 ;;; The file descriptor or file refers to a byte-stream socket.
503 ;;; The peer of this socket has closed or disconnected.
663 ;;; High bandwidth data is available at a socket.
696 ;;; Returns the message without removing it from the socket's receive queue.
715 ;;; Which channels on a socket to shut down.
|