commpi.C File Reference

Contains a dummy implementation of MPI subroutines for one thread. More...

#include "commpi.h"
#include <cstring>
#include <cstdlib>
#include <iostream>
#include <map>

Include dependency graph for commpi.C:

Go to the source code of this file.

Typedefs
typedef std::map< int, void * >	Msg_Queue
	A map from message tags to data addresses. More...

Functions
static int	get_sizeof (MPI_Datatype i) throw (int)
	Get the size of a given MPI data type. More...
int	COM_send (Msg_Queue &sendQ, Msg_Queue &recvQ, void *buf, int count, MPI_Datatype datatype, int tag)
int	COM_recv (Msg_Queue &sendQ, Msg_Queue &recvQ, void *buf, int count, MPI_Datatype datatype, int tag)
int	COMMPI_Isend (void *buf, int count, MPI_Datatype datatype, int dest, int tag, MPI_Comm comm, MPI_Request *request)
	Begins a nonblocking send. More...
int	COMMPI_Irecv (void *buf, int count, MPI_Datatype datatype, int src, int tag, MPI_Comm comm, MPI_Request *request)
	Begins a nonblocking receive. More...

Variables
static Msg_Queue *	sendQ =NULL
static Msg_Queue *	recvQ =NULL

Detailed Description

Contains a dummy implementation of MPI subroutines for one thread.

If DUMMY_MPI is not define, it does produce anything. Note: This implementation is not thread-safe and it need not to be because it is only intended for a placeholder of MPI for one thread. It works even if MPI_Init was not called.

See Also

commpi.h

Definition in file commpi.C.

Typedef Documentation

typedef std::map<int, void*> Msg_Queue

A map from message tags to data addresses.

Definition at line 41 of file commpi.C.

Function Documentation

int COM_recv	(	Msg_Queue &	sendQ,
		Msg_Queue &	recvQ,
		void *	buf,
		int	count,
		MPI_Datatype	datatype,
		int	tag
	)

Definition at line 88 of file commpi.C.

References get_sizeof().

Referenced by COMMPI_Irecv().

                                                                     {
  try {
    Msg_Queue::iterator it;
    if ( (it=sendQ.find( tag)) != sendQ.end()) {
      int extent=count*get_sizeof(datatype);
      std::memcpy( buf, it->second, extent);
      sendQ.erase(it);
    }
    else
      recvQ[tag] = buf;
  }
  catch (int) {
    std::cerr << "Unsupported data type " << datatype 
              << " used for MPI_Irecv" << std::endl;
    std::abort();
  }
  return 0;
}

Here is the call graph for this function:

Here is the caller graph for this function:

int COM_send	(	Msg_Queue &	sendQ,
		Msg_Queue &	recvQ,
		void *	buf,
		int	count,
		MPI_Datatype	datatype,
		int	tag
	)

Definition at line 68 of file commpi.C.

References get_sizeof().

Referenced by COMMPI_Isend().

                                                                    {
  try {
    Msg_Queue::iterator it;
    if ( (it=recvQ.find( tag)) != recvQ.end()) {
      int extent=count*get_sizeof(datatype);
      std::memcpy( it->second, (char*)buf, extent);
      recvQ.erase(it);
    }
    else
      sendQ[tag] = buf;
  }
  catch (int) {
    std::cerr << "Unsupported data type " << datatype 
              << " used for MPI_Isend" << std::endl;
    std::abort();
  }
  return 0;
}

Here is the call graph for this function:

Here is the caller graph for this function:

int COMMPI_Irecv	(	void *	buf,
		int	count,
		MPI_Datatype	datatype,
		int	src,
		int	tag,
		MPI_Comm	comm,
		MPI_Request *	request
	)

Begins a nonblocking receive.

Definition at line 131 of file commpi.C.

References COM_recv(), and COMMPI_Initialized().

Referenced by Pane_communicator::begin_update(), and Pane_ghost_connectivity::send_pane_info().

                                                        { 
#ifndef DUMMY_MPI
  if ( COMMPI_Initialized())
    return MPI_Irecv( buf, count, datatype, src, tag, comm, request);
#endif
  try {
    if ( sendQ == NULL) sendQ = new Msg_Queue();
    if ( recvQ == NULL) recvQ = new Msg_Queue();
  }
  catch (...) {
    std::cerr << "Out of memory" << std::endl;
    std::abort();
  }
  return COM_recv( *sendQ, *recvQ, buf, count, datatype, tag);
}

Here is the call graph for this function:

Here is the caller graph for this function:

int COMMPI_Isend	(	void *	buf,
		int	count,
		MPI_Datatype	datatype,
		int	dest,
		int	tag,
		MPI_Comm	comm,
		MPI_Request *	request
	)

Begins a nonblocking send.

Definition at line 112 of file commpi.C.

References COM_send(), and COMMPI_Initialized().

Referenced by Pane_communicator::begin_update(), and Pane_ghost_connectivity::send_pane_info().

                                                        {
#ifndef DUMMY_MPI
  if ( COMMPI_Initialized())
    return MPI_Isend( buf, count, datatype, dest, tag, comm, request);
#endif
  try {
    if ( sendQ == NULL) sendQ = new Msg_Queue();
    if ( recvQ == NULL) recvQ = new Msg_Queue();
  }
  catch (...) {
    std::cerr << "Out of memory" << std::endl;
    std::abort();
  }
  return COM_send( *sendQ, *recvQ, buf, count, datatype, tag); 
}

Here is the call graph for this function:

Here is the caller graph for this function:

static int get_sizeof ( MPI_Datatype  i ) throw ( int )

static

Get the size of a given MPI data type.

Definition at line 44 of file commpi.C.

References i, and MPI_BYTE.

Referenced by Attribute::allocate(), COM_get_sizeof(), COM_recv(), COM_send(), Attribute::copy_array(), Attribute::inherit(), io_hdf_data(), io_pane_attribute(), Roccom_base::set_f90pointer(), Attribute::set_pointer(), and write_attr_CGNS().

                                                  {
  if(i == MPI_DOUBLE)
    return(sizeof(double));
  else if(i == MPI_FLOAT)
    return(sizeof(float));
  else if(i == MPI_INT)
    return(sizeof(int));
  else if(i == MPI_BYTE)
    return(sizeof(char));
  else if(i == MPI_CHAR)
    return(sizeof(char));
  else 
    throw(-1);
}

Here is the caller graph for this function:

Variable Documentation

Msg_Queue* recvQ =NULL

static

Definition at line 109 of file commpi.C.

Msg_Queue* sendQ =NULL

static

Definition at line 108 of file commpi.C.