Public Types | Public Member Functions | List of all members
bulkio::InStringPort< PortTraits > Class Template Reference

#include <bulkio_in_port.h>

Inheritance diagram for bulkio::InStringPort< PortTraits >:
bulkio::InPortBase< PortTraits > Port_Provides_base_impl PortBase

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
 
- Public Types inherited from bulkio::InPortBase< PortTraits >
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)
 
- Public Member Functions inherited from bulkio::InPortBase< PortTraits >
virtual ~InPortBase ()
 
virtual DataTransferTypegetPacket (float timeout)
 
virtual DataTransferTypegetPacket (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
 
- Public Member Functions inherited from Port_Provides_base_impl
 Port_Provides_base_impl (std::string port_name)
 
virtual ~Port_Provides_base_impl ()
 
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 releasePort ()
 
virtual std::string getName ()
 
virtual std::string getDescription ()
 

Additional Inherited Members

- Protected Member Functions inherited from bulkio::InPortBase< PortTraits >
 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)
 
DataTransferTypefetchPacket (const std::string &streamID)
 
void packetReceived (const std::string &streamID)
 
size_t samplesAvailable (const std::string &streamID, bool firstPacket)
 
int _getElementLength (PushArgumentType data)
 
- Protected Attributes inherited from bulkio::InPortBase< PortTraits >
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
 
queueSemaphorequeueSem
 
linkStatisticsstats
 
LOGGER_PTR logger
 
redhawk::signal< std::string > packetWaiters
 
- Protected Attributes inherited from PortBase
std::string name
 
std::string description
 

Member Typedef Documentation

template<typename PortTraits >
typedef DataTransfer< typename Traits::DataTransferTraits > bulkio::InStringPort< PortTraits >::dataTransfer
template<typename PortTraits >
typedef DataTransfer< typename Traits::DataTransferTraits > bulkio::InStringPort< PortTraits >::DataTransferType
template<typename PortTraits >
typedef Traits::NativeType bulkio::InStringPort< PortTraits >::NativeType
template<typename PortTraits >
typedef char* bulkio::InStringPort< PortTraits >::PortSequenceType
template<typename PortTraits >
typedef Traits::PortType bulkio::InStringPort< PortTraits >::PortType
template<typename PortTraits >
typedef Traits::POAPortType bulkio::InStringPort< PortTraits >::PortVarType
template<typename PortTraits >
typedef Traits::PortType bulkio::InStringPort< PortTraits >::ProvidesPortType
template<typename PortTraits >
typedef PortTraits bulkio::InStringPort< PortTraits >::Traits
template<typename PortTraits >
typedef Traits::TransportType bulkio::InStringPort< PortTraits >::TransportType
template<typename PortTraits >
typedef std::deque< DataTransferType * > bulkio::InStringPort< PortTraits >::WorkQueue

Constructor & Destructor Documentation

template<typename PortTraits >
bulkio::InStringPort< PortTraits >::InStringPort ( std::string  port_name,
LOGGER_PTR  logger,
bulkio::sri::Compare  = bulkio::sri::DefaultComparator,
SriListener *  newStreamCB = NULL 
)
template<typename PortTraits >
bulkio::InStringPort< PortTraits >::InStringPort ( std::string  port_name,
bulkio::sri::Compare  = bulkio::sri::DefaultComparator,
SriListener *  newStreamCB = NULL 
)
template<typename PortTraits >
bulkio::InStringPort< PortTraits >::InStringPort ( std::string  port_name,
void *   
)

Member Function Documentation

template<typename PortTraits >
virtual void bulkio::InStringPort< PortTraits >::pushPacket ( const char *  data,
const BULKIO::PrecisionUTCTime &  T,
CORBA::Boolean  EOS,
const char *  streamID 
)
virtual
template<typename PortTraits >
virtual void bulkio::InStringPort< PortTraits >::pushPacket ( const char *  data,
CORBA::Boolean  EOS,
const char *  streamID 
)
virtual

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