Provides a Timing Wheel version of ACE_Timer_Queue. More...

#include <Timer_Wheel_T.h>

Inheritance diagram for ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >:

[legend]

Collaboration diagram for ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >:

[legend]

Public Types
typedef ACE_Timer_Wheel_Iterator_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >	Iterator
	Type of iterator.

typedef ACE_Timer_Node_T< TYPE >	Node

typedef ACE_Timer_Queue_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >	Base_Timer_Queue
	Type inherited from.

typedef ACE_Free_List< Node >	FreeList

Public Types inherited from ACE_Timer_Queue_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >
typedef TIME_POLICY	time_policy_t
	Type of time policy.

Public Types inherited from ACE_Abstract_Timer_Queue< TYPE >
typedef ACE_Timer_Queue_Iterator_T< TYPE >	ITERATOR
	Type of Iterator.

Public Member Functions
	ACE_Timer_Wheel_T (FUNCTOR upcall_functor=0, FreeList freelist=0, TIME_POLICY const &time_policy=TIME_POLICY())
	Default constructor.

	ACE_Timer_Wheel_T (u_int spoke_count, u_int resolution, size_t prealloc=0, FUNCTOR upcall_functor=0, FreeList freelist=0, TIME_POLICY const &time_policy=TIME_POLICY())
	Constructor with opportunities to set the wheelsize and resolution.

virtual	~ACE_Timer_Wheel_T ()
	Destructor.

virtual bool	is_empty () const
	True if queue is empty, else false.

virtual const ACE_Time_Value &	earliest_time () const

virtual int	reset_interval (long timer_id, const ACE_Time_Value &interval)

virtual int	cancel (const TYPE &type, int dont_call_handle_close=1)

virtual int	cancel (long timer_id, const void **act=0, int dont_call_handle_close=1)

virtual int	close ()

virtual int	expire ()

int	expire (const ACE_Time_Value &current_time)

virtual ACE_Timer_Queue_Iterator_T< TYPE > &	iter ()
	Returns a pointer to this <ACE_Timer_Queue_T>'s iterator.

virtual ACE_Timer_Node_T< TYPE > *	remove_first ()
	Removes the earliest node from the queue and returns it.

virtual void	dump () const
	Dump the state of an object.

virtual ACE_Timer_Node_T< TYPE > *	get_first ()
	Reads the earliest node from the queue and returns it.

Public Member Functions inherited from ACE_Timer_Queue_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >
	ACE_Timer_Queue_T (FUNCTOR upcall_functor=0, ACE_Free_List< ACE_Timer_Node_T< TYPE > > freelist=0, TIME_POLICY const &time_policy=TIME_POLICY())

virtual	~ACE_Timer_Queue_T ()

virtual long	schedule (const TYPE &type, const void *act, const ACE_Time_Value &future_time, const ACE_Time_Value &interval=ACE_Time_Value::zero)

virtual int	expire_single (ACE_Command_Base &pre_dispatch_command)

virtual int	dispatch_info (const ACE_Time_Value &current_time, ACE_Timer_Node_Dispatch_Info_T< TYPE > &info)

virtual ACE_Time_Value	gettimeofday ()

virtual void	gettimeofday (ACE_Time_Value(*gettimeofday)())

ACE_Time_Value	gettimeofday_static ()

void	set_time_policy (TIME_POLICY const &time_policy)

virtual ACE_Time_Value *	calculate_timeout (ACE_Time_Value *max)

virtual ACE_Time_Value *	calculate_timeout (ACE_Time_Value max, ACE_Time_Value the_timeout)

virtual ACE_Time_Value	current_time ()

void	timer_skew (const ACE_Time_Value &skew)
	Set the timer skew for the Timer_Queue.

const ACE_Time_Value &	timer_skew () const
	Get the timer skew for the Timer_Queue.

ACE_LOCK &	mutex ()
	Synchronization variable used by the queue.

virtual void	return_node (ACE_Timer_Node_T< TYPE > *)

void	preinvoke (ACE_Timer_Node_Dispatch_Info_T< TYPE > &info, const ACE_Time_Value &cur_time, const void *&upcall_act)
	This method will call the preinvoke() on <functor>.

void	upcall (ACE_Timer_Node_Dispatch_Info_T< TYPE > &info, const ACE_Time_Value &cur_time)
	This method will call the timeout() on <functor>.

void	postinvoke (ACE_Timer_Node_Dispatch_Info_T< TYPE > &info, const ACE_Time_Value &cur_time, const void *upcall_act)
	This method will call the postinvoke() on <functor>.

Public Member Functions inherited from ACE_Timer_Queue_Upcall_Base< TYPE, FUNCTOR >
	ACE_Timer_Queue_Upcall_Base (FUNCTOR *upcall_functor=nullptr)

virtual	~ACE_Timer_Queue_Upcall_Base ()
	Destructor.

FUNCTOR &	upcall_functor ()
	Accessor to the upcall functor.

Public Member Functions inherited from ACE_Abstract_Timer_Queue< TYPE >
virtual	~ACE_Abstract_Timer_Queue ()=0
	Destructor.

Protected Member Functions
virtual long	schedule_i (const TYPE &type, const void *act, const ACE_Time_Value &future_time, const ACE_Time_Value &interval)
	Schedules a timer.

Protected Member Functions inherited from ACE_Timer_Queue_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >
virtual ACE_Timer_Node_T< TYPE > *	alloc_node ()
	Factory method that allocates a new node.

virtual void	free_node (ACE_Timer_Node_T< TYPE > *)
	Factory method that frees a previously allocated node.

virtual int	dispatch_info_i (const ACE_Time_Value &current_time, ACE_Timer_Node_Dispatch_Info_T< TYPE > &info)
	Non-locking version of dispatch_info ()

void	recompute_next_abs_interval_time (ACE_Timer_Node_T< TYPE > *expired, const ACE_Time_Value &cur_time)
	Recompute when the next time is that this interval timer should fire.

Private Member Functions
ACE_Timer_Node_T< TYPE > *	get_first_i () const

ACE_Timer_Node_T< TYPE > *	remove_first_expired (const ACE_Time_Value &now)

void	open_i (size_t prealloc, u_int spokes, u_int res)

virtual void	reschedule (ACE_Timer_Node_T< TYPE > *)

ACE_Timer_Node_T< TYPE > *	find_spoke_node (u_int spoke, long timer_id) const
	Searches for a node by timer_id within one spoke.

ACE_Timer_Node_T< TYPE > *	find_node (long timer_id) const

u_int	calculate_spoke (const ACE_Time_Value &expire) const

long	generate_timer_id (u_int spoke)

void	schedule_i (ACE_Timer_Node_T< TYPE > *n, u_int spoke, const ACE_Time_Value &expire)
	The shared scheduling functionality between schedule() and reschedule()

void	cancel_i (ACE_Timer_Node_T< TYPE > *n)
	Shared subset of the two cancel() methods.

void	unlink (ACE_Timer_Node_T< TYPE > *n)

void	recalc_earliest (const ACE_Time_Value &last)

int	power2bits (int n, int min_bits, int max_bits)

Private Attributes
ACE_Timer_Node_T< TYPE > **	spokes_
	Timing Wheel.

u_int	spoke_count_
	Size of the timing wheel.

int	spoke_bits_
	Number of timer_id bits used for the spoke.

int	res_bits_
	Resolution (in microsoconds) of the timing wheel.

u_int	earliest_spoke_
	Index of the list with the earliest time.

Iterator *	iterator_
	Iterator used to expire timers.

ACE_Time_Value	wheel_time_
	The total amount of time in one iteration of the wheel. (resolution * spoke_count)

u_int	timer_count_
	The total number of timers currently scheduled.

Friends
class	ACE_Timer_Wheel_Iterator_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >
	Iterator is a friend.

Additional Inherited Members
Protected Attributes inherited from ACE_Timer_Queue_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >
ACE_LOCK	mutex_

ACE_Free_List< ACE_Timer_Node_T< TYPE > > *	free_list_
	Class that implements a free list.

TIME_POLICY	time_policy_
	The policy to return the current time of day.

bool const	delete_free_list_
	Flag to delete only if the class created the <free_list_>

Protected Attributes inherited from ACE_Timer_Queue_Upcall_Base< TYPE, FUNCTOR >
FUNCTOR *	upcall_functor_
	Upcall functor.

bool const	delete_upcall_functor_
	To delete or not to delete is the question?

Detailed Description

template<class TYPE, class FUNCTOR, class ACE_LOCK, typename TIME_POLICY = ACE_Default_Time_Policy>
class ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >

Provides a Timing Wheel version of ACE_Timer_Queue.

This implementation uses a hash table of ordered doubly- linked lists of absolute times. The enhancements over the ACE_Timer_List include adding a free list and the ability to preallocate nodes. Timer Wheel is based on the timing wheel implementation used in Adam M. Costello and George Varghese's paper "Redesigning the BSD Callout and Timer Facilities" (http://dworkin.wustl.edu/~varghese/PAPERS/newbsd.ps.Z)

Member Typedef Documentation

◆ Base_Timer_Queue

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY = ACE_Default_Time_Policy>

typedef ACE_Timer_Queue_T<TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY> ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::Base_Timer_Queue

Type inherited from.

◆ FreeList

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY = ACE_Default_Time_Policy>

typedef ACE_Free_List<Node> ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::FreeList

◆ Iterator

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY = ACE_Default_Time_Policy>

typedef ACE_Timer_Wheel_Iterator_T<TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY> ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::Iterator

Type of iterator.

◆ Node

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY = ACE_Default_Time_Policy>

typedef ACE_Timer_Node_T<TYPE> ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::Node

Constructor & Destructor Documentation

◆ ACE_Timer_Wheel_T() [1/2]

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY >

ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::ACE_Timer_Wheel_T	(	FUNCTOR *	upcall_functor = 0,
		FreeList *	freelist = 0,
		TIME_POLICY const &	time_policy = TIME_POLICY() )

Default constructor.

Default Constructor that sets defaults for spoke_count_ and resolution_ and doesn't do any preallocation.

Parameters

upcall_functor	A pointer to a functor to use instead of the default
freelist	A pointer to a freelist to use instead of the default

◆ ACE_Timer_Wheel_T() [2/2]

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY >

ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::ACE_Timer_Wheel_T	(	u_int	spoke_count,
		u_int	resolution,
		size_t	prealloc = 0,
		FUNCTOR *	upcall_functor = 0,
		FreeList *	freelist = 0,
		TIME_POLICY const &	time_policy = TIME_POLICY() )

Constructor with opportunities to set the wheelsize and resolution.

Constructor that sets up the timing wheel and also may preallocate some nodes on the free list

Parameters

spoke_count	The number of lists in the timer wheel
resolution	The time resolution in milliseconds used by the hashing function
prealloc	The number of entries to prealloc in the free_list
upcall_functor	A pointer to a functor to use instead of the default
freelist	A pointer to a freelist to use instead of the default

◆ ~ACE_Timer_Wheel_T()

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY >

ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::~ACE_Timer_Wheel_T ( )

virtual

Destructor.

Destructor just cleans up its memory.

Member Function Documentation

◆ calculate_spoke()

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY >

u_int ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::calculate_spoke ( const ACE_Time_Value & t ) const

private

Uses a simple hash to find which spoke to use based on when the timer is due to expire. Hopefully the 64bit int operations avoid any overflow problems.

◆ cancel() [1/2]

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY >

int ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::cancel	(	const TYPE &	type,
		int	skip_close = 1 )

virtual

Cancel all timer associated with type. If dont_call_handle_close is 0 then the <functor> will be invoked. Returns number of timers cancelled.

Goes through every list in the wheel and whenever we find one with the correct type value, we remove it and continue. At the end make sure we reset the earliest time value in case the earliest timers were removed.

Parameters

type	The value to search for.
skip_close	If this non-zero, the cancellation method of the functor will not be called for each cancelled timer.

Returns: Number of timers cancelled

Implements ACE_Abstract_Timer_Queue< TYPE >.

◆ cancel() [2/2]

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY >

int ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::cancel	(	long	timer_id,
		const void **	act = 0,
		int	skip_close = 1 )

virtual

Cancels the single timer that is specified by the timer_id. In this case the timer_id is actually a pointer to the node, so we cast it to the node. This can be dangerous if the timer_id is made up (or deleted twice) so we do a little sanity check. Finally we update the earliest time in case the earliest timer was removed.

Parameters

timer_id	Timer Identifier
act	Asychronous Completion Token (AKA magic cookie): If this is non-zero, stores the magic cookie of the cancelled timer here.
skip_close	If this non-zero, the cancellation method of the functor will not be called.

Returns: 1 for sucess and 0 if the timer_id wasn't found (or was found to be invalid)

Implements ACE_Abstract_Timer_Queue< TYPE >.

◆ cancel_i()

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY >

void ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::cancel_i ( ACE_Timer_Node_T< TYPE > * n )

private

Shared subset of the two cancel() methods.

◆ close()

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY >

int ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::close ( )

virtual

Destroy timer queue. Cancels all timers.

Implements ACE_Abstract_Timer_Queue< TYPE >.

◆ dump()

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY >

void ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::dump ( ) const

virtual

Dump the state of an object.

Dumps out the size of the wheel, the resolution, and the contents of the wheel.

Reimplemented from ACE_Timer_Queue_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >.

◆ earliest_time()

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY >

const ACE_Time_Value & ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::earliest_time ( ) const

virtual

Returns the time of the earlier node in the ACE_Timer_Wheel. Must be called on a non-empty queue.

Returns: First (earliest) node in the wheel_'s earliest_spoke_ list

Implements ACE_Abstract_Timer_Queue< TYPE >.

◆ expire() [1/2]

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY >

int ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::expire ( )

virtual

Run the <functor> for all timers whose values are <= <ACE_OS::gettimeofday>. Also accounts for <timer_skew>. Returns the number of timers canceled.

Reimplemented from ACE_Timer_Queue_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >.

◆ expire() [2/2]

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY >

int ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::expire ( const ACE_Time_Value & cur_time )

virtual

This is a specialized version of expire that is more suited for the internal data representation.

Parameters

cur_time The time to expire timers up to.

Returns: Number of timers expired

Reimplemented from ACE_Timer_Queue_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >.

◆ find_node()

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY >

ACE_Timer_Node_T< TYPE > * ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::find_node ( long timer_id ) const

private

Searches all spokes for a node matching the specified timer_id Uses the spoke encoded in the timer_id as a starting place.

◆ find_spoke_node()

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY >

ACE_Timer_Node_T< TYPE > * ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::find_spoke_node	(	u_int	spoke,
		long	timer_id ) const

private

Searches for a node by timer_id within one spoke.

◆ generate_timer_id()

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY >

long ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::generate_timer_id ( u_int spoke )

private

Generates a unique timer_id for the given spoke. It should be pretty fast until the point where the counter overflows. At that time you have to do exhaustive searches within the spoke to ensure that a particular timer id is not already in use. Some optimizations are in place so that this hopefully doesn't have to happen often.

◆ get_first()

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY >

ACE_Timer_Node_T< TYPE > * ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::get_first ( )

virtual

Reads the earliest node from the queue and returns it.

Returns the earliest node without removing it

Returns: The earliest timer node.

Implements ACE_Abstract_Timer_Queue< TYPE >.

◆ get_first_i()

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY >

ACE_Timer_Node_T< TYPE > * ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::get_first_i ( ) const

private

◆ is_empty()

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY >

bool ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::is_empty ( ) const

virtual

True if queue is empty, else false.

Check to see if the wheel is empty

Returns: True if empty

Implements ACE_Abstract_Timer_Queue< TYPE >.

◆ iter()

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY >

ACE_Timer_Queue_Iterator_T< TYPE > & ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::iter ( )

virtual

Returns a pointer to this <ACE_Timer_Queue_T>'s iterator.

Returns: The iterator

Implements ACE_Abstract_Timer_Queue< TYPE >.

◆ open_i()

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY >

void ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::open_i	(	size_t	prealloc,
		u_int	spokes,
		u_int	res )

private

Initialize the queue. Uses the established members for all needed information.

◆ power2bits()

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY >

int ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::power2bits	(	int	n,
		int	min_bits,
		int	max_bits )

private

◆ recalc_earliest()

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY >

void ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::recalc_earliest ( const ACE_Time_Value & last )

private

There are a few places where we have to figure out which timer will expire next. This method makes the assumption that spokes are always sorted, and that timers are always in the correct spoke determined from their expiration time. The last time is always passed in, even though you can often calculate it as get_first()->get_timer_value().

◆ remove_first()

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY >

ACE_Timer_Node_T< TYPE > * ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::remove_first ( )

virtual

Removes the earliest node from the queue and returns it.

Removes the earliest node and then find the new <earliest_spoke_>

Returns: The earliest timer node.

Implements ACE_Abstract_Timer_Queue< TYPE >.

◆ remove_first_expired()

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY >

ACE_Timer_Node_T< TYPE > * ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::remove_first_expired ( const ACE_Time_Value & now )

private

◆ reschedule()

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY >

void ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::reschedule ( ACE_Timer_Node_T< TYPE > * n )

privatevirtual

Takes an ACE_Timer_Node and inserts it into the correct position in the correct list. Also makes sure to update the earliest time.

Parameters

n	The timer node to reschedule

Implements ACE_Timer_Queue_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >.

◆ reset_interval()

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY >

int ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::reset_interval	(	long	timer_id,
		const ACE_Time_Value &	interval )

virtual

Changes the interval of a timer (and can make it periodic or non periodic by setting it to ACE_Time_Value::zero or not).

Find the timer node by using the id as a pointer. Then use set_interval() on the node to update the interval.

Parameters

timer_id	The timer identifier
interval	The new interval

Returns: 0 if successful, -1 if no.

Implements ACE_Abstract_Timer_Queue< TYPE >.

◆ schedule_i() [1/2]

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY >

void ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::schedule_i	(	ACE_Timer_Node_T< TYPE > *	n,
		u_int	spoke,
		const ACE_Time_Value &	expire )

private

The shared scheduling functionality between schedule() and reschedule()

◆ schedule_i() [2/2]

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY >

long ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::schedule_i	(	const TYPE &	type,
		const void *	act,
		const ACE_Time_Value &	future_time,
		const ACE_Time_Value &	interval )

protectedvirtual

Schedules a timer.

Creates a ACE_Timer_Node_T based on the input parameters. Then inserts the node into the wheel using reschedule (). Then returns a timer_id.

Parameters

type	The data of the timer node
act	Asynchronous Completion Token (AKA magic cookie)
future_time	The time the timer is scheduled for (absolute time)
interval	If not ACE_Time_Value::zero, then this is a periodic timer and interval is the time period

Returns: Unique identifier (can be used to cancel the timer). -1 on failure.

Implements ACE_Timer_Queue_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >.

◆ unlink()

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY >

void ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::unlink ( ACE_Timer_Node_T< TYPE > * n )

private

Friends And Related Symbol Documentation

◆ ACE_Timer_Wheel_Iterator_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY = ACE_Default_Time_Policy>

friend class ACE_Timer_Wheel_Iterator_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >

friend

Iterator is a friend.

Member Data Documentation

◆ earliest_spoke_

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY = ACE_Default_Time_Policy>

u_int ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::earliest_spoke_

private

Index of the list with the earliest time.

◆ iterator_

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY = ACE_Default_Time_Policy>

Iterator* ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::iterator_

private

Iterator used to expire timers.

◆ res_bits_

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY = ACE_Default_Time_Policy>

int ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::res_bits_

private

Resolution (in microsoconds) of the timing wheel.

◆ spoke_bits_

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY = ACE_Default_Time_Policy>

int ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::spoke_bits_

private

Number of timer_id bits used for the spoke.

◆ spoke_count_

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY = ACE_Default_Time_Policy>

u_int ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::spoke_count_

private

Size of the timing wheel.

◆ spokes_

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY = ACE_Default_Time_Policy>

ACE_Timer_Node_T<TYPE>** ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::spokes_

private

Timing Wheel.

◆ timer_count_

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY = ACE_Default_Time_Policy>

u_int ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::timer_count_

private

The total number of timers currently scheduled.

◆ wheel_time_

template<class TYPE , class FUNCTOR , class ACE_LOCK , typename TIME_POLICY = ACE_Default_Time_Policy>

ACE_Time_Value ACE_Timer_Wheel_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >::wheel_time_

private

The total amount of time in one iteration of the wheel. (resolution * spoke_count)

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

Public Types

Public Member Functions

Protected Member Functions

Private Member Functions

Private Attributes

Friends

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ Base_Timer_Queue

◆ FreeList

◆ Iterator

◆ Node

Constructor & Destructor Documentation

◆ ACE_Timer_Wheel_T() [1/2]

◆ ACE_Timer_Wheel_T() [2/2]

◆ ~ACE_Timer_Wheel_T()

Member Function Documentation

◆ calculate_spoke()

◆ cancel() [1/2]

◆ cancel() [2/2]

◆ cancel_i()

◆ close()

◆ dump()

◆ earliest_time()

◆ expire() [1/2]

◆ expire() [2/2]

◆ find_node()

◆ find_spoke_node()

◆ generate_timer_id()

◆ get_first()

◆ get_first_i()

◆ is_empty()

◆ iter()

◆ open_i()

◆ power2bits()

◆ recalc_earliest()

◆ remove_first()

◆ remove_first_expired()

◆ reschedule()

◆ reset_interval()

◆ schedule_i() [1/2]

◆ schedule_i() [2/2]

◆ unlink()

Friends And Related Symbol Documentation

◆ ACE_Timer_Wheel_Iterator_T< TYPE, FUNCTOR, ACE_LOCK, TIME_POLICY >

Member Data Documentation

◆ earliest_spoke_

◆ iterator_

◆ res_bits_

◆ spoke_bits_

◆ spoke_count_

◆ spokes_

◆ timer_count_

◆ wheel_time_