Home
last modified time | relevance | path

Searched refs:sequenceId (Results 1 – 25 of 41) sorted by relevance

12

/ohos5.0/foundation/ai/ai_engine/services/server/server_executor/source/
H A Dfuture_factory.cpp94 long long sequenceId = FindSequenceId(); in CreateFuture() local
95 if (sequenceId == INVALID_SEQUENCE_ID) { in CreateFuture()
105 req->SetInnerSequenceId(sequenceId); in CreateFuture()
111 AddFuture(sequenceId, future); in CreateFuture()
119 futures_[sequenceId] = future; in AddFuture()
122 void FutureFactory::Release(long long sequenceId) in Release() argument
124 DeleteFuture(sequenceId); in Release()
127 void FutureFactory::DeleteFuture(long long sequenceId) in DeleteFuture() argument
130 auto iter = futures_.find(sequenceId); in DeleteFuture()
134 futures_.erase(sequenceId); in DeleteFuture()
[all …]
H A Dfuture.cpp28 Future::Future(IRequest *request, long long sequenceId, long long transactionId) in Future() argument
29 : sequenceId_(sequenceId), in Future()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/src/
H A Dkvdb_notifier_client.cpp38 auto finded = syncCallbackInfo_.Find(sequenceId); in SyncCompleted()
41 finded.second->SyncCompleted(results, sequenceId); in SyncCompleted()
42 DeleteSyncCallback(sequenceId); in SyncCompleted()
116 const std::shared_ptr<KvStoreSyncCallback> callback, uint64_t sequenceId) in AddSyncCallback() argument
122 auto inserted = syncCallbackInfo_.Insert(sequenceId, callback); in AddSyncCallback()
124 ZLOGE("The sequeuceId %{public}" PRIu64 "is repeat!", sequenceId); in AddSyncCallback()
128 void KVDBNotifierClient::DeleteSyncCallback(uint64_t sequenceId) in DeleteSyncCallback() argument
130 syncCallbackInfo_.Erase(sequenceId); in DeleteSyncCallback()
139 cloudSyncCallbacks_.Insert(sequenceId, async); in AddCloudSyncCallback()
142 void KVDBNotifierClient::DeleteCloudSyncCallback(uint64_t sequenceId) in DeleteCloudSyncCallback() argument
[all …]
H A Dkvdb_notifier_stub.cpp63 uint64_t sequenceId; in OnSyncCompleted() local
64 if (!ITypesUtil::Unmarshal(data, results, sequenceId)) { in OnSyncCompleted()
65 …OGE("Unmarshal results size:%{public}zu, sequenceId:%{public}" PRIu64, results.size(), sequenceId); in OnSyncCompleted()
68 SyncCompleted(std::move(results), sequenceId); in OnSyncCompleted()
75 uint64_t sequenceId; in OnCloudSyncCompleted() local
76 if (!ITypesUtil::Unmarshal(data, sequenceId, detail)) { in OnCloudSyncCompleted()
77 ZLOGE("Unmarshal sequenceId:%{public}" PRIu64, sequenceId); in OnCloudSyncCompleted()
80 SyncCompleted(sequenceId, std::move(detail)); in OnCloudSyncCompleted()
H A Dkvdb_notifier_client.h31 void SyncCompleted(const std::map<std::string, Status> &results, uint64_t sequenceId) override;
38 void AddSyncCallback(const std::shared_ptr<KvStoreSyncCallback> callback, uint64_t sequenceId);
40 void DeleteSyncCallback(uint64_t sequenceId);
46 void AddCloudSyncCallback(uint64_t sequenceId, const AsyncDetail &async);
47 void DeleteCloudSyncCallback(uint64_t sequenceId);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_message_schedule.cpp156 uint32_t sequenceId = msg->GetSequenceId(); in GetMsgFromMap() local
157 if (sequenceId < expectedSequenceId_) { in GetMsgFromMap()
168 if (sequenceId == expectedSequenceId_) { in GetMsgFromMap()
179 messageMap_[sequenceId] = msg; in GetMsgFromMap()
306 uint32_t sequenceId = msg->GetSequenceId(); in UpdateMsgMapIfNeed() local
320 if (messageMap_.count(sequenceId) > 0) { in UpdateMsgMapIfNeed()
321 const auto *cachePacket = messageMap_[sequenceId]->GetObject<DataRequestPacket>(); in UpdateMsgMapIfNeed()
324 if ((GetPacketId(messageMap_[sequenceId], cachePacketId) == E_OK) && in UpdateMsgMapIfNeed()
331 delete messageMap_[sequenceId]; in UpdateMsgMapIfNeed()
332 messageMap_[sequenceId] = nullptr; in UpdateMsgMapIfNeed()
[all …]
H A Dsingle_ver_data_sync.h45 uint32_t sequenceId = 0; member
89 uint32_t sequenceId, uint32_t inMsgId);
212 uint32_t sessionId, uint32_t sequenceId);
H A Dsingle_ver_data_sync.cpp166 uint32_t sequenceId = message->GetSequenceId(); in TryContinueSync() local
176 if (reSendMap_.count(sequenceId) != 0) { in TryContinueSync()
177 lastQueryTime = reSendMap_[sequenceId].end; in TryContinueSync()
178 reSendMap_.erase(sequenceId); in TryContinueSync()
216 uint32_t sequenceId = reSendMap_.begin()->first; in ReSendData() local
1168 uint32_t sequenceId = message->GetSequenceId(); in AckPacketIdCheck() local
1169 if (reSendMap_.count(sequenceId) != 0) { in AckPacketIdCheck()
1170 uint64_t originalPacketId = reSendMap_[sequenceId].packetId; in AckPacketIdCheck()
1236 uint32_t sessionId, uint32_t sequenceId, uint32_t inMsgId) in SendSaveDataNotifyPacket() argument
1414 errCode = SendReSendPacket(packet, context, reSendInfo.sessionId, reSendInfo.sequenceId); in ReSend()
[all …]
/ohos5.0/foundation/ai/ai_engine/services/server/server_executor/include/
H A Dfuture_factory.h54 void Release(long long sequenceId);
81 void AddFuture(long long sequenceId, Future* future);
83 void DeleteFuture(long long sequenceId);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_anti_dos_sync_test.cpp186 uint32_t sequenceId = index; variable
192 message->SetSequenceId(sequenceId);
238 uint32_t sequenceId = index; variable
244 message->SetSequenceId(sequenceId);
303 uint32_t sequenceId = index; variable
310 message->SetSequenceId(sequenceId);
H A Dmock_remote_executor.h28 …int CallResponseFailed(int errCode, uint32_t sessionId, uint32_t sequenceId, const std::string &de… in CallResponseFailed() argument
30 return RemoteExecutor::ResponseFailed(errCode, sessionId, sequenceId, device); in CallResponseFailed()
H A Dmock_single_ver_state_machine.h45 bool CallStartSaveDataNotify(uint32_t sessionId, uint32_t sequenceId, uint32_t inMsgId) in CallStartSaveDataNotify() argument
47 return SingleVerSyncStateMachine::StartSaveDataNotify(sessionId, sequenceId, inMsgId); in CallStartSaveDataNotify()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/
H A Dkvdb_notifier_proxy.cpp59 …KVDBNotifierProxy::SyncCompleted(const std::map<std::string, Status> &results, uint64_t sequenceId) in SyncCompleted() argument
63 KVDBNotifierCode::TRANS_SYNC_COMPLETED), reply, results, sequenceId); in SyncCompleted()
66 status, results.size(), sequenceId); in SyncCompleted()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/object/
H A Dobject_manager.cpp897 SyncCompleted(result, sequenceId); in SyncOnStore()
1099 uint64_t sequenceId = KvStoreUtils::GenerateSequenceId(); in AddNotifier() local
1100 userIdSeqIdRelations_[userId].emplace_back(sequenceId); in AddNotifier()
1101 seqIdCallbackRelations_[sequenceId] = callback; in AddNotifier()
1102 return sequenceId; in AddNotifier()
1109 if (seqIdCallbackRelations_.count(sequenceId) == 0) { in Process()
1117 seqIdCallbackRelations_[sequenceId](syncResults); in Process()
1119 return DeleteNotifierNoLock(sequenceId, userId); in Process()
1125 if (seqIdCallbackRelations_.count(sequenceId) == 0) { in DeleteNotifier()
1129 return DeleteNotifierNoLock(sequenceId, userId); in DeleteNotifier()
[all …]
H A Dobject_manager.h52 Result DeleteNotifier(uint64_t sequenceId, std::string &userId);
54 …uint64_t sequenceId, const std::map<std::string, DistributedDB::DBStatus> &results, std::string &u…
57 Result DeleteNotifierNoLock(uint64_t sequenceId, std::string &userId);
159 … SyncCompleted(const std::map<std::string, DistributedDB::DBStatus> &results, uint64_t sequenceId);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dsync_state_machine.h117 virtual void SendNotifyPacket(uint32_t sessionId, uint32_t sequenceId, uint32_t inMsgId) = 0;
138 bool StartSaveDataNotify(uint32_t sessionId, uint32_t sequenceId, uint32_t inMsgId);
151 virtual void DoSaveDataNotify(uint32_t sessionId, uint32_t sequenceId, uint32_t inMsgId);
H A Dremote_executor.cpp283 uint32_t sequenceId = inMsg->GetSequenceId(); in ReceiveRemoteExecutorAck() local
300 ReceiveDataWithValidSession(targetDev, sessionId, sequenceId, packet); in ReceiveRemoteExecutorAck()
538 int RemoteExecutor::ResponseFailed(int errCode, uint32_t sessionId, uint32_t sequenceId, in ResponseFailed() argument
548 return ResponseStart(packet, sessionId, sequenceId, device); in ResponseFailed()
565 return ResponseStart(packet, sendMessage.sessionId, sendMessage.sequenceId, device); in ResponseData()
603 message->SetSequenceId(sequenceId); in ResponseStart()
820 taskMap_[sessionId].taskId, sequenceId); in ReceiveDataWithValidSession()
823 taskMap_[sessionId].targetCount = sequenceId; in ReceiveDataWithValidSession()
958 uint32_t sequenceId = 1u; in ResponseRemoteQueryRequest() local
966 SendMessage sendMessage = { sessionId, sequenceId, token == nullptr, option }; in ResponseRemoteQueryRequest()
[all …]
H A Dremote_executor.h80 …int ResponseFailed(int errCode, uint32_t sessionId, uint32_t sequenceId, const std::string &device…
85 uint32_t sequenceId = 0u; member
115 int ResponseStart(RemoteExecutorAckPacket *packet, uint32_t sessionId, uint32_t sequenceId,
131 … ReceiveDataWithValidSession(const std::string &targetDev, uint32_t sessionId, uint32_t sequenceId,
H A Dsync_state_machine.cpp228 bool SyncStateMachine::StartSaveDataNotify(uint32_t sessionId, uint32_t sequenceId, uint32_t inMsgI… in StartSaveDataNotify() argument
242 [this, sessionId, sequenceId, inMsgId](TimerId timerId) { in StartSaveDataNotify()
244 … int ret = RuntimeContext::GetInstance()->ScheduleTask([this, sessionId, sequenceId, inMsgId]() { in StartSaveDataNotify()
245 DoSaveDataNotify(sessionId, sequenceId, inMsgId); in StartSaveDataNotify()
388 void SyncStateMachine::DoSaveDataNotify(uint32_t sessionId, uint32_t sequenceId, uint32_t inMsgId) in DoSaveDataNotify() argument
397 SendNotifyPacket(sessionId, sequenceId, inMsgId); in DoSaveDataNotify()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/
H A Dcommunicator_linker.cpp285 uint64_t sequenceId = incSequenceId_.fetch_add(1, std::memory_order_seq_cst); in TriggerLabelExchangeEvent() local
301 …SerialBuffer *buffer = ProtocolProto::BuildLabelExchange(localDistinctValue_, sequenceId, onlineLa… in TriggerLabelExchangeEvent()
311 waitAckSeq_[toTarget] = sequenceId; in TriggerLabelExchangeEvent()
312 } else if (waitAckSeq_[toTarget] > sequenceId) { in TriggerLabelExchangeEvent()
315 …" be triggered for target=%s{private}", ULL(waitAckSeq_[toTarget]), ULL(sequenceId), toTarget.c_st… in TriggerLabelExchangeEvent()
320 waitAckSeq_[toTarget] = sequenceId; in TriggerLabelExchangeEvent()
325 SendLabelExchange(toTarget, buffer, sequenceId, 0); // Initially retransmitCount is 0 in TriggerLabelExchangeEvent()
H A Dheader_converter.cpp78 headerConverted.sequenceId = NetToHost(headerOriginal.sequenceId); in ConvertNetToHost()
H A Dframe_header.h68 uint32_t sequenceId = 0; // Sequence of message member
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/relational/
H A Drelational_result_set_impl.cpp331 int RelationalResultSetImpl::Put(const DeviceID &deviceName, uint32_t sequenceId, RelationalRowData… in Put() argument
333 if (sequenceId == 0) { in Put()
337 cacheDataSet_[sequenceId - 1] = std::move(data); in Put()
/ohos5.0/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/
H A Dkvstore_sync_callback.h52 …RT virtual void SyncCompleted(const std::map<std::string, Status> &results, uint64_t sequenceId) {} in SyncCompleted() argument
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/include/
H A Dikvdb_notifier.h32 … virtual void SyncCompleted(const std::map<std::string, Status> &results, uint64_t sequenceId) = 0;

12