amroc/hds/CommRcvServer.h

Go to the documentation of this file.

// -*- C++ -*-

#ifndef _included_GridTableCommRcv_h
#define _included_GridTableCommRcv_h

#include "DAGHParams.h"
#include "CommServer.h"
#include "GridTable.h"

//#include <iosfwd>
#include <cstdlib>

#define GridTableGhostRcvNULL   ((GridTableGhostRcv *) 0)
#define GridTableDataRcvNULL    ((GridTableDataRcv *) 0)

class GridTableGhostRcv : public comm_service 
  {
public:
   GridTable &Table;
   char *Request;
   const unsigned Size;
   short rcvflag;

   GridTableGhostRcv(GridTable& GT, 
                     const unsigned tag, 
                     const unsigned size, 
                     const int src=MPI_ANY_SOURCE);

   inline ~GridTableGhostRcv()
     { if ( Request ) delete [] Request; }

   void rcv_update( void * );
   void callrecv( const MPI_Status & );
   void callrecvNpost( const MPI_Status & );
   void postrcv();
   int received() { return (rcvflag == DAGHTrue); }
   const char * name() const;
  };

class GridTableDataRcv : public comm_service 
  {
public:
   GridTable &Table;
   char *Request;
   const unsigned Size;
   short rcvflag;

   GridTableDataRcv(GridTable& GT, 
                    const unsigned tag, 
                    const unsigned size, 
                    const int src=MPI_ANY_SOURCE);

   inline ~GridTableDataRcv()
     { if ( Request ) delete [] Request; }

   void rcv_update( void * );
   void callrecv( const MPI_Status & );
   void callrecvNpost( const MPI_Status & );
   void postrcv();
   int received() { return (rcvflag == DAGHTrue); }
   const char * name() const;
  };

// std::ostream & operator << ( std::ostream & , const MPI_Status & );

#endif

---