rsb::transport::inprocess::InPullConnector Class Reference

#include <InPullConnector.h>

Inheritance diagram for rsb::transport::inprocess::InPullConnector:

Collaboration diagram for rsb::transport::inprocess::InPullConnector:

Public Member Functions
	InPullConnector ()
virtual	~InPullConnector ()
void	setQualityOfServiceSpecs (const QualityOfServiceSpec &specs)
	Requests new QoS settings for publishing events.
void	handle (EventPtr event)
	Handle event.
EventPtr	raiseEvent (bool block)
Public Member Functions inherited from rsb::transport::inprocess::InConnector
virtual	~InConnector ()
void	printContents (std::ostream &stream) const
virtual void	activate ()
	Activates the connector.
virtual void	deactivate ()
virtual Scope	getScope () const
virtual void	setScope (const Scope &scope)
	Sets the scope this connector will send/receive events to/from.
Public Member Functions inherited from rsb::eventprocessing::Handler
virtual	~Handler ()

Static Public Member Functions
static rsb::transport::InPullConnector *	create (const rsc::runtime::Properties &args)

Private Attributes
rsc::logging::LoggerPtr	logger
rsc::threading::SynchronizedQueue < EventPtr >	queue

Additional Inherited Members
Public Types inherited from rsb::transport::InPullConnector
typedef boost::shared_ptr < InPullConnector >	Ptr
Public Types inherited from rsb::transport::InConnector
typedef boost::shared_ptr < InConnector >	Ptr
Protected Member Functions inherited from rsb::transport::inprocess::InConnector
	InConnector ()

Detailed Description

Author

jmoringe

Definition at line 48 of file InPullConnector.h.

Constructor & Destructor Documentation

rsb::transport::inprocess::InPullConnector::InPullConnector

(

)

Definition at line 42 of file InPullConnector.cpp.

rsb::transport::inprocess::InPullConnector::~InPullConnector ( )

virtual

Reimplemented from rsb::transport::InPullConnector.

Definition at line 50 of file InPullConnector.cpp.

Member Function Documentation

static rsb::transport::InPullConnector* rsb::transport::inprocess::InPullConnector::create ( const rsc::runtime::Properties &  args )

static

void rsb::transport::inprocess::InPullConnector::handle ( EventPtr  event )

virtual

Handle event.

Parameters

event

The event that should be handled.

TODO(jmoringe, 2011-11-07): This ensures not overwriting earlier receive timestamp added by different connector. However, thread-safety issue remains.

Implements rsb::eventprocessing::Handler.

Definition at line 56 of file InPullConnector.cpp.

References queue.

EventPtr rsb::transport::inprocess::InPullConnector::raiseEvent ( bool  block )

virtual

Implements rsb::transport::InPullConnector.

Definition at line 68 of file InPullConnector.cpp.

References queue.

void rsb::transport::inprocess::InPullConnector::setQualityOfServiceSpecs ( const QualityOfServiceSpec &  specs )

virtual

Requests new QoS settings for publishing events.

Does not influence the receiving part.

Parameters

specs

QoS specification

Exceptions

UnsupportedQualityOfServiceException

requirements cannot be met

Implements rsb::transport::Connector.

Definition at line 53 of file InPullConnector.cpp.

Member Data Documentation

rsc::logging::LoggerPtr rsb::transport::inprocess::InPullConnector::logger

private

Definition at line 63 of file InPullConnector.h.

rsc::threading::SynchronizedQueue<EventPtr> rsb::transport::inprocess::InPullConnector::queue

private

Definition at line 65 of file InPullConnector.h.

Referenced by handle(), and raiseEvent().

---

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

• rsb/transport/inprocess/InPullConnector.h
• rsb/transport/inprocess/InPullConnector.cpp