Home
last modified time | relevance | path

Searched refs:sequenceId (Results 1 - 25 of 40) sorted by relevance

12

/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()
108 AIE_NEW(future, Future(request, sequenceId, request->GetTransactionId())); in CreateFuture()
111 AddFuture(sequenceId, future); in CreateFuture()
115 void FutureFactory::AddFuture(long long sequenceId, Future* future) in AddFuture() argument
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
185 long long sequenceId = response->GetInnerSequenceId(); FetchFuture() local
[all...]
H A Dfuture.cpp28 Future::Future(IRequest *request, long long sequenceId, long long transactionId) in Future() argument
29 : sequenceId_(sequenceId), in Future()
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/src/
H A Dkvdb_notifier_client.cpp35 void KVDBNotifierClient::SyncCompleted(const std::map<std::string, Status> &results, uint64_t sequenceId) in SyncCompleted() argument
38 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()
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()
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...]
H A Dkvdb_notifier_stub.cpp63 uint64_t sequenceId; in OnSyncCompleted() local
64 if (!ITypesUtil::Unmarshal(data, results, sequenceId)) { in OnSyncCompleted()
65 ZLOGE("Unmarshal results size:%{public}zu, sequenceId:%{public}" PRIu64, results.size(), sequenceId); in OnSyncCompleted()
68 SyncCompleted(std::move(results), sequenceId); in OnSyncCompleted() local
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, st in OnCloudSyncCompleted()
[all...]
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);
/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()
158 uint64_t revisePacketId = finishedPacketId_ - (expectedSequenceId_ - 1 - sequenceId); in GetMsgFromMap()
168 if (sequenceId == expectedSequenceId_) { in GetMsgFromMap()
178 // sequenceId > expectedSequenceId_, not need handle, put into map again 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], cachePacketI 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);
271 // sequenceId as key
275 // max sequenceId has been sent
/foundation/ai/ai_engine/services/server/server_executor/include/
H A Dfuture_factory.h50 * Release the future corresponding to sequenceId.
52 * @param [in] sequenceId The sequence number that uniquely identifies an asynchronous task.
54 void Release(long long sequenceId);
81 void AddFuture(long long sequenceId, Future* future);
83 void DeleteFuture(long long sequenceId);
H A Dfuture.h35 Future(IRequest *request, long long sequenceId, long long transactionId);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dmock_remote_executor.h28 int CallResponseFailed(int errCode, uint32_t sessionId, uint32_t sequenceId, const std::string &device) 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()
H A Ddistributeddb_anti_dos_sync_test.cpp186 uint32_t sequenceId = index; in HWTEST_F() local
192 message->SetSequenceId(sequenceId); in HWTEST_F()
238 uint32_t sequenceId = index; in HWTEST_F() local
244 message->SetSequenceId(sequenceId); in HWTEST_F()
303 uint32_t sequenceId = index; in HWTEST_F() local
310 message->SetSequenceId(sequenceId); in HWTEST_F()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/
H A Dkvdb_notifier_proxy.cpp59 void 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()
65 ZLOGE("status:%{public}d, results size:%{public}zu, sequenceId:%{public}" PRIu64, in SyncCompleted()
66 status, results.size(), sequenceId); in SyncCompleted()
76 ZLOGE("status:%{public}d, sequenceId:%{public}" PRIu64, status, seqNum); in SyncCompleted()
H A Dkvdb_notifier_proxy.h29 void SyncCompleted(const std::map<std::string, Status> &results, uint64_t sequenceId) override;
/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.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 void 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 inMsgId) 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()
H A Dremote_executor.cpp283 uint32_t sequenceId = inMsg->GetSequenceId(); in ReceiveRemoteExecutorAck() local
300 ReceiveDataWithValidSession(targetDev, sessionId, sequenceId, packet); in ReceiveRemoteExecutorAck()
537 int RemoteExecutor::ResponseFailed(int errCode, uint32_t sessionId, uint32_t sequenceId, in ResponseFailed() argument
547 return ResponseStart(packet, sessionId, sequenceId, device); in ResponseFailed()
564 return ResponseStart(packet, sendMessage.sessionId, sendMessage.sequenceId, device); in ResponseData()
567 int RemoteExecutor::ResponseStart(RemoteExecutorAckPacket *packet, uint32_t sessionId, uint32_t sequenceId, in ResponseStart() argument
602 message->SetSequenceId(sequenceId); in ResponseStart()
808 void RemoteExecutor::ReceiveDataWithValidSession(const std::string &targetDev, uint32_t sessionId, uint32_t sequenceId, in ReceiveDataWithValidSession() argument
818 LOGD("[RemoteExecutor][ReceiveRemoteExecutorAck] taskId=%" PRIu32 " sequenceId=%" PRIu32, in ReceiveDataWithValidSession()
819 taskMap_[sessionId].taskId, sequenceId); in ReceiveDataWithValidSession()
957 uint32_t sequenceId = 1u; ResponseRemoteQueryRequest() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/
H A Dcommunicator_linker.cpp92 // the distinctValue of this remote target may be changed, and the sequenceId may start from zero in TargetOffline()
151 // Update top sequenceId of received LabelExchange in ReceiveLabelExchange()
205 // Update top sequenceId of received LabelExchangeAck in ReceiveLabelExchangeAck()
265 // The process of remote target must have undergone a quit and restart, the remote sequenceId will start from zero. in DetectDistinctValueChange()
284 // Apply for a latest sequenceId in TriggerLabelExchangeEvent()
285 uint64_t sequenceId = incSequenceId_.fetch_add(1, std::memory_order_seq_cst); in TriggerLabelExchangeEvent() local
301 SerialBuffer *buffer = ProtocolProto::BuildLabelExchange(localDistinctValue_, sequenceId, onlineLabels, error); 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), toTarge in TriggerLabelExchangeEvent()
[all...]
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
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/object/
H A Dobject_manager.cpp749 const std::map<std::string, DistributedDB::DBStatus> &results, uint64_t sequenceId) in SyncCompleted()
752 SequenceSyncManager::Result result = SequenceSyncManager::GetInstance()->Process(sequenceId, results, userId); in SyncCompleted()
760 ZLOGI("Sync data success, sequenceId: 0x%{public}" PRIx64 "", sequenceId); in SyncCompleted()
764 ZLOGE("Sync data failed, sequenceId: 0x%{public}" PRIx64 ", status: %{public}d", sequenceId, item.second); in SyncCompleted()
886 uint64_t sequenceId = SequenceSyncManager::GetInstance()->AddNotifier(userId_, callback); in SyncOnStore() local
889 ZLOGI("Start sync data, sequenceId: 0x%{public}" PRIx64 "", sequenceId); in SyncOnStore()
891 [this, sequenceId](cons in SyncOnStore()
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...]
/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/
H A Dkvstore_sync_callback.h50 * @param sequenceId sequence Id of current synchronization.
52 API_EXPORT virtual void SyncCompleted(const std::map<std::string, Status> &results, uint64_t sequenceId) {} in SyncCompleted() argument
/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;
/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, RelationalRowDataSet &&data) in Put() argument
333 if (sequenceId == 0) { in Put()
334 LOGE("[RelationalResultSetImpl] Invalid sequenceId"); in Put()
337 cacheDataSet_[sequenceId - 1] = std::move(data); in Put()

Completed in 12 milliseconds

12