Inheritance diagram for aggregator::PullStreamAligner:

Public Member Functions
template<class T >
int	registerStream (typename PullStream< T >::pull_callback_t pull_callback, typename Stream< T >::callback_t callback, int bufferSize, base::Time period, int priority=-1)

bool	pull ()

void	copyState (const PullStreamAligner &other)

	~PullStreamAligner ()

Public Member Functions inherited from aggregator::StreamAligner
	StreamAligner (base::Time timeout=base::Time::fromSeconds(1))

virtual	~StreamAligner ()

void	copyState (const StreamAligner &other)

void	setTimeout (const base::Time &t)

void	disableStream (int idx)

void	enableStream (int idx)

bool	isStreamActive (int idx) const

void	unregisterStream (int idx)

template<class T >
int	registerStream (typename Stream< T >::callback_t callback, int bufferSize, base::Time period, int priority=-1, const std::string &name=std::string())

template<class T >
void	push (int idx, const base::Time &ts, const T &data)
	Push new data into the stream. More...

template<class T >
bool	getNextSample (int idx, std::pair< base::Time, T > &sample) const

bool	step ()

void	clear ()

base::Time	getTimeOut () const

base::Time	getLatency () const

base::Time	getCurrentTime () const

base::Time	getLatestTime () const

int	getStreamSize () const

const StreamStatus &	getBufferStatus (int idx) const

const StreamAlignerStatus &	getStatus () const

Protected Types
typedef std::vector< PullStreamBase * >	pull_stream_vector

Additional Inherited Members
Public Types inherited from aggregator::StreamAligner
typedef std::vector< StreamBase * >	stream_vector

Static Public Member Functions inherited from aggregator::StreamAligner
static bool	compareStreams (const StreamBase b1, const StreamBase b2)

Public Attributes inherited from aggregator::StreamAligner
stream_vector	streams

base::Time	timeout

base::Time	latest_ts

base::Time	current_ts

double	buffer_size_factor

StreamAlignerStatus	status

Member Typedef Documentation

◆ pull_stream_vector

protected

aggregator::PullStreamAligner::~PullStreamAligner ( )

inline

void aggregator::PullStreamAligner::copyState ( const PullStreamAligner & other )

inline

bool aggregator::PullStreamAligner::pull ( )

inline

template<class T >

int aggregator::PullStreamAligner::registerStream	(	typename PullStream< T >::pull_callback_t	pull_callback,
		typename Stream< T >::callback_t	callback,
		int	bufferSize,
		base::Time	period,
		int	priority = `-1`
	)

inline

pull_stream_vector aggregator::PullStreamAligner::pull_streams

protected

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

/build/rock-master-18.09-drivers-aggregator-0.20160914/src/PullStreamAligner.hpp