/commonlibrary/c_utils/base/src/ |
H A D | timer.cpp | 82 uint32_t Timer::Register(const TimerCallback& callback, uint32_t interval /* ms */, bool once) in Register() 86 int timerFd = once ? INVALID_TIMER_FD : GetTimerFd(interval); in Register() 88 uint32_t ret = DoRegister([this](int fd) { this->OnTimer(fd); }, interval, once, timerFd); in Register() 90 UTILS_LOGE("do register interval timer %{public}d failed, return %{public}u", interval, ret); in Register() 103 entry->interval = interval; in Register() 108 intervalToTimers_[interval].push_back(entry); in Register() 111 UTILS_LOGD("register timer %{public}u with %{public}u ms interval.", entry->timerId, entry->interval); in Register() 156 DoRegister(const TimerListCallback& callback, uint32_t interval, bool once, int &timerFd) DoRegister() argument 168 DoUnregister(uint32_t interval) DoUnregister() argument 179 uint32_t interval; OnTimer() local 239 EraseUnusedTimerId(uint32_t interval, const std::vector<uint32_t>& unusedIds) EraseUnusedTimerId() argument [all...] |
H A D | event_reactor.cpp | 98 uint32_t EventReactor::ScheduleTimer(const TimerCallback& cb, uint32_t interval, int& timerFd, bool once) in ScheduleTimer() argument 101 std::shared_ptr<TimerEventHandler> handler = std::make_shared<TimerEventHandler>(this, interval, once); in ScheduleTimer() 105 UTILS_LOGD("ScheduleTimer %{public}d initialize failed", interval); in ScheduleTimer()
|
H A D | event_reactor.h | 69 uint32_t ScheduleTimer(const TimerCallback& cb, uint32_t interval /* ms */, int& timerFd, bool once);
|
/commonlibrary/c_utils/base/include/ |
H A D | timer.h | 98 * @param interval Indicates the interval of a timed event, in ms. 106 uint32_t Register(const TimerCallback& callback, uint32_t interval /* ms */, bool once = false); 119 virtual uint32_t DoRegister(const TimerListCallback& callback, uint32_t interval, bool once, int &timerFd); 120 virtual void DoUnregister(uint32_t interval); 123 int GetTimerFd(uint32_t interval /* ms */); 124 void EraseUnusedTimerId(uint32_t interval, const std::vector<uint32_t>& unusedIds); 129 uint32_t interval; // million second member 138 std::map<uint32_t, TimerEntryList> intervalToTimers_; // interval to TimerEntryList 145 std::map<uint32_t, uint32_t> timers_; // timer_fd to interval [all...] |
/commonlibrary/c_utils/base/test/unittest/common/ |
H A D | utils_event_test.cpp | 68 bool Initialize(uint32_t interval); 254 bool TimerFdHandler::Initialize(uint32_t interval) in Initialize() argument 266 // next time out time is now + interval in Initialize() 267 newValue.it_value.tv_sec = now.tv_sec + interval / MILLI_TO_BASE; in Initialize() 268 newValue.it_value.tv_nsec = now.tv_nsec + (interval % MILLI_TO_BASE) * MILLI_TO_NANO; in Initialize() 274 // interval in Initialize() 275 newValue.it_interval.tv_sec = interval / MILLI_TO_BASE; in Initialize() 276 newValue.it_interval.tv_nsec = (interval % MILLI_TO_BASE) * MILLI_TO_NANO; in Initialize() 280 newValue.it_value.tv_sec << ", interval:" << newValue.it_interval.tv_sec << std::endl; in Initialize() 312 static void InitAndRun(std::shared_ptr<TimerFdHandler>& handler, const uint32_t interval, in InitAndRun() argument 345 uint32_t interval = 10; HWTEST_F() local 378 uint32_t interval = 10; HWTEST_F() local 417 uint32_t interval = 10; HWTEST_F() local 451 uint32_t interval = 10; HWTEST_F() local 488 uint32_t interval = 15; HWTEST_F() local 525 uint32_t interval = 15; HWTEST_F() local 677 ScheduleTimer(const TimerEventCallback& callback, uint32_t interval, uint32_t timerId, int& timerFd, bool once) ScheduleTimer() argument 968 uint32_t interval = 1; TestTimerEvent() local 1055 uint32_t interval = 7; TimerEvent() local 1151 uint32_t interval = 10; TimerRegisterMechanism() local [all...] |
H A D | utils_timer_test.cpp | 129 uint32_t interval = 1; in TestTimerEvent() local 130 timer.Register(TimeOutCallback1, interval); in TestTimerEvent() 222 uint32_t interval = 7; in TimerEventFun() local 225 timerId = timer.Register(TimeOutCallback1, interval, true); in TimerEventFun() 330 uint32_t interval = 10; in TimerRegisterMechanism() local 331 timer.Register(TimeOutCallback1, interval, once); in TimerRegisterMechanism() 332 timer.Register(TimeOutCallback1, interval, !once); in TimerRegisterMechanism() 333 timer.Register(TimeOutCallback1, interval, once); in TimerRegisterMechanism() 334 timer.Register(TimeOutCallback1, interval, !once); in TimerRegisterMechanism()
|
/commonlibrary/c_utils/base/test/benchmarktest/event_benchmark_test/ |
H A D | event_benchmark_test.cpp | 90 bool Initialize(uint32_t interval); 355 bool TimerFdHandler::Initialize(uint32_t interval) in Initialize() argument 368 // next time out time is now + interval in Initialize() 369 newValue.it_value.tv_sec = now.tv_sec + interval / MILLI_TO_BASE; in Initialize() 370 newValue.it_value.tv_nsec = now.tv_nsec + (interval % MILLI_TO_BASE) * MILLI_TO_NANO; in Initialize() 376 // interval in Initialize() 377 newValue.it_interval.tv_sec = interval / MILLI_TO_BASE; in Initialize() 378 newValue.it_interval.tv_nsec = (interval % MILLI_TO_BASE) * MILLI_TO_NANO; in Initialize() 727 uint32_t Register(const TimerCallback& callback, uint32_t interval /* ms */, bool once = false); 734 int GetTimerFd(uint32_t interval /* m 812 ScheduleTimer(const TimerEventCallback& callback, uint32_t interval, uint32_t timerId, int& timerFd, bool once) ScheduleTimer() argument [all...] |
/commonlibrary/c_utils/base/test/fuzztest/timer_fuzzer/ |
H A D | timer_fuzzer.cpp | 40 uint32_t interval = dataProvider->ConsumeIntegralInRange<uint32_t>(0, MAX_TIME_MS); 42 uint32_t timerId = timer.Register(TimeOutCallback, interval, once); 44 FUZZ_LOGI("Register, interval = %{public}d, once = %{public}d, timerId = %{public}d", interval, once, timerId);
|