savedata.h

Go to the documentation of this file.

#ifndef SAVEDATA_H
#define SAVEDATA_H

#include <boost/noncopyable.hpp>
#include <fstream>
#include <future>
#include <string>

#include "../clib/streamsaver.h"

namespace Pol
{
namespace Core
{
class SaveContext : boost::noncopyable
{
  // typedef Clib::ThreadedOFStreamWriter SaveStrategy; // too many context switches!
  typedef Clib::OFStreamWriter SaveStrategy;

private:
  std::ofstream _pol;
  std::ofstream _objects;
  std::ofstream _pcs;
  std::ofstream _pcequip;
  std::ofstream _npcs;
  std::ofstream _npcequip;
  std::ofstream _items;
  std::ofstream _multis;
  std::ofstream _storage;
  std::ofstream _resource;
  std::ofstream _guilds;
  std::ofstream _datastore;
  std::ofstream _party;

public:
  SaveContext();
  ~SaveContext();
  SaveStrategy pol;
  SaveStrategy objects;
  SaveStrategy pcs;
  SaveStrategy pcequip;
  SaveStrategy npcs;
  SaveStrategy npcequip;
  SaveStrategy items;
  SaveStrategy multis;
  SaveStrategy storage;
  SaveStrategy resource;
  SaveStrategy guilds;
  SaveStrategy datastore;
  SaveStrategy party;
  static std::shared_future<bool> finished;
  static void ready();
};

int save_incremental( unsigned int& dirty_writes, unsigned int& clean_objects,
                      long long& elapsed_ms );

void write_system_data( Clib::StreamWriter& sw );
void write_global_properties( Clib::StreamWriter& sw );
void write_shadow_realms( Clib::StreamWriter& sw );

bool commit( const std::string& basename );
void commit_incremental_saves();
bool should_write_data();
}
}
#endif