#include <bulkio_in_port.h>
Public Types | |
typedef PortTraits | Traits |
typedef Traits::POAPortType | PortVarType |
typedef Traits::PortType | PortType |
typedef Traits::PortType | ProvidesPortType |
typedef char * | PortSequenceType |
typedef Traits::TransportType | TransportType |
typedef Traits::NativeType | NativeType |
typedef DataTransfer< typename Traits::DataTransferTraits > | DataTransferType |
typedef DataTransfer< typename Traits::DataTransferTraits > | dataTransfer |
typedef std::deque< DataTransferType * > | WorkQueue |
![]() | |
typedef PortTraits | Traits |
typedef Traits::SequenceType | PortSequenceType |
typedef Traits::TransportType | TransportType |
typedef Traits::PushType | PushArgumentType |
typedef Traits::PortType | PortType |
typedef DataTransfer< typename Traits::DataTransferTraits > | DataTransferType |
typedef std::deque< DataTransferType * > | WorkQueue |
Public Member Functions | |
InStringPort (std::string port_name, LOGGER_PTR logger, bulkio::sri::Compare=bulkio::sri::DefaultComparator, SriListener *newStreamCB=NULL) | |
InStringPort (std::string port_name, bulkio::sri::Compare=bulkio::sri::DefaultComparator, SriListener *newStreamCB=NULL) | |
InStringPort (std::string port_name, void *) | |
virtual void | pushPacket (const char *data, const BULKIO::PrecisionUTCTime &T, CORBA::Boolean EOS, const char *streamID) |
virtual void | pushPacket (const char *data, CORBA::Boolean EOS, const char *streamID) |
![]() | |
virtual | ~InPortBase () |
virtual DataTransferType * | getPacket (float timeout) |
virtual DataTransferType * | getPacket (float timeout, const std::string &streamID) |
virtual void | pushSRI (const BULKIO::StreamSRI &H) |
virtual void | enableStats (bool enable) |
virtual BULKIO::PortUsageType | state () |
virtual BULKIO::PortStatistics * | statistics () |
virtual BULKIO::StreamSRISequence * | activeSRIs () |
virtual int | getCurrentQueueDepth () |
virtual int | getMaxQueueDepth () |
virtual void | setMaxQueueDepth (int newDepth) |
virtual void | block () |
virtual void | unblock () |
virtual void | startPort () |
virtual void | stopPort () |
virtual bool | blocked () |
template<typename T > | |
void | setNewStreamListener (T &target, void(T::*func)(BULKIO::StreamSRI &)) |
template<typename T > | |
void | setNewStreamListener (T *target, void(T::*func)(BULKIO::StreamSRI &)) |
void | setNewStreamListener (SriListener *newListener) |
void | setNewStreamListener (SriListenerCallbackFn newListener) |
void | setLogger (LOGGER_PTR logger) |
std::string | getRepid () const |
![]() | |
Port_Provides_base_impl (std::string port_name) | |
virtual | ~Port_Provides_base_impl () |
virtual std::string | getDirection () const |
![]() | |
PortBase (const std::string &name) | |
virtual | ~PortBase () |
virtual void | setDescription (const std::string &desc) |
virtual void | releasePort () |
virtual std::string | getName () |
virtual std::string | getDescription () |
Additional Inherited Members | |
![]() | |
InPortBase (std::string port_name, LOGGER_PTR logger, bulkio::sri::Compare sriCmp=bulkio::sri::DefaultComparator, SriListener *newStreamCB=NULL) | |
void | queuePacket (PushArgumentType data, const BULKIO::PrecisionUTCTime &T, CORBA::Boolean EOS, const char *streamID) |
virtual void | createStream (const std::string &streamID, const BULKIO::StreamSRI &sri) |
virtual void | removeStream (const std::string &streamID) |
virtual bool | isStreamActive (const std::string &streamID) |
virtual bool | isStreamEnabled (const std::string &streamID) |
DataTransferType * | fetchPacket (const std::string &streamID) |
void | packetReceived (const std::string &streamID) |
size_t | samplesAvailable (const std::string &streamID, bool firstPacket) |
int | _getElementLength (PushArgumentType data) |
![]() | |
WorkQueue | workQueue |
uint32_t | lastQueueSize |
bulkio::sri::Compare | sri_cmp |
boost::shared_ptr< SriListener > | newStreamCallback |
SriMap | currentHs |
MUTEX | dataBufferLock |
MUTEX | sriUpdateLock |
MUTEX | dataAvailableMutex |
CONDITION | dataAvailable |
bool | breakBlock |
bool | blocking |
queueSemaphore * | queueSem |
linkStatistics * | stats |
LOGGER_PTR | logger |
redhawk::signal< std::string > | packetWaiters |
![]() | |
std::string | name |
std::string | description |
typedef DataTransfer< typename Traits::DataTransferTraits > bulkio::InStringPort< PortTraits >::dataTransfer |
typedef DataTransfer< typename Traits::DataTransferTraits > bulkio::InStringPort< PortTraits >::DataTransferType |
typedef Traits::NativeType bulkio::InStringPort< PortTraits >::NativeType |
typedef char* bulkio::InStringPort< PortTraits >::PortSequenceType |
typedef Traits::PortType bulkio::InStringPort< PortTraits >::PortType |
typedef Traits::POAPortType bulkio::InStringPort< PortTraits >::PortVarType |
typedef Traits::PortType bulkio::InStringPort< PortTraits >::ProvidesPortType |
typedef PortTraits bulkio::InStringPort< PortTraits >::Traits |
typedef Traits::TransportType bulkio::InStringPort< PortTraits >::TransportType |
typedef std::deque< DataTransferType * > bulkio::InStringPort< PortTraits >::WorkQueue |
bulkio::InStringPort< PortTraits >::InStringPort | ( | std::string | port_name, |
LOGGER_PTR | logger, | ||
bulkio::sri::Compare | = bulkio::sri::DefaultComparator , |
||
SriListener * | newStreamCB = NULL |
||
) |
bulkio::InStringPort< PortTraits >::InStringPort | ( | std::string | port_name, |
bulkio::sri::Compare | = bulkio::sri::DefaultComparator , |
||
SriListener * | newStreamCB = NULL |
||
) |
bulkio::InStringPort< PortTraits >::InStringPort | ( | std::string | port_name, |
void * | |||
) |
|
virtual |
|
virtual |