Home
last modified time | relevance | path

Searched refs:res (Results 1 - 25 of 115) sorted by relevance

12345

/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dstdio_cargo_test.rs35 let res = stdout.write_all(b"something").await; in sdv_stdio_write()
36 assert!(res.is_ok()); in sdv_stdio_write()
37 let res = stdout.flush().await; in sdv_stdio_write()
38 assert!(res.is_ok()); in sdv_stdio_write()
39 let res = stdout.shutdown().await; in sdv_stdio_write()
40 assert!(res.is_ok()); in sdv_stdio_write()
47 let res = stderr.write_all(b"something").await; in sdv_stdio_write()
48 assert!(res.is_ok()); in sdv_stdio_write()
49 let res = stderr.flush().await; in sdv_stdio_write()
50 assert!(res in sdv_stdio_write()
[all...]
H A Dblock_on.rs53 let res = runtime.block_on(async { 1 + 2 }); in sdv_single1_block_on()
54 assert_eq!(res, 3); in sdv_single1_block_on()
55 let res = ylong_runtime::block_on(async { 1 + 2 }); in sdv_single1_block_on()
56 assert_eq!(res, 3); in sdv_single1_block_on()
62 let res = runtime.block_on(async { in sdv_block_on_nest_spawn()
66 assert_eq!(res, 3); in sdv_block_on_nest_spawn()
67 let res = ylong_runtime::block_on(async { in sdv_block_on_nest_spawn()
71 assert_eq!(res, 3); in sdv_block_on_nest_spawn()
96 let res = runtime.block_on(task()); in sdv_block_on_nest_spawn_spawn_blocking()
97 assert_eq!(res, in sdv_block_on_nest_spawn_spawn_blocking()
205 let mut res = 0; sdv_block_on_nest_batch_spawn() variables
230 let mut res = 0; sdv_block_on_nest_await_spawn() variables
264 let mut res = 0; sdv_block_on_nest_await_spawn_bug_test() variables
[all...]
H A Dasync_read.rs35 let res = AsyncReadExt::read(&mut slice.as_slice(), &mut buf) in sdv_async_read_slice()
38 assert_eq!(res, 3); in sdv_async_read_slice()
44 let res = AsyncReadExt::read(&mut slice.as_slice(), &mut buf) in sdv_async_read_slice()
47 assert_eq!(res, 2); in sdv_async_read_slice()
68 let mut res = String::from("Hello"); in sdv_buf_reader_read_to_string() variables
69 let ret = buf_reader.read_to_string(&mut res).await.unwrap(); in sdv_buf_reader_read_to_string()
71 assert_eq!(res.as_str(), "HelloWorld"); in sdv_buf_reader_read_to_string()
H A Dasync_fs.rs34 let res = file.write(&buf).await.unwrap(); in sdv_async_fs_write()
35 assert_eq!(res, 5); in sdv_async_fs_write()
43 let res = file.read(&mut buf).await.unwrap(); in sdv_async_fs_write()
44 assert_eq!(res, 5); in sdv_async_fs_write()
63 let res = file.write(&buf).await.unwrap(); in sdv_async_fs_read()
64 assert_eq!(res, 5); in sdv_async_fs_read()
69 let res = file.read(&mut buf).await.unwrap(); in sdv_async_fs_read()
70 assert_eq!(res, 5); in sdv_async_fs_read()
78 let res = file.read(&mut buf).await.unwrap(); in sdv_async_fs_read()
79 assert_eq!(res, in sdv_async_fs_read()
[all...]
H A Dasync_buf_read.rs37 let mut res = vec![]; in sdv_buf_reader_read_until() variables
38 let ret = buf_reader.read_until(b':', &mut res).await.unwrap(); in sdv_buf_reader_read_until()
40 assert_eq!(res.as_slice(), &[1, 2, 3, b':']); in sdv_buf_reader_read_until()
81 let mut res = String::from("Hello"); in sdv_buf_reader_read_line() variables
82 let ret = buf_reader.read_line(&mut res).await.unwrap(); in sdv_buf_reader_read_line()
84 assert_eq!(res.as_str(), "HelloWorld\n"); in sdv_buf_reader_read_line()
85 let ret = buf_reader.read_line(&mut res).await.unwrap(); in sdv_buf_reader_read_line()
87 assert_eq!(res.as_str(), "HelloWorld\nline"); in sdv_buf_reader_read_line()
210 let res = file.write(buf).await.unwrap(); in sdv_buf_reader_seek()
212 assert_eq!(res, 1 in sdv_buf_reader_seek()
219 let mut res = vec![]; sdv_buf_reader_seek() variables
[all...]
H A Dtask_cancel.rs40 let res = task.await.err().unwrap(); in sdv_task_cancel_simple()
41 assert_eq!(res.kind(), ErrorKind::TaskCanceled); in sdv_task_cancel_simple()
60 let res = task.await.unwrap(); in sdv_task_cancel_failed()
61 assert_eq!(res, 1); in sdv_task_cancel_failed()
101 let res = handle.await; in sdv_task_cancel_multiple()
102 assert!(res.is_err()); in sdv_task_cancel_multiple()
/commonlibrary/rust/ylong_runtime/ylong_signal/tests/
H A Dsignal.rs55 let res = unsafe { in sdv_signal_register_succeed()
60 assert!(res.is_ok()); in sdv_signal_register_succeed()
62 let res = unsafe { in sdv_signal_register_succeed()
67 assert!(res.is_ok()); in sdv_signal_register_succeed()
78 let res = ylong_signal::deregister_signal_action(libc::SIGTERM); in sdv_signal_register_succeed()
79 assert!(res.is_ok()); in sdv_signal_register_succeed()
83 let res = unsafe { in sdv_signal_register_succeed()
88 assert!(res.is_ok()); in sdv_signal_register_succeed()
93 let res = ylong_signal::deregister_signal_hook(libc::SIGTERM); in sdv_signal_register_succeed()
94 assert!(res in sdv_signal_register_succeed()
[all...]
/commonlibrary/ets_utils/js_sys_module/test/
H A Dtest_process.cpp118 bool res = false; in HWTEST_F() local
119 napi_get_value_bool(env, result, &res); in HWTEST_F()
120 ASSERT_FALSE(res); in HWTEST_F()
143 bool res = false; in HWTEST_F() local
144 napi_get_value_bool(env, result, &res); in HWTEST_F()
145 ASSERT_FALSE(res); in HWTEST_F()
165 bool res = false; in HWTEST_F() local
166 napi_is_promise(env, output, &res); in HWTEST_F()
167 ASSERT_TRUE(res); in HWTEST_F()
187 bool res in HWTEST_F() local
204 bool res = false; HWTEST_F() local
223 bool res = false; HWTEST_F() local
242 bool res = false; HWTEST_F() local
261 bool res = false; HWTEST_F() local
280 bool res = false; HWTEST_F() local
299 bool res = false; HWTEST_F() local
324 bool res = false; HWTEST_F() local
349 bool res = false; HWTEST_F() local
370 bool res = false; HWTEST_F() local
403 bool res = false; HWTEST_F() local
428 bool res = false; HWTEST_F() local
451 bool res = false; HWTEST_F() local
468 bool res = false; HWTEST_F() local
485 bool res = false; HWTEST_F() local
506 bool res = false; HWTEST_F() local
521 bool res = false; HWTEST_F() local
545 bool res = false; HWTEST_F() local
568 bool res = false; HWTEST_F() local
591 bool res = false; HWTEST_F() local
612 bool res = false; HWTEST_F() local
631 bool res = false; HWTEST_F() local
650 bool res = false; HWTEST_F() local
672 bool res = false; HWTEST_F() local
701 bool res = false; HWTEST_F() local
729 bool res = false; HWTEST_F() local
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/fs/
H A Dasync_dir.rs547 for res in std_dir.by_ref().take(BLOCK_SIZE) { in fill_block()
548 match res { in fill_block()
580 let res = match block.pop_front() { in poll_next()
586 return Ready(res); in poll_next()
751 let res = remove_file(file_path).await; in ut_fs_create_remove_file()
753 assert!(res.is_ok()); in ut_fs_create_remove_file()
784 let res = rename(file_path, "new_file1.txt").await; in ut_fs_rename()
785 assert!(res.is_ok()); in ut_fs_rename()
787 let res = remove_file("new_file1.txt").await; in ut_fs_rename()
788 assert!(res in ut_fs_rename()
[all...]
H A Dasync_file.rs73 let (file_buf, res) = poll_ready!(Pin::new(x).poll(cx))?;
76 Poll::Ready(res.map(|_| 0_u64))
79 let (file_buf, res) = poll_ready!(Pin::new(x).poll(cx))?;
81 Poll::Ready(res)
290 let (buf, res) = spawn_blocking(&TaskBuilder::new(), move || { in fmt()
291 let res = if buf.remaining() == 0 { in fmt()
300 (buf, res) in fmt()
306 res.map(|u| file.idx = u) in fmt()
503 let res = poll_ready!(Pin::new(state).poll(cx)); in poll_seek()
507 if let Err(e) = res { in poll_seek()
[all...]
/commonlibrary/ets_utils/js_util_module/util/
H A Djs_uuid.cpp31 unsigned char res = 0; // 0: initialization in CharToHex() local
59 res = it->second; in CharToHex()
61 res = HEX_ZERO_FLG; in CharToHex()
63 return res; in CharToHex()
68 unsigned char res = '0'; in HexToChar() local
70 case HEX_ZERO_FLG: res = '0'; break; in HexToChar()
71 case HEX_ONE_FLG: res = '1'; break; in HexToChar()
72 case HEX_TWO_FLG: res = '2'; break; in HexToChar()
73 case HEX_THREE_FLG: res = '3'; break; in HexToChar()
74 case HEX_FOUR_FLG: res in HexToChar()
[all...]
/commonlibrary/rust/ylong_json/src/
H A Ddeserializer.rs956 let res = from_slice::<i32>(incorrect_input); in ut_deserialize_simple_error()
957 assert!(res.is_err()); in ut_deserialize_simple_error()
960 let res = from_slice::<bool>(incorrect_input); in ut_deserialize_simple_error()
961 assert!(res.is_err()); in ut_deserialize_simple_error()
964 let res = from_slice::<bool>(incorrect_input); in ut_deserialize_simple_error()
965 assert!(res.is_err()); in ut_deserialize_simple_error()
968 let res = from_slice::<bool>(incorrect_input); in ut_deserialize_simple_error()
969 assert!(res.is_err()); in ut_deserialize_simple_error()
972 let res = from_slice::<bool>(incorrect_input); in ut_deserialize_simple_error()
973 assert!(res in ut_deserialize_simple_error()
[all...]
/commonlibrary/c_utils/base/src/
H A Dio_event_epoll.cpp106 ErrCode IOEventEpoll::Polling(int timeout /* ms */, std::vector<std::pair<int, REventId>>& res) in Polling() argument
118 res.emplace_back(std::make_pair(epollEvents[idx].data.fd, Epoll2Reactor(epollEvents[idx].events))); in Polling()
129 REventId res = Events::EVENT_NONE; in Epoll2Reactor() local
131 res |= Events::EVENT_CLOSE; in Epoll2Reactor()
135 res |= Events::EVENT_ERROR; in Epoll2Reactor()
139 res |= Events::EVENT_READ; in Epoll2Reactor()
143 res |= Events::EVENT_WRITE; in Epoll2Reactor()
146 return res; in Epoll2Reactor()
151 EPEventId res = 0u; in Reactor2Epoll() local
154 res | in Reactor2Epoll()
[all...]
H A Dio_event_handler.cpp49 ErrCode res = reactor->AddHandler(this); in Start() local
50 if (res != EVENT_SYS_ERR_OK) { in Start()
62 ErrCode res = reactor->RemoveHandler(this); in Stop() local
63 if (res != EVENT_SYS_ERR_OK) { in Stop()
75 ErrCode res = reactor->UpdateHandler(this); in Update() local
76 if (res != EVENT_SYS_ERR_OK) { in Update()
H A Dio_event_reactor.cpp44 ErrCode res = backend_->SetUp(); in SetUp() local
45 if (res != EVENT_SYS_ERR_OK) { in SetUp()
47 return res; in SetUp()
51 return res; in SetUp()
215 ErrCode res = backend_->ModifyEvents(fd, emask); in UpdateToDemultiplexer() local
216 if (res != EVENT_SYS_ERR_OK) { in UpdateToDemultiplexer()
218 new event: %{public}d, error code: %{public}d", __FUNCTION__, fd, emask, res); in UpdateToDemultiplexer()
284 ErrCode res; in Run() local
290 res = backend_->Polling(timeout, gotEvents); in Run()
292 res in Run()
335 ErrCode res = EVENT_SYS_ERR_OK; CleanUp() local
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/
H A Dstdio.rs87 let res = loop {
90 res => break res,
94 match res {
99 res
103 let res = std.write_all(&self.inner);
105 res
133 let res = buf_inner.write_into(&mut std).map(|_| n); in poll_write()
135 (res, buf_inner, std) in poll_write()
142 let (res, buf_inne in poll_write()
[all...]
/commonlibrary/rust/ylong_http/ylong_http/tests/
H A Dsdv_http_body.rs29 let mut res = b"400\r\n".to_vec(); in init_chunk() variables
31 res.extend_from_slice(&[i % 10; 100]); in init_chunk()
33 res.extend_from_slice(&[1; 24]); in init_chunk()
34 res.extend_from_slice(b"\r\n4c\r\n"); in init_chunk()
35 res.extend_from_slice(&[1; 76]); in init_chunk()
36 res.extend_from_slice(b"\r\n0\r\n"); in init_chunk()
37 res in init_chunk()
40 fn append_trailer(mut res: Vec<u8>) -> Vec<u8> { in append_trailer()
41 res.extend_from_slice(b"accept:text/html\r\n"); in append_trailer()
42 res in append_trailer()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_signal/src/
H A Dcommon.rs181 let res = unsafe { in ut_signal_register()
186 assert!(res.is_ok()); in ut_signal_register()
188 let res = unsafe { in ut_signal_register()
193 assert!(res.is_ok()); in ut_signal_register()
204 let res = Signal::deregister_action(libc::SIGTERM); in ut_signal_register()
205 assert!(res.is_ok()); in ut_signal_register()
209 let res = unsafe { in ut_signal_register()
214 assert!(res.is_ok()); in ut_signal_register()
219 let res = Signal::deregister_hook(libc::SIGTERM); in ut_signal_register()
220 assert!(res in ut_signal_register()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/
H A Dmod.rs18 let res = unsafe { $fn($($arg, )*) };
19 if res == 0 {
55 let res = unsafe { $fn($($arg, )*) };
56 if $err_fn(&res, &$err_val) {
59 Ok(res)
/commonlibrary/ets_utils/js_sys_module/process/
H A Djs_childprocess.cpp127 napi_value res = nullptr; in Wait() local
128 napi_get_undefined(env, &res); in Wait()
132 return res; in Wait()
150 napi_value res = nullptr; in GetOutput() local
151 NAPI_CALL(env, napi_get_undefined(env, &res)); in GetOutput()
153 return res; in GetOutput()
164 napi_value res = nullptr; in GetOutput() local
165 NAPI_CALL(env, napi_get_undefined(env, &res)); in GetOutput()
166 return res; in GetOutput()
178 napi_value res in GetErrorOutput() local
192 napi_value res = nullptr; GetErrorOutput() local
215 napi_value res = nullptr; Getpid() local
380 auto res = std::find(signalType.begin(), signalType.end(), static_cast<int32_t>(signal)); Kill() local
416 auto res = std::find(signalType.begin(), signalType.end(), temp->killSignal); TimeoutListener() local
[all...]
/commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/format/
H A Ddecoder.rs108 ($res: expr ,$buf_index: expr) => {
109 if let DecResult::Decoded((cnt, repr)) = $res {
112 $res
240 let res = InstValueString::new( in decode()
246 return_res!(res, buf_index) in decode()
254 let res = InstNameAndValue::new( in decode()
260 return_res!(res, buf_index) in decode()
294 let res = ReprValueString::new( in decode()
300 return_res!(res, buf_index) in decode()
308 let res in decode()
[all...]
/commonlibrary/ets_utils/js_concurrent_module/test/
H A Dtest_concurrent.cpp44 bool res; in HWTEST_F() local
45 res = NapiHelper::IsString(env, value); in HWTEST_F()
46 ASSERT_TRUE(res); in HWTEST_F()
54 bool res; in HWTEST_F() local
55 res = NapiHelper::IsNotUndefined(env, value) ? false : true; in HWTEST_F()
56 ASSERT_TRUE(res); in HWTEST_F()
66 bool res = NapiHelper::IsNotUndefined(env, param); in HWTEST_F() local
67 ASSERT_FALSE(res); in HWTEST_F()
107 bool res = NapiHelper::IsArray(env, propNames); in HWTEST_F() local
109 ASSERT_FALSE(res); in HWTEST_F()
124 bool res = NapiHelper::IsArray(env, strAttribute); HWTEST_F() local
140 bool res; HWTEST_F() local
209 bool res = false; HWTEST_F() local
345 bool res = false; HWTEST_F() local
357 bool res = false; HWTEST_F() local
561 bool res = NapiHelper::IsNumber(env, numberAttribute); HWTEST_F() local
575 bool res = NapiHelper::IsArrayBuffer(env, arrayBuffer); HWTEST_F() local
584 bool res = NapiHelper::IsArrayBuffer(env, arraybuffer); HWTEST_F() local
595 bool res = NapiHelper::IsArrayBuffer(env, numberAttribute); HWTEST_F() local
604 bool res = NapiHelper::IsAsyncFunction(env, value); HWTEST_F() local
613 bool res = NapiHelper::IsConcurrentFunction(env, value); HWTEST_F() local
622 bool res = NapiHelper::IsGeneratorFunction(env, value); HWTEST_F() local
637 bool res = NapiHelper::IsStrictEqual(env, lhs, rhs); HWTEST_F() local
653 bool res = NapiHelper::IsStrictEqual(env, lhs, rhs); HWTEST_F() local
663 bool res = NapiHelper::IsSendable(env, value); HWTEST_F() local
672 bool res = NapiHelper::IsSendable(env, value); HWTEST_F() local
688 bool res = NapiHelper::HasNameProperty(env, result, name); HWTEST_F() local
699 bool res = NapiHelper::HasNameProperty(env, result, name); HWTEST_F() local
[all...]
/commonlibrary/rust/ylong_http/ylong_http/src/body/
H A Dchunk.rs1444 let mut res = b"400\r\n".to_vec(); in res_message() variables
1446 res.extend_from_slice(&[i % 10; 100]); in res_message()
1448 res.extend_from_slice(&[0; 24]); in res_message()
1449 res.extend_from_slice(b"\r\n4c\r\n"); in res_message()
1450 res.extend_from_slice(&[0; 76]); in res_message()
1451 res.extend_from_slice(b"\r\n0\r\n\r\n"); in res_message()
1452 res in res_message()
1455 let mut res = b"400\r\n".to_vec(); in res_trailer_message() variables
1457 res.extend_from_slice(&[i % 10; 100]); in res_trailer_message()
1459 res in res_trailer_message()
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/
H A Dnormalizer.rs260 let res = part.headers.get("Host").unwrap(); in ut_request_format()
261 assert_eq!(res.to_string().unwrap().as_bytes(), b"example1.com"); in ut_request_format()
277 let res = body_len_parser.parse().unwrap(); in ut_body_length_parser()
278 assert_eq!(res, BodyLength::UntilClose); in ut_body_length_parser()
285 let res = body_len_parser.parse().unwrap(); in ut_body_length_parser()
286 assert_eq!(res, BodyLength::Chunk); in ut_body_length_parser()
293 let res = body_len_parser.parse().unwrap(); in ut_body_length_parser()
294 assert_eq!(res, BodyLength::Length(20)); in ut_body_length_parser()
301 let res = body_len_parser.parse(); in ut_body_length_parser()
302 assert!(res in ut_body_length_parser()
[all...]
/commonlibrary/rust/ylong_http/ylong_http/src/h3/
H A Doctets.rs30 let res = <$ty>::from_be_bytes(bytes);
31 Ok(res)
37 let res = peek_bytes!($this.buf[$this.idx..], $ty, $len);
39 res

Completed in 15 milliseconds

12345