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);