Skip to content
Snippets Groups Projects
MpiBodyComm.hpp 642 B
Newer Older
#ifndef COMM_BUFFER_HPP
#define COMM_BUFFER_HPP

#include <mpi.h>
#include <vector>
#include "../datastructures/Body.hpp"

namespace nbody {
	using namespace std;

	class MpiBodyComm {
	protected:
		MPI_Datatype* datatype;
		MPI_Request request;
Paul Heinzlreiter's avatar
Paul Heinzlreiter committed
		vector<Body> buffer;
	public:
		MpiBodyComm(MPI_Datatype* bodyDatatype);
		virtual ~MpiBodyComm();
		virtual void cleanup();
Paul Heinzlreiter's avatar
Paul Heinzlreiter committed
		virtual void sendBlocking(int target, vector<Body> bodies);
		virtual void recvBlocking(int source, vector<Body>& bodies);
Paul Heinzlreiter's avatar
Paul Heinzlreiter committed
		virtual bool sendUnblocking(int target, vector<Body> bodies);
Paul Heinzlreiter's avatar
Paul Heinzlreiter committed
		virtual bool recvUnblocking(int source, vector<Body>& bodies);