class OffHeapByteBufferStore implements OffHeapStore {

  protected void nextBuffer() {
    bufferChangeLock.lock();
    try {
      Integer currentBuffer = availableBuffers.poll();
      if (currentBuffer == null) {
        throw new BufferOverflowException();
      }
      this.currentBuffer.set(currentBuffer);
    } finally {
      bufferChangeLock.unlock();
    }
  }

  public  OffHeapByteBufferStore(int capacity, int bufferSize);
  public  OffHeapByteBufferStore(int capacity, int bufferSize, int concurrencyLevel);

}