| /wasmtime-44.0.1/crates/wasi-http/src/p3/host/ |
| H A D | types.rs | 59 req: &Resource<Request>, in get_request()
66 req: &Resource<Request>, in get_request_mut()
69 .get_mut(req) in get_request_mut()
350 let req = table.push(req).context("failed to push request to table")?; in new() localVariable
352 req, in new()
369 .delete(req) in consume_body()
378 .delete(req) in drop()
396 let req = get_request_mut(self.table, &req)?; in set_method() localVariable
416 let req = get_request_mut(self.table, &req)?; in set_path_with_query() localVariable
438 let req = get_request_mut(self.table, &req)?; in set_scheme() localVariable
[all …]
|
| H A D | handler.rs | 40 req: Resource<Request>, in send()
56 let req = table in send() localVariable
57 .delete(req) in send()
60 let (req, options) = in send()
61 req.into_http_with_getter(&mut store, io_task_result(io_result_rx), getter)?; in send()
63 req.map(|body| body.with_state(io_task_rx).boxed_unsync()), in send()
|
| /wasmtime-44.0.1/crates/test-programs/src/bin/ |
| H A D | p2_http_outbound_request_response_build.rs | 44 let req = http_types::OutgoingRequest::new(http_types::Fields::new()); in main() localVariable
47 req.set_method(&http_types::Method::Other("invalid method".to_string())) in main()
51 assert!(req.set_authority(Some("bad-\nhost")).is_err()); in main()
53 assert!(req.set_authority(Some("[::]:443")).is_ok()); in main()
54 assert!(req.set_authority(Some("[::]")).is_ok()); in main()
57 req.set_scheme(Some(&http_types::Scheme::Other("bad\nscheme".to_string()))) in main()
61 assert!(req.set_path_with_query(Some("/bad\npath")).is_err()); in main()
|
| H A D | p2_http_outbound_request_missing_path_and_query.rs | 6 let req = OutgoingRequest::new(fields); in main() localVariable
7 req.set_method(&Method::Get).unwrap(); in main()
8 req.set_scheme(Some(&Scheme::Https)).unwrap(); in main()
9 req.set_authority(Some("example.com")).unwrap(); in main()
14 let res = handle(req, None); in main()
|
| H A D | p3_http_outbound_request_response_build.rs | 47 let (req, _) = Request::new(Fields::new(), None, trailers_rx, None); in run()
50 req.set_method(&Method::Other("invalid method".to_string())) in run()
54 assert!(req.set_authority(Some("bad-port:99999")).is_err()); in run()
55 assert!(req.set_authority(Some("bad-\nhost")).is_err()); in run()
56 assert!(req.set_authority(Some("too-many-ports:80:80:80")).is_err()); in run()
59 req.set_scheme(Some(&Scheme::Other("bad\nscheme".to_string()))) in run()
63 assert!(req.set_path_with_query(Some("/bad\npath")).is_err()); in run()
|
| H A D | p3_http_outbound_request_missing_path_and_query.rs | 13 let (req, _) = Request::new(fields, None, rx, None); in run()
14 req.set_method(&Method::Get).unwrap(); in run()
15 req.set_scheme(Some(&Scheme::Https)).unwrap(); in run()
16 req.set_authority(Some("example.com")).unwrap(); in run()
21 let res = send(req).await; in run()
|
| H A D | p2_http_outbound_request_invalid_header.rs | 60 let req = OutgoingRequest::new(hdrs); in main() localVariable
61 let hdrs = req.headers(); in main()
|
| H A D | p3_http_outbound_request_invalid_header.rs | 67 let (req, _) = Request::new(hdrs, None, rx, None); in run()
68 let hdrs = req.get_headers(); in run()
|
| /wasmtime-44.0.1/crates/wasi-http/src/p2/ |
| H A D | http_impl.rs | 38 let req = self.table.delete(request_id)?; in handle() localVariable
41 builder = builder.method(match req.method { in handle()
57 let (use_tls, scheme) = match req.scheme.unwrap_or(Scheme::Https) { in handle()
65 let authority = req.authority.unwrap_or_else(String::new); in handle()
73 if let Some(path) = req.path_with_query { in handle()
79 for (k, v) in req.headers.iter() { in handle()
83 let body = req.body.unwrap_or_else(|| { in handle()
|
| H A D | types_impl.rs | 177 let req = self.table.get(&id)?; in path_with_query() localVariable
178 Ok(req in path_with_query()
184 let req = self.table.get(&id)?; in scheme() localVariable
185 Ok(Some(req.scheme.clone())) in scheme()
205 match req.body.take() { in consume()
247 let req = self in body() localVariable
252 if req.body.is_some() { in body()
264 req.body = Some(hyper_body); in body()
298 req.method = method; in set_method()
348 req.scheme = scheme; in set_scheme()
[all …]
|
| H A D | types.rs | 111 req: hyper::Request<B>, in new_incoming_request()
117 let (mut parts, body) = req.into_parts(); in new_incoming_request()
135 let req = HostIncomingRequest { in new_incoming_request() localVariable
143 Ok(self.table.push(req)?) in new_incoming_request()
|
| /wasmtime-44.0.1/crates/wasi-http/src/p3/ |
| H A D | proxy.rs | 12 req: impl Into<Request>, in handle()
14 let req = store.with(|mut store| { in handle() localVariable
19 .push(req.into()) in handle()
22 match self.wasi_http_handler().call_handle(store, req).await? { in handle()
|
| H A D | request.rs | 93 req: http::Request<T>, in from_http()
110 ) = req.into_parts(); in from_http()
238 let mut req = http::Request::builder(); in into_http_with_getter() localVariable
240 let req = req in into_http_with_getter() localVariable
245 let (req, body) = req.into_parts(); in into_http_with_getter()
295 let uri = req.uri(); in default_send_request()
387 *req.uri_mut() = http::Uri::builder() in default_send_request()
389 req.uri() in default_send_request()
532 let (req, fut) = Request::new( in test_request_into_http_schemes()
568 let (req, fut) = Request::new( in test_request_into_http_uri_error()
[all …]
|
| /wasmtime-44.0.1/crates/wasi-http/tests/all/ |
| H A D | http_server.rs | 13 req: Request<hyper::body::Incoming>, in test()
15 debug!(?req, "preparing mocked response for request"); in test()
16 let method = req.method().to_string(); in test()
17 let uri = req.uri().to_string(); in test()
21 let resp = if let Some(content_length) = req.headers().get(CONTENT_LENGTH) { in test()
26 let body = req.into_body(); in test()
|
| H A D | p2.rs | 134 req: hyper::Request<BoxBody<Bytes, hyper::Error>>, in run_wasi_http()
180 let req = store in run_wasi_http() localVariable
183 .new_incoming_request(Scheme::Http, req) in run_wasi_http()
205 .call_handle(&mut store, req, out) in run_wasi_http()
239 let req = hyper::Request::builder() in wasi_http_proxy_tests() localVariable
246 req.body(body::empty())?, in wasi_http_proxy_tests()
576 let req = hyper::Request::builder() in wasi_http_without_port() localVariable
582 req.body(body::empty())?, in wasi_http_without_port()
600 let req = hyper::Request::builder() in wasi_http_no_trap_on_early_drop() localVariable
606 req.body(body::empty())?, in wasi_http_no_trap_on_early_drop()
|
| /wasmtime-44.0.1/src/commands/ |
| H A D | serve.rs | 697 hyper::service::service_fn(move |req| { in serve()
1047 hyper::service::service_fn(move |req| { in debug_serve_body()
1080 .new_incoming_request(Scheme::Http, req); in debug_serve_body()
1125 req: Request, in handle_request()
1133 req.method(), in handle_request()
1134 req.uri() in handle_request()
1183 let req = store in handle_request() localVariable
1188 wasmtime::error::Ok((req, out)) in handle_request()
1193 .call_handle(store, req, out) in handle_request()
1202 let (req, body) = req.into_parts(); in handle_request()
[all …]
|
| /wasmtime-44.0.1/cranelift/filetests/src/ |
| H A D | concurrent.rs | 142 Ok(req) => req, in worker_thread()
|
| /wasmtime-44.0.1/crates/wasi-http/tests/all/p3/ |
| H A D | mod.rs | 154 req: http::Request<impl Body<Data = Bytes, Error = E> + Send + Sync + 'static>, in run_http()
172 let (req, io) = Request::from_http(req); in run_http()
177 let res = match service.handle(store, req).await? { in run_http()
287 let req = http::Request::builder() in wasi_http_proxy_tests() localVariable
293 req.body(Empty::new())?, in wasi_http_proxy_tests()
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/trampoline/ |
| H A D | memory.rs | 212 req: &'a mut InstanceAllocationRequest<'b, 'c>, in allocate_table()
216 self.ondemand.allocate_table(req, ty, table_index) in allocate_table()
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/vm/ |
| H A D | instance.rs | 168 req: InstanceAllocationRequest, in new()
172 let module = req.runtime_info.env_module(); in new()
178 let wmemcheck_state = if req.store.engine().config().wmemcheck { in new()
194 id: req.id, in new()
195 runtime_info: req.runtime_info.clone(), in new()
209 ret.get_mut().initialize_vmctx(req.store, req.imports); in new()
|
| /wasmtime-44.0.1/crates/fuzzing/src/generators/gc_ops/ |
| H A D | types.rs | 499 req: Option<StackType>, in fixup()
505 match req { in fixup()
|
| /wasmtime-44.0.1/tests/all/ |
| H A D | cli_tests.rs | 1633 async fn send_request(&self, req: http::Request<String>) -> Result<http::Response<String>> { in send_request()
1636 let response = Self::send_request_with(&mut send, req).await?; in send_request()
1646 req: http::Request<String>, in send_request_with()
1649 .send_request(req) in send_request_with()
|
| /wasmtime-44.0.1/crates/wasmtime/src/runtime/vm/instance/ |
| H A D | allocator.rs | 218 req: &'a mut InstanceAllocationRequest<'b, 'c>, in allocate_table()
|