You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by nn...@apache.org on 2022/06/03 17:04:58 UTC
[geode] branch develop updated: GEODE-10356: Corrected the comment (#7762)
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 <na...@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);