Class FileSerializer

Inheritance Relationships

Base Type

  • public IProcessor

Class Documentation

class FileSerializer : public IProcessor

Public Functions

FileSerializer()
void CreatePorts() override
void Configure(const GlobalContext &context) override
void Preprocess(ProcessingContext &context) override
void Process(ProcessingContext &context) override
void Postprocess(ProcessingContext &context) override

Protected Functions

void create_preamble(std::ostream &out, int slot)

Protected Attributes

PortIn<AnyType> *data_port_
std::unique_ptr<Serialization::Serializer> serializer_
std::vector<std::unique_ptr<std::ostream>> streams_
std::vector<uint64_t> packetid_
std::vector<unsigned int> upstream_buffer_size_
double throttle_level_
std::vector<uint64_t> nskipped_
options::String path_ = {"run://"}
options::Value<Serialization::Encoding, false> encoding_{Serialization::Encoding::BINARY}
options::Value<Serialization::Format, false> format_{Serialization::Format::FULL}
options::Bool overwrite_ = {false}
options::Bool throttle_ = {false}
options::Double throttle_threshold_ = {0.3, options::inrange<double>(0., 1.)}
options::Double throttle_smooth_ = {0.5, options::inrange<double>(0., 1.)}
options::Bool preamble_ = {true}