ISaveable.cpp

Go to the documentation of this file.

// Mantid Repository : https://github.com/mantidproject/mantid
//
// Copyright © 2018 ISIS Rutherford Appleton Laboratory UKRI,
//   NScD Oak Ridge National Laboratory, European Spallation Source,
//   Institut Laue - Langevin & CSNS, Institute of High Energy Physics, CAS
// SPDX - License - Identifier: GPL - 3.0 +
#include "MantidKernel/ISaveable.h"
//#include "MantidKernel/INode.h"
 
namespace Mantid::Kernel {
 
ISaveable::ISaveable()
    : m_Busy(false), m_dataChanged(false), m_wasSaved(false), m_isLoaded(false), m_BufMemorySize(0),
      m_fileIndexStart(std::numeric_limits<uint64_t>::max()), m_fileNumEvents(0) {}
 
//----------------------------------------------------------------------------------------------
ISaveable::ISaveable(const ISaveable &other)
    : m_Busy(other.m_Busy), m_dataChanged(other.m_dataChanged), m_wasSaved(other.m_wasSaved), m_isLoaded(false),
      m_BufPosition(other.m_BufPosition), m_BufMemorySize(other.m_BufMemorySize),
      m_fileIndexStart(other.m_fileIndexStart), m_fileNumEvents(other.m_fileNumEvents)
 
{}
 
//---------------------------------------------------------------------------
 
void ISaveable::setFilePosition(uint64_t newPos, size_t newSize, bool wasSaved) {
  std::lock_guard<std::mutex> lock(m_setter);
  this->m_fileIndexStart = newPos;
  this->m_fileNumEvents = static_cast<uint64_t>(newSize);
  m_wasSaved = wasSaved;
}
 
// ----------- PRIVATE, only DB availible
 
void ISaveable::saveAt(uint64_t newPos, uint64_t newSize) {
  std::lock_guard<std::mutex> lock(m_setter);
  // load old contents if it was there
  if (this->wasSaved())
    this->load();
  // set new position, derived by the disk buffer
  m_fileIndexStart = newPos;
  m_fileNumEvents = newSize;
  // save in the new location
  this->save();
  this->clearDataFromMemory();
}
 
size_t ISaveable::setBufferPosition(std::list<ISaveable *>::iterator bufPosition) {
  std::lock_guard<std::mutex> lock(m_setter);
  m_BufPosition = boost::optional<std::list<ISaveable *>::iterator>(bufPosition);
  m_BufMemorySize = this->getDataMemorySize();
 
  return m_BufMemorySize;
}
 
void ISaveable::clearBufferState() {
  std::lock_guard<std::mutex> lock(m_setter);
 
  m_BufMemorySize = 0;
  m_BufPosition = boost::optional<std::list<ISaveable *>::iterator>();
}
 
} // namespace Mantid::Kernel