Skip to content

Commit 18121d2

Browse files
committed
Fix based on feedback
1 parent ab7e018 commit 18121d2

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

core/src/main/java/com/scalar/db/common/StorageInfoImpl.java

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -55,12 +55,17 @@ public boolean equals(Object o) {
5555
StorageInfoImpl that = (StorageInfoImpl) o;
5656
return getMaxAtomicMutationsCount() == that.getMaxAtomicMutationsCount()
5757
&& Objects.equals(getStorageName(), that.getStorageName())
58-
&& getMutationAtomicityUnit() == that.getMutationAtomicityUnit();
58+
&& getMutationAtomicityUnit() == that.getMutationAtomicityUnit()
59+
&& isConsistentVirtualTableRead() == that.isConsistentVirtualTableRead();
5960
}
6061

6162
@Override
6263
public int hashCode() {
63-
return Objects.hash(getStorageName(), getMutationAtomicityUnit(), getMaxAtomicMutationsCount());
64+
return Objects.hash(
65+
getStorageName(),
66+
getMutationAtomicityUnit(),
67+
getMaxAtomicMutationsCount(),
68+
isConsistentVirtualTableRead());
6469
}
6570

6671
@Override
@@ -69,6 +74,7 @@ public String toString() {
6974
.add("storageName", storageName)
7075
.add("mutationAtomicityUnit", mutationAtomicityUnit)
7176
.add("maxAtomicMutationsCount", maxAtomicMutationsCount)
77+
.add("consistentVirtualTableRead", consistentVirtualTableRead)
7278
.toString();
7379
}
7480
}

0 commit comments

Comments
 (0)