Home
last modified time | relevance | path

Searched refs:Err (Results 1 - 25 of 149) sorted by relevance

123456

/commonlibrary/rust/ylong_runtime/ylong_io/tests/
H A Dudp_socket_test.rs32 Err(e) => { in sdv_send_recv()
39 Err(e) => { in sdv_send_recv()
46 Err(e) => { in sdv_send_recv()
52 Err(e) => { in sdv_send_recv()
61 Err(e) => { in sdv_send_recv()
70 Err(e) if e.kind() == ErrorKind::WouldBlock => {} in sdv_send_recv()
71 Err(e) => panic!("{:?}", e), in sdv_send_recv()
92 Err(e) => { in sdv_send_to_recv_from()
99 Err(e) => { in sdv_send_to_recv_from()
108 Err( in sdv_send_to_recv_from()
[all...]
H A Dtcp_test.rs37 Err(e) if e.kind() == io::ErrorKind::WouldBlock => continue, in sdv_tcp_server()
38 Err(e) => panic!("tcp accept failed: {e:?}"), in sdv_tcp_server()
48 Err(e) if e.kind() == io::ErrorKind::WouldBlock => { in sdv_tcp_server()
51 Err(e) => panic!("tcp write failed: {e:?}"), in sdv_tcp_server()
66 Err(e) if e.kind() == io::ErrorKind::WouldBlock => continue, in sdv_tcp_server()
67 Err(e) => panic!("tcp write failed: {e:?}"), in sdv_tcp_server()
75 Err(_) => continue, in sdv_tcp_server()
107 Err(e) if e.kind() == io::ErrorKind::WouldBlock => continue, in sdv_tcp_server_vectored()
108 Err(e) => panic!("tcp accept failed: {e:?}"), in sdv_tcp_server_vectored()
120 Err( in sdv_tcp_server_vectored()
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h3/
H A Dio_manager.rs70 Poll::Ready(None) => Poll::Ready(Err(DispatchErrorKind::ChannelClosed)), in poll_recv_signal()
76 Poll::Ready(Err(_e)) => Poll::Ready(Err(DispatchErrorKind::ChannelClosed)), in poll_recv_signal()
112 Err(e) => Poll::Ready(Err(DispatchErrorKind::Quic(e))),
115 Poll::Ready(Err(e)) => Poll::Ready(Err(DispatchErrorKind::Io(e.kind()))),
130 Err(quiche::Error::Done) => { in poll_io_send()
134 Err(e) => { in poll_io_send()
135 return Poll::Ready(Err(DispatchErrorKin in poll_io_send()
[all...]
H A Dstream_manager.rs87 Poll::Ready(None) => Poll::Ready(Err(DispatchErrorKind::ChannelClosed)), in poll_recv_signal()
93 Poll::Ready(Err(_e)) => Poll::Ready(Err(DispatchErrorKind::ChannelClosed)), in poll_recv_signal()
105 Poll::Ready(None) => Poll::Ready(Err(DispatchErrorKind::ChannelClosed)), in poll_recv_request()
111 Poll::Ready(Err(_e)) => Poll::Ready(Err(DispatchErrorKind::ChannelClosed)), in poll_recv_request()
170 if let Err(e) = self.poll_send_frame(id, None) { in input_stream_frame()
173 e => Err(e), in input_stream_frame()
188 if let Err(e) = self.poll_send_frame(id, Some(*data)) { in input_stream_frame()
191 e => Err( in input_stream_frame()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/
H A Depoll.rs42 Err(err) => { in new()
43 return Err(err); in new()
68 Err(err) => { in select()
69 return Err(err); in select()
84 Err(err) => Err(err), in register()
97 Err(err) => Err(err), in reregister()
110 Err(err) => Err(er in deregister()
[all...]
H A Dwaker.rs56 Err(err)
68 Err(ref err) if err.kind() == io::ErrorKind::WouldBlock => {
71 Err(err) if err.kind() != io::ErrorKind::WouldBlock => Err(err),
75 Err(err) => Err(err),
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/
H A Doutput.rs86 Poll::Ready(Err(e)) => {
102 Poll::Ready(Err(e)) => {
103 return Poll::Ready(Err(e));
109 Err(e) => {
111 Poll::Ready(Err(_)) => {
112 return Poll::Ready(Err(DispatchErrorKind::ChannelClosed))
130 Poll::Ready(Err(e)) => return Poll::Ready(Err(e)),
135 return Poll::Ready(Err(e));
145 Poll::Ready(Err( in poll_blocked_task()
[all...]
H A Dstreams.rs37 Err(H2Error),
51 Err(H2Error),
276 return Err(H2Error::StreamError(id, ErrorCode::FlowControlError));
288 return Err(H2Error::ConnectionError(ErrorCode::FlowControlError));
421 None => Err(H2Error::ConnectionError(ErrorCode::IntervalError)),
440 None => Err(H2Error::ConnectionError(ErrorCode::IntervalError)),
474 return Err(H2Error::ConnectionError(ErrorCode::IntervalError)); in poll_sized_data()
500 Poll::Ready(None) => Err(H2Error::ConnectionError(ErrorCode::IntervalError)), in poll_sized_data()
559 None => StreamEndState::Err(H2Error::ConnectionError(ErrorCode::ProtocolError)),
584 None => return FrameRecvState::Err(H2Erro
[all...]
/commonlibrary/rust/ylong_http/ylong_http/src/request/
H A Dmethod.rs117 return Err(ErrorKind::InvalidInput.into()); in from_bytes()
124 _ => Err(ErrorKind::InvalidInput.into()), in from_bytes()
131 _ => Err(ErrorKind::InvalidInput.into()), in from_bytes()
228 Err(HttpError::from(ErrorKind::InvalidInput)) in ut_method_from_bytes()
234 Err(HttpError::from(ErrorKind::InvalidInput)) in ut_method_from_bytes()
240 Err(HttpError::from(ErrorKind::InvalidInput)) in ut_method_from_bytes()
246 Err(HttpError::from(ErrorKind::InvalidInput)) in ut_method_from_bytes()
252 Err(HttpError::from(ErrorKind::InvalidInput)) in ut_method_from_bytes()
256 Err(HttpError::from(ErrorKind::InvalidInput)) in ut_method_from_bytes()
260 Err(HttpErro in ut_method_from_bytes()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Duds_test.rs42 Err(ref e) if e.kind() == io::ErrorKind::WouldBlock => continue, in sdv_uds_stream_try_test()
43 Err(e) => panic!("{e:?}"), in sdv_uds_stream_try_test()
55 Err(ref e) if e.kind() == io::ErrorKind::WouldBlock => continue, in sdv_uds_stream_try_test()
56 Err(e) => panic!("{e:?}"), in sdv_uds_stream_try_test()
84 Err(ref e) if e.kind() == io::ErrorKind::WouldBlock => continue, in sdv_uds_datagram_try_test()
85 Err(e) => panic!("{e:?}"), in sdv_uds_datagram_try_test()
97 Err(ref e) if e.kind() == io::ErrorKind::WouldBlock => continue, in sdv_uds_datagram_try_test()
98 Err(e) => panic!("{e:?}"), in sdv_uds_datagram_try_test()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/
H A Dsemaphore.rs107 Err(e) => Err(e), in new()
145 /// * `Err(PermitError::Empty)` if no permit remaining in semaphore.
146 /// * `Err(PermitError::Closed)` if semaphore is closed.
163 Err(e) => Err(e), in try_acquire()
172 /// * `Err(PermitError::Closed)` if semaphore is closed.
238 Err(e) => Err(e), in new()
260 /// * `Err(PermitErro
[all...]
H A Doneshot.rs31 //! if let Err(_) = tx.send(6) {
38 //! Err(_) => println!("Sender dropped"),
73 /// if let Err(_) = tx.send(6) {
80 /// Err(_) => println!("Sender dropped"),
104 /// if let Err(_) = tx.send(6) {
111 /// Err(_) => println!("Sender dropped"),
131 /// Err(_) => println!("Sender dropped"),
154 /// if let Err(_) = tx.send(6) {
161 /// Err(_) => println!("Sender dropped"),
183 return Err(sel in send()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/
H A Dylong_runtime_tcp_client_perf.rs27 Err(err) => return Err(err), in main()
36 Err(_) => { in main()
47 Err(_) => { in main()
H A Dylong_runtime_tcp_server_perf.rs29 Err(_) => return, in main()
35 Err(_e) => continue, in main()
45 Err(_) => { in main()
60 Err(_) => { in main()
H A Dylong_tokio_tcp_perf.rs44 Err(e) => { in ylong_create_client()
57 Err(e) => { in ylong_create_client()
80 Err(e) => { in tokio_create_client()
93 Err(e) => { in tokio_create_client()
130 Err(e) => { in main()
174 Err(e) => { in main()
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/
H A Dlistener.rs52 /// This may return an `Err(e)` where `e.kind()` is
68 Err(err) => { in accept()
69 return Err(err); in accept()
83 Err(e) => return Err(e), in accept()
90 Err(err) => Err(err), in accept()
170 Err(err)
H A Dsocket.rs60 Err(err) => Err(err),
68 Err(err) => Err(err),
84 Err(err) if err.raw_os_error() != Some(libc::EINPROGRESS) => Err(err),
/commonlibrary/rust/ylong_http/ylong_http/src/request/uri/
H A Dmod.rs227 return Err(InvalidUri::UriTooLong.into()); in from_bytes()
230 return Err(InvalidUri::InvalidFormat.into()); in from_bytes()
239 _ => return Err(InvalidUri::UriMissQuery.into()), in from_bytes()
568 Err(InvalidUri::InvalidScheme) in from_bytes()
650 return Err(InvalidUri::UriMissAuthority); in from_bytes()
658 Err(InvalidUri::InvalidAuthority) in from_bytes()
779 type Err = HttpError; types
793 fn from_str(host: &str) -> Result<Self, Self::Err> { in from_str()
795 Err(InvalidUri::UriMissHost.into()) in from_str()
849 type Err types
[all...]
/commonlibrary/rust/ylong_http/ylong_http/src/response/
H A Dstatus.rs54 return Err(ErrorKind::InvalidInput.into()); in from_u16()
84 return Err(ErrorKind::InvalidInput.into()); in from_bytes()
92 return Err(ErrorKind::InvalidInput.into()); in from_bytes()
486 Err(HttpError::from(ErrorKind::InvalidInput)) in ut_status_code_from_u16()
490 Err(HttpError::from(ErrorKind::InvalidInput)) in ut_status_code_from_u16()
524 Err(HttpError::from(ErrorKind::InvalidInput)) in ut_status_code_from_bytes()
530 Err(HttpError::from(ErrorKind::InvalidInput)) in ut_status_code_from_bytes()
534 Err(HttpError::from(ErrorKind::InvalidInput)) in ut_status_code_from_bytes()
540 Err(HttpError::from(ErrorKind::InvalidInput)) in ut_status_code_from_bytes()
544 Err(HttpErro in ut_status_code_from_bytes()
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/
H A Dc_ssl_stream.rs142 Err(ref e) if e.code() == SslErrorCode::ZERO_RETURN => {} in poll_shutdown()
145 Err(ref e) in poll_shutdown()
151 Err(e) => { in poll_shutdown()
152 return Poll::Ready(Err(e in poll_shutdown()
166 Err(e) => match e.code() { in check_result_to_poll()
168 _ => Poll::Ready(Err(e)), in check_result_to_poll()
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ssl/
H A Dctx.rs186 Err(_) => return Err(ErrorStack::get()),
236 None => return Err(ErrorStack::get()),
240 Err(_) => Err(ErrorStack::get()),
253 _ => Err(ErrorStack::get()),
307 Err(_) => return Err(ErrorStack::get()),
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/bounded/
H A Darray.rs97 Err(actual) => tail = actual, in prepare_send()
125 SendPosition::Full => Err(TrySendError::Full(value)),
126 SendPosition::Closed => Err(TrySendError::Closed(value)),
136 SendPosition::Closed => Err(SendError(value)),
161 Err(TryRecvError::Closed)
163 Err(TryRecvError::Empty)
171 Err(TryRecvError::Closed) => return Ready(Err(RecvError)),
172 Err(TryRecvError::Empty) => {}
179 Err(TryRecvErro
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/quic/
H A Dmod.rs106 if let Err(e) = conn.connect_inner(stream, &mut new_ssl, tls_config).await {
108 return Err(e);
114 Err(HttpClientError::from_str(
152 e = Err(HttpClientError::from_str(
156 if let Err(quiche::Error::Done) =
166 Err(quiche::Error::Done) => {
169 Err(err) => {
171 e = Err(HttpClientError::from_error(ErrorKind::Connect, err));
207 Err(quiche::Error::Done) => {
210 Err(
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/
H A Dstate.rs142 Err(actual) => cur = actual,
155 return Err(ErrorKind::TaskShutdown);
159 return Err(ErrorKind::TaskStateInvalid);
168 Err(actual) => cur = actual,
200 Err(actual) => cur = actual,
219 return Err(cur);
223 return Err(cur);
232 Err(actual) => cur = actual,
245 return Err(cur);
248 return Err(cu
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/
H A Dasync_source.rs85 Err(ref e) if e.kind() == io::ErrorKind::WouldBlock => {
129 Err(e) if e.kind() == io::ErrorKind::WouldBlock => {
145 return Err(io::ErrorKind::WouldBlock.into());
149 Err(ref e) if e.kind() == io::ErrorKind::WouldBlock => {
151 Err(io::ErrorKind::WouldBlock.into())
190 Poll::Ready(Err(e)) => return Poll::Ready(Err(e)),

Completed in 9 milliseconds

123456