| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/src/ |
| H A D | kvdb_notifier_client.cpp | 35 …VDBNotifierClient::SyncCompleted(const std::map<std::string, Status> &results, uint64_t sequenceId) in SyncCompleted()
116 const std::shared_ptr<KvStoreSyncCallback> callback, uint64_t sequenceId) in AddSyncCallback()
128 void KVDBNotifierClient::DeleteSyncCallback(uint64_t sequenceId) in DeleteSyncCallback()
133 void KVDBNotifierClient::AddCloudSyncCallback(uint64_t sequenceId, const AsyncDetail &async) in AddCloudSyncCallback()
142 void KVDBNotifierClient::DeleteCloudSyncCallback(uint64_t sequenceId) in DeleteCloudSyncCallback()
|
| H A D | kvdb_notifier_stub.cpp | 63 uint64_t sequenceId; in OnSyncCompleted() local
75 uint64_t sequenceId; in OnCloudSyncCompleted() local
|
| /ohos5.0/foundation/ai/ai_engine/services/server/server_executor/source/ |
| 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()
122 void FutureFactory::Release(long long sequenceId) in Release()
127 void FutureFactory::DeleteFuture(long long sequenceId) in DeleteFuture()
185 long long sequenceId = response->GetInnerSequenceId(); in FetchFuture() local
|
| H A D | future.cpp | 28 Future::Future(IRequest *request, long long sequenceId, long long transactionId) in Future()
|
| /ohos5.0/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 &de… in CallResponseFailed()
|
| H A D | distributeddb_anti_dos_sync_test.cpp | 186 uint32_t sequenceId = index; variable
238 uint32_t sequenceId = index; variable
303 uint32_t sequenceId = index; variable
|
| H A D | mock_single_ver_state_machine.h | 45 bool CallStartSaveDataNotify(uint32_t sessionId, uint32_t sequenceId, uint32_t inMsgId) in CallStartSaveDataNotify()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/ |
| H A D | kvstore_sync_callback.h | 52 …RT virtual void SyncCompleted(const std::map<std::string, Status> &results, uint64_t sequenceId) {} in SyncCompleted()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/ |
| H A D | kvdb_notifier_proxy.cpp | 59 …KVDBNotifierProxy::SyncCompleted(const std::map<std::string, Status> &results, uint64_t sequenceId) in SyncCompleted()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| 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
|
| H A D | single_ver_data_sync.h | 45 uint32_t sequenceId = 0; member
|
| H A D | single_ver_data_sync.cpp | 166 uint32_t sequenceId = message->GetSequenceId(); in TryContinueSync() local
216 uint32_t sequenceId = reSendMap_.begin()->first; in ReSendData() local
1168 uint32_t sequenceId = message->GetSequenceId(); in AckPacketIdCheck() local
1236 uint32_t sessionId, uint32_t sequenceId, uint32_t inMsgId) in SendSaveDataNotifyPacket()
1437 uint32_t sessionId, uint32_t sequenceId) in SendReSendPacket()
|
| H A D | single_ver_data_sync_utils.cpp | 295 int SingleVerDataSyncUtils::GetReSendMode(int mode, uint32_t sequenceId, SyncType syncType) in GetReSendMode()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | remote_executor.cpp | 283 uint32_t sequenceId = inMsg->GetSequenceId(); in ReceiveRemoteExecutorAck() local
538 int RemoteExecutor::ResponseFailed(int errCode, uint32_t sessionId, uint32_t sequenceId, in ResponseFailed()
568 …teExecutor::ResponseStart(RemoteExecutorAckPacket *packet, uint32_t sessionId, uint32_t sequenceId, in ResponseStart()
809 …:ReceiveDataWithValidSession(const std::string &targetDev, uint32_t sessionId, uint32_t sequenceId, in ReceiveDataWithValidSession()
958 uint32_t sequenceId = 1u; in ResponseRemoteQueryRequest() local
|
| H A D | sync_state_machine.cpp | 228 bool SyncStateMachine::StartSaveDataNotify(uint32_t sessionId, uint32_t sequenceId, uint32_t inMsgI… in StartSaveDataNotify()
388 void SyncStateMachine::DoSaveDataNotify(uint32_t sessionId, uint32_t sequenceId, uint32_t inMsgId) in DoSaveDataNotify()
|
| H A D | remote_executor.h | 85 uint32_t sequenceId = 0u; member
|
| /ohos5.0/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
|
| H A D | protocol_proto.cpp | 896 uint64_t sequenceId = NetToHost(*fieldPtr++); in ParseLabelExchange() local
945 uint64_t sequenceId = NetToHost(*fieldPtr++); in ParseLabelExchangeAck() local
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/object/ |
| H A D | object_manager.cpp | 749 const std::map<std::string, DistributedDB::DBStatus> &results, uint64_t sequenceId) in SyncCompleted()
886 uint64_t sequenceId = SequenceSyncManager::GetInstance()->AddNotifier(userId_, callback); in SyncOnStore() local
1099 uint64_t sequenceId = KvStoreUtils::GenerateSequenceId(); in AddNotifier() local
1106 …uint64_t sequenceId, const std::map<std::string, DistributedDB::DBStatus> &results, std::string &u… in Process()
1122 SequenceSyncManager::Result SequenceSyncManager::DeleteNotifier(uint64_t sequenceId, std::string &u… in DeleteNotifier()
1132 SequenceSyncManager::Result SequenceSyncManager::DeleteNotifierNoLock(uint64_t sequenceId, std::str… in DeleteNotifierNoLock()
|
| /ohos5.0/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, RelationalRowData… in Put()
|
| /ohos5.0/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 i… in SendNotifyPacket()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
| H A D | object_manager_test.cpp | 874 auto sequenceId = syncManager->AddNotifier(userId_, func); variable
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/test/ |
| H A D | single_store_impl_test.cpp | 1155 … void SyncCompleted(const std::map<std::string, Status> &results, uint64_t sequenceId) override in SyncCompleted()
1179 … void SyncCompleted(const std::map<std::string, Status> &results, uint64_t sequenceId) override in SyncCompleted()
|
| /ohos5.0/base/inputmethod/imf/frameworks/native/inputmethod_ability/src/ |
| H A D | input_method_panel.cpp | 95 uint32_t sequenceId = GenerateSequenceId(); in GeneratePanelName() local
|