| /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() argument
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()
105 entry->once = once; in Register()
130 if ((*itor)->once) { in Unregister()
156 uint32_t Timer::DoRegister(const TimerListCallback& callback, uint32_t interval, bool once, int &timerFd) in DoRegister() argument
159 uint32_t ret = reactor_->ScheduleTimer(cb, interval, timerFd, once); in DoRegister()
197 if (!ptr->once) { in OnTimer()
232 if (!ptr->once) { in GetTimerFd()
[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()
|
| H A D | timer_event_handler.cpp | 32 TimerEventHandler::TimerEventHandler(EventReactor* p, uint32_t timeout /* ms */, bool once) in TimerEventHandler() argument
34 once_(once), in TimerEventHandler()
69 // interval, 0 means time out only once in Initialize()
|
| H A D | timer_event_handler.h | 33 TimerEventHandler(EventReactor* p, uint32_t timeout, bool once);
|
| 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/test/unittest/common/ |
| H A D | utils_timer_test.cpp | 157 bool StartTimer(int milliseconds, bool once);
177 bool A::StartTimer(int milliseconds, bool once) in StartTimer() argument
179 uint32_t timerId = timer_.Register(std::bind(&A::TimeOutProc, this), milliseconds, once); in StartTimer()
328 static void TimerRegisterMechanism(Utils::Timer& timer, bool once) in TimerRegisterMechanism() argument
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()
339 * @tc.desc: once timer register
347 bool once in HWTEST_F() local
364 bool once = false; HWTEST_F() local
[all...] |
| H A D | utils_event_test.cpp | 352 // 6. Check result, execute once at least in HWTEST_F()
548 TimerEventHandler(int timerFd, uint32_t timeout, bool once);
549 TimerEventHandler(uint32_t timeout /* ms */, bool once);
596 uint32_t Register(const TimerCallback& callback, uint32_t interval /* ms */, bool once = false);
611 bool once);
678 int& timerFd, bool once) in ScheduleTimer()
680 std::shared_ptr<TimerEventHandler> handler = std::make_shared<TimerEventHandler>(timerFd, interval, once); in ScheduleTimer()
701 uint32_t Timer::Register(const TimerCallback& callback, uint32_t interval /* ms */, bool once) in Register() argument
707 int timerFd = once ? IO_EVENT_INVALID_FD : GetTimerFd(interval); // Get timerFd in Register()
710 uint32_t ret = ScheduleTimer(wrappedCb, interval, timerId, timerFd, once); in Register()
677 ScheduleTimer(const TimerEventCallback& callback, uint32_t interval, uint32_t timerId, int& timerFd, bool once) ScheduleTimer() argument
806 TimerEventHandler(int timerFd, uint32_t timeout , bool once) TimerEventHandler() argument
1018 StartTimer(int milliseconds, bool once) StartTimer() argument
[all...] |
| /commonlibrary/c_utils/base/include/ |
| H A D | timer.h | 99 * @param once Indicates whether the timed event is one-shot.
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);
131 bool once; member
|
| /commonlibrary/c_utils/base/test/fuzztest/timer_fuzzer/ |
| H A D | timer_fuzzer.cpp | 41 bool once = dataProvider->ConsumeBool();
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);
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/unix/ |
| H A D | registry.rs | 31 once: Once,
41 once: Once::new(), in default()
53 self.once.call_once(|| {
|
| /commonlibrary/c_utils/base/test/benchmarktest/event_benchmark_test/ |
| H A D | event_benchmark_test.cpp | 449 // 7. Check result, execute once at least in BENCHMARK_F()
680 TimerEventHandler(int timerFd, uint32_t timeout, bool once);
681 TimerEventHandler(uint32_t timeout /* ms */, bool once);
727 uint32_t Register(const TimerCallback& callback, uint32_t interval /* ms */, bool once = false);
742 bool once);
813 uint32_t timerId, int& timerFd, bool once) in ScheduleTimer()
816 std::shared_ptr<TimerEventHandler> handler = std::make_shared<TimerEventHandler>(timerFd, interval, once); in ScheduleTimer()
839 uint32_t Timer::Register(const TimerCallback& callback, uint32_t interval /* ms */, bool once) in Register() argument
846 int timerFd = once ? IO_EVENT_INVALID_FD : GetTimerFd(interval); // Get timerFd in Register()
849 uint32_t ret = ScheduleTimer(wrappedCb, interval, timerId, timerFd, once); in Register()
812 ScheduleTimer(const TimerEventCallback& callback, uint32_t interval, uint32_t timerId, int& timerFd, bool once) ScheduleTimer() argument
947 TimerEventHandler(int timerFd, uint32_t timeout , bool once) TimerEventHandler() argument
1177 StartTimer(int milliseconds, bool once) StartTimer() argument
[all...] |
| /commonlibrary/c_utils/base/test/benchmarktest/timer_benchmark_test/ |
| H A D | timer_benchmark_test.cpp | 147 bool StartTimer(int milliseconds, bool once);
166 bool A::StartTimer(int milliseconds, bool once) in StartTimer() argument
169 uint32_t timerId = timer_.Register(std::bind(&A::TimeOutProc, this), milliseconds, once); in StartTimer()
313 * @tc.desc: once timer register
336 * @tc.desc: once timer register
|