Home
last modified time | relevance | path

Searched refs:err (Results 1 - 25 of 55) sorted by relevance

123

/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/
H A Dwaker.rs55 let err = io::Error::last_os_error();
56 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),
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(err), in deregister()
[all...]
/commonlibrary/memory_utils/libpurgeablemem/cpp/src/
H A Dux_page_table.cpp34 PMState err = InitUxPageTable(uxpt_, addr, len); /* dataPtr is aligned */ in UxPageTable() local
35 if (err != PM_OK) { in UxPageTable()
36 HILOG_ERROR(LOG_CORE, "%{public}s: InitUxPageTable fail, %{public}s", __func__, GetPMStateName(err)); in UxPageTable()
46 PMState err = DeinitUxPageTable(uxpt_); in ~UxPageTable() local
47 if (err != PM_OK) { in ~UxPageTable()
48 HILOG_ERROR(LOG_CORE, "%{public}s: deinit upt fail, %{public}s", __func__, GetPMStateName(err)); in ~UxPageTable()
H A Dpurgeable_mem_base.cpp68 PMState err = PM_OK; in BeginRead() local
85 err = PMB_BUILD_ALL_FAIL; in BeginRead()
91 PM_HILOG_ERROR(LOG_CORE, "%{public}s: err %{public}s, UxptePut. tryTime:%{public}d", in BeginRead()
92 __func__, GetPMStateName(err), tryTimes); in BeginRead()
119 PMState err = PM_OK; in BeginWrite() local
131 err = PMB_BUILD_ALL_FAIL; in BeginWrite()
134 if (err == PM_OK) { in BeginWrite()
138 PM_HILOG_ERROR(LOG_CORE, "%{public}s: err %{public}s, UxptePut.", __func__, GetPMStateName(err)); in BeginWrite()
/commonlibrary/rust/ylong_http/ylong_http/src/
H A Derror.rs48 fn from(err: InvalidUri) -> Self { in from()
49 ErrorKind::Uri(err).into() in from()
55 fn from(err: H2Error) -> Self { in from()
56 ErrorKind::H2(err).into() in from()
62 fn from(err: H3Error) -> Self { in from()
63 ErrorKind::H3(err).into() in from()
/commonlibrary/rust/ylong_http/ylong_http_client/src/
H A Derror.rs137 pub(crate) fn from_error<T>(kind: ErrorKind, err: T) -> Self
143 cause: Cause::Other(err.into()),
148 pub(crate) fn from_tls_error<T>(kind: ErrorKind, err: T) -> Self
154 cause: Cause::Tls(err.into()),
165 pub(crate) fn from_io_error(kind: ErrorKind, err: io::Error) -> Self {
168 cause: Cause::Io(err),
172 pub(crate) fn from_dns_error(kind: ErrorKind, err: io::Error) -> Self {
175 cause: Cause::Dns(err),
287 Self::Dns(err) => Debug::fmt(err, in fmt()
[all...]
/commonlibrary/memory_utils/libpurgeablemem/c/src/
H A Dpurgeable_mem_c.c93 PMState err = InitUxPageTable(pugObj->uxPageTable, (uint64_t)(pugObj->dataPtr), size); /* dataPtr is aligned */ in PurgMemCreate_() local
94 if (err != PM_OK) { in PurgMemCreate_()
96 "%{public}s: InitUxPageTable fail, %{public}s", __func__, GetPMStateName(err)); in PurgMemCreate_()
159 PMState err = PM_OK; in PurgMemDestroy() local
169 err = PMB_DESTORY_FAIL; in PurgMemDestroy()
179 err = PM_UNMAP_PURG_FAIL; in PurgMemDestroy()
184 err = PM_UXPT_PRESENT_DATA_PURGED; in PurgMemDestroy()
195 err = deinitRet; in PurgMemDestroy()
202 if (err == PM_OK) { in PurgMemDestroy()
208 PM_HILOG_ERROR_C(LOG_CORE, "%{public}s: fail, %{public}s", __func__, GetPMStateName(err)); in PurgMemDestroy()
298 PMState err = PM_OK; PurgMemBeginRead() local
333 PMState err = PM_OK; PurgMemBeginWrite() local
[all...]
/commonlibrary/ets_utils/js_util_module/util/
H A Djs_stringdecoder.cpp59 std::string err = "decoder error, "; in Write() local
60 err += u_errorName(codeFlag); in Write()
61 napi_throw_error(env, ERROR_CODE, err.c_str()); in Write()
95 std::string err = "decoder error, "; in End() local
96 err += u_errorName(errorCode); in End()
97 napi_throw_error(env, ERROR_CODE, err.c_str()); in End()
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/
H A Dlistener.rs68 Err(err) => { in accept()
69 return Err(err); in accept()
90 Err(err) => Err(err), in accept()
169 let err = io::Error::new(io::ErrorKind::Other, "Cannot transfer address into socket.");
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/tests/
H A Dsdv_http_error.rs32 .err(); in sdv_client_send_request_repeatedly()
48 decoder.decode(b"HTTP/1.3 304 OK\r\nCon").err().unwrap() in sdv_client_send_request_repeatedly()
55 decoder.decode(b"HTTP/1.3 304 OK\r\nCon").err().unwrap() in sdv_client_send_request_repeatedly()
H A Dsdv_http_headers.rs35 format!("{:?}", HeaderValue::from_bytes(b"Foo\r\n").err().unwrap()), in sdv_client_send_request_repeatedly()
40 format!("{:?}", value.append_bytes(b"Foo\r\n").err().unwrap()), in sdv_client_send_request_repeatedly()
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/
H A Dbio.rs176 fn retry_error(err: &io::Error) -> bool { in retry_error()
178 err.kind(), in retry_error()
193 Ok(Err(err)) => {
194 state.error = Some(err);
198 Err(err) => {
199 state.panic = Some(err);
235 Ok(Err(err)) => {
236 if retry_error(&err) {
239 $state.error = Some(err);
243 Err(err)
[all...]
H A Derror.rs28 use crate::util::c_openssl::ffi::err::ERR_get_error_all;
30 use crate::util::c_openssl::ffi::err::{ERR_func_error_string, ERR_get_error_line_data};
31 use crate::util::c_openssl::ffi::err::{ERR_lib_error_string, ERR_reason_error_string};
213 for err in &self.0 { in fmt()
214 write!(fmt, "{err} ")?; in fmt()
225 while let Some(err) = StackError::get() {
226 vec.push(err);
H A Dx509.rs22 use super::ffi::err::{ERR_clear_error, ERR_peek_last_error};
92 let err = ERR_peek_last_error();
93 if error_get_lib(err) == ERR_LIB_PEM
94 && error_get_reason(err) == PEM_R_NO_START_LINE
179 pub(crate) fn from_raw(err: c_int) -> X509VerifyResult {
180 X509VerifyResult(err)
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/
H A Dsocket.rs47 Err(err) if err.raw_os_error() != Some(libc::EINPROGRESS) => Err(err),
64 Err(err) => Err(err),
/commonlibrary/rust/ylong_runtime/ylong_runtime/examples/
H A Dylong_runtime_spawn_panic.rs20 let err = ylong_runtime::block_on(handle).unwrap_err(); in main()
21 assert_eq!(err.kind(), ylong_runtime::error::ErrorKind::Panic); in main()
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/udp/
H A Dsocket.rs50 Err(err) if err.raw_os_error() != Some(libc::EINPROGRESS) => Err(err),
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/dns/
H A Dresolver.rs84 Ok(Err(err)) => Err(Box::new(err) as StdError), in poll()
85 Err(err) => Err(Box::new(Error::new(io::ErrorKind::Interrupted, err)) as StdError), in poll()
126 .expect("dns resolver resolve domain occurs err"); in ut_resolver_std_dns_resolver_resolve()
156 .expect("dns resolver resolve domain occurs err"); in ut_resolver_std_dns_resolver_resolve()
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ssl/
H A Dstream.rs45 pub(crate) fn get_error(&mut self, err: c_int) -> SslError {
47 let code = self.ssl.get_error(err);
70 if let Some(err) = unsafe { get_panic::<S>(self.ssl.get_raw_bio()) } { in check_panic()
71 resume_unwind(err) in check_panic()
203 Err(err) => { in read()
204 return Err(err in read()
206 .unwrap_or_else(|err| io::Error::new(io::ErrorKind::Other, err))) in read()
221 Err(err) => { in write()
222 return Err(err in write()
[all...]
/commonlibrary/c_utils/base/src/
H A Dthread_pool.cpp52 int err = pthread_setname_np(t.native_handle(), (myName_ + std::to_string(i)).c_str()); in Start() local
53 if (err != 0) { in Start()
54 UTILS_LOGD("Failed to set name to thread. %{public}s", strerror(err)); in Start()
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h3/
H A Dstream_manager.rs449 Err(quiche::Error::StreamStopped(err)) | Err(quiche::Error::StreamReset(err)) => { in read_stream()
450 if err != H3ErrorCode::H3NoError as u64 { in read_stream()
451 return Err(DispatchErrorKind::H3(H3Error::Stream(id, err.into()))); in read_stream()
651 fn handle_error(&mut self, cx: &mut Context<'_>, err: &DispatchErrorKind) -> bool { in handle_error()
652 match err { in handle_error()
661 err => { in handle_error()
662 self.handle_connection_error(cx, err); in handle_error()
668 fn handle_stream_error(&mut self, cx: &mut Context<'_>, id: u64, err: &H3ErrorCode) { in handle_stream_error()
673 .stream_shutdown(id, Shutdown::Read, *err a in handle_stream_error()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/
H A Dylong_runtime_tcp_client_perf.rs27 Err(err) => return Err(err), in main()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/
H A Ddriver.rs252 let err = io::Error::new(io::ErrorKind::Other, "driver event store missing.");
253 return Err(err);
259 Err(err) => return Err(err),
/commonlibrary/rust/ylong_http/ylong_http/src/h2/
H A Derror.rs114 let err = match value { in try_from()
131 Ok(err) in try_from()

Completed in 8 milliseconds

123