filval/include/dataset.hpp

/**
 * @file
 * @author  Caleb Fangmeier <caleb@fangmeier.tech>
 * @version 0.1
 *
 * @section LICENSE
 *
 *
 * MIT License
 *
 * Copyright (c) 2017 Caleb Fangmeier
 *
 * Permission is hereby granted, free of charge, to any person obtaining a copy
 * of this software and associated documentation files (the "Software"), to deal
 * in the Software without restriction, including without limitation the rights
 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
 * copies of the Software, and to permit persons to whom the Software is
 * furnished to do so, subject to the following conditions:
 *
 * The above copyright notice and this permission notice shall be included in all
 * copies or substantial portions of the Software.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 * SOFTWARE.
 */
#ifndef dataset_hpp
#define dataset_hpp
#include <iostream>
#include "value.hpp"
#include "container.hpp"
#include "memtrack.hpp"
#include "config.hpp"
#include "log.hpp"

#include "TFile.h"

namespace fv {

/*
 * A DataSet is a generic source of data that is used to populate
 * ObservedValues. For each ObservedValue, it is recommened that the DataSet
 * have a field whose value is updated when the load_next() method is called. A
 * pointer to this value is then passed during the creation of the
 * ObservedValue. It is important, therefore, that the location in memory of
 * the data not change from event to event.
 */
    class DataSet {
    private:
        void summary() {
            INFO(GenValue::summary());
        }

        int max_events;

    protected:
        std::map<std::string, GenContainer *> containers;

        virtual int get_events() = 0;

        virtual int get_current_event() = 0;

        virtual fv_util::DataFileDescriptor &get_current_file() = 0;

        std::map<std::string, std::string> get_container_name_value_map() {
            std::map<std::string, std::string> value_map;
            for (auto container : containers)
                value_map[container.first] = container.second->get_value_name();
            return value_map;
        }

        virtual bool load_next() = 0;

        virtual void save_config() = 0;

    public:
        bool next(bool print_status=true) {
            if(print_status) {
                size_t m_used = fv_util::getCurrentRSS() / 1024 / 1024;
                size_t m_peak = fv_util::getPeakRSS() / 1024 / 1024;
                std::cout << "\rprocessing event: " << get_current_event() + 1 << "/" << get_events()
                          << ", " << m_used << "/" << m_peak << "MB used/peak"
                          << " of file: " << get_current_file().filename << std::flush;
            }
            if (max_events && get_current_event() + 1 >= max_events) return false;
            GenValue::reset();
            return load_next();
        }

        void set_max_events(const int &max_events) {
            this->max_events = max_events;
        }

        int get_max_events() {
            return this->max_events;
        }

        virtual void save_all() {
            for (auto container : containers)
                container.second->save();
            save_config();
        }

        template<typename C, typename... ArgTypes>
        C *register_container(ArgTypes... args) {
            C *container = new C(args...);
            if (containers[container->get_name()] != nullptr) {
                CRITICAL("Container with name \"" + container->get_name() + "\" already exists.", -1);
            }
            containers[container->get_name()] = container;
            return container;
        }

        GenContainer *get_container(std::string container_name) {
            GenContainer *c = containers[container_name];
            if (c == nullptr) {
                CRITICAL("Request for container \"" << container_name << "\" failed. Doesn't exist.", -1);
            }
            return c;
        }
    };

}
#endif // dataset_hpp