| /foundation/resourceschedule/device_standby/services/core/src/ |
| H A D | standby_service.cpp | 89 state_.store(ServiceRunningState::STATE_RUNNING); in OnStart()
275 state_.store(ServiceRunningState::STATE_NOT_START); in OnStop()
|
| /foundation/resourceschedule/device_usage_statistics/services/common/include/ |
| H A D | bundle_active_usage_database.h | 135 void UpdateOldDataUid(const std::shared_ptr<NativeRdb::RdbStore> store, const std::string& tableName,
138 void AddRdbColumn(const std::shared_ptr<NativeRdb::RdbStore> store, const std::string& tableName,
|
| /foundation/resourceschedule/ffrt/src/queue/ |
| H A D | eventhandler_adapter_queue.cpp | 125 isActiveState_.store(true);
in Push()
159 isActiveState_.store(false);
in Pull()
|
| /foundation/deviceprofile/device_info_manager/services/core/src/deviceprofilemanager/listener/ |
| H A D | kv_data_change_listener.cpp | 75 HILOGI("Cloud data Change. store=%{public}s", origin.store.c_str()); in OnChange()
76 if (origin.store == STATIC_STORE_ID) { in OnChange()
|
| /foundation/communication/netstack/test/fuzztest/netsslinner_fuzzer/ |
| H A D | netssl_inner_fuzzer.cpp | 163 X509_STORE *store = nullptr; in SetFreeResourcesTest() local
165 FreeResources(&cert, &cert, &store, &ctx); in SetFreeResourcesTest()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_store_instance.cpp | 96 void RelationalStoreInstance::SaveRelationalDBToCache(IRelationalStore *store, const RelationalDBProperties &properties) in SaveRelationalDBToCache() argument
101 dbs_.insert(std::pair<std::string, IRelationalStore *>(identifier, store)); in SaveRelationalDBToCache()
110 LOGE("Failed to get relational store! err:%d", errCode); in OpenDatabase()
165 LOGE("Failed to check store path, the input path does not match with cached store."); in CheckCompatibility()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/cloud/ |
| H A D | cloud_meta_data.cpp | 24 CloudMetaData::CloudMetaData(ICloudSyncStorageInterface *store) in CloudMetaData() argument
25 : store_(store) in CloudMetaData()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/interface/src/ |
| H A D | result_set.cpp | 37 int ResultSet::Init(std::shared_ptr<QueryContext> &context, DocumentStore *store, bool isCutBranch) in Init() argument
41 store_ = store; in Init()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/ |
| H A D | generic_kvdb_connection.cpp | 329 isExclusive_.store(true);
337 isExclusive_.store(false);
|
| /foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
| H A D | rdb_types_util.cpp | 176 return Marshal(data, input.origin, input.dataType, input.id, input.store); in Marshalling()
181 return Unmarshal(data, output.origin, output.dataType, output.id, output.store); in Unmarshalling()
|
| /foundation/distributedhardware/distributed_audio/services/audioclient/test/unittest/spkclient/src/ |
| H A D | dspeaker_client_test.cpp | 132 speakerClient_->isRenderReady_.store(true); in HWTEST_F()
163 speakerClient_->isRenderReady_.store(false); in HWTEST_F()
|
| /foundation/distributedhardware/distributed_screen/services/screendemo/ |
| H A D | decoder_demo.cpp | 124 isRunning_.store(true); in Start()
136 isRunning_.store(false); in Stop()
|
| /foundation/filemanagement/app_file_service/tools/backup_tool/src/ |
| H A D | tools_op_backup.cpp | 155 ctx->isAllBundelsFinished.store(true); in OnBundleStarted()
175 ctx->isAllBundelsFinished.store(true); in OnAllBundlesFinished()
|
| /foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_control_center/services/src/ |
| H A D | av_trans_control_center.cpp | 32 rootEngineId_.store(BASE_ENGINE_ID); in AVTransControlCenter()
46 rootEngineId_.store(BASE_ENGINE_ID); in ~AVTransControlCenter()
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/componentmanager/ |
| H A D | component_privacy.cpp | 251 isPrivacePageOpen_.store(true); in SetPageFlagTrue()
256 isPrivacePageOpen_.store(false); in SetPageFlagFalse()
|
| /foundation/filemanagement/dfs_service/services/cloudsyncservice/src/transport/ |
| H A D | file_transfer_manager.cpp | 175 taskCount_.store(0); in OnSessionClosed()
267 taskCount_.store(0); in DecTransTaskCount()
|
| /foundation/window/window_manager/window_scene/session/host/src/ |
| H A D | scene_persistence.cpp | 102 isSavingSnapshot_.store(true); in SaveSnapshot()
144 scenePersistence->isSavingSnapshot_.store(false); in SaveSnapshot()
|
| /foundation/graphic/graphic_2d/rosen/modules/hyper_graphic_manager/core/frame_rate_manager/ |
| H A D | hgm_frame_rate_manager.cpp | 96 curScreenId_.store(screenList.empty() ? 0 : screenList.front()); in Init()
207 startCheck_.store(false); in InitTouchManager()
211 startCheck_.store(false); in InitTouchManager()
220 HgmTaskHandleThread::Instance().PostEvent(UP_TIME_OUT_TASK_ID, [this] () { startCheck_.store(true); }, in InitTouchManager()
226 startCheck_.store(false); in InitTouchManager()
285 changeGeneratorRateValid_.store(true); in ProcessPendingRefreshRate()
581 changeGeneratorRateValid_.store(false); in HandleFrameRateChangeForLTPO()
885 curScreenId_.store(id); in HandleScreenPowerStatus()
903 isAdaptive_.store(false); in HandleScreenPowerStatus()
1234 isAdaptive_.store(!isAdaptive in ProcessAdaptiveSync()
[all...] |
| /foundation/multimedia/audio_framework/services/audio_service/server/src/ |
| H A D | audio_endpoint.cpp | 551 isInited_.store(false); in Release()
559 stopUpdateThread_.store(true); in Release()
577 endpointStatus_.store(INVALID); in Release()
667 isInited_.store(true); in ConfigInputPoint()
707 isInited_.store(true); in StartThread()
858 dstAudioBuffer_->GetStreamStatus()->store(StreamStatus::STREAM_IDEL); in PrepareDeviceBuffer()
1330 tempBuffer->GetStreamStatus()->store(StreamStatus::STREAM_STAND_BY); in CheckAllBufferReady()
1950 curWriteSpan->spanStatus.store(SpanStatus::SPAN_WRITTING); in WriteToSpecialProcBuf()
1975 curWriteSpan->spanStatus.store(SpanStatus::SPAN_READ_DONE); in WriteToSpecialProcBuf()
1978 curWriteSpan->spanStatus.store(SpanStatu in WriteToSpecialProcBuf()
[all...] |
| /foundation/multimedia/media_library/frameworks/innerkitsimpl/test/unittest/medialibrary_thumbnail_service_test/src/ |
| H A D | medialibrary_thumbnail_service_test.cpp | 47 int ConfigTestOpenCall::OnCreate(RdbStore &store) in OnCreate() argument
49 return store.ExecuteSql(CREATE_TABLE_TEST); in OnCreate()
52 int ConfigTestOpenCall::OnUpgrade(RdbStore &store, int oldVersion, int newVersion) in OnUpgrade() argument
63 shared_ptr<NativeRdb::RdbStore> store = NativeRdb::RdbHelper::GetRdbStore(config, 1, helper, errCode); in SetUpTestCase() local
64 storePtr = store; in SetUpTestCase()
866 opts.store = ThumbnailService::GetInstance()->rdbStorePtr_; in HWTEST_F()
|
| /foundation/ability/dmsfwk/services/dtbschedmgr/src/ |
| H A D | datashare_manager.cpp | 175 isCurrentContinueSwitchOn_.store(status); in SetCurrentContinueSwitch()
|
| /foundation/ai/intelligent_voice_framework/services/intell_voice_trigger/server/connector_mgr/ |
| H A D | trigger_connector.h | 105 state_.store(state); in SetState()
|
| /foundation/resourceschedule/ffrt/src/sync/ |
| H A D | io_poller.cpp | 55 m_exitFlag.store(true, std::memory_order_relaxed);
|
| /foundation/communication/netstack/frameworks/js/napi/socket/async_context/include/ |
| H A D | local_socket_context.h | 41 isSockClosed.store(flag, std::memory_order_relaxed); in SetSocketCloseStatus()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/data_share/common/ |
| H A D | db_delegate.h | 56 explicit Entity(std::shared_ptr<DBDelegate> store);
|