X-Git-Url: https://git.donarmstrong.com/?p=mothur.git;a=blobdiff_plain;f=readphylip.cpp;h=6de23e83279482127f5f261c53f94c345585455d;hp=d256f92a816b03c101a01c12fdf19f4cace6678a;hb=615301e57c25e241356a9c2380648d117709458d;hpb=0cefb55a2616975bd4a144fc345693695ffc9bb6 diff --git a/readphylip.cpp b/readphylip.cpp index d256f92..6de23e8 100644 --- a/readphylip.cpp +++ b/readphylip.cpp @@ -200,7 +200,194 @@ int ReadPhylipMatrix::read(NameAssignment* nameMap){ exit(1); } } +/***********************************************************************/ + +int ReadPhylipMatrix::read(CountTable* countTable){ + try { + + float distance; + int square, nseqs; + string name; + vector matrixNames; + + string numTest; + fileHandle >> numTest >> name; + + if (!m->isContainingOnlyDigits(numTest)) { m->mothurOut("[ERROR]: expected a number and got " + numTest + ", quitting."); m->mothurOutEndLine(); exit(1); } + else { convert(numTest, nseqs); } + + matrixNames.push_back(name); + + if(countTable == NULL){ + list = new ListVector(nseqs); + list->set(0, name); + } + else{ list = new ListVector(countTable->getListVector()); } + + if (m->control_pressed) { return 0; } + + char d; + while((d=fileHandle.get()) != EOF){ + + if(isalnum(d)){ + square = 1; + fileHandle.putback(d); + for(int i=0;i> distance; + } + break; + } + if(d == '\n'){ + square = 0; + break; + } + } + + Progress* reading; + DMatrix->resize(nseqs); + + if(square == 0){ + + reading = new Progress("Reading matrix: ", nseqs * (nseqs - 1) / 2); + + int index = 0; + + for(int i=1;icontrol_pressed) { fileHandle.close(); delete reading; return 0; } + + fileHandle >> name; + matrixNames.push_back(name); + + + //there's A LOT of repeated code throughout this method... + if(countTable == NULL){ + list->set(i, name); + + for(int j=0;jcontrol_pressed) { delete reading; fileHandle.close(); return 0; } + + fileHandle >> distance; + + if (distance == -1) { distance = 1000000; } + else if (sim) { distance = 1.0 - distance; } //user has entered a sim matrix that we need to convert. + + if(distance < cutoff){ + PDistCell value(i, distance); + DMatrix->addCell(j, value); + } + index++; + reading->update(index); + } + + } + else{ + for(int j=0;j> distance; + + if (m->control_pressed) { delete reading; fileHandle.close(); return 0; } + + if (distance == -1) { distance = 1000000; } + else if (sim) { distance = 1.0 - distance; } //user has entered a sim matrix that we need to convert. + + if(distance < cutoff){ + int iIndex = countTable->get(matrixNames[i]); + int jIndex = countTable->get(matrixNames[j]); + + if (m->control_pressed) { delete reading; fileHandle.close(); return 0; } + if (iIndex < jIndex) { + PDistCell value(jIndex, distance); + DMatrix->addCell(iIndex, value); + }else { + PDistCell value(iIndex, distance); + DMatrix->addCell(jIndex, value); + } + } + index++; + reading->update(index); + } + } + } + } + else{ + + reading = new Progress("Reading matrix: ", nseqs * nseqs); + + int index = nseqs; + + for(int i=1;i> name; + matrixNames.push_back(name); + + + + if(countTable == NULL){ + list->set(i, name); + for(int j=0;j> distance; + + if (m->control_pressed) { fileHandle.close(); delete reading; return 0; } + + if (distance == -1) { distance = 1000000; } + else if (sim) { distance = 1.0 - distance; } //user has entered a sim matrix that we need to convert. + + if(distance < cutoff && j < i){ + PDistCell value(i, distance); + DMatrix->addCell(j, value); + } + index++; + reading->update(index); + } + + } + else{ + for(int j=0;j> distance; + + if (m->control_pressed) { fileHandle.close(); delete reading; return 0; } + + if (distance == -1) { distance = 1000000; } + else if (sim) { distance = 1.0 - distance; } //user has entered a sim matrix that we need to convert. + + if(distance < cutoff && j < i){ + int iIndex = countTable->get(matrixNames[i]); + int jIndex = countTable->get(matrixNames[j]); + + if (m->control_pressed) { delete reading; fileHandle.close(); return 0; } + if (iIndex < jIndex) { + PDistCell value(jIndex, distance); + DMatrix->addCell(iIndex, value); + }else { + PDistCell value(iIndex, distance); + DMatrix->addCell(jIndex, value); + + } + } + index++; + reading->update(index); + } + } + } + } + + if (m->control_pressed) { fileHandle.close(); delete reading; return 0; } + + reading->finish(); + delete reading; + + list->setLabel("0"); + fileHandle.close(); + + + return 1; + + } + catch(exception& e) { + m->errorOut(e, "ReadPhylipMatrix", "read"); + exit(1); + } +} /***********************************************************************/ ReadPhylipMatrix::~ReadPhylipMatrix(){} /***********************************************************************/