fast::PipelineSynchronizer class
#include <FAST/PipelineSynchronizer.hpp>

Synchronize multiple process objects This PO takes in N input connections and creates N output connections. It keeps the last frame of every connection, and every time a connection has a new data frame, it send out the latest frame to all output connections.

Contents

Base classes

class ProcessObject
Abstract base class for all process objects.

Public functions

auto create() -> std::shared_ptr<PipelineSynchronizer>
auto addInputConnection(DataChannel::pointer port) -> uint virtual

Protected functions

void execute() override

Protected variables

std::unordered_map<uint, std::shared_ptr<DataObject>> m_latestData

Function documentation

uint fast::PipelineSynchronizer::addInputConnection(DataChannel::pointer port) virtual

Parameters
port
Returns the input nr of the new connection

Adds a new input connection