| /foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/ |
| H A D | kvstore_sync_callback.h | 52 API_EXPORT virtual void SyncCompleted(const std::map<std::string, Status> &results, uint64_t sequenceId) {} in SyncCompleted() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | mock_remote_executor.h | 28 int CallResponseFailed(int errCode, uint32_t sessionId, uint32_t sequenceId, const std::string &device) in CallResponseFailed() argument
|
| H A D | mock_single_ver_state_machine.h | 45 bool CallStartSaveDataNotify(uint32_t sessionId, uint32_t sequenceId, uint32_t inMsgId) in CallStartSaveDataNotify() argument
|
| H A D | distributeddb_anti_dos_sync_test.cpp | 186 uint32_t sequenceId = index; in HWTEST_F() local
238 uint32_t sequenceId = index; in HWTEST_F() local
303 uint32_t sequenceId = index; in HWTEST_F() local
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/ |
| H A D | kvdb_notifier_proxy.cpp | 59 void KVDBNotifierProxy::SyncCompleted(const std::map<std::string, Status> &results, uint64_t sequenceId) in SyncCompleted() argument
|
| /foundation/ai/ai_engine/services/server/server_executor/source/ |
| H A D | future.cpp | 28 Future::Future(IRequest *request, long long sequenceId, long long transactionId) in Future() argument
|
| H A D | future_factory.cpp | 94 long long sequenceId = FindSequenceId(); in CreateFuture() local
115 void FutureFactory::AddFuture(long long sequenceId, Future* future) in AddFuture() argument
122 void FutureFactory::Release(long long sequenceId) in Release() argument
127 void FutureFactory::DeleteFuture(long long sequenceId) in DeleteFuture() argument
185 long long sequenceId = response->GetInnerSequenceId(); FetchFuture() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| H A D | frame_header.h | 68 uint32_t sequenceId = 0; // Sequence of message member
|
| H A D | communicator_linker.cpp | 285 uint64_t sequenceId = incSequenceId_.fetch_add(1, std::memory_order_seq_cst); in TriggerLabelExchangeEvent() local
[all...] |
| H A D | protocol_proto.cpp | 896 uint64_t sequenceId = NetToHost(*fieldPtr++); in ParseLabelExchange() local
945 uint64_t sequenceId = NetToHost(*fieldPtr++); in ParseLabelExchangeAck() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/src/ |
| H A D | kvdb_notifier_stub.cpp | 63 uint64_t sequenceId; in OnSyncCompleted() local
68 SyncCompleted(std::move(results), sequenceId); in OnSyncCompleted() local
75 uint64_t sequenceId; in OnCloudSyncCompleted() local
[all...] |
| H A D | kvdb_notifier_client.cpp | 35 void KVDBNotifierClient::SyncCompleted(const std::map<std::string, Status> &results, uint64_t sequenceId) in SyncCompleted() argument
128 void KVDBNotifierClient::DeleteSyncCallback(uint64_t sequenceId) in DeleteSyncCallback() argument
133 void KVDBNotifierClient::AddCloudSyncCallback(uint64_t sequenceId, cons argument
115 AddSyncCallback( const std::shared_ptr<KvStoreSyncCallback> callback, uint64_t sequenceId) AddSyncCallback() argument
142 DeleteCloudSyncCallback(uint64_t sequenceId) DeleteCloudSyncCallback() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | remote_executor.h | 85 uint32_t sequenceId = 0u; member
|
| H A D | sync_state_machine.cpp | 228 bool SyncStateMachine::StartSaveDataNotify(uint32_t sessionId, uint32_t sequenceId, uint32_t inMsgId) in StartSaveDataNotify() argument
388 void SyncStateMachine::DoSaveDataNotify(uint32_t sessionId, uint32_t sequenceId, uint32_t inMsgId) in DoSaveDataNotify() argument
|
| H A D | remote_executor.cpp | 283 uint32_t sequenceId = inMsg->GetSequenceId(); in ReceiveRemoteExecutorAck() local
537 int RemoteExecutor::ResponseFailed(int errCode, uint32_t sessionId, uint32_t sequenceId, in ResponseFailed() argument
567 int RemoteExecutor::ResponseStart(RemoteExecutorAckPacket *packet, uint32_t sessionId, uint32_t sequenceId, in ResponseStart() argument
808 void RemoteExecutor::ReceiveDataWithValidSession(const std::string &targetDev, uint32_t sessionId, uint32_t sequenceId, in ReceiveDataWithValidSession() argument
957 uint32_t sequenceId = 1u; ResponseRemoteQueryRequest() local
[all...] |
| H A D | ability_sync.cpp | 380 int AbilitySync::SyncStart(uint32_t sessionId, uint32_t sequenceId, uint16_t remoteCommunicatorVersion, in SyncStart() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
| H A D | multi_ver_sync_state_machine.cpp | 305 void MultiVerSyncStateMachine::SendNotifyPacket(uint32_t sessionId, uint32_t sequenceId, uint32_t inMsgId) in SendNotifyPacket() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_data_sync.h | 45 uint32_t sequenceId = 0; member
|
| H A D | single_ver_data_message_schedule.cpp | 156 uint32_t sequenceId = msg->GetSequenceId(); in GetMsgFromMap() local
306 uint32_t sequenceId = msg->GetSequenceId(); in UpdateMsgMapIfNeed() local
[all...] |
| H A D | single_ver_data_sync_utils.cpp | 295 int SingleVerDataSyncUtils::GetReSendMode(int mode, uint32_t sequenceId, SyncType syncType) in GetReSendMode() argument
|
| H A D | single_ver_sync_state_machine.cpp | 298 void SingleVerSyncStateMachine::SendNotifyPacket(uint32_t sessionId, uint32_t sequenceId, uint32_t inMsgId) in SendNotifyPacket() argument
|
| H A D | single_ver_data_sync.cpp | 167 uint32_t sequenceId = message->GetSequenceId(); in TryContinueSync() local
217 uint32_t sequenceId = reSendMap_.begin()->first; in ReSendData() local
1179 uint32_t sequenceId = message->GetSequenceId(); in AckPacketIdCheck() local
1246 SendSaveDataNotifyPacket(SingleVerSyncTaskContext *context, uint32_t pktVersion, uint32_t sessionId, uint32_t sequenceId, uint32_t inMsgId) SendSaveDataNotifyPacket() argument
1447 SendReSendPacket(DataRequestPacket *packet, SingleVerSyncTaskContext *context, uint32_t sessionId, uint32_t sequenceId) SendReSendPacket() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/relational/ |
| H A D | relational_result_set_impl.cpp | 331 int RelationalResultSetImpl::Put(const DeviceID &deviceName, uint32_t sequenceId, RelationalRowDataSet &&data) in Put() argument
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
| H A D | object_manager_test.cpp | 876 auto sequenceId = syncManager->AddNotifier(userId_, func); in HWTEST_F() local
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/object/ |
| H A D | object_manager.cpp | 886 uint64_t sequenceId = SequenceSyncManager::GetInstance()->AddNotifier(userId_, callback);
in SyncOnStore() local
748 SyncCompleted( const std::map<std::string, DistributedDB::DBStatus> &results, uint64_t sequenceId) SyncCompleted() argument
1099 uint64_t sequenceId = KvStoreUtils::GenerateSequenceId(); AddNotifier() local
1105 Process( uint64_t sequenceId, const std::map<std::string, DistributedDB::DBStatus> &results, std::string &userId) Process() argument
1122 DeleteNotifier(uint64_t sequenceId, std::string &userId) DeleteNotifier() argument
1132 DeleteNotifierNoLock(uint64_t sequenceId, std::string &userId) DeleteNotifierNoLock() argument
[all...] |