Home
last modified time | relevance | path

Searched refs:threadLockInfo (Results 1 – 5 of 5) sorted by relevance

/ohos5.0/foundation/communication/ipc/ipc/native/c/rpc/src/
H A Drpc_process_skeleton.c150 if (threadLockInfo == NULL) { in AddDataThreadInWait()
152 if (threadLockInfo == NULL) { in AddDataThreadInWait()
159 free(threadLockInfo); in AddDataThreadInWait()
164 free(threadLockInfo); in AddDataThreadInWait()
168 free(threadLockInfo); in AddDataThreadInWait()
181 pthread_cond_wait(&threadLockInfo->condition, &threadLockInfo->mutex); in AddDataThreadInWait()
189 if (threadLockInfo != NULL) { in WakeUpDataThread()
366 if (threadLockInfo == NULL) { in AddSendThreadInWait()
368 if (threadLockInfo == NULL) { in AddSendThreadInWait()
380 free(threadLockInfo); in AddSendThreadInWait()
[all …]
/ohos5.0/foundation/communication/ipc/services/dbinder/c/src/
H A Ddbinder_service.c290 if (threadLockInfo == NULL) { in NewThreadLock()
296 free(threadLockInfo); in NewThreadLock()
301 free(threadLockInfo); in NewThreadLock()
305 return threadLockInfo; in NewThreadLock()
330 if (threadLockInfo == NULL) { in InvokerRemoteDBinder()
337 free(threadLockInfo); in InvokerRemoteDBinder()
351 free(threadLockInfo); in InvokerRemoteDBinder()
355 ret = pthread_cond_timedwait(&threadLockInfo->condition, &threadLockInfo->mutex, &waitTime); in InvokerRemoteDBinder()
360 free(threadLockInfo); in InvokerRemoteDBinder()
373 free(threadLockInfo); in InvokerRemoteDBinder()
[all …]
/ohos5.0/foundation/communication/ipc/services/dbinder/dbinder_service/src/
H A Ddbinder_service.cpp474 … std::shared_ptr<struct ThreadLockInfo> threadLockInfo = std::make_shared<struct ThreadLockInfo>(); in InvokerRemoteDBinder()
475 result = AttachThreadLockInfo(seqNumber, stub->GetDeviceID(), threadLockInfo); in InvokerRemoteDBinder()
482 std::unique_lock<std::mutex> lock(threadLockInfo->mutex); in InvokerRemoteDBinder()
483 if (threadLockInfo->condition.wait_for(lock, std::chrono::seconds(WAIT_FOR_REPLY_MAX_SEC), in InvokerRemoteDBinder()
484 [&threadLockInfo] { return threadLockInfo->ready; }) == false) { in InvokerRemoteDBinder()
488 threadLockInfo->ready = false; in InvokerRemoteDBinder()
1040 std::shared_ptr<struct ThreadLockInfo> threadLockInfo = QueryThreadLockInfo(seqNumber); in WakeupThreadByStub()
1041 if (threadLockInfo == nullptr) { in WakeupThreadByStub()
1046 std::unique_lock<std::mutex> lock(threadLockInfo->mutex); in WakeupThreadByStub()
1047 threadLockInfo->ready = true; in WakeupThreadByStub()
[all …]
/ohos5.0/foundation/communication/ipc/ipc/native/src/core/source/
H A Dipc_process_skeleton.cpp826 if (threadLockInfo != nullptr) { in WakeUpDataThread()
831 threadLockInfo->ready = true; in WakeUpDataThread()
832 threadLockInfo->condition.notify_one(); in WakeUpDataThread()
840 std::shared_ptr<SocketThreadLockInfo> threadLockInfo; in AddDataThreadInWait() local
842 threadLockInfo = QueryThreadLockInfo(threadId); in AddDataThreadInWait()
843 if (threadLockInfo == nullptr) { in AddDataThreadInWait()
844 threadLockInfo = std::make_shared<struct SocketThreadLockInfo>(); in AddDataThreadInWait()
845 if (!AttachThreadLockInfo(threadLockInfo, threadId)) { in AddDataThreadInWait()
852 std::unique_lock<std::mutex> lock_unique(threadLockInfo->mutex); in AddDataThreadInWait()
853 … threadLockInfo->condition.wait(lock_unique, [&threadLockInfo] { return threadLockInfo->ready; }); in AddDataThreadInWait()
[all …]
/ohos5.0/foundation/communication/ipc/services/dbinder/test/unittest/
H A Ddbinder_service_unittest.cpp1005 std::shared_ptr<OHOS::ThreadLockInfo> threadLockInfo = std::make_shared<OHOS::ThreadLockInfo>(); variable
1006 EXPECT_TRUE(threadLockInfo != nullptr);
1007 dBinderService->AttachThreadLockInfo(seqNumber, "networkId", threadLockInfo);
1010 EXPECT_EQ(dBinderService->QueryThreadLockInfo(seqNumber), threadLockInfo);
1186 std::shared_ptr<OHOS::ThreadLockInfo> threadLockInfo = std::make_shared<OHOS::ThreadLockInfo>(); variable
1187 EXPECT_TRUE(threadLockInfo != nullptr);
1190 dBinderService->AttachThreadLockInfo(seqNumber, networkId, threadLockInfo);