Home
last modified time | relevance | path

Searched refs:syncInfo (Results 1 - 19 of 19) sorted by relevance

/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/
H A Dkvdb_service_client.cpp167 Status KVDBServiceClient::Sync(const AppId &appId, const StoreId &storeId, SyncInfo &syncInfo) in Sync() argument
171 syncInfo.seqId, syncInfo.mode, syncInfo.devices, syncInfo.delay, syncInfo.query); in Sync()
174 appId.appId.c_str(), StoreUtil::Anonymous(storeId.storeId).c_str(), syncInfo.seqId); in Sync()
179 Status KVDBServiceClient::CloudSync(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) in CloudSync() argument
183 static_cast<uint32_t>(KVDBServiceInterfaceCode::TRANS_CLOUD_SYNC), reply, appId, storeId, syncInfo.seqId); in CloudSync()
289 Status KVDBServiceClient::AddSubscribeInfo(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) in AddSubscribeInfo() argument
302 RmvSubscribeInfo(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) RmvSubscribeInfo() argument
[all...]
H A Dsingle_store_impl.cpp580 KVDBService::SyncInfo syncInfo; in Sync() local
581 syncInfo.seqId = StoreUtil::GenSequenceId(); in Sync()
582 syncInfo.mode = mode; in Sync()
583 syncInfo.delay = delay; in Sync()
584 syncInfo.devices = devices; in Sync()
585 return DoSync(syncInfo, syncObserver_); in Sync()
592 KVDBService::SyncInfo syncInfo; in Sync() local
593 syncInfo.seqId = StoreUtil::GenSequenceId(); in Sync()
594 syncInfo.mode = mode; in Sync()
595 syncInfo in Sync()
614 KVDBService::SyncInfo syncInfo; CloudSync() local
694 SyncInfo syncInfo; SubscribeWithQuery() local
716 SyncInfo syncInfo; UnsubscribeWithQuery() local
[all...]
H A Dauto_sync_timer.cpp109 KVDBService::SyncInfo syncInfo; in ProcessTask() local
110 syncInfo.devices.push_back(res.second); in ProcessTask()
113 service->Sync({ id.first }, storeId, syncInfo); in ProcessTask()
H A Dauto_sync_timer_mock.cpp109 KVDBService::SyncInfo syncInfo; in ProcessTask() local
110 service->Sync({ id.first }, storeId, syncInfo); in ProcessTask()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/
H A Dkvdb_service_stub.cpp191 SyncInfo syncInfo; in OnSync() local
192 if (!ITypesUtil::Unmarshal(data, syncInfo.seqId, syncInfo.mode, syncInfo.devices, syncInfo.delay, syncInfo.query)) { in OnSync()
197 int32_t status = Sync(appId, storeId, syncInfo); in OnSync()
209 SyncInfo syncInfo; in OnCloudSync() local
210 if (!ITypesUtil::Unmarshal(data, syncInfo.seqId)) { in OnCloudSync()
215 int32_t status = CloudSync(appId, storeId, syncInfo); in OnCloudSync()
350 SyncInfo syncInfo; OnAddSubInfo() local
368 SyncInfo syncInfo; OnRmvSubInfo() local
[all...]
H A Dkvdb_service_impl.h50 Status CloudSync(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) override;
51 Status Sync(const AppId &appId, const StoreId &storeId, SyncInfo &syncInfo) override;
60 Status AddSubscribeInfo(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) override;
61 Status RmvSubscribeInfo(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) override;
124 Status DoCloudSync(const StoreMetaData &meta, const SyncInfo &syncInfo);
H A Dkvdb_service_impl.cpp220 Status KVDBServiceImpl::CloudSync(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) in CloudSync() argument
228 return DoCloudSync(metaData, syncInfo); in CloudSync()
240 Status KVDBServiceImpl::Sync(const AppId &appId, const StoreId &storeId, SyncInfo &syncInfo) in Sync() argument
244 auto delay = GetSyncDelayTime(syncInfo.delay, storeId); in Sync()
245 if (metaData.isAutoSync && syncInfo.seqId == std::numeric_limits<uint64_t>::max()) { in Sync()
255 syncInfo.syncId = ++syncId_; in Sync()
258 std::to_string(syncInfo.syncId), DATA_TYPE, metaData.dataType, SYNC_TYPE, in Sync()
259 SYNC, OS_TYPE, IsOHOSType(syncInfo.devices)); in Sync()
261 std::bind(&KVDBServiceImpl::DoSyncInOrder, this, metaData, syncInfo, std::placeholders::_1, ACTION_SYNC), in Sync()
262 std::bind(&KVDBServiceImpl::DoComplete, this, metaData, syncInfo, RefCoun in Sync()
519 AddSubscribeInfo(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) AddSubscribeInfo() argument
529 RmvSubscribeInfo(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) RmvSubscribeInfo() argument
907 DoCloudSync(const StoreMetaData &meta, const SyncInfo &syncInfo) DoCloudSync() argument
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/include/
H A Dkvdb_service_client.h39 Status Sync(const AppId &appId, const StoreId &storeId, SyncInfo &syncInfo) override;
48 Status AddSubscribeInfo(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) override;
49 Status RmvSubscribeInfo(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) override;
54 Status CloudSync(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) override;
H A Dkvdb_service.h55 virtual Status Sync(const AppId &appId, const StoreId &storeId, SyncInfo &syncInfo) = 0;
64 virtual Status AddSubscribeInfo(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) = 0;
65 virtual Status RmvSubscribeInfo(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) = 0;
70 virtual Status CloudSync(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) = 0;
H A Dsingle_store_impl.h129 Status DoSync(SyncInfo &syncInfo, std::shared_ptr<SyncCallback> observer);
130 Status DoClientSync(SyncInfo &syncInfo, std::shared_ptr<SyncCallback> observer);
/foundation/distributeddatamgr/kv_store/kvstoremock/frameworks/innerkitsimpl/kvdb/include/
H A Dkvdb_service.h43 virtual Status Sync(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) = 0;
51 virtual Status AddSubscribeInfo(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) = 0;
52 virtual Status RmvSubscribeInfo(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) = 0;
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/
H A Dsync_manager.cpp232 int32_t SyncManager::DoCloudSync(SyncInfo syncInfo) in DoCloudSync() argument
237 auto syncId = GenerateId(syncInfo.user_); in DoCloudSync()
239 actives_.Compute(syncId, [this, &ref, &syncInfo](const uint64_t &key, TaskId &taskId) mutable { in DoCloudSync()
240 taskId = executor_->Execute(GetSyncTask(0, true, ref, std::move(syncInfo))); in DoCloudSync()
335 ExecutorPool::Task SyncManager::GetSyncTask(int32_t times, bool retry, RefCount ref, SyncInfo &&syncInfo)
338 return [this, times, retry, keep = std::move(ref), info = std::move(syncInfo)]() mutable {
436 SyncInfo syncInfo(store.user, store.bundleName, store.storeName);
437 syncInfo.SetMode(evt.GetMode());
438 syncInfo.SetWait(evt.GetWait());
439 syncInfo
[all...]
H A Dsync_manager.h95 int32_t DoCloudSync(SyncInfo syncInfo);
133 Task GetSyncTask(int32_t times, bool retry, RefCount ref, SyncInfo &&syncInfo);
134 void UpdateSchema(const SyncInfo &syncInfo);
137 Retryer GetRetryer(int32_t times, const SyncInfo &syncInfo, int32_t user);
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/
H A Dkvdb_service_impl_test.cpp163 SyncInfo syncInfo; in HWTEST_F() local
164 status = kvdbServiceImpl_->CloudSync(appId, id1, syncInfo); in HWTEST_F()
269 SyncInfo syncInfo; in HWTEST_F() local
270 auto status = kvdbServiceImpl_->Sync(appId, storeId, syncInfo); in HWTEST_F()
411 SyncInfo syncInfo; in HWTEST_F() local
412 auto status = kvdbServiceImpl_->AddSubscribeInfo(appId, storeId, syncInfo); in HWTEST_F()
429 SyncInfo syncInfo; in HWTEST_F() local
430 auto status = kvdbServiceImpl_->RmvSubscribeInfo(appId, storeId, syncInfo); in HWTEST_F()
665 SyncInfo syncInfo; in HWTEST_F() local
666 status = kvdbServiceImpl_->DoCloudSync(metaData, syncInfo); in HWTEST_F()
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/udmf/
H A Dudmf_service_impl.cpp543 auto callback = [this](AsyncProcessInfo &syncInfo) { in Sync()
544 asyncProcessInfo_.syncId = syncInfo.syncId; in Sync()
545 asyncProcessInfo_.syncStatus = syncInfo.syncStatus; in Sync()
546 asyncProcessInfo_.syncTotal = syncInfo.syncTotal; in Sync()
547 asyncProcessInfo_.syncFinished = syncInfo.syncFinished; in Sync()
548 asyncProcessInfo_.srcDevName = syncInfo.srcDevName; in Sync()
553 syncInfo.srcDevName.c_str(), syncInfo.syncId, syncInfo.syncStatus, in Sync()
554 syncInfo in Sync()
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/udmf/store/
H A Dstore.h30 using ProcessCallback = std::function<void(AsyncProcessInfo &syncInfo)>;
/foundation/communication/dsoftbus/tests/core/bus_center/lnn/net_builder/src/
H A Dlnn_data_cloud_sync_mock_test.cpp594 CloudSyncInfo syncInfo; in HWTEST_F() local
595 (void)memset_s(&syncInfo, sizeof(CloudSyncInfo), 0, sizeof(CloudSyncInfo)); in HWTEST_F()
596 syncInfo.broadcastCipherKey = reinterpret_cast<char *>(SoftBusCalloc(TMP_LEN)); in HWTEST_F()
597 ASSERT_TRUE(syncInfo.broadcastCipherKey != nullptr); in HWTEST_F()
602 .WillRepeatedly(DoAll(SetArgPointee<0>(syncInfo), Return(SOFTBUS_OK))); in HWTEST_F()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/
H A Drelational_store_delegate_impl.cpp121 RelationalStoreConnection::SyncInfo syncInfo{devices, mode, in Sync()
125 int errCode = conn_->SyncToDevice(syncInfo); in Sync()
/foundation/communication/dsoftbus/core/bus_center/lnn/net_builder/src/
H A Dlnn_data_cloud_sync.c1048 CloudSyncInfo syncInfo = { 0 }; in PackBroadcastCipherKeyInner() local
1049 if (LnnGetLocalBroadcastCipherInfo(&syncInfo) != SOFTBUS_OK) { in PackBroadcastCipherKeyInner()
1053 if (!AddStringToJsonObject(json, DEVICE_INFO_JSON_BROADCAST_KEY_TABLE, syncInfo.broadcastCipherKey)) { in PackBroadcastCipherKeyInner()
1054 JSON_Free(syncInfo.broadcastCipherKey); in PackBroadcastCipherKeyInner()
1058 JSON_Free(syncInfo.broadcastCipherKey); in PackBroadcastCipherKeyInner()

Completed in 17 milliseconds