amroc/hds/CommIOServer.h

Go to the documentation of this file.

// -*- C++ -*-

#ifndef _included_CommIOServer_h
#define _included_CommIOServer_h

#include "DAGHParams.h"
#include "DAGHIOParams.h"
#include "PackedGridDataBucket.h"
#include "CommServer.h"

class GridHierarchy;

#define DAGHIOServerRcvNULL     ((DAGHIOServerRcv *) 0)
#define DAGHIOServerSndNULL     ((DAGHIOServerSnd *) 0)
#define DAGHIOServerPingNULL    ((DAGHIOServerPing *) 0)

class DAGHIOServerRcv : public comm_service 
  {
public:
   GridHierarchy& gh;
   int Size;
   DAGHIO_WriteFunc wf;
   int end_cnt;

   DAGHIOServerRcv(const unsigned tag, GridHierarchy& gridhierarchy, 
                   DAGHIO_WriteFunc writefunc);
   void callrecv( const MPI_Status & );
   void rcv_update( void * );
   inline void Set_DAGHIOWriteFunc(DAGHIO_WriteFunc writefunc) { wf = writefunc; }
   const char * name(void) const;
  };

class DAGHIOServerSnd : public comm_service 
  {
public:
   GridHierarchy& gh;
   int Size;
   DAGHIO_ReadFunc rf;
   int end_cnt;

   DAGHIOServerSnd(const unsigned tag, GridHierarchy& gridhierarchy, 
                   DAGHIO_ReadFunc readfunc);
   void callrecv( const MPI_Status & );
   void snd_update( void * );
   inline void Set_DAGHIOReadFunc(DAGHIO_ReadFunc readfunc) { rf = readfunc; }
   const char * name(void) const;
  };

class DAGHIOServerPing : public comm_service 
  {
   GridHierarchy& gh;
   DAGHIO_PingFunc pf;
   int flag;
   int end_cnt;
public:
   DAGHIOServerPing(const unsigned tag, GridHierarchy& gridhierarchy, 
                    DAGHIO_PingFunc pingfunc);
   void callrecv( const MPI_Status & );
   const char * name(void) const;
  };

#endif

---