Home
last modified time | relevance | path

Searched refs:e (Results 1 – 25 of 40) sorted by relevance

12

/tonic/tonic/src/transport/server/
H A Dio_stream.rs57 Some(Err(e)) => match handle_tcp_accept_error(e) { in poll_next_without_tls()
62 ControlFlow::Break(e) => Poll::Ready(Some(Err(e))), in poll_next_without_tls()
105 SelectOutput::TcpErr(e) => match handle_tcp_accept_error(e) { in poll_next()
110 ControlFlow::Break(e) => Poll::Ready(Some(Err(e))), in poll_next()
125 let e = e.into(); in handle_tcp_accept_error() localVariable
127 if let Some(e) = e.downcast_ref::<io::Error>() { in handle_tcp_accept_error()
129 e.kind(), in handle_tcp_accept_error()
141 ControlFlow::Break(e) in handle_tcp_accept_error()
156 Err(e) => SelectOutput::TcpErr(e.into()), in select()
169 Ok(Err(e)) => SelectOutput::TlsErr(e), in select()
[all …]
H A Dincoming.rs106 if let Err(e) = stream.set_nodelay(nodelay) { in set_accepted_socket_options()
113 if let Err(e) = sock_ref.set_tcp_keepalive(keepalive) { in set_accepted_socket_options()
/tonic/examples/data/gcp/
H A Droots.pem8 # SHA256 Fingerprint: d7:a7:a0:fb:5d:7e:27:31:d7:71:e9:48:4e:bc:de:f7:1d:5f:0c:3e:0a:29:48:78:2b:c8…
108 # MD5 Fingerprint: 7c:62:ff:74:9d:31:53:5e:68:4a:d5:78:aa:1e:bf:23
307 # SHA256 Fingerprint: 3e:90:99:b5:01:5e:8f:48:6c:00:bc:ea:9d:11:1e:e7:21:fa:ba:35:5a:89:bc:f1:df:69…
367 # MD5 Fingerprint: 7c:7f:65:31:0c:81:df:8d:ba:3e:99:e2:5c:ad:6e:fb
453 # MD5 Fingerprint: f5:5d:a4:50:a5:fb:28:7e:1e:0f:0d:cc:96:57:56:ca
454 # SHA1 Fingerprint: 7e:04:de:89:6a:3e:66:6d:00:e6:87:d3:3f:fa:d9:3b:e8:3d:34:9e
550 # MD5 Fingerprint: f7:75:ab:29:fb:51:4e:b7:77:5e:ff:05:3c:99:8e:f5
768 # MD5 Fingerprint: c4:5d:0e:48:b6:ac:28:30:4e:0a:bc:f9:38:16:87:57
1056 # SHA256 Fingerprint: c3:84:6b:f2:4b:9e:93:ca:64:27:4c:0e:c6:7c:1e:cc:5e:02:4f:fc:ac:d2:d7:40:19:35…
1087 # MD5 Fingerprint: 94:14:77:7e:3e:5e:fd:8f:30:bd:41:b0:cf:e7:d0:30
[all …]
/tonic/.github/workflows/
H A DCI.yml29 - uses: taiki-e/install-action@cargo-deny
39 - uses: taiki-e/install-action@protoc
59 - uses: taiki-e/install-action@cargo-hack
60 - uses: taiki-e/install-action@cargo-udeps
61 - uses: taiki-e/install-action@protoc
79 - uses: taiki-e/install-action@cargo-hack
80 - uses: taiki-e/install-action@protoc
119 - uses: taiki-e/install-action@protoc
120 - uses: taiki-e/install-action@cargo-hack
132 - uses: taiki-e/install-action@cargo-hack
[all …]
/tonic/examples/src/json-codec/
H A Dcommon.rs31 serde_json::to_writer(buf.writer(), &item).map_err(|e| Status::internal(e.to_string())) in encode()
48 serde_json::from_reader(buf.reader()).map_err(|e| Status::internal(e.to_string()))?; in decode()
/tonic/tonic/src/transport/channel/service/
H A Dreconnect.rs95 Poll::Ready(Err(e)) => { in poll_ready()
101 return Poll::Ready(Err(e.into())); in poll_ready()
103 let error = e.into(); in poll_ready()
214 InnerProj::Error(e) => { in poll()
215 let e = e.take().expect("Polled after ready."); in poll() localVariable
216 Poll::Ready(Err(e)) in poll()
H A Dconnection.rs201 if let Err(e) = conn.await { in call()
202 tracing::debug!("connection task error: {:?}", e); in call()
/tonic/tonic-web/src/
H A Dcall.rs194 Some(Err(e)) => return Poll::Ready(Some(Err(internal_error(e)))), in poll_decode()
244 Some(Err(e)) => Poll::Ready(Some(Err(internal_error(e)))), in poll_encode()
287 Some(Err(e)) => return Poll::Ready(Some(Err(e))), in poll_frame()
302 Err(e) => return Poll::Ready(Some(Err(e))), in poll_frame()
375 fn internal_error(e: impl std::fmt::Display) -> Status { in internal_error()
376 Status::internal(format!("tonic-web: {}", e)) in internal_error()
437 .map_err(|e| Status::internal(format!("Unable to parse HeaderName: {}", e)))?; in decode_trailers_frame()
439 .map_err(|e| Status::internal(format!("Unable to parse HeaderValue: {}", e)))?; in decode_trailers_frame()
/tonic/examples/src/load_balance/
H A Dserver.rs43 if let Err(e) = serve.await { in main()
44 eprintln!("Error = {:?}", e); in main()
/tonic/examples/src/dynamic_load_balance/
H A Dserver.rs43 if let Err(e) = serve.await { in main()
44 eprintln!("Error = {:?}", e); in main()
/tonic/tonic/src/codec/
H A Dcompression.rs27 for e in self.inner.iter_mut() { in enable()
28 match e { in enable()
29 Some(e) if *e == encoding => return, in enable()
31 *e = Some(encoding); in enable()
70 self.inner.iter().all(|e| e.is_none()) in is_empty()
H A Ddecode.rs289 if let Err(Some(e)) = crate::status::infer_grpc_status(self.trailers.as_ref(), status) { in response()
293 return Err(e); in response()
332 Some(Err(e)) => Err(e), in message()
/tonic/tonic-build/src/
H A Dclient.rs240 self.inner.ready().await.map_err(|e| { in generate_unary()
241 tonic::Status::unknown(format!("Service was not ready: {}", e.into())) in generate_unary()
271 self.inner.ready().await.map_err(|e| { in generate_server_streaming()
272 tonic::Status::unknown(format!("Service was not ready: {}", e.into())) in generate_server_streaming()
302 self.inner.ready().await.map_err(|e| { in generate_client_streaming()
303 tonic::Status::unknown(format!("Service was not ready: {}", e.into())) in generate_client_streaming()
333 self.inner.ready().await.map_err(|e| { in generate_streaming()
334 tonic::Status::unknown(format!("Service was not ready: {}", e.into())) in generate_streaming()
/tonic/tonic/src/transport/service/
H A Dgrpc_timeout.rs42 let client_timeout = try_parse_grpc_timeout(req.headers()).unwrap_or_else(|e| { in call()
43 tracing::trace!("Error parsing `grpc-timeout` header {:?}", e); in call()
162 try_parse_grpc_timeout(&hm).map_err(|e| e.clone()) in setup_map_try_parse()
/tonic/examples/data/tls/
H A Dca.pem10 y/vE61ItbN/1qMYt13LMf+le1svwfkCCOPsygk7nWeRXmomgUpymqn1LnWiuB0+e
/tonic/examples/src/routeguide/
H A Dclient.rs55 Err(e) => println!("something went wrong: {:?}", e), in run_record_route()
/tonic/tonic/src/metadata/
H A Dmap.rs958 http::header::Entry::Occupied(e) => Entry::Occupied(OccupiedEntry { in generic_entry()
959 inner: e, in generic_entry()
962 http::header::Entry::Vacant(e) => Entry::Vacant(VacantEntry { in generic_entry()
963 inner: e, in generic_entry()
1466 Occupied(e) => e.into_mut(), in or_insert()
1467 Vacant(e) => e.insert(default), in or_insert()
1512 Occupied(e) => e.into_mut(), in or_insert_with()
1513 Vacant(e) => e.insert(default()), in or_insert_with()
1531 Vacant(ref e) => e.inner.key(), in key()
1532 Occupied(ref e) => e.inner.key(), in key()
/tonic/examples/src/tls_rustls/
H A Dserver.rs55 Err(e) => { in main()
56 eprintln!("Error accepting connection: {}", e); in main()
/tonic/tonic/src/transport/channel/
H A Dendpoint.rs52 let me = dst.try_into().map_err(|e| Error::from_source(e.into()))?; in new()
83 let uri = Uri::from_maybe_shared(s.into()).map_err(|e| Error::new_invalid_uri().with(e))?; in from_shared()
/tonic/examples/src/h2c/
H A Dserver.rs59 Err(e) => { in main()
60 eprintln!("Error accepting connection: {}", e); in main()
/tonic/tonic-health/src/generated/
H A Dgrpc_health_v1.rs150 .map_err(|e| { in check()
152 format!("Service was not ready: {}", e.into()), in check()
189 .map_err(|e| { in watch()
191 format!("Service was not ready: {}", e.into()), in watch()
/tonic/tonic/benches-disabled/benchmarks/compiled_protos/
H A Dhelloworld.rs46 self.inner.ready().await.map_err(|e| { in ready()
49 format!("Service was not ready: {}", e.into()), in ready()
/tonic/tests/compression/src/
H A Dcompressing_request.rs103 assert!(supported_encodings.iter().any(|e| e == req_encoding)); in client_enabled_server_enabled_multi_encoding()
/tonic/examples/proto/routeguide/
H A Droute_guide.proto36 // streamed rather than returned at once (e.g. in a response message with a
50 // while receiving other RouteNotes (e.g. from other users).
/tonic/tonic/benches-disabled/
H A DREADME.md19 …r establishing a first-run baseline and then comparing after code-changes - e.g. `Performance has …

12