| /wasmtime-44.0.1/crates/test-programs/src/bin/ |
| H A D | p2_tcp_streams.rs | 11 setup(net, family, |server, client| { in test_tcp_input_stream_should_be_closed_by_remote_shutdown()
17 client.input.subscribe().block(); in test_tcp_input_stream_should_be_closed_by_remote_shutdown()
34 setup(net, family, |server, client| { in test_tcp_input_stream_should_be_closed_by_local_shutdown()
41 client.input.subscribe().block(); in test_tcp_input_stream_should_be_closed_by_local_shutdown()
59 setup(net, family, |_server, client| { in test_tcp_output_stream_should_be_closed_by_local_shutdown()
70 client.output.write(message), in test_tcp_output_stream_should_be_closed_by_local_shutdown()
76 client.output.check_write(), in test_tcp_output_stream_should_be_closed_by_local_shutdown()
85 setup(net, family, |server, client| { in test_tcp_shutdown_should_not_lose_data()
87 client.socket.set_send_buffer_size(1024).unwrap(); in test_tcp_shutdown_should_not_lose_data()
91 let big_buffer_size = client in test_tcp_shutdown_should_not_lose_data()
[all …]
|
| H A D | p2_udp_connect.rs | 13 let client = UdpSocket::new(family).unwrap(); in test_udp_connect_disconnect_reconnect() localVariable
16 _ = client.stream(None).unwrap(); in test_udp_connect_disconnect_reconnect()
19 _ = client.stream(None).unwrap(); in test_udp_connect_disconnect_reconnect()
22 _ = client.stream(Some(remote1)).unwrap(); in test_udp_connect_disconnect_reconnect()
23 assert_eq!(client.remote_address(), Ok(remote1)); in test_udp_connect_disconnect_reconnect()
25 _ = client.stream(Some(remote1)).unwrap(); in test_udp_connect_disconnect_reconnect()
26 assert_eq!(client.remote_address(), Ok(remote1)); in test_udp_connect_disconnect_reconnect()
28 _ = client.stream(Some(remote2)).unwrap(); in test_udp_connect_disconnect_reconnect()
31 _ = client.stream(None).unwrap(); in test_udp_connect_disconnect_reconnect()
34 _ = client.stream(Some(remote1)).unwrap(); in test_udp_connect_disconnect_reconnect()
[all …]
|
| H A D | p3_sockets_udp_connect.rs | 21 let client = UdpSocket::create(family).unwrap(); in test_udp_connect_disconnect_reconnect() localVariable
25 client.get_remote_address(), in test_udp_connect_disconnect_reconnect()
31 client.get_remote_address(), in test_udp_connect_disconnect_reconnect()
35 _ = client.connect(remote1).unwrap(); in test_udp_connect_disconnect_reconnect()
38 _ = client.connect(remote1).unwrap(); in test_udp_connect_disconnect_reconnect()
41 _ = client.connect(remote2).unwrap(); in test_udp_connect_disconnect_reconnect()
44 _ = client.disconnect().unwrap(); in test_udp_connect_disconnect_reconnect()
46 client.get_remote_address(), in test_udp_connect_disconnect_reconnect()
50 _ = client.connect(remote1).unwrap(); in test_udp_connect_disconnect_reconnect()
184 client.bind(unspecified_port).unwrap(); in test_udp_connect_and_send()
[all …]
|
| H A D | p3_sockets_tcp_streams.rs | 17 setup(family, |mut server, mut client| async move { in test_tcp_ping_pong()
43 setup(family, |server, mut client| async move { in test_tcp_receive_stream_should_be_dropped_by_remote_shutdown()
50 client.receive_result.await.unwrap(); in test_tcp_receive_stream_should_be_dropped_by_remote_shutdown()
58 setup(family, |mut server, client| async move { in test_tcp_receive_future_should_resolve_when_stream_dropped()
79 setup(family, |_server, client| async move { in test_tcp_send_future_should_resolve_when_stream_dropped()
84 } = client; in test_tcp_send_future_should_resolve_when_stream_dropped()
104 let result = client.send_result.await; in test_tcp_send_drops_stream_when_remote_shutdown()
141 setup(family, |_server, client| async move { in test_tcp_send_once()
161 setup(family, |server, client| async move { in test_tcp_stream_lifetimes()
175 } = client; in test_tcp_stream_lifetimes()
[all …]
|
| H A D | p3_sockets_udp_sample_application.rs | 23 let client = UdpSocket::create(family).unwrap(); in test_udp_sample_application() localVariable
24 client.bind(unspecified_addr).unwrap(); in test_udp_sample_application()
25 client.connect(addr).unwrap(); in test_udp_sample_application()
26 let client_addr = client.get_local_address().unwrap(); in test_udp_sample_application()
29 client.send(first_message.to_vec(), None).await.unwrap(); in test_udp_sample_application()
30 client in test_udp_sample_application()
49 let client = UdpSocket::create(family).unwrap(); in test_udp_sample_application() localVariable
50 client.bind(unspecified_addr).unwrap(); in test_udp_sample_application()
51 client in test_udp_sample_application()
|
| H A D | p2_udp_sample_application.rs | 23 let client = UdpSocket::new(family).unwrap(); in test_udp_sample_application() localVariable
24 client.blocking_bind(&net, unspecified_addr).unwrap(); in test_udp_sample_application()
25 let (_, client_outgoing) = client.stream(Some(addr)).unwrap(); in test_udp_sample_application()
39 client.local_address().unwrap() in test_udp_sample_application()
56 let client = UdpSocket::new(family).unwrap(); in test_udp_sample_application() localVariable
57 client.blocking_bind(&net, unspecified_addr).unwrap(); in test_udp_sample_application()
58 let (_, client_outgoing) = client.stream(None).unwrap(); in test_udp_sample_application()
|
| H A D | p3_sockets_tcp_connect.rs | 120 let client = TcpSocket::create(family).unwrap(); in test_tcp_connect_explicit_bind() localVariable
121 client in test_tcp_connect_explicit_bind()
124 println!("local address: {:?}", client.get_local_address().unwrap()); in test_tcp_connect_explicit_bind()
125 client.connect(listener_address).await.unwrap(); in test_tcp_connect_explicit_bind()
126 println!("local address: {:?}", client.get_local_address().unwrap()); in test_tcp_connect_explicit_bind()
151 let client = TcpSocket::create(family).unwrap(); in test_tcp_connect_local_address_change() localVariable
152 client.bind(IpSocketAddress::new(ip_unspec, 0)).unwrap(); in test_tcp_connect_local_address_change()
154 let before = client.get_local_address().unwrap(); in test_tcp_connect_local_address_change()
155 client.connect(listener_address).await.unwrap(); in test_tcp_connect_local_address_change()
156 let after = client.get_local_address().unwrap(); in test_tcp_connect_local_address_change()
|
| H A D | p2_udp_send_too_much.rs | 12 let client = UdpSocket::new(family).unwrap(); in main() localVariable
13 client.blocking_bind(&net, unspecified_port).unwrap(); in main()
15 let (_, tx) = client.stream(Some(remote)).unwrap(); in main()
16 assert_eq!(client.remote_address(), Ok(remote)); in main()
|
| H A D | p3_sockets_tcp_sample_application.rs | 27 let client = TcpSocket::create(family).unwrap(); in test_tcp_sample_application() localVariable
28 client.connect(addr).await.unwrap(); in test_tcp_sample_application()
32 client.send(data_rx).await.unwrap(); in test_tcp_sample_application()
62 let client = TcpSocket::create(family).unwrap(); in test_tcp_sample_application() localVariable
63 client.connect(addr).await.unwrap(); in test_tcp_sample_application()
67 client.send(data_rx).await.unwrap(); in test_tcp_sample_application()
|
| H A D | p2_tcp_sample_application.rs | 21 let client = TcpSocket::new(family).unwrap(); in test_tcp_sample_application() localVariable
22 let (_client_input, client_output) = client.blocking_connect(&net, addr).unwrap(); in test_tcp_sample_application()
42 let client = TcpSocket::new(family).unwrap(); in test_tcp_sample_application() localVariable
43 let (_client_input, client_output) = client.blocking_connect(&net, addr).unwrap(); in test_tcp_sample_application()
|
| H A D | p3_http_outbound_request_content_length.rs | 2 use test_programs::p3::wasi::http::client;
50 async { client::send(request).await }, in run()
67 async { client::send(request).await }, in run()
96 async { client::send(request).await }, in run()
|
| H A D | p2_cli_hostcall_fuel.rs | 246 let client = in read_tcp_big() localVariable
262 client in read_tcp_big()
268 client.subscribe().block(); in read_tcp_big()
269 let (input, _output) = client.finish_connect().unwrap(); in read_tcp_big()
|
| H A D | p2_tcp_connect.rs | 112 let client = TcpSocket::new(family).unwrap(); in test_tcp_connect_explicit_bind() localVariable
115 client in test_tcp_connect_explicit_bind()
120 client.blocking_connect(net, listener_address).unwrap(); in test_tcp_connect_explicit_bind()
|
| H A D | p3_http_proxy.rs | 5 client,
45 client::send(outgoing_request).await? in handle()
|
| H A D | p2_tcp_sockopts.rs | 131 let client = TcpSocket::new(family).unwrap(); in test_tcp_sockopt_inheritance() localVariable
132 client.blocking_connect(&net, bound_addr).unwrap(); in test_tcp_sockopt_inheritance()
197 let client = TcpSocket::new(family).unwrap(); in test_tcp_sockopt_after_listen() localVariable
198 client.blocking_connect(&net, bound_addr).unwrap(); in test_tcp_sockopt_after_listen()
|
| H A D | p3_sockets_tcp_sockopts.rs | 135 let client = TcpSocket::create(family).unwrap(); in test_tcp_sockopt_inheritance() localVariable
138 client.connect(bound_addr).await.unwrap(); in test_tcp_sockopt_inheritance()
199 let client = TcpSocket::create(family).unwrap(); in test_tcp_sockopt_after_listen() localVariable
202 client.connect(bound_addr).await.unwrap(); in test_tcp_sockopt_after_listen()
|
| H A D | p2_tcp_bind.rs | 52 let client = TcpSocket::new(ip.family()).unwrap(); in test_tcp_bind_reuseaddr() localVariable
64 client.blocking_connect(net, connect_addr).unwrap(); in test_tcp_bind_reuseaddr()
86 drop(client); in test_tcp_bind_reuseaddr()
|
| H A D | p3_http_outbound_request_missing_path_and_query.rs | 1 use test_programs::p3::wasi::http::client::send;
|
| /wasmtime-44.0.1/crates/wasi-tls/wit/deps/tls/ |
| H A D | types.wit | 11 resource client-handshake {
16 finish: static func(this: client-handshake) -> future-client-streams;
20 resource client-connection {
26 resource future-client-streams {
31 …get: func() -> option<result<result<tuple<client-connection, input-stream, output-stream>, io-erro…
|
| /wasmtime-44.0.1/crates/wasi-tls/src/p2/ |
| H A D | host.rs | 60 let client = HostClientConnection(write_stream.clone()); in finish() localVariable
65 Ok((client, input, output)) in finish()
118 FutureOutput::Ready(Ok((client, input, output))) => { in get()
119 let client = self.table.push(client)?; in get() localVariable
120 let input = self.table.push_child(input, &client)?; in get()
121 let output = self.table.push_child(output, &client)?; in get()
123 Some(Ok(Ok((client, input, output)))) in get()
|
| /wasmtime-44.0.1/crates/wasi-tls/src/p3/ |
| H A D | mod.rs | 16 use bindings::tls::{client, types};
24 client::add_to_linker::<_, WasiTls>(linker, T::tls)?; in add_to_linker()
|
| /wasmtime-44.0.1/crates/wasi-keyvalue/wit/deps/keyvalue/ |
| H A D | store.wit | 15 /// writes." In particular, this means that the client should never get a value that is older than
17 /// guarantees only apply to the same client (which will likely be provided by the host or an
18 /// external capability of some kind). In this context a "client" is referring to the caller or
19 /// guest that is consuming this interface. Once a write request is committed by a specific client,
20 /// all subsequent read requests by the same client will reflect that write or any subsequent
21 /// writes. Another client running in a different context may or may not immediately see the result
23 /// the client writes B, then immediately reads, it should get B. If something else writes C in
24 /// quick succession, then the client may get C. However, a client running in a separate context may
|
| /wasmtime-44.0.1/crates/wasi-tls/src/p3/wit/deps/tls/ |
| H A D | world.wit | 4 import client;
|
| /wasmtime-44.0.1/crates/test-programs/src/p3/ |
| H A D | http.rs | 5 use crate::p3::wasi::http::{client, types};
94 let response = client::send(request).await?; in request()
|
| /wasmtime-44.0.1/cranelift/filetests/filetests/isa/x64/ |
| H A D | simd-abs-avx512.clif | 2 target x86_64 icelake-client
|