Ignore:
Timestamp:
Mar 21, 2017, 11:55:00 AM (2 years ago)
Author:
xuedongx
Message:

Add1 processing rate; pablo Count only up to EOFbit

File:
1 edited

Legend:

Unmodified
Added
Removed
  • icGREP/icgrep-devel/icgrep/kernels/pipeline.cpp

    r5366 r5370  
    191191        }
    192192        kernels[k]->createDoSegmentCall(doSegmentArgs);
    193         std::vector<Value *> produced;
    194         for (unsigned i = 0; i < kernels[k]->getStreamOutputs().size(); i++) {
    195             produced.push_back(kernels[k]->getProducedItemCount(instancePtrs[k], kernels[k]->getStreamOutputs()[i].name));
    196         }
    197         ProducerPos.push_back(produced);
    198         if (! (kernels[k]->hasNoTerminateAttribute())) {
     193         if (! (kernels[k]->hasNoTerminateAttribute())) {
    199194            Value * terminated = kernels[k]->getTerminationSignal(instancePtrs[k]);
    200195            doFinal = iBuilder->CreateOr(doFinal, terminated);
    201196        }
     197       std::vector<Value *> produced;
     198        for (unsigned i = 0; i < kernels[k]->getStreamOutputs().size(); i++) {
     199            produced.push_back(kernels[k]->getProducedItemCount(instancePtrs[k], kernels[k]->getStreamOutputs()[i].name, doFinal));
     200        }
     201        ProducerPos.push_back(produced);
    202202
    203203        kernels[k]->releaseLogicalSegmentNo(instancePtrs[k], nextSegNo);
     
    515515        std::vector<Value *> produced;
    516516        for (unsigned i = 0; i < kernels[k]->getStreamOutputs().size(); i++) {
    517             produced.push_back(kernels[k]->getProducedItemCount(instance, kernels[k]->getStreamOutputs()[i].name));
     517            produced.push_back(kernels[k]->getProducedItemCount(instance, kernels[k]->getStreamOutputs()[i].name, terminationFound));
    518518        }
    519519        ProducerPos.push_back(produced);
Note: See TracChangeset for help on using the changeset viewer.