Skip to content

Commit 820bf1d

Browse files
committed
Bug 37213681 - [37052594->25.03] RFA: InFilter query did not return all expected results when querying by indexed
[git-p4: depot-paths = "//dev/coherence-ce/main/": change = 112179]
1 parent 872d5ab commit 820bf1d

File tree

1 file changed

+4
-2
lines changed
  • prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/partitionedService

1 file changed

+4
-2
lines changed

prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/partitionedService/PartitionedCache.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10873,7 +10873,7 @@ public void scheduleInitialIndexUpdate(int nPartition, int nEventId, Storage sto
1087310873
// import java.util.Iterator;
1087410874
// import java.util.Map;
1087510875
// import java.util.Queue as java.util.Queue;
10876-
10876+
1087710877
if (isPartitionIndexPending(nPartition))
1087810878
{
1087910879
// find a pending request that pertains to the specified partition
@@ -42007,7 +42007,7 @@ public void onTransmitCompleted(int iPartition, int iStore)
4200742007
// import java.util.Map;
4200842008

4200942009
super.onTransmitCompleted(iPartition, iStore);
42010-
42010+
4201142011
if (iStore == 0)
4201242012
{
4201342013
// drop the deferred events for this partition
@@ -43664,6 +43664,8 @@ public void onResponse(com.tangosol.coherence.component.net.Message msg)
4366443664

4366543665
if (service.getIndexPendingPartitions().containsKey(nPartition))
4366643666
{
43667+
// this is a retry, adjust pending count by decrementing as scheduleIndexUpdate increments
43668+
service.updatePendingIndexPartition(nPartition, false);
4366743669
service.scheduleIndexUpdate(nPartition, msgRetry.getEventId(), msgRetry.getUpdateMap());
4366843670
}
4366943671
}

0 commit comments

Comments
 (0)