[geode] branch feature/gha1 updated (f479e58cc0 -> 6a1ede9a56)
This is an automated email from the ASF dual-hosted git repository. sai_boorlagadda pushed a change to branch feature/gha1 in repository https://gitbox.apache.org/repos/asf/geode.git from f479e58cc0 another try to see if clear works add 6a1ede9a56 try using restore system properties No new revisions were added by this update. Summary of changes: .../cache/OplogEntryIdSetDrfHashSetThresholdTest.java | 13 - .../apache/geode/internal/cache/OplogEntryIdSetTest.java| 6 +- 2 files changed, 9 insertions(+), 10 deletions(-)
[geode] 01/01: another try to see if clear works
This is an automated email from the ASF dual-hosted git repository.
sai_boorlagadda pushed a commit to branch feature/gha1
in repository https://gitbox.apache.org/repos/asf/geode.git
commit f479e58cc06ae2b3a627ae56ff8ba03dfbe4cd33
Author: Sai Boorlagadda
AuthorDate: Sat Jan 21 19:41:42 2023 -0800
another try to see if clear works
---
.../apache/geode/internal/cache/DiskStoreImpl.java | 26 +-
.../geode/internal/cache/PersistentOplogSet.java | 2 +-
.../OplogEntryIdSetDrfHashSetThresholdTest.java| 6 -
.../geode/internal/cache/OplogEntryIdSetTest.java | 6 -
4 files changed, 17 insertions(+), 23 deletions(-)
diff --git
a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreImpl.java
b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreImpl.java
index dd2bb2c300..8415a00b34 100644
---
a/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreImpl.java
+++
b/geode-core/src/main/java/org/apache/geode/internal/cache/DiskStoreImpl.java
@@ -71,7 +71,6 @@ import it.unimi.dsi.fastutil.ints.IntOpenHashSet;
import it.unimi.dsi.fastutil.longs.LongOpenHashSet;
import org.apache.commons.io.FileUtils;
import org.apache.logging.log4j.Logger;
-import org.jetbrains.annotations.TestOnly;
import org.apache.geode.CancelCriterion;
import org.apache.geode.CancelException;
@@ -199,7 +198,7 @@ public class DiskStoreImpl implements DiskStore {
GeodeGlossary.GEMFIRE_PREFIX + "disk.recoverLruValues";
static final long DRF_HASHMAP_OVERFLOW_THRESHOLD_DEFAULT = 805306368;
- final long DRF_HASHMAP_OVERFLOW_THRESHOLD =
+ static final long DRF_HASHMAP_OVERFLOW_THRESHOLD =
Long.getLong(DRF_HASHMAP_OVERFLOW_THRESHOLD_NAME,
DRF_HASHMAP_OVERFLOW_THRESHOLD_DEFAULT);
boolean RECOVER_VALUES =
getBoolean(DiskStoreImpl.RECOVER_VALUE_PROPERTY_NAME, true);
@@ -3533,26 +3532,18 @@ public class DiskStoreImpl implements DiskStore {
private final List allLongs;
private final AtomicReference currentInts;
private final AtomicReference currentLongs;
-private final long drfHashMapOverFlowThreashold;
// For testing purposes only.
@VisibleForTesting
-OplogEntryIdSet(List allInts, List
allLongs,
-long drfHashMapOverflowThreshold) {
+OplogEntryIdSet(List allInts, List
allLongs) {
this.allInts = allInts;
currentInts = new AtomicReference<>(this.allInts.get(0));
this.allLongs = allLongs;
currentLongs = new AtomicReference<>(this.allLongs.get(0));
- this.drfHashMapOverFlowThreashold = drfHashMapOverflowThreshold;
-}
-
-@TestOnly
-OplogEntryIdSet(List allInts, List
allLongs) {
- this(allInts, allLongs, DRF_HASHMAP_OVERFLOW_THRESHOLD_DEFAULT);
}
-public OplogEntryIdSet(long drfHashMapOverflowThreshold) {
+public OplogEntryIdSet() {
IntOpenHashSet intHashSet = new IntOpenHashSet((int) INVALID_ID);
allInts = new ArrayList<>();
allInts.add(intHashSet);
@@ -3562,11 +3553,6 @@ public class DiskStoreImpl implements DiskStore {
allLongs = new ArrayList<>();
allLongs.add(longHashSet);
currentLongs = new AtomicReference<>(longHashSet);
- this.drfHashMapOverFlowThreashold = drfHashMapOverflowThreshold;
-}
-
-public OplogEntryIdSet() {
- this(DRF_HASHMAP_OVERFLOW_THRESHOLD_DEFAULT);
}
public void add(long id) {
@@ -3594,14 +3580,14 @@ public class DiskStoreImpl implements DiskStore {
boolean shouldOverflow(final long id) {
if (id > 0 && id <= 0xL) {
-return currentInts.get().size() == drfHashMapOverFlowThreashold;
+return currentInts.get().size() == DRF_HASHMAP_OVERFLOW_THRESHOLD;
} else {
-return currentLongs.get().size() == drfHashMapOverFlowThreashold;
+return currentLongs.get().size() == DRF_HASHMAP_OVERFLOW_THRESHOLD;
}
}
void overflowToNewHashMap(final long id) {
- if (drfHashMapOverFlowThreashold ==
DRF_HASHMAP_OVERFLOW_THRESHOLD_DEFAULT) {
+ if (DRF_HASHMAP_OVERFLOW_THRESHOLD ==
DRF_HASHMAP_OVERFLOW_THRESHOLD_DEFAULT) {
logger.warn(
"There is a large number of deleted entries within the disk-store,
please execute an offline compaction.");
}
diff --git
a/geode-core/src/main/java/org/apache/geode/internal/cache/PersistentOplogSet.java
b/geode-core/src/main/java/org/apache/geode/internal/cache/PersistentOplogSet.java
index 80a9378cfd..67291651a3 100644
---
a/geode-core/src/main/java/org/apache/geode/internal/cache/PersistentOplogSet.java
+++
b/geode-core/src/main/java/org/apache/geode/internal/cache/PersistentOplogSet.java
@@ -440,7 +440,7 @@ public class PersistentOplogSet implements OplogSet {
}
private long recoverOplogs(long byteCount) {
-OplogEntryIdSet deletedIds = new
OplogEntryIdSet(parent.DRF_HASHMAP_OVERFLOW_THRESHOLD);
+OplogEntryIdSet deletedIds = new OplogEntryIdSet();
TreeSet oplogSet =
[geode] branch feature/gha1 created (now f479e58cc0)
This is an automated email from the ASF dual-hosted git repository. sai_boorlagadda pushed a change to branch feature/gha1 in repository https://gitbox.apache.org/repos/asf/geode.git at f479e58cc0 another try to see if clear works This branch includes the following new commits: new f479e58cc0 another try to see if clear works The 1 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference.
[geode] branch feature/gha updated (ba34f3ff32 -> 2507ad58f9)
This is an automated email from the ASF dual-hosted git repository. sai_boorlagadda pushed a change to branch feature/gha in repository https://gitbox.apache.org/repos/asf/geode.git from ba34f3ff32 fix spotless add 2507ad58f9 removed trap No new revisions were added by this update. Summary of changes: .../src/main/java/org/apache/geode/distributed/DistributedSystem.java | 2 -- 1 file changed, 2 deletions(-)
[geode] branch feature/gha updated (953269ccd5 -> ba34f3ff32)
This is an automated email from the ASF dual-hosted git repository. sai_boorlagadda pushed a change to branch feature/gha in repository https://gitbox.apache.org/repos/asf/geode.git from 953269ccd5 add trap add ba34f3ff32 fix spotless No new revisions were added by this update. Summary of changes: .../main/java/org/apache/geode/distributed/DistributedSystem.java| 2 +- .../src/main/java/org/apache/geode/internal/cache/DiskStoreImpl.java | 2 +- .../test/java/org/apache/geode/internal/cache/DiskStoreImplTest.java | 5 +++-- 3 files changed, 5 insertions(+), 4 deletions(-)
[geode] branch feature/gha updated (dc9c60565f -> 953269ccd5)
This is an automated email from the ASF dual-hosted git repository. sai_boorlagadda pushed a change to branch feature/gha in repository https://gitbox.apache.org/repos/asf/geode.git from dc9c60565f remove trap add 953269ccd5 add trap No new revisions were added by this update. Summary of changes: .../src/main/java/org/apache/geode/distributed/DistributedSystem.java | 2 ++ 1 file changed, 2 insertions(+)
[geode] branch feature/gha updated (c162022ea6 -> dc9c60565f)
This is an automated email from the ASF dual-hosted git repository. sai_boorlagadda pushed a change to branch feature/gha in repository https://gitbox.apache.org/repos/asf/geode.git from c162022ea6 fix license add dc9c60565f remove trap No new revisions were added by this update. Summary of changes: .../src/main/java/org/apache/geode/distributed/DistributedSystem.java | 2 -- 1 file changed, 2 deletions(-)
[geode] branch feature/gha updated (70e1fbddd6 -> c162022ea6)
This is an automated email from the ASF dual-hosted git repository. sai_boorlagadda pushed a change to branch feature/gha in repository https://gitbox.apache.org/repos/asf/geode.git from 70e1fbddd6 add a new DiskStoreImplTest add c162022ea6 fix license No new revisions were added by this update. Summary of changes: .../internal/DistributionIntegrationTest.java | 17 - .../apache/geode/internal/cache/DiskStoreImplTest.java | 17 - 2 files changed, 24 insertions(+), 10 deletions(-)
[geode] branch feature/gha updated (4fadc93040 -> 70e1fbddd6)
This is an automated email from the ASF dual-hosted git repository. sai_boorlagadda pushed a change to branch feature/gha in repository https://gitbox.apache.org/repos/asf/geode.git from 4fadc93040 trap to find distributed system creators add 70e1fbddd6 add a new DiskStoreImplTest No new revisions were added by this update. Summary of changes: .../apache/geode/internal/cache/DiskStoreImpl.java | 11 - .../geode/internal/cache/DiskStoreImplTest.java| 47 ++ .../OplogEntryIdSetDrfHashSetThresholdTest.java| 5 +-- 3 files changed, 57 insertions(+), 6 deletions(-) create mode 100644 geode-core/src/test/java/org/apache/geode/internal/cache/DiskStoreImplTest.java
[geode] branch feature/gha updated (c239d89f79 -> 4fadc93040)
This is an automated email from the ASF dual-hosted git repository. sai_boorlagadda pushed a change to branch feature/gha in repository https://gitbox.apache.org/repos/asf/geode.git from c239d89f79 make DistributionTest as integraiton test add 4fadc93040 trap to find distributed system creators No new revisions were added by this update. Summary of changes: .../src/main/java/org/apache/geode/distributed/DistributedSystem.java | 2 ++ 1 file changed, 2 insertions(+)
[geode] branch feature/gha updated (9b75802f6d -> c239d89f79)
This is an automated email from the ASF dual-hosted git repository.
sai_boorlagadda pushed a change to branch feature/gha
in repository https://gitbox.apache.org/repos/asf/geode.git
from 9b75802f6d fix errors for drfHashMapOverflowThresold
add c239d89f79 make DistributionTest as integraiton test
No new revisions were added by this update.
Summary of changes:
.../internal/DistributionIntegrationTest.java}| 19 ++-
1 file changed, 6 insertions(+), 13 deletions(-)
rename
geode-core/src/{test/java/org/apache/geode/distributed/internal/DistributionTest.java
=>
integrationTest/java/org/apache/geode/distributed/internal/DistributionIntegrationTest.java}
(92%)
[geode] branch feature/gha updated (11ba1ec254 -> 9b75802f6d)
This is an automated email from the ASF dual-hosted git repository. sai_boorlagadda pushed a change to branch feature/gha in repository https://gitbox.apache.org/repos/asf/geode.git from 11ba1ec254 make p2p timeout clear add 9b75802f6d fix errors for drfHashMapOverflowThresold No new revisions were added by this update. Summary of changes: .../org/apache/geode/internal/cache/DiskStoreImpl.java| 15 +++ .../apache/geode/internal/cache/PersistentOplogSet.java | 2 +- 2 files changed, 12 insertions(+), 5 deletions(-)
[geode] branch feature/gha updated (8e51e1c19b -> 11ba1ec254)
This is an automated email from the ASF dual-hosted git repository. sai_boorlagadda pushed a change to branch feature/gha in repository https://gitbox.apache.org/repos/asf/geode.git from 8e51e1c19b removed logs add 11ba1ec254 make p2p timeout clear No new revisions were added by this update. Summary of changes: .../src/main/java/org/apache/geode/internal/tcp/Connection.java| 7 +++ .../test/java/org/apache/geode/internal/tcp/ConnectionTest.java| 6 ++ .../org/apache/geode/internal/tcp/ConnectionTransmissionTest.java | 6 ++ 3 files changed, 19 insertions(+)
[geode] branch feature/gha updated (53fb5276bc -> 8e51e1c19b)
This is an automated email from the ASF dual-hosted git repository. sai_boorlagadda pushed a change to branch feature/gha in repository https://gitbox.apache.org/repos/asf/geode.git from 53fb5276bc add logs add 7210584d9b make the constant non-static add 8e51e1c19b removed logs No new revisions were added by this update. Summary of changes: geode-core/build.gradle | 6 -- .../main/java/org/apache/geode/internal/cache/DiskStoreImpl.java| 2 +- .../src/main/java/org/apache/geode/internal/tcp/Connection.java | 4 .../java/org/apache/geode/internal/cache/OplogEntryIdSetTest.java | 4 +--- 4 files changed, 2 insertions(+), 14 deletions(-)
[geode] branch feature/gha updated (d9604eb53a -> 53fb5276bc)
This is an automated email from the ASF dual-hosted git repository. sai_boorlagadda pushed a change to branch feature/gha in repository https://gitbox.apache.org/repos/asf/geode.git from d9604eb53a removed ignore add 53fb5276bc add logs No new revisions were added by this update. Summary of changes: geode-core/build.gradle | 6 ++ .../src/main/java/org/apache/geode/internal/tcp/Connection.java | 4 2 files changed, 10 insertions(+)
[geode] branch feature/gha updated (3d338443aa -> d9604eb53a)
This is an automated email from the ASF dual-hosted git repository. sai_boorlagadda pushed a change to branch feature/gha in repository https://gitbox.apache.org/repos/asf/geode.git from 3d338443aa removed ignore add d9604eb53a removed ignore No new revisions were added by this update. Summary of changes: .../java/org/apache/geode/distributed/internal/DistributionTest.java| 2 -- 1 file changed, 2 deletions(-)
[geode] branch feature/gha updated (c2736ba2d8 -> 3d338443aa)
This is an automated email from the ASF dual-hosted git repository. sai_boorlagadda pushed a change to branch feature/gha in repository https://gitbox.apache.org/repos/asf/geode.git from c2736ba2d8 disable oplog test add 3d338443aa removed ignore No new revisions were added by this update. Summary of changes: .../org/apache/geode/distributed/LocatorLauncherBuilderTest.java| 3 --- .../org/apache/geode/distributed/ServerLauncherBuilderTest.java | 3 --- .../org/apache/geode/distributed/internal/DistributionTest.java | 6 -- .../internal/cache/OplogEntryIdSetDrfHashSetThresholdTest.java | 5 + .../src/test/java/org/apache/geode/internal/tcp/ConnectionTest.java | 2 -- 5 files changed, 1 insertion(+), 18 deletions(-)
