Unit service observer. More...

#include <B2BITS_BatsUnitService.h>

Classes
struct	Notification
	Service notifications. More...

struct	ReadingCtx
	Passed when it is possible to utilize current thread and proceed reading multicast feed from other threads in pool. More...

Public Member Functions
virtual void	onMessage (UnitService service, const PitchMsg msg, System::u32 seconds, Timestamp &ts)=0
	Called on PITCH message.

virtual void	onNotification (UnitService *service, Notification::Type type)
	Called on service notifications.

virtual void	onReset (UnitService *service, ResetReason::Type resetReason)=0
	Called on service reset.

virtual void	onUnitProcessed (ReadingCtx *ctx, Timestamp &ts)
	Called when whole sequenced unit has been processed.

Detailed Description

Unit service observer.

Provides interface to receive service level events.

Member Function Documentation

virtual void Bats::ServiceListener::onMessage	(	UnitService *	service,
		const PitchMsg *	msg,
		System::u32	seconds,
		Timestamp &	ts )

pure virtual

Called on PITCH message.

This method is called when PITCH message is received, messages are guaranteed to be properly ordered

Parameters

service	Service that generated notification
msg	Message received
seconds	Last BATS Unit timestamp, sent via Bats::TimeMsg message

virtual void Bats::ServiceListener::onNotification	(	UnitService *	service,
		Notification::Type	type )

inlinevirtual

Called on service notifications.

Parameters

service	Service that generated notification
type	Type of notification

virtual void Bats::ServiceListener::onReset	(	UnitService *	service,
		ResetReason::Type	resetReason )

pure virtual

Called on service reset.

Parameters

service	Service that generated notification
resetReason	reason why reset has been generated

virtual void Bats::ServiceListener::onUnitProcessed	(	ReadingCtx *	ctx,
		Timestamp &	ts )

inlinevirtual

Called when whole sequenced unit has been processed.

Parameters

service	Service that generated notification
ctx	If not NULL, can be used to utilize current thread and continue reading multicast feed