Ignore:
Timestamp:
Feb 2, 2018, 2:49:08 PM (21 months ago)
Author:
nmedfort
Message:

Revised pipeline structure to better control I/O rates

File:
1 edited

Legend:

Unmodified
Added
Removed
  • icGREP/icgrep-devel/icgrep/editd/editd.cpp

    r5847 r5856  
    258258
    259259    auto ChStream = pxDriver.addBuffer<SourceBuffer>(idb, idb->getStreamSetTy(4));
    260     auto mmapK = pxDriver.addKernelInstance<MemorySourceKernel>(idb, inputType, segmentSize);
     260    auto mmapK = pxDriver.addKernelInstance<MemorySourceKernel>(idb, inputType);
    261261    mmapK->setInitialArguments({inputStream, fileSize});
    262262    pxDriver.makeKernelCall(mmapK, {}, {ChStream});
     
    329329    auto ByteStream = pxDriver.addBuffer<SourceBuffer>(iBuilder, iBuilder->getStreamSetTy(1, 8));
    330330
    331     auto mmapK = pxDriver.addKernelInstance<MMapSourceKernel>(iBuilder, segmentSize);
     331    auto mmapK = pxDriver.addKernelInstance<MMapSourceKernel>(iBuilder);
    332332    mmapK->setInitialArguments({fileDescriptor});
    333333    pxDriver.makeKernelCall(mmapK, {}, {ByteStream});
     
    371371    auto ByteStream = pxDriver.addBuffer<SourceBuffer>(idb, idb->getStreamSetTy(1, 8));
    372372
    373     auto mmapK = pxDriver.addKernelInstance<MMapSourceKernel>(idb, segmentSize);
     373    auto mmapK = pxDriver.addKernelInstance<MMapSourceKernel>(idb);
    374374    mmapK->setInitialArguments({fileDescriptor});
    375375    pxDriver.makeKernelCall(mmapK, {}, {ByteStream});
     
    437437
    438438    auto ChStream = pxDriver.addBuffer<SourceBuffer>(idb, idb->getStreamSetTy(4));
    439     auto mmapK = pxDriver.addKernelInstance<MemorySourceKernel>(idb, inputType, segmentSize);
     439    auto mmapK = pxDriver.addKernelInstance<MemorySourceKernel>(idb, inputType);
    440440    mmapK->setInitialArguments({inputStream, fileSize});
    441441    pxDriver.makeKernelCall(mmapK, {}, {ChStream});
     
    666666    Module * M = iBuilder->getModule();
    667667
    668     const unsigned segmentSize = codegen::SegmentSize;
    669     const unsigned bufferSegments = codegen::BufferSegments * codegen::ThreadNum;
    670 
    671668    Type * mBitBlockType = iBuilder->getBitBlockType();
    672669    Type * const size_ty = iBuilder->getSizeTy();
     
    684681
    685682    StreamSetBuffer * MatchResults = pxDriver.addBuffer<SourceBuffer>(iBuilder, iBuilder->getStreamSetTy(editDistance+1));
    686     kernel::Kernel * sourceK = pxDriver.addKernelInstance<kernel::MemorySourceKernel>(iBuilder, inputType, segmentSize * bufferSegments);
     683    kernel::Kernel * sourceK = pxDriver.addKernelInstance<kernel::MemorySourceKernel>(iBuilder, inputType);
    687684    sourceK->setInitialArguments({inputStream, fileSize});
    688685    pxDriver.makeKernelCall(sourceK, {}, {MatchResults});
Note: See TracChangeset for help on using the changeset viewer.