Method getOne

src/readpool.cpp:64–75

}

Read* ReadPool::getOne() {
    for(int t=0; t<mOptions->thread; t++) {
        if(mBufferLists[t]->canBeConsumed()) {
            Read* r = mBufferLists[t]->consume();
            mConsumed++;
            if((mConsumed & 0xFF) == 0)
                updateFullStatus();
            return r;
        }
    }
    return NULL;
}