added MPI to dist.seqs command

[mothur.git] / mothurout.cpp

diff --git a/mothurout.cpp b/mothurout.cpp
index 0f4faed55e30930b7cc2d7f7cc6f91b06e38ba6f..fe6fd26b09765e43b1032632564401ae86f36c6c 100644 (file)
--- a/mothurout.cpp
+++ b/mothurout.cpp
@@ -20,7 +20,19 @@ MothurOut* MothurOut::getInstance() {
 void MothurOut::setFileName(string filename)  {
        try {
                logFileName = filename;
+               
+               #ifdef USE_MPI
+                       int pid;
+                       MPI_Comm_rank(MPI_COMM_WORLD, &pid); 
+                                       
+                       if (pid == 0) { //only one process should output to screen
+               #endif
+               
                openOutputFile(filename, out);
+               
+               #ifdef USE_MPI
+                       }
+               #endif
        }
        catch(exception& e) {
                errorOut(e, "MothurOut", "setFileName");
@@ -31,7 +43,19 @@ void MothurOut::setFileName(string filename)  {
 MothurOut::~MothurOut() {
        try {
                _uniqueInstance = 0;
+               
+               #ifdef USE_MPI
+                       int pid;
+                       MPI_Comm_rank(MPI_COMM_WORLD, &pid); 
+                                       
+                       if (pid == 0) { //only one process should output to screen
+               #endif
+               
                out.close();
+               
+               #ifdef USE_MPI
+                       }
+               #endif
        }
        catch(exception& e) {
                errorOut(e, "MothurOut", "MothurOut");
@@ -42,10 +66,20 @@ MothurOut::~MothurOut() {
 /*********************************************************************************************/
 void MothurOut::mothurOut(string output) {
        try {
-       
+               
+               #ifdef USE_MPI
+                       int pid;
+                       MPI_Comm_rank(MPI_COMM_WORLD, &pid); 
+                                       
+                       if (pid == 0) { //only one process should output to screen
+               #endif
+               
                cout << output;
                out << output;
                
+               #ifdef USE_MPI
+                       }
+               #endif
        }
        catch(exception& e) {
                errorOut(e, "MothurOut", "MothurOut");
@@ -55,8 +89,19 @@ void MothurOut::mothurOut(string output) {
 /*********************************************************************************************/
 void MothurOut::mothurOutEndLine() {
        try {
+               #ifdef USE_MPI
+                       int pid;
+                       MPI_Comm_rank(MPI_COMM_WORLD, &pid); 
+                                       
+                       if (pid == 0) { //only one process should output to screen
+               #endif
+               
                cout << endl;
                out << endl;
+               
+               #ifdef USE_MPI
+                       }
+               #endif
        }
        catch(exception& e) {
                errorOut(e, "MothurOut", "MothurOutEndLine");
@@ -66,7 +111,18 @@ void MothurOut::mothurOutEndLine() {
 /*********************************************************************************************/
 void MothurOut::mothurOutJustToLog(string output) {
        try {
+               #ifdef USE_MPI
+                       int pid;
+                       MPI_Comm_rank(MPI_COMM_WORLD, &pid); 
+                                       
+                       if (pid == 0) { //only one process should output to screen
+               #endif
+               
                out << output;
+               
+               #ifdef USE_MPI
+                       }
+               #endif
        }
        catch(exception& e) {
                errorOut(e, "MothurOut", "MothurOutJustToLog");