Home
last modified time | relevance | path

Searched defs:readLock (Results 1 – 25 of 30) sorted by relevance

12

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/
Dstorage_proxy.cpp57 std::shared_lock<std::shared_mutex> readLock(storeMutex_); in GetLocalWaterMark() local
70 std::shared_lock<std::shared_mutex> readLock(storeMutex_); in GetLocalWaterMarkByMode() local
79 std::shared_lock<std::shared_mutex> readLock(storeMutex_); in PutLocalWaterMark() local
92 std::shared_lock<std::shared_mutex> readLock(storeMutex_); in PutWaterMarkByMode() local
105 std::shared_lock<std::shared_mutex> readLock(storeMutex_); in GetCloudWaterMark() local
114 std::shared_lock<std::shared_mutex> readLock(storeMutex_); in SetCloudWaterMark() local
123 std::shared_lock<std::shared_mutex> readLock(storeMutex_); in StartTransaction() local
137 std::shared_lock<std::shared_mutex> readLock(storeMutex_); in Commit() local
150 std::shared_lock<std::shared_mutex> readLock(storeMutex_); in Rollback() local
164 std::shared_lock<std::shared_mutex> readLock(storeMutex_); in GetUploadCount() local
[all …]
Dstorage_engine.cpp372 std::lock_guard<std::mutex> readLock(readMutex_, std::adopt_lock); in TryToDisable() local
397 std::lock_guard<std::mutex> readLock(readMutex_, std::adopt_lock); in Enable() local
410 std::lock_guard<std::mutex> readLock(readMutex_, std::adopt_lock); in Abort() local
/foundation/graphic/graphic_2d/frameworks/text/service/skia_txt/
Dtypography.cpp57 std::shared_lock<std::shared_mutex> readLock(mutex_); in GetMaxWidth() local
63 std::shared_lock<std::shared_mutex> readLock(mutex_); in GetHeight() local
69 std::shared_lock<std::shared_mutex> readLock(mutex_); in GetActualWidth() local
75 std::shared_lock<std::shared_mutex> readLock(mutex_); in GetLongestLineWithIndent() local
81 std::shared_lock<std::shared_mutex> readLock(mutex_); in GetMinIntrinsicWidth() local
87 std::shared_lock<std::shared_mutex> readLock(mutex_); in GetMaxIntrinsicWidth() local
93 std::shared_lock<std::shared_mutex> readLock(mutex_); in GetAlphabeticBaseline() local
99 std::shared_lock<std::shared_mutex> readLock(mutex_); in GetIdeographicBaseline() local
105 std::shared_lock<std::shared_mutex> readLock(mutex_); in DidExceedMaxLines() local
111 std::shared_lock<std::shared_mutex> readLock(mutex_); in GetLineCount() local
[all …]
Dfont_collection.cpp233 std::shared_lock readLock(mutex_); in UnloadFont() local
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/relational/
Drelational_result_set_impl.cpp35 std::shared_lock<std::shared_mutex> readLock(mutex_); in GetCount() local
44 std::shared_lock<std::shared_mutex> readLock(mutex_); in GetPosition() local
91 std::shared_lock<std::shared_mutex> readLock(mutex_); in IsFirst() local
97 std::shared_lock<std::shared_mutex> readLock(mutex_); in IsLast() local
103 std::shared_lock<std::shared_mutex> readLock(mutex_); in IsBeforeFirst() local
109 std::shared_lock<std::shared_mutex> readLock(mutex_); in IsAfterLast() local
115 std::shared_lock<std::shared_mutex> readLock(mutex_); in IsClosed() local
139 std::shared_lock<std::shared_mutex> readLock(mutex_); in GetColumnNames() local
180 std::shared_lock<std::shared_mutex> readLock(mutex_); in GetColumnType() local
203 std::shared_lock<std::shared_mutex> readLock(mutex_); in GetColumnIndex() local
[all …]
/foundation/multimedia/av_codec/services/media_engine/plugins/ffmpeg_adapter/demuxer/
Dffmpeg_demuxer_thread.cpp115 std::unique_lock<std::mutex> readLock(readPacketMutex_); in HandleReadAgain() local
167 std::lock_guard<std::mutex> readLock(ioContext_.invokerTypeMutex); in ReadSample() local
218 std::lock_guard<std::mutex> readLock(readPacketMutex_); in WaitForLoop() local
223 std::lock_guard<std::mutex> readLock(ioContext_.invokerTypeMutex); in WaitForLoop() local
228 std::unique_lock<std::mutex> readLock(readSampleMutex_); in WaitForLoop() local
254 std::lock_guard<std::mutex> readLock(readSampleMutex_); in FFmpegReadLoop() local
270 std::lock_guard<std::mutex> readLock(readSampleMutex_); in FFmpegReadLoop() local
288 std::unique_lock<std::mutex> readLock(ioContext_.invokerTypeMutex); in HandleReadWait() local
358 std::lock_guard<std::mutex> readLock(readSampleMutex_); in ReadAndProcessFrame() local
375 std::lock_guard<std::mutex> readLock(readSampleMutex_); in HandleAVPacketEndOfStream() local
[all …]
/foundation/distributeddatamgr/preferences/frameworks/ndk/src/
Doh_preferences_option.cpp57 std::shared_lock<std::shared_mutex> readLock(opMutex_); in GetStorageType() local
63 std::shared_lock<std::shared_mutex> readLock(opMutex_); in GetFileName() local
69 std::shared_lock<std::shared_mutex> readLock(opMutex_); in GetBundleName() local
75 std::shared_lock<std::shared_mutex> readLock(opMutex_); in GetDataGroupId() local
Doh_preferences.cpp149 std::shared_lock<std::shared_mutex> readLock(mutex_); in GetPreferencesStoreFilePath() local
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/
Dknowledge_schema_helper.cpp83 std::shared_lock<std::shared_mutex> readLock(libMutex_); in GetRdbKnowledgeSchema() local
118 std::shared_lock<std::shared_mutex> readLock(libMutex_); in DonateKnowledgeData() local
172 std::shared_lock<std::shared_mutex> readLock(libMutex_); in IsLoadLib() local
183 std::shared_lock<std::shared_mutex> readLock(libMutex_); in StartTask() local
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
Dcloud_db_proxy.cpp51 std::shared_lock<std::shared_mutex> readLock(cloudMutex_); in GetCloudDB() local
108 std::shared_lock<std::shared_mutex> readLock(cloudMutex_); in BatchInsert() local
127 std::shared_lock<std::shared_mutex> readLock(cloudMutex_); in BatchUpdate() local
146 std::shared_lock<std::shared_mutex> readLock(cloudMutex_); in BatchDelete() local
164 std::shared_lock<std::shared_mutex> readLock(cloudMutex_); in Query() local
189 std::shared_lock<std::shared_mutex> readLock(cloudMutex_); in Lock() local
204 std::shared_lock<std::shared_mutex> readLock(cloudMutex_); in UnLock() local
250 std::shared_lock<std::shared_mutex> readLock(cloudMutex_); in HeartBeat() local
262 std::shared_lock<std::shared_mutex> readLock(cloudMutex_); in IsNotExistCloudDB() local
272 std::shared_lock<std::shared_mutex> readLock(assetLoaderMutex_); in Download() local
[all …]
/foundation/graphic/graphic_2d/frameworks/text/adapter/skia/txt/
Dplatform.cpp40 std::shared_lock<std::shared_mutex> readLock(lock_); in GetDefaultFontFamilies() local
48 std::shared_lock<std::shared_mutex> readLock(lock_); in GetThemeFontFamilies() local
/foundation/arkui/ace_engine/adapter/ohos/entrance/
Ddata_ability_helper_standard.cpp170 std::shared_lock<std::shared_mutex> readLock(dataShareHelperLock_); in OpenFileWithDataShare() local
186 std::shared_lock<std::shared_mutex> readLock(dataShareHelperLock_); in OpenFileWithDataShare() local
/foundation/systemabilitymgr/samgr/services/samgr/native/source/schedule/
Dsystem_ability_state_scheduler.cpp170 std::shared_lock<samgr::shared_mutex> readLock(abiltyMapLock_); in GetSystemAbilityContext() local
225 std::shared_lock<samgr::shared_mutex> readLock(processMapLock_); in GetSystemProcessContext() local
771 std::shared_lock<samgr::shared_mutex> readLock(processMapLock_); in UnloadProcess() local
798 std::shared_lock<samgr::shared_mutex> readLock(processMapLock_); in UnloadAllIdleSystemAbility() local
958 std::shared_lock<samgr::shared_mutex> readLock(listenerSetLock_); in NotifyProcessStarted() local
970 std::shared_lock<samgr::shared_mutex> readLock(listenerSetLock_); in NotifyProcessStopped() local
1078 std::shared_lock<samgr::shared_mutex> readLock(processMapLock_); in GetRunningSystemProcess() local
1097 std::shared_lock<samgr::shared_mutex> readLock(processMapLock_); in GetProcessNameByProcessId() local
1114 std::shared_lock<samgr::shared_mutex> readLock(abiltyMapLock_); in GetAllSystemAbilityInfo() local
1208 std::shared_lock<samgr::shared_mutex> readLock(abiltyMapLock_); in GetAllSystemAbilityInfoByState() local
/foundation/systemabilitymgr/safwk/services/safwk/src/
Dlocal_ability_manager.cpp492 std::shared_lock<std::shared_mutex> readLock(localAbilityMapLock_); in GetAbility() local
526 std::shared_lock<std::shared_mutex> readLock(localAbilityMapLock_); in StartOndemandSystemAbility() local
533 std::shared_lock<std::shared_mutex> readLock(localAbilityMapLock_); in StartOndemandSystemAbility() local
652 std::unique_lock<std::shared_mutex> readLock(localAbilityMapLock_); in InitializeSaProfilesInnerLocked() local
1068 std::shared_lock<std::shared_mutex> readLock(localAbilityMapLock_); in IsResident() local
1085 std::shared_lock<std::shared_mutex> readLock(unusedCfgMapLock_); in IsConfigUnused() local
1137 std::shared_lock<std::shared_mutex> readLock(localAbilityMapLock_); in IdentifyUnusedResident() local
1171 std::shared_lock<std::shared_mutex> readLock(unusedCfgMapLock_); in IdentifyUnusedOndemand() local
1258 std::shared_lock<std::shared_mutex> readLock(localAbilityMapLock_); in StartTimedQuery() local
/foundation/filemanagement/dfs_service/services/distributedfiledaemon/src/channel_manager/
Dchannel_manager.cpp251 std::shared_lock<std::shared_mutex> readLock(clientMutex_); in CreateClientChannel() local
311 std::shared_lock<std::shared_mutex> readLock(clientMutex_); in HasExistChannel() local
347 std::shared_lock<std::shared_mutex> readLock(clientMutex_); in SendBytes() local
525 std::shared_lock<std::shared_mutex> readLock(clientMutex_); in SendRequest() local
Dsystem_notifier.cpp282 std::shared_lock<std::shared_mutex> readLock(mutex); in CreateNotification() local
322 std::shared_lock<std::shared_mutex> readLock(mutex); in CreateLocalLiveView() local
/foundation/arkui/napi/native_engine/
Dnative_event.cpp85 std::shared_lock<std::shared_mutex> readLock(eng->GetEventMutex()); in napi_send_event() local
136 std::shared_lock<std::shared_mutex> readLock(eng->GetEventMutex()); in napi_send_cancelable_event() local
163 std::shared_lock<std::shared_mutex> readLock(eng->GetEventMutex()); in napi_cancel_event() local
/foundation/ability/dmsfwk/services/dtbcollabmgr/src/ability_connection_manager/
Dability_connection_manager.cpp119 std::shared_lock<std::shared_mutex> readLock(sessionMutex_); in FindExistingSession() local
327 std::shared_lock<std::shared_mutex> readLock(streamMutex_); in CheckStreamIsRegistered() local
508 std::shared_lock<std::shared_mutex> readLock(sessionMutex_); in GetAbilityConnectionSession() local
523 std::shared_lock<std::shared_mutex> readLock(streamMutex_); in GetAbilityConnectionSessionByStreamId() local
/foundation/ability/dmsfwk/services/dtbcollabmgr/src/channel_manager/
Dchannel_manager.cpp780 std::shared_lock<std::shared_mutex> readLock(socketMutex_); in GetSocketStatus() local
864 std::shared_lock<std::shared_mutex> readLock(channelMutex_); in UpdateChannelStatus() local
980 std::shared_lock<std::shared_mutex> readLock(channelMutex_); in GetChannelId() local
1042 std::shared_lock<std::shared_mutex> readLock(listenerMutex_); in NotifyListeners() local
1063 std::shared_lock<std::shared_mutex> readLock(listenerMutex_); in NotifyListenersNew() local
1124 std::shared_lock<std::shared_mutex> readLock(socketMutex_); in GetChannelId() local
1141 std::shared_lock<std::shared_mutex> readLock(channelMutex_); in GetChannelStatus() local
1339 std::shared_lock<std::shared_mutex> readLock(channelMutex_); in ProcessRecvData() local
1562 std::shared_lock<std::shared_mutex> readLock(listenerMutex_); in GetRecvPathFromUser() local
/foundation/systemabilitymgr/samgr/services/samgr/native/source/
Dsystem_ability_manager.cpp96 std::shared_lock<samgr::shared_mutex> readLock(dBinderServiceLock_); in RegisterDistribute() local
108 std::shared_lock<samgr::shared_mutex> readLock(dBinderServiceLock_); in RegisterDistribute() local
381 shared_lock<samgr::shared_mutex> readLock(abilityMapLock_); in GetAllOndemandSa() local
511 shared_lock<samgr::shared_mutex> readLock(abilityMapLock_); in GetSystemAbilityFromRemote() local
534 shared_lock<samgr::shared_mutex> readLock(abilityMapLock_); in CheckSystemAbility() local
860 shared_lock<samgr::shared_mutex> readLock(abilityMapLock_); in ListSystemAbilities() local
1011 std::shared_lock<samgr::shared_mutex> readLock(dBinderServiceLock_); in NotifyRemoteSaDied() local
1024 std::shared_lock<samgr::shared_mutex> readLock(dBinderServiceLock_); in NotifyRemoteDeviceOffline() local
1894 std::shared_lock<samgr::shared_mutex> readLock(dBinderServiceLock_); in DoMakeRemoteBinder() local
1918 std::shared_lock<samgr::shared_mutex> readLock(dBinderServiceLock_); in NotifyRpcLoadCompleted() local
[all …]
/foundation/ability/dmsfwk/services/dtbschedmgr/src/mission/
Ddistributed_data_storage.cpp164 shared_lock<shared_mutex> readLock(initLock_); in SubscribeDistributedDataStorage() local
374 shared_lock<shared_mutex> readLock(initLock_); in Query() local
/foundation/filemanagement/dfs_service/services/cloudfiledaemon/include/cloud_disk/
Dcloud_disk_inode.h69 ffrt::mutex readLock; member
/foundation/systemabilitymgr/samgr/services/samgr/native/source/collect/
Ddevice_status_collect_manager.cpp132 std::shared_lock<samgr::shared_mutex> readLock(saProfilesLock_); in GetSaControlListByEvent() local
428 std::shared_lock<samgr::shared_mutex> readLock(saProfilesLock_); in GetOnDemandEvents() local
/foundation/distributeddatamgr/preferences/frameworks/native/src/
Dpreferences_enhance_impl.cpp281 std::shared_lock<std::shared_mutex> readLock(pref->obseverMetux_); in NotifyPreferencesObserver() local
/foundation/ability/dmsfwk/services/dtbschedmgr/src/collab/
Ddsched_collab_manager.cpp561 std::shared_lock<std::shared_mutex> readLock(collabReadMutex_); in ReleaseAbilityLink() local

12