XSignalBuffer Class Reference

#include <xscheduler.h>

Public Member Functions
void	registerTransactionList (XTransaction_ *)
	Called by Talker.
bool	synchronize ()
	be called by thread pool

Private Types
typedef atomic_pointer_queue < XTransaction_, 1000 >	Queue
typedef std::deque< std::pair < XTransaction_ *, XTime > >	SkippedQueue

Private Member Functions
XTransaction_ *	popOldest ()

Private Attributes
Queue	m_queue
SkippedQueue	m_skippedQueue
atomic< XTime >	m_oldest_timestamp

Detailed Description

Synchronize requests in talkers with main-thread

See Also

Talker, XListener

Definition at line 21 of file xscheduler.h.

Member Function Documentation

bool XSignalBuffer::synchronize

(

)

be called by thread pool

Returns

true if not busy

Definition at line 117 of file xscheduler.cpp.

---

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

• kame/xscheduler.h
• kame/xscheduler.cpp