/ohos5.0/base/msdp/device_status/rust/ipc/client/src/ |
H A D | lib.rs | 53 Err(err) => { in connect() 59 Err(err) => { in connect() 61 Err(FusionErrorCode::Fail) in connect() 73 Err(_) => { in add_interface_token() 75 Err(FusionErrorCode::Fail) in add_interface_token() 98 Err(FusionErrorCode::Fail) in enable() 121 Err(FusionErrorCode::Fail) in disable() 144 Err(FusionErrorCode::Fail) in start() 167 Err(FusionErrorCode::Fail) in stop() 192 Err(FusionErrorCode::Fail) in add_watch() [all …]
|
/ohos5.0/base/security/code_signature/services/key_enable/src/ |
H A D | profile_utils.rs | 215 Err(_) => Err("UDID is not valid UTF-8".to_string()), in init_udid() 334 Err(_) => { in process_profile() 402 return Err(()); in validate_and_convert_inputs() 411 Err(_) => { in process_data() 419 Err(_) => { in process_data() 427 Err(_) => { in process_data() 429 Err(()) in process_data() 461 return Err(()); in enable_key_in_profile_internal() 465 return Err(()); in enable_key_in_profile_internal() 470 return Err(()); in enable_key_in_profile_internal() [all …]
|
H A D | cert_path_utils.rs | 65 _ => Err(()), in from_str() 94 _ => Err(()), in from_str() 189 Err(e) => { in parse_cert_profile() 197 Err(e) => { in parse_cert_profile() 205 Err(e) => { in parse_cert_profile() 213 Err(e) => { in parse_cert_profile() 221 Err(e) => { in parse_cert_profile() 229 Err(e) => { in parse_cert_profile() 264 Err(e) => { in load_cert_path_from_json_file() 275 Err(_) => { in load_cert_path_from_json_file() [all …]
|
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/tests/ |
H A D | udp_socket_test.rs | 32 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(e) => { in sdv_send_to_recv_from() [all …]
|
H A D | tcp_test.rs | 37 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() 67 Err(e) => panic!("tcp write failed: {e:?}"), in sdv_tcp_server() 75 Err(_) => continue, in sdv_tcp_server() 108 Err(e) => panic!("tcp accept failed: {e:?}"), in sdv_tcp_server_vectored() 120 Err(e) if e.kind() == io::ErrorKind::WouldBlock => { in sdv_tcp_server_vectored() 124 Err(e) => panic!("tcp write failed: {e:?}"), in sdv_tcp_server_vectored() 141 Err(e) => panic!("tcp write failed: {e:?}"), in sdv_tcp_server_vectored() [all …]
|
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h3/ |
H A D | encoder.rs | 142 Err(FrameEncoderErr::NoCurrentFrame) in encode_frame() 162 Err(_) => Err(FrameEncoderErr::NoCurrentFrame), in encode() 191 Err(FrameEncoderErr) in encode() 204 Err(_) => Err(FrameEncoderErr::NoCurrentFrame), in encode() 229 Err(FrameEncoderErr) in encode() 242 Err(_) => Err(FrameEncoderErr::NoCurrentFrame), in encode() 255 Err(FrameEncoderErr) in encode() 268 Err(_) => Err(FrameEncoderErr::NoCurrentFrame), in encode() 321 Err(_) => Err(FrameEncoderErr::NoCurrentFrame), in encode() 333 Err(_) => Err(FrameEncoderErr::NoCurrentFrame), in encode() [all …]
|
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
H A D | output.rs | 86 Poll::Ready(Err(e)) => { in poll_read_frame() 102 Poll::Ready(Err(e)) => { in poll_read_frame() 109 Err(e) => { in poll_read_frame() 111 Poll::Ready(Err(_)) => { in poll_read_frame() 130 Poll::Ready(Err(e)) => return Poll::Ready(Err(e)), in poll_read_frame() 135 return Poll::Ready(Err(e)); in poll_read_frame() 145 Poll::Ready(Err(_)) => { in poll_blocked_task() 179 Poll::Ready(Err(e)) => { in poll_iterator_frames() 180 return Poll::Ready(Err(e)); in poll_iterator_frames() 200 Poll::Ready(_) => Poll::Ready(Err(exit_err)), in transmit_error() [all …]
|
/ohos5.0/base/msdp/device_status/rust/subsystem/dsoftbus/sys/src/ |
H A D | dsoftbus.rs | 615 Err(err) => { in on_session_closed() 858 Err(err) => { in init() 882 Err(err) => { in release() 923 Err(err) => { in open_input_softbus() 952 Err(err) => { in close_input_softbus() 995 Err(err) => { in on_session_opened() 1025 Err(err) => { in on_session_closed() 1060 Err(err) => { in on_bytes_received() 1103 Err(err) => { in send_msg() 1195 Err(err) => { in get_session_dev_map() [all …]
|
/ohos5.0/base/msdp/device_status/rust/modules/coordination/server/src/ |
H A D | coordination.rs | 42 Err(FusionErrorCode::Fail) in enable() 49 Err(FusionErrorCode::Fail) in disable() 56 Err(FusionErrorCode::Fail) in start() 63 Err(FusionErrorCode::Fail) in stop() 70 Err(FusionErrorCode::Fail) in get_state() 77 Err(FusionErrorCode::Fail) in register_listener() 84 Err(FusionErrorCode::Fail) in unregister_listener()
|
H A D | lib.rs | 49 let param = GeneralCoordinationParam::deserialize(data).or(Err(FusionErrorCode::Fail))?; in enable() 56 let param = GeneralCoordinationParam::deserialize(data).or(Err(FusionErrorCode::Fail))?; in disable() 63 let param = StartCoordinationParam::deserialize(data).or(Err(FusionErrorCode::Fail))?; in start() 70 let param = StopCoordinationParam::deserialize(data).or(Err(FusionErrorCode::Fail))?; in stop() 77 let param = GeneralCoordinationParam::deserialize(data).or(Err(FusionErrorCode::Fail))?; in add_watch() 84 let param = GeneralCoordinationParam::deserialize(data).or(Err(FusionErrorCode::Fail))?; in remove_watch() 91 Err(FusionErrorCode::Fail) in set_param() 97 let param = GetCoordinationStateParam::deserialize(data).or(Err(FusionErrorCode::Fail))?; in get_param() 104 Err(FusionErrorCode::Fail) in control()
|
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/ |
H A D | epoll.rs | 42 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(err), in deregister() 117 if let Err(_err) = syscall!(close(self.ep)) { in drop()
|
H A D | socket.rs | 30 if let Err(e) = syscall!(setsockopt( in set_non_block() 38 return Err(e); in set_non_block() 41 if let Err(e) = syscall!(fcntl(socket, libc::F_SETFL, libc::O_NONBLOCK)) { in set_non_block() 43 return Err(e); in set_non_block() 46 if let Err(e) = syscall!(fcntl(socket, libc::F_SETFD, libc::FD_CLOEXEC)) { in set_non_block() 48 return Err(e); in set_non_block()
|
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ssl/ |
H A D | stream.rs | 125 Err(self.get_error(ret)) in ssl_read() 137 Err(self.get_error(ret)) in ssl_write() 170 Err(self.get_error(ret)) in connect() 203 Err(err) => { in read() 204 return Err(err in read() 221 Err(err) => { in write() 222 return Err(err in write() 273 return Err(SslError { in verify_server_cert() 282 return Err(SslError { in verify_server_cert() 292 return Err(SslError { in verify_server_cert() [all …]
|
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/request/ |
H A D | method.rs | 117 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(HttpError::from(ErrorKind::InvalidInput)) in ut_method_from_bytes()
|
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/request/uri/ |
H A D | mod.rs | 568 Err(InvalidUri::InvalidScheme) in from_bytes() 658 Err(InvalidUri::InvalidAuthority) in from_bytes() 846 Err(InvalidUri::InvalidPath) in from_bytes() 1008 Err(InvalidUri::InvalidScheme) in scheme_token() 1140 Err(InvalidUri::UriMissHost) in host_port() 1409 (Err(res), Err(tar)) => assert_eq!(res, tar), in ut_uri_from_bytes() 1472 Err(HttpError::from(ErrorKind::Uri( in ut_uri_from_bytes() 1479 Err(HttpError::from(ErrorKind::Uri( in ut_uri_from_bytes() 1486 Err(HttpError::from(ErrorKind::Uri( in ut_uri_from_bytes() 1498 Err(HttpError::from(ErrorKind::Uri( in ut_uri_from_bytes() [all …]
|
/ohos5.0/base/security/asset/interfaces/inner_kits/c/src/ |
H A D | lib.rs | 46 Err(_) => return None, in into_map() 80 Err(e) => return e.code as i32, in add_asset() 83 if let Err(e) = manager.add(&map) { in add_asset() 100 Err(e) => return e.code as i32, in remove_asset() 130 Err(e) => return e.code as i32, in update_asset() 159 Err(e) => return e.code as i32, in pre_query_asset() 163 Err(e) => return e.code as i32, in pre_query_asset() 168 Err(e) => e.code as i32, in pre_query_asset() 195 Err(e) => return e.code as i32, in query_asset() 199 Err(e) => return e.code as i32, in query_asset() [all …]
|
/ohos5.0/base/request/request/services/src/task/ |
H A D | upload.rs | 92 Poll::Ready(Err(e)) => Poll::Ready(Err(e)), in poll_read() 105 Poll::Ready(Err(e)) => Poll::Ready(Err(e)), in poll_read() 171 Err(err) => build_request_common(&task, index, Err(err)), in build_stream_request() 215 Err(err) => build_request_common(&task, index, Err(err)), in build_multipart_request() 232 Err(e) => { in build_request_common() 324 return Err(TaskError::Failed(Reason::OthersError)); in upload_inner() 372 return Err(TaskError::Failed(Reason::BuildRequestFailed)); in upload_one_file() 402 Err(e) => { in upload_one_file() 414 return Err(TaskError::Failed(Reason::Dns)); in upload_one_file() 416 return Err(TaskError::Failed(Reason::Ssl)); in upload_one_file() [all …]
|
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/response/ |
H A D | status.rs | 54 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() 487 Err(HttpError::from(ErrorKind::InvalidInput)) in ut_status_code_from_u16() 491 Err(HttpError::from(ErrorKind::InvalidInput)) in ut_status_code_from_u16() 525 Err(HttpError::from(ErrorKind::InvalidInput)) in ut_status_code_from_bytes() 531 Err(HttpError::from(ErrorKind::InvalidInput)) in ut_status_code_from_bytes() 535 Err(HttpError::from(ErrorKind::InvalidInput)) in ut_status_code_from_bytes() 541 Err(HttpError::from(ErrorKind::InvalidInput)) in ut_status_code_from_bytes() 545 Err(HttpError::from(ErrorKind::InvalidInput)) in ut_status_code_from_bytes() [all …]
|
/ohos5.0/base/security/asset/services/db_key_operator/src/ |
H A D | lib.rs | 50 Err(ret) => Err(ret), in generate_secret_key_if_needed() 53 Err(ret) => Err(ret), in generate_secret_key_if_needed() 119 Err(e) => Err(e), in get_db_key() 122 Err(e) => Err(e), in get_db_key()
|
/ohos5.0/base/msdp/device_status/rust/modules/coordination/client/src/ |
H A D | lib.rs | 59 Err(FusionErrorCode::Fail) in enable_coordination() 79 Err(FusionErrorCode::Fail) in disable_coordination() 102 Err(FusionErrorCode::Fail) in start_coordination() 124 Err(FusionErrorCode::Fail) in stop_coordination() 148 Err(_) => { in get_coordination_state() 150 Err(FusionErrorCode::Fail) in get_coordination_state() 156 Err(FusionErrorCode::Fail) in get_coordination_state() 174 Err(FusionErrorCode::Fail) in register_coordination_listener() 192 Err(FusionErrorCode::Fail) in unregister_coordination_listener()
|
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h2/ |
H A D | decoder.rs | 451 return Err(H2Error::StreamError( in decode_priority_payload() 517 return Err(H2Error::StreamError( in decode_window_update_payload() 1410 Err(H2Error::ConnectionError(ErrorCode::FrameSizeError)) in ut_decode_ping_payload() 1418 Err(H2Error::ConnectionError(ErrorCode::ProtocolError)) in ut_decode_ping_payload() 1466 Err(H2Error::ConnectionError(ErrorCode::ProtocolError)) in ut_decode_priority_payload() 1516 Err(H2Error::ConnectionError(ErrorCode::ProtocolError)) in ut_decode_goaway_payload() 1610 Err(H2Error::ConnectionError(ErrorCode::ProtocolError)) in ut_decode_reset_payload() 1692 Err(H2Error::ConnectionError(ErrorCode::ProtocolError)) in ut_decode_settings_payload() 1735 Err(H2Error::ConnectionError(ErrorCode::ProtocolError)) in ut_decode_push_promise_payload() 1743 Err(H2Error::ConnectionError(ErrorCode::ProtocolError)) in ut_decode_push_promise_payload() [all …]
|
/ohos5.0/base/request/request/services/src/service/command/ |
H A D | resume.rs | 27 return Err(IpcStatusCode::Failed); in resume() 39 return Err(IpcStatusCode::Failed); in resume() 46 return Err(IpcStatusCode::Failed); in resume() 51 return Err(IpcStatusCode::Failed); in resume() 60 return Err(IpcStatusCode::Failed); in resume() 69 return Err(IpcStatusCode::Failed); in resume()
|
H A D | start.rs | 27 return Err(IpcStatusCode::Failed); in start() 36 return Err(IpcStatusCode::Failed); in start() 43 return Err(IpcStatusCode::Failed); in start() 48 return Err(IpcStatusCode::Failed); in start() 57 return Err(IpcStatusCode::Failed); in start() 66 return Err(IpcStatusCode::Failed); in start()
|
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/bounded/ |
H A D | array.rs | 97 Err(actual) => tail = actual, in prepare_send() 125 SendPosition::Full => Err(TrySendError::Full(value)), in try_send() 126 SendPosition::Closed => Err(TrySendError::Closed(value)), in try_send() 136 SendPosition::Closed => Err(SendError(value)), in send() 161 Err(TryRecvError::Closed) in try_recv() 163 Err(TryRecvError::Empty) in try_recv() 171 Err(TryRecvError::Closed) => return Ready(Err(RecvError)), in poll_recv() 172 Err(TryRecvError::Empty) => {} in poll_recv() 179 Err(TryRecvError::Closed) => Ready(Err(RecvError)), in poll_recv() 180 Err(TryRecvError::Empty) => Pending, in poll_recv()
|
/ohos5.0/foundation/communication/ipc/interfaces/innerkits/rust/src/parcel/ |
H A D | msg.rs | 204 false => Err(IpcStatusCode::Failed), in write_file() 251 false => Err(IpcStatusCode::Failed), in write_buffer() 272 false => Err(IpcStatusCode::Failed), in read_buffer() 279 false => Err(IpcStatusCode::Failed), in write_string16() 290 false => Err(IpcStatusCode::Failed), in write_string16_vec() 353 Err(IpcStatusCode::Failed) in read_remote() 496 Err(ParcelSetError) in set_size() 517 Err(ParcelSetError) in set_capacity() 537 Err(ParcelSetError) in set_max_capacity() 560 Err(ParcelSetError) in set_read_position() [all …]
|