Method ReadPool

src/readpool.cpp:7–16

#include "common.h"

ReadPool::ReadPool(Options* opt){
    mOptions = opt;
    initBufferLists();
    mLimit = PACK_SIZE * PACK_IN_MEM_LIMIT;
    if(mOptions->interleavedInput)
        mLimit *= 2;
    mIsFull = false;
    mProduced = 0;
    mConsumed = 0;
}

ReadPool::~ReadPool() {
    cleanup();