Public Types | Public Member Functions | Protected Types | Protected Member Functions | Protected Attributes | List of all members
bulkio::OutPortBase< PortTraits > Class Template Reference

#include <bulkio_out_port.h>

Inheritance diagram for bulkio::OutPortBase< PortTraits >:
Port_Uses_base_impl PortBase bulkio::OutPort< PortTraits >

Public Types

typedef PortTraits Traits
 
typedef Traits::PortVarType PortVarType
 
typedef Traits::PortType PortType
 
typedef PortType::_ptr_type PortPtrType
 
typedef Traits::SequenceType PortSequenceType
 
typedef Traits::PushType PushArgumentType
 
typedef Traits::NativeType NativeType
 
typedef bulkio::Connections< PortVarType >::List ConnectionsList
 
typedef std::map< std::string, SriMapStructOutPortSriMap
 

Public Member Functions

 OutPortBase (std::string port_name, ConnectionEventListener *connectCB=NULL, ConnectionEventListener *disconnectCB=NULL)
 
 OutPortBase (std::string port_name, LOGGER_PTR logger, ConnectionEventListener *connectCB=NULL, ConnectionEventListener *disconnectCB=NULL)
 
virtual ~OutPortBase ()
 
virtual ExtendedCF::UsesConnectionSequence * connections ()
 
virtual void connectPort (CORBA::Object_ptr connection, const char *connectionId)
 
virtual void disconnectPort (const char *connectionId)
 
void updateConnectionFilter (const std::vector< connection_descriptor_struct > &_filterTable)
 
template<typename T >
void setNewConnectListener (T &target, void(T::*func)(const char *connectionId))
 
template<typename T >
void setNewConnectListener (T *target, void(T::*func)(const char *connectionId))
 
template<typename T >
void setNewDisconnectListener (T &target, void(T::*func)(const char *connectionId))
 
template<typename T >
void setNewDisconnectListener (T *target, void(T::*func)(const char *connectionId))
 
void setNewConnectListener (ConnectionEventListener *newListener)
 
void setNewConnectListener (ConnectionEventCallbackFn newListener)
 
void setNewDisconnectListener (ConnectionEventListener *newListener)
 
void setNewDisconnectListener (ConnectionEventCallbackFn newListener)
 
virtual void pushSRI (const BULKIO::StreamSRI &H)
 
virtual BULKIO::UsesPortStatisticsSequence * statistics ()
 
virtual BULKIO::PortUsageType state ()
 
virtual void enableStats (bool enable)
 
virtual bulkio::SriMap getCurrentSRI ()
 
virtual bulkio::SriList getActiveSRIs ()
 
virtual ConnectionsList getConnections ()
 
virtual ConnectionsList __attribute__ ((deprecated)) _getConnections()
 
void setLogger (LOGGER_PTR newLogger)
 
std::string getRepid () const
 
OutPortSriMap currentSRIs __attribute__ ((deprecated))
 
- Public Member Functions inherited from Port_Uses_base_impl
 Port_Uses_base_impl (std::string port_name)
 
virtual ~Port_Uses_base_impl ()
 
virtual void setActiveStatus (bool active_flag)
 
virtual bool isActive ()
 
virtual std::string getDirection () const
 
- Public Member Functions inherited from PortBase
 PortBase (const std::string &name)
 
virtual ~PortBase ()
 
virtual void setDescription (const std::string &desc)
 
virtual void startPort ()
 
virtual void stopPort ()
 
virtual void releasePort ()
 
virtual std::string getName ()
 
virtual std::string getDescription ()
 

Protected Types

typedef std::map< std::string, linkStatistics_StatsMap
 

Protected Member Functions

void _pushSRI (typename ConnectionsList::iterator connPair, SriMapStruct &sri_ctx)
 
void _pushSRI (const std::string &connectionId, SriMapStruct &sri_ctx)
 
bool _isStreamRoutedToConnection (const std::string &connectionID, const std::string &streamID)
 
void _pushSinglePacket (PushArgumentType data, const BULKIO::PrecisionUTCTime &T, bool EOS, const std::string &streamID)
 
void _pushPacketLocked (PushArgumentType data, const BULKIO::PrecisionUTCTime &T, bool EOS, const std::string &streamID)
 
void _sendEOS (PortPtrType port, const std::string &streamID)
 
void _pushPacketToPort (PortPtrType port, PushArgumentType data, const BULKIO::PrecisionUTCTime &T, bool EOS, const char *streamID)
 
size_t _dataLength (PushArgumentType data)
 

Protected Attributes

ConnectionsList outConnections
 
ExtendedCF::UsesConnectionSequence recConnections
 
bool recConnectionsRefresh
 
_StatsMap stats
 
LOGGER_PTR logger
 
std::vector< connection_descriptor_structfilterTable
 
boost::shared_ptr< ConnectionEventListener > _connectCB
 
boost::shared_ptr< ConnectionEventListener > _disconnectCB
 
- Protected Attributes inherited from Port_Uses_base_impl
bool active
 
boost::mutex updatingPortsLock
 
bool refreshSRI
 
- Protected Attributes inherited from PortBase
std::string name
 
std::string description
 

Member Typedef Documentation

template<typename PortTraits>
typedef std::map<std::string, linkStatistics > bulkio::OutPortBase< PortTraits >::_StatsMap
protected
template<typename PortTraits>
typedef bulkio::Connections< PortVarType >::List bulkio::OutPortBase< PortTraits >::ConnectionsList
template<typename PortTraits>
typedef Traits::NativeType bulkio::OutPortBase< PortTraits >::NativeType
template<typename PortTraits>
typedef std::map< std::string, SriMapStruct > bulkio::OutPortBase< PortTraits >::OutPortSriMap
template<typename PortTraits>
typedef PortType::_ptr_type bulkio::OutPortBase< PortTraits >::PortPtrType
template<typename PortTraits>
typedef Traits::SequenceType bulkio::OutPortBase< PortTraits >::PortSequenceType
template<typename PortTraits>
typedef Traits::PortType bulkio::OutPortBase< PortTraits >::PortType
template<typename PortTraits>
typedef Traits::PortVarType bulkio::OutPortBase< PortTraits >::PortVarType
template<typename PortTraits>
typedef Traits::PushType bulkio::OutPortBase< PortTraits >::PushArgumentType
template<typename PortTraits>
typedef PortTraits bulkio::OutPortBase< PortTraits >::Traits

Constructor & Destructor Documentation

template<typename PortTraits>
bulkio::OutPortBase< PortTraits >::OutPortBase ( std::string  port_name,
ConnectionEventListener *  connectCB = NULL,
ConnectionEventListener *  disconnectCB = NULL 
)
template<typename PortTraits>
bulkio::OutPortBase< PortTraits >::OutPortBase ( std::string  port_name,
LOGGER_PTR  logger,
ConnectionEventListener *  connectCB = NULL,
ConnectionEventListener *  disconnectCB = NULL 
)
template<typename PortTraits>
virtual bulkio::OutPortBase< PortTraits >::~OutPortBase ( )
virtual

Member Function Documentation

template<typename PortTraits>
virtual ConnectionsList bulkio::OutPortBase< PortTraits >::__attribute__ ( (deprecated)  )
inlinevirtual
template<typename PortTraits>
OutPortSriMap currentSRIs bulkio::OutPortBase< PortTraits >::__attribute__ ( (deprecated)  )
template<typename PortTraits>
size_t bulkio::OutPortBase< PortTraits >::_dataLength ( PushArgumentType  data)
protected
template<typename PortTraits>
bool bulkio::OutPortBase< PortTraits >::_isStreamRoutedToConnection ( const std::string &  connectionID,
const std::string &  streamID 
)
protected
template<typename PortTraits>
void bulkio::OutPortBase< PortTraits >::_pushPacketLocked ( PushArgumentType  data,
const BULKIO::PrecisionUTCTime &  T,
bool  EOS,
const std::string &  streamID 
)
protected
template<typename PortTraits>
void bulkio::OutPortBase< PortTraits >::_pushPacketToPort ( PortPtrType  port,
PushArgumentType  data,
const BULKIO::PrecisionUTCTime &  T,
bool  EOS,
const char *  streamID 
)
protected
template<typename PortTraits>
void bulkio::OutPortBase< PortTraits >::_pushSinglePacket ( PushArgumentType  data,
const BULKIO::PrecisionUTCTime &  T,
bool  EOS,
const std::string &  streamID 
)
protected
template<typename PortTraits>
void bulkio::OutPortBase< PortTraits >::_pushSRI ( typename ConnectionsList::iterator  connPair,
SriMapStruct sri_ctx 
)
protected
template<typename PortTraits>
void bulkio::OutPortBase< PortTraits >::_pushSRI ( const std::string &  connectionId,
SriMapStruct sri_ctx 
)
protected
template<typename PortTraits>
void bulkio::OutPortBase< PortTraits >::_sendEOS ( PortPtrType  port,
const std::string &  streamID 
)
protected
template<typename PortTraits>
virtual ExtendedCF::UsesConnectionSequence* bulkio::OutPortBase< PortTraits >::connections ( )
virtual
template<typename PortTraits>
virtual void bulkio::OutPortBase< PortTraits >::connectPort ( CORBA::Object_ptr  connection,
const char *  connectionId 
)
virtual

Reimplemented from Port_Uses_base_impl.

template<typename PortTraits>
virtual void bulkio::OutPortBase< PortTraits >::disconnectPort ( const char *  connectionId)
virtual

Reimplemented from Port_Uses_base_impl.

template<typename PortTraits>
virtual void bulkio::OutPortBase< PortTraits >::enableStats ( bool  enable)
virtual
template<typename PortTraits>
virtual bulkio::SriList bulkio::OutPortBase< PortTraits >::getActiveSRIs ( )
virtual
template<typename PortTraits>
virtual ConnectionsList bulkio::OutPortBase< PortTraits >::getConnections ( )
virtual
template<typename PortTraits>
virtual bulkio::SriMap bulkio::OutPortBase< PortTraits >::getCurrentSRI ( )
virtual
template<typename PortTraits>
std::string bulkio::OutPortBase< PortTraits >::getRepid ( ) const
virtual

Reimplemented from PortBase.

template<typename PortTraits>
virtual void bulkio::OutPortBase< PortTraits >::pushSRI ( const BULKIO::StreamSRI &  H)
virtual
template<typename PortTraits>
void bulkio::OutPortBase< PortTraits >::setLogger ( LOGGER_PTR  newLogger)
template<typename PortTraits>
template<typename T >
void bulkio::OutPortBase< PortTraits >::setNewConnectListener ( T &  target,
void(T::*)(const char *connectionId)  func 
)
inline
template<typename PortTraits>
template<typename T >
void bulkio::OutPortBase< PortTraits >::setNewConnectListener ( T *  target,
void(T::*)(const char *connectionId)  func 
)
inline
template<typename PortTraits>
void bulkio::OutPortBase< PortTraits >::setNewConnectListener ( ConnectionEventListener *  newListener)
template<typename PortTraits>
void bulkio::OutPortBase< PortTraits >::setNewConnectListener ( ConnectionEventCallbackFn  newListener)
template<typename PortTraits>
template<typename T >
void bulkio::OutPortBase< PortTraits >::setNewDisconnectListener ( T &  target,
void(T::*)(const char *connectionId)  func 
)
inline
template<typename PortTraits>
template<typename T >
void bulkio::OutPortBase< PortTraits >::setNewDisconnectListener ( T *  target,
void(T::*)(const char *connectionId)  func 
)
inline
template<typename PortTraits>
void bulkio::OutPortBase< PortTraits >::setNewDisconnectListener ( ConnectionEventListener *  newListener)
template<typename PortTraits>
void bulkio::OutPortBase< PortTraits >::setNewDisconnectListener ( ConnectionEventCallbackFn  newListener)
template<typename PortTraits>
virtual BULKIO::PortUsageType bulkio::OutPortBase< PortTraits >::state ( )
virtual
template<typename PortTraits>
virtual BULKIO::UsesPortStatisticsSequence* bulkio::OutPortBase< PortTraits >::statistics ( )
virtual
template<typename PortTraits>
void bulkio::OutPortBase< PortTraits >::updateConnectionFilter ( const std::vector< connection_descriptor_struct > &  _filterTable)
inline

Member Data Documentation

template<typename PortTraits>
boost::shared_ptr< ConnectionEventListener > bulkio::OutPortBase< PortTraits >::_connectCB
protected
template<typename PortTraits>
boost::shared_ptr< ConnectionEventListener > bulkio::OutPortBase< PortTraits >::_disconnectCB
protected
template<typename PortTraits>
std::vector<connection_descriptor_struct> bulkio::OutPortBase< PortTraits >::filterTable
protected
template<typename PortTraits>
LOGGER_PTR bulkio::OutPortBase< PortTraits >::logger
protected
template<typename PortTraits>
ConnectionsList bulkio::OutPortBase< PortTraits >::outConnections
protected
template<typename PortTraits>
ExtendedCF::UsesConnectionSequence bulkio::OutPortBase< PortTraits >::recConnections
protected
template<typename PortTraits>
bool bulkio::OutPortBase< PortTraits >::recConnectionsRefresh
protected
template<typename PortTraits>
_StatsMap bulkio::OutPortBase< PortTraits >::stats
protected

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