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

#include <bulkio_in_port.h>

Inheritance diagram for bulkio::InPort< 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 Traits::SequenceType PortSequenceType
 
typedef Traits::TransportType TransportType
 
typedef Traits::NativeType NativeType
 
typedef DataTransfer< typename Traits::DataTransferTraits > DataTransferType
 
typedef DataTransferType dataTransfer
 
typedef std::deque< DataTransferType * > WorkQueue
 
typedef InputStream< PortTraits > StreamType
 
typedef std::list< StreamTypeStreamList
 
- 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

 InPort (std::string port_name, LOGGER_PTR logger, bulkio::sri::Compare sriCmp=bulkio::sri::DefaultComparator, SriListener *newStreamCB=NULL)
 
 InPort (std::string port_name, bulkio::sri::Compare sriCmp=bulkio::sri::DefaultComparator, SriListener *newStreamCB=NULL)
 
 InPort (std::string port_name, void *)
 
virtual void pushPacket (const PortSequenceType &data, const BULKIO::PrecisionUTCTime &T, CORBA::Boolean EOS, const char *streamID)
 
StreamList getStreams ()
 
StreamList pollStreams (float timeout)
 
StreamList pollStreams (StreamList &pollset, float timeout)
 
StreamList pollStreams (size_t samples, float timeout)
 
StreamList pollStreams (StreamList &pollset, size_t samples, float timeout)
 
template<class Target , class Func >
void addStreamListener (Target target, Func func)
 
template<class Target , class Func >
void removeStreamListener (Target target, Func func)
 
- 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 ()
 

Protected Types

typedef InPortBase< PortTraits > super
 
typedef std::map< std::string, StreamTypeStreamMap
 

Protected Member Functions

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)
 
StreamList getReadyStreams (size_t samples)
 
- 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)
 
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

ossie::notification< void(StreamType)> streamAdded
 
StreamMap streams
 
boost::mutex streamsMutex
 
std::multimap< std::string, StreamTypependingStreams
 
- 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 DataTransferType bulkio::InPort< PortTraits >::dataTransfer
template<typename PortTraits >
typedef DataTransfer< typename Traits::DataTransferTraits > bulkio::InPort< PortTraits >::DataTransferType
template<typename PortTraits >
typedef Traits::NativeType bulkio::InPort< PortTraits >::NativeType
template<typename PortTraits >
typedef Traits::SequenceType bulkio::InPort< PortTraits >::PortSequenceType
template<typename PortTraits >
typedef Traits::PortType bulkio::InPort< PortTraits >::PortType
template<typename PortTraits >
typedef Traits::POAPortType bulkio::InPort< PortTraits >::PortVarType
template<typename PortTraits >
typedef Traits::PortType bulkio::InPort< PortTraits >::ProvidesPortType
template<typename PortTraits >
typedef std::list<StreamType> bulkio::InPort< PortTraits >::StreamList
template<typename PortTraits >
typedef std::map<std::string,StreamType> bulkio::InPort< PortTraits >::StreamMap
protected
template<typename PortTraits >
typedef InputStream<PortTraits> bulkio::InPort< PortTraits >::StreamType
template<typename PortTraits >
typedef InPortBase<PortTraits> bulkio::InPort< PortTraits >::super
protected
template<typename PortTraits >
typedef PortTraits bulkio::InPort< PortTraits >::Traits
template<typename PortTraits >
typedef Traits::TransportType bulkio::InPort< PortTraits >::TransportType
template<typename PortTraits >
typedef std::deque< DataTransferType * > bulkio::InPort< PortTraits >::WorkQueue

Constructor & Destructor Documentation

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

Member Function Documentation

template<typename PortTraits >
template<class Target , class Func >
void bulkio::InPort< PortTraits >::addStreamListener ( Target  target,
Func  func 
)
inline
template<typename PortTraits >
virtual void bulkio::InPort< PortTraits >::createStream ( const std::string &  streamID,
const BULKIO::StreamSRI &  sri 
)
protectedvirtual

Reimplemented from bulkio::InPortBase< PortTraits >.

template<typename PortTraits >
StreamList bulkio::InPort< PortTraits >::getReadyStreams ( size_t  samples)
protected
template<typename PortTraits >
StreamList bulkio::InPort< PortTraits >::getStreams ( )
template<typename PortTraits >
virtual bool bulkio::InPort< PortTraits >::isStreamActive ( const std::string &  streamID)
protectedvirtual

Reimplemented from bulkio::InPortBase< PortTraits >.

template<typename PortTraits >
virtual bool bulkio::InPort< PortTraits >::isStreamEnabled ( const std::string &  streamID)
protectedvirtual

Reimplemented from bulkio::InPortBase< PortTraits >.

template<typename PortTraits >
StreamList bulkio::InPort< PortTraits >::pollStreams ( float  timeout)
template<typename PortTraits >
StreamList bulkio::InPort< PortTraits >::pollStreams ( StreamList pollset,
float  timeout 
)
template<typename PortTraits >
StreamList bulkio::InPort< PortTraits >::pollStreams ( size_t  samples,
float  timeout 
)
template<typename PortTraits >
StreamList bulkio::InPort< PortTraits >::pollStreams ( StreamList pollset,
size_t  samples,
float  timeout 
)
template<typename PortTraits >
virtual void bulkio::InPort< PortTraits >::pushPacket ( const PortSequenceType data,
const BULKIO::PrecisionUTCTime &  T,
CORBA::Boolean  EOS,
const char *  streamID 
)
virtual
template<typename PortTraits >
virtual void bulkio::InPort< PortTraits >::removeStream ( const std::string &  streamID)
protectedvirtual

Reimplemented from bulkio::InPortBase< PortTraits >.

template<typename PortTraits >
template<class Target , class Func >
void bulkio::InPort< PortTraits >::removeStreamListener ( Target  target,
Func  func 
)
inline

Member Data Documentation

template<typename PortTraits >
std::multimap<std::string,StreamType> bulkio::InPort< PortTraits >::pendingStreams
protected
template<typename PortTraits >
ossie::notification<void (StreamType)> bulkio::InPort< PortTraits >::streamAdded
protected
template<typename PortTraits >
StreamMap bulkio::InPort< PortTraits >::streams
protected
template<typename PortTraits >
boost::mutex bulkio::InPort< PortTraits >::streamsMutex
protected

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