Home
last modified time | relevance | path

Searched refs:MultiVerSyncTaskContext (Results 1 – 12 of 12) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/
H A Dmulti_ver_sync_task_context.cpp25 DEFINE_OBJECT_TAG_FACILITIES(MultiVerSyncTaskContext) in DEFINE_OBJECT_TAG_FACILITIES() argument
27 MultiVerSyncTaskContext::~MultiVerSyncTaskContext() in DEFINE_OBJECT_TAG_FACILITIES()
92 int MultiVerSyncTaskContext::GetCommitIndex() const in GetCommitIndex()
97 void MultiVerSyncTaskContext::SetCommitIndex(int index) in SetCommitIndex()
102 int MultiVerSyncTaskContext::GetEntriesIndex() const in GetEntriesIndex()
107 void MultiVerSyncTaskContext::SetEntriesIndex(int index) in SetEntriesIndex()
147 void MultiVerSyncTaskContext::ReleaseEntries(void) in ReleaseEntries()
174 int MultiVerSyncTaskContext::GetCommitsSize() const in GetCommitsSize()
184 int MultiVerSyncTaskContext::GetEntriesSize() const in GetEntriesSize()
194 int MultiVerSyncTaskContext::GetValueSlicesSize() const in GetValueSlicesSize()
[all …]
H A Dmulti_ver_data_sync.h82 void TimeOutCallback(MultiVerSyncTaskContext *context, const Message *message) const;
84 int SyncStart(MultiVerSyncTaskContext *context);
86 int RequestRecvCallback(const MultiVerSyncTaskContext *context, const Message *message);
88 int AckRecvCallback(MultiVerSyncTaskContext *context, const Message *message);
97 void SendFinishedRequest(const MultiVerSyncTaskContext *context);
114 int GetValidCommit(MultiVerSyncTaskContext *context, MultiVerCommitNode &commit);
120 int SendRequestPacket(const MultiVerSyncTaskContext *context, MultiVerCommitNode &commit);
122 …int SendAckPacket(const MultiVerSyncTaskContext *context, const std::vector<MultiVerKvEntry *> &da…
H A Dvalue_slice_sync.h81 int SyncStart(MultiVerSyncTaskContext *context);
83 int RequestRecvCallback(const MultiVerSyncTaskContext *context, const Message *message);
85 int AckRecvCallback(const MultiVerSyncTaskContext *context, const Message *message);
87 void SendFinishedRequest(const MultiVerSyncTaskContext *context);
104 int GetValidValueSliceHashNode(MultiVerSyncTaskContext *context, ValueSliceHash &valueHashNode);
108 int SendRequestPacket(const MultiVerSyncTaskContext *context, ValueSliceHash &valueSliceHash);
110 int SendAckPacket(const MultiVerSyncTaskContext *context, const ValueSlice &value, int ackCode,
H A Dmulti_ver_sync_task_context.h24 class MultiVerSyncTaskContext final : public SyncTaskContext {
26 MultiVerSyncTaskContext() {}; in MultiVerSyncTaskContext() function
28 DISABLE_COPY_ASSIGN_MOVE(MultiVerSyncTaskContext);
86 ~MultiVerSyncTaskContext() override;
91 DECLARE_OBJECT_TAG(MultiVerSyncTaskContext);
H A Dmulti_ver_sync_state_machine.h100 int TimeSyncPacketRecvCallback(const MultiVerSyncTaskContext *context, const Message *inMsg);
102 int CommitHistorySyncPktRecvCallback(MultiVerSyncTaskContext *context, const Message *inMsg);
104 int MultiVerDataPktRecvCallback(MultiVerSyncTaskContext *context, const Message *inMsg);
106 int ValueSlicePktRecvCallback(MultiVerSyncTaskContext *context, const Message *inMsg);
128 MultiVerSyncTaskContext *context_;
H A Dmulti_ver_data_sync.cpp179 void MultiVerDataSync::TimeOutCallback(MultiVerSyncTaskContext *context, const Message *message) co… in TimeOutCallback()
184 int MultiVerDataSync::SyncStart(MultiVerSyncTaskContext *context) in SyncStart()
210 int MultiVerDataSync::RequestRecvCallback(const MultiVerSyncTaskContext *context, const Message *me… in RequestRecvCallback()
252 int MultiVerDataSync::AckRecvCallback(MultiVerSyncTaskContext *context, const Message *message) in AckRecvCallback()
318 void MultiVerDataSync::SendFinishedRequest(const MultiVerSyncTaskContext *context) in SendFinishedRequest()
540 int MultiVerDataSync::GetValidCommit(MultiVerSyncTaskContext *context, MultiVerCommitNode &commit) in GetValidCommit()
589 int MultiVerDataSync::SendRequestPacket(const MultiVerSyncTaskContext *context, MultiVerCommitNode … in SendRequestPacket()
631 int MultiVerDataSync::SendAckPacket(const MultiVerSyncTaskContext *context, in SendAckPacket()
H A Dvalue_slice_sync.cpp179 int ValueSliceSync::SyncStart(MultiVerSyncTaskContext *context) in SyncStart()
231 int ValueSliceSync::RequestRecvCallback(const MultiVerSyncTaskContext *context, const Message *mess… in RequestRecvCallback()
267 int ValueSliceSync::AckRecvCallback(const MultiVerSyncTaskContext *context, const Message *message) in AckRecvCallback()
300 void ValueSliceSync::SendFinishedRequest(const MultiVerSyncTaskContext *context) in SendFinishedRequest()
500 int ValueSliceSync::GetValidValueSliceHashNode(MultiVerSyncTaskContext *context, ValueSliceHash &va… in GetValidValueSliceHashNode()
538 int ValueSliceSync::SendRequestPacket(const MultiVerSyncTaskContext *context, ValueSliceHash &value… in SendRequestPacket()
580 int ValueSliceSync::SendAckPacket(const MultiVerSyncTaskContext *context, const ValueSlice &value, in SendAckPacket()
H A Dmulti_ver_sync_state_machine.cpp90 context_ = static_cast<MultiVerSyncTaskContext *>(context); in Initialize()
320 int MultiVerSyncStateMachine::TimeSyncPacketRecvCallback(const MultiVerSyncTaskContext *context, co… in TimeSyncPacketRecvCallback()
341 int MultiVerSyncStateMachine::CommitHistorySyncPktRecvCallback(MultiVerSyncTaskContext *context, co… in CommitHistorySyncPktRecvCallback()
370 int MultiVerSyncStateMachine::MultiVerDataPktRecvCallback(MultiVerSyncTaskContext *context, const M… in MultiVerDataPktRecvCallback()
397 int MultiVerSyncStateMachine::ValueSlicePktRecvCallback(MultiVerSyncTaskContext *context, const Mes… in ValueSlicePktRecvCallback()
H A Dmulti_ver_sync_engine.cpp23 return new (std::nothrow) MultiVerSyncTaskContext; in CreateSyncTaskContext()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dcommit_history_sync.h101 void TimeOutCallback(MultiVerSyncTaskContext *context, const Message *message) const;
103 int SyncStart(MultiVerSyncTaskContext *context);
105 int RequestRecvCallback(const MultiVerSyncTaskContext *context, const Message *message);
107 int AckRecvCallback(MultiVerSyncTaskContext *context, const Message *message);
130 int SendRequestPacket(const MultiVerSyncTaskContext *context,
133 …int SendAckPacket(const MultiVerSyncTaskContext *context, std::vector<MultiVerCommitNode> &commits,
H A Dcommit_history_sync.cpp222 void CommitHistorySync::TimeOutCallback(MultiVerSyncTaskContext *context, const Message *message) c… in TimeOutCallback()
229 int CommitHistorySync::SyncStart(MultiVerSyncTaskContext *context) in SyncStart()
251 int CommitHistorySync::RequestRecvCallback(const MultiVerSyncTaskContext *context, const Message *m… in RequestRecvCallback()
294 int CommitHistorySync::AckRecvCallback(MultiVerSyncTaskContext *context, const Message *message) in AckRecvCallback()
616 int CommitHistorySync::SendRequestPacket(const MultiVerSyncTaskContext *context, in SendRequestPacket()
660 int CommitHistorySync::SendAckPacket(const MultiVerSyncTaskContext *context, in SendAckPacket()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dgeneric_virtual_device.cpp103 context_ = new (std::nothrow) MultiVerSyncTaskContext; in Initialize()