|
| 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) |
|
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 () |
|
|
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) |
|