diff --git a/src/bees-hash.cc b/src/bees-hash.cc index 4e7917f..1e1a5b2 100644 --- a/src/bees-hash.cc +++ b/src/bees-hash.cc @@ -335,9 +335,6 @@ BeesHashTable::fetch_missing_extent(HashType hash) } BEESCOUNT(hash_extent_in); - // We don't block when fetching an extent but we do slow down the - // prefetch thread. - m_prefetch_rate_limit.borrow(BLOCK_SIZE_HASHTAB_EXTENT); lock.lock(); m_buckets_missing.erase(extent_number); } @@ -596,7 +593,6 @@ BeesHashTable::BeesHashTable(shared_ptr ctx, string filename, off_t m_writeback_thread("hash_writeback"), m_prefetch_thread("hash_prefetch"), m_flush_rate_limit(BEES_FLUSH_RATE), - m_prefetch_rate_limit(BEES_FLUSH_RATE), m_stats_file(m_ctx->home_fd(), "beesstats.txt") { // Sanity checks to protect the implementation from its weaknesses diff --git a/src/bees.h b/src/bees.h index 5aabdd0..d3b674e 100644 --- a/src/bees.h +++ b/src/bees.h @@ -444,7 +444,6 @@ private: BeesThread m_writeback_thread; BeesThread m_prefetch_thread; RateLimiter m_flush_rate_limit; - RateLimiter m_prefetch_rate_limit; mutex m_extent_mutex; mutex m_bucket_mutex; condition_variable m_condvar;