ensure retirement is always attempted

src/raw.rs

@@ -459,19 +459,6 @@ impl Collector {
 
         // Safety: The batch is non-null.
         let batch_entries = unsafe { (*batch).entries.as_mut_ptr() };
-
-        // If there are not enough entries in this batch to add to all active threads
-        // reservation lists, we have to try again later.
-        //
-        // Relaxed: the fence above already ensures that we see any threads that might
-        // have access to any objects in this batch. Any threads that were created
-        // after it will see their new values.
-        //
-        // Safety: Local batch pointers are valid until relamation.
-        if unsafe { (*batch).entries.len() } <= self.reservations.threads.load(Ordering::Relaxed) {
-            return;
-        }
-
         let current_reservation = self.reservations.load(thread);
         let mut marked = 0;
 

tests/lib.rs

@@ -416,7 +416,7 @@ fn reentrant() {
 
 #[test]
 fn owned_guard() {
-    let collector = Collector::new().batch_size(5).epoch_frequency(None);
+    let collector = Collector::new().batch_size(5);
     let dropped = Arc::new(AtomicUsize::new(0));
 
     let objects = UnsafeSend(
@@ -462,7 +462,7 @@ fn owned_guard() {
 
 #[test]
 fn owned_guard_concurrent() {
-    let collector = Collector::new().batch_size(1).epoch_frequency(None);
+    let collector = Collector::new().batch_size(1);
     let dropped = Arc::new(AtomicUsize::new(0));
 
     let objects = UnsafeSend(