Skip to content

Commit

Permalink
ns
Browse files Browse the repository at this point in the history
  • Loading branch information
belaban committed Dec 21, 2022
1 parent fee3656 commit 1e77dd4
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/org/jgroups/protocols/PerDestinationBundler.java
Original file line number Diff line number Diff line change
Expand Up @@ -147,7 +147,7 @@ protected void addMessage(Address dest, Message msg) {
try {
if(total_bytes + msg_bytes >= max_size) {
num_batches_sent_due_to_max_size++;
sendBatch(dest);
sendBatch(dest); // will not throw an exception, just log a warning
}

msgs[index++]=msg;
Expand All @@ -159,7 +159,7 @@ protected void addMessage(Address dest, Message msg) {

if(thread_count.decrementAndGet() == 0) {
num_batches_sent_due_to_last_thread++;
sendBatch(dest);
sendBatch(dest); // will not throw an exception, just log a warning
}
}
finally {
Expand Down

0 comments on commit 1e77dd4

Please sign in to comment.