/foundation/multimedia/av_codec/test/unittest/video_test/vcodec_server_test/mock/ |
H A D | codecbase_mock.cpp | 33 std::lock_guard<std::mutex> lock(g_mutex); in CreateByName() 35 auto mock = g_mockObject.lock(); in CreateByName() 42 std::lock_guard<std::mutex> lock(g_mutex); in CreateByName() 44 auto mock = g_mockObject.lock(); in CreateByName() 51 std::lock_guard<std::mutex> lock(g_mutex); in CreateByName() 53 auto mock = g_mockObject.lock(); in CreateByName() 60 std::lock_guard<std::mutex> lock(g_mutex); in GetCapabilityList() 62 auto mock = g_mockObject.lock(); in GetCapabilityList() 71 std::lock_guard<std::mutex> lock(g_mutex); in GetCapabilityList() 73 auto mock = g_mockObject.lock(); in GetCapabilityList() [all...] |
/foundation/arkui/ace_engine/frameworks/bridge/declarative_frontend/jsview/models/ |
H A D | patternlock_model_impl.cpp | 30 auto lock = AceType::MakeRefPtr<V2::PatternLockComponent>(); in Create() local 35 lock->SetRegularColor(lockTheme->GetRegularColor()); in Create() 36 lock->SetSelectedColor(lockTheme->GetSelectedColor()); in Create() 37 lock->SetActiveColor(lockTheme->GetActiveColor()); in Create() 38 lock->SetPathColor(lockTheme->GetPathColor()); in Create() 41 ViewStackProcessor::GetInstance()->Push(lock); in Create() 54 return lock->GetPatternLockController(); in Create() 59 auto lock = AceType::DynamicCast<V2::PatternLockComponent>(ViewStackProcessor::GetInstance()->GetMainComponent()); in SetPatternComplete() local 60 CHECK_NULL_VOID(lock); in SetPatternComplete() 61 lock in SetPatternComplete() 66 auto lock = AceType::DynamicCast<V2::PatternLockComponent>(ViewStackProcessor::GetInstance()->GetMainComponent()); SetSelectedColor() local 73 auto lock = AceType::DynamicCast<V2::PatternLockComponent>(ViewStackProcessor::GetInstance()->GetMainComponent()); SetAutoReset() local 80 auto lock = AceType::DynamicCast<V2::PatternLockComponent>(ViewStackProcessor::GetInstance()->GetMainComponent()); SetPathColor() local 87 auto lock = AceType::DynamicCast<V2::PatternLockComponent>(ViewStackProcessor::GetInstance()->GetMainComponent()); SetActiveColor() local 94 auto lock = AceType::DynamicCast<V2::PatternLockComponent>(ViewStackProcessor::GetInstance()->GetMainComponent()); SetRegularColor() local 101 auto lock = AceType::DynamicCast<V2::PatternLockComponent>(ViewStackProcessor::GetInstance()->GetMainComponent()); SetCircleRadius() local 108 auto lock = AceType::DynamicCast<V2::PatternLockComponent>(ViewStackProcessor::GetInstance()->GetMainComponent()); SetSideLength() local [all...] |
/foundation/communication/wifi/wifi/services/wifi_standard/wifi_framework/wifi_manage/wifi_p2p/ |
H A D | wifi_p2p_group_info_proxy.cpp | 21 std::unique_lock<std::mutex> lock(proxyMutex); in operator ==() 27 std::unique_lock<std::mutex> lock(proxyMutex); in operator !=() 33 std::unique_lock<std::mutex> lock(proxyMutex); in SetIsGroupOwner() 39 std::unique_lock<std::mutex> lock(proxyMutex); in IsGroupOwner() 45 std::unique_lock<std::mutex> lock(proxyMutex); in SetOwner() 51 std::unique_lock<std::mutex> lock(proxyMutex); in GetOwner() 57 std::unique_lock<std::mutex> lock(proxyMutex); in SetPassphrase() 63 std::unique_lock<std::mutex> lock(proxyMutex); in GetPassphrase() 69 std::unique_lock<std::mutex> lock(proxyMutex); in SetInterface() 75 std::unique_lock<std::mutex> lock(proxyMute in GetInterface() [all...] |
/foundation/communication/wifi/wifi/frameworks/native/src/ |
H A D | wifi_device_impl.cpp | 124 std::lock_guard<std::mutex> lock(mutex_); in EnableWifi() 131 std::lock_guard<std::mutex> lock(mutex_); in DisableWifi() 138 std::lock_guard<std::mutex> lock(mutex_); in InitWifiProtect() 145 std::lock_guard<std::mutex> lock(mutex_); in GetWifiProtectRef() 152 std::lock_guard<std::mutex> lock(mutex_); in PutWifiProtectRef() 159 std::lock_guard<std::mutex> lock(mutex_); in IsHeldWifiProtectRef() 185 std::lock_guard<std::mutex> lock(mutex_); in RemoveCandidateConfig() 192 std::lock_guard<std::mutex> lock(mutex_); in RemoveCandidateConfig() 199 std::lock_guard<std::mutex> lock(mutex_); in AddDeviceConfig() 206 std::lock_guard<std::mutex> lock(mutex in UpdateDeviceConfig() [all...] |
H A D | wifi_p2p_impl.cpp | 78 std::lock_guard<std::mutex> lock(mutex_); in EnableP2p() 85 std::lock_guard<std::mutex> lock(mutex_); in DisableP2p() 92 std::lock_guard<std::mutex> lock(mutex_); in DiscoverDevices() 99 std::lock_guard<std::mutex> lock(mutex_); in StopDiscoverDevices() 106 std::lock_guard<std::mutex> lock(mutex_); in DiscoverServices() 113 std::lock_guard<std::mutex> lock(mutex_); in StopDiscoverServices() 120 std::lock_guard<std::mutex> lock(mutex_); in RequestService() 127 std::lock_guard<std::mutex> lock(mutex_); in PutLocalP2pService() 134 std::lock_guard<std::mutex> lock(mutex_); in DeleteLocalP2pService() 141 std::lock_guard<std::mutex> lock(mutex in StartP2pListen() [all...] |
/foundation/multimedia/camera_framework/services/deferred_processing_service/include/base/ |
H A D | blocking_queue.h | 39 std::unique_lock<std::mutex> lock(mutex_); in Size() 44 std::unique_lock<std::mutex> lock(mutex_); in Full() 53 std::unique_lock<std::mutex> lock(mutex_); in Empty() 58 std::unique_lock<std::mutex> lock(mutex_); in Push() 59 auto ret = CanPush(lock); in Push() 68 std::unique_lock<std::mutex> lock(mutex_); in Push() 69 auto ret = CanPush(lock, timeoutMs); in Push() 78 std::unique_lock<std::mutex> lock(mutex_); in Push() 79 auto ret = CanPush(lock, timeoutMs); in Push() 88 std::unique_lock<std::mutex> lock(mutex in Pop() 189 CanPush(std::unique_lock<std::mutex>& lock) CanPush() argument 202 CanPush(std::unique_lock<std::mutex>& lock, int timeoutMs) CanPush() argument [all...] |
/foundation/graphic/graphic_3d/lume/metaobject/include/meta/api/threading/ |
H A D | mutex.h | 54 api_.lock(handle_); in Lock() 78 * @brief Construct lock from mutex and lock it. 86 * @brief Construct by moving from another lock. 88 UniqueLock(UniqueLock&& lock) : locked_(lock.locked_), mutex_(lock.mutex_) in UniqueLock() argument 90 lock.mutex_ = nullptr; in UniqueLock() 91 lock.locked_ = false; in UniqueLock() 95 * @brief Destroy lock, unlock 107 operator =(UniqueLock&& lock) operator =() argument [all...] |
/foundation/multimedia/camera_framework/frameworks/native/camera/src/output/ |
H A D | capture_output.cpp | 40 std::lock_guard<std::mutex> lock(deathRecipientMutex_); in RegisterStreamBinderDied() 56 std::lock_guard<std::mutex> lock(bufferProducerMutex_); in GetBufferProducer() 62 std::lock_guard<std::mutex> lock(deathRecipientMutex_); in UnregisterStreamBinderDied() 101 std::lock_guard<std::mutex> lock(streamMutex_); in IsStreamCreated() 107 std::lock_guard<std::mutex> lock(streamMutex_); in GetStream() 114 std::lock_guard<std::mutex> lock(streamMutex_); in SetStream() 122 std::lock_guard<std::mutex> lock(sessionMutex_); in GetSession() 128 std::lock_guard<std::mutex> lock(sessionMutex_); in SetSession() 136 std::lock_guard<std::mutex> lock(streamMutex_); in Release() 145 std::lock_guard<std::mutex> lock(photoProfileMutex in SetPhotoProfile() [all...] |
/foundation/multimedia/av_codec/test/unittest/sa_avcodec_test/mock/ |
H A D | codec_service_stub_mock.cpp | 30 std::lock_guard<std::mutex> lock(g_mutex); in RegisterMock() 37 std::lock_guard<std::mutex> lock(g_mutex); in Create() 39 auto mock = g_mockObject.lock(); in Create() 51 std::lock_guard<std::mutex> lock(g_mutex); in ~CodecServiceStub() 53 auto mock = g_mockObject.lock(); in ~CodecServiceStub() 60 std::lock_guard<std::mutex> lock(g_mutex); in Init() 63 auto mock = g_mockObject.lock(); in Init() 70 std::lock_guard<std::mutex> lock(g_mutex); in DestroyStub() 71 auto mock = g_mockObject.lock(); in DestroyStub() 78 std::lock_guard<std::mutex> lock(g_mute in Dump() [all...] |
H A D | system_ability_mock.cpp | 29 std::lock_guard<std::mutex> lock(g_mutex); in RegisterMock() 36 std::lock_guard<std::mutex> lock(g_mutex); in SystemAbility() 38 auto mock = g_mockObject.lock(); in SystemAbility() 45 std::lock_guard<std::mutex> lock(g_mutex); in SystemAbility() 47 auto mock = g_mockObject.lock(); in SystemAbility() 54 std::lock_guard<std::mutex> lock(g_mutex); in ~SystemAbility() 56 auto mock = g_mockObject.lock(); in ~SystemAbility() 63 std::lock_guard<std::mutex> lock(g_mutex); in Publish() 65 auto mock = g_mockObject.lock(); in Publish() 93 auto mock = g_mockObject.lock(); in AddSystemAbilityListener() [all...] |
/foundation/multimedia/media_foundation/src/osal/task/ffrt/ |
H A D | condition_variable.cpp | 40 void ConditionVariable::Wait(AutoLock& lock) noexcept 42 cond_.wait(lock); 45 void ConditionVariable::Wait(AutoLock& lock, std::function<bool()> pred) noexcept 48 Wait(lock); variable 52 bool ConditionVariable::WaitFor(AutoLock& lock, int64_t timeoutMs) in WaitFor() argument 54 auto status = cond_.wait_for(lock, std::chrono::milliseconds(timeoutMs)); in WaitFor() 62 bool ConditionVariable::WaitFor(AutoLock& lock, int64_t timeoutMs, std::function<bool()> pred) in WaitFor() argument 64 return cond_.wait_for(lock, std::chrono::milliseconds(timeoutMs), pred); in WaitFor()
|
/foundation/multimedia/camera_lite/frameworks/ |
H A D | event_handler.cpp | 48 std::unique_lock<std::mutex> lock(hdl->mtx_);
in EventDispatch() 52 hdl->cv_.wait(lock); // wait for task or exit signal
in EventDispatch() 56 lock.unlock();
in EventDispatch() 59 lock.lock();
in EventDispatch() 66 lock.unlock();
in EventDispatch() 69 lock.lock();
in EventDispatch()
|
/foundation/resourceschedule/ffrt/src/util/ |
H A D | slab.h | 47 fast_mutex lock; member in ffrt::SimpleAllocator 115 lock.lock(); in SimpleAllocatorLock() 120 lock.unlock(); in SimpleAllocatorUnLock() 125 lock.lock(); in init() 127 lock.unlock(); in init() 138 lock.unlock(); in init() 151 lock.lock(); in Alloc() 215 std::mutex lock; global() member in ffrt::QSimpleAllocator [all...] |
/foundation/communication/dsoftbus/core/bus_center/lnn/net_ledger/distributed_ledger/src/ |
H A D | lnn_distributed_net_ledger_manager.c | 302 if (SoftBusMutexLock(&(LnnGetDistributedNetLedger()->lock)) != 0) { in LnnUpdateNodeBleMac() 303 LNN_LOGE(LNN_LEDGER, "lock mutex fail!"); in LnnUpdateNodeBleMac() 309 SoftBusMutexUnlock(&(LnnGetDistributedNetLedger()->lock)); in LnnUpdateNodeBleMac() 314 SoftBusMutexUnlock(&(LnnGetDistributedNetLedger()->lock)); in LnnUpdateNodeBleMac() 319 SoftBusMutexUnlock(&(LnnGetDistributedNetLedger()->lock)); in LnnUpdateNodeBleMac() 336 if (SoftBusMutexLock(&(LnnGetDistributedNetLedger()->lock)) != SOFTBUS_OK) { in LnnSetRemoteScreenStatusInfo() 337 LNN_LOGE(LNN_LEDGER, "lock mutex fail!"); in LnnSetRemoteScreenStatusInfo() 345 SoftBusMutexUnlock(&(LnnGetDistributedNetLedger()->lock)); in LnnSetRemoteScreenStatusInfo() 352 SoftBusMutexUnlock(&(LnnGetDistributedNetLedger()->lock)); in LnnSetRemoteScreenStatusInfo() 360 SoftBusMutexUnlock(&LnnGetDistributedNetLedger()->lock); in LnnSetRemoteScreenStatusInfo() [all...] |
/foundation/resourceschedule/ffrt/src/eu/ |
H A D | cpu_monitor.cpp | 174 setWorkerNumLock.lock(); in QosWorkerNumSegment() 187 workerCtrl.lock.lock(); in QosWorkerNumSegment() 191 workerCtrl.lock.unlock(); in QosWorkerNumSegment() 219 workerCtrl.lock.unlock(); in QosWorkerNumSegment() 286 workerCtrl.lock.lock(); in TimeoutCount() 292 workerCtrl.lock.unlock(); in TimeoutCount() 298 workerCtrl.lock.lock(); in WakeupCount() [all...] |
/foundation/communication/wifi/wifi/services/wifi_standard/wifi_framework/wifi_manage/wifi_sta/ |
H A D | sta_interface.cpp | 32 std::lock_guard<std::mutex> lock(mutex); in ~StaInterface() 53 std::lock_guard<std::mutex> lock(mutex); in EnableStaService() 70 std::lock_guard<std::mutex> lock(mutex); in DisableStaService() 82 std::lock_guard<std::mutex> lock(mutex); in ConnectToNetwork() 94 std::lock_guard<std::mutex> lock(mutex); in ConnectToDevice() 106 std::lock_guard<std::mutex> lock(mutex); in StartRoamToNetwork() 118 std::lock_guard<std::mutex> lock(mutex); in StartConnectToUserSelectNetwork() 130 std::lock_guard<std::mutex> lock(mutex); in ReConnect() 142 std::lock_guard<std::mutex> lock(mutex); in ReAssociate() 154 std::lock_guard<std::mutex> lock(mute in Disconnect() [all...] |
/foundation/communication/nfc/services/src/ipc/controller/ |
H A D | nfc_controller_impl.cpp | 40 return nfcService_.lock()->GetNfcState();
in GetState() 48 return nfcService_.lock()->ExecuteTask(KITS::TASK_TURN_ON);
in TurnOn() 56 return nfcService_.lock()->ExecuteTask(KITS::TASK_TURN_OFF);
in TurnOff() 64 isOpen = nfcService_.lock()->IsNfcEnabled();
in IsNfcOpen() 74 if (!nfcService_.lock()->SetRegisterCallBack(callback, type, callerToken)) {
in RegisterCallBack() 86 if (!nfcService_.lock()->RemoveRegisterCallBack(type, callerToken)) {
in UnRegisterCallBack() 97 if (!nfcService_.lock()->RemoveAllRegisterCallBack(callerToken)) {
in UnRegisterAllCallBack() 108 return nfcService_.lock()->GetTagServiceIface();
in GetTagServiceIface() 117 if (nfcService_.lock()->RegNdefMsgCb(callback)) {
in RegNdefMsgCallback() 137 if (nfcService_.lock() in NotifyEventStatus() [all...] |
/foundation/arkui/ace_engine/interfaces/inner_api/form_render/src/ |
H A D | form_renderer_dispatcher_impl.cpp | 39 auto handler = eventHandler_.lock(); in DispatchPointerEvent() 48 auto uiContent = uiContent_.lock(); in DispatchPointerEvent() 61 std::unique_lock<std::mutex> lock(serializedResultData->mtx); in DispatchPointerEvent() 65 std::unique_lock<std::mutex> lock(serializedResultData->mtx); in DispatchPointerEvent() 67 if (serializedResultData->cv.wait_for(lock, std::chrono::milliseconds(PROCESS_WAIT_TIME)) == in DispatchPointerEvent() 76 auto uiContent = content.lock(); in DispatchPointerEvent() 100 auto handler = eventHandler_.lock(); in DispatchSurfaceChangeEvent() 107 auto uiContent = content.lock(); in DispatchSurfaceChangeEvent() 149 auto formRenderer = formRenderer_.lock(); in DispatchSurfaceChangeEvent() 159 auto handler = eventHandler_.lock(); in SetObscured() [all...] |
/foundation/communication/nfc/services/src/nci_adapter/nci_native_default/src/ |
H A D | nci_tag_impl_default.cpp | 30 auto tag = TagNativeImpl::GetInstance().GetTag(tagDiscId).lock(); in GetTechList() 39 auto tag = TagNativeImpl::GetInstance().GetTag(tagDiscId).lock(); in GetConnectedTech() 48 auto tag = TagNativeImpl::GetInstance().GetTag(tagDiscId).lock(); in GetTechExtrasData() 57 auto tag = TagNativeImpl::GetInstance().GetTag(tagDiscId).lock(); in GetTagUid() 66 auto tag = TagNativeImpl::GetInstance().GetTag(tagDiscId).lock(); in Connect() 75 auto tag = TagNativeImpl::GetInstance().GetTag(tagDiscId).lock(); in Disconnect() 84 auto tag = TagNativeImpl::GetInstance().GetTag(tagDiscId).lock(); in Reconnect() 93 auto tag = TagNativeImpl::GetInstance().GetTag(tagDiscId).lock(); in Transceive() 102 auto tag = TagNativeImpl::GetInstance().GetTag(tagDiscId).lock(); in ReadNdef() 111 auto tag = TagNativeImpl::GetInstance().GetTag(tagDiscId).lock(); in FindNdefTech() [all...] |
/foundation/multimedia/player_framework/services/services/recorder/client/ |
H A D | recorder_client.cpp | 48 std::lock_guard<std::mutex> lock(mutex_); in ~RecorderClient() 61 std::lock_guard<std::mutex> lock(mutex_); in MediaServerDied() 72 std::lock_guard<std::mutex> lock(mutex_); in CreateListenerObject() 87 std::lock_guard<std::mutex> lock(mutex_); in SetVideoSource() 96 std::lock_guard<std::mutex> lock(mutex_); in SetVideoEncoder() 105 std::lock_guard<std::mutex> lock(mutex_); in SetVideoSize() 114 std::lock_guard<std::mutex> lock(mutex_); in SetVideoFrameRate() 123 std::lock_guard<std::mutex> lock(mutex_); in SetVideoEncodingBitRate() 132 std::lock_guard<std::mutex> lock(mutex_); in SetVideoIsHdr() 141 std::lock_guard<std::mutex> lock(mutex in SetVideoEnableTemporalScale() [all...] |
/foundation/resourceschedule/ffrt/src/sched/ |
H A D | scheduler.cpp | 52 auto lock = FFRTFacade::GetEUInstance().GetSleepCtl(level); in InsertNode() local 53 lock->lock(); in InsertNode() 55 lock->unlock(); in InsertNode() 73 auto lock = FFRTFacade::GetEUInstance().GetSleepCtl(level); in RemoveNode() local 74 lock->lock(); in RemoveNode() 76 lock->unlock(); in RemoveNode() 80 lock->unlock(); in RemoveNode() 102 auto lock in WakeupTask() local [all...] |
/foundation/multimedia/player_framework/services/services/screen_capture/client/ |
H A D | screen_capture_client.cpp | 47 std::lock_guard<std::mutex> lock(mutex_); in CreateListenerObject() 63 std::lock_guard<std::mutex> lock(mutex_); in ~ScreenCaptureClient() 72 std::lock_guard<std::mutex> lock(mutex_); in SetScreenCaptureCallback() 83 std::lock_guard<std::mutex> lock(mutex_); in MediaServerDied() 93 std::lock_guard<std::mutex> lock(mutex_); in Release() 100 std::lock_guard<std::mutex> lock(mutex_); in SetCaptureMode() 107 std::lock_guard<std::mutex> lock(mutex_); in SetDataType() 114 std::lock_guard<std::mutex> lock(mutex_); in SetRecorderInfo() 121 std::lock_guard<std::mutex> lock(mutex_); in SetOutputFile() 128 std::lock_guard<std::mutex> lock(mutex in InitAudioEncInfo() [all...] |
/foundation/graphic/graphic_3d/lume/metaobject/test/src/base/ |
H A D | PointerTest.cpp | 105 auto p = wptr.lock(); in HWTEST_F() 114 auto p = wptr.lock(); in HWTEST_F() 268 ASSERT_TRUE(wp2.lock()); in HWTEST_F() 270 ASSERT_TRUE(wp2.lock() == b3); in HWTEST_F() 271 ASSERT_TRUE(b3 == interface_pointer_cast<IBase3>(wp2.lock())); in HWTEST_F() 273 ASSERT_TRUE(wp2.lock()); in HWTEST_F() 275 ASSERT_FALSE(b3 == interface_pointer_cast<IBase3>(wp2.lock())); in HWTEST_F() 279 ASSERT_TRUE(wp.lock()); in HWTEST_F() 281 ASSERT_TRUE(t == wp.lock()); in HWTEST_F() 283 ASSERT_TRUE(wp2.lock()); in HWTEST_F() [all...] |
/foundation/multimedia/player_framework/services/services/player/client/ |
H A D | player_client.cpp | 44 std::lock_guard<std::mutex> lock(mutex_); in ~PlayerClient() 56 std::lock_guard<std::mutex> lock(mutex_); in CreateListenerObject() 72 std::lock_guard<std::mutex> lock(mutex_); in MediaServerDied() 86 std::lock_guard<std::mutex> lock(mutex_); in SetSource() 94 std::lock_guard<std::mutex> lock(mutex_); in SetSource() 109 std::lock_guard<std::mutex> lock(mutex_); in SetSource() 124 std::lock_guard<std::mutex> lock(mutex_); in AddSubSource() 131 std::lock_guard<std::mutex> lock(mutex_); in AddSubSource() 139 std::lock_guard<std::mutex> lock(mutex_); in Play() 147 std::lock_guard<std::mutex> lock(mutex in SetPlayRange() [all...] |
/foundation/communication/dsoftbus/core/transmission/trans_channel/manager/src/ |
H A D | trans_lane_manager.c | 100 if (SoftBusMutexLock(&(g_channelLaneList->lock)) != SOFTBUS_OK) { in TransLaneChannelForEachShowInfo() 101 TRANS_LOGE(TRANS_SVC, "lock failed"); in TransLaneChannelForEachShowInfo() 114 (void)SoftBusMutexUnlock(&(g_channelLaneList->lock)); in TransLaneChannelForEachShowInfo() 155 if (SoftBusMutexLock(&g_channelLaneList->lock) != SOFTBUS_OK) { in TransLaneMgrDeinit() 156 TRANS_LOGE(TRANS_SVC, "lock failed"); in TransLaneMgrDeinit() 171 (void)SoftBusMutexUnlock(&g_channelLaneList->lock); in TransLaneMgrDeinit() 182 if (SoftBusMutexLock(&g_socketChannelList->lock) != SOFTBUS_OK) { in TransSocketLaneMgrDeinit() 183 TRANS_LOGE(TRANS_SVC, "lock failed"); in TransSocketLaneMgrDeinit() 193 (void)SoftBusMutexUnlock(&g_socketChannelList->lock); in TransSocketLaneMgrDeinit() 221 if (SoftBusMutexLock(&(g_channelLaneList->lock)) ! in TransLaneMgrAddLane() [all...] |