| /wasmtime-44.0.1/crates/component-macro/tests/codegen/ |
| H A D | share-types.wit | 4 record request {
14 use http-types.{request,response};
15 handle-request: func(request: request) -> response;
18 use http-types.{request,response};
19 fetch-request: func(request: request) -> response;
|
| /wasmtime-44.0.1/crates/test-programs/src/bin/ |
| H A D | p2_http_outbound_request_content_length.rs | 4 let request = http_types::OutgoingRequest::new( in make_request() localVariable
8 request in make_request()
11 request in make_request()
15 request in make_request()
18 request in make_request()
22 request in make_request()
28 let request = make_request(); in main() localVariable
29 let outgoing_body = request.body().unwrap(); in main()
43 let request = make_request(); in main() localVariable
44 let outgoing_body = request.body().unwrap(); in main()
[all …]
|
| H A D | p2_api_proxy.rs | 11 fn handle(request: IncomingRequest, outparam: ResponseOutparam) { in handle()
12 assert!(request.scheme().is_some()); in handle()
13 assert!(request.authority().is_some()); in handle()
14 assert!(request.path_with_query().is_some()); in handle()
18 match (request.method(), request.path_with_query().as_deref()) { in handle()
34 let r = modify_fields_handler(request); in handle()
39 let r = new_fields_handler(request); in handle()
48 let req_hdrs = request.headers(); in handle()
125 let path = request.path_with_query().unwrap(); in modify_fields_handler()
134 fn new_fields_handler(request: IncomingRequest) -> Result<()> { in new_fields_handler()
[all …]
|
| H A D | p3_http_outbound_request_content_length.rs | 19 let (request, transmit) = Request::new( in make_request()
26 request.set_method(&Method::Post).expect("setting method"); in make_request()
27 request in make_request()
34 request in make_request()
37 request in make_request()
41 (request, contents_tx, trailers_tx, transmit) in make_request()
48 let (request, mut contents_tx, trailers_tx, transmit) = make_request(); in run()
50 async { client::send(request).await }, in run()
65 let (request, mut contents_tx, trailers_tx, transmit) = make_request(); in run()
67 async { client::send(request).await }, in run()
[all …]
|
| H A D | p2_api_proxy_forward_request.rs | 10 fn handle(request: IncomingRequest, outparam: ResponseOutparam) { in handle()
11 let res = test_programs::http::request( in handle()
12 request.method(), in handle()
13 request.scheme().unwrap(), in handle()
14 request.authority().unwrap().as_str(), in handle()
15 request.path_with_query().unwrap().as_str(), in handle()
|
| H A D | p2_http_outbound_request_response_build.rs | 11 let request = http_types::OutgoingRequest::new(headers); in main() localVariable
13 request in main()
16 request in main()
19 request in main()
23 let outgoing_body = request.body().unwrap(); in main()
|
| H A D | p3_api_proxy.rs | 11 async fn handle(request: Request) -> Result<Response, ErrorCode> { in handle()
12 assert!(request.get_scheme().is_some()); in handle()
13 assert!(request.get_authority().is_some()); in handle()
14 assert!(request.get_path_with_query().is_some()); in handle()
20 let req_hdrs = request.get_headers(); in handle()
|
| H A D | p3_http_outbound_request_response_build.rs | 19 let (request, _) = Request::new(headers, Some(contents_rx), trailers_rx, None); in run()
21 request.set_method(&Method::Get).expect("setting method"); in run()
22 request in run()
25 request in run()
28 drop(request); in run()
|
| H A D | p2_api_proxy_streaming.rs | 16 fn handle(request: IncomingRequest, response_out: ResponseOutparam) { in handle()
18 handle_request(request, response_out).await; in handle()
24 let headers = request.headers().entries(); in handle_request()
26 assert!(request.authority().is_some()); in handle_request()
28 match (request.method(), request.path_with_query().as_deref()) { in handle_request()
115 match double_echo(request, &url).await { in handle_request()
257 let request = OutgoingRequest::new(Fields::new()); in hash() localVariable
259 request in hash()
262 request in hash()
269 request in hash()
[all …]
|
| H A D | p3_http_middleware.rs | 45 async fn handle(request: Request) -> Result<Response, ErrorCode> { in handle()
47 let method = request.get_method(); in handle()
48 let scheme = request.get_scheme(); in handle()
49 let path_with_query = request.get_path_with_query(); in handle()
50 let authority = request.get_authority(); in handle()
53 let headers = request.get_headers(); in handle()
71 let (mut body, trailers) = Request::consume_body(request, result_rx); in handle()
|
| H A D | p3_http_proxy.rs | 19 async fn handle(request: Request) -> Result<Response, ErrorCode> { in handle()
20 let headers = request.get_headers().copy_all(); in handle()
28 let method = request.get_method(); in handle()
29 let (rx, trailers) = Request::consume_body(request, wit_future::new(|| Ok(())).1); in handle()
|
| H A D | p2_cli_serve_authority_and_scheme.rs | 11 fn handle(request: IncomingRequest, outparam: ResponseOutparam) { in handle()
12 let authority = request.authority(); in handle()
13 let scheme = request.scheme(); in handle()
|
| H A D | p3_http_echo.rs | 16 async fn handle(request: Request) -> Result<Response, ErrorCode> { in handle()
17 let headers = request.get_headers(); in handle()
19 let (body, trailers) = Request::consume_body(request, result_rx); in handle()
|
| /wasmtime-44.0.1/crates/wasi-http/tests/all/ |
| H A D | p2.rs | 293 move |request: http::request::Parts| { in do_wasi_http_hash_all()
373 request = request.header("url", format!("{prefix}{path}")); in do_wasi_http_hash_all()
375 let request = request.body(body::empty())?; in do_wasi_http_hash_all() localVariable
379 request, in do_wasi_http_hash_all()
422 let request = request.header("url", format!("http://forbidden.com")); in wasi_http_hash_all_with_reject() localVariable
423 let request = request.header("url", format!("http://localhost")); in wasi_http_hash_all_with_reject() localVariable
424 let request = request.body(body::empty())?; in wasi_http_hash_all_with_reject() localVariable
428 request, in wasi_http_hash_all_with_reject()
538 request = request.header("url", url_header); in do_wasi_http_echo()
541 let request = request.body(BoxBody::new(StreamBody::new(stream::iter( in do_wasi_http_echo() localVariable
[all …]
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/vm/sys/unix/ |
| H A D | machports.rs | 212 let mut request: ExceptionRequest = unsafe { mem::zeroed() }; in handler_thread() localVariable
215 &mut request.body.Head, in handler_thread()
218 mem::size_of_val(&request) as u32, in handler_thread()
234 if request.body.Head.msgh_id != EXCEPTION_MSG_ID { in handler_thread()
247 let reply_code = if unsafe { handle_exception(&mut request) } { in handler_thread()
260 reply.Head.msgh_remote_port = request.body.Head.msgh_remote_port; in handler_thread()
262 reply.Head.msgh_id = request.body.Head.msgh_id + 100; in handler_thread()
279 unsafe fn handle_exception(request: &mut ExceptionRequest) -> bool { in handle_exception()
282 match request.body.exception as u32 { in handle_exception()
292 Some(request.body.code[1] as usize) in handle_exception()
[all …]
|
| /wasmtime-44.0.1/crates/test-programs/src/ |
| H A D | http.rs | 33 pub fn request( in request() function
58 let request = http_types::OutgoingRequest::new(headers); in request() localVariable
60 request in request()
63 request in request()
66 request in request()
69 request in request()
73 let outgoing_body = request in request()
89 let future_response = outgoing_handler::handle(request, options)?; in request()
|
| /wasmtime-44.0.1/crates/wasi-http/src/p3/wit/deps/ |
| H A D | http.wit | 72 HTTP-request-denied,
73 HTTP-request-length-required,
75 HTTP-request-method-invalid,
76 HTTP-request-URI-invalid,
77 HTTP-request-URI-too-long,
134 variant request-options-error {
266 resource request {
317 /// Get the `request-options` to be associated with this request
353 resource request-options {
440 handle: async func(request: request) -> result<response, error-code>;
[all …]
|
| /wasmtime-44.0.1/crates/wasi-http/src/p2/ |
| H A D | mod.rs | 290 request: hyper::Request<body::HyperOutgoingBody>, in send_request()
293 Ok(default_send_request(request, config)) in send_request()
300 request: hyper::Request<body::HyperOutgoingBody>, in send_request()
556 request: hyper::Request<body::HyperOutgoingBody>, in default_send_request()
560 Ok(default_send_request_handler(request, config).await) in default_send_request()
571 mut request: hyper::Request<body::HyperOutgoingBody>,
585 let authority = if let Some(authority) = request.uri().authority() {
682 *request.uri_mut() = http::Uri::builder()
684 request
693 let resp = timeout(first_byte_timeout, sender.send_request(request))
|
| H A D | types_impl.rs | 243 request: Resource<HostOutgoingRequest>, in body()
249 .get_mut(&request) in body()
274 let _ = self.table.delete(request)?; in drop()
282 Ok(self.table.get(&request)?.method.clone()) in method()
290 let req = self.table.get_mut(&request)?; in set_method()
315 let req = self.table.get_mut(&request)?; in set_path_with_query()
332 Ok(self.table.get(&request)?.scheme.clone()) in scheme()
340 let req = self.table.get_mut(&request)?; in set_scheme()
357 Ok(self.table.get(&request)?.authority.clone()) in authority()
365 let req = self.table.get_mut(&request)?; in set_authority()
[all …]
|
| /wasmtime-44.0.1/crates/test-programs/src/p3/ |
| H A D | http.rs | 37 pub async fn request( in request() function
75 let (request, transmit) = in request()
78 request in request()
81 request in request()
84 request in request()
87 request in request()
94 let response = client::send(request).await?; in request()
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/vm/instance/allocator/ |
| H A D | on_demand.rs | 115 request: &'a mut InstanceAllocationRequest<'b, 'c>, in allocate_memory()
126 request.runtime_info.memory_image(memory_index)? in allocate_memory()
134 request.store.engine(), in allocate_memory()
137 request.limiter.as_deref_mut(), in allocate_memory()
156 request: &'a mut InstanceAllocationRequest<'b, 'c>, in allocate_table()
164 request.store.engine().tunables(), in allocate_table()
165 request.limiter.as_deref_mut(), in allocate_table()
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/vm/instance/ |
| H A D | allocator.rs | 193 request: &'a mut InstanceAllocationRequest<'b, 'c>, in allocate_memory()
320 mut request: InstanceAllocationRequest<'_, '_>, in allocate_module()
322 let module = request.runtime_info.env_module(); in allocate_module()
341 self.allocate_memories(&mut request, &mut guard.memories) in allocate_module()
343 self.allocate_tables(&mut request, &mut guard.tables) in allocate_module()
351 request, in allocate_module()
403 request: &mut InstanceAllocationRequest<'_, '_>, in allocate_memories()
406 let module = request.runtime_info.env_module(); in allocate_memories()
419 .allocate_memory(request, ty, Some(memory_index)) in allocate_memories()
456 request: &mut InstanceAllocationRequest<'_, '_>, in allocate_tables()
[all …]
|
| /wasmtime-44.0.1/crates/wasi-http/src/p3/ |
| H A D | mod.rs | 16 mod request; module
20 pub use request::default_send_request;
21 pub use request::{Request, RequestOptions};
110 request: http::Request<UnsyncBoxBody<Bytes, ErrorCode>>, in send_request()
125 let (res, io) = default_send_request(request, options).await?; in send_request()
152 request: http::Request<UnsyncBoxBody<Bytes, ErrorCode>>, in send_request()
|
| /wasmtime-44.0.1/crates/wasi-http/tests/all/p3/ |
| H A D | mod.rs | 62 .send(request.into_body()); in send_request()
448 let mut request = http::Request::builder() in test_http_echo() localVariable
453 request = request in test_http_echo()
458 request = request.header("x-host-to-host", "true"); in test_http_echo()
547 let request = http::Request::builder() in p3_http_proxy() localVariable
651 let request = http::Request::builder() in p3_http_empty_frame_at_end_of_stream() localVariable
659 request.body(wrapped_body)?, in p3_http_empty_frame_at_end_of_stream()
703 let request = http::Request::builder() in p3_http_data_frame_at_end_of_stream() localVariable
711 request.body(wrapped_body)?, in p3_http_data_frame_at_end_of_stream()
792 let request = http::Request::builder() in p3_http_empty_frames_interleaved() localVariable
[all …]
|
| /wasmtime-44.0.1/crates/wasi-http/wit/deps/ |
| H A D | http.wit | 80 HTTP-request-denied,
83 HTTP-request-method-invalid,
84 HTTP-request-URI-invalid,
85 HTTP-request-URI-too-long,
159 /// `incoming-request.headers`, `outgoing-request.headers`) might be
249 resource incoming-request {
280 resource outgoing-request {
356 resource request-options {
651 handle: func(request: incoming-request, response-out: response-outparam);
659 use types.{outgoing-request, request-options, future-incoming-response, error-code};
[all …]
|