Home
last modified time | relevance | path

Searched refs:deviceIds (Results 1 – 25 of 30) sorted by relevance

12

/foundation/distributeddatamgr/distributeddatamgr/services/distributeddataservice/app/src/
Dsingle_kvstore_impl.h56 Status Sync(const std::vector<std::string> &deviceIds, SyncMode mode, uint32_t allowedDelayMs,
58 Status Sync(const std::vector<std::string> &deviceIds, SyncMode mode,
93 Status AddSync(const std::vector<std::string> &deviceIds, SyncMode mode, uint32_t delayMs,
95 Status AddSync(const std::vector<std::string> &deviceIds, SyncMode mode,
100 …Status DoSync(const std::vector<std::string> &deviceIds, SyncMode mode, const KvStoreSyncManager::…
102 …Status DoQuerySync(const std::vector<std::string> &deviceIds, SyncMode mode, const std::string &qu…
110 Status DoSubscribe(const std::vector<std::string> &deviceIds,
112 Status AddSubscribe(const std::vector<std::string> &deviceIds,
114 Status Subscribe(const std::vector<std::string> &deviceIds,
116 Status DoUnSubscribe(const std::vector<std::string> &deviceIds,
[all …]
Dsingle_kvstore_impl.cpp717 Status SingleKvStoreImpl::Sync(const std::vector<std::string> &deviceIds, SyncMode mode, in Sync() argument
730 … (lastSyncDeviceIds_ == deviceIds) && (lastSyncMode_ == mode) && (lastSyncDelayMs_ == delayMs)) { in Sync()
733 lastSyncDeviceIds_ = deviceIds; in Sync()
737 return AddSync(deviceIds, mode, delayMs, sequenceId); in Sync()
740 Status SingleKvStoreImpl::Sync(const std::vector<std::string> &deviceIds, SyncMode mode, in Sync() argument
750 return AddSync(deviceIds, mode, query, delayMs, sequenceId); in Sync()
753 Status SingleKvStoreImpl::AddSync(const std::vector<std::string> &deviceIds, SyncMode mode, uint32_… in AddSync() argument
759 … std::bind(&SingleKvStoreImpl::DoSync, this, deviceIds, mode, std::placeholders::_1, sequenceId), in AddSync()
763 Status SingleKvStoreImpl::AddSync(const std::vector<std::string> &deviceIds, SyncMode mode, in AddSync() argument
769 …std::bind(&SingleKvStoreImpl::DoQuerySync, this, deviceIds, mode, query, std::placeholders::_1, se… in AddSync()
[all …]
/foundation/deviceprofile/device_profile_core/services/core/src/dbstorage/
Donline_sync_table.cpp77 int32_t OnlineSyncTable::SyncDeviceProfile(const std::vector<std::string>& deviceIds, in SyncDeviceProfile() argument
81 auto syncTask = [this, deviceIds = std::move(deviceIds), syncMode]() { in SyncDeviceProfile()
84 int32_t errCode = DeviceProfileStorage::SyncDeviceProfile(deviceIds, syncMode); in SyncDeviceProfile()
123 auto retrySyncTask = [this, deviceIds = std::move(failedDeviceIds)]() { in SyncCompleted()
125 DeviceProfileStorage::SyncDeviceProfile(deviceIds, SyncMode::PUSH); in SyncCompleted()
/foundation/deviceprofile/device_profile_core/services/core/src/devicemanager/
Ddevice_manager.cpp196 std::vector<std::string> deviceIds = {"", std::move(udid), ""}; in AddLocalDeviceIds() local
198 deviceIdsList_.emplace_back(std::move(deviceIds)); in AddLocalDeviceIds()
213 std::vector<std::string> deviceIds = {networkId, std::move(udid), std::move(uuid)}; in AddDeviceIds() local
215 deviceIdsList_.emplace_back(std::move(deviceIds)); in AddDeviceIds()
299 for (const auto& deviceIds : deviceIdsList_) { in TransformDeviceId() local
300 auto iter = std::find(deviceIds.begin(), deviceIds.end(), fromDeviceId); in TransformDeviceId()
301 if (iter != deviceIds.end()) { in TransformDeviceId()
302 toDeviceId = deviceIds[idx]; in TransformDeviceId()
/foundation/distributeddatamgr/distributeddatamgr/interfaces/innerkits/distributeddata/include/
Dsingle_kvstore.h121 KVSTORE_API virtual Status Sync(const std::vector<std::string> &deviceIds, SyncMode mode,
187 …KVSTORE_API virtual Status SyncWithCondition(const std::vector<std::string> &deviceIds, SyncMode m…
198 KVSTORE_API virtual Status SubscribeWithQuery(const std::vector<std::string> &deviceIds,
209 KVSTORE_API virtual Status UnsubscribeWithQuery(const std::vector<std::string> &deviceIds,
/foundation/distributeddatamgr/distributeddatamgr/frameworks/innerkitsimpl/distributeddatafwk/src/
Dsingle_kvstore_client.cpp175 Status SingleKvStoreClient::Sync(const std::vector<std::string> &deviceIds, SyncMode mode, uint32_t… in Sync() argument
182 if (deviceIds.empty()) { in Sync()
189 return kvStoreProxy_->Sync(deviceIds, mode, allowedDelayMs, sequenceId); in Sync()
476 Status SingleKvStoreClient::SyncWithCondition(const std::vector<std::string> &deviceIds, SyncMode m… in SyncWithCondition() argument
483 if (deviceIds.empty()) { in SyncWithCondition()
494 return kvStoreProxy_->Sync(deviceIds, mode, query.ToString(), sequenceId); in SyncWithCondition()
497 Status SingleKvStoreClient::SubscribeWithQuery(const std::vector<std::string> &deviceIds, const Dat… in SubscribeWithQuery() argument
503 if (deviceIds.empty()) { in SubscribeWithQuery()
510 return kvStoreProxy_->Subscribe(deviceIds, query.ToString(), sequenceId); in SubscribeWithQuery()
513 Status SingleKvStoreClient::UnsubscribeWithQuery(const std::vector<std::string> &deviceIds, const D… in UnsubscribeWithQuery() argument
[all …]
Dsingle_kvstore_client.h53 …Status Sync(const std::vector<std::string> &deviceIds, SyncMode mode, uint32_t allowedDelayMs) ove…
91 …Status SyncWithCondition(const std::vector<std::string> &deviceIds, SyncMode mode, const DataQuery…
94 …Status SubscribeWithQuery(const std::vector<std::string> &deviceIds, const DataQuery &query) overr…
95 …Status UnsubscribeWithQuery(const std::vector<std::string> &deviceIds, const DataQuery &query) ove…
Dapp_kvstore_impl.h109 Status Sync(const std::vector<std::string> &deviceIds, SyncMode mode,
Dikvstore_single.cpp464 Status SingleKvStoreProxy::Sync(const std::vector<std::string> &deviceIds, SyncMode mode, in Sync() argument
474 if (!data.WriteStringVector(deviceIds) || in Sync()
495 Status SingleKvStoreProxy::Sync(const std::vector<std::string> &deviceIds, SyncMode mode, in Sync() argument
504 if (!data.WriteStringVector(deviceIds) || in Sync()
861 Status SingleKvStoreProxy::Subscribe(const std::vector<std::string> &deviceIds, const std::string &… in Subscribe() argument
869 if (!data.WriteStringVector(deviceIds)) { in Subscribe()
891 Status SingleKvStoreProxy::UnSubscribe(const std::vector<std::string> &deviceIds, const std::string… in UnSubscribe() argument
899 if (!data.WriteStringVector(deviceIds)) { in UnSubscribe()
Dapp_kvstore_impl.cpp236 Status AppKvStoreImpl::Sync(const std::vector<std::string> &deviceIds, SyncMode mode, in Sync() argument
254 status = kvStoreNbDelegate_->Sync(deviceIds, dbMode, in Sync()
/foundation/distributeddatamgr/distributeddatamgr/frameworks/innerkitsimpl/distributeddatafwk/include/
Dikvstore_single.h78 virtual Status Sync(const std::vector<std::string> &deviceIds, SyncMode mode,
93 virtual Status Sync(const std::vector<std::string> &deviceIds, SyncMode mode,
95 virtual Status Subscribe(const std::vector<std::string> &deviceIds, const std::string &query,
97 virtual Status UnSubscribe(const std::vector<std::string> &deviceIds, const std::string &query,
185 …virtual Status Sync(const std::vector<std::string> &deviceIds, SyncMode mode, uint32_t allowedDela…
187 virtual Status Sync(const std::vector<std::string> &deviceIds, SyncMode mode,
202 virtual Status Subscribe(const std::vector<std::string> &deviceIds, const std::string &query,
204 virtual Status UnSubscribe(const std::vector<std::string> &deviceIds, const std::string &query,
/foundation/deviceprofile/device_profile_core/tools/dp/src/
Ddp_command.cpp202 std::list<std::string> deviceIds; in SyncCommand() local
214 result = HandleSyncOption(option, mode, deviceIds); in SyncCommand()
220 for (const auto& deviceId : deviceIds) { in SyncCommand()
328 … DpShellCommand::HandleSyncOption(int option, std::string& mode, std::list<std::string>& deviceIds) in HandleSyncOption() argument
348 deviceIds.push_back(temp); in HandleSyncOption()
/foundation/deviceprofile/device_profile_core/services/core/include/dbstorage/
Donline_sync_table.h33 … int32_t SyncDeviceProfile(const std::vector<std::string>& deviceIds, SyncMode syncMode) override;
/foundation/distributeddatamgr/distributeddatamgr/frameworks/innerkitsimpl/distributeddatafwk/test/unittest/
Dsingle_kvstore_client_test.cpp345 std::vector<std::string> deviceIds = { deviceId }; variable
346 auto syncStatus = singleKvStorePtr->Sync(deviceIds, SyncMode::PUSH);
391 std::vector<std::string> deviceIds = { deviceId }; variable
393 auto syncStatus = singleKvStorePtr->Sync(deviceIds, SyncMode::PUSH, allowedDelayMs);
1067 std::vector<std::string> deviceIds = {"invalid_device_id1", "invalid_device_id2"}; variable
1070 auto syncStatus = singleKvStorePtr->SyncWithCondition(deviceIds, SyncMode::PUSH, dataQuery);
1084 std::vector<std::string> deviceIds = {"invalid_device_id1", "invalid_device_id2"}; variable
1087 auto syncStatus = singleKvStorePtr->SubscribeWithQuery(deviceIds, dataQuery);
1101 std::vector<std::string> deviceIds = {"invalid_device_id1", "invalid_device_id2"}; variable
1104 auto unSubscribeStatus = singleKvStorePtr->UnsubscribeWithQuery(deviceIds, dataQuery);
/foundation/multimedia/medialibrary_standard/frameworks/innerkitsimpl/media_library/src/
Dmedia_thumbnail_helper.cpp129 std::vector<std::string> deviceIds = { deviceId }; in SyncKvstore() local
132 …DistributedKv::Status status = singleKvStorePtr_->SyncWithCondition(deviceIds, OHOS::DistributedKv… in SyncKvstore()
/foundation/distributeddatamgr/objectstore/frameworks/innerkitsimpl/src/adaptor/
Dflat_object_storage_engine.cpp335 std::vector<std::string> deviceIds; in SyncAllData() local
338 deviceIds.push_back(item.deviceId); in SyncAllData()
340 if (deviceIds.empty()) { in SyncAllData()
345 …DistributedDB::DBStatus status = kvstore->Sync(deviceIds, DistributedDB::SyncMode::SYNC_MODE_PULL_… in SyncAllData()
/foundation/deviceprofile/device_profile_core/tools/dp/include/
Ddp_command.h93 std::list<std::string>& deviceIds);
/foundation/distributeddatamgr/distributeddatamgr/interfaces/innerkits/app_distributeddata/include/
Dapp_kvstore.h98 KVSTORE_API virtual Status Sync(const std::vector<std::string> &deviceIds, SyncMode mode,
/foundation/deviceprofile/device_profile_core/
DREADME.md139 for (const auto& deviceId : deviceIds) {
DREADME_zh.md139 for (const auto& deviceId : deviceIds) {
/foundation/distributedschedule/dmsfwk/services/dtbschedmgr/test/unittest/
Dmock_distributed_sched.h64 …void GetCachedOsdSwitch(std::vector<std::u16string>& deviceIds, std::vector<int32_t>& values) over…
Dmock_distributed_sched.cpp137 void MockDistributedSched::GetCachedOsdSwitch(std::vector<std::u16string>& deviceIds, in GetCachedOsdSwitch() argument
/foundation/distributedschedule/dmsfwk/services/dtbschedmgr/include/
Ddistributed_sched_proxy.h65 …void GetCachedOsdSwitch(std::vector<std::u16string>& deviceIds, std::vector<int32_t>& values) over…
Ddistributed_sched_interface.h79 …virtual void GetCachedOsdSwitch(std::vector<std::u16string>& deviceIds, std::vector<int32_t>& valu…
/foundation/distributedschedule/dmsfwk/services/dtbschedmgr/include/mission/
Ddistributed_sched_mission_manager.h107 void GetCachedOsdSwitch(std::vector<std::u16string>& deviceIds, std::vector<int32_t>& values);

12