DataWriter.h

// -*- c++ -*-

// tools
#include "tools/ToolsConfig.h"
#include "tools/AutoPtr.h"
#include "tools/NoCopy.h"

// storage
#include "storage/CtrlInfo.h"
#include "storage/RawValue.h"
#include "storage/Index.h"


class DataWriter
{
public:
    DataWriter(Index &index,
               const stdString &channel_name,
               const CtrlInfo &ctrl_info,
               DbrType dbr_type,
               DbrCount dbr_count,
               double period,
               size_t num_samples);

    ~DataWriter();

    epicsTime getLastStamp();

    bool add(const RawValue::Data *data);

    static FileOffset file_size_limit;

    static stdString data_file_name_base;

    void write(DbrType type, DbrCount count,
               size_t size, const RawValue::Data *value,
               MemoryBuffer<dbr_time_string> &cvt_buffer,
               class DataFile *datafile, FileOffset offset);

public:

  dbr_time_string* write1(size_t size,
                                 MemoryBuffer<dbr_time_string> &cvt_buffer,
                                 class DataFile *datafile); 
  void write2(dbr_time_string* buffer, size_t size,
              const RawValue::Data *value);

  void write3(dbr_time_string* buffer);

  void write4(DbrType type, DbrCount count, 
              dbr_time_string* buffer,
              size_t size, const RawValue::Data *value,
              class DataFile *datafile, FileOffset offset);

  void write5a(class DataFile *datafile, FileOffset offset);

  void write5b(class DataFile *datafile, FileOffset offset);

  void write6(dbr_time_string* buffer, size_t size,
                     class DataFile *datafile, FileOffset offset);

    
private:

    PROHIBIT_DEFAULT_COPY(DataWriter);
    Index &index;
    AutoPtr<Index::Result> index_result;
    const stdString channel_name;
    const CtrlInfo &ctrl_info;
    DbrType dbr_type;
    DbrCount dbr_count;
    double period;
    size_t raw_value_size;

    void makeDataFileName(int serial, stdString &name);
    DataFile *createNewDataFile(size_t headroom);

    // Sets next_buffer_size to at least 'start',
    // so that buffers get bigger and bigger up to
    // some limit.
    void calc_next_buffer_size(size_t start);
    size_t next_buffer_size;

    AutoPtr<class DataHeader> header;
    size_t available;
    MemoryBuffer<dbr_time_string> cvt_buffer;

    void addNewHeader(bool new_ctrl_info);
};