X-Git-Url: https://git.donarmstrong.com/?a=blobdiff_plain;f=prcseqscommand.cpp;fp=prcseqscommand.cpp;h=4d5b6d963a026433c5851de6d444edc524cd6d1a;hb=14cddf859d97118481161bf3e85a647976020758;hp=5fc9f988be038bb02a724e38cc11b2d9ddf1fa3e;hpb=4b54ce99af7db8019ea907cd7c2edf789369ada9;p=mothur.git

diff --git a/prcseqscommand.cpp b/prcseqscommand.cpp
index 5fc9f98..4d5b6d9 100644
--- a/prcseqscommand.cpp
+++ b/prcseqscommand.cpp
@@ -516,6 +516,9 @@ int PcrSeqsCommand::createProcesses(string filename, string goodFileName, string
 		//Close all thread handles and free memory allocations.
 		for(int i=0; i < pDataArray.size(); i++){
 			num += pDataArray[i]->count;
+            if (pDataArray[i]->count != pDataArray[i]->fend) {
+                m->mothurOut("[ERROR]: process " + toString(i) + " only processed " + toString(pDataArray[i]->count) + " of " + toString(pDataArray[i]->fend) + " sequences assigned to it, quitting. \n"); m->control_pressed = true; 
+            }
             for (set<string>::iterator it = pDataArray[i]->badSeqNames.begin(); it != pDataArray[i]->badSeqNames.end(); it++) {	badSeqNames.insert(*it);       }
 			CloseHandle(hThreadArray[i]);
 			delete pDataArray[i];