| /commonlibrary/rust/ylong_runtime/ylong_signal/tests/ |
| D | signal.rs | 55 let res = unsafe { in sdv_signal_register_succeed() localVariable
62 let res = unsafe { in sdv_signal_register_succeed() localVariable
78 let res = ylong_signal::deregister_signal_action(libc::SIGTERM); in sdv_signal_register_succeed() localVariable
83 let res = unsafe { in sdv_signal_register_succeed() localVariable
93 let res = ylong_signal::deregister_signal_hook(libc::SIGTERM); in sdv_signal_register_succeed() localVariable
96 let res = ylong_signal::deregister_signal_hook(libc::SIGINT); in sdv_signal_register_succeed() localVariable
115 let res = unsafe { ylong_signal::register_signal_action(libc::SIGSEGV, move || {}) }; in sdv_signal_register_failed() localVariable
118 let res = unsafe { ylong_signal::register_signal_action(libc::SIGTERM, move || {}) }; in sdv_signal_register_failed() localVariable
120 let res = unsafe { ylong_signal::register_signal_action(libc::SIGTERM, move || {}) }; in sdv_signal_register_failed() localVariable
123 let res = ylong_signal::deregister_signal_hook(libc::SIGTERM); in sdv_signal_register_failed() localVariable
[all …]
|
| /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 { in sdv_block_on_nest_spawn() localVariable
67 let res = ylong_runtime::block_on(async { in sdv_block_on_nest_spawn() localVariable
96 let res = runtime.block_on(task()); in sdv_block_on_nest_spawn_spawn_blocking() localVariable
98 let res = ylong_runtime::block_on(task()); in sdv_block_on_nest_spawn_spawn_blocking() localVariable
139 let res = runtime.block_on(task()); in sdv_block_on_nest_spawn_and_spawn() localVariable
141 let res = ylong_runtime::block_on(task()); in sdv_block_on_nest_spawn_and_spawn() localVariable
175 let res = runtime.block_on(task()); in sdv_block_on_nest_spawn_nest_spawn() localVariable
177 let res = ylong_runtime::block_on(task()); in sdv_block_on_nest_spawn_nest_spawn() localVariable
[all …]
|
| D | async_fs.rs | 34 let res = file.write(&buf).await.unwrap(); in sdv_async_fs_write() localVariable
43 let res = file.read(&mut buf).await.unwrap(); in sdv_async_fs_write() localVariable
63 let res = file.write(&buf).await.unwrap(); in sdv_async_fs_read() localVariable
69 let res = file.read(&mut buf).await.unwrap(); in sdv_async_fs_read() localVariable
78 let res = file.read(&mut buf).await.unwrap(); in sdv_async_fs_read() localVariable
107 let res = file.write(&buf).await.unwrap(); in sdv_async_fs_rw() localVariable
192 let res = file.write(&buf).await.unwrap(); in sdv_async_fs_seek() localVariable
306 let res = file.set_len(10).await; in sdv_async_fs_set_len() localVariable
309 let res = ylong_runtime::fs::remove_file(file_path).await; in sdv_async_fs_set_len() localVariable
326 let res = file.try_clone().await; in sdv_async_fs_try_clone() localVariable
[all …]
|
| D | async_buf_write.rs | 119 let res = file.write(buf).await.unwrap(); in sdv_buf_writer_seek() localVariable
208 let res = buf_writer.write_all(b"something").await; in sdv_buf_writer_stdio_write() localVariable
210 let res = buf_writer.flush().await; in sdv_buf_writer_stdio_write() localVariable
212 let res = buf_writer.shutdown().await; in sdv_buf_writer_stdio_write() localVariable
217 let res = buf_writer.write_all(b"something").await; in sdv_buf_writer_stdio_write() localVariable
219 let res = buf_writer.flush().await; in sdv_buf_writer_stdio_write() localVariable
221 let res = buf_writer.shutdown().await; in sdv_buf_writer_stdio_write() 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
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/fs/ |
| D | async_dir.rs | 580 let res = match block.pop_front() { in poll_next() localVariable
751 let res = remove_file(file_path).await; in ut_fs_create_remove_file() localVariable
784 let res = rename(file_path, "new_file1.txt").await; in ut_fs_rename() localVariable
787 let res = remove_file("new_file1.txt").await; in ut_fs_rename() localVariable
808 let res = write(file_path, input.as_bytes()).await; in ut_fs_write_and_read_to_string() localVariable
813 let res = remove_file(file_path).await; in ut_fs_write_and_read_to_string() localVariable
834 let res = write(file_path, input.as_bytes()).await; in ut_fs_write_and_read() localVariable
840 let res = remove_file(file_path).await; in ut_fs_write_and_read() localVariable
856 let res = read_link(file_path).await; in ut_fs_read_link() localVariable
876 let res = copy(file_path, "new_file5.txt").await; in ut_fs_copy() localVariable
[all …]
|
| /commonlibrary/ets_utils/js_sys_module/test/ |
| 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/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
241 let res = stdout.write_all(b"something").await; in ut_test_stdio_write() localVariable
243 let res = stdout.flush().await; in ut_test_stdio_write() localVariable
245 let res = stdout.shutdown().await; in ut_test_stdio_write() localVariable
253 let res = stderr.write_all(b"something").await; in ut_test_stdio_write() localVariable
255 let res = stderr.flush().await; in ut_test_stdio_write() localVariable
257 let res = stderr.shutdown().await; in ut_test_stdio_write() localVariable
|
| /commonlibrary/ets_utils/js_concurrent_module/test/ |
| D | test_concurrent.cpp | 44 bool res; variable
54 bool res; variable
66 bool res = NapiHelper::IsNotUndefined(env, param); variable
107 bool res = NapiHelper::IsArray(env, propNames); variable
124 bool res = NapiHelper::IsArray(env, strAttribute); variable
140 bool res; variable
209 bool res = false; variable
345 bool res = false; variable
357 bool res = false; variable
561 bool res = NapiHelper::IsNumber(env, numberAttribute); variable
[all …]
|
| /commonlibrary/rust/ylong_json/src/ |
| D | deserializer.rs | 956 let res = from_slice::<i32>(incorrect_input); in ut_deserialize_simple_error() localVariable
960 let res = from_slice::<bool>(incorrect_input); in ut_deserialize_simple_error() localVariable
964 let res = from_slice::<bool>(incorrect_input); in ut_deserialize_simple_error() localVariable
968 let res = from_slice::<bool>(incorrect_input); in ut_deserialize_simple_error() localVariable
972 let res = from_slice::<bool>(incorrect_input); in ut_deserialize_simple_error() localVariable
976 let res = from_slice::<u64>(incorrect_input); in ut_deserialize_simple_error() localVariable
980 let res = from_slice::<u64>(incorrect_input); in ut_deserialize_simple_error() localVariable
984 let res = from_slice::<i64>(incorrect_input); in ut_deserialize_simple_error() localVariable
988 let res = from_slice::<f64>(incorrect_input); in ut_deserialize_simple_error() localVariable
992 let res = from_slice::<String>(incorrect_input); in ut_deserialize_simple_error() localVariable
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_signal/src/ |
| D | common.rs | 181 let res = unsafe { in ut_signal_register() localVariable
188 let res = unsafe { in ut_signal_register() localVariable
204 let res = Signal::deregister_action(libc::SIGTERM); in ut_signal_register() localVariable
209 let res = unsafe { in ut_signal_register() localVariable
219 let res = Signal::deregister_hook(libc::SIGTERM); in ut_signal_register() localVariable
222 let res = Signal::deregister_hook(libc::SIGINT); in ut_signal_register() localVariable
|
| /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/uri/test/ |
| D | test_napi.cpp | 617 bool res = uri.IsAbsolute(); variable
624 bool res = uri.IsAbsolute(); variable
631 bool res = uri.IsAbsolute(); variable
638 bool res = uri.IsRelative(); variable
645 bool res = uri.IsRelative(); variable
652 bool res = uri.IsOpaque(); variable
659 bool res = uri.IsOpaque(); variable
666 bool res = uri.IsHierarchical(); variable
673 bool res = uri.IsHierarchical(); variable
680 bool res = uri.IsHierarchical(); variable
[all …]
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/ |
| D | octets.rs | 57 let res: u8 = u8::from_be_bytes(bytes); in into_u8() localVariable
60 let res: u8 = u8::from_le_bytes(bytes); in into_u8() localVariable
73 let res: u16 = u16::from_be_bytes(bytes); in into_u16() localVariable
76 let res: u16 = u16::from_le_bytes(bytes); in into_u16() localVariable
89 let res: u32 = u32::from_be_bytes(bytes); in into_u32() localVariable
92 let res: u32 = u32::from_le_bytes(bytes); in into_u32() localVariable
105 let res: u64 = u64::from_be_bytes(bytes); in into_u64() localVariable
108 let res: u64 = u64::from_le_bytes(bytes); in into_u64() localVariable
255 let res = match len { in write_varint_with_len() 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_http/ylong_http/src/h3/qpack/format/ |
| D | decoder.rs | 250 let res = InstValueString::new( in decode() localVariable
264 let res = InstNameAndValue::new( in decode() localVariable
306 let res = ReprValueString::new( in decode() localVariable
320 let res = ReprValueString::new( in decode() localVariable
334 let res = in decode() localVariable
364 let res: usize; in decode() localVariable
395 let res: usize; in decode() localVariable
450 let res = localVariable
551 let res = HuffmanStringBytes::new(length).decode(&buf[buf_index..]); in decode() localVariable
559 let res = AsciiStringBytes::new(length).decode(&buf[buf_index..]); in decode() localVariable
[all …]
|
| /commonlibrary/ets_utils/js_api_module/buffer/test/ |
| D | test_napi.cpp | 123 uint32_t res = buf->Copy(nullptr, 0, 0, 0); variable
262 int32_t res = buf->ReadInt32BE(0); variable
279 int32_t res = buf->ReadInt32BE(1); variable
296 int32_t res = buf->ReadInt32BE(1); variable
314 int32_t res = buf->ReadInt32LE(0); variable
334 int32_t res = buf->ReadInt32LE(0); variable
352 int32_t res = buf->ReadInt32LE(1); variable
370 int32_t res = buf->ReadUInt32BE(0); variable
388 int32_t res = buf->ReadUInt32BE(0); variable
406 int32_t res = buf->ReadUInt32BE(1); variable
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/ |
| D | mod.rs | 18 let res = unsafe { $fn($($arg, )*) }; localVariable
55 let res = unsafe { $fn($($arg, )*) }; localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/ |
| D | chunk.rs | 1444 let mut res = b"400\r\n".to_vec(); in res_message() localVariable
1455 let mut res = b"400\r\n".to_vec(); in res_trailer_message() localVariable
1617 let res = decoder.decode(&chunk_body_bytes[..1]); in ut_chunk_body_decode_0() localVariable
1629 let res = decoder.decode(&chunk_body_bytes[1..2]); in ut_chunk_body_decode_0() localVariable
1641 let res = decoder.decode(&chunk_body_bytes[2..2]); in ut_chunk_body_decode_0() localVariable
1653 let res = decoder.decode(&chunk_body_bytes[2..3]); in ut_chunk_body_decode_0() localVariable
1666 let res = decoder.decode(&chunk_body_bytes[3..5]); in ut_chunk_body_decode_0() localVariable
1679 let res = decoder.decode(&chunk_body_bytes[5..9]); in ut_chunk_body_decode_0() localVariable
1692 let res = decoder.decode(&chunk_body_bytes[9..9]); in ut_chunk_body_decode_0() localVariable
1705 let res = decoder.decode(&chunk_body_bytes[9..10]); in ut_chunk_body_decode_0() localVariable
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| D | ylong_tokio_unbounded_mpsc.rs | 34 let res = receiver.recv().await.unwrap(); localVariable
68 let res = receiver.recv().await.unwrap(); localVariable
|
| D | ylong_tokio_bounded_mpsc.rs | 34 let res = receiver.recv().await.unwrap(); localVariable
68 let res = receiver.recv().await.unwrap(); localVariable
|