check for capacity exceeded more defensively

datalust · Feb 6, 2019 · b0048ff · b0048ff
1 parent d7e1b2d
commit b0048ff
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/sqelf/src/receive.rs b/sqelf/src/receive.rs
@@ -180,7 +180,9 @@ impl Gelf {
 
     fn gc(&mut self) -> Result<(), Error> {
         // Check the capacity of the incomplete chunk list
-        if self.by_id.chunks.len() == self.config.incomplete_capacity {
+        // If we're past the threshold then drop *all* chunks,
+        // whether they've expired or not.
+        if self.by_id.chunks.len() >= self.config.incomplete_capacity {
             self.by_id.chunks.clear();
             self.by_arrival.chunks.clear();
         }