#include <bulkio_out_port.h>
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, SriMapStruct > | OutPortSriMap |
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)) |
![]() | |
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 |
![]() | |
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_struct > | filterTable |
boost::shared_ptr< ConnectionEventListener > | _connectCB |
boost::shared_ptr< ConnectionEventListener > | _disconnectCB |
![]() | |
bool | active |
boost::mutex | updatingPortsLock |
bool | refreshSRI |
![]() | |
std::string | name |
std::string | description |
|
protected |
typedef bulkio::Connections< PortVarType >::List bulkio::OutPortBase< PortTraits >::ConnectionsList |
typedef Traits::NativeType bulkio::OutPortBase< PortTraits >::NativeType |
typedef std::map< std::string, SriMapStruct > bulkio::OutPortBase< PortTraits >::OutPortSriMap |
typedef PortType::_ptr_type bulkio::OutPortBase< PortTraits >::PortPtrType |
typedef Traits::SequenceType bulkio::OutPortBase< PortTraits >::PortSequenceType |
typedef Traits::PortType bulkio::OutPortBase< PortTraits >::PortType |
typedef Traits::PortVarType bulkio::OutPortBase< PortTraits >::PortVarType |
typedef Traits::PushType bulkio::OutPortBase< PortTraits >::PushArgumentType |
typedef PortTraits bulkio::OutPortBase< PortTraits >::Traits |
bulkio::OutPortBase< PortTraits >::OutPortBase | ( | std::string | port_name, |
ConnectionEventListener * | connectCB = NULL , |
||
ConnectionEventListener * | disconnectCB = NULL |
||
) |
bulkio::OutPortBase< PortTraits >::OutPortBase | ( | std::string | port_name, |
LOGGER_PTR | logger, | ||
ConnectionEventListener * | connectCB = NULL , |
||
ConnectionEventListener * | disconnectCB = NULL |
||
) |
|
virtual |
|
inlinevirtual |
OutPortSriMap currentSRIs bulkio::OutPortBase< PortTraits >::__attribute__ | ( | (deprecated) | ) |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
virtual |
|
virtual |
Reimplemented from Port_Uses_base_impl.
|
virtual |
Reimplemented from Port_Uses_base_impl.
|
virtual |
|
virtual |
|
virtual |
|
virtual |
|
virtual |
Reimplemented from PortBase.
|
virtual |
void bulkio::OutPortBase< PortTraits >::setLogger | ( | LOGGER_PTR | newLogger | ) |
|
inline |
|
inline |
void bulkio::OutPortBase< PortTraits >::setNewConnectListener | ( | ConnectionEventListener * | newListener | ) |
void bulkio::OutPortBase< PortTraits >::setNewConnectListener | ( | ConnectionEventCallbackFn | newListener | ) |
|
inline |
|
inline |
void bulkio::OutPortBase< PortTraits >::setNewDisconnectListener | ( | ConnectionEventListener * | newListener | ) |
void bulkio::OutPortBase< PortTraits >::setNewDisconnectListener | ( | ConnectionEventCallbackFn | newListener | ) |
|
virtual |
|
virtual |
|
inline |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |
|
protected |