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

#include <bulkio_out_port.h>

Inheritance diagram for bulkio::OutFilePort:
bulkio::OutPortBase< FilePortTraits > Port_Uses_base_impl PortBase

Public Types

typedef FilePortTraits Traits
 
typedef Traits::PortVarType PortVarType
 
typedef Traits::PortType PortType
 
typedef Traits::SequenceType PortSequenceType
 
typedef Traits::TransportType TransportType
 
typedef char * NativeSequenceType
 
typedef Traits::NativeType NativeType
 
- Public Types inherited from bulkio::OutPortBase< FilePortTraits >
typedef FilePortTraits 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

 OutFilePort (std::string pname, ConnectionEventListener *connectCB=NULL, ConnectionEventListener *disconnectCB=NULL)
 
 OutFilePort (std::string port_name, LOGGER_PTR logger, ConnectionEventListener *connectCB=NULL, ConnectionEventListener *disconnectCB=NULL)
 
virtual ~OutFilePort ()
 
void pushPacket (const char *URL, const BULKIO::PrecisionUTCTime &T, bool EOS, const std::string &streamID)
 
void pushPacket (const std::string &URL, const BULKIO::PrecisionUTCTime &T, bool EOS, const std::string &streamID)
 
void pushPacket (const char *data, bool EOS, const std::string &streamID)
 
- Public Member Functions inherited from bulkio::OutPortBase< FilePortTraits >
 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

- Protected Types inherited from bulkio::OutPortBase< FilePortTraits >
typedef std::map< std::string, linkStatistics_StatsMap
 
- Protected Member Functions inherited from bulkio::OutPortBase< FilePortTraits >
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< FilePortTraits >
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

typedef Traits::NativeType bulkio::OutFilePort::NativeType
typedef Traits::SequenceType bulkio::OutFilePort::PortSequenceType
typedef Traits::PortType bulkio::OutFilePort::PortType
typedef Traits::PortVarType bulkio::OutFilePort::PortVarType
typedef FilePortTraits bulkio::OutFilePort::Traits
typedef Traits::TransportType bulkio::OutFilePort::TransportType

Constructor & Destructor Documentation

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

Member Function Documentation

void bulkio::OutFilePort::pushPacket ( const char *  URL,
const BULKIO::PrecisionUTCTime &  T,
bool  EOS,
const std::string &  streamID 
)
void bulkio::OutFilePort::pushPacket ( const std::string &  URL,
const BULKIO::PrecisionUTCTime &  T,
bool  EOS,
const std::string &  streamID 
)
void bulkio::OutFilePort::pushPacket ( const char *  data,
bool  EOS,
const std::string &  streamID 
)

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