Skip to content

Commit d57d9a5

Browse files
committed
dedup cache: add debug statements to see if head/tail keys are loaded
1 parent 26e100b commit d57d9a5

File tree

1 file changed

+3
-0
lines changed
  • crates/generic_log_worker/src

1 file changed

+3
-0
lines changed

crates/generic_log_worker/src/lib.rs

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -258,16 +258,19 @@ impl DedupCache {
258258

259259
// Load batches of cache entries from DO storage into the in-memory cache.
260260
async fn load(&self) -> Result<()> {
261+
log::debug!("DedupCache: loading head");
261262
let head = self
262263
.storage
263264
.get::<usize>(Self::FIFO_HEAD_KEY)
264265
.await
265266
.unwrap_or_default();
267+
log::debug!("DedupCache: loading tail");
266268
let tail = self
267269
.storage
268270
.get::<usize>(Self::FIFO_TAIL_KEY)
269271
.await
270272
.unwrap_or_default();
273+
log::debug!("DedupCache: head and tail loaded");
271274
let keys = (0..(tail - head)).map(Self::fifo_key).collect::<Vec<_>>();
272275
let map = self.storage.get_multiple(keys).await?;
273276
for value in map.values() {

0 commit comments

Comments
 (0)