This is an automated email from the ASF dual-hosted git repository. nnag pushed a commit to branch develop in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/develop by this push: new 968331758c GEODE-10356: Corrected the comment (#7762) 968331758c is described below commit 968331758cff9c315bb95c7159ac1610aed9ad34 Author: Nabarun Nag <nabarun...@users.noreply.github.com> AuthorDate: Fri Jun 3 10:04:53 2022 -0700 GEODE-10356: Corrected the comment (#7762) * The previous comment on removeOldEntry mentioned that the old entry was replaced * This has been corrected to mention that the old entry is removed and the new entry has been added to the region queue --- .../geode/internal/cache/wan/serial/SerialGatewaySenderQueue.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/wan/serial/SerialGatewaySenderQueue.java b/geode-core/src/main/java/org/apache/geode/internal/cache/wan/serial/SerialGatewaySenderQueue.java index 81dc5696e1..e76ec400f0 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/wan/serial/SerialGatewaySenderQueue.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/wan/serial/SerialGatewaySenderQueue.java @@ -611,7 +611,8 @@ public class SerialGatewaySenderQueue implements RegionQueue { keepOldEntry = true; } - // Replace the object's value into the queue if necessary + // Remove the old entry from the queue if necessary. The new entry is already present + // in the queue region. if (!keepOldEntry) { Conflatable previous = (Conflatable) region.remove(previousIndex); stats.decQueueSize(1);