Home
last modified time | relevance | path

Searched refs:sequenceId_ (Results 1 - 18 of 18) sorted by relevance

/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/utils/src/
H A Dkvstore_utils.cpp27 std::atomic<uint64_t> KvStoreUtils::sequenceId_{ 0 };
43 uint64_t seqId = ++sequenceId_; in GenerateSequenceId()
45 return ++sequenceId_; in GenerateSequenceId()
/foundation/ai/ai_engine/services/server/server_executor/source/
H A Dfuture_factory.cpp55 FutureFactory::FutureFactory() : sequenceId_(0) in FutureFactory()
82 ++sequenceId_; in FindSequenceId()
83 if (sequenceId_ < MIN_SEQUENCE_ID) { in FindSequenceId()
84 HILOGI("[FutureFactory]The sequenceId_ is smaller than MIN_SEQUENCE_ID."); in FindSequenceId()
85 sequenceId_ = MIN_SEQUENCE_ID; in FindSequenceId()
87 } while (futures_.find(sequenceId_) != futures_.end()); in FindSequenceId()
89 return sequenceId_; in FindSequenceId()
H A Dfuture.cpp29 : sequenceId_(sequenceId), in Future()
58 futureFactory->Release(sequenceId_); in Release()
102 return sequenceId_; in GetSequenceId()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_single_ver_msg_schedule_test.cpp76 info.sequenceId_ = i; in HWTEST_F()
126 info.sequenceId_ = 1; in HWTEST_F()
168 info.sequenceId_ = 1; in HWTEST_F()
180 info.sequenceId_ = 1; in HWTEST_F()
185 info.sequenceId_ = 2; in HWTEST_F()
190 info.sequenceId_ = 2; in HWTEST_F()
236 info.sequenceId_ = i; in HWTEST_F()
245 info.sequenceId_ = i; in HWTEST_F()
295 info.sequenceId_ = i; in HWTEST_F()
302 info.sequenceId_ in HWTEST_F()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/
H A Dmessage.h132 sequenceId_ = inSequenceId; in SetSequenceId()
175 return sequenceId_; in GetSequenceId()
209 uint32_t sequenceId_ = 0; // Distinguish different message even in same session with same content in retry case member in DistributedDB::Message
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/
H A Dobject_manager_test.cpp46 uint64_t sequenceId_ = 10; member in OHOS::Test::ObjectManagerTest
106 auto result = syncManager->DeleteNotifier(sequenceId_, userId_); in HWTEST_F()
127 auto result = syncManager->Process(sequenceId_, results, userId_); in HWTEST_F()
129 syncManager->seqIdCallbackRelations_.emplace(sequenceId_, func); in HWTEST_F()
130 result = syncManager->Process(sequenceId_, results, userId_); in HWTEST_F()
148 syncManager->seqIdCallbackRelations_.emplace(sequenceId_, func); in HWTEST_F()
149 std::vector<uint64_t> seqIds = {sequenceId_, sequenceId_2, sequenceId_3}; in HWTEST_F()
151 auto result = syncManager->DeleteNotifierNoLock(sequenceId_, userId_); in HWTEST_F()
154 result = syncManager->DeleteNotifierNoLock(sequenceId_, userId_); in HWTEST_F()
577 manager->SyncCompleted(results, sequenceId_); in HWTEST_F()
859 auto sequenceId_ = syncManager->AddNotifier(userId_, func); HWTEST_F() local
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/include/utils/
H A Dkvstore_utils.h37 static std::atomic<uint64_t> sequenceId_; member in OHOS::DistributedKv::KvStoreUtils
/foundation/ai/ai_engine/services/server/server_executor/include/
H A Dfuture_factory.h99 std::atomic<long long> sequenceId_; member in OHOS::AI::FutureFactory
H A Dfuture.h75 long long sequenceId_; member in OHOS::AI::Future
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/
H A Dstore_util.cpp33 std::atomic<uint64_t> StoreUtil::sequenceId_ = 0; member in OHOS::DistributedKv::StoreUtil
274 uint64_t seqId = ++sequenceId_; in GenSequenceId()
276 return ++sequenceId_; in GenSequenceId()
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/include/
H A Dstore_util.h54 static std::atomic<uint64_t> sequenceId_; member in OHOS::DistributedKv::final
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dsync_task_context.cpp155 sequenceId_ = 1; in Clear()
384 sequenceId_++; in IncSequenceId()
389 return sequenceId_; in GetSequenceId()
394 sequenceId_ = 1; in ReSetSequenceId()
H A Dsync_task_context.h266 volatile uint32_t sequenceId_ = 1; member in DistributedDB::SyncTaskContext
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/
H A Dmulti_ver_sync_task_context.cpp230 sequenceId_ = 1; // minimum valid ID : 1 in Clear()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/
H A Ddistributeddb_tools_unit_test.h73 uint32_t sequenceId_ = 0; member
H A Ddistributeddb_tools_unit_test.cpp1108 message->SetSequenceId(messageInfo.sequenceId_); in BuildMessage()
/foundation/distributeddatamgr/pasteboard/services/core/include/
H A Dpasteboard_service.h289 std::atomic<uint16_t> sequenceId_ = 0; member in OHOS::MiscServices::final
/foundation/distributeddatamgr/pasteboard/services/core/src/
H A Dpasteboard_service.cpp2067 event.seqId = ++sequenceId_; in SetDistributedData()

Completed in 15 milliseconds