RTT::corba::CorbaDispatcher Class Reference

#include <CorbaDispatcher.hpp>

Inheritance diagram for RTT::corba::CorbaDispatcher:
Inheritance graph
[legend]

List of all members.

Public Member Functions

bool breakLoop ()
bool breakLoop ()
void cancelChannel (base::ChannelElementBase::shared_ptr chan)
void cancelChannel (base::ChannelElementBase::shared_ptr chan)
void dispatchChannel (base::ChannelElementBase::shared_ptr chan)
void dispatchChannel (base::ChannelElementBase::shared_ptr chan)
bool initialize ()
bool initialize ()
void loop ()
void loop ()

Static Public Member Functions

static CorbaDispatcher * Instance (DataFlowInterface *iface, int scheduler=defaultScheduler, int priority=defaultPriority)
static CorbaDispatcher * Instance (DataFlowInterface *iface, int scheduler=defaultScheduler, int priority=defaultPriority)
static void Release (DataFlowInterface *iface)
static void Release (DataFlowInterface *iface)
static void ReleaseAll ()
static void ReleaseAll ()

Private Types

typedef std::map
< DataFlowInterface
*, CorbaDispatcher * > 		DispatchMap
typedef std::map
< DataFlowInterface
*, CorbaDispatcher * > 		DispatchMap
typedef internal::List
< base::ChannelElementBase::shared_ptr > 		RCList
typedef internal::List
< base::ChannelElementBase::shared_ptr > 		RCList

Private Member Functions

 CorbaDispatcher (const std::string &name, int scheduler, int priority)
 CorbaDispatcher (const std::string &name)
 CorbaDispatcher (const std::string &name, int scheduler, int priority)
 CorbaDispatcher (const std::string &name)
 ~CorbaDispatcher ()
 ~CorbaDispatcher ()

Private Attributes

bool do_exit
RCList RClist

Static Private Attributes

static RTT_CORBA_API int defaultPriority = os::LowestPriority
static RTT_CORBA_API int defaultScheduler = ORO_SCHED_RT
static RTT_CORBA_API DispatchMap DispatchI
static RTT_CORBA_API os::Mutex * mlock = 0

Detailed Description

This object sends over data flow messages from local buffers to a remote channel element.

Definition at line 53 of file install/include/rtt/transports/corba/CorbaDispatcher.hpp.

Member Typedef Documentation

typedef std::map<DataFlowInterface*,CorbaDispatcher*> RTT::corba::CorbaDispatcher::DispatchMap [private]

Definition at line 59 of file rtt/transports/corba/CorbaDispatcher.hpp.

typedef std::map<DataFlowInterface*,CorbaDispatcher*> RTT::corba::CorbaDispatcher::DispatchMap [private]

Definition at line 49 of file install/include/rtt/transports/corba/CorbaDispatcher.hpp.

typedef internal::List<base::ChannelElementBase::shared_ptr> RTT::corba::CorbaDispatcher::RCList [private]

Definition at line 62 of file rtt/transports/corba/CorbaDispatcher.hpp.

typedef internal::List<base::ChannelElementBase::shared_ptr> RTT::corba::CorbaDispatcher::RCList [private]

Definition at line 52 of file install/include/rtt/transports/corba/CorbaDispatcher.hpp.

Constructor & Destructor Documentation

RTT::corba::CorbaDispatcher::CorbaDispatcher ( const std::string &  name  )  [inline, private]

Definition at line 62 of file install/include/rtt/transports/corba/CorbaDispatcher.hpp.

RTT::corba::CorbaDispatcher::CorbaDispatcher ( const std::string &  name,
int  scheduler,
int  priority 
) [inline, private]

Definition at line 68 of file install/include/rtt/transports/corba/CorbaDispatcher.hpp.

RTT::corba::CorbaDispatcher::~CorbaDispatcher (  )  [inline, private]

Definition at line 74 of file install/include/rtt/transports/corba/CorbaDispatcher.hpp.

RTT::corba::CorbaDispatcher::CorbaDispatcher ( const std::string &  name  )  [inline, private]

Definition at line 72 of file rtt/transports/corba/CorbaDispatcher.hpp.

RTT::corba::CorbaDispatcher::CorbaDispatcher ( const std::string &  name,
int  scheduler,
int  priority 
) [inline, private]

Definition at line 78 of file rtt/transports/corba/CorbaDispatcher.hpp.

RTT::corba::CorbaDispatcher::~CorbaDispatcher (  )  [inline, private]

Definition at line 84 of file rtt/transports/corba/CorbaDispatcher.hpp.

Member Function Documentation

bool RTT::corba::CorbaDispatcher::breakLoop (  )  [inline, virtual]
See also:
base::RunnableInterface::breakLoop()

Reimplemented from RTT::Activity.

Definition at line 176 of file rtt/transports/corba/CorbaDispatcher.hpp.

bool RTT::corba::CorbaDispatcher::breakLoop (  )  [inline, virtual]
See also:
base::RunnableInterface::breakLoop()

Reimplemented from RTT::Activity.

Definition at line 166 of file install/include/rtt/transports/corba/CorbaDispatcher.hpp.

void RTT::corba::CorbaDispatcher::cancelChannel ( base::ChannelElementBase::shared_ptr  chan  )  [inline]

Definition at line 156 of file rtt/transports/corba/CorbaDispatcher.hpp.

void RTT::corba::CorbaDispatcher::cancelChannel ( base::ChannelElementBase::shared_ptr  chan  )  [inline]

Definition at line 146 of file install/include/rtt/transports/corba/CorbaDispatcher.hpp.

void RTT::corba::CorbaDispatcher::dispatchChannel ( base::ChannelElementBase::shared_ptr  chan  )  [inline]

Definition at line 151 of file rtt/transports/corba/CorbaDispatcher.hpp.

void RTT::corba::CorbaDispatcher::dispatchChannel ( base::ChannelElementBase::shared_ptr  chan  )  [inline]

Definition at line 141 of file install/include/rtt/transports/corba/CorbaDispatcher.hpp.

bool RTT::corba::CorbaDispatcher::initialize (  )  [inline, virtual]
See also:
base::RunnableInterface::initialize()

Reimplemented from RTT::Activity.

Definition at line 160 of file rtt/transports/corba/CorbaDispatcher.hpp.

bool RTT::corba::CorbaDispatcher::initialize (  )  [inline, virtual]
See also:
base::RunnableInterface::initialize()

Reimplemented from RTT::Activity.

Definition at line 150 of file install/include/rtt/transports/corba/CorbaDispatcher.hpp.

static CorbaDispatcher* RTT::corba::CorbaDispatcher::Instance ( DataFlowInterface *  iface,
int  scheduler = defaultScheduler,
int  priority = defaultPriority 
) [inline, static]

Create a new dispatcher for a given data flow interface. This method will only lock and allocate when a new dispatcher must be created, otherwise, the access is lock-free and real-time. One dispatcher per iface is created.

Parameters:
iface The interface to dispatch data flow messages for.
Returns:

Definition at line 97 of file rtt/transports/corba/CorbaDispatcher.hpp.

static CorbaDispatcher* RTT::corba::CorbaDispatcher::Instance ( DataFlowInterface *  iface,
int  scheduler = defaultScheduler,
int  priority = defaultPriority 
) [inline, static]

Create a new dispatcher for a given data flow interface. This method will only lock and allocate when a new dispatcher must be created, otherwise, the access is lock-free and real-time. One dispatcher per iface is created.

Parameters:
iface The interface to dispatch data flow messages for.
Returns:

Definition at line 87 of file install/include/rtt/transports/corba/CorbaDispatcher.hpp.

void RTT::corba::CorbaDispatcher::loop (  )  [inline, virtual]
See also:
base::RunnableInterface::loop()

Reimplemented from RTT::Activity.

Definition at line 166 of file rtt/transports/corba/CorbaDispatcher.hpp.

void RTT::corba::CorbaDispatcher::loop (  )  [inline, virtual]
See also:
base::RunnableInterface::loop()

Reimplemented from RTT::Activity.

Definition at line 156 of file install/include/rtt/transports/corba/CorbaDispatcher.hpp.

static void RTT::corba::CorbaDispatcher::Release ( DataFlowInterface *  iface  )  [inline, static]

Releases and cleans up a specific interface from dispatching.

Parameters:
iface 

Definition at line 125 of file rtt/transports/corba/CorbaDispatcher.hpp.

static void RTT::corba::CorbaDispatcher::Release ( DataFlowInterface *  iface  )  [inline, static]

Releases and cleans up a specific interface from dispatching.

Parameters:
iface 

Definition at line 115 of file install/include/rtt/transports/corba/CorbaDispatcher.hpp.

static void RTT::corba::CorbaDispatcher::ReleaseAll (  )  [inline, static]

May be called during program termination to clean up all resources.

Definition at line 140 of file rtt/transports/corba/CorbaDispatcher.hpp.

static void RTT::corba::CorbaDispatcher::ReleaseAll (  )  [inline, static]

May be called during program termination to clean up all resources.

Definition at line 130 of file install/include/rtt/transports/corba/CorbaDispatcher.hpp.

Member Data Documentation

static RTT_CORBA_API int RTT::corba::CorbaDispatcher::defaultPriority = os::LowestPriority [static, private]

Definition at line 60 of file install/include/rtt/transports/corba/CorbaDispatcher.hpp.

static RTT_CORBA_API int RTT::corba::CorbaDispatcher::defaultScheduler = ORO_SCHED_RT [static, private]

Definition at line 59 of file install/include/rtt/transports/corba/CorbaDispatcher.hpp.

static RTT_CORBA_API DispatchMap RTT::corba::CorbaDispatcher::DispatchI [static, private]

Definition at line 50 of file install/include/rtt/transports/corba/CorbaDispatcher.hpp.

bool RTT::corba::CorbaDispatcher::do_exit [private]

Definition at line 55 of file install/include/rtt/transports/corba/CorbaDispatcher.hpp.

static RTT_CORBA_API os::Mutex * RTT::corba::CorbaDispatcher::mlock = 0 [static, private]

Definition at line 57 of file install/include/rtt/transports/corba/CorbaDispatcher.hpp.

RCList RTT::corba::CorbaDispatcher::RClist [private]

Definition at line 53 of file install/include/rtt/transports/corba/CorbaDispatcher.hpp.

The documentation for this class was generated from the following files:
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Defines

rtt
Author(s): RTT Developers
autogenerated on Fri Jan 11 09:49:53 2013