|
| 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) |
|
| 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) |
|
| 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 |
|
| 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 () |
|
|
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< NativeType > | NativeSequenceType |
|
typedef Traits::DataBufferType | DataBufferType |
|
typedef bulkio::Connections< PortVarType >::List | ConnectionsList |
|
typedef std::map< std::string, SriMapStruct > | OutPortSriMap |
|
typedef OutputStream< CharPortTraits > | StreamType |
|
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, SriMapStruct > | OutPortSriMap |
|
typedef std::map< std::string, linkStatistics > | _StatsMap |
|
void | _pushOversizedPacket (const TransportType *buffer, size_t size, const BULKIO::PrecisionUTCTime &T, bool EOS, const std::string &streamID) |
|
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) |
|
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 |
|