u3d_migr_io.hpp

/* u3d_migr_io.hpp */
/* $Id: u3d_migr_io.hpp,v 1.1 2008/05/13 12:19:18 sad Exp $ */

#ifndef __u3d_migr_io_hpp
#define __u3d_migr_io_hpp

#include "u3d_migr_defines.hpp"


#include <ios>
#include <vector>


/* ========== GLOBAL PROCEDURES =========== */

bool   saveCube(bool is_SP, int num, MigrCell *grid, int size, int prog_id, bool local=false);

bool   loadCube(bool is_SP, int num, MigrCell *&grid, int &size, int prog_id, bool local=false);

char*  getTmpFilePath(const char* name, int prog_id, bool local=false);


char*  getTmpFilePathLocal(const char* name, int prog_id);


void   deleteTmpFiles(int spN, int recN, int prog_id);


void   deleteTmpFilesLocal(int recN, int prog_id);



/* ========== DEBUG =========== */
bool   saveC(bool is_SP, int num, MigrCell *grid, int size, int prog_id);
bool   loadC(bool is_SP, int num, MigrCell *&grid, int &size, int prog_id);
bool   getTmpFileName(const char* name, int prog_id, char *&result_name);
/* ========== DEBUG =========== */



class IPDataStorage {
public:
  
  class IPFile {     
  public:      
    IPFile(const char* name, bool createFile) throw (std::ios_base::failure);
    void write(IPCell* ipcells, int size);
    void reduce(int size); // server
    void read(long pos, int size, IPCell** ipcells); //client
    long size() { return fsize - curpos; };
    long tellpos() { return curpos; };
    void deletefile();
    // compare() returns true if files are equal
    bool compare(const IPFile& other, FILE* result_file); // result_file must be already opened for appending text file
  private:
    std::string fname;
    long fsize;
    long curpos;
  };
  
  
  IPDataStorage(int sp_num, int mpid, bool haveToCreateFiles);
  
  int size() { return m_sp_num; };
  
  const std::vector<int>&          getBadSPs()      { return errspnums; };
  const std::vector<std::string>&  getErrmessages() { return errmessages; };
  
  
  IPFile& operator[](int n) { return ipfiles[n]; };
  
  // Returns true if equal
  bool compare(const IPDataStorage& other, const char* result_file);

  // Recalculates size of all files
  void recalculateSize();
  
  // Recalculates size of file with number n
  void recalculateSize(int n);
  
  // Only for server side!
  void clear();
  
  
  ~IPDataStorage();
  
private:
  const int m_sp_num;
  const int m_pid;
  
  IPFile* ipfiles;
  
  std::vector<std::string> errmessages;
  std::vector<int> errspnums;
};






/* ------------ DEBUG ---------------- */

void   saveIPCube(MigrDataCube migr_cube, ushort i_max, ushort j_max, ushort k_max, int prog_id, int sp_num);
  
  
#endif