Commented out debugging code from inside the CharmMessageHolder class inside
[charm.git] / src / conv-com / StreamingStrategy.C
index 001ea4d256e8fa8be2b9475e2039b484f1a83f56..b9e09d3c95b1071d4e9fec9e6cd6dd3a666fd84e 100644 (file)
@@ -78,7 +78,7 @@ void StreamingStrategy::insertMessage(MessageHolder *cmsg) {
     streamingMsgBuf[pe].enq(cmsg);
     streamingMsgCount[pe]++;
     bufSize[pe]+=size;
-    if (streamingMsgCount[pe] > bufferMax || bufSize[pe] > bufSizeMax) flushPE(pe);
+    if (streamingMsgCount[pe] >= bufferMax || bufSize[pe] >= bufSizeMax) flushPE(pe);
 }
 
 void StreamingStrategy::doneInserting() {