Home
last modified time | relevance | path

Searched refs:seqId (Results 1 - 21 of 21) sorted by relevance

/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/utils/src/
H A Dkvstore_utils.cpp43 uint64_t seqId = ++sequenceId_; in GenerateSequenceId() local
44 if (seqId == std::numeric_limits<uint64_t>::max()) { in GenerateSequenceId()
47 return seqId; in GenerateSequenceId()
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/
H A Drdb_sql_statistic.cpp58 SqlStatistic::SqlStatistic(const std::string &sql, int32_t step, uint32_t seqId) in SqlStatistic() argument
64 key_ = seqId == 0 ? GetThreadId() : uint64_t(seqId); in SqlStatistic()
71 if (execInfo_ == nullptr && seqId != 0) { in SqlStatistic()
/foundation/distributeddatamgr/pasteboard/framework/framework/include/clip/
H A Dclip_plugin.h35 uint16_t seqId = 0; member
44 return globalEvent.seqId == this->seqId && globalEvent.deviceId == this->deviceId; in operator ==()
/foundation/distributeddatamgr/pasteboard/framework/framework/clip/
H A Dclip_plugin.cpp91 ret = ret && SetValue(node, seqId, GET_NAME(seqId)); in Marshal()
107 ret = ret && GetValue(node, GET_NAME(seqId), seqId); in Unmarshal()
/foundation/ai/ai_engine/services/common/protocol/data_channel/source/
H A Dresponse.cpp60 void Response::SetInnerSequenceId(long long seqId) in SetInnerSequenceId() argument
62 innerSequenceId_ = seqId; in SetInnerSequenceId()
H A Drequest.cpp49 void Request::SetInnerSequenceId(long long seqId) in SetInnerSequenceId() argument
51 innerSequenceId_ = seqId; in SetInnerSequenceId()
/foundation/ai/ai_engine/services/common/protocol/data_channel/include/
H A Dresponse.h47 * @param [in] seqId Inner sequence Id.
49 void SetInnerSequenceId(long long seqId);
H A Drequest.h39 * @param [in] seqId Inner sequence Id.
41 void SetInnerSequenceId(long long seqId);
/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/
H A Drdb_sql_statistic.h43 SqlStatistic(const std::string &sql, int32_t step, uint32_t seqId = 0);
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/
H A Dstore_util.cpp274 uint64_t seqId = ++sequenceId_; in GenSequenceId() local
275 if (seqId == std::numeric_limits<uint64_t>::max()) { in GenSequenceId()
278 return seqId; in GenSequenceId()
H A Dkvdb_service_client.cpp171 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()
183 static_cast<uint32_t>(KVDBServiceInterfaceCode::TRANS_CLOUD_SYNC), reply, appId, storeId, syncInfo.seqId); in CloudSync()
293 reply, appId, storeId, syncInfo.seqId, syncInfo.devices, syncInfo.query); in AddSubscribeInfo()
306 reply, appId, storeId, syncInfo.seqId, syncInfo.devices, syncInfo.query); in RmvSubscribeInfo()
H A Dsingle_store_impl.cpp581 syncInfo.seqId = StoreUtil::GenSequenceId(); in Sync()
593 syncInfo.seqId = StoreUtil::GenSequenceId(); in Sync()
615 syncInfo.seqId = StoreUtil::GenSequenceId(); in CloudSync()
616 serviceAgent->AddCloudSyncCallback(syncInfo.seqId, async); in CloudSync()
620 serviceAgent->DeleteCloudSyncCallback(syncInfo.seqId); in CloudSync()
695 syncInfo.seqId = StoreUtil::GenSequenceId(); in SubscribeWithQuery()
705 serviceAgent->AddSyncCallback(syncObserver_, syncInfo.seqId); in SubscribeWithQuery()
717 syncInfo.seqId = StoreUtil::GenSequenceId(); in UnsubscribeWithQuery()
727 serviceAgent->AddSyncCallback(syncObserver_, syncInfo.seqId); in UnsubscribeWithQuery()
961 serviceAgent->AddSyncCallback(observer, syncInfo.seqId);
[all...]
/foundation/distributeddatamgr/pasteboard/framework/test/src/
H A Dpaste_data_test.cpp782 event1.seqId = 0; in HWTEST_F()
786 event2.seqId = 0; in HWTEST_F()
802 event1.seqId = 0; in HWTEST_F()
806 event2.seqId = 0; in HWTEST_F()
822 event1.seqId = 0; in HWTEST_F()
826 event2.seqId = 1; in HWTEST_F()
H A Dserializable_test.cpp484 event.seqId = 0; in HWTEST_F()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/
H A Dkvdb_service_impl.cpp245 if (metaData.isAutoSync && syncInfo.seqId == std::numeric_limits<uint64_t>::max()) { in Sync()
942 GenAsync syncCallback = [tokenId = storeInfo.tokenId, seqId = syncInfo.seqId, this](const GenDetails &details) { in DoCloudSync()
943 OnAsyncComplete(tokenId, seqId, HandleGenDetails(details)); in DoCloudSync()
955 ZLOGD("seqId:0x%{public}" PRIx64 " type:%{public}d remote:%{public}zu appId:%{public}s storeId:%{public}s", in DoSync()
956 info.seqId, type, info.devices.size(), meta.bundleName.c_str(), Anonymous::Change(meta.storeId).c_str()); in DoSync()
959 ZLOGW("no device online seqId:0x%{public}" PRIx64 " remote:%{public}zu appId:%{public}s storeId:%{public}s", in DoSync()
960 info.seqId, info.devices.size(), meta.bundleName.c_str(), Anonymous::Change(meta.storeId).c_str()); in DoSync()
970 ZLOGD("type:%{public}d seqId:0x%{public}" PRIx64 " remote:%{public}zu appId:%{public}s storeId:%{public}s", type, in DoSyncInOrder()
971 info.seqId, inf in DoSyncInOrder()
[all...]
H A Dkvdb_service_stub.cpp192 if (!ITypesUtil::Unmarshal(data, syncInfo.seqId, syncInfo.mode, syncInfo.devices, syncInfo.delay, syncInfo.query)) { in OnSync()
210 if (!ITypesUtil::Unmarshal(data, syncInfo.seqId)) { in OnCloudSync()
351 if (!ITypesUtil::Unmarshal(data, syncInfo.seqId, syncInfo.devices, syncInfo.query)) { in OnAddSubInfo()
369 if (!ITypesUtil::Unmarshal(data, syncInfo.seqId, syncInfo.devices, syncInfo.query)) { in OnRmvSubInfo()
/foundation/distributeddatamgr/kv_store/kvstoremock/frameworks/innerkitsimpl/kvdb/include/
H A Dkvdb_service.h27 uint64_t seqId = std::numeric_limits<uint64_t>::max(); member
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/include/
H A Dkvdb_service.h30 uint64_t seqId = std::numeric_limits<uint64_t>::max(); member
/foundation/distributeddatamgr/pasteboard/services/core/src/
H A Dpasteboard_service.cpp672 auto key = event.deviceId + std::to_string(event.seqId); in GetRemoteDataTask()
688 auto key = event.deviceId + std::to_string(event.seqId); in Notify()
706 auto key = event.deviceId + std::to_string(event.seqId); in WaitRemoteData()
727 auto key = event.deviceId + std::to_string(event.seqId); in ClearRemoteDataTask()
1351 if (evt.deviceId == currentEvent_.deviceId && evt.seqId == currentEvent_.seqId && in GetValidDistributeEvent()
2067 event.seqId = ++sequenceId_; in SetDistributedData()
2076 PASTEBOARD_HILOGI(PASTEBOARD_MODULE_SERVICE, "dataId:%{public}u, seqId:%{public}hu, expiration:%{public}" PRIu64, in SetDistributedData()
2077 data.GetDataId(), event.seqId, event.expiration); in SetDistributedData()
2086 "distributed data encode failed, dataId:%{public}u, seqId in SetDistributedData()
[all...]
/foundation/multimedia/camera_framework/services/camera_service/include/
H A Dhcapture_session.h286 string CreateBurstDisplayName(int32_t seqId);
/foundation/multimedia/camera_framework/services/camera_service/src/
H A Dhcapture_session.cpp1655 std::string HCaptureSession::CreateBurstDisplayName(int32_t seqId) in CreateBurstDisplayName() argument
1660 if (seqId == 1) { in CreateBurstDisplayName()
1674 ss << std::setw(burstWidth) << std::setfill(placeholder) << seqId in CreateBurstDisplayName()
1677 ss << lastBurstPrefix_ << std::setw(burstWidth) << std::setfill(placeholder) << seqId; in CreateBurstDisplayName()

Completed in 28 milliseconds