Home
last modified time | relevance | path

Searched refs:semaphore_ (Results 1 - 7 of 7) sorted by relevance

/foundation/ai/ai_engine/services/server/server_executor/source/
H A Dfuture.cpp36 semaphore_ = ISemaphore::MakeShared(0); in Future()
50 semaphore_->Wait(timeOut); in GetResponse()
92 semaphore_->Signal(); in SetResponse()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/
H A Dsync_operation.cpp32 semaphore_(nullptr), in SyncOperation()
71 semaphore_ = std::make_unique<SemaphoreUtils>(0); in Initialize()
213 if (isBlockSync_ && (semaphore_ != nullptr)) { in WaitIfNeed()
215 semaphore_->WaitSemaphore(); in WaitIfNeed()
221 if (isBlockSync_ && (semaphore_ != nullptr)) { in NotifyIfNeed()
223 semaphore_->SendSemaphore(); in NotifyIfNeed()
H A Dsync_operation.h190 std::unique_ptr<SemaphoreUtils> semaphore_; member in DistributedDB::SyncOperation
/foundation/ai/ai_engine/services/server/server_executor/include/
H A Dfuture.h82 std::shared_ptr<ISemaphore> semaphore_; member in OHOS::AI::Future
/foundation/multimedia/av_session/frameworks/js/napi/session/include/
H A Dnapi_async_callback.h75 sem_t semaphore_ = {}; member in OHOS::AVSession::final
/foundation/multimedia/av_session/frameworks/js/napi/session/src/
H A Dnapi_async_callback.cpp28 int res = sem_init(&semaphore_, 0, 1); in NapiAsyncCallback()
37 sem_destroy(&semaphore_); in ~NapiAsyncCallback()
/foundation/graphic/graphic_2d/frameworks/vulkan_layers/test/unittest/
H A Dvulkan_loader_unit_test.cpp101 static inline VkSemaphore semaphore_ = VK_NULL_HANDLE; member in vulkan::loader::VulkanLoaderUnitTest
974 VkResult err = vkCreateSemaphore(device_, &semaphoreCreateInfo, nullptr, &semaphore_); in HWTEST_F()
991 pAcquireInfo.semaphore = semaphore_; in HWTEST_F()
1035 EXPECT_NE(semaphore_, VK_NULL_HANDLE); in HWTEST_F()
1036 presentInfo.pWaitSemaphores = &semaphore_; in HWTEST_F()

Completed in 4 milliseconds