| /commonlibrary/c_utils/base/test/unittest/common/ |
| H A D | utils_thread_test.cpp | 133 ThreadStatus status = test->Start("test_thread_01", THREAD_PROI_LOW, 1024); in HWTEST_F() local
134 EXPECT_EQ(status == ThreadStatus::OK, true); in HWTEST_F()
161 ThreadStatus status = test->Start("test_thread_02", THREAD_PROI_LOW, 1024); in HWTEST_F() local
163 EXPECT_EQ(status == ThreadStatus::OK, true); in HWTEST_F()
189 ThreadStatus status = test->Start("test_thread_03", THREAD_PROI_LOW, 1024); in HWTEST_F() local
190 EXPECT_EQ(status == ThreadStatus::OK, true); in HWTEST_F()
216 ThreadStatus status = test->Start("test_thread_04", THREAD_PROI_LOW, 1024); in HWTEST_F() local
218 EXPECT_EQ(status == ThreadStatus::OK, true); in HWTEST_F()
244 ThreadStatus status = test->Start("test_thread_05", THREAD_PROI_LOW, 1024); in HWTEST_F() local
245 EXPECT_EQ(status in HWTEST_F()
271 ThreadStatus status = test->Start("test_thread_06", THREAD_PROI_LOW, 1024); HWTEST_F() local
304 ThreadStatus status = test->Start("", THREAD_PROI_LOW, 0); HWTEST_F() local
332 ThreadStatus status = test->Start("", THREAD_PROI_NORMAL, 1024); HWTEST_F() local
387 ThreadStatus status = test->Start("", THREAD_PROI_NORMAL, 1024); HWTEST_F() local
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http/src/h2/ |
| H A D | pseudo.rs | 27 status: Option<String>,
39 status: None,
48 && self.status.is_none()
133 self.status.is_some()
137 pub fn status(&self) -> Option<&str> { in status() functions
138 self.status.as_deref() in status()
142 pub fn set_status(&mut self, status: Option<String>) { in set_status()
143 self.status = status; in set_status()
148 self.status
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/ |
| H A D | pseudo.rs | 27 status: Option<String>,
38 status: None,
47 && self.status.is_none()
132 self.status.is_some()
136 pub fn status(&self) -> Option<&str> { in status() functions
137 self.status.as_deref() in status()
141 pub fn set_status(&mut self, status: Option<String>) { in set_status()
142 self.status = status; in set_status()
147 self.status
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/ |
| H A D | events.rs | 49 pub(super) fn from_completion_status(status: &CompletionStatus) -> Event {
51 flags: status.bytes_transferred(),
52 data: status.token() as u64,
59 pub(crate) status: Box<[CompletionStatus]>,
67 status: vec![CompletionStatus::zero(); cap].into_boxed_slice(), in with_capacity()
75 for status in self.status.iter_mut() { in clear()
76 *status = CompletionStatus::zero(); in clear()
|
| H A D | afd.rs | 97 let status = NtCreateFile( in new()
111 if status != STATUS_SUCCESS { in new()
112 let raw_error = io::Error::from_raw_os_error(RtlNtStatusToDosError(status) as i32); in new()
145 let status = NtDeviceIoControlFile(
158 match status {
163 RtlNtStatusToDosError(status) as i32
178 let status = NtCancelIoFileEx(self.fd.as_raw_handle() as HANDLE, iosb, &mut cancel_iosb);
179 match status {
182 RtlNtStatusToDosError(status) as i32
262 pub status in fmt()
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http_client/tests/tcp_server/ |
| H A D | async_utils.rs | 29 Status: $status: expr,
61 Status: $status,
86 Status: $status,
119 Status: $status: expr,
146 Status: $status,
176 Status: $status: expr,
204 assert_eq!(response.status().as_u16(), $status, "Assert response status code failed") ;
|
| H A D | sync_utils.rs | 28 Status: $status: expr,
57 Status: $status,
81 Status: $status,
113 Status: $status: expr,
139 Status: $status,
168 Status: $status: expr,
193 assert_eq!(response.status().as_u16(), $status, "Assert response status code failed") ;
|
| /commonlibrary/rust/ylong_http/ylong_http_client/tests/common/ |
| H A D | async_utils.rs | 31 Status: $status: expr,
51 Status: $status,
93 Status: $status,
120 Status: $status: expr,
140 Status: $status,
181 Status: $status,
215 Status: $status: expr,
245 Status: $status,
272 Status: $status: expr,
299 Status: $status,
[all...] |
| H A D | sync_utils.rs | 30 Status: $status: expr,
50 Status: $status,
92 Status: $status,
118 Status: $status: expr,
138 Status: $status,
179 Status: $status,
213 Status: $status: expr,
242 Status: $status,
271 Status: $status: expr,
296 Status: $status,
[all...] |
| /commonlibrary/c_utils/base/test/benchmarktest/thread_benchmark_test/ |
| H A D | thread_benchmark_test.cpp | 150 ThreadStatus status = test->Start("test_thread_01", THREAD_PROI_LOW, THREAD_STACK_SIZE); in BENCHMARK_F() local
151 AssertEqual((status == ThreadStatus::OK), true, in BENCHMARK_F()
152 "(status == ThreadStatus::OK) did not equal true as expected.", state); in BENCHMARK_F()
190 ThreadStatus status = test->Start("test_thread_02", THREAD_PROI_LOW, THREAD_STACK_SIZE); in BENCHMARK_F() local
192 AssertEqual((status == ThreadStatus::OK), true, in BENCHMARK_F()
193 "status == ThreadStatus::OK did not equal true as expected.", state); in BENCHMARK_F()
254 ThreadStatus status = test->Start("test_thread_03", THREAD_PROI_LOW, THREAD_STACK_SIZE); in BENCHMARK_F() local
255 AssertEqual((status == ThreadStatus::OK), true, in BENCHMARK_F()
256 "status == ThreadStatus::OK did not equal true as expected.", state); in BENCHMARK_F()
274 ThreadStatus status in BENCHMARK_F() local
314 ThreadStatus status = test->Start("test_thread_05", THREAD_PROI_LOW, THREAD_STACK_SIZE); BENCHMARK_F() local
334 ThreadStatus status = test->Start("test_thread_06", THREAD_PROI_LOW, THREAD_STACK_SIZE); BENCHMARK_F() local
377 ThreadStatus status = test->Start("", THREAD_PROI_LOW, 0); BENCHMARK_F() local
404 ThreadStatus status = test->Start("", THREAD_PROI_NORMAL, THREAD_STACK_SIZE); ThreadTestStart() local
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | process.rs | 34 assert!(output.status.success()); in sdv_process_output_test()
41 /// SDV test cases for `status()`.
45 /// 2. Use `status()` waiting result.
52 let status = command.status().await.unwrap(); in sdv_process_status_test()
53 assert!(status.success()); in sdv_process_status_test()
72 let status = child.wait().await.unwrap(); in sdv_process_spawn_test()
73 assert!(status.success()); in sdv_process_spawn_test()
77 let status = child.wait().await.unwrap(); in sdv_process_spawn_test()
78 assert!(status in sdv_process_spawn_test()
[all...] |
| H A D | pty_process.rs | 85 let status = child.wait().await.unwrap(); in sdv_pty_process_read_and_write_test()
86 assert!(status.success()); in sdv_pty_process_read_and_write_test()
119 let status = child.wait().await.unwrap(); in sdv_pty_split_test()
120 assert!(status.success()); in sdv_pty_split_test()
151 let status = child.wait().await.unwrap(); in sdv_pty_into_split_test()
152 assert!(status.success()); in sdv_pty_into_split_test()
182 let status = child.wait().await.unwrap(); in sdv_pty_unsplit_test()
183 assert!(status.success()); in sdv_pty_unsplit_test()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/response/ |
| H A D | mod.rs | 16 pub mod status; modules
17 use status::StatusCode;
26 /// The status-line and field-line of a response-message are stored in
31 /// According to the [`RFC9112`], the origin reason-phrase of status-line is not
32 /// saved, the unified reason in `StatusCode` is used to indicate the status
36 /// [`Response`]: https://httpwg.org/specs/rfc9112.html#status.line
49 pub fn status(&self) -> StatusCode { in status() functions
50 self.part.status in status()
92 /// [`Status Line`]: https://httpwg.org/specs/rfc9112.html#status.line
98 pub status
[all...] |
| /commonlibrary/ets_utils/js_sys_module/process/ |
| H A D | js_childprocess.cpp | 102 [](napi_env env, napi_status status, void* data) {
in Spawn()
124 int32_t status;
in Wait() local
134 waitpid(optionsInfo_->pid, &status, 0);
in Wait()
135 exitCode_ = status;
in Wait()
306 void ChildProcess::EndStdOut(napi_env env, napi_status status, void* buffer)
in EndStdOut() argument
341 void ChildProcess::EndStdErr(napi_env env, napi_status status, void* buffer)
in EndStdErr() argument
390 int32_t status = 0;
in Close() local
395 if (isWait_ && !(waitpid(optionsInfo_->pid, &status, WNOHANG)) && isNeedRun_) {
in Close()
397 waitpid(optionsInfo_->pid, &status, 0);
in Close()
399 exitCode_ = status;
in Close()
435 napi_status status = napi_ok; InitOptionsInfo() local
483 int32_t status = 0; ~ChildProcess() local
[all...] |
| H A D | js_childprocess.h | 28 int status {0};
94 * Get kill status.
115 * Get exit status.
144 static void EndStdOut(napi_env env, napi_status status, void* buffer);
146 static void EndStdErr(napi_env env, napi_status status, void* buffer);
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| H A D | schedule_io.rs | 37 // ScheduleIO::status structure
43 /// ScheduleIO status
44 pub(crate) status: AtomicUsize,
82 status: AtomicUsize::new(0), in default()
112 let status_bit = Bit::from_usize(self.status.load(Acquire)); in reset()
118 self.status.store(next.as_usize(), Release); in reset()
124 let base = Bit::from_usize(self.status.load(Acquire)); in generation()
134 // Get current status and check if it contains our interest
135 let curr_bit = Bit::from_usize(self.status.load(Acquire));
162 let status_bit = Bit::from_usize(self.status
[all...] |
| /commonlibrary/c_utils/base/src/ |
| H A D | rwlock.cpp | 64 // Only when no thread has acquired a read lock or a write lock (the lock counter status is FREE) in LockWrite()
66 for (int status = LOCK_STATUS_FREE; !lockCount_.compare_exchange_weak(status, LOCK_STATUS_WRITE); in LockWrite()
67 status = LOCK_STATUS_FREE) { in LockWrite()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/ |
| H A D | simple.rs | 39 status: ReadStatus,
56 status: ReadStatus::Never, in new()
178 self.status = ReadStatus::Reading(MultiPartStates { states, index: 0 })
182 match std::mem::replace(&mut self.status, ReadStatus::Never) {
186 self.status = ReadStatus::Reading(states);
191 self.status = ReadStatus::Reading(states);
210 match self.status { in poll_read()
216 let status = if let ReadStatus::Reading(ref mut status) = self.status { in poll_read()
[all...] |
| /commonlibrary/ets_utils/js_concurrent_module/utils/locks/ |
| H A D | async_lock.cpp | 70 // IF so, we mustn't change the status. in CleanUpLockRequestOnCompletion()
171 napi_status status = napi_set_property(env, held, index, info); in FillLockState() local
172 if (status != napi_ok) { in FillLockState()
173 return status; in FillLockState()
187 napi_status status = napi_set_property(env, pending, index, info); in FillLockState() local
188 if (status != napi_ok) { in FillLockState()
189 return status; in FillLockState()
223 napi_status status = napi_create_async_work( in AsyncDestroy() local
225 if (status != napi_ok) { in AsyncDestroy()
228 status in AsyncDestroy()
[all...] |
| H A D | lock_request.cpp | 54 napi_status status = napi_create_async_work( in LockRequest() local
56 if (status != napi_ok) { in LockRequest()
91 void LockRequest::AsyncAfterWorkCallback(napi_env env, [[maybe_unused]] napi_status status, void *data) in AsyncAfterWorkCallback() argument
129 napi_status status = napi_queue_async_work(env_, work_); in CallCallbackAsync() local
131 if (status != napi_ok) { in CallCallbackAsync()
149 napi_status status = napi_call_function(env_, nullptr, cb, 0, nullptr, &result); in CallCallback() local
152 if (status == napi_ok) { in CallCallback()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/ |
| H A D | command.rs | 51 /// * Inherit stdin/stdout/stderr for spawn or status, but create pipes for
246 /// Defaults to inherit when used with spawn or status, and defaults to
269 /// Defaults to inherit when used with spawn or status, and defaults to
292 /// Defaults to inherit when used with spawn or status, and defaults to
388 /// collecting its status. By default, stdin, stdout and stderr are
401 /// .status()
403 /// .expect("Command status failed!")
408 pub fn status(&mut self) -> impl Future<Output = io::Result<ExitStatus>> { in status() functions
625 assert!(output.status.success()); in ut_process_output_test()
632 /// UT test cases for `status()`
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http/src/h1/request/ |
| H A D | encoder.rs | 154 // Component encoding status.
491 status: Option<HeaderStatus>,
513 status: Some(HeaderStatus::Name), in new()
523 status: Some(HeaderStatus::EmptyHeader), in new()
534 match self.status.take().unwrap() { in encode()
548 self.status = Some(HeaderStatus::Colon); in encode_name()
552 self.status = Some(HeaderStatus::Name); in encode_name()
563 self.status = Some(HeaderStatus::Value); in encode_colon()
567 self.status = Some(HeaderStatus::Colon); in encode_colon()
579 self.status in encode_value()
[all...] |
| /commonlibrary/ets_utils/js_util_module/util/ |
| H A D | js_uuid.cpp | 208 napi_status status = napi_ok;
in DoParseUUID() local
209 status = napi_get_value_string_utf8(env, src, nullptr, 0, &bufferSize);
in DoParseUUID()
210 if (status != napi_ok) {
in DoParseUUID()
215 status = napi_get_value_string_utf8(env, src, buffer.data(), bufferSize + 1, &bufferSize);
in DoParseUUID()
216 if (status != napi_ok) {
in DoParseUUID()
|
| /commonlibrary/ets_utils/js_sys_module/timer/ |
| H A D | timer.cpp | 62 napi_status status = napi_define_properties(env, globalObj, sizeof(properties) / sizeof(properties[0]), properties); in RegisterTime() local
63 return status == napi_ok; in RegisterTime()
88 napi_status status = napi_get_value_uint32(env, argv[0], &tId); in ClearTimer() local
89 if (status != napi_ok) { in ClearTimer()
177 napi_status status = napi_get_value_int32(env, argv[1], &timeout); in SetTimeoutInnerCore() local
178 if (status != napi_ok) { in SetTimeoutInnerCore()
|
| /commonlibrary/ets_utils/js_api_module/convertxml/ |
| H A D | js_convertxml.cpp | 305 napi_status status = napi_create_object(env, &object);
in Convert() local
306 if (status != napi_ok) {
in Convert()
344 napi_status status = napi_ok;
in DealNapiStrValue() local
345 status = napi_get_value_string_utf8(env, napi_StrValue, nullptr, -1, &bufferSize);
in DealNapiStrValue()
346 if (status != napi_ok) {
in DealNapiStrValue()
348 return status;
in DealNapiStrValue()
353 status = napi_get_value_string_utf8(env, napi_StrValue, buffer.data(), bufferSize + 1, &bufferSize);
in DealNapiStrValue()
354 if (status != napi_ok) {
in DealNapiStrValue()
356 return status;
in DealNapiStrValue()
362 return status;
in DealNapiStrValue()
[all...] |