Home
last modified time | relevance | path

Searched refs:Err (Results 1 – 25 of 67) sorted by relevance

123

/tonic/tests/default_stubs/src/
H A Dlib.rs22 Err(Status::permission_denied("")) in unary()
29 Err(Status::permission_denied("")) in server_stream()
33 Err(Status::permission_denied("")) in client_stream()
40 Err(Status::permission_denied("")) in bidirectional_stream()
/tonic/tonic/src/codec/
H A Ddecode.rs181 return Err(Status::internal(message)); in decode_chunk()
190 return Err(Status::out_of_range( in decode_chunk()
216 if let Err(err) = decompress( in decode_chunk()
233 return Err(Status::internal(message)); in decode_chunk()
251 Some(Err(status)) => { in poll_frame()
258 return Poll::Ready(Err(status)); in poll_frame()
264 Err(Status::internal("Unexpected EOF decoding stream.")) in poll_frame()
293 return Err(e); in response()
332 Some(Err(e)) => Err(e), in message()
395 return Poll::Ready(status.take().map(Err)); in poll_next()
[all …]
H A Dencode.rs90 return Poll::Ready(Some(Err(status))); in poll_next()
105 if let Err(status) = encode_item( in poll_next()
114 return Poll::Ready(Some(Err(status))); in poll_next()
121 Poll::Ready(Some(Err(status))) => { in poll_next()
123 return Poll::Ready(Some(Err(status))); in poll_next()
189 return Err(Status::out_of_range(format!( in finish_encoding()
196 return Err(Status::resource_exhausted(format!( in finish_encoding()
322 Some(Err(status)) => match self_proj.state.role { in poll_frame()
323 Role::Client => Some(Err(status)).into(), in poll_frame()
/tonic/examples/src/streaming/
H A Dserver.rs41 Err(Status::unimplemented("not implemented")) in unary_echo()
68 Err(_item) => { in server_streaming_echo()
87 Err(Status::unimplemented("not implemented")) in client_streaming_echo()
112 Err(err) => { in bidirectional_streaming_echo()
122 match tx.send(Err(err)).await { in bidirectional_streaming_echo()
124 Err(_err) => break, // response was dropped in bidirectional_streaming_echo()
/tonic/interop/src/
H A Dserver.rs36 return Err(status); in unary_call()
43 return Err(status); in unary_call()
115 return Err(status); in full_duplex_call()
125 Err(status)?; in full_duplex_call()
150 Err(Status::unimplemented("TODO")) in half_duplex_call()
154 Err(Status::unimplemented("")) in unimplemented_call()
164 Err(Status::unimplemented("")) in unimplemented_call()
H A Dclient.rs238 Err(status) => status.code() == Code::Unknown, in status_code_and_message()
247 Err(status) => status.message() == TEST_STATUS_MESSAGE, in status_code_and_message()
280 Err(e) => Err(e), in status_code_and_message()
300 Err(status) => status.code() == Code::Unknown, in special_status_message()
309 Err(status) => status.message() == SPECIAL_TEST_STATUS_MESSAGE, in special_status_message()
321 Err(status) => status.code() == Code::Unimplemented, in unimplemented_method()
336 Err(status) => status.code() == Code::Unimplemented, in unimplemented_service()
/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()
110 ControlFlow::Break(e) => Poll::Ready(Some(Err(e))), in poll_next()
156 Err(e) => SelectOutput::TcpErr(e.into()), in select()
169 Ok(Err(e)) => SelectOutput::TlsErr(e), in select()
170 Err(e) => SelectOutput::TlsErr(e.into()), in select()
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/tonic-reflection/src/server/
H A Dv1alpha.rs42 None => Err(Status::invalid_argument("invalid MessageRequest")), in server_reflection_info()
57 Err(Status::not_found("extensions are not supported")) in server_reflection_info()
87 Err(status) => { in server_reflection_info()
88 resp_tx.send(Err(status)).await.expect("send"); in server_reflection_info()
H A Dv1.rs42 None => Err(Status::invalid_argument("invalid MessageRequest")), in server_reflection_info()
57 Err(Status::not_found("extensions are not supported")) in server_reflection_info()
87 Err(status) => { in server_reflection_info()
88 resp_tx.send(Err(status)).await.expect("send"); in server_reflection_info()
H A Dmod.rs142 return Err(Error::InvalidFileDescriptorSet("missing name".to_string())); in new()
254 None => Err(Status::not_found(format!("symbol '{}' not found", symbol))), in symbol_by_name()
258 return Err(Status::internal("encoding error")); in symbol_by_name()
268 None => Err(Status::not_found(format!("file '{}' not found", filename))), in file_by_filename()
272 return Err(Status::internal("encoding error")); in file_by_filename()
287 None => Err(Error::InvalidFileDescriptorSet(format!( in extract_name()
/tonic/tonic-web/src/
H A Dcall.rs187 return Poll::Ready(Some(Err(internal_error( in poll_decode()
192 return Poll::Ready(Some(Err(internal_error("unexpected frame type")))) in poll_decode()
194 Some(Err(e)) => return Poll::Ready(Some(Err(internal_error(e)))), in poll_decode()
197 Poll::Ready(Some(Err(internal_error("malformed base64 request")))) in poll_decode()
243 Some(Ok(_)) => Poll::Ready(Some(Err(internal_error("unexpected frame type")))), in poll_encode()
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()
481 return Err(Status::internal(format!( in find_trailers()
/tonic/tests/integration_tests/tests/
H A Dstatus.rs25 Err(Status::with_details( in status_with_details()
87 Err(Status::with_metadata(Code::Internal, MESSAGE, metadata)) in status_with_metadata()
157 Err::<OutputStream, _>(Status::unavailable("foo")), in status_from_server_stream()
158 Err::<OutputStream, _>(Status::unavailable("bar")), in status_from_server_stream()
201 Err::<TokioIo<MockStream>, _>(std::io::Error::other("WTF")) in status_from_server_stream_with_source()
228 Err::<OutputStream, _>(Status::unavailable("foo")), in message_and_then_status_from_server_stream()
H A Duser_agent.rs18 None => Err(Status::internal("user-agent header is missing")), in writes_user_agent_header()
53 Err(status) => panic!("{}", status.message()), in writes_user_agent_header()
H A Dmax_message_size.rs169 Err(std::io::Error::other("Client already taken")) in response_stream_limit()
246 (Some(code), Err(status)) => { in assert_test_case()
255 (None, Err(status)) => panic!("Expected success, but got failure, got: {:?}", status), in assert_test_case()
335 Err(std::io::Error::other("Client already taken")) in max_message_run()
/tonic/tonic/src/metadata/
H A Dkey.rs45 return Err(InvalidMetadataKey::new()); in from_bytes()
53 Err(_) => Err(InvalidMetadataKey::new()), in from_bytes()
143 type Err = InvalidMetadataKey; typedef
/tonic/tonic/src/service/
H A Drecover_error.rs98 Err(err) => match Status::try_from_error(err.into()) { in poll()
104 Err(err) => Poll::Ready(Err(err)), in poll()
/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()
125 Poll::Ready(Err(_)) => { in poll_ready()
216 Poll::Ready(Err(e)) in poll()
H A Dtls.rs69 return Err(TlsError::NativeCertsNotFound.into()); in new()
117 return Err(TlsError::H2NotNegotiated.into()); in connect()
/tonic/tonic/src/transport/service/
H A Dgrpc_timeout.rs89 return Poll::Ready(Err(TimeoutExpired(()).into())); in poll()
113 .and_then(|s| if s.is_empty() { Err(val) } else { Ok(s) })? in try_parse_grpc_timeout()
124 return Err(val); in try_parse_grpc_timeout()
142 _ => return Err(val), in try_parse_grpc_timeout()
/tonic/tonic/src/server/
H A Dgrpc.rs20 Err(status) => return status.into_http(),
236 Err(status) => { in unary()
238 Err(status), in unary()
280 Err(status) => { in server_streaming()
282 Err(status), in server_streaming()
/tonic/examples/src/cancellation/
H A Dclient.rs21 Err(_) => { in main()
/tonic/tonic-types/src/richer_error/std_messages/
H A Dretry_info.rs104 Err(_) => prost_types::Duration { in from()
156 Err(error) => panic!("Error generating RetryInfo from Any: {:?}", error), in gen_retry_info()
/tonic/examples/src/richer-error/
H A Dclient.rs25 Err(status) => { in main()
H A Dclient_vec.rs25 Err(status) => { in main()

123