Specialization of the BroacastTimeAlarm to expire on the necessary clock minutes that must be produced. More...

Inheritance diagram for openlcb::BroadcastTimeServerAlarm:

Public Member Functions
	BroadcastTimeServerAlarm (BroadcastTimeServer *server)
	Constructor.

	~BroadcastTimeServerAlarm ()
	Destructor.

void	subscribe (int hour, int min)
	Add a time event subscriber.

Public Member Functions inherited from openlcb::BroadcastTimeAlarm
	BroadcastTimeAlarm (Node node, BroadcastTime clock, std::function< void(BarrierNotifiable *)> callback)
	Constructor.

	~BroadcastTimeAlarm ()
	Destructor.

void	set_period (time_t period)
	Start the alarm to expire at the given period from now.

void	set (time_t time)
	Start the alarm to expire at the given fast time.

void	clear ()
	Inactivate the alarm.

Public Member Functions inherited from StateFlowBase
void	run () override
	Callback from the executor.

void	notify () override
	Wakeup call arrived.

Service *	service ()
	Return a pointer to the service I am bound to.

Public Member Functions inherited from Executable
void	test_deletion ()

Public Member Functions inherited from QMember
void	init ()
	Initiailize a QMember, in place of a public placement construction.

Private Member Functions
Action	entry () override
	Entry point of the state machine.

void	expired_callback (BarrierNotifiable *done)
	callback for when the alarm expires.

void	update_notify () override
	Called when the clock time has changed.

time_t	next_active_minute (time_t seconds, const struct tm *tm)
	Get the next active minute that we will produce a time event on.

bool	next_minute (int hour, int min)
	Advance to the next hour/min based on rate setting.

	DISALLOW_COPY_AND_ASSIGN (BroadcastTimeServerAlarm)

Private Attributes
BroadcastTimeServer *	server_
	reference to our parent

uint64_t	activeMinutes_ [24]
	active minutes to produce events on

Additional Inherited Members
Static Public Member Functions inherited from StateFlowBase
template<class T , typename... Args>
static void	invoke_subflow_and_ignore_result (FlowInterface< Buffer< T > > *target_flow, Args &&... args)
	Calls a helper flow to perform some actions.

Protected Types inherited from StateFlowBase
typedef Action(StateFlowBase::*	Callback) ()
	State Flow callback prototype.

Protected Member Functions inherited from StateFlowBase
	StateFlowBase (Service *service)
	Constructor.

	~StateFlowBase ()
	Destructor.

void	reset_flow (Callback c)
	Resets the flow to the specified state.

bool	is_state (Callback c)

bool	is_terminated ()

void	start_flow (Callback c)
	Resets the flow to the specified state and starts it.

Action	again ()
	Call the current state again via call_immediately.

Action	exit ()
	Terminate current StateFlow activity.

Action	delete_this ()
	Terminates the flow and deletes *this.

Action	set_terminated ()
	Sets the flow to terminated state.

Action	call_immediately (Callback c)
	Imediately call the next state upon return.

Action	wait ()
	Wait for an asynchronous call.

Action	wait_and_call (Callback c)
	Wait for resource to become available before proceeding to next state.

template<class T >
Action	allocate_and_call (FlowInterface< Buffer< T > > target_flow, Callback c, Pool pool=nullptr)
	Allocates a buffer from a pool and proceed to the next state when allocation is successful.

Action	allocate_and_call (Callback c, QAsync *queue)
	Allocates an entry from an asynchronous queue, and transitions to a state once the allocation is complete.

template<class T >
Buffer< T > *	full_allocation_result (FlowInterface< Buffer< T > > *target_flow)
	Takes the result of the asynchronous allocation without resetting the object.

template<class T >
T *	full_allocation_result (TypedQAsync< T > *queue)
	Takes the result of the asynchronous allocation without resetting the object.

template<class T >
void	cast_allocation_result (T **member)
	Takes the result of the asynchronous allocation without resetting the object.

template<class T >
Buffer< T > *	get_allocation_result (FlowInterface< Buffer< T > > *target_flow)
	Takes the result of the asynchronous allocation.

Action	yield_and_call (Callback c)
	Place the current flow to the back of the executor, and transition to a new state after we get the CPU again.

Action	yield ()
	Place the current flow to the back of the executor, and re-try the current state after we get the CPU again.

Action	sleep_and_call (::Timer *timer, long long timeout_nsec, Callback c)
	Suspends execution of this control flow for a specified time.

template<class T , typename... Args>
Action	invoke_subflow_and_wait (FlowInterface< Buffer< T > > *target_flow, Callback c, Args &&... args)
	Calls a helper flow to perform some actions.

Action	read_repeated (StateFlowSelectHelper helper, int fd, void buf, size_t size, Callback c, unsigned priority=Selectable::MAX_PRIO)
	Blocks until size bytes are read and then invokes the next state.

Action	read_single (StateFlowSelectHelper helper, int fd, void buf, size_t size, Callback c, unsigned priority=Selectable::MAX_PRIO)
	Attempts to read at most size_t bytes, and blocks the caller until at least one byte is read.

Action	read_nonblocking (StateFlowSelectHelper helper, int fd, void buf, size_t size, Callback c, unsigned priority=Selectable::MAX_PRIO)
	Attempts to read at most size bytes, and then invokes the next state, even if only zero bytes are available right now.

Action	read_repeated_with_timeout (StateFlowTimedSelectHelper helper, long long timeout_nsec, int fd, void buf, size_t size, Callback c, unsigned priority=Selectable::MAX_PRIO)
	Blocks until size bytes are read, or a timeout expires.

Action	internal_try_read ()
	Implementation state that gets repeatedly called upon every wakeup and tries to make progress on reading.

Action	write_repeated (StateFlowSelectHelper helper, int fd, const void buf, size_t size, Callback c, unsigned priority=Selectable::MAX_PRIO)
	Writes some data into a file descriptor, repeating the operation as necessary until all bytes are written.

Action	internal_try_write ()
	Implementation state that gets repeatedly called upon every wakeup and tries to make progress on writing.

Protected Member Functions inherited from QMember
	QMember ()
	Constructor.

	~QMember ()
	Destructor.

Protected Member Functions inherited from Atomic
void	lock ()

void	unlock ()

Protected Attributes inherited from openlcb::BroadcastTimeAlarm
BroadcastTime *	clock_
	clock that our alarm is based off of

Protected Attributes inherited from QMember
QMember *	next
	pointer to the next member in the queue

Detailed Description

Specialization of the BroacastTimeAlarm to expire on the necessary clock minutes that must be produced.

Definition at line 651 of file BroadcastTimeServer.cxx.

Constructor & Destructor Documentation

◆ BroadcastTimeServerAlarm()

openlcb::BroadcastTimeServerAlarm::BroadcastTimeServerAlarm ( BroadcastTimeServer * server )

inline

Constructor.

Parameters

clock clock that our alarm is based off of

Definition at line 656 of file BroadcastTimeServer.cxx.

◆ ~BroadcastTimeServerAlarm()

openlcb::BroadcastTimeServerAlarm::~BroadcastTimeServerAlarm ( )

inline

Destructor.

Definition at line 667 of file BroadcastTimeServer.cxx.

Member Function Documentation

◆ entry()

Action openlcb::BroadcastTimeServerAlarm::entry ( )

inlineoverrideprivatevirtual

Entry point of the state machine.

Returns: BroadcastTimeAlarm::entry();

Reimplemented from openlcb::BroadcastTimeAlarm.

Definition at line 690 of file BroadcastTimeServer.cxx.

◆ expired_callback()

void openlcb::BroadcastTimeServerAlarm::expired_callback ( BarrierNotifiable * done )

inlineprivate

callback for when the alarm expires.

Parameters

done	used to notify we are finished

Definition at line 699 of file BroadcastTimeServer.cxx.

◆ next_active_minute()

time_t openlcb::BroadcastTimeServerAlarm::next_active_minute	(	time_t	seconds,
		const struct tm *	tm
	)

inlineprivate

Get the next active minute that we will produce a time event on.

Parameters

seconds	current time in seconds
tm	current time in struct tm format

Returns: the next time in rate seconds that we will expire

Definition at line 721 of file BroadcastTimeServer.cxx.

◆ next_minute()

bool openlcb::BroadcastTimeServerAlarm::next_minute	(	int *	hour,
		int *	min
	)

inlineprivate

Advance to the next hour/min based on rate setting.

Parameters

hour	input is current hour, output is hour for the next minute @paran min input is the current minute, output is the next minute

Returns: true of we have a date rollover, else false

Definition at line 762 of file BroadcastTimeServer.cxx.

◆ subscribe()

void openlcb::BroadcastTimeServerAlarm::subscribe	(	int	hour,
		int	min
	)

inline

Add a time event subscriber.

Parameters

hour	hour to subscribe to
min	minute to subscribe to

Definition at line 674 of file BroadcastTimeServer.cxx.

◆ update_notify()

void openlcb::BroadcastTimeServerAlarm::update_notify ( )

inlineoverrideprivatevirtual

Called when the clock time has changed.

Reimplemented from openlcb::BroadcastTimeAlarm.

Definition at line 707 of file BroadcastTimeServer.cxx.

Member Data Documentation

◆ activeMinutes_

uint64_t openlcb::BroadcastTimeServerAlarm::activeMinutes_[24]

private

active minutes to produce events on

Definition at line 793 of file BroadcastTimeServer.cxx.

◆ server_

BroadcastTimeServer* openlcb::BroadcastTimeServerAlarm::server_

private

reference to our parent

Definition at line 792 of file BroadcastTimeServer.cxx.

The documentation for this class was generated from the following file:

BroadcastTimeServer.cxx

Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ BroadcastTimeServerAlarm()

◆ ~BroadcastTimeServerAlarm()

Member Function Documentation

◆ entry()

◆ expired_callback()

◆ next_active_minute()

◆ next_minute()

◆ subscribe()

◆ update_notify()

Member Data Documentation

◆ activeMinutes_

◆ server_