Skip to content

Commit

Permalink
Add error logging
Browse files Browse the repository at this point in the history
  • Loading branch information
archang19 committed Dec 6, 2024
1 parent a7ec31f commit cb16e90
Showing 1 changed file with 17 additions and 2 deletions.
19 changes: 17 additions & 2 deletions file/file_prefetch_buffer.cc
Original file line number Diff line number Diff line change
Expand Up @@ -11,6 +11,7 @@

#include <algorithm>
#include <cassert>
#include <cinttypes>

#include "file/random_access_file_reader.h"
#include "monitoring/histogram.h"
Expand Down Expand Up @@ -856,9 +857,23 @@ bool FilePrefetchBuffer::TryReadFromCacheUntracked(
if (copy_to_overlap_buffer) {
buf = overlap_buf_;
}
assert(buf->offset_ <= offset);
if (offset < buf->offset_) {
fprintf(stderr,
"Requested offset %" PRIu64 " is less than buffer offset %" PRIu64
". UseFSBuffer(reader)=%d\n",
offset, buf->offset_, UseFSBuffer(reader));
assert(false);
return false;
}
uint64_t offset_in_buffer = offset - buf->offset_;
assert(n <= buf->CurrentSize() - offset_in_buffer);
if (buf->CurrentSize() - offset_in_buffer < n) {
fprintf(stderr,
"Insufficient room in buffer. Only have %" PRIu64
" but need %" PRIu64 ". UseFSBuffer(reader)=%d\n",
buf->CurrentSize() - offset_in_buffer, n, UseFSBuffer(reader));
assert(false);
return false;
}
*result = Slice(buf->buffer_.BufferStart() + offset_in_buffer, n);
if (prefetched) {
readahead_size_ = std::min(max_readahead_size_, readahead_size_ * 2);
Expand Down

0 comments on commit cb16e90

Please sign in to comment.