source: XIOS3/branches/xios-3.0-beta/src/buffer_client.hpp @ 2427

#ifndef __BUFFER_CLIENT_HPP__
#define __BUFFER_CLIENT_HPP__

#include "buffer_cs_base.hpp"
#include "xios_spl.hpp"
#include "buffer_out.hpp"
#include "mpi.hpp"
#include "cxios.hpp"

namespace xios
{
  class CClientBuffer : public CBufferClientServerBase
  {
    public:
      static size_t maxRequestSize;

      CClientBuffer(MPI_Comm intercomm, int serverRank, StdSize bufferSize, StdSize estimatedMaxEventSize);
      ~CClientBuffer();
//      void createWindows(MPI_Comm oneSidedComm) ;
      void freeWindows(void) ;
      void lockBuffer(void) ;
      void unlockBuffer(void) ;
      
      bool isBufferFree(StdSize size);
      CBufferOut* getBuffer(size_t timeLine, StdSize size);
      bool checkBuffer(bool send=false);
      bool hasPendingRequest(void);
      StdSize remain(void);
      MPI_Aint getWinAddress(int numWindows) ;
      void infoBuffer(void) ;
      bool isNotifiedFinalized(void) ;
      void setGrowableBuffer(double growFactor) { growFactor_=growFactor ; isGrowableBuffer_=true ;}
      void fixBufferSize(size_t bufferSize) { newBufferSize_=bufferSize ; isGrowableBuffer_=false ; resizingBufferStep_=1 ;}
      void fixBuffer(void) { isGrowableBuffer_=false ;}
      void attachWindows(vector<MPI_Win>& windows) ;
    private:
       void resizeBuffer(size_t newSize) ;
       void resizeBufferNotify(void) ;
       bool isNotifiedChangeBufferSize(void) ;


      char* buffer[2];
      char* bufferHeader[2];
      size_t* firstTimeLine[2] ;
      size_t* bufferCount[2] ;
      size_t* control[2] ;
      size_t* notify[2] ;
      bool winState[2] ;
      int current;
      
      double growFactor_=1.2 ;
      bool isGrowableBuffer_=true ;

      int resizingBufferStep_ = 0 ;
      size_t newBufferSize_ ;
      StdSize count;
      StdSize maxEventSize;
      StdSize bufferSize;
      const StdSize estimatedMaxEventSize;
      bool isFinalized_=false ;

      const int serverRank;
      const int clientRank_;
      bool pending;

      MPI_Request request;

      CBufferOut* retBuffer;
      const MPI_Comm interComm;
      std::vector<MPI_Win> windows_ ;
      bool hasWindows ;

      double latency_=0 ;
      double lastCheckedWithNothing_=0 ;
      double lastCheckedNotify_=0 ;
  };
}
#endif