NAKACK2.removeAndDeliver(): increment FastArray by 1024 rather than (…

…default) 5
belaban · Aug 27, 2024 · d50bc13 · d50bc13
1 parent 3733c34
commit d50bc13
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/org/jgroups/protocols/pbcast/NAKACK2.java b/src/org/jgroups/protocols/pbcast/NAKACK2.java
@@ -890,6 +890,7 @@ protected void removeAndDeliver(Table<Message> buf, Address sender, boolean loop
             return;
         boolean remove_msgs=discard_delivered_msgs && !loopback;
         MessageBatch batch=new MessageBatch(buf.size()).dest(null).sender(sender).clusterName(cluster_name).multicast(true);
+        batch.array().increment(1024);
         Supplier<MessageBatch> batch_creator=() -> batch;
         MessageBatch mb=null;
         do {