| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| D | block_on.rs | 53 let res = runtime.block_on(async { 1 + 2 }); in sdv_single1_block_on() localVariable
55 let res = ylong_runtime::block_on(async { 1 + 2 }); in sdv_single1_block_on() localVariable
62 let res = runtime.block_on(async { runtime.block_on(async { 1 + 2 }) }); in sdv_nest_block_on() localVariable
64 let res = ylong_runtime::block_on(async { ylong_runtime::block_on(async { 1 + 2 }) }); in sdv_nest_block_on() localVariable
71 let res = runtime.block_on(async { in sdv_block_on_nest_spawn() localVariable
76 let res = ylong_runtime::block_on(async { in sdv_block_on_nest_spawn() localVariable
105 let res = runtime.block_on(task()); in sdv_block_on_nest_spawn_spawn_blocking() localVariable
107 let res = ylong_runtime::block_on(task()); in sdv_block_on_nest_spawn_spawn_blocking() localVariable
148 let res = runtime.block_on(task()); in sdv_block_on_nest_spawn_and_spawn() localVariable
150 let res = ylong_runtime::block_on(task()); in sdv_block_on_nest_spawn_and_spawn() localVariable
[all …]
|
| D | slots.rs | 54 let res = slots.remove(remove_index); in sdv_slots_huge_data_remove() localVariable
86 let res = slots.remove(index); in sdv_slots_remove_and_pop() localVariable
91 let res = slots.remove(remove_index); in sdv_slots_remove_and_pop() localVariable
96 let res = slots.remove(remove_index); in sdv_slots_remove_and_pop() localVariable
|
| D | async_read.rs | 35 let res = AsyncReadExt::read(&mut slice.as_slice(), &mut buf) in sdv_async_read_slice() localVariable
44 let res = AsyncReadExt::read(&mut slice.as_slice(), &mut buf) in sdv_async_read_slice() localVariable
68 let mut res = String::from("Hello"); in sdv_buf_reader_read_to_string() localVariable
|
| D | task_cancel.rs | 40 let res = task.await.err().unwrap(); in sdv_task_cancel_simple() localVariable
60 let res = task.await.unwrap(); in sdv_task_cancel_failed() localVariable
101 let res = handle.await; in sdv_task_cancel_multiple() localVariable
|
| D | async_fs.rs | 33 let res = file.write(&buf).await.unwrap(); in sdv_async_fs_write() localVariable
42 let res = file.read(&mut buf).await.unwrap(); in sdv_async_fs_write() localVariable
61 let res = file.write(&buf).await.unwrap(); in sdv_async_fs_read() localVariable
67 let res = file.read(&mut buf).await.unwrap(); in sdv_async_fs_read() localVariable
76 let res = file.read(&mut buf).await.unwrap(); in sdv_async_fs_read() localVariable
104 let res = file.write(&buf).await.unwrap(); in sdv_async_fs_rw() localVariable
187 let res = file.write(&buf).await.unwrap(); in sdv_async_fs_seek() localVariable
|
| D | async_buf_read.rs | 37 let mut res = vec![]; in sdv_buf_reader_read_until() localVariable
81 let mut res = String::from("Hello"); in sdv_buf_reader_read_line() localVariable
210 let res = file.write(buf).await.unwrap(); in sdv_buf_reader_seek() localVariable
218 let mut res = vec![]; in sdv_buf_reader_seek() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/fs/ |
| D | async_dir.rs | 579 let res = match block.pop_front() { in poll_next() localVariable
747 let res = remove_file(file_path).await; in ut_fs_create_remove_file() localVariable
766 let res = rename(file_path, "new_file1.txt").await; in ut_fs_rename() localVariable
769 let res = remove_file("new_file1.txt").await; in ut_fs_rename() localVariable
790 let res = write(file_path, input.as_bytes()).await; in ut_fs_write_and_read_to_string() localVariable
795 let res = remove_file(file_path).await; in ut_fs_write_and_read_to_string() localVariable
816 let res = write(file_path, input.as_bytes()).await; in ut_fs_write_and_read() localVariable
822 let res = remove_file(file_path).await; in ut_fs_write_and_read() localVariable
838 let res = read_link(file_path).await; in ut_fs_read_link() localVariable
858 let res = copy(file_path, "new_file5.txt").await; in ut_fs_copy() localVariable
[all …]
|
| D | async_file.rs | 283 let res = if buf.remaining() == 0 { in set_len() localVariable
371 let res = poll_ready!(Pin::new(state).poll(cx)); in poll_seek() localVariable
486 let res = w_buf.write(&mut &*file); in poll_write() localVariable
522 let res = poll_ready!(Pin::new(state).poll(cx)); in poll_flush() localVariable
550 let res = file.set_len(10).await; in ut_fs_file_set_len() localVariable
553 let res = remove_file(file_path).await; in ut_fs_file_set_len() localVariable
572 let res = file.try_clone().await; in ut_fs_file_try_clone() localVariable
575 let res = remove_file(file_path).await; in ut_fs_file_try_clone() localVariable
|
| /commonlibrary/ets_utils/js_sys_module/test/unittest/ |
| D | test_process.cpp | 118 bool res = false; variable
143 bool res = false; variable
165 bool res = false; variable
187 bool res = false; variable
204 bool res = false; variable
223 bool res = false; variable
242 bool res = false; variable
261 bool res = false; variable
280 bool res = false; variable
299 bool res = false; variable
[all …]
|
| /commonlibrary/c_utils/base/src/ |
| D | io_event_handler.cpp | 49 ErrCode res = reactor->AddHandler(this); in Start() local
62 ErrCode res = reactor->RemoveHandler(this); in Stop() local
75 ErrCode res = reactor->UpdateHandler(this); in Update() local
|
| D | io_event_epoll.cpp | 106 ErrCode IOEventEpoll::Polling(int timeout /* ms */, std::vector<std::pair<int, REventId>>& res) in Polling()
129 REventId res = Events::EVENT_NONE; in Epoll2Reactor() local
151 EPEventId res = 0u; in Reactor2Epoll() local
|
| D | mapped_file.cpp | 204 ErrCode res = Normalize(); in Map() local
360 int res = Map(); in Resize() local
405 ErrCode res = Unmap(); in TurnNext() local
459 ErrCode res = Unmap(); in Clear() local
478 ErrCode res = Unmap(); in ~MappedFile() local
|
| D | io_event_reactor.cpp | 44 ErrCode res = backend_->SetUp(); in SetUp() local
215 ErrCode res = backend_->ModifyEvents(fd, emask); in UpdateToDemultiplexer() local
284 ErrCode res; in Run() local
335 ErrCode res = EVENT_SYS_ERR_OK; in CleanUp() local
|
| /commonlibrary/ets_utils/js_api_module/buffer/test/ |
| D | test_napi.cpp | 121 uint32_t res = buf->Copy(nullptr, 0, 0, 0); variable
258 int32_t res = buf->ReadInt32BE(0); variable
275 int32_t res = buf->ReadInt32BE(1); variable
292 int32_t res = buf->ReadInt32BE(1); variable
310 int32_t res = buf->ReadInt32LE(0); variable
330 int32_t res = buf->ReadInt32LE(0); variable
348 int32_t res = buf->ReadInt32LE(1); variable
366 int32_t res = buf->ReadUInt32BE(0); variable
384 int32_t res = buf->ReadUInt32BE(0); variable
402 int32_t res = buf->ReadUInt32BE(1); variable
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/ |
| D | mod.rs | 16 let res = unsafe { $fn($($arg, )*) }; localVariable
51 let res = unsafe { $fn($($arg, )*) }; localVariable
|
| /commonlibrary/ets_utils/js_sys_module/process/ |
| D | js_childprocess.cpp | 127 napi_value res = nullptr; in Wait() local
150 napi_value res = nullptr; in GetOutput() local
164 napi_value res = nullptr; in GetOutput() local
178 napi_value res = nullptr; in GetErrorOutput() local
192 napi_value res = nullptr; in GetErrorOutput() local
215 napi_value res = nullptr; in Getpid() local
380 … auto res = std::find(signalType.begin(), signalType.end(), static_cast<int32_t>(signal)); in Kill() local
416 auto res = std::find(signalType.begin(), signalType.end(), temp->killSignal); in TimeoutListener() local
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| D | stdio.rs | 87 let res = loop { in read_from() localVariable
103 let res = std.write_all(&self.inner); in write_into() localVariable
133 let res = buf_inner.write_into(&mut std).map(|_| n); localVariable
168 let res = inner.flush().map(|_| 0); localVariable
|
| /commonlibrary/ets_utils/js_concurrent_module/test/ |
| D | test_concurrent.cpp | 43 bool res; variable
53 bool res; variable
102 bool res; variable
171 bool res = false; variable
288 bool res = false; variable
300 bool res = false; variable
460 napi_value res = nullptr; variable
|
| /commonlibrary/c_utils/base/test/unittest/common/ |
| D | utils_mapped_file_test.cpp | 161 std::string res; variable
220 std::string res; variable
340 std::string res; variable
622 std::string res; variable
679 std::string res; variable
760 std::string res; variable
882 std::string res; variable
1416 std::string res; variable
1485 std::string res; variable
1551 std::string res; variable
[all …]
|
| /commonlibrary/ets_utils/js_api_module/xml/test/ |
| D | test_xml.cpp | 1747 size_t res = XmlTest::GetNSCount(1); variable
1812 int res = testXml.TestGetColumnNumber(env); variable
1824 int res = testXml.TestGetLineNumber(env); variable
1839 std::string res = testXml.TestGetText(env); variable
1850 bool res = xml.ParseStartTagFuncDeal(true); variable
1862 bool res = testXml.TestParseNsp(env); variable
1875 bool res = false; variable
1887 std::string res = testXml.TestParseDelimiterInfo(env); variable
1899 bool res = testXml.TestParseEndTag(env); variable
1910 bool res = xml.ParserDoctInnerInfo(false, true); variable
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| D | state.rs | 139 let res = self.0.compare_exchange(cur, next, AcqRel, Acquire); in turning_to_running() localVariable
165 let res = self.0.compare_exchange(cur, next, AcqRel, Acquire); in turning_to_finish() localVariable
197 let res = self.0.compare_exchange(cur, next, AcqRel, Acquire); in turning_to_idle() localVariable
229 let res = self.0.compare_exchange(cur, next, AcqRel, Acquire); in turn_to_un_set_waker() localVariable
254 let res = self.0.compare_exchange(cur, next, AcqRel, Acquire); in turn_to_set_waker() localVariable
285 let res = self.0.compare_exchange(cur, next, AcqRel, Acquire); in turn_to_canceled_and_scheduled() localVariable
308 let res = self.0.compare_exchange(cur, next, AcqRel, Acquire); in turn_to_un_join_handle() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/ |
| D | chunk.rs | 1493 let mut res = b"400\r\n".to_vec(); in res_message() localVariable
1504 let mut res = b"400\r\n".to_vec(); in res_trailer_message() localVariable
1643 let res = decoder.decode(&chunk_body_bytes[..1]); in ut_chunk_body_decode_0() localVariable
1655 let res = decoder.decode(&chunk_body_bytes[1..2]); in ut_chunk_body_decode_0() localVariable
1667 let res = decoder.decode(&chunk_body_bytes[2..2]); in ut_chunk_body_decode_0() localVariable
1679 let res = decoder.decode(&chunk_body_bytes[2..3]); in ut_chunk_body_decode_0() localVariable
1692 let res = decoder.decode(&chunk_body_bytes[3..5]); in ut_chunk_body_decode_0() localVariable
1705 let res = decoder.decode(&chunk_body_bytes[5..9]); in ut_chunk_body_decode_0() localVariable
1718 let res = decoder.decode(&chunk_body_bytes[9..9]); in ut_chunk_body_decode_0() localVariable
1731 let res = decoder.decode(&chunk_body_bytes[9..10]); in ut_chunk_body_decode_0() localVariable
[all …]
|
| /commonlibrary/ets_utils/js_api_module/uri/test/ |
| D | test_napi.cpp | 593 bool res = uri.IsAbsolute(); variable
600 bool res = uri.IsAbsolute(); variable
607 bool res = uri.IsAbsolute(); variable
641 std::string res = GetStringUtf8(env, getTemp); variable
702 std::string res = GetStringUtf8(env, result); variable
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/linux/ |
| D | mod.rs | 18 let res = unsafe { libc::$fn($($arg, )*) }; localVariable
|
| /commonlibrary/ets_utils/js_util_module/util/ |
| D | js_uuid.cpp | 30 unsigned char res = 0; // 0: initialization in CharToHex() local
67 unsigned char res = '0'; in HexToChar() local
135 bool res = GenerateUuid(uuid.elements, sizeof(uuid.elements)); in GetUUID() local
|