Home
last modified time | relevance | path

Searched refs:ref (Results 1 - 19 of 19) sorted by relevance

/commonlibrary/c_utils/base/test/unittest/common/
H A Dutils_rwlock_test.cpp75 thread first(bind(&TestRWLock::WriteStr, ref(test), ref(WRITE_IN_1))); in HWTEST_F()
79 thread second(bind(&TestRWLock::ReadStr, ref(test), ref(readOut1))); in HWTEST_F()
80 thread third(bind(&TestRWLock::WriteStr, ref(test), ref(WRITE_IN_2))); in HWTEST_F()
82 thread fourth(bind(&TestRWLock::ReadStr, ref(test), ref(readOut2))); in HWTEST_F()
104 thread first(bind(&TestRWLock::WriteStr, ref(test), ref(WRITE_IN_ in HWTEST_F()
[all...]
H A Dutils_safe_block_queue_test.cpp175 threads[i] = std::thread(PutHandleThreadData, std::ref(demoDatas[i]), i); in HWTEST_F()
233 threads[i] = std::thread(PutHandleThreadDataTime, std::ref(demoDatas[i]), i, system_clock::from_time_t(timeT)); in HWTEST_F()
302 threads[i] = std::thread(PutHandleThreadDataTime, std::ref(demoDatas[i]), i, system_clock::from_time_t(timeT)); in HWTEST_F()
349 std::ref(demoDatas[i]), i, system_clock::from_time_t(timeT)); in HWTEST_F()
402 threads[i] = std::thread(GetHandleThreadDataTime, std::ref(demoDatas[i]), i, system_clock::from_time_t(timeT)); in HWTEST_F()
456 std::ref(demoDatas[i]), i, system_clock::from_time_t(timeT)); in HWTEST_F()
506 std::ref(demoDatas[i]), i, system_clock::from_time_t(timeT)); in HWTEST_F()
569 std::ref(demoDatas[i]), i, system_clock::from_time_t(timeT)); in HWTEST_F()
574 std::ref(demoDatas[i]), i, system_clock::from_time_t(timeT)); in HWTEST_F()
617 std::ref(demoData in HWTEST_F()
[all...]
H A Dutils_safe_block_queue_tracking.cpp172 threads[i] = std::thread(PutHandleThreadData, std::ref(demoDatas[i]), i); in HWTEST_F()
241 threads[i] = std::thread(PutHandleThreadDataTime, std::ref(demoDatas[i]), i, system_clock::from_time_t(timeT)); in HWTEST_F()
323 threads[i] = std::thread(PutHandleThreadDataTime, std::ref(demoDatas[i]), i, system_clock::from_time_t(timeT)); in HWTEST_F()
381 std::ref(demoDatas[i]), i, system_clock::from_time_t(timeT)); in HWTEST_F()
457 std::ref(demoDatas[i]), i, system_clock::from_time_t(timeT)); in HWTEST_F()
532 std::ref(demoDatas[i]), i, system_clock::from_time_t(timeT)); in HWTEST_F()
594 threads[i] = std::thread(PutHandleThreadDataTime, std::ref(demoDatas[i]), i, system_clock::from_time_t(timeT)); in HWTEST_F()
662 std::ref(demoDatas[i]), i, system_clock::from_time_t(timeT)); in HWTEST_F()
667 std::ref(demoDatas[i]), i, system_clock::from_time_t(timeT)); in HWTEST_F()
H A Dutils_safe_map_test.cpp255 threads[i] = std::thread(lamfuncIterate, std::ref(demoData), i, system_clock::from_time_t(timeT)); in HWTEST_F()
299 threads[i] = std::thread(lamfuncInsert, std::ref(demoData), key, i, system_clock::from_time_t(timeT)); in HWTEST_F()
300 checkThread[i] = std::thread(lamfuncCheck, std::ref(demoData), key, system_clock::from_time_t(timeT)); in HWTEST_F()
349 threads[i] = std::thread(lamfuncInsert, std::ref(demoData), in HWTEST_F()
352 std::ref(demoData), key + std::to_string(i), system_clock::from_time_t(timeT))); in HWTEST_F()
437 threads[i] = std::thread(lamfuncInsert, std::ref(demoData), in HWTEST_F()
440 std::ref(demoData), key + std::to_string(i), i + 1, system_clock::from_time_t(timeT))); in HWTEST_F()
H A Dutils_safe_queue_test.cpp95 std::ref(demoDatas[i]), i, system_clock::from_time_t(timeT)); in AllThreadPut()
104 std::ref(demoDatas[i]), i, system_clock::from_time_t(timeT)); in AllThreadGet()
/commonlibrary/c_utils/base/test/benchmarktest/rwlock_benchmark_test/
H A Drwlock_benchmark_test.cpp103 thread first(bind(&TestRWLock::WriteStr, ref(test), ref(WRITE_IN_1))); in BENCHMARK_F()
108 thread second(bind(&TestRWLock::ReadStr, ref(test), ref(readOut1))); in BENCHMARK_F()
109 thread third(bind(&TestRWLock::WriteStr, ref(test), ref(WRITE_IN_2))); in BENCHMARK_F()
111 thread fourth(bind(&TestRWLock::ReadStr, ref(test), ref(readOut2))); in BENCHMARK_F()
139 thread first(bind(&TestRWLock::WriteStr, ref(test), ref(WRITE_IN_ in BENCHMARK_F()
[all...]
/commonlibrary/c_utils/base/test/benchmarktest/safe_block_queue_benchmark_test/
H A Dsafe_block_queue_benchmark_test.cpp245 threads[i] = std::thread(PutHandleThreadData, std::ref(demoDatas[i]), i); in BENCHMARK_F()
270 std::ref(demoDatas[i]), i, timeT); in BENCHMARK_F()
301 std::ref(demoDatas[i]), i, timeT); in BENCHMARK_F()
348 std::ref(demoDatas[i]), i, timeT); in BENCHMARK_F()
401 std::ref(demoDatas[i]), i, timeT); in BENCHMARK_F()
449 std::ref(demoDatas[i]), i, timeT); in BENCHMARK_F()
496 std::ref(demoDatas[i]), i, timeT); in BENCHMARK_F()
541 std::ref(demoDatas[i]), i, timeT); in BENCHMARK_F()
545 std::ref(demoDatas[i]), i, timeT); in BENCHMARK_F()
592 std::ref(demoData in BENCHMARK_F()
[all...]
/commonlibrary/c_utils/base/test/benchmarktest/safe_queue_benchmark_test/
H A Dsafe_queue_benchmark_test.cpp147 std::ref(demoDatas[i]), i, system_clock::from_time_t(timeT)); in AllThreadPut()
155 std::ref(demoDatas[i]), i, system_clock::from_time_t(timeT)); in AllThreadGet()
164 std::ref(demoDatas[i]), i, system_clock::from_time_t(timeT)); in AllThreadErase()
173 std::ref(demoDatas[i]), system_clock::from_time_t(timeT)); in AllThreadEmpty()
/commonlibrary/c_utils/base/test/benchmarktest/safe_map_benchmark_test/
H A Dsafe_map_benchmark_test.cpp436 threads[i] = std::thread(lamfuncIterate, std::ref(demoData), i, timeT); in BENCHMARK_F()
487 threads[i] = std::thread(lamfuncInsert, std::ref(demoData), key, i, timeT); in BENCHMARK_F()
488 checkThread[i] = std::thread(lamfuncCheck, std::ref(demoData), key, timeT); in BENCHMARK_F()
539 threads[i] = std::thread(lamfuncInsert, std::ref(demoData), key + std::to_string(i), i, timeT); in BENCHMARK_F()
541 std::ref(demoData), key + std::to_string(i), timeT)); in BENCHMARK_F()
588 threads[i] = std::thread(lamfuncInsert, std::ref(demoData), in BENCHMARK_F()
591 std::ref(demoData), key + std::to_string(i), i + 1, timeT)); in BENCHMARK_F()
/commonlibrary/c_utils/base/src/
H A Drefbase.cpp82 RefTracker(RefTracker* exTracker, const void* id, int strong, int weak, int ref, int pid, int tid);
98 RefTracker::RefTracker(RefTracker* exTracker, const void* id, int strong, int weak, int ref, int pid, int tid) in RefTracker() argument
99 : ptrID (id), strongRefCnt (strong), weakRefCnt (weak), refCnt (ref), PID (pid), TID (tid), exTrace (exTracker) in RefTracker()
112 RefTracker* ref = exTrace; in PopTrace() local
115 return ref; in PopTrace()
302 // only weak ptr but never had a strong ref, we should do nothing here theoretically. But it may cause a leak. in DecWeakRefCount()
523 UTILS_LOGF("%{public}p still incStrongRef after last strong ref", this); in IncStrongRef()
/commonlibrary/ets_utils/js_concurrent_module/common/helper/
H A Dnapi_helper.h52 static napi_value GetReferenceValue(napi_env env, napi_ref ref);
53 static void DeleteReference(napi_env env, napi_ref ref);
H A Dnapi_helper.cpp240 napi_value NapiHelper::GetReferenceValue(napi_env env, napi_ref ref) in GetReferenceValue() argument
243 napi_get_reference_value(env, ref, &result); in GetReferenceValue()
247 void NapiHelper::DeleteReference(napi_env env, napi_ref ref) in DeleteReference() argument
249 napi_delete_reference(env, ref); in DeleteReference()
/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A Dtask.h212 CallbackInfo(napi_env env, uint32_t count, napi_ref ref, Task* task) in CallbackInfo()
213 : hostEnv(env), refCount(count), callbackRef(ref), task(task), onCallbackSignal(nullptr), worker(nullptr) {} in CallbackInfo()
/commonlibrary/ets_utils/js_concurrent_module/worker/test/
H A Dtest_worker.cpp210 napi_ref ref = NapiHelper::CreateReference(env, obj, 1); in SetWorkerRef() local
211 worker->workerRef_ = ref; in SetWorkerRef()
248 napi_ref ref = NapiHelper::CreateReference(env, obj, 1); in RemoveGlobalCallObject() local
251 worker->AddGlobalCallObject(instanceName, ref); in RemoveGlobalCallObject()
297 napi_ref ref = NapiHelper::CreateReference(env, obj, 1); in TestHostOnMessageInner() local
298 worker->workerRef_ = ref; in TestHostOnMessageInner()
366 napi_ref ref = NapiHelper::CreateReference(env, obj, 1); in HostOnGlobalCallInner001() local
367 worker->AddGlobalCallObject(instanceName, ref); in HostOnGlobalCallInner001()
395 napi_ref ref = NapiHelper::CreateReference(env, obj, 1); in HostOnGlobalCallInner002() local
396 worker->AddGlobalCallObject(instanceName, ref); in HostOnGlobalCallInner002()
427 napi_ref ref = NapiHelper::CreateReference(env, obj, 1); HostOnGlobalCallInner003() local
461 napi_ref ref = NapiHelper::CreateReference(env, obj, 1); HostOnGlobalCallInner004() local
494 napi_ref ref = NapiHelper::CreateReference(env, obj, 1); HostOnGlobalCallInner005() local
526 napi_ref ref = NapiHelper::CreateReference(env, obj, 1); HostOnGlobalCallInner006() local
573 napi_ref ref = NapiHelper::CreateReference(env, obj, 1); HostOnError() local
592 napi_ref ref = NapiHelper::CreateReference(env, obj, 1); HostOnErrorInner() local
670 napi_ref ref = NapiHelper::CreateReference(workerEnv, obj, 1); TestWorkerOnMessageInner() local
721 napi_ref ref = NapiHelper::CreateReference(workerEnv, obj, 1); HandleHostException() local
795 napi_ref ref = NapiHelper::CreateReference(workerEnv, obj, 1); RemoveListenerInner() local
830 napi_ref ref = NapiHelper::CreateReference(env, obj, 1); ParentPortAddListenerInnerTest() local
[all...]
/commonlibrary/ets_utils/js_concurrent_module/worker/
H A Dworker.h76 FindWorkerListener(napi_env env, napi_ref ref) : env_(env), ref_(ref) {} in FindWorkerListener()
/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
H A Dtest_taskpool.cpp936 napi_ref ref = NapiHelper::CreateReference(env, thisValue, 1); in HWTEST_F() local
937 taskGroupManager.AddTask(groupId, ref, task->taskId_); in HWTEST_F()
2037 napi_ref ref = NapiHelper::CreateReference(env, thisValue, 0); in HWTEST_F() local
2039 CallbackInfo* cbInfo = new CallbackInfo(env, 1, ref, task); in HWTEST_F()
2068 napi_ref ref = NapiHelper::CreateReference(env, thisValue, 0); in HWTEST_F() local
2070 CallbackInfo* cbInfo = new CallbackInfo(env, 1, ref, task); in HWTEST_F()
2102 napi_ref ref = NapiHelper::CreateReference(env, thisValue, 0); in HWTEST_F() local
2104 CallbackInfo* cbInfo = new CallbackInfo(env, 1, ref, task); in HWTEST_F()
2146 napi_ref ref = NapiHelper::CreateReference(env, thisValue, 0); in HWTEST_F() local
2148 CallbackInfo* cbInfo = new CallbackInfo(env, 1, ref, tas in HWTEST_F()
2426 napi_ref ref = NapiHelper::CreateReference(env, thisValue, 1); HWTEST_F() local
2727 napi_ref ref = NapiHelper::CreateReference(env, thisValue, 1); HWTEST_F() local
2760 napi_ref ref = NapiHelper::CreateReference(env, thisValue, 1); HWTEST_F() local
3889 napi_ref ref = NapiHelper::CreateReference(env, thisValue, 0); HWTEST_F() local
3906 napi_ref ref = NapiHelper::CreateReference(env, thisValue, 0); HWTEST_F() local
3933 napi_ref ref = NapiHelper::CreateReference(env, thisValue, 0); HWTEST_F() local
4526 napi_ref ref = NapiHelper::CreateReference(env, thisValue, 0); HWTEST_F() local
[all...]
H A Dtest.cpp333 napi_ref ref = NapiHelper::CreateReference(env, val, 0); in CancelTask() local
334 task->taskRef_ = ref; in CancelTask()
610 napi_ref ref = NapiHelper::CreateReference(env, obj, 1); in CheckTask() local
611 group->groupRef_ = ref; in CheckTask()
/commonlibrary/c_utils/base/test/benchmarktest/safe_block_queue_tracking_benchmark_test/
H A Dsafe_block_queue_tracking_benchmark_test.cpp155 threads[i] = std::thread(function, std::ref(demoDatas[i]), i, timeT);
249 threads[i] = std::thread(PutHandleThreadData, std::ref(demoDatas[i]), i); in BENCHMARK_F()
/commonlibrary/c_utils/base/test/benchmarktest/refbase_benchmark_test/
H A Drefbase_benchmark_test.cpp912 RefBase ref; in BENCHMARK_F() local
913 sptr<RefBase> baseObject = sptr<RefBase>::MakeSptr(ref); in BENCHMARK_F()

Completed in 27 milliseconds