| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/utils/src/ |
| H A D | kvstore_utils.cpp | 43 uint64_t seqId = ++sequenceId_; in GenerateSequenceId() local
44 if (seqId == std::numeric_limits<uint64_t>::max()) { in GenerateSequenceId()
47 return seqId; in GenerateSequenceId()
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
| H A D | rdb_sql_statistic.cpp | 58 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()
|
| /ohos5.0/foundation/distributeddatamgr/pasteboard/framework/framework/clip/ |
| H A D | clip_plugin.cpp | 96 ret = ret && SetValue(node, seqId, GET_NAME(seqId)); in Marshal()
112 ret = ret && GetValue(node, GET_NAME(seqId), seqId); in Unmarshal()
|
| /ohos5.0/foundation/distributeddatamgr/pasteboard/framework/framework/include/clip/ |
| H A D | clip_plugin.h | 35 uint16_t seqId = 0; member
44 return globalEvent.seqId == this->seqId && globalEvent.deviceId == this->deviceId;
|
| /ohos5.0/foundation/ai/ai_engine/services/common/protocol/data_channel/source/ |
| H A D | request.cpp | 49 void Request::SetInnerSequenceId(long long seqId) in SetInnerSequenceId() argument
51 innerSequenceId_ = seqId; in SetInnerSequenceId()
|
| H A D | response.cpp | 60 void Response::SetInnerSequenceId(long long seqId) in SetInnerSequenceId() argument
62 innerSequenceId_ = seqId; in SetInnerSequenceId()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/ |
| H A D | single_store_impl.cpp | 581 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()
956 serviceAgent->AddSyncCallback(observer, syncInfo.seqId); in DoSync()
[all …]
|
| H A D | kvdb_service_client.cpp | 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()
183 …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 D | store_util.cpp | 274 uint64_t seqId = ++sequenceId_; in GenSequenceId() local
275 if (seqId == std::numeric_limits<uint64_t>::max()) { in GenSequenceId()
278 return seqId; in GenSequenceId()
|
| /ohos5.0/foundation/ai/ai_engine/services/common/protocol/data_channel/include/ |
| H A D | request.h | 41 void SetInnerSequenceId(long long seqId);
|
| H A D | response.h | 49 void SetInnerSequenceId(long long seqId);
|
| /ohos5.0/foundation/distributeddatamgr/pasteboard/framework/test/src/ |
| H A D | paste_data_test.cpp | 723 event1.seqId = 0;
727 event2.seqId = 0;
743 event1.seqId = 0;
747 event2.seqId = 0;
763 event1.seqId = 0;
767 event2.seqId = 1;
|
| H A D | serializable_test.cpp | 491 event.seqId = 0;
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/include/ |
| H A D | rdb_sql_statistic.h | 43 SqlStatistic(const std::string &sql, int32_t step, uint32_t seqId = 0);
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/ |
| H A D | kvdb_service_impl.cpp | 251 if (metaData.isAutoSync && syncInfo.seqId == std::numeric_limits<uint64_t>::max()) { in Sync()
983 …GenAsync syncCallback = [tokenId = storeInfo.tokenId, seqId = syncInfo.seqId, this](const GenDetai… in DoCloudSync()
984 OnAsyncComplete(tokenId, seqId, HandleGenDetails(details)); in DoCloudSync()
997 …info.seqId, type, info.devices.size(), meta.bundleName.c_str(), Anonymous::Change(meta.storeId).c_… in DoSync()
1001 …info.seqId, info.devices.size(), meta.bundleName.c_str(), Anonymous::Change(meta.storeId).c_str()); in DoSync()
1012 …info.seqId, info.devices.size(), meta.bundleName.c_str(), Anonymous::Change(meta.storeId).c_str()); in DoSyncInOrder()
1016 …info.seqId, info.devices.size(), meta.bundleName.c_str(), Anonymous::Change(meta.storeId).c_str()); in DoSyncInOrder()
1159 …ZLOGD("seqId:0x%{public}" PRIx64 " tokenId:0x%{public}x remote:%{public}zu", info.seqId, meta.toke… in DoComplete()
1192 if (info.seqId == std::numeric_limits<uint64_t>::max()) { in DoComplete()
1203 notifier->SyncCompleted(result, info.seqId); in DoComplete()
|
| H A D | kvdb_service_stub.cpp | 192 …if (!ITypesUtil::Unmarshal(data, syncInfo.seqId, syncInfo.mode, syncInfo.devices, syncInfo.delay, … 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()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/kvstoremock/frameworks/innerkitsimpl/kvdb/include/ |
| H A D | kvdb_service.h | 27 uint64_t seqId = std::numeric_limits<uint64_t>::max();
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/include/ |
| H A D | kvdb_service.h | 30 uint64_t seqId = std::numeric_limits<uint64_t>::max();
|
| /ohos5.0/base/hiviewdfx/hiview/base/test/unittest/common/ |
| H A D | event_loop_test.cpp | 338 auto seqId = currentLooper_->AddTimerEvent(nullptr, nullptr, task, 2, true); variable
341 currentLooper_->RemoveEvent(seqId);
|
| /ohos5.0/drivers/peripheral/distributed_camera/hdi_service/include/dcamera_device/ |
| H A D | dcamera_device.h | 54 int32_t GetSecureCameraSeq(uint64_t &seqId) override;
|
| /ohos5.0/foundation/distributeddatamgr/pasteboard/services/core/src/ |
| H A D | pasteboard_service.cpp | 680 auto key = event.deviceId + std::to_string(event.seqId); in GetRemoteDataTask()
696 auto key = event.deviceId + std::to_string(event.seqId); in Notify()
714 auto key = event.deviceId + std::to_string(event.seqId); in WaitRemoteData()
735 auto key = event.deviceId + std::to_string(event.seqId); in ClearRemoteDataTask()
1364 if (evt.deviceId == currentEvent_.deviceId && evt.seqId == currentEvent_.seqId && in GetValidDistributeEvent()
2144 event.seqId = ++sequenceId_; in SetDistributedData()
2154 data.GetDataId(), event.seqId, event.expiration); in SetDistributedData()
2163 …tributed data encode failed, dataId:%{public}u, seqId:%{public}hu", data.GetDataId(), event.seqId); in SetDistributedData()
|
| /ohos5.0/drivers/peripheral/distributed_camera/hdi_service/src/dcamera_device/ |
| H A D | dcamera_device.cpp | 183 int32_t DCameraDevice::GetSecureCameraSeq(uint64_t &seqId) in GetSecureCameraSeq() argument
185 (void)seqId; in GetSecureCameraSeq()
|
| /ohos5.0/base/inputmethod/imf/frameworks/native/inputmethod_ability/src/ |
| H A D | input_method_panel.cpp | 905 uint32_t seqId = ++sequenceId_; in GenerateSequenceId() local
906 if (seqId == std::numeric_limits<uint32_t>::max()) { in GenerateSequenceId()
909 return seqId; in GenerateSequenceId()
|
| /ohos5.0/foundation/multimedia/camera_framework/services/camera_service/include/ |
| H A D | hcapture_session.h | 310 string CreateBurstDisplayName(int32_t imageSeqId, int32_t seqId);
|
| /ohos5.0/foundation/multimedia/camera_framework/services/camera_service/src/ |
| H A D | hcapture_session.cpp | 1884 std::string HCaptureSession::CreateBurstDisplayName(int32_t imageSeqId, int32_t seqId) in CreateBurstDisplayName() argument
1902 ss << std::setw(burstWidth) << std::setfill(placeholder) << seqId; in CreateBurstDisplayName()
1904 ss << lastBurstPrefix_ << std::setw(burstWidth) << std::setfill(placeholder) << seqId; in CreateBurstDisplayName()
1908 if (seqId == 1) { in CreateBurstDisplayName()
|