worked on trim.seqs

[mothur.git] / collectcommand.cpp

diff --git a/collectcommand.cpp b/collectcommand.cpp
index d8da50e0d2f559f25657008d046e7ec6951c4552..cf8ba10e8e43054304c42892cbfb9c2014a8da1f 100644 (file)
--- a/collectcommand.cpp
+++ b/collectcommand.cpp
@@ -140,7 +140,9 @@ int CollectCommand::execute(){
                else {  inputFileNames = parseSharedFile(globaldata->getSharedFile());  globaldata->setFormat("rabund");  }
        
                for (int p = 0; p < inputFileNames.size(); p++) {
-               
+                       
+                       if (m->control_pressed) {  for (int i = 0; i < outputNames.size(); i++) {       remove(outputNames[i].c_str());         }  globaldata->Groups.clear(); return 0; }
+                       
                        if (outputDir == "") { outputDir += hasPath(inputFileNames[p]); }
                        string fileNameRoot = outputDir + getRootName(getSimpleName(inputFileNames[p]));
                        globaldata->inputFileName = inputFileNames[p];
@@ -230,16 +232,40 @@ int CollectCommand::execute(){
                        //if the users enters label "0.06" and there is no "0.06" in their file use the next lowest label.
                        set<string> processedLabels;
                        set<string> userLabels = labels;
+                       
+                       if (m->control_pressed) {  
+                               for(int i=0;i<cDisplays.size();i++){    delete cDisplays[i];    }
+                               for (int i = 0; i < outputNames.size(); i++) {  remove(outputNames[i].c_str());         }
+                               delete input;  globaldata->ginput = NULL;
+                               delete read;
+                               delete order; globaldata->gorder = NULL;
+                               delete validCalculator;
+                               globaldata->Groups.clear();
+                               return 0;
+                       }
+
 
                        while((order != NULL) && ((allLines == 1) || (userLabels.size() != 0))) {
+                       
+                               if (m->control_pressed) { 
+                                       for(int i=0;i<cDisplays.size();i++){    delete cDisplays[i];    }
+                                       for (int i = 0; i < outputNames.size(); i++) {  remove(outputNames[i].c_str());         }
+                                       delete input;  globaldata->ginput = NULL;
+                                       delete read;
+                                       delete order; globaldata->gorder = NULL;
+                                       delete validCalculator;
+                                       globaldata->Groups.clear();
+                                       return 0;
+                               }
+
                                
                                if(allLines == 1 || labels.count(order->getLabel()) == 1){
-                                       
+                               
+                                       m->mothurOut(order->getLabel()); m->mothurOutEndLine();
                                        cCurve = new Collect(order, cDisplays);
                                        cCurve->getCurve(freq);
                                        delete cCurve;
                                        
-                                       m->mothurOut(order->getLabel()); m->mothurOutEndLine();
                                        processedLabels.insert(order->getLabel());
                                        userLabels.erase(order->getLabel());
                                        
@@ -252,11 +278,12 @@ int CollectCommand::execute(){
                                        delete order;
                                        order = (input->getOrderVector(lastLabel));
                                        
+                                       m->mothurOut(order->getLabel()); m->mothurOutEndLine();
                                        cCurve = new Collect(order, cDisplays);
                                        cCurve->getCurve(freq);
                                        delete cCurve;
                                        
-                                       m->mothurOut(order->getLabel()); m->mothurOutEndLine();
+                                       
                                        processedLabels.insert(order->getLabel());
                                        userLabels.erase(order->getLabel());
                                        
@@ -270,6 +297,17 @@ int CollectCommand::execute(){
                                order = (input->getOrderVector());
                        }
                        
+                       
+                       if (m->control_pressed) { 
+                                       for(int i=0;i<cDisplays.size();i++){    delete cDisplays[i];    }
+                                       for (int i = 0; i < outputNames.size(); i++) {  remove(outputNames[i].c_str());         }
+                                       delete input;  globaldata->ginput = NULL;
+                                       delete read;
+                                       delete validCalculator;
+                                       globaldata->Groups.clear();
+                                       return 0;
+                       }
+                               
                        //output error messages about any remaining user labels
                        set<string>::iterator it;
                        bool needToRun = false;
@@ -293,6 +331,17 @@ int CollectCommand::execute(){
                                cCurve = new Collect(order, cDisplays);
                                cCurve->getCurve(freq);
                                delete cCurve;
+                               
+                               if (m->control_pressed) { 
+                                       for(int i=0;i<cDisplays.size();i++){    delete cDisplays[i];    }
+                                       for (int i = 0; i < outputNames.size(); i++) {  remove(outputNames[i].c_str());         }
+                                       delete input;  globaldata->ginput = NULL;
+                                       delete read;
+                                       delete order; globaldata->gorder = NULL;
+                                       delete validCalculator;
+                                       globaldata->Groups.clear();
+                                       return 0;
+                               }
                                delete order;
                        }
                        
@@ -304,6 +353,8 @@ int CollectCommand::execute(){
                        delete validCalculator;
                }
                
+               if (m->control_pressed) { for (int i = 0; i < outputNames.size(); i++) {        remove(outputNames[i].c_str());         } return 0; }
+
                m->mothurOutEndLine();
                m->mothurOut("Output File Names: "); m->mothurOutEndLine();
                for (int i = 0; i < outputNames.size(); i++) {  m->mothurOut(outputNames[i]); m->mothurOutEndLine();    }