| /wasmtime-44.0.1/crates/wasi-http/tests/all/p2/ |
| H A D | sync.rs | 23 let server = Server::http1(1)?; in p2_http_outbound_request_get() localVariable 29 let server = Server::http1(1)?; in p2_http_outbound_request_timeout() localVariable 35 let server = Server::http1(1)?; in p2_http_outbound_request_post() localVariable 41 let server = Server::http1(1)?; in p2_http_outbound_request_large_post() localVariable 47 let server = Server::http1(1)?; in p2_http_outbound_request_put() localVariable 53 let server = Server::http2(1)?; in p2_http_outbound_request_invalid_version() localVariable 59 let server = Server::http2(1)?; in p2_http_outbound_request_invalid_header() localVariable 65 let server = Server::http1(1)?; in p2_http_outbound_request_unknown_method() localVariable 71 let server = Server::http1(1)?; in p2_http_outbound_request_unsupported_scheme() localVariable 74 &server, in p2_http_outbound_request_unsupported_scheme() [all …]
|
| H A D | async_.rs | 23 let server = Server::http1(1)?; in p2_http_outbound_request_get() localVariable 29 let server = Server::http1(1)?; in p2_http_outbound_request_timeout() localVariable 35 let server = Server::http1(1)?; in p2_http_outbound_request_post() localVariable 41 let server = Server::http1(1)?; in p2_http_outbound_request_large_post() localVariable 47 let server = Server::http1(1)?; in p2_http_outbound_request_put() localVariable 53 let server = Server::http2(1)?; in p2_http_outbound_request_invalid_version() localVariable 59 let server = Server::http2(1)?; in p2_http_outbound_request_invalid_header() localVariable 65 let server = Server::http1(1)?; in p2_http_outbound_request_unknown_method() localVariable 71 let server = Server::http1(1)?; in p2_http_outbound_request_unsupported_scheme() localVariable 74 &server, in p2_http_outbound_request_unsupported_scheme() [all …]
|
| /wasmtime-44.0.1/crates/test-programs/src/bin/ |
| 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() 44 drop(server); 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() 93 setup(family, |server, mut client| async move { in test_tcp_send_drops_stream_when_remote_shutdown() 94 drop(server); in test_tcp_send_drops_stream_when_remote_shutdown() 118 setup(family, |mut server, client| async move { in test_tcp_receive_once() 161 setup(family, |server, client| async move { in test_tcp_stream_lifetimes() 168 } = server; in test_tcp_stream_lifetimes() 219 setup(family, |mut server, mut client| async move { in test_tcp_read_cancellation() [all …]
|
| H A D | p3_sockets_udp_sample_application.rs | 18 let server = UdpSocket::create(family).unwrap(); in test_udp_sample_application() localVariable 20 server.bind(bind_address).unwrap(); in test_udp_sample_application() 21 let addr = server.get_local_address().unwrap(); in test_udp_sample_application() 37 let (buf, addr) = server.receive().await.unwrap(); in test_udp_sample_application() 41 let (buf, addr) = server.receive().await.unwrap(); in test_udp_sample_application() 58 let (buf, _) = server.receive().await.unwrap(); in test_udp_sample_application()
|
| H A D | p2_cli_hostcall_fuel.rs | 244 let server = in read_tcp_big() localVariable 249 server in read_tcp_big() 258 server.finish_bind().unwrap(); in read_tcp_big() 259 server.start_listen().unwrap(); in read_tcp_big() 260 server.finish_listen().unwrap(); in read_tcp_big() 265 server.local_address().unwrap(), in read_tcp_big() 272 server.subscribe().block(); in read_tcp_big() 273 let (socket, input, output) = server.accept().unwrap(); in read_tcp_big()
|
| H A D | p2_tcp_streams.rs | 11 setup(net, family, |server, client| { in test_tcp_input_stream_should_be_closed_by_remote_shutdown() 13 server.socket.shutdown(ShutdownType::Both).unwrap(); in test_tcp_input_stream_should_be_closed_by_remote_shutdown() 14 drop(server); 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() 38 …server.output.blocking_write_util(b"Lorem ipsum dolor sit amet, consectetur adipiscing elit, sed d… in test_tcp_input_stream_should_be_closed_by_local_shutdown() 85 setup(net, family, |server, client| { in test_tcp_shutdown_should_not_lose_data() 104 let incoming_data = server.input.blocking_read_to_end().unwrap(); in test_tcp_shutdown_should_not_lose_data()
|
| H A D | p2_udp_sample_application.rs | 16 let server = UdpSocket::new(family).unwrap(); in test_udp_sample_application() localVariable 18 server.blocking_bind(&net, bind_address).unwrap(); in test_udp_sample_application() 19 let (server_incoming, _) = server.stream(None).unwrap(); in test_udp_sample_application() 20 let addr = server.local_address().unwrap(); in test_udp_sample_application()
|
| /wasmtime-44.0.1/crates/wasi-http/tests/all/p3/ |
| H A D | mod.rs | 195 let server = Server::http1(1)?; in p3_http_outbound_request_get() localVariable 201 let server = Server::http1(1)?; in p3_http_outbound_request_timeout() localVariable 207 let server = Server::http1(1)?; in p3_http_outbound_request_post() localVariable 213 let server = Server::http1(1)?; in p3_http_outbound_request_large_post() localVariable 219 let server = Server::http1(1)?; in p3_http_outbound_request_put() localVariable 225 let server = Server::http2(1)?; in p3_http_outbound_request_invalid_version() localVariable 231 let server = Server::http2(1)?; in p3_http_outbound_request_invalid_header() localVariable 237 let server = Server::http1(1)?; in p3_http_outbound_request_unknown_method() localVariable 243 let server = Server::http1(1)?; in p3_http_outbound_request_unsupported_scheme() localVariable 246 &server, in p3_http_outbound_request_unsupported_scheme() [all …]
|
| /wasmtime-44.0.1/tests/all/ |
| H A D | cli_tests.rs | 1746 server.finish()?; in p2_cli_serve_echo_env() 1758 let resp = server in p2_cli_serve_outgoing_body_config() 1770 server.finish()?; in p2_cli_serve_outgoing_body_config() 1842 drop(server); in p2_cli_serve_only_one_process_allowed() 1883 drop(server); in p2_cli_serve_quick_rebind_allowed() 2006 let resp = server in p2_cli_serve_authority_and_scheme() 2017 let resp = server in p2_cli_serve_authority_and_scheme() 2590 let server = server.clone(); in cli_serve_hello_world() localVariable 2593 let server = server.clone(); in cli_serve_hello_world() localVariable 2687 let server = server.clone(); in cli_serve_sleep() localVariable [all …]
|
| /wasmtime-44.0.1/crates/wasi-http/tests/all/ |
| H A D | p2.rs | 6 use hyper::{Method, StatusCode, body::Bytes, server::conn::http1, service::service_fn}; 92 fn store(engine: &Engine, server: &Server) -> Store<Ctx> { in store() 100 builder.env("HTTP_SERVER", &server.addr()); in store() 327 let server = async move { in do_wasi_http_hash_all() localVariable 363 drop(future::select(server, rx).await); in do_wasi_http_hash_all() 464 let server = async move { in wasi_http_double_echo() localVariable 514 drop(future::select(server, rx).await); in wasi_http_double_echo()
|
| H A D | http_server.rs | 86 let mut builder = hyper::server::conn::http1::Builder::new(); in http1() 100 let mut builder = hyper::server::conn::http2::Builder::new(TokioExecutor); in http2()
|
| /wasmtime-44.0.1/crates/wasi-tls/wit/deps/tls/ |
| H A D | types.wit | 13 constructor(server-name: string, input: input-stream, output: output-stream);
|
| /wasmtime-44.0.1/crates/wasi-tls/src/p3/wit/deps/tls/ |
| H A D | client.wit | 20 connect: static async func(this: connector, server-name: string) -> result<_, error>;
|
| /wasmtime-44.0.1/ |
| H A D | RELEASES.md | 19 to host a `gdbstub`-compatible server (can be connected to with LLDB) to debug
|
| /wasmtime-44.0.1/src/commands/ |
| H A D | serve.rs | 543 use hyper::server::conn::http1; in serve() 999 use hyper::server::conn::http1; in debug_serve_body()
|
| /wasmtime-44.0.1/crates/debugger/wit/ |
| H A D | world.wit | 17 /// Launch the debugger top-half (e.g., protocol server or UI)
|
| /wasmtime-44.0.1/crates/wasi/src/p3/wit/deps/ |
| H A D | sockets.wit | 265 /// by the time the server attempts to perform its first I/O on it. This
|
| /wasmtime-44.0.1/crates/wasi-http/src/p3/wit/deps/ |
| H A D | sockets.wit | 265 /// by the time the server attempts to perform its first I/O on it. This
|
| /wasmtime-44.0.1/crates/c-api/ |
| H A D | doxygen.conf.in | 1653 # implemented using a web server instead of a web client using JavaScript. There 1654 # are two flavors of web server based searching depending on the EXTERNAL_SEARCH 1681 # The SEARCHENGINE_URL should point to a search engine hosted by a web server
|
| /wasmtime-44.0.1/docs/js/ |
| H A D | mermaid.min.11.6.0.js | 2554 …ill: none; stroke: #fff; stroke-miterlimit: 10; stroke-width: 2px;"/>')},server:{body:dy('<rect x=…
|