#include <bulkio_in_port.h>
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< StreamType > | StreamList |
![]() | |
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) |
![]() | |
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 () |
Protected Types | |
typedef InPortBase< PortTraits > | super |
typedef std::map< std::string, StreamType > | StreamMap |
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) |
![]() | |
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) |
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) |
Protected Attributes | |
ossie::notification< void(StreamType)> | streamAdded |
StreamMap | streams |
boost::mutex | streamsMutex |
std::multimap< std::string, StreamType > | pendingStreams |
![]() | |
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 DataTransferType bulkio::InPort< PortTraits >::dataTransfer |
typedef DataTransfer< typename Traits::DataTransferTraits > bulkio::InPort< PortTraits >::DataTransferType |
typedef Traits::NativeType bulkio::InPort< PortTraits >::NativeType |
typedef Traits::SequenceType bulkio::InPort< PortTraits >::PortSequenceType |
typedef Traits::PortType bulkio::InPort< PortTraits >::PortType |
typedef Traits::POAPortType bulkio::InPort< PortTraits >::PortVarType |
typedef Traits::PortType bulkio::InPort< PortTraits >::ProvidesPortType |
typedef std::list<StreamType> bulkio::InPort< PortTraits >::StreamList |
|
protected |
typedef InputStream<PortTraits> bulkio::InPort< PortTraits >::StreamType |
|
protected |
typedef PortTraits bulkio::InPort< PortTraits >::Traits |
typedef Traits::TransportType bulkio::InPort< PortTraits >::TransportType |
typedef std::deque< DataTransferType * > bulkio::InPort< PortTraits >::WorkQueue |
bulkio::InPort< PortTraits >::InPort | ( | std::string | port_name, |
LOGGER_PTR | logger, | ||
bulkio::sri::Compare | sriCmp = bulkio::sri::DefaultComparator , |
||
SriListener * | newStreamCB = NULL |
||
) |
bulkio::InPort< PortTraits >::InPort | ( | std::string | port_name, |
bulkio::sri::Compare | sriCmp = bulkio::sri::DefaultComparator , |
||
SriListener * | newStreamCB = NULL |
||
) |
bulkio::InPort< PortTraits >::InPort | ( | std::string | port_name, |
void * | |||
) |
|
inline |
|
protectedvirtual |
Reimplemented from bulkio::InPortBase< PortTraits >.
|
protected |
StreamList bulkio::InPort< PortTraits >::getStreams | ( | ) |
|
protectedvirtual |
Reimplemented from bulkio::InPortBase< PortTraits >.
|
protectedvirtual |
Reimplemented from bulkio::InPortBase< PortTraits >.
StreamList bulkio::InPort< PortTraits >::pollStreams | ( | float | timeout | ) |
StreamList bulkio::InPort< PortTraits >::pollStreams | ( | StreamList & | pollset, |
float | timeout | ||
) |
StreamList bulkio::InPort< PortTraits >::pollStreams | ( | size_t | samples, |
float | timeout | ||
) |
StreamList bulkio::InPort< PortTraits >::pollStreams | ( | StreamList & | pollset, |
size_t | samples, | ||
float | timeout | ||
) |
|
virtual |
|
protectedvirtual |
Reimplemented from bulkio::InPortBase< PortTraits >.
|
inline |
|
protected |
|
protected |
|
protected |
|
protected |