Home
last modified time | relevance | path

Searched refs:timer (Results 1 - 25 of 94) sorted by relevance

1234

/foundation/communication/dsoftbus/components/nstackx/nstackx_util/platform/unix/
H A Dsys_timer.c23 void TimerDelete(Timer *timer) in TimerDelete() argument
25 if (timer == NULL) { in TimerDelete()
28 if (timer->task.taskfd != INVALID_TASK_DESC) { in TimerDelete()
29 if (DeRegisterEpollTask(&(timer->task)) != NSTACKX_EOK) { in TimerDelete()
32 if (close(timer->task.taskfd) < 0) { in TimerDelete()
33 LOGE(TAG, "close timer task failed"); in TimerDelete()
35 timer->task.taskfd = INVALID_TASK_DESC; in TimerDelete()
37 free(timer); in TimerDelete()
43 Timer *timer = NULL; in TimerReadHandle() local
50 timer in TimerReadHandle()
72 TimerGetRemainTime(Timer *timer, uint32_t *remainTimeMsPtr) TimerGetRemainTime() argument
92 TimerSetTimeout(Timer *timer, uint32_t timeoutMs, uint8_t repeated) TimerSetTimeout() argument
124 Timer *timer = calloc(1, sizeof(Timer)); TimerStart() local
[all...]
/foundation/communication/dsoftbus/components/nstackx/nstackx_util/platform/liteos/
H A Dsys_timer.c28 void TimerDelete(Timer *timer) in TimerDelete() argument
30 if (timer == NULL) { in TimerDelete()
33 if (TASKFD_TO_TIMERID(timer->task.taskfd) != NULL) { in TimerDelete()
34 if (timer_delete(TASKFD_TO_TIMERID(timer->task.taskfd)) < 0) { in TimerDelete()
35 LOGE(TAG, "close timer task failed"); in TimerDelete()
37 timer->task.taskfd = TIMERID_TO_TASKFD(NULL); in TimerDelete()
39 free(timer); in TimerDelete()
45 Timer *timer = NULL; in TimerReadHandle() local
51 timer = task->ptr; in TimerReadHandle()
52 if (timer in TimerReadHandle()
68 TimerGetRemainTime(Timer *timer, uint32_t *remainTimeMsPtr) TimerGetRemainTime() argument
88 TimerSetTimeout(Timer *timer, uint32_t timeoutMs, uint8_t repeated) TimerSetTimeout() argument
131 Timer *timer = calloc(1, sizeof(Timer)); TimerStart() local
[all...]
/foundation/distributedhardware/device_manager/test/commonunittest/
H A DUTTest_dm_timer.cpp56 std::shared_ptr<DmTimer> timer = std::make_shared<DmTimer>(); in HWTEST_F() local
57 int32_t ret = timer->StartTimer("", timeout, TimeOut); in HWTEST_F()
60 ret = timer->StartTimer(std::string(AUTHENTICATE_TIMEOUT_TASK), 400, TimeOut); in HWTEST_F()
63 ret = timer->StartTimer(std::string(AUTHENTICATE_TIMEOUT_TASK), -20, TimeOut); in HWTEST_F()
66 ret = timer->StartTimer(std::string(AUTHENTICATE_TIMEOUT_TASK), timeout, nullptr); in HWTEST_F()
82 std::shared_ptr<DmTimer> timer = std::make_shared<DmTimer>(); in HWTEST_F() local
83 int32_t ret = timer->StartTimer(name, timeOut, TimeOut); in HWTEST_F()
86 ret = timer->StartTimer(name2, timeOut2, TimeOut); in HWTEST_F()
99 std::shared_ptr<DmTimer> timer = std::make_shared<DmTimer>(); in HWTEST_F() local
100 int32_t ret = timer in HWTEST_F()
117 std::shared_ptr<DmTimer> timer = std::make_shared<DmTimer>(); HWTEST_F() local
133 std::shared_ptr<DmTimer> timer = std::make_shared<DmTimer>(); HWTEST_F() local
[all...]
/foundation/arkui/ace_engine_lite/frameworks/src/core/context/
H A Djs_timer_list.cpp27 TimerNode *timer = static_cast<TimerNode *>(ace_malloc(sizeof(TimerNode))); in AddTimer() local
28 if (timer == nullptr) { in AddTimer()
32 timer->index = index; in AddTimer()
33 timer->next = timerListHead_; in AddTimer()
34 timer->timerId = timerId; in AddTimer()
36 timer->arguments = arg; in AddTimer()
37 timerListHead_ = timer; in AddTimer()
38 timer = nullptr; in AddTimer()
54 void TimerList::DeleteTimer(uint8_t timer) in DeleteTimer() argument
61 while ((timer ! in DeleteTimer()
[all...]
/foundation/multimodalinput/input/service/timer_manager/src/
H A Dtimer_manager.cpp87 for (const auto &timer : timers_) { in TakeNextTimerId()
88 timerSlot |= (one << timer->id); in TakeNextTimerId()
108 auto timer = std::make_unique<TimerItem>(); in AddTimerInternal() local
109 timer->id = timerId; in AddTimerInternal()
110 timer->intervalMs = intervalMs; in AddTimerInternal()
111 timer->repeatCount = repeatCount; in AddTimerInternal()
112 timer->callbackCount = 0; in AddTimerInternal()
114 if (!AddInt64(nowTime, timer->intervalMs, timer->nextCallTime)) { in AddTimerInternal()
118 timer in AddTimerInternal()
140 auto timer = std::move(*it); ResetTimerInternal() local
166 InsertTimerInternal(std::unique_ptr<TimerItem>& timer) InsertTimerInternal() argument
[all...]
/foundation/communication/bluetooth_service/services/bluetooth/service/src/util/internal/
H A Dtimer_linux.cpp16 #include "timer.h"
35 bool AddTimer(Timer &timer);
36 void RemoveTimer(Timer &timer);
45 void OnCallback(Timer &timer) const;
108 void TimerManager::OnCallback(Timer &timer) const in OnCallback()
111 int ret = read(timer.fd_, &num, sizeof(uint64_t)); in OnCallback()
116 timer.callback_(); in OnCallback()
147 Timer *timer = (Timer *)events[i].data.ptr; in OnTimer() local
150 auto it = std::find(unregisteredList_.begin(), unregisteredList_.end(), timer); in OnTimer()
154 std::lock_guard<std::mutex> itemLock(timer in OnTimer()
161 AddTimer(Timer &timer) AddTimer() argument
183 RemoveTimer(Timer &timer) RemoveTimer() argument
[all...]
/foundation/graphic/graphic_utils_lite/frameworks/
H A Dgraphic_timer.cpp41 GRAPHIC_LOGE("Timer set period failed, timer should be created first."); in SetPeriod()
60 GraphicTimer* timer = reinterpret_cast<GraphicTimer*>(lpArg); in TimerCallback() local
61 if (timer != nullptr) { in TimerCallback()
62 (void)timer->Callback(); in TimerCallback()
68 GraphicTimer* timer = reinterpret_cast<GraphicTimer*>(lpParam); in WinAsyncThread() local
70 liDueTime.QuadPart = -(timer->GetPeriod() * HUNDRED_NS_PER_MS); in WinAsyncThread()
72 LONG period = (timer->IsPeriodic() ? timer->GetPeriod() : 0); in WinAsyncThread()
73 if (!SetWaitableTimer(timer->GetNativeTimer(), &liDueTime, period, TimerCallback, timer, FALS in WinAsyncThread()
140 GraphicTimer* timer = reinterpret_cast<GraphicTimer*>(args); TimerCallback() local
203 GraphicTimer* timer = reinterpret_cast<GraphicTimer*>(v.sival_ptr); TimerCallback() local
[all...]
/foundation/multimodalinput/input/intention/scheduler/timer_manager/src/
H A Dtimer_manager.cpp165 [] (uint64_t s, const auto &timer) {
166 return (s |= (uint64_t(1U) << timer->id));
191 auto timer = std::make_unique<TimerItem>();
192 timer->id = nextTimerId;
193 timer->repeatCount = repeatCount;
194 timer->intervalMs = intervalMs;
195 timer->callbackCount = 0;
197 if (!AddInt64(nowTime, timer->intervalMs, timer->nextCallTime)) {
201 timer
[all...]
/foundation/multimedia/camera_framework/services/deferred_processing_service/src/base/timer/core/
H A Dtimer_core.cpp70 bool TimerCore::RegisterTimer(uint64_t timestampMs, const std::shared_ptr<Timer>& timer) in RegisterTimer() argument
75 if (timer == nullptr) { in RegisterTimer()
87 registeredTimers_[timestampMs].push_back(timer); in RegisterTimer()
88 DP_DEBUG_LOG("register timer (%s), timestamp: %{public}d, timeline.top: %{public}d", timer->GetName().c_str(), in RegisterTimer()
93 bool TimerCore::DeregisterTimer(uint64_t timestampMs, const std::shared_ptr<Timer>& timer) in DeregisterTimer() argument
98 if (timer == nullptr) { in DeregisterTimer()
102 DP_DEBUG_LOG("(%s, %{public}d) entered.", timer->GetName().c_str(), static_cast<int>(timestampMs)); in DeregisterTimer()
107 [this, &timer](auto& weakTimer) { return IsSameOwner(timer, weakTime in DeregisterTimer()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/
H A Devloop_timer_unit_test.cpp166 * @tc.desc: Create and destroy a timer object.
174 * @tc.steps: step1. create event(timer) object. in HWTEST_F()
178 IEvent *timer = IEvent::CreateEvent(TIME_PIECE_1, errCode); in HWTEST_F() local
179 ASSERT_EQ(timer != nullptr, true); in HWTEST_F()
186 errCode = timer->SetAction([](EventsMask revents) -> int { in HWTEST_F()
192 timer->KillAndDecObjRef(timer); in HWTEST_F()
193 timer = nullptr; in HWTEST_F()
199 * @tc.desc: Start a timer
230 * @tc.steps: step2. create and start a timer in HWTEST_F()
234 IEvent *timer = IEvent::CreateEvent(TIME_PIECE_10, errCode); HWTEST_F() local
287 IEvent *timer = IEvent::CreateEvent(10, errCode); HWTEST_F() local
347 IEvent *timer = IEvent::CreateEvent(TIME_PIECE_10, errCode); HWTEST_F() local
404 IEvent *timer = IEvent::CreateEvent(TIME_PIECE_1000, errCode); HWTEST_F() local
[all...]
H A Ddistributeddb_thread_pool_test.cpp136 void SetTimer(int &timerCount, TimerId &timer, int &finalizeCount, int timeOut = ONE_HUNDRED_MILLISECONDS) in SetTimer() argument
141 if (timerCount < MAX_TIMER_COUNT) { // max timer count is 5 in SetTimer()
145 }, [&finalizeCount, timer]() { in SetTimer()
147 LOGI("Timer %" PRIu64" finalize", timer + 1); in SetTimer()
148 }, timer); in SetTimer()
152 void SetTimer(int &timerCount, TimerId &timer) in SetTimer() argument
157 if (timerCount < MAX_TIMER_COUNT) { // max timer count is 5 in SetTimer()
161 }, nullptr, timer); in SetTimer()
208 * @tc.desc: Test set timer by thread pool
220 * @tc.steps: step1. set timer an in HWTEST_F()
224 TimerId timer = 0; HWTEST_F() local
269 TimerId timer; HWTEST_F() local
300 TimerId timer = 0; HWTEST_F() local
329 TimerId timer = 0; HWTEST_F() local
[all...]
/foundation/communication/bluetooth_service/services/bluetooth/stack/src/rfcomm/
H A Drfcomm_session.c51 if (session->timer != NULL) { in RfcommDestroySessionList()
52 AlarmDelete(session->timer); in RfcommDestroySessionList()
53 session->timer = NULL; in RfcommDestroySessionList()
97 * @brief Start session's timer.
106 if (session->timer == NULL) { in RfcommStartSessionTimer()
107 LOG_ERROR("%{public}s Session's timer is NULL.", __func__); in RfcommStartSessionTimer()
111 AlarmSet(session->timer, timeout * RFCOMM_PER_SEC, RfcommSessionTimeoutCallback, session); in RfcommStartSessionTimer()
115 * @brief Stop session's timer.
123 if (session->timer == NULL) { in RfcommStopSessionTimer()
124 LOG_ERROR("%{public}s Session's timer i in RfcommStopSessionTimer()
[all...]
/foundation/arkui/ace_engine_lite/frameworks/src/core/modules/presets/
H A Dtimer_module.cpp41 HILOG_ERROR(HILOG_MODULE_ACE, "init timer failed %{public}d", initRes_); in Init()
57 HILOG_ERROR(HILOG_MODULE_ACE, "start timer failed, timer init failed %{public}d", in CreateTimer()
140 HILOG_ERROR(HILOG_MODULE_ACE, "stop timer failed, init timer failed %{public}d", in ClearTimer()
154 TimerList::TimerNode* timer = timerList->GetTimer(index); in ClearTimer() local
155 if (timer != nullptr) { in ClearTimer()
156 int result = StopTimerTask(timer->timerId); in ClearTimer()
180 HILOG_ERROR(HILOG_MODULE_ACE, "copy timer id failed\n"); in Task()
194 TimerList::TimerNode* timer in Task() local
221 TimerList::TimerNode* timer = timerList->GetTimer(*timerId); Task() local
[all...]
/foundation/multimedia/media_foundation/src/osal/utils/
H A Dutil.cpp26 HANDLE timer = CreateWaitableTimer(nullptr, TRUE, nullptr); in usleep() local
30 SetWaitableTimer(timer, &dueTime, 0, nullptr, nullptr, 0); in usleep()
31 WaitForSingleObject(timer, INFINITE); in usleep()
32 CloseHandle(timer); in usleep()
/foundation/multimedia/media_foundation/engine/foundation/osal/utils/
H A Dutil.cpp25 HANDLE timer = CreateWaitableTimer(nullptr, TRUE, nullptr); in usleep() local
29 SetWaitableTimer(timer, &dueTime, 0, nullptr, nullptr, 0); in usleep()
30 WaitForSingleObject(timer, INFINITE); in usleep()
31 CloseHandle(timer); in usleep()
/foundation/communication/dsoftbus/components/nstackx/nstackx_util/interface/
H A Dnstackx_timer.h42 NSTACKX_EXPORT int32_t TimerSetTimeout(Timer *timer, uint32_t timeoutMs, uint8_t repeated);
43 NSTACKX_EXPORT int32_t TimerGetRemainTime(Timer *timer, uint32_t *remainTimeMsPtr);
45 NSTACKX_EXPORT void TimerDelete(Timer *timer);
/foundation/arkui/ui_lite/frameworks/components/
H A Dui_video.cpp82 char timer[10] = {0}; // 10:timer length in Prepare() local
83 if (!GetTimerFromMSecond(duration_, timer, sizeof(timer))) { in Prepare()
86 totalTimeLabel_->SetText(&timer[0]); in Prepare()
621 char timer[10] = {0}; // 10:timer length in OnChange() local
622 if (!GetTimerFromMSecond(currentValue, timer, sizeof(timer))) { in OnChange()
625 currentTimeLabel_->SetText(&timer[ in OnChange()
675 GetTimerFromMSecond(int64_t currentTime, char* timer, int32_t len) GetTimerFromMSecond() argument
695 char timer[10] = {0}; // 10:timer length Callback() local
[all...]
/foundation/communication/netstack/utils/napi_utils/src/
H A Dtiming.cpp29 Timer timer; in RecieveTimer() local
30 timer.timerName_ = type; in RecieveTimer()
31 timerMap_.insert(std::pair<const char *const, Timer>(type, timer)); in RecieveTimer()
/foundation/multimodalinput/input/service/timer_manager/test/
H A Dtimer_manager_test.cpp122 * @tc.desc: Test adding a timer to the TimerManager
143 * @tc.desc: Test removing a timer from the TimerManager
161 * @tc.desc: Test resetting a timer in the TimerManager
180 * @tc.desc: Test checking if a timer exists in the TimerManager
198 * @tc.desc: Test calculating the next delayed timer in the TimerManager
212 * @tc.desc: Test obtaining the ID of the next timer in the TimerManager
226 * @tc.desc: Test adding a timer internally within the TimerManager
251 * @tc.desc: Test removing a timer internally within the TimerManager
269 * @tc.desc: Test resetting a timer internally within the TimerManager
285 * @tc.desc: Test checking if a timer exist
314 auto timer = std::make_unique<TimerManager::TimerItem>(); HWTEST_F() local
387 auto timer = std::make_unique<TimerManager::TimerItem>(); HWTEST_F() local
416 auto timer = std::make_unique<TimerManager::TimerItem>(); HWTEST_F() local
[all...]
/foundation/communication/dsoftbus/components/nstackx/nstackx_ctrl/core/
H A Dnstackx_device_local.c47 Timer *timer; member
58 Timer *timer; member
93 DFINDER_LOGD(TAG, "start offline timer again, timeout %u", nextTimeout); in LocalDeviceTimeout()
94 (void)TimerSetTimeout(g_localDevice.timer, nextTimeout, NSTACKX_FALSE); in LocalDeviceTimeout()
122 if (g_localDevice.timer != NULL) { in LocalDeviceDeinit()
123 TimerDelete(g_localDevice.timer); in LocalDeviceDeinit()
124 g_localDevice.timer = NULL; in LocalDeviceDeinit()
133 g_localDevice.timer = TimerStart(epollfd, 0, NSTACKX_FALSE, LocalDeviceTimeout, NULL); in LocalDeviceInit()
134 if (g_localDevice.timer == NULL) { in LocalDeviceInit()
135 DFINDER_LOGE(TAG, "timer ini in LocalDeviceInit()
[all...]
/foundation/multimedia/camera_framework/services/deferred_processing_service/src/base/timer/
H A Dtimer.cpp16 #include "timer.h"
28 DP_DEBUG_LOG("name: %s, timer type: %{public}d(0: once, 1: periodic), intervalMs: %u", in Create()
36 auto timer = std::make_shared<MakeSharedHelper>(name, timerType, intervalMs, std::move(callback)); in Create() local
37 if (!timer->Initialize()) { in Create()
38 timer.reset(); in Create()
40 return timer; in Create()
46 DP_DEBUG_LOG("name: %s, timer type: %{public}d(0: once, 1: periodic), intervalMs: %u", in Timer()
52 DP_DEBUG_LOG("name: %s, timer type: %{public}d(0: once, 1: periodic), intervalMs: %u", in ~Timer()
83 DP_DEBUG_LOG("stop timer (%s), timer typ in Stop()
[all...]
/foundation/graphic/graphic_utils_lite/test/
H A Dgraphic_timer_test.cpp94 GraphicTimer timer(NORMAL_PERIORD, GraphicTimerTest::TimerCb, &timer, false); in HWTEST_F()
95 EXPECT_EQ(timer.SetPeriod(OVERFLOW_PERIORD), false); in HWTEST_F()
/foundation/communication/netmanager_base/services/common/include/
H A Dffrt_timer.h38 FfrtTimer(const FfrtTimer &timer) in FfrtTimer() argument
40 stopStatus_ = timer.stopStatus_.load(); in FfrtTimer()
41 tryStopFlag_ = timer.tryStopFlag_.load(); in FfrtTimer()
/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/lowlatency/lowlatencylistener/src/
H A Dlow_latency_listener_test.cpp221 LowLatencyTimer timer(timerId, delayTimeMs); in HWTEST_F()
222 timer.ExecuteInner(); in HWTEST_F()
239 LowLatencyTimer timer(timerId, delayTimeMs); in HWTEST_F()
240 timer.HandleStopTimer(); in HWTEST_F()
/foundation/multimedia/camera_framework/services/deferred_processing_service/include/base/timer/core/
H A Dtimer_core.h29 #include "timer.h"
39 bool RegisterTimer(uint64_t timestampMs, const std::shared_ptr<Timer>& timer);
40 bool DeregisterTimer(uint64_t timestampMs, const std::shared_ptr<Timer>& timer);

Completed in 10 milliseconds

1234