Class Distributor¶

Defined in File distributor.hpp

Inheritance Relationships¶

Base Type¶

public IProcessor

Class Documentation¶

class Distributor : public IProcessor¶

Public Functions

Distributor()¶

void CreatePorts() override¶

void CompleteStreamInfo() override¶

void Prepare(GlobalContext &context) override¶

void Process(ProcessingContext &context) override¶

void Postprocess(ProcessingContext &context) override¶

Protected Attributes

PortIn<MultiChannelType<double>> *input_port_¶

std::map<std::string, PortOut<MultiChannelType<double>>*> data_ports_¶

unsigned int incoming_batch_size_¶

unsigned int max_n_channels_¶

const unsigned int MAX_N_CHANNELS = 4096¶

const int BUFFER_SIZE = 2000¶

const WaitStrategy WAIT_STRATEGY = WaitStrategy::kBlockingStrategy¶

options::Value<ChannelMap, false> channelmap_¶