source: XIOS3/trunk/src/buffer_server.hpp @ 2628

#ifndef __BUFFER_SERVER_HPP__
#define __BUFFER_SERVER_HPP__

#include "buffer_cs_base.hpp"
#include "xios_spl.hpp"
#include "buffer.hpp"
#include "mpi.hpp"
#include "cxios.hpp"
#include "window_dynamic.hpp"


namespace xios
{
  class CServerBuffer : public CBufferClientServerBase
  {
    public:
      CServerBuffer(int clientRank, vector<CWindowDynamic*>& windows, vector<MPI_Aint>& winAddress, int windowsRank, StdSize bufSize) ;
      ~CServerBuffer() ;

      bool isBufferFree(size_t count) ;
      bool isResizing(void) { return resizingBuffer_ ;}
      void* getBuffer(size_t count) ;
      void freeBuffer(size_t count) ;
      void popBuffer(size_t count) ;
      void createWindows(MPI_Comm oneSidedComm) ;
      bool getBufferFromClient(size_t timeLine, char* & buffer, size_t& count) ;
      bool isBufferEmpty(void) ;
      void updateCurrentWindows(void) ;
      void lockBuffer(void) ;
      void unlockBuffer(void) ;
      void notifyClientFinalize(void) ;
      void notifyBufferResizing(void) ;
      size_t getUsed(void) { return used ;}
    private:
      char* buffer;
      size_t first;   // first occupied element
      size_t current; // first free element
      size_t end;
      size_t size;
      size_t used ;  // count of element occupied
      std::vector<CWindowDynamic*> windows_ ;
      std::vector<MPI_Aint> winAddress_ ;
      bool resizingBuffer_ = false ;
      int currentWindows ;
      bool hasWindows ;
      int clientRank_ ; // for debugging
      int windowsRank_ ;
      double bufferFromClientLatency_=1e-1 ;
      double bufferFromClientTime_ = 0;

  };
}

#endif