_getElementLength(PushArgumentType data) | bulkio::InPortBase< PortTraits > | protected |
activeSRIs() | bulkio::InPortBase< PortTraits > | virtual |
block() | bulkio::InPortBase< PortTraits > | virtual |
blocked() | bulkio::InPortBase< PortTraits > | virtual |
blocking | bulkio::InPortBase< PortTraits > | protected |
breakBlock | bulkio::InPortBase< PortTraits > | protected |
createStream(const std::string &streamID, const BULKIO::StreamSRI &sri) | bulkio::InPortBase< PortTraits > | protectedvirtual |
currentHs | bulkio::InPortBase< PortTraits > | protected |
dataAvailable | bulkio::InPortBase< PortTraits > | protected |
dataAvailableMutex | bulkio::InPortBase< PortTraits > | protected |
dataBufferLock | bulkio::InPortBase< PortTraits > | protected |
DataTransferType typedef | bulkio::InPortBase< PortTraits > | |
description | PortBase | protected |
enableStats(bool enable) | bulkio::InPortBase< PortTraits > | virtual |
fetchPacket(const std::string &streamID) | bulkio::InPortBase< PortTraits > | protected |
getCurrentQueueDepth() | bulkio::InPortBase< PortTraits > | virtual |
getDescription() | PortBase | inlinevirtual |
getDirection() const | Port_Provides_base_impl | inlinevirtual |
getMaxQueueDepth() | bulkio::InPortBase< PortTraits > | virtual |
getName() | PortBase | inlinevirtual |
getPacket(float timeout) | bulkio::InPortBase< PortTraits > | virtual |
getPacket(float timeout, const std::string &streamID) | bulkio::InPortBase< PortTraits > | virtual |
getRepid() const | bulkio::InPortBase< PortTraits > | virtual |
InPortBase(std::string port_name, LOGGER_PTR logger, bulkio::sri::Compare sriCmp=bulkio::sri::DefaultComparator, SriListener *newStreamCB=NULL) | bulkio::InPortBase< PortTraits > | protected |
InputStream< PortTraits > class | bulkio::InPortBase< PortTraits > | friend |
isStreamActive(const std::string &streamID) | bulkio::InPortBase< PortTraits > | protectedvirtual |
isStreamEnabled(const std::string &streamID) | bulkio::InPortBase< PortTraits > | protectedvirtual |
lastQueueSize | bulkio::InPortBase< PortTraits > | protected |
logger | bulkio::InPortBase< PortTraits > | protected |
name | PortBase | protected |
newStreamCallback | bulkio::InPortBase< PortTraits > | protected |
packetReceived(const std::string &streamID) | bulkio::InPortBase< PortTraits > | protected |
packetWaiters | bulkio::InPortBase< PortTraits > | protected |
Port_Provides_base_impl(std::string port_name) | Port_Provides_base_impl | inline |
PortBase(const std::string &name) | PortBase | inline |
PortSequenceType typedef | bulkio::InPortBase< PortTraits > | |
PortType typedef | bulkio::InPortBase< PortTraits > | |
PushArgumentType typedef | bulkio::InPortBase< PortTraits > | |
pushSRI(const BULKIO::StreamSRI &H) | bulkio::InPortBase< PortTraits > | virtual |
queuePacket(PushArgumentType data, const BULKIO::PrecisionUTCTime &T, CORBA::Boolean EOS, const char *streamID) | bulkio::InPortBase< PortTraits > | protected |
queueSem | bulkio::InPortBase< PortTraits > | protected |
releasePort() | PortBase | inlinevirtual |
removeStream(const std::string &streamID) | bulkio::InPortBase< PortTraits > | protectedvirtual |
samplesAvailable(const std::string &streamID, bool firstPacket) | bulkio::InPortBase< PortTraits > | protected |
setDescription(const std::string &desc) | PortBase | inlinevirtual |
setLogger(LOGGER_PTR logger) | bulkio::InPortBase< PortTraits > | |
setMaxQueueDepth(int newDepth) | bulkio::InPortBase< PortTraits > | virtual |
setNewStreamListener(T &target, void(T::*func)(BULKIO::StreamSRI &)) | bulkio::InPortBase< PortTraits > | inline |
setNewStreamListener(T *target, void(T::*func)(BULKIO::StreamSRI &)) | bulkio::InPortBase< PortTraits > | inline |
setNewStreamListener(SriListener *newListener) | bulkio::InPortBase< PortTraits > | |
setNewStreamListener(SriListenerCallbackFn newListener) | bulkio::InPortBase< PortTraits > | |
sri_cmp | bulkio::InPortBase< PortTraits > | protected |
sriUpdateLock | bulkio::InPortBase< PortTraits > | protected |
startPort() | bulkio::InPortBase< PortTraits > | virtual |
state() | bulkio::InPortBase< PortTraits > | virtual |
statistics() | bulkio::InPortBase< PortTraits > | virtual |
stats | bulkio::InPortBase< PortTraits > | protected |
stopPort() | bulkio::InPortBase< PortTraits > | virtual |
Traits typedef | bulkio::InPortBase< PortTraits > | |
TransportType typedef | bulkio::InPortBase< PortTraits > | |
unblock() | bulkio::InPortBase< PortTraits > | virtual |
WorkQueue typedef | bulkio::InPortBase< PortTraits > | |
workQueue | bulkio::InPortBase< PortTraits > | protected |
~InPortBase() | bulkio::InPortBase< PortTraits > | virtual |
~Port_Provides_base_impl() | Port_Provides_base_impl | inlinevirtual |
~PortBase() | PortBase | inlinevirtual |