Home
last modified time | relevance | path

Searched refs:TimerId (Results 1 – 25 of 44) sorted by relevance

12

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/
H A Druntime_context_impl.h49 const TimerFinalizer &finalizer, TimerId &timerId) override;
52 int ModifyTimer(TimerId timerId, int milliSeconds) override;
55 void RemoveTimer(TimerId timerId, bool wait) override;
192 int AllocTimerId(IEvent *evTimer, TimerId &timerId);
201 int ModifyTimerByThreadPool(TimerId timerId, int milliSeconds);
205 void ThreadPoolTimerAction(int milliSeconds, const TimerAction &action, TimerId timerId);
220 TimerId currentTimerId_;
221 std::map<TimerId, IEvent *> timers_;
226 TimerId taskPoolReportsTimerId_;
275 std::map<TimerId, TaskId> taskIds_;
[all …]
H A Dtime_tick_monitor.h66 int TimeTick(TimerId timerId);
71 TimerId monitorTimerId_ = 0;
H A Druntime_context_impl.cpp164 const TimerFinalizer &finalizer, TimerId &timerId) in SetTimer()
219 int RuntimeContextImpl::ModifyTimer(TimerId timerId, int milliSeconds) in ModifyTimer()
242 void RuntimeContextImpl::RemoveTimer(TimerId timerId, bool wait) in RemoveTimer()
385 int RuntimeContextImpl::AllocTimerId(IEvent *evTimer, TimerId &timerId) in AllocTimerId()
388 TimerId startId = currentTimerId_; in AllocTimerId()
987 const TimerFinalizer &finalizer, bool allocTimerId, TimerId &timerId) in SetTimerByThreadPool()
1021 int RuntimeContextImpl::ModifyTimerByThreadPool(TimerId timerId, int milliSeconds) in ModifyTimerByThreadPool()
1044 void RuntimeContextImpl::RemoveTimerByThreadPool(TimerId timerId, bool wait) in RemoveTimerByThreadPool()
1071 void RuntimeContextImpl::ThreadPoolTimerAction(int milliSeconds, const TimerAction &action, TimerId… in ThreadPoolTimerAction()
H A Dtime_tick_monitor.cpp52 monitorCallback_ = [this](TimerId timerId) { return TimeTick(timerId); }; in StartTimeTickMonitor()
119 int TimeTickMonitor::TimeTick(TimerId timerId) in TimeTick()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/
H A Ddistributeddb_thread_pool_test.cpp138 int errCode = RuntimeContext::GetInstance()->SetTimer(timeOut, [&timerCount](TimerId timerId) { in SetTimer()
152 void SetTimer(int &timerCount, TimerId &timer) in SetTimer()
224 TimerId timer = 0;
269 TimerId timer;
300 TimerId timer = 0;
329 TimerId timer = 0;
370 TimerId timerIdArray[MAX_TIMER_COUNT] = {};
410 std::set<TimerId> removeSet;
411 std::set<TimerId> checkSet;
412 std::set<TimerId> timerSet;
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dsync_state_machine.h35 TimerId feedDogTimerId = 0;
56 int TimeoutCallback(TimerId timerId) override;
90 virtual void StepToTimeout(TimerId timerId) = 0;
157 void StopFeedDogForGetDataInner(TimerId timerId);
175 TimerId saveDataNotifyTimerId_;
181 TimerId getDataNotifyTimerId_;
H A Dsync_state_machine.cpp79 int SyncStateMachine::TimeoutCallback(TimerId timerId) in TimeoutCallback()
85 TimerId timer = syncContext_->GetTimerId(); in TimeoutCallback()
242 [this, sessionId, sequenceId, inMsgId](TimerId timerId) { in StartSaveDataNotify()
316 [this, flag](TimerId timerId) { in StartFeedDogForSync()
449 [this, sessionId](TimerId timerId) { in StartFeedDogForGetData()
478 TimerId timerId = 0; in StopFeedDogForGetData()
502 void SyncStateMachine::StopFeedDogForGetDataInner(TimerId timerId) in StopFeedDogForGetDataInner()
H A Dremote_executor.h120 int TimeoutCallBack(TimerId timerId);
121 void DoTimeout(TimerId timerId);
156 std::map<TimerId, uint32_t> timeoutMap_; // use to abort task when timeout
157 std::map<uint32_t, TimerId> taskFinishMap_; // use to wake up timer when task finished
H A Dsync_task_context.h111 TimerId GetTimerId() const override;
228 virtual int TimeOut(TimerId id);
281 TimerId timerId_ = 0;
H A Dsync_task_context.cpp312 TimerId timerId = 0; in StartTimer()
314 TimerAction timeOutCallback = [this](TimerId id) { return TimeOut(id); }; in StartTimer()
332 TimerId timerId; in StopTimer()
373 TimerId SyncTaskContext::GetTimerId() const in GetTimerId()
556 int SyncTaskContext::TimeOut(TimerId id) in TimeOut()
H A Dtime_sync.h128 int TimeSyncDriver(TimerId timerId);
157 TimerId driverTimerId_;
H A Disync_state_machine.h43 virtual int TimeoutCallback(TimerId timerId) = 0;
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_sync_engine.cpp75 TimerId timerId = 0; in StartAutoSubscribeTimer()
76 TimerAction timeOutCallback = [this](TimerId id) { return SubscribeTimeOut(id); }; in StartAutoSubscribeTimer()
89 TimerId subscribeTimerId = 0u; in StopAutoSubscribeTimer()
102 int SingleVerSyncEngine::SubscribeTimeOut(TimerId id) in SubscribeTimeOut()
H A Dsingle_ver_sync_engine.h35 int SubscribeTimeOut(TimerId id);
56 TimerId subscribeTimerId_ = 0;
H A Dsingle_ver_data_message_schedule.h53 int TimeOut(TimerId timerId);
71 TimerId timerId_ = 0;
H A Dsingle_ver_data_message_schedule.cpp229 TimerId timerId = 0; in StartTimer()
231 TimerAction timeOutCallback = [this](TimerId timerId) { return TimeOut(timerId); }; in StartTimer()
252 TimerId timerId; in StopTimer()
271 int SingleVerDataMessageSchedule::TimeOut(TimerId timerId) in TimeOut()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/
H A Dmulti_ver_sync_state_machine.h36 TimerId timerId = 0;
59 void StepToTimeout(TimerId timerId) override;
123 int SyncResponseTimeout(TimerId timerId);
H A Dmulti_ver_sync_state_machine.cpp184 void MultiVerSyncStateMachine::StepToTimeout(TimerId timerId) in StepToTimeout()
188 TimerId timer = syncContext_->GetTimerId(); in StepToTimeout()
546 …TimerAction timeOutCallback = [this](TimerId timerId) -> int { return SyncResponseTimeout(timerId)… in SyncResponseBegin()
549 TimerId timerId = 0; in SyncResponseBegin()
589 int MultiVerSyncStateMachine::SyncResponseTimeout(TimerId timerId) in SyncResponseTimeout()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/
H A Druntime_context.h38 using TimerId = uint64_t; variable
39 using TimerAction = std::function<int(TimerId timerId)>;
64 const TimerFinalizer &finalizer, TimerId &timerId) = 0;
65 virtual int ModifyTimer(TimerId timerId, int milliSeconds) = 0;
66 virtual void RemoveTimer(TimerId timerId, bool wait = false) = 0;
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Dmock_sync_task_context.h50 MOCK_CONST_METHOD0(GetTimerId, TimerId(void));
101 int CallTimeout(TimerId id) in CallTimeout()
H A Dmock_single_ver_state_machine.h25 void CallStepToTimeout(TimerId timerId) in CallStepToTimeout()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/
H A Dframe_combiner.h70 TimerId timerId_ = 0; // 0 is invalid timerId
H A Dframe_retainer.h73 TimerId timerId_ = 0; // 0 is invalid timerId
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_single_ver_natural_store_extend.cpp62 TimerId timerId = 0; in StartLifeCycleTimer()
64 [this](TimerId id) -> int { in StartLifeCycleTimer()
120 TimerId timerId = lifeTimerId_; in StopLifeCycleTimer()
/ohos5.0/docs/zh-cn/application-dev/reference/apis-arkui/
H A Djs-apis-arkui-Prefetcher.md237 type TimerId = number;
242 private readonly fetches: Map<ItemIndex, TimerId> = new Map();

12