Method input

src/readpool.cpp:22–31

}

bool ReadPool::input(int tid, Read* data) {
    if(mIsFull)
        return false;

    mBufferLists[tid]->produce(data);
    mProduced++;
    if((mProduced & 0xFF) == 0)
        updateFullStatus();
    return true;
}

void ReadPool::cleanup() {
    for(int t=0; t<mOptions->thread; t++) {