in src/main/java/com/microsoft/azure/datalake/store/ReadBufferManager.java [258:274]
private ReadBuffer getFromList(Collection<ReadBuffer> list, ADLFileInputStream file, long requestedOffset ) {
for (ReadBuffer buffer : list) {
if (buffer.file == file) {
if (buffer.status == ReadBufferStatus.AVAILABLE
&& requestedOffset >= buffer.offset
&& requestedOffset < buffer.offset + buffer.length
) {
return buffer;
} else if (requestedOffset >= buffer.offset
&& requestedOffset < buffer.offset + buffer.requestedLength
) {
return buffer;
}
}
}
return null;
}