StorableTimeslice.h

Go to the documentation of this file.

// Copyright 2013 Jan de Cuveland <cmail@cuveland.de>
// #pragma once#
 
#ifndef STTS_H
#define STTS_H 1
 
#include "ArchiveDescriptor.h"
#include "StorableMicroslice.h"
#include "Timeslice.h"
 
#include <algorithm>   // std::copy
#include <boost/serialization/access.hpp>
#include <boost/serialization/vector.hpp>
#include <cstdint>
#include <fstream>
#include <vector>
// Note: <fstream> has to precede boost/serialization includes for non-obvious
// reasons to avoid segfault similar to
// http://lists.debian.org/debian-hppa/2009/11/msg00069.html
 
namespace fles
{
 
// template <class Base, class Derived, ArchiveType archive_type>
// class InputArchive;
// template <class Base, class Derived, ArchiveType archive_type>
// class InputArchiveLoop;
 
class StorableTimeslice : public Timeslice
{
  public:
    StorableTimeslice();   // KAA - moved from private
    StorableTimeslice(const StorableTimeslice& ts);
    //  void operator=(const StorableTimeslice&) = delete;
    StorableTimeslice(StorableTimeslice&& ts) noexcept;
 
    //  /// Construct by copying from given Timeslice object.
    //  StorableTimeslice(const Timeslice& ts);
 
    explicit StorableTimeslice(uint32_t num_core_microslices, uint64_t index = UINT64_MAX, uint64_t ts_pos = UINT64_MAX)
    {
        timeslice_descriptor_.index = index;
        timeslice_descriptor_.ts_pos = ts_pos;
        timeslice_descriptor_.num_core_microslices = num_core_microslices;
        timeslice_descriptor_.num_components = 0;
    }
 
    uint32_t append_component(uint64_t num_microslices, uint64_t /* dummy */ = 0)
    {
        TimesliceComponentDescriptor ts_desc = TimesliceComponentDescriptor();
        ts_desc.ts_num = timeslice_descriptor_.index;
        ts_desc.offset = 0;
        ts_desc.num_microslices = num_microslices;
 
        std::vector<uint8_t> data;
        for (uint64_t m = 0; m < num_microslices; ++m) {
            MicrosliceDescriptor desc = MicrosliceDescriptor();
            uint8_t* desc_bytes = reinterpret_cast<uint8_t*>(&desc);
            data.insert(data.end(), desc_bytes, desc_bytes + sizeof(MicrosliceDescriptor));
        }
 
        ts_desc.size = data.size();
        desc_.push_back(ts_desc);
        data_.push_back(data);
        uint32_t component = timeslice_descriptor_.num_components++;
 
        init_pointers();
        return component;
    }
 
    uint64_t append_microslice(uint32_t component,
                               uint64_t microslice,
                               MicrosliceDescriptor descriptor,
                               const uint8_t* content)
    {
        assert(component < timeslice_descriptor_.num_components);
        std::vector<uint8_t>& this_data = data_[component];
        TimesliceComponentDescriptor& this_desc = desc_[component];
 
        assert(microslice < this_desc.num_microslices);
        uint8_t* desc_bytes = reinterpret_cast<uint8_t*>(&descriptor);
 
        // set offset relative to first microslice
        if (microslice > 0) {
            uint64_t offset = this_data.size() - this_desc.num_microslices * sizeof(MicrosliceDescriptor);
            uint64_t first_offset = reinterpret_cast<MicrosliceDescriptor*>(this_data.data())->offset;
            descriptor.offset = offset + first_offset;
        }
 
        std::copy(desc_bytes, desc_bytes + sizeof(MicrosliceDescriptor),
                  &this_data[microslice * sizeof(MicrosliceDescriptor)]);
 
        this_data.insert(this_data.end(), content, content + descriptor.size);
        this_desc.size = this_data.size();
 
        init_pointers();
        return microslice;
    }
 
    uint64_t append_microslice(uint32_t component, uint64_t microslice, StorableMicroslice& m)
    {
        return append_microslice(component, microslice, m.desc(), m.content());
    }
 
  private:
    friend class boost::serialization::access;
    friend class InputArchive<Timeslice, StorableTimeslice, ArchiveType::TimesliceArchive>;
    friend class InputArchiveLoop<Timeslice, StorableTimeslice, ArchiveType::TimesliceArchive>;
    friend class TimesliceSubscriber;
 
    template<class Archive>
    void serialize(Archive& ar, const unsigned int /* version */)
    {
        ar & timeslice_descriptor_;
        ar & data_;
        ar & desc_;
 
        init_pointers();
    }
 
    void init_pointers()
    {
        data_ptr_.resize(num_components());
        desc_ptr_.resize(num_components());
        for (size_t c = 0; c < num_components(); ++c) {
            desc_ptr_[c] = &desc_[c];
            data_ptr_[c] = data_[c].data();
        }
    }
 
    std::vector<std::vector<uint8_t>> data_;
    std::vector<TimesliceComponentDescriptor> desc_;
};
 
}   // namespace fles
#endif   // STTS_H