| buffer_size_factor | aggregator::StreamAligner | |
| clear() | aggregator::StreamAligner | inline |
| compareStreams(const StreamBase *b1, const StreamBase *b2) | aggregator::StreamAligner | inlinestatic |
| copyState(const PullStreamAligner &other) | aggregator::PullStreamAligner | inline |
| aggregator::StreamAligner::copyState(const StreamAligner &other) | aggregator::StreamAligner | inline |
| current_ts | aggregator::StreamAligner | |
| disableStream(int idx) | aggregator::StreamAligner | inline |
| enableStream(int idx) | aggregator::StreamAligner | inline |
| getBufferStatus(int idx) const | aggregator::StreamAligner | inline |
| getCurrentTime() const | aggregator::StreamAligner | inline |
| getLatency() const | aggregator::StreamAligner | inline |
| getLatestTime() const | aggregator::StreamAligner | inline |
| getNextSample(int idx, std::pair< base::Time, T > &sample) const | aggregator::StreamAligner | inline |
| getStatus() const | aggregator::StreamAligner | inline |
| getStreamSize() const | aggregator::StreamAligner | inline |
| getTimeOut() const | aggregator::StreamAligner | inline |
| isStreamActive(int idx) const | aggregator::StreamAligner | inline |
| latest_ts | aggregator::StreamAligner | |
| pull() | aggregator::PullStreamAligner | inline |
| pull_stream_vector typedef | aggregator::PullStreamAligner | protected |
| pull_streams | aggregator::PullStreamAligner | protected |
| push(int idx, const base::Time &ts, const T &data) | aggregator::StreamAligner | inline |
| registerStream(typename PullStream< T >::pull_callback_t pull_callback, typename Stream< T >::callback_t callback, int bufferSize, base::Time period, int priority=-1) | aggregator::PullStreamAligner | inline |
| aggregator::StreamAligner::registerStream(typename Stream< T >::callback_t callback, int bufferSize, base::Time period, int priority=-1, const std::string &name=std::string()) | aggregator::StreamAligner | inline |
| setTimeout(const base::Time &t) | aggregator::StreamAligner | inline |
| status | aggregator::StreamAligner | mutable |
| step() | aggregator::StreamAligner | inline |
| stream_vector typedef | aggregator::StreamAligner | |
| StreamAligner(base::Time timeout=base::Time::fromSeconds(1)) | aggregator::StreamAligner | inlineexplicit |
| streams | aggregator::StreamAligner | |
| timeout | aggregator::StreamAligner | |
| unregisterStream(int idx) | aggregator::StreamAligner | inline |
| ~PullStreamAligner() | aggregator::PullStreamAligner | inline |
| ~StreamAligner() | aggregator::StreamAligner | inlinevirtual |
