KeyParameterHistory.cpp

Go to the documentation of this file.

// KeyParameterHistory.cpp: implementation of the KeyParameterHistory class.
//
#if defined(_WIN32)
#include <direct.h>
#include <boost/serialization/export.hpp>
#else
#include <sys/stat.h>
#include <sys/types.h>
#endif
 
#include "KeyParameterHistory.h"
#include "../Branch/BranchRecord.h"
#include "../Scheduler/Scheduler.h"
#include <filesystem>
#include "SimulationContext.h"
#include "CheckedIO.h"
#include <boost/archive/binary_oarchive.hpp>
#include <boost/archive/binary_iarchive.hpp>
BOOST_CLASS_EXPORT_IMPLEMENT(KeyParameterHistory)
using namespace std;
namespace fs = std::filesystem;
 
 
// Construction/Destruction
 
KeyParameterHistory::KeyParameterHistory()
{
    this->m_timer = 0;
}
 
KeyParameterHistory::~KeyParameterHistory()
{
    this->clearKeyParameterHistory();
}
 
void KeyParameterHistory::addDataSet(){ //Modified by Yuandan
    if (this->m_timer < 1)
    {
        auto kpu_pt = make_unique<KeyParameterHistoryUnit>();
        kpu_pt->addDataSet();
        kps_history.push_back(std::move(kpu_pt));
        this->m_timer = 2;
    }
    else
    {this->m_timer  = this->m_timer -1;}
 
}
 
void KeyParameterHistory::outputHistoryToFile(int iESID, string strKPSDir)
{
    if (kps_history.empty()) return;
    string full_file_name, full_file_name_diagnosis, full_file_name_PIF;
    int num_subfolder, size_of_subfolder, es_id;
    int num_column, num_row, num_column_diagnosis, num_column_PIF;
    decltype(kps_history)::iterator kps_history_itr;
//
    es_id = iESID;
 
    size_of_subfolder = g_sim.Branch_center.getSizeOfSubFolder();
    full_file_name = strKPSDir;
    full_file_name += "KPSFolder_";
    num_subfolder = es_id / size_of_subfolder;
    // itoa(num_subfolder, numtext, 10);
    full_file_name += to_string(num_subfolder);
    fs::create_directories(full_file_name);
    full_file_name_diagnosis = full_file_name;
    full_file_name_PIF= full_file_name;
 
    full_file_name += "/ZKPS_";
    full_file_name_diagnosis += "/ZDIA_";
    full_file_name_PIF += "/ZPIF_";
 
    
    // itoa(es_id, numtext, 10);
    full_file_name += to_string(es_id);
    full_file_name += ".txt";
    full_file_name_diagnosis += to_string(es_id);
    full_file_name_diagnosis += ".txt";
    full_file_name_PIF += to_string(es_id);
    full_file_name_PIF += ".txt";
 
    
    kps_history_itr = kps_history.begin();
    num_column = (*kps_history_itr)->getNumOfData();
    num_column_diagnosis = (*kps_history_itr)->getDiagnosisNumOfData();
    num_column_PIF = (*kps_history_itr)->getPIFNumOfData();
    num_row = kps_history.size() + 2;
    //
    // output keyparameter data
    ofstream fout(full_file_name.c_str(), ios::out);
    // output column and row
    fout << num_column << '\t' << num_row << '\n';
    (*kps_history_itr)->outputLabelToFile(fout);
    (*kps_history_itr)->outputUnitToFile(fout);
    for(kps_history_itr = this->kps_history.begin(); kps_history_itr != this->kps_history.end(); kps_history_itr++){
        (*kps_history_itr)->outputAllDataToFile(fout);
    }
    checked_close(fout, full_file_name);
    //
    // output diagnosis data
    ofstream fout1(full_file_name_diagnosis.c_str(), ios::out);
    fout1 << num_column_diagnosis << '\t' << num_row << '\n';
    // the data loop above left the iterator at end() — re-anchor before the
    // label/unit rows (dereferencing end() read one slot past the buffer)
    kps_history_itr = this->kps_history.begin();
    (*kps_history_itr)->outputDiagnosisLabelToFile(fout1);
    (*kps_history_itr)->outputDiagnosisUnitToFile(fout1);
    for(kps_history_itr = this->kps_history.begin(); kps_history_itr != this->kps_history.end(); kps_history_itr++){
        (*kps_history_itr)->outputAllDiagnosisDataToFile(fout1);
    }
    checked_close(fout1, full_file_name_diagnosis);
    //
    // output PIF (SPDS & Time Constrained) data
    ofstream fout2(full_file_name_PIF.c_str(), ios::out);
    fout2 << num_column_PIF << '\t' << num_row << '\n';
    kps_history_itr = this->kps_history.begin();
    (*kps_history_itr)->outputPIFLabelToFile(fout2);
    (*kps_history_itr)->outputPIFUnitToFile(fout2);
    for(kps_history_itr = this->kps_history.begin(); kps_history_itr != this->kps_history.end(); kps_history_itr++){
        (*kps_history_itr)->outputAllPIFDataToFile(fout2);
    }
    checked_close(fout2, full_file_name_PIF);
}
 
void KeyParameterHistory::outputHistoryToFile(){
    if (kps_history.empty()) return;
    string full_file_name;
 
    int es_id = g_sim.Branch_center.getIDOfRecentGeneratedES();
    full_file_name = g_sim.SScheduler.getKPSDirectory();
 
    outputHistoryToFile(es_id, full_file_name);
}
void KeyParameterHistory::clearKeyParameterHistory(){
    kps_history.clear();
}
void KeyParameterHistory::copyKeyParameterHistory(KeyParameterHistory &kph){
    this->kps_history.reserve(this->kps_history.size() + kph.kps_history.size());
    for(auto& src : kph.kps_history){
        auto ptr = make_unique<KeyParameterHistoryUnit>();
        ptr->copyKeyParameterHistoryUnit(*src);
        this->kps_history.push_back(std::move(ptr));
    }
}
void KeyParameterHistory::saveKeyParameterHistoryToFile(ofstream &fout){
    int i, num;
    num = kps_history.size();
    fout << "KeyParameterHistory\n" << num << '\n';
    for(i = 0; i < num; i++){
        kps_history.at(i)->saveKeyParameterHistoryUnitToFile(fout);
    }
}
void KeyParameterHistory::retrieveKeyParameterHistoryFromFile(ifstream &fin){
    int i, num;
    string str;
    fin >> str >> num;
    if (str != "KeyParameterHistory"){
        ofstream fout("err messages.txt", ios::app);
        cout << "KeyParameterHistory::retrieveKeyParameterHistoryFromFile retrieval error in previous function" << endl;
        fout << r5pars_.timesno << "  KeyParameterHistory::retrieveKeyParameterHistoryFromFile retrieval error in previous function\n";
        fout.close();
        r5pars_.sim_err = true;
        g_sim.Branch_center.setTempESMessage("KeyParameterHistory::retrieveKeyParameterHistoryFromFile Prior error");
        g_sim.Branch_center.setTempTypeOfConsequence(Consequence::NoKB);
        return;
    }
    for(i = 0; i < num; i++){
        auto ptr = make_unique<KeyParameterHistoryUnit>();
        ptr->retrieveKeyParameterHistoryUnitFromFile(fin);
        kps_history.push_back(std::move(ptr));
    }
}