Home
last modified time | relevance | path

Searched refs:syncMutex_ (Results 1 - 22 of 22) sorted by relevance

/foundation/filemanagement/dfs_service/frameworks/native/cloud_file_kit_inner/src/data_sync/
H A Dsync_state_manager.cpp27 std::unique_lock<std::shared_mutex> lck(syncMutex_); in UpdateSyncState()
35 std::unique_lock<std::shared_mutex> lck(syncMutex_); in CheckAndSetPending()
65 std::unique_lock<std::shared_mutex> lck(syncMutex_); in SetCleaningFlag()
72 std::unique_lock<std::shared_mutex> lck(syncMutex_); in ClearCleaningFlag()
84 std::unique_lock<std::shared_mutex> lck(syncMutex_); in SetDisableCloudFlag()
91 std::unique_lock<std::shared_mutex> lck(syncMutex_); in ClearDisableCloudFlag()
103 std::unique_lock<std::shared_mutex> lck(syncMutex_); in SetStopSyncFlag()
/foundation/communication/bluetooth_service/services/bluetooth/service/src/ble/
H A Dble_adapter.cpp119 std::recursive_mutex syncMutex_ {};
174 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in EnableTask()
248 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in DisableTask()
314 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in StartOrStopAdvAndScan()
475 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in GetLocalAddress()
483 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in GetLocalName()
491 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in SetLocalName()
516 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in GetDeviceName()
556 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in ReadRemoteDeviceNameByGatt()
586 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in GetDeviceUuids()
[all...]
/foundation/communication/bluetooth_service/services/bluetooth/service/src/common/
H A Dadapter_manager.cpp78 std::recursive_mutex syncMutex_ = {}; member
172 std::lock_guard<std::recursive_mutex> lock(syncMutex_); in ProcessMessage()
311 std::lock_guard<std::recursive_mutex> lock(pimpl->syncMutex_); in Stop()
350 std::lock_guard<std::recursive_mutex> lock(pimpl->syncMutex_); in Enable()
389 std::lock_guard<std::recursive_mutex> lock(pimpl->syncMutex_); in Disable()
429 std::lock_guard<std::recursive_mutex> lock(pimpl->syncMutex_); in FactoryReset()
496 std::lock_guard<std::recursive_mutex> lock(pimpl->syncMutex_); in GetState()
536 std::lock_guard<std::recursive_mutex> lock(pimpl->syncMutex_); in GetClassicAdapterInterface()
542 std::lock_guard<std::recursive_mutex> lock(pimpl->syncMutex_); in GetBleAdapterInterface()
554 std::lock_guard<std::recursive_mutex> lock(pimpl->syncMutex_); in OnSysStateChange()
[all...]
/foundation/communication/bluetooth_service/services/bluetooth/service/src/classic/
H A Dclassic_adapter.cpp35 std::recursive_mutex syncMutex_ {};
535 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in GetBondableMode()
543 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in SetBondableMode()
558 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in StartBtDiscovery()
585 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in CancelBtDiscovery()
606 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in IsBtDiscovering()
614 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in GetBtDiscoveryEndMillis()
999 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in HandleInquiryResult()
1026 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in FindRemoteDevice()
1042 std::lock_guard<std::recursive_mutex> lk(pimpl->syncMutex_); in HandleInquiryComplete()
[all...]
/foundation/multimedia/media_library/frameworks/services/media_cloud_sync_notify_handle/src/
H A Dcloud_sync_observer.cpp50 lock_guard<mutex> lock(syncMutex_); in OnChange()
77 lock_guard<mutex> lock(syncMutex_); in HandleIndex()
/foundation/multimedia/av_codec/services/services/codec/client/
H A Dcodec_client.cpp31 CHECK_AND_RETURN_RET_LOG(codec != nullptr && std::static_pointer_cast<CodecClient>(codec)->syncMutex_ != nullptr, in Create()
42 : codecProxy_(ipcProxy), syncMutex_(std::make_shared<std::recursive_mutex>()) in CodecClient()
49 std::scoped_lock lock(mutex_, *syncMutex_); in ~CodecClient()
60 std::scoped_lock lock(mutex_, *syncMutex_); in AVCodecServerDied()
74 listenerStub_->SetMutex(syncMutex_); in CreateListenerObject()
202 std::scoped_lock lock(mutex_, *syncMutex_); in Stop()
218 std::scoped_lock lock(mutex_, *syncMutex_); in Flush()
244 std::scoped_lock lock(mutex_, *syncMutex_); in Reset()
262 std::scoped_lock lock(mutex_, *syncMutex_); in Release()
H A Dcodec_client.h114 std::shared_ptr<std::recursive_mutex> syncMutex_ = nullptr; member in OHOS::MediaAVCodec::CodecClient
/foundation/multimedia/media_library/frameworks/services/media_cloud_sync/src/
H A Dcloud_sync_helper.cpp62 lock_guard<mutex> lock(syncMutex_); in StartSync()
162 unique_lock<mutex> lock(syncMutex_); in OnTimerCallback()
/foundation/multimedia/media_library/frameworks/services/media_cloud_sync_notify_handle/include/
H A Dcloud_sync_observer.h48 std::mutex syncMutex_; member in OHOS::Media::CloudSyncObserver
/foundation/multimedia/av_session/services/session/adapter/
H A Dability_manager_adapter.h49 std::mutex syncMutex_; member in OHOS::AVSession::AbilityManagerAdapter
H A Dability_manager_adapter.cpp97 std::unique_lock<std::mutex> lock(syncMutex_); in WaitForTimeout()
/foundation/filemanagement/dfs_service/interfaces/inner_api/native/cloud_file_kit_inner/
H A Dsync_state_manager.h61 mutable std::shared_mutex syncMutex_; member in OHOS::FileManagement::CloudSync::SyncStateManager
/foundation/multimedia/media_library/frameworks/services/media_cloud_sync/include/
H A Dcloud_sync_helper.h53 std::mutex syncMutex_; member in OHOS::Media::final
/foundation/multimedia/av_codec/services/services/codec/ipc/
H A Dcodec_listener_stub.h71 std::shared_ptr<std::recursive_mutex> syncMutex_; member in OHOS::MediaAVCodec::CodecListenerStub
H A Dcodec_listener_stub.cpp326 CHECK_AND_RETURN_RET_LOG(syncMutex_ != nullptr, AVCS_ERR_INVALID_OPERATION, "sync mutex is nullptr"); in OnRemoteRequest()
327 std::lock_guard<std::recursive_mutex> lock(*syncMutex_); in OnRemoteRequest()
559 syncMutex_ = mutex; in SetMutex()
/foundation/multimedia/av_codec/services/media_engine/plugins/ffmpeg_adapter/demuxer/
H A Dffmpeg_reference_parser.cpp120 std::unique_lock<std::mutex> sLock(syncMutex_); in ParserFirstDts()
234 std::unique_lock<std::mutex> sLock(syncMutex_); in ParserRefInfoLoop()
H A Dffmpeg_demuxer_plugin.h202 std::mutex syncMutex_; member in OHOS::Media::Plugins::Ffmpeg::FFmpegDemuxerPlugin
H A Dffmpeg_demuxer_plugin.cpp666 std::unique_lock<std::mutex> sLock(syncMutex_); in ReadPacketToCacheQueue()
1165 std::unique_lock<std::mutex> sLock(syncMutex_); in GetVideoFirstKeyFrame()
/foundation/multimedia/av_codec/services/engine/codec/video/fcodec/
H A Dfcodec.h174 std::mutex syncMutex_; member in OHOS::MediaAVCodec::Codec::FCodec
H A Dfcodec.cpp949 std::unique_lock<std::mutex> sLock(syncMutex_); in SendFrame()
1027 std::unique_lock<std::mutex> sLock(syncMutex_); in FramePostProcess()
1087 std::unique_lock<std::mutex> sLock(syncMutex_); in ReceiveFrame()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dcloud_syncer.h448 std::mutex syncMutex_; // Clean Cloud Data and Sync are mutually exclusive member in DistributedDB::CloudSyncer
H A Dcloud_syncer.cpp226 std::lock_guard<std::mutex> lock(syncMutex_); in DoSync()
1658 std::lock_guard<std::mutex> lock(syncMutex_); in CleanCloudData()
1698 std::lock_guard<std::mutex> lock(syncMutex_); in CleanWaterMarkInMemory()

Completed in 22 milliseconds