added cluster.split command

[mothur.git] / engine.cpp

diff --git a/engine.cpp b/engine.cpp
index 9e5801b1b057b2f2a1cc4a986e105ae3e73f14b5..90103eae920da6cd225e03606fcb2bf3d6198e2e 100644 (file)
--- a/engine.cpp
+++ b/engine.cpp
@@ -73,6 +73,8 @@ bool InteractEngine::getInput(){
                                        int pid;
                                        MPI_Comm_rank(MPI_COMM_WORLD, &pid); 
                                        
+                                       MPI_Barrier(MPI_COMM_WORLD); //make everyone wait - just in case
+                               
                                        if ((cFactory->MPIEnabled(commandName)) || (pid == 0)) {
                                #endif
                                //executes valid command
@@ -200,7 +202,9 @@ bool BatchEngine::getInput(){
                                        #ifdef USE_MPI
                                                int pid;
                                                MPI_Comm_rank(MPI_COMM_WORLD, &pid); 
-                                       
+cout << pid << " is waiting " << commandName << endl;                                          
+                                               MPI_Barrier(MPI_COMM_WORLD); //make everyone wait - just in case
+cout << pid << " is here " << commandName << endl;
                                                if ((cFactory->MPIEnabled(commandName)) || (pid == 0)) {
                                        #endif
                                        //executes valid command
@@ -292,6 +296,8 @@ bool ScriptEngine::getInput(){
                                        int pid;
                                        MPI_Comm_rank(MPI_COMM_WORLD, &pid); 
                                        
+                                       MPI_Barrier(MPI_COMM_WORLD); //make everyone wait - just in case
+                                       
                                        if ((cFactory->MPIEnabled(commandName)) || (pid == 0)) {
                                #endif
                                //executes valid command