Add member and env variable to disable pipelined buffers

tapioca.cpp

@@ -79,6 +79,7 @@ void Tapioca::SetDefaultValues ()
   this->currentDataSize_ = 0;
   this->nCommit_ = 0;
   this->writeDevNull_ = false;
+  this->pipelinedBuffers_ = true;
   /* DEBUG */
 }
 
@@ -90,6 +91,7 @@ void Tapioca::ParseEnvVariables ()
   char *envBufferSize = getenv("TAPIOCA_BUFFERSIZE");
   char *envSplit      = getenv("TAPIOCA_COMMSPLIT");
   char *envDevNull    = getenv("TAPIOCA_DEVNULL");
+  char *envPipelining = getenv("TAPIOCA_PIPELINING");
   
   if (envStrategy != NULL) {
     strcmp(envStrategy, "SHORTEST_PATH")    ? 0 : this->strategy_ = SHORTEST_PATH;
@@ -116,6 +118,11 @@ void Tapioca::ParseEnvVariables ()
     strcmp(envDevNull, "true")  ? 0 : this->writeDevNull_ = true;
     strcmp(envDevNull, "false") ? 0 : this->writeDevNull_ = false;
   }
+
+  if (envPipelining != NULL) {
+    strcmp(envPipelining, "true")  ? 0 : this->pipelinedBuffers_ = true;
+    strcmp(envPipelining, "false") ? 0 : this->pipelinedBuffers_ = false;
+  }
 }
 
 

tapioca.hpp

@@ -173,6 +173,7 @@ class Tapioca
   bool writeDevNull_;
   MPI_File devNullFileHandle_;
 
+  bool pipelinedBuffers_;
   /* TIMING */
   double startAggrTime, endAggrTime, totAggrTime;
   double startIOTime, endIOTime, totIOTime;