Class Distributor

• Defined in File distributor.hpp

Inheritance Relationships

Base Type

• public IProcessor

Class Documentation

class Distributor : public IProcessor

Public Functions

Distributor()

void Configure(const GlobalContext &context) override

void CreatePorts() override

void CompleteStreamInfo() override

void Prepare(GlobalContext &context) override

void Process(ProcessingContext &context) override

void Postprocess(ProcessingContext &context) override

Protected Attributes

PortIn<TimeSeriesType<double>> *input_port_

std::vector<PortOut<TimeSeriesType<double>>*> data_ports_

SlotType slot_

const unsigned int MAX_N_CHANNELS = 4096

const int BUFFER_SIZE = 2000

const WaitStrategy WAIT_STRATEGY = WaitStrategy::kBlockingStrategy

options::Value<ChannelMap, false> channelmap_

options::String channelmap_file_ = {""}

options::String distribution_type_ = {"ports"}