29#ifndef ETL_MESSAGE_TIMER_LOCKED_INCLUDED
30#define ETL_MESSAGE_TIMER_LOCKED_INCLUDED
34#include "message_types.h"
36#include "message_router.h"
37#include "message_bus.h"
38#include "static_assert.h"
72 bool is_space = (number_of_registered_timers < MAX_TIMERS);
84 if (
timer.
id == etl::timer::id::NO_TIMER)
88 ++number_of_registered_timers;
106 if (
id_ != etl::timer::id::NO_TIMER)
110 if (
timer.
id != etl::timer::id::NO_TIMER)
112 if (
timer.is_active())
115 active_list.remove(
timer.
id,
true);
121 --number_of_registered_timers;
155 for (
int i = 0;
i < MAX_TIMERS; ++
i)
160 number_of_registered_timers = 0
U;
180 while (
has_active && (count >= active_list.front().delta))
182 timer_data&
timer = active_list.front();
184 count -=
timer.delta;
186 active_list.remove(
timer.
id,
true);
188 if (
timer.p_router != ETL_NULLPTR)
190 timer.p_router->receive(
timer.destination_router_id, *(
timer.p_message));
195 timer.delta = timer.period;
196 active_list.insert(timer.id);
199 has_active = !active_list.empty();
205 active_list.front().delta -= count;
226 if (
id_ != etl::timer::id::NO_TIMER)
231 if (
timer.
id != etl::timer::id::NO_TIMER)
234 if (
timer.period != etl::timer::state::Inactive)
237 if (
timer.is_active())
239 active_list.remove(
timer.
id,
false);
262 if (
id_ != etl::timer::id::NO_TIMER)
267 if (
timer.
id != etl::timer::id::NO_TIMER)
269 if (
timer.is_active())
272 active_list.remove(
timer.
id,
false);
327 bool result = !active_list.empty();
339 uint32_t delta =
static_cast<uint32_t>(etl::timer::interval::No_Active_Interval);
342 if (!active_list.empty())
344 delta = active_list.front().delta;
359 : p_message(ETL_NULLPTR)
360 , p_router(ETL_NULLPTR)
362 , delta(etl::timer::state::Inactive)
363 , destination_router_id(etl::imessage_bus::ALL_MESSAGE_ROUTERS)
364 , id(etl::timer::id::NO_TIMER)
365 , previous(etl::timer::id::NO_TIMER)
366 , next(etl::timer::id::NO_TIMER)
381 , delta(etl::timer::state::Inactive)
384 , previous(etl::timer::id::NO_TIMER)
385 , next(etl::timer::id::NO_TIMER)
395 return delta != etl::timer::state::Inactive;
403 delta = etl::timer::state::Inactive;
430 , number_of_registered_timers(0
U)
463 return head == etl::timer::id::NO_TIMER;
471 timer_data& timer = ptimers[id_];
473 if (head == etl::timer::id::NO_TIMER)
478 timer.previous = etl::timer::id::NO_TIMER;
479 timer.next = etl::timer::id::NO_TIMER;
486 while (test_id != etl::timer::id::NO_TIMER)
488 timer_data& test = ptimers[test_id];
491 if (timer.delta <= test.delta)
499 timer.previous = test.previous;
500 test.previous = timer.id;
501 timer.next = test.id;
504 test.delta -= timer.delta;
506 if (timer.previous != etl::timer::id::NO_TIMER)
508 ptimers[timer.previous].next = timer.id;
514 timer.delta -= test.delta;
517 test_id = next(test_id);
521 if (test_id == etl::timer::id::NO_TIMER)
524 ptimers[tail].next = timer.id;
525 timer.previous = tail;
526 timer.next = etl::timer::id::NO_TIMER;
535 timer_data& timer = ptimers[id_];
543 ptimers[timer.previous].next = timer.next;
548 tail = timer.previous;
552 ptimers[timer.next].previous = timer.previous;
558 if (timer.next != etl::timer::id::NO_TIMER)
560 ptimers[timer.next].delta += timer.delta;
564 timer.previous = etl::timer::id::NO_TIMER;
565 timer.next = etl::timer::id::NO_TIMER;
566 timer.delta = etl::timer::state::Inactive;
572 return ptimers[head];
576 const timer_data& front()
const
578 return ptimers[head];
591 current = ptimers[last].previous;
598 current = ptimers[last].next;
607 while (
id != etl::timer::id::NO_TIMER)
609 timer_data& timer = ptimers[id];
611 timer.next = etl::timer::id::NO_TIMER;
614 head = etl::timer::id::NO_TIMER;
615 tail = etl::timer::id::NO_TIMER;
616 current = etl::timer::id::NO_TIMER;
625 timer_data*
const ptimers;
629 timer_data*
const timer_array;
632 timer_list active_list;
635 uint_least8_t number_of_registered_timers;
637 try_lock_type try_lock;
643 const uint_least8_t MAX_TIMERS;
649 template <u
int_least8_t MAX_TIMERS_>
654 ETL_STATIC_ASSERT(
MAX_TIMERS_ <= 254,
"No more than 254 timers are allowed");
Declaration.
Definition delegate_cpp03.h:191
This is the base of all message routers.
Definition message_router_generator.h:121
Interface for message timer.
Definition message_timer_locked.h:51
bool has_active_timer() const
Check if there is an active timer.
Definition message_timer_locked.h:324
bool is_running() const
Get the enable/disable state.
Definition message_timer_locked.h:141
uint32_t time_to_next() const
Definition message_timer_locked.h:337
~imessage_timer_locked()
Destructor.
Definition message_timer_locked.h:438
bool set_period(etl::timer::id::type id_, uint32_t period_)
Sets a timer's period.
Definition message_timer_locked.h:286
void enable(bool state_)
Enable/disable the timer.
Definition message_timer_locked.h:133
void clear()
Clears the timer of data.
Definition message_timer_locked.h:149
bool start(etl::timer::id::type id_, bool immediate_=false)
Starts a timer.
Definition message_timer_locked.h:221
imessage_timer_locked(timer_data *const timer_array_, const uint_least8_t MAX_TIMERS_)
Constructor.
Definition message_timer_locked.h:426
void set_locks(try_lock_type try_lock_, lock_type lock_, unlock_type unlock_)
Sets the lock and unlock delegates.
Definition message_timer_locked.h:314
etl::timer::id::type register_timer(const etl::imessage &message_, etl::imessage_router &router_, uint32_t period_, bool repeating_, etl::message_router_id_t destination_router_id_=etl::imessage_router::ALL_MESSAGE_ROUTERS)
Register a timer.
Definition message_timer_locked.h:64
bool stop(etl::timer::id::type id_)
Stops a timer.
Definition message_timer_locked.h:257
bool unregister_timer(etl::timer::id::type id_)
Unregister a timer.
Definition message_timer_locked.h:102
bool set_mode(etl::timer::id::type id_, bool repeating_)
Sets a timer's mode.
Definition message_timer_locked.h:300
The message timer.
Definition message_timer_locked.h:651
message_timer_locked()
Constructor.
Definition message_timer_locked.h:664
message_timer_locked(try_lock_type try_lock_, lock_type lock_, unlock_type unlock_)
Constructor.
Definition message_timer_locked.h:672
ETL_CONSTEXPR14 TIterator remove(TIterator first, TIterator last, const T &value)
Definition algorithm.h:2192
bitset_ext
Definition absolute.h:38
ETL_CONSTEXPR TContainer::iterator begin(TContainer &container)
Definition iterator.h:962
The configuration of a timer.
Definition message_timer_locked.h:356
bool is_active() const
Returns true if the timer is active.
Definition message_timer_locked.h:393
void set_inactive()
Sets the timer to the inactive state.
Definition message_timer_locked.h:401
pair holds two objects of arbitrary type
Definition utility.h:164
Common definitions for the timer framework.
Definition timer.h:55