Home
last modified time | relevance | path

Searched refs:syncInfo (Results 1 – 25 of 26) sorted by relevance

12

/ohos5.0/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 … KVDBServiceClient::CloudSync(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) in CloudSync() argument
183 …cast<uint32_t>(KVDBServiceInterfaceCode::TRANS_CLOUD_SYNC), reply, appId, storeId, syncInfo.seqId); in CloudSync()
289 …rviceClient::AddSubscribeInfo(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) in AddSubscribeInfo() argument
293 … reply, appId, storeId, syncInfo.seqId, syncInfo.devices, syncInfo.query); in AddSubscribeInfo()
297 StoreUtil::Anonymous(syncInfo.query).c_str()); in AddSubscribeInfo()
302 …rviceClient::RmvSubscribeInfo(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) in RmvSubscribeInfo() argument
306 … reply, appId, storeId, syncInfo.seqId, syncInfo.devices, syncInfo.query); in RmvSubscribeInfo()
[all …]
H A Dsingle_store_impl.cpp580 KVDBService::SyncInfo syncInfo; in Sync() local
582 syncInfo.mode = mode; in Sync()
583 syncInfo.delay = delay; in Sync()
584 syncInfo.devices = devices; in Sync()
594 syncInfo.mode = mode; in Sync()
595 syncInfo.devices = devices; in Sync()
597 syncInfo.delay = delay; in Sync()
694 SyncInfo syncInfo; in SubscribeWithQuery() local
696 syncInfo.devices = devices; in SubscribeWithQuery()
716 SyncInfo syncInfo; in 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()
/ohos5.0/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, … 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; in OnAddSubInfo() local
351 if (!ITypesUtil::Unmarshal(data, syncInfo.seqId, syncInfo.devices, syncInfo.query)) { in OnAddSubInfo()
356 int32_t status = AddSubscribeInfo(appId, storeId, syncInfo); in OnAddSubInfo()
368 SyncInfo syncInfo; in OnRmvSubInfo() local
[all …]
H A Dkvdb_service_impl.h51 Status CloudSync(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) override;
52 Status Sync(const AppId &appId, const StoreId &storeId, SyncInfo &syncInfo) override;
61 …Status AddSubscribeInfo(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) over…
62 …Status RmvSubscribeInfo(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) over…
123 Status DoCloudSync(const StoreMetaData &meta, const SyncInfo &syncInfo);
H A Dkvdb_service_impl.cpp226 …us KVDBServiceImpl::CloudSync(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) in CloudSync() argument
234 return DoCloudSync(metaData, syncInfo); in CloudSync()
246 Status KVDBServiceImpl::Sync(const AppId &appId, const StoreId &storeId, SyncInfo &syncInfo) in Sync() argument
250 auto delay = GetSyncDelayTime(syncInfo.delay, storeId); in Sync()
251 if (metaData.isAutoSync && syncInfo.seqId == std::numeric_limits<uint64_t>::max()) { in Sync()
261 syncInfo.syncId = ++syncId_; in Sync()
264 std::to_string(syncInfo.syncId), DATA_TYPE, metaData.dataType, SYNC_TYPE, in Sync()
265 SYNC, OS_TYPE, IsOHOSType(syncInfo.devices)); in Sync()
529 auto delay = GetSyncDelayTime(syncInfo.delay, storeId); in AddSubscribeInfo()
539 auto delay = GetSyncDelayTime(syncInfo.delay, storeId); in RmvSubscribeInfo()
[all …]
/ohos5.0/drivers/hdf_core/adapter/khdf/linux/platform/mipi_dsi/
H A Dmipi_tx_hi35xx.c508 g_mipiTxRegsVa->VID_VSA_LINES.u32 = cfg->syncInfo.vidVsaLines; in SetTimingConfig()
509 g_mipiTxRegsVa->VID_VBP_LINES.u32 = cfg->syncInfo.vidVbpLines; in SetTimingConfig()
1047 dev.syncInfo.vidPktSize = cntlr->cfg.timing.xPixels; in GetDevCfg()
1048 dev.syncInfo.vidHsaPixels = cntlr->cfg.timing.hsaPixels; in GetDevCfg()
1049 dev.syncInfo.vidHbpPixels = cntlr->cfg.timing.hbpPixels; in GetDevCfg()
1050 dev.syncInfo.vidHlinePixels = cntlr->cfg.timing.hlinePixels; in GetDevCfg()
1051 dev.syncInfo.vidVsaLines = cntlr->cfg.timing.vsaLines; in GetDevCfg()
1052 dev.syncInfo.vidVbpLines = cntlr->cfg.timing.vbpLines; in GetDevCfg()
1053 dev.syncInfo.vidVfpLines = cntlr->cfg.timing.vfpLines; in GetDevCfg()
1054 dev.syncInfo.vidActiveLines = cntlr->cfg.timing.ylines; in GetDevCfg()
[all …]
H A Dmipi_dsi_define.h73 SyncInfoTag syncInfo; member
/ohos5.0/base/print/print_fwk/services/scan_service/src/
H A Dscan_mdns_service.cpp200 ScanDeviceInfoSync syncInfo; in HandleResolveResult() local
201 syncInfo.deviceId = pair.second; in HandleResolveResult()
202 syncInfo.oldDeviceId = pair.first; in HandleResolveResult()
203 syncInfo.discoverMode = "TCP"; in HandleResolveResult()
204 syncInfo.uniqueId = scannerInfo->addr; in HandleResolveResult()
205 syncInfo.syncMode = "update"; in HandleResolveResult()
208 g_infoQueue.push(syncInfo); in HandleResolveResult()
H A Dscan_usb_manager.cpp201 ScanDeviceInfoSync syncInfo; in UpdateUsbScannerId() local
202 syncInfo.deviceId = newDeviceId; in UpdateUsbScannerId()
203 syncInfo.serialNumber = serialNumber; in UpdateUsbScannerId()
204 syncInfo.oldDeviceId = it->second.deviceId; in UpdateUsbScannerId()
205 syncInfo.discoverMode = "USB"; in UpdateUsbScannerId()
206 syncInfo.syncMode = "update"; in UpdateUsbScannerId()
207 ScanServiceAbility::GetInstance()->UpdateScannerId(syncInfo); in UpdateUsbScannerId()
H A Dscan_system_data.cpp128 ScanDeviceInfoSync syncInfo; in RefreshUsbDeviceId() local
129 syncInfo.deviceId = newDeviceId; in RefreshUsbDeviceId()
130 syncInfo.serialNumber = serialNumber; in RefreshUsbDeviceId()
131 syncInfo.oldDeviceId = oldDeviceId; in RefreshUsbDeviceId()
132 syncInfo.discoverMode = "USB"; in RefreshUsbDeviceId()
138 saPtr->UpdateScannerId(syncInfo); in RefreshUsbDeviceId()
H A Dscan_service_ability.cpp1351 void ScanServiceAbility::UpdateScannerId(const ScanDeviceInfoSync& syncInfo) in UpdateScannerId() argument
1357 SCAN_HILOGD("UpdateScannerId start newDeviceId:[%{private}s]", syncInfo.deviceId.c_str()); in UpdateScannerId()
1358 ScanDeviceInfoSync scanDeviceInfoSync = syncInfo; in UpdateScannerId()
1363 it->second.deviceId = syncInfo.deviceId; in UpdateScannerId()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/
H A Dsync_manager.cpp224 int32_t SyncManager::DoCloudSync(SyncInfo syncInfo) in DoCloudSync() argument
229 auto syncId = GenerateId(syncInfo.user_); in DoCloudSync()
430 syncInfo.SetMode(evt.GetMode()); in GetClientChangeHandler()
431 syncInfo.SetWait(evt.GetWait()); in GetClientChangeHandler()
432 syncInfo.SetAsyncDetail(evt.GetAsyncDetail()); in GetClientChangeHandler()
433 syncInfo.SetQuery(evt.GetQuery()); in GetClientChangeHandler()
434 syncInfo.SetCompensation(evt.IsCompensation()); in GetClientChangeHandler()
435 syncInfo.SetTriggerMode(evt.GetTriggerMode()); in GetClientChangeHandler()
505 void SyncManager::UpdateSchema(const SyncManager::SyncInfo &syncInfo) in UpdateSchema() argument
508 storeInfo.user = syncInfo.user_; in UpdateSchema()
[all …]
H A Dsync_manager.h95 int32_t DoCloudSync(SyncInfo syncInfo);
132 Task GetSyncTask(int32_t times, bool retry, RefCount ref, SyncInfo &&syncInfo);
133 void UpdateSchema(const SyncInfo &syncInfo);
136 Retryer GetRetryer(int32_t times, const SyncInfo &syncInfo, int32_t user);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/include/
H A Dkvdb_service.h55 virtual Status Sync(const AppId &appId, const StoreId &storeId, SyncInfo &syncInfo) = 0;
64 … Status AddSubscribeInfo(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) = 0;
65 … 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 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) over…
49 …Status RmvSubscribeInfo(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) over…
54 Status CloudSync(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) override;
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);
/ohos5.0/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 … Status AddSubscribeInfo(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) = 0;
52 … Status RmvSubscribeInfo(const AppId &appId, const StoreId &storeId, const SyncInfo &syncInfo) = 0;
/ohos5.0/base/print/print_fwk/test/fuzztest/scancallback_fuzzer/
H A Dscancallback_fuzzer.cpp47 ScanDeviceInfoSync syncInfo; in TestSetCallbackSyncParam() local
48 param.SetCallbackSyncParam(state, syncInfo); in TestSetCallbackSyncParam()
70 ScanDeviceInfoSync syncInfo; in TestOnCallbackSync() local
71 callBack.OnCallbackSync(state, syncInfo); in TestOnCallbackSync()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/
H A Dkvdb_service_impl_test.cpp161 SyncInfo syncInfo; variable
162 status = kvdbServiceImpl_->CloudSync(appId, id1, syncInfo);
267 SyncInfo syncInfo; variable
268 auto status = kvdbServiceImpl_->Sync(appId, storeId, syncInfo);
409 SyncInfo syncInfo; variable
427 SyncInfo syncInfo; variable
663 SyncInfo syncInfo; variable
664 status = kvdbServiceImpl_->DoCloudSync(metaData, syncInfo);
666 syncInfo.devices = {"device1", "device2"};
667 syncInfo.query = "query";
[all …]
/ohos5.0/foundation/communication/dsoftbus/tests/core/bus_center/lnn/net_builder/src/
H A Dlnn_data_cloud_sync_mock_test.cpp594 CloudSyncInfo syncInfo; variable
595 (void)memset_s(&syncInfo, sizeof(CloudSyncInfo), 0, sizeof(CloudSyncInfo));
596 syncInfo.broadcastCipherKey = reinterpret_cast<char *>(SoftBusCalloc(TMP_LEN));
597 ASSERT_TRUE(syncInfo.broadcastCipherKey != nullptr);
602 .WillRepeatedly(DoAll(SetArgPointee<0>(syncInfo), Return(SOFTBUS_OK)));
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/
H A Drelational_store_delegate_impl.cpp121 RelationalStoreConnection::SyncInfo syncInfo{devices, mode, in Sync() local
125 int errCode = conn_->SyncToDevice(syncInfo); in Sync()
/ohos5.0/foundation/communication/dsoftbus/core/bus_center/lnn/net_builder/src/
H A Dlnn_data_cloud_sync.c1043 CloudSyncInfo syncInfo = { 0 }; in PackBroadcastCipherKeyInner() local
1044 if (LnnGetLocalBroadcastCipherInfo(&syncInfo) != SOFTBUS_OK) { in PackBroadcastCipherKeyInner()
1048 …if (!AddStringToJsonObject(json, DEVICE_INFO_JSON_BROADCAST_KEY_TABLE, syncInfo.broadcastCipherKey… in PackBroadcastCipherKeyInner()
1049 JSON_Free(syncInfo.broadcastCipherKey); in PackBroadcastCipherKeyInner()
1053 JSON_Free(syncInfo.broadcastCipherKey); in PackBroadcastCipherKeyInner()
/ohos5.0/docs/zh-cn/device-dev/driver/
H A Ddriver-platform-mipidsi-develop.md194 SyncInfoTag syncInfo; // 时序相关的设置

12