| /commonlibrary/c_utils/base/test/benchmarktest/rwlock_benchmark_test/ |
| H A D | rwlock_benchmark_test.cpp | 93 * @tc.desc: RWLock here is under write-first mode. If there are some writing operation waiting,
103 thread first(bind(&TestRWLock::WriteStr, ref(test), ref(WRITE_IN_1))); in BENCHMARK_F()
104 // Try our best to make `first` get the lock in BENCHMARK_F()
114 first.join(); in BENCHMARK_F()
129 * @tc.desc: RWLock here is not under write-first mode. So if there are writing and reading operations in queue
139 thread first(bind(&TestRWLock::WriteStr, ref(test), ref(WRITE_IN_1))); in BENCHMARK_F()
148 first.join(); in BENCHMARK_F()
160 * @tc.desc: This test case validates the default constructor of RWLock. By default, the RWLock is in write-first mode.
171 thread first(bind(&TestRWLock::WriteStr, ref(test), ref(WRITE_IN_1))); in BENCHMARK_F()
177 first in BENCHMARK_F()
[all...] |
| /commonlibrary/c_utils/base/test/unittest/common/ |
| H A D | utils_rwlock_test.cpp | 67 * @tc.desc: RWLock here is under write-first mode. If there are some writing operation waiting,
75 thread first(bind(&TestRWLock::WriteStr, ref(test), ref(WRITE_IN_1))); in HWTEST_F()
76 this_thread::sleep_for(std::chrono::milliseconds(4)); // Try our best to make `first` get the lock in HWTEST_F()
85 first.join(); in HWTEST_F()
96 * @tc.desc: RWLock here is not under write-first mode. So if there are writing and reading operations in queue
104 thread first(bind(&TestRWLock::WriteStr, ref(test), ref(WRITE_IN_1))); in HWTEST_F()
113 first.join(); in HWTEST_F()
|
| /commonlibrary/memory_utils/libmeminfo/src/ |
| H A D | meminfo.cpp | 132 if (memtrack->GetDevMem(pid, memTrackerType.first, records) != HDF_SUCCESS) {
in GetGraphicsMemory()
142 if (memTrackerType.first == MEMORY_TRACKER_TYPE_GL) {
in GetGraphicsMemory()
145 } else if (memTrackerType.first == MEMORY_TRACKER_TYPE_GRAPH) {
in GetGraphicsMemory()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/ |
| H A D | socket_addr.rs | 35 if bytes.first() == Some(&0) {
55 match bytes.first() {
|
| /commonlibrary/c_utils/base/src/ |
| H A D | thread_ex.cpp | 182 bool first = true; in ThreadStart() local
186 if (first) { in ThreadStart()
187 first = false; in ThreadStart()
|
| H A D | string_ex.cpp | 234 bool IsSameTextStr(const string& first, const string& second) in IsSameTextStr() argument
236 return UpperStr(first) == UpperStr(second); in IsSameTextStr()
|
| H A D | timer.cpp | 172 reactor_->CancelTimer(itor.first); in DoUnregister()
|
| H A D | io_event_reactor.cpp | 265 int fd = events[idx].first; in HandleAll()
|
| /commonlibrary/c_utils/base/include/ |
| H A D | safe_map.h | 122 map_.erase(ret.first); in EnsureInsert()
211 callback(it -> first, it -> second); in Iterate()
|
| H A D | string_ex.h | 181 * @brief Obtains the first substring between the substrings specified
211 * @param first Indicates the first string to check.
215 bool IsSameTextStr(const std::string& first, const std::string& second);
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/common/ |
| H A D | mod.rs | 160 while let [first, rest @ ..] = bytes { in trim_ascii_start()
161 if first.is_ascii_whitespace() { in trim_ascii_start()
|
| /commonlibrary/ets_utils/js_sys_module/process/ |
| H A D | js_process.cpp | 274 while (iter.first != iter.second) {
in Off()
275 NAPI_CALL(env, napi_delete_reference(env, iter.first->second));
in Off()
277 iter.first = eventMap.erase(iter.first);
in Off()
|
| /commonlibrary/ets_utils/js_concurrent_module/utils/locks/ |
| H A D | async_lock.cpp | 221 data->first = this; in AsyncDestroy()
237 delete lockAndWork->first; in AsyncDestroyCallback()
|
| H A D | async_lock_manager.cpp | 376 AsyncLockIdentity identity = {true, entry.first, ""}; in CreateLockStates()
390 AsyncLockIdentity identity = {false, 0, entry.first}; in CreateLockStates()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/representation/ |
| H A D | decoder.rs | 263 /// `FirstByte` is responsible for decoding the first byte of the index of
345 /// `LengthFirstByte` is responsible for decoding the first byte of the
606 ($octets: literal, $({ $pat: ident $(, $kind: ident)? => $first: expr $(, $second: expr)?} $(,)?)*) => { in ut_repr_decoder()
610 inner_test_case!(decoder, $pat $(, $kind)? => $first $(, $second)?); in ut_repr_decoder()
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| H A D | task_manager.cpp | 1040 if (taskInfo.first != 0) { in NotifyDependencyTaskInfo()
1041 EnqueueTaskId(taskInfo.first, taskInfo.second); in NotifyDependencyTaskInfo()
1168 if (it->first == taskId) { in DequeuePendingTaskInfo()
1169 result = std::make_pair(it->first, it->second); in DequeuePendingTaskInfo()
1237 iter->second.first = totalDuration; in StoreTaskDuration()
1253 return iter->second.first; in GetTaskDuration()
1256 } else if (iter->second.first == 0) { in GetTaskDuration()
1259 return iter->second.first - iter->second.second; in GetTaskDuration()
1713 // refresh priority default values on first creation in CreateOrGetGlobalRunner()
1774 globalSeqRunner_.erase(iter->first); in RemoveSequenceRunner()
[all...] |
| H A D | worker.cpp | 388 if (taskInfo.first == 0) {
in PerformTask()
394 Task* task = TaskManager::GetInstance().GetTask(taskInfo.first);
in PerformTask()
|
| /commonlibrary/ets_utils/js_util_module/util/ |
| H A D | js_textdecoder.cpp | 170 char *utf8Str = tempPair.first; in GetResultStr()
178 char *utf8Str = tempPair.first; in GetResultStr()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/util/ |
| H A D | linked_list.rs | 101 if let Some(first) = head.next {
102 L::node(first).as_mut().prev = node;
263 /// 3. Remove the first node from the list and check the list.
|
| /commonlibrary/ets_utils/js_concurrent_module/worker/ |
| H A D | worker.cpp | 222 "the type of the first param must be string."); in Constructor()
597 "the type of listener first param must be string."); in AddListener()
646 "the type of removelistener the first param must be string."); in RemoveListener()
705 "the type of DispatchEvent first param must be event object."); in DispatchEvent()
1031 "the type of worker listener first param must be string."); in ParentPortAddEventListener()
1075 "the type of worker DispatchEvent first param must be Event."); in ParentPortDispatchEvent()
1190 if (iter->first == instanceName) { in RemoveGlobalCallObject()
1509 if (pair.first == globalCallId_) { in HostOnGlobalCallInner()
1510 currentCallId = pair.first; in HostOnGlobalCallInner()
1621 int32_t errCode = pair.first; in HandleGlobalCallError()
[all...] |
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
| H A D | test_taskpool.cpp | 165 ASSERT_TRUE(result.first == 0); in HWTEST_F()
277 ASSERT_TRUE(result.first == 0); in HWTEST_F()
520 ASSERT_TRUE(result.first == taskId); in HWTEST_F()
667 ASSERT_EQ(res.first, 24); in HWTEST_F()
822 ASSERT_TRUE(result.first == 36); in HWTEST_F()
830 ASSERT_TRUE(result.first == 37); in HWTEST_F()
833 ASSERT_TRUE(result.first == 0); in HWTEST_F()
|
| /commonlibrary/ets_utils/js_api_module/url/ |
| H A D | js_url.cpp | 323 if (i.first == urlinfo.scheme && i.second == it) {
in AnalysisPort()
1740 HandleIllegalChar(winput, result[0].first);
in ToUSVString()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/request/uri/ |
| H A D | mod.rs | 235 let query = match rest.first() { in from_bytes()
|
| /commonlibrary/ets_utils/js_api_module/buffer/test/ |
| H A D | test_napi.cpp | 767 * @tc.desc: The index of the first occurrence of value in buf.
784 * @tc.desc: The index of the first occurrence of value in buf.
801 * @tc.desc: The index of the first occurrence of value in buf.
991 std::string type = item->first; in HWTEST_F()
|
| /commonlibrary/ets_utils/js_concurrent_module/worker/test/ |
| H A D | test_worker.cpp | 1591 ASSERT_EQ(pair.first, 2); in HWTEST_F()
|