Searched refs:SingleVerSyncStateMachine (Results 1 – 5 of 5) sorted by relevance
23 class MockSingleVerStateMachine : public SingleVerSyncStateMachine {27 SingleVerSyncStateMachine::StepToTimeout(timerId); in CallStepToTimeout()37 return SingleVerSyncStateMachine::TimeMarkSyncRecv(inMsg); in CallTimeMarkSyncRecv()42 SingleVerSyncStateMachine::DataAckRecvErrCodeHandle(errCode, handleError); in CallDataAckRecvErrCodeHandle()47 return SingleVerSyncStateMachine::StartSaveDataNotify(sessionId, sequenceId, inMsgId); in CallStartSaveDataNotify()52 SingleVerSyncStateMachine::StopSaveDataNotify(); in CallStopSaveDataNotify()62 return SingleVerSyncStateMachine::PrepareNextSyncTask(); in CallPrepareNextSyncTask()67 return SingleVerSyncStateMachine::StartWatchDog(); in CallStartWatchDog()72 SingleVerSyncStateMachine::StopWatchDog(); in CallStopWatchDog()82 SingleVerSyncStateMachine::ResponsePullError(errCode, ignoreInnerErr); in CallResponsePullError()
105 using State = SingleVerSyncStateMachine::State;629 …stateMachine.CallSwitchMachineState(SingleVerSyncStateMachine::Event::START_SYNC_EVENT); // START_…1754 SingleVerSyncStateMachine stateMachine;
35 using Event = SingleVerSyncStateMachine::Event;36 using State = SingleVerSyncStateMachine::State;103 SingleVerSyncStateMachine::SingleVerSyncStateMachine() in SingleVerSyncStateMachine() function in DistributedDB::SingleVerSyncStateMachine113 SingleVerSyncStateMachine::~SingleVerSyncStateMachine() in ~SingleVerSyncStateMachine()168 void SingleVerSyncStateMachine::SyncStep() in SyncStep()223 void SingleVerSyncStateMachine::SyncStepInner() in SyncStepInner()256 void SingleVerSyncStateMachine::AbortInner() in AbortInner()548 Event SingleVerSyncStateMachine::DoTimeout() in DoTimeout()563 Event SingleVerSyncStateMachine::DoInnerErr() in DoInnerErr()912 void SingleVerSyncStateMachine::Clear() in Clear()[all …]
36 class SingleVerSyncStateMachine : public SyncStateMachine {72 SingleVerSyncStateMachine();73 ~SingleVerSyncStateMachine() override;223 DISABLE_COPY_ASSIGN_MOVE(SingleVerSyncStateMachine);
49 stateMachine_ = new (std::nothrow) SingleVerSyncStateMachine; in Initialize()71 …timeOutCallback = [stateMachine = static_cast<SingleVerSyncStateMachine *>(stateMachine_)](TimerId… in Initialize()517 … int errCode = static_cast<SingleVerSyncStateMachine *>(stateMachine_)->GetSendQueryWaterMark( in GetCorrectedSendWaterMarkForCurrentTask()525 … static_cast<SingleVerSyncStateMachine *>(stateMachine_)->GetLocalWaterMark(deviceId_, waterMark); in GetCorrectedSendWaterMarkForCurrentTask()