Public Member Functions | List of all members
bulkio::OutCharPort Class Reference

#include <bulkio_out_port.h>

Inheritance diagram for bulkio::OutCharPort:
bulkio::OutPort< CharPortTraits > bulkio::OutPortBase< CharPortTraits > Port_Uses_base_impl PortBase

Public Member Functions

 OutCharPort (std::string port_name, ConnectionEventListener *connectCB=NULL, ConnectionEventListener *disconnectCB=NULL)
 
 OutCharPort (std::string port_name, LOGGER_PTR logger, ConnectionEventListener *connectCB=NULL, ConnectionEventListener *disconnectCB=NULL)
 
virtual ~OutCharPort ()
 
void pushPacket (const std::vector< Int8 > &data, const BULKIO::PrecisionUTCTime &T, bool EOS, const std::string &streamID)
 
void pushPacket (const std::vector< Char > &data, const BULKIO::PrecisionUTCTime &T, bool EOS, const std::string &streamID)
 
void pushPacket (const Int8 *buffer, size_t size, const BULKIO::PrecisionUTCTime &T, bool EOS, const std::string &streamID)
 
void pushPacket (const Char *buffer, size_t size, const BULKIO::PrecisionUTCTime &T, bool EOS, const std::string &streamID)
 
- Public Member Functions inherited from bulkio::OutPort< CharPortTraits >
 OutPort (std::string port_name, ConnectionEventListener *connectCB=NULL, ConnectionEventListener *disconnectCB=NULL)
 
 OutPort (std::string port_name, LOGGER_PTR logger, ConnectionEventListener *connectCB=NULL, ConnectionEventListener *disconnectCB=NULL)
 
virtual ~OutPort ()
 
void pushPacket (NativeSequenceType &data, const BULKIO::PrecisionUTCTime &T, bool EOS, const std::string &streamID)
 
void pushPacket (const TransportType *data, size_t size, const BULKIO::PrecisionUTCTime &T, bool EOS, const std::string &streamID)
 
void pushPacket (const DataBufferType &data, const BULKIO::PrecisionUTCTime &T, bool EOS, const std::string &streamID)
 
StreamType createStream (const std::string &streamID)
 
StreamType createStream (const BULKIO::StreamSRI &sri)
 
- Public Member Functions inherited from bulkio::OutPortBase< CharPortTraits >
 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)
 
void setNewConnectListener (T &target, void(T::*func)(const char *connectionId))
 
void setNewConnectListener (T *target, void(T::*func)(const char *connectionId))
 
void setNewConnectListener (ConnectionEventListener *newListener)
 
void setNewConnectListener (ConnectionEventCallbackFn newListener)
 
void setNewDisconnectListener (T &target, void(T::*func)(const char *connectionId))
 
void setNewDisconnectListener (T *target, void(T::*func)(const char *connectionId))
 
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()
 
OutPortSriMap currentSRIs __attribute__ ((deprecated))
 
void setLogger (LOGGER_PTR newLogger)
 
std::string getRepid () const
 
- 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 ()
 

Additional Inherited Members

- Public Types inherited from bulkio::OutPort< CharPortTraits >
typedef CharPortTraits Traits
 
typedef Traits::PortVarType PortVarType
 
typedef Traits::PortType PortType
 
typedef Traits::SequenceType PortSequenceType
 
typedef Traits::TransportType TransportType
 
typedef Traits::NativeType NativeType
 
typedef std::vector< NativeTypeNativeSequenceType
 
typedef Traits::DataBufferType DataBufferType
 
typedef bulkio::Connections< PortVarType >::List ConnectionsList
 
typedef std::map< std::string, SriMapStructOutPortSriMap
 
typedef OutputStream< CharPortTraits > StreamType
 
- Public Types inherited from bulkio::OutPortBase< CharPortTraits >
typedef CharPortTraits 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
 
- Protected Types inherited from bulkio::OutPortBase< CharPortTraits >
typedef std::map< std::string, linkStatistics_StatsMap
 
- Protected Member Functions inherited from bulkio::OutPort< CharPortTraits >
void _pushOversizedPacket (const TransportType *buffer, size_t size, const BULKIO::PrecisionUTCTime &T, bool EOS, const std::string &streamID)
 
- Protected Member Functions inherited from bulkio::OutPortBase< CharPortTraits >
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 inherited from bulkio::OutPortBase< CharPortTraits >
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
 

Constructor & Destructor Documentation

bulkio::OutCharPort::OutCharPort ( std::string  port_name,
ConnectionEventListener *  connectCB = NULL,
ConnectionEventListener *  disconnectCB = NULL 
)
bulkio::OutCharPort::OutCharPort ( std::string  port_name,
LOGGER_PTR  logger,
ConnectionEventListener *  connectCB = NULL,
ConnectionEventListener *  disconnectCB = NULL 
)
virtual bulkio::OutCharPort::~OutCharPort ( )
inlinevirtual

Member Function Documentation

void bulkio::OutCharPort::pushPacket ( const std::vector< Int8 > &  data,
const BULKIO::PrecisionUTCTime &  T,
bool  EOS,
const std::string &  streamID 
)
void bulkio::OutCharPort::pushPacket ( const std::vector< Char > &  data,
const BULKIO::PrecisionUTCTime &  T,
bool  EOS,
const std::string &  streamID 
)
void bulkio::OutCharPort::pushPacket ( const Int8 buffer,
size_t  size,
const BULKIO::PrecisionUTCTime &  T,
bool  EOS,
const std::string &  streamID 
)
void bulkio::OutCharPort::pushPacket ( const Char buffer,
size_t  size,
const BULKIO::PrecisionUTCTime &  T,
bool  EOS,
const std::string &  streamID 
)

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