summaryrefslogtreecommitdiffstats
path: root/include/framework/DynamicExtension.h
diff options
context:
space:
mode:
Diffstat (limited to 'include/framework/DynamicExtension.h')
-rw-r--r--include/framework/DynamicExtension.h11
1 files changed, 1 insertions, 10 deletions
diff --git a/include/framework/DynamicExtension.h b/include/framework/DynamicExtension.h
index 67f6ff8..4d4585f 100644
--- a/include/framework/DynamicExtension.h
+++ b/include/framework/DynamicExtension.h
@@ -759,22 +759,13 @@ private:
}
int internal_append(const RecordType &rec, bool ts) {
- size_t max_l0 = (log(get_record_count()) / log(8)) + 1;
- size_t current_l0 = get_active_version()->get_structure()->get_level_vector()[0]->get_shard_count();
-
- if (m_buffer->is_at_low_watermark() && current_l0 <= max_l0) {
+ if (m_buffer->is_at_low_watermark()) {
auto old = false;
if (m_scheduling_reconstruction.compare_exchange_strong(old, true)) {
schedule_flush();
}
}
- if (m_buffer->is_at_high_watermark() && current_l0 > max_l0) {
- schedule_maint_reconstruction(true);
- // fprintf(stderr, "[I] Current L0: %ld\tMax L0:%ld\n", current_l0, max_l0);
- return 0;
- }
-
/* this will fail if the HWM is reached and return 0 */
return m_buffer->append(rec, ts);
}