Lines Matching refs:interval
82 uint32_t Timer::Register(const TimerCallback& callback, uint32_t interval /* ms */, bool once)
86 int timerFd = once ? INVALID_TIMER_FD : GetTimerFd(interval);
88 uint32_t ret = DoRegister([this](int fd) { this->OnTimer(fd); }, interval, once, timerFd);
90 UTILS_LOGE("do register interval timer %{public}d failed, return %{public}u", interval, ret);
103 entry->interval = interval;
108 intervalToTimers_[interval].push_back(entry);
111 UTILS_LOGD("register timer %{public}u with %{public}u ms interval.", entry->timerId, entry->interval);
124 UTILS_LOGD("deregister timer %{public}u with %{public}u ms interval", timerId, entry->interval);
126 auto itor = intervalToTimers_[entry->interval].begin();
127 for (; itor != intervalToTimers_[entry->interval].end(); ++itor) {
134 intervalToTimers_[entry->interval].erase(itor);
139 if (intervalToTimers_[entry->interval].empty()) {
140 UTILS_LOGD("deregister timer interval: %{public}u.", entry->interval);
141 intervalToTimers_.erase(entry->interval);
142 DoUnregister(entry->interval);
156 uint32_t Timer::DoRegister(const TimerListCallback& callback, uint32_t interval, bool once, int &timerFd)
159 uint32_t ret = reactor_->ScheduleTimer(cb, interval, timerFd, once);
164 timers_[timerFd] = interval;
168 void Timer::DoUnregister(uint32_t interval)
171 if (itor.second == interval) {
179 uint32_t interval;
183 interval = timers_[timerFd];
184 entryList = intervalToTimers_[interval];
204 EraseUnusedTimerId(interval, onceIdsUnused);
225 int Timer::GetTimerFd(uint32_t interval /* ms */)
227 if (intervalToTimers_.find(interval) == intervalToTimers_.end()) {
230 auto &entryList = intervalToTimers_[interval];
239 void Timer::EraseUnusedTimerId(uint32_t interval, const std::vector<uint32_t>& unusedIds)
242 auto &entryList = intervalToTimers_[interval];
256 intervalToTimers_.erase(interval);
257 DoUnregister(interval);