| /wasmtime-44.0.1/crates/wasi/src/p2/host/ |
| H A D | tcp.rs | 117 let socket = self.table.get(&this)?; in local_address() localVariable
122 let socket = self.table.get(&this)?; in remote_address() localVariable
127 let socket = self.table.get(&this)?; in is_listening() localVariable
136 let socket = self.table.get(&this)?; in address_family() localVariable
151 let socket = self.table.get(&this)?; in keep_alive_enabled() localVariable
160 let socket = self.table.get(&this)?; in set_keep_alive_enabled() localVariable
166 let socket = self.table.get(&this)?; in keep_alive_idle_time() localVariable
181 let socket = self.table.get(&this)?; in keep_alive_interval() localVariable
190 let socket = self.table.get(&this)?; in set_keep_alive_interval() localVariable
196 let socket = self.table.get(&this)?; in keep_alive_count() localVariable
[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
|
| 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
|
| H A D | udp.rs | 31 let socket = self.table.get_mut(&this)?; in start_bind() localVariable
62 let socket = self.table.get_mut(&this)?; in stream() localVariable
98 let socket = self.table.get(&this)?; in local_address() localVariable
103 let socket = self.table.get(&this)?; in remote_address() localVariable
111 let socket = self.table.get(&this)?; in address_family() localVariable
116 let socket = self.table.get(&this)?; in unicast_hop_limit() localVariable
125 let socket = self.table.get(&this)?; in set_unicast_hop_limit() localVariable
131 let socket = self.table.get(&this)?; in receive_buffer_size() localVariable
140 let socket = self.table.get(&this)?; in set_receive_buffer_size() localVariable
146 let socket = self.table.get(&this)?; in send_buffer_size() localVariable
[all …]
|
| /wasmtime-44.0.1/crates/test-programs/src/bin/ |
| H A D | p2_cli_hostcall_fuel.rs | 131 let socket = in udp_socket() localVariable
149 let socket = udp_socket(); in udp_send_many() localVariable
165 let socket = udp_socket(); in udp_send_big() localVariable
|
| H A D | p2_tls_sample_application.rs | 16 let socket = TcpSocket::new(ip.family()).unwrap(); in test_tls_sample_application() localVariable
53 let socket = TcpSocket::new(ip.family()).unwrap(); in test_tls_invalid_certificate() localVariable
|
| H A D | p2_tcp_streams.rs | 132 socket: TcpSocket, field
|
| H A D | p3_sockets_tcp_streams.rs | 303 socket: TcpSocket, field
|
| /wasmtime-44.0.1/crates/wasi/src/sockets/ |
| H A D | udp.rs | 45 socket: Arc<tokio::net::UdpSocket>, field
78 let socket = with_ambient_tokio_runtime(|| { in new() localVariable
190 let mut socket = match (&self.udp_state, addr) { in send_p3() localVariable
245 let socket = match self.udp_state { in receive_p3() localVariable
251 let socket = socket?; in receive_p3() localVariable
324 pub(crate) fn socket(&self) -> &Arc<tokio::net::UdpSocket> { in socket() method
|
| H A D | tcp.rs | 164 let socket = match family { in new() localVariable
167 let socket = tokio::net::TcpSocket::new_v6()?; in new() localVariable
|
| H A D | util.rs | 377 let socket = cap_std::net::UdpSocket::new(family, Blocking::No)?; in udp_socket() localVariable
|
| /wasmtime-44.0.1/crates/wasi/src/p3/sockets/host/types/ |
| H A D | tcp.rs | 82 let socket = TcpSocket::new_accept(res, &self.options, self.family) in poll_produce() localVariable
85 let socket = table in poll_produce() localVariable
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
356 let socket = get_socket_mut(self.table, &socket)?; in bind() localVariable
364 let socket = TcpSocket::new(self.ctx, family)?; in create() localVariable
|
| H A D | udp.rs | 78 let socket = get_socket_mut(self.table, &socket)?; in bind() localVariable
93 let socket = get_socket_mut(self.table, &socket)?; in connect() localVariable
99 let socket = UdpSocket::new(self.ctx, address_family.into())?; in create() localVariable
107 let socket = get_socket_mut(self.table, &socket)?; in disconnect() localVariable
|
| /wasmtime-44.0.1/crates/wasi-common/src/sync/ |
| H A D | mod.rs | 118 let socket: Socket = socket.into(); in preopened_socket() localVariable
|
| /wasmtime-44.0.1/crates/wasi-common/src/tokio/ |
| H A D | mod.rs | 100 let socket: Socket = socket.into(); in preopened_socket() localVariable
|
| /wasmtime-44.0.1/src/commands/ |
| H A D | serve.rs | 618 let socket = match &self.addr { in serve() localVariable
1022 let socket = match addr { in debug_serve_body() localVariable
|