CommunicationPlace.cpp

Go to the documentation of this file.

// CommunicationPlace.cpp: implementation of the CommunicationPlace class.
//
 
#include <string>
#include <boost/serialization/export.hpp>
 
#include "CommunicationPlace.h"
#include <boost/archive/binary_oarchive.hpp>
#include <boost/archive/binary_iarchive.hpp>
BOOST_CLASS_EXPORT_IMPLEMENT(CommunicationPlace)
using namespace std;
 
// Construction/Destruction
 
CommunicationPlace::CommunicationPlace() {
 
}
 
CommunicationPlace::~CommunicationPlace() {
}
void CommunicationPlace::clearCommunicationPlaceAll() {
  BranchUnit::clearBranchUnit();
  HW_reliability.clear();
  SS_reliability.clear();
  new_alarm.clear();
}
void CommunicationPlace::clearCommunicationPlaceForRestart() {
  this->clearCommunicationPlaceAllPointers();
}
void CommunicationPlace::clearCommunicationPlaceAllPointers() {
  BranchUnit::clearBranchUnitAllPointers();
  HW_reliability.clear();
  SS_reliability.clear();
  new_alarm.clear();
}
int CommunicationPlace::getTotalPiecesOfInfo() {
  int n_return;
  n_return = BranchUnit::getTotalPiecesOfInfo();
  n_return += new_alarm.size();
  return n_return;
}
void CommunicationPlace::updateSenderReceiverInfo() {
  for (auto &e : action) {
    if (e->getSender() == sim::Source::Plant) {
      e->setSender(e->getIntendedReceiver());
      e->setIntendedReceiver(sim::Source::Plant);
    }
  }
  for (auto &e : alarm_state) {
    if (e->getSender() == sim::Source::Plant) {
      e->setSender(e->getIntendedReceiver());
      e->setIntendedReceiver(sim::Source::Plant);
    }
  }
  for (auto &e : component_state) {
    if (e->getSender() == sim::Source::Plant) {
      e->setSender(e->getIntendedReceiver());
      e->setIntendedReceiver(sim::Source::Plant);
    }
  }
  for (auto &e : support_system_state) {
    if (e->getSender() == sim::Source::Plant) {
      e->setSender(e->getIntendedReceiver());
      e->setIntendedReceiver(sim::Source::Plant);
    }
  }
  for (auto &e : parameter_value) {
    if (e->getSender() == sim::Source::Plant) {
      e->setSender(e->getIntendedReceiver());
      e->setIntendedReceiver(sim::Source::Plant);
    }
  }
  for (auto &e : parameter_difference) {
    if (e->getSender() == sim::Source::Plant) {
      e->setSender(e->getIntendedReceiver());
      e->setIntendedReceiver(sim::Source::Plant);
    }
  }
  for (auto &e : parameter_trend) {
    if (e->getSender() == sim::Source::Plant) {
      e->setSender(e->getIntendedReceiver());
      e->setIntendedReceiver(sim::Source::Plant);
    }
  }
}
void CommunicationPlace::copyCommunicationPlace(CommunicationPlace &_cp) {
  this->copyBranchUnit((BranchUnit &) _cp);
  for (auto &e : _cp.HW_reliability) {
    auto p = make_shared<BranchSystemAction>();
    p->copyBranchSystemAction(*e);
    this->HW_reliability.push_back(std::move(p));
  }
  for (auto &e : _cp.SS_reliability) {
    auto p = make_shared<BranchSupportSystemAction>();
    p->copyBranchSupportSystemAction(*e);
    this->SS_reliability.push_back(std::move(p));
  }
  for (auto &e : _cp.new_alarm) {
    auto p = make_shared<BranchSystemAlarmState>();
    p->copyBranchSystemAlarmState(*e);
    this->new_alarm.push_back(std::move(p));
  }
}
void CommunicationPlace::saveInfoToFileAsBranchForADSV1(ostream &fout) {
  string str;
  double probability;
//
  fout << this->getNumberOfItemInCommunicationPlace() << ' ';
  for (auto &e : goal) { e->saveInfoToFile(fout); }
  for (auto &e : strategy) { e->saveInfoToFile(fout); }
  for (auto &e : subgoal) { e->saveInfoToFile(fout); }
  for (auto &e : diagnosis) { e->saveInfoToFile(fout); }
  for (auto &e : action_objective) { e->saveInfoToFile(fout); }
  for (auto &e : action_pack) { e->saveInfoToFile(fout); }
  for (auto &e : action) { e->saveInfoToFile(fout); }
  for (auto &e : alarm_state) { e->saveInfoToFile(fout); }
  for (auto &e : component_state) { e->saveInfoToFile(fout); }
  for (auto &e : support_system_state) { e->saveInfoToFile(fout); }
  for (auto &e : parameter_trend) { e->saveInfoToFile(fout); }
  for (auto &e : parameter_value) { e->saveInfoToFile(fout); }
  for (auto &e : parameter_difference) { e->saveInfoToFile(fout); }
  for (auto &e : procedure_step) { e->saveInfoToFile(fout); }
  for (auto &e : instinctive_response_procedure) { e->saveInfoToFile(fout); }
  for (auto &e : info_gather_mode) { e->saveInfoToFile(fout); }
  for (auto &e : mental_belief) { e->saveInfoToFile(fout); }
  for (auto &e : this->scanned_parameter) { e->saveInfoToFile(fout); }
  if (HW_reliability.size() > 0 && SS_reliability.size() && new_alarm.size() > 0) {
    str = '"';
    probability = 1.0;
    for (auto &e : HW_reliability) {
      str += e->getDisplayName();
      probability *= e->getProbability();
      if (e->getFunctionalState() == sim::State::Failed) {
        str += "_failed;";
      } else {
        str += "_success;";
      }
    }
    for (auto &e : SS_reliability) {
      str += e->getDisplayName();
      probability *= e->getProbability();
      if (e->getFunctionalState() == sim::State::Failed) {
        str += "_failed;";
      } else {
        str += "_success;";
      }
    }
    for (auto &e : new_alarm) {
      str += e->getAlarmName();
      str += ";";
    }
    str += '"';
    auto &hw_first = HW_reliability.front();
    fout << ' ' << sim::Source::Plant << ' ' << sim::Action::Direct << ' ' << sim::None << " Multi_Comp_Failure_And_Alarm " << probability << ' '
         << hw_first->getTimeOfCommunication() << ' ' << hw_first->getRemainingTime()
         << " 0.0 0 "
         << str << '\n';
  } else if (HW_reliability.size() > 0) {
    if (HW_reliability.size() == 1) {
      HW_reliability.front()->saveInfoToFile(fout);
    } else {
      str = '"';
      probability = 1.0;
      for (auto &e : HW_reliability) {
        str += e->getDisplayName();
        probability *= e->getProbability();
        if (e->getFunctionalState() == sim::State::Failed) {
          str += "_failed;";
        } else {
          str += "_success;";
        }
      }
      str += '"';
      auto &hw_first = HW_reliability.front();
      fout << ' ' << sim::Source::Plant << ' ' << sim::Action::Direct << ' ' << sim::None << " Multi_Comp_Failure " << probability << ' '
           << hw_first->getTimeOfCommunication() << ' ' << hw_first->getRemainingTime()
           << " 0.0 0 "
           << str << '\n';
    }
  } else if (SS_reliability.size() > 0) {
    if (SS_reliability.size() == 1) {
      SS_reliability.front()->saveInfoToFile(fout);
    } else {
      str = '"';
      probability = 1.0;
      for (auto &e : SS_reliability) {
        str += e->getDisplayName();
        probability *= e->getProbability();
        if (e->getFunctionalState() == sim::State::Failed) {
          str += "_failed;";
        } else {
          str += "_success;";
        }
      }
      str += '"';
      auto &ss_first = SS_reliability.front();
      fout << ' ' << sim::Source::Plant << ' ' << sim::Action::Direct << ' ' << sim::None << " Multi_Comp_Failure " << probability << ' '
           << ss_first->getTimeOfCommunication() << ' ' << ss_first->getRemainingTime()
           << " 0.0 0 "
           << str << '\n';
    }
  } else if (new_alarm.size() > 0) {
    if (new_alarm.size() == 1) {
      new_alarm.front()->saveInfoToFile(fout);
    } else {
      str = '"';
      probability = 1.0;
      for (auto &e : new_alarm) {
        str += e->getAlarmName();
        str += ";";
      }
      str += '"';
      auto &na_first = new_alarm.front();
      fout << ' ' << sim::Source::Plant << ' ' << sim::Action::SendInfo << ' ' << sim::None << " Multi_Alarms " << probability << ' '
           << na_first->getTimeAtWhichThisAlarmIsActivated() << ' ' << na_first->getRemainingTime()
           << " 0.0 0 "
           << str << '\n';
    }
  } else {
  }
}
int CommunicationPlace::getNumberOfItemInCommunicationPlace() {
  int n;
  n = this->getNumberOfItemInBranchUnit();
  if (new_alarm.size() > 0 || HW_reliability.size() > 0 || SS_reliability.size() > 0) n++;
  return n;
}
void CommunicationPlace::saveCommunicationPlaceToFile(ofstream &fout) {
  int i, num;
  num = HW_reliability.size();
  fout << num << '\n';
  for (i = 0; i < num; i++) {
    HW_reliability.at(i)->saveBranchSystemActionToFile(fout);
  }
  num = SS_reliability.size();
  fout << num << '\n';
  for (i = 0; i < num; i++) {
    SS_reliability.at(i)->saveBranchSupportSystemActionToFile(fout);
  }
  num = new_alarm.size();
  fout << num << '\n';
  for (i = 0; i < num; i++) {
    new_alarm.at(i)->saveBranchSystemAlarmStateToFile(fout);
  }
  this->saveBranchUnitToFile(fout);
}
void CommunicationPlace::retrieveCommunicationPlaceFromFile(ifstream &fin) {
  int i, num;
  fin >> num;
  for (i = 0; i < num; i++) {
    auto p = make_shared<BranchSystemAction>();
    p->retrieveBranchSystemActionFromFile(fin);
    this->HW_reliability.push_back(std::move(p));
  }
  fin >> num;
  for (i = 0; i < num; i++) {
    auto p = make_shared<BranchSupportSystemAction>();
    p->retrieveBranchSupportSystemActionFromFile(fin);
    this->SS_reliability.push_back(std::move(p));
  }
  fin >> num;
  for (i = 0; i < num; i++) {
    auto p = make_shared<BranchSystemAlarmState>();
    p->retrieveBranchSystemAlarmStateFromFile(fin);
    this->new_alarm.push_back(std::move(p));
  }
  this->retrieveBranchUnitFromFile(fin);
}