Skip to content

Commit

Permalink
Fix inconsistent line ending format.
Browse files Browse the repository at this point in the history
  • Loading branch information
@Alexander-Shukaev
Alexander-Shukaev committed Jan 30, 2015
1 parent 1240c24 commit 6a9e5db
Show file tree
Hide file tree
Showing 7 changed files with 2,939 additions and 2,932 deletions.
9 changes: 8 additions & 1 deletion .gitattributes
View file
Original file line number Diff line number Diff line change
@@ -1 +1,8 @@
* text=auto
* text=auto
*.c text
*.cpp text
*.dox text
*.h text
*.hpp text
*.py text
*.xml text
350 changes: 175 additions & 175 deletions src/com/MPICommunication.cpp
View file
Original file line number Diff line number Diff line change
@@ -1,197 +1,197 @@
// Copyright (C) 2011 Technische Universitaet Muenchen
// This file is part of the preCICE project. For conditions of distribution and
// use, please see the license notice at http://www5.in.tum.de/wiki/index.php/PreCICE_License
#ifndef PRECICE_NO_MPI

#include "MPICommunication.hpp"
#include "utils/Globals.hpp"

namespace precice {
namespace com {

tarch::logging::Log MPICommunication::
_log ("precice::com::MPICommunication");


MPICommunication:: MPICommunication
(
const MPI_Comm& communicator )
:
Communication (),
_communicator ( communicator )
#ifndef PRECICE_NO_MPI

#include "MPICommunication.hpp"
#include "utils/Globals.hpp"

namespace precice {
namespace com {

tarch::logging::Log MPICommunication::
_log ("precice::com::MPICommunication");


MPICommunication:: MPICommunication
(
const MPI_Comm& communicator )
:
Communication (),
_communicator ( communicator )
{
_rankOffset = 0;
}

void MPICommunication:: send
(
const std::string& itemToSend,
int rankReceiver )
{
}

void MPICommunication:: send
(
const std::string& itemToSend,
int rankReceiver )
{
preciceTrace2("send()", itemToSend, rankReceiver);
rankReceiver = rankReceiver - _rankOffset;
assertion(rankReceiver != ANY_SENDER);
int length = itemToSend.size();
preciceDebug( "Message length: " << length );
rankReceiver = rankReceiver - _rankOffset;
assertion(rankReceiver != ANY_SENDER);
int length = itemToSend.size();
preciceDebug( "Message length: " << length );
// const_cast is needed because MPI_Send expects a void* as first argument.
char *cstr = const_cast<char*>(itemToSend.c_str());
preciceDebug ("Message: " + std::string(cstr));
MPI_Send(cstr, length+1, MPI_CHAR, rankReceiver, 0, _communicator);
}

void MPICommunication:: send
(
int* itemsToSend,
int size,
int rankReceiver )
{
preciceDebug ("Message: " + std::string(cstr));
MPI_Send(cstr, length+1, MPI_CHAR, rankReceiver, 0, _communicator);
}

void MPICommunication:: send
(
int* itemsToSend,
int size,
int rankReceiver )
{
preciceTrace1 ( "send(int*)", size );
rankReceiver = rankReceiver - _rankOffset;
assertion ( rankReceiver != ANY_SENDER );
MPI_Send ( itemsToSend, size, MPI_INT, rankReceiver, 0, _communicator );
}

void MPICommunication:: send
(
double* itemsToSend,
int size,
int rankReceiver )
{
rankReceiver = rankReceiver - _rankOffset;
assertion ( rankReceiver != ANY_SENDER );
MPI_Send ( itemsToSend, size, MPI_INT, rankReceiver, 0, _communicator );
}

void MPICommunication:: send
(
double* itemsToSend,
int size,
int rankReceiver )
{
preciceTrace1 ( "send(double*)", size );
rankReceiver = rankReceiver - _rankOffset;
assertion ( rankReceiver != ANY_SENDER );
MPI_Send ( itemsToSend, size, MPI_DOUBLE, rankReceiver, 0, _communicator );
}

void MPICommunication:: send
(
double itemToSend,
int rankReceiver )
{
rankReceiver = rankReceiver - _rankOffset;
assertion ( rankReceiver != ANY_SENDER );
MPI_Send ( itemsToSend, size, MPI_DOUBLE, rankReceiver, 0, _communicator );
}

void MPICommunication:: send
(
double itemToSend,
int rankReceiver )
{
preciceTrace2 ( "send(double)", itemToSend, rankReceiver );
rankReceiver = rankReceiver - _rankOffset;
assertion ( rankReceiver != ANY_SENDER );
MPI_Send (&itemToSend, 1, MPI_DOUBLE, rankReceiver, 0, _communicator);
}

void MPICommunication:: send
(
int itemToSend,
int rankReceiver )
{
rankReceiver = rankReceiver - _rankOffset;
assertion ( rankReceiver != ANY_SENDER );
MPI_Send (&itemToSend, 1, MPI_DOUBLE, rankReceiver, 0, _communicator);
}

void MPICommunication:: send
(
int itemToSend,
int rankReceiver )
{
preciceTrace2 ( "send(int)", itemToSend, rankReceiver );
rankReceiver = rankReceiver - _rankOffset;
assertion ( rankReceiver != ANY_SENDER );
MPI_Send (&itemToSend, 1, MPI_INT, rankReceiver, 0, _communicator);
}

void MPICommunication:: send
(
bool itemToSend,
int rankReceiver )
{
rankReceiver = rankReceiver - _rankOffset;
assertion ( rankReceiver != ANY_SENDER );
MPI_Send (&itemToSend, 1, MPI_INT, rankReceiver, 0, _communicator);
}

void MPICommunication:: send
(
bool itemToSend,
int rankReceiver )
{
preciceTrace2 ( "send(bool)", itemToSend, rankReceiver );
rankReceiver = rankReceiver - _rankOffset;
assertion ( rankReceiver != ANY_SENDER );
int buffer = itemToSend ? 1 : 0;
MPI_Send ( &buffer, 1, MPI_INT, rankReceiver, 0, _communicator );
}

int MPICommunication:: receive
(
std::string& itemToReceive,
int rankSender )
{
rankReceiver = rankReceiver - _rankOffset;
assertion ( rankReceiver != ANY_SENDER );
int buffer = itemToSend ? 1 : 0;
MPI_Send ( &buffer, 1, MPI_INT, rankReceiver, 0, _communicator );
}

int MPICommunication:: receive
(
std::string& itemToReceive,
int rankSender )
{
preciceTrace2("receive(string)", itemToReceive, rankSender);
rankSender = rankSender - _rankOffset;
int length;
MPI_Status status;
rankSender = rankSender == ANY_SENDER ? MPI_ANY_SOURCE : rankSender;
rankSender = rankSender - _rankOffset;
int length;
MPI_Status status;
rankSender = rankSender == ANY_SENDER ? MPI_ANY_SOURCE : rankSender;
MPI_Probe(rankSender, 0, _communicator, &status);
MPI_Get_count(&status, MPI_CHAR, &length);
rankSender = status.MPI_SOURCE;
preciceDebug( "Stringlength = " << length );
rankSender = status.MPI_SOURCE;
preciceDebug( "Stringlength = " << length );
char cstr[length];
MPI_Recv(cstr, length, MPI_CHAR, rankSender, 0, _communicator, MPI_STATUS_IGNORE);
itemToReceive = std::string(cstr);
preciceDebug("Received \"" << itemToReceive << "\" from rank " << rankSender);
return rankSender;
}

int MPICommunication:: receive
(
int* itemsToReceive,
int size,
int rankSender )
{
MPI_Recv(cstr, length, MPI_CHAR, rankSender, 0, _communicator, MPI_STATUS_IGNORE);
itemToReceive = std::string(cstr);
preciceDebug("Received \"" << itemToReceive << "\" from rank " << rankSender);
return rankSender;
}

int MPICommunication:: receive
(
int* itemsToReceive,
int size,
int rankSender )
{
preciceTrace1 ( "receive(int*)", size );
rankSender = rankSender - _rankOffset;
rankSender = rankSender == ANY_SENDER ? MPI_ANY_SOURCE : rankSender;
MPI_Status status;
MPI_Recv ( itemsToReceive, size, MPI_INT, rankSender, 0, _communicator, &status );
return status.MPI_SOURCE;
}

int MPICommunication:: receive
(
double * itemsToReceive,
int size,
int rankSender )
{
rankSender = rankSender - _rankOffset;
rankSender = rankSender == ANY_SENDER ? MPI_ANY_SOURCE : rankSender;
MPI_Status status;
MPI_Recv ( itemsToReceive, size, MPI_INT, rankSender, 0, _communicator, &status );
return status.MPI_SOURCE;
}

int MPICommunication:: receive
(
double * itemsToReceive,
int size,
int rankSender )
{
preciceTrace1 ( "receive(double*)", size );
rankSender = rankSender - _rankOffset;
rankSender = rankSender == ANY_SENDER ? MPI_ANY_SOURCE : rankSender;
MPI_Status status;
MPI_Recv ( itemsToReceive, size, MPI_DOUBLE, rankSender, 0, _communicator, &status );
return status.MPI_SOURCE;
}

int MPICommunication:: receive
(
double & itemToReceive,
int rankSender )
{
rankSender = rankSender - _rankOffset;
rankSender = rankSender == ANY_SENDER ? MPI_ANY_SOURCE : rankSender;
MPI_Status status;
MPI_Recv ( itemsToReceive, size, MPI_DOUBLE, rankSender, 0, _communicator, &status );
return status.MPI_SOURCE;
}

int MPICommunication:: receive
(
double & itemToReceive,
int rankSender )
{
preciceTrace1 ( "receive(double)", rankSender );
rankSender = rankSender - _rankOffset;
rankSender = rankSender == ANY_SENDER ? MPI_ANY_SOURCE : rankSender;
MPI_Status status;
MPI_Recv (&itemToReceive, 1, MPI_DOUBLE, rankSender, 0, _communicator, &status);
preciceDebug ( "Received " << itemToReceive << " from rank " << status.MPI_SOURCE );
return status.MPI_SOURCE;
}

int MPICommunication:: receive
(
int & itemToReceive,
int rankSender )
{
rankSender = rankSender - _rankOffset;
rankSender = rankSender == ANY_SENDER ? MPI_ANY_SOURCE : rankSender;
MPI_Status status;
MPI_Recv (&itemToReceive, 1, MPI_DOUBLE, rankSender, 0, _communicator, &status);
preciceDebug ( "Received " << itemToReceive << " from rank " << status.MPI_SOURCE );
return status.MPI_SOURCE;
}

int MPICommunication:: receive
(
int & itemToReceive,
int rankSender )
{
preciceTrace1 ( "receive(int)", rankSender );
rankSender = rankSender - _rankOffset;
rankSender = rankSender == ANY_SENDER ? MPI_ANY_SOURCE : rankSender;
MPI_Status status;
MPI_Recv (&itemToReceive, 1, MPI_INT, rankSender, 0,
_communicator, &status);
preciceDebug ( "Received " << itemToReceive << " from rank " << status.MPI_SOURCE );
return status.MPI_SOURCE;
}

int MPICommunication:: receive
(
bool & itemToReceive,
int rankSender )
{
rankSender = rankSender - _rankOffset;
rankSender = rankSender == ANY_SENDER ? MPI_ANY_SOURCE : rankSender;
MPI_Status status;
MPI_Recv (&itemToReceive, 1, MPI_INT, rankSender, 0,
_communicator, &status);
preciceDebug ( "Received " << itemToReceive << " from rank " << status.MPI_SOURCE );
return status.MPI_SOURCE;
}

int MPICommunication:: receive
(
bool & itemToReceive,
int rankSender )
{
preciceTrace1 ( "receive(bool)", rankSender );
rankSender = rankSender - _rankOffset;
rankSender = rankSender == ANY_SENDER ? MPI_ANY_SOURCE : rankSender;
MPI_Status status;
int buffer = -1;
MPI_Recv ( &buffer, 1, MPI_INT, rankSender, 0, _communicator, &status );
assertion ( buffer != -1 );
itemToReceive = (buffer == 1) ? true : false;
preciceDebug ( "Received " << itemToReceive << " from rank " << status.MPI_SOURCE );
return status.MPI_SOURCE;
}

}} // namespace precice, com

#endif // not PRECICE_NO_MPI
rankSender = rankSender - _rankOffset;
rankSender = rankSender == ANY_SENDER ? MPI_ANY_SOURCE : rankSender;
MPI_Status status;
int buffer = -1;
MPI_Recv ( &buffer, 1, MPI_INT, rankSender, 0, _communicator, &status );
assertion ( buffer != -1 );
itemToReceive = (buffer == 1) ? true : false;
preciceDebug ( "Received " << itemToReceive << " from rank " << status.MPI_SOURCE );
return status.MPI_SOURCE;
}

}} // namespace precice, com

#endif // not PRECICE_NO_MPI
Expand Down
Loading

0 comments on commit 6a9e5db

Please sign in to comment.