timoninmaxim commented on code in PR #11866:
URL: https://github.com/apache/ignite/pull/11866#discussion_r1954065558
##########
modules/core/src/main/java/org/apache/ignite/internal/management/cache/IdleVerifyResult.java:
##########
@@ -414,4 +405,128 @@ private void printConflicts(Consumer<String> printer) {
@Override public String toString() {
return S.toString(IdleVerifyResult.class, this);
}
+
+ /** */
+ public static IdleVerifyResult ofErrors(Map<ClusterNode, Exception>
exceptions) {
+ return new IdleVerifyResult(exceptions);
+ }
+
+ /** @return A fresh result builder. */
+ public static Builder builder() {
+ return new Builder();
+ }
+
+ /** Builder of {@link IdleVerifyResult}. Is not thread-safe. */
+ public static final class Builder {
+ /** */
+ private @Nullable Map<PartitionKey, List<PartitionHashRecord>>
partHashes;
+
+ /** */
+ private @Nullable List<List<TransactionsHashRecord>> txHashConflicts;
+
+ /** */
+ private @Nullable Map<ClusterNode, Collection<GridCacheVersion>>
partiallyCommittedTxs;
+
+ /** */
+ private Map<ClusterNode, Exception> exceptions;
+
+ /** */
+ private Builder() {
+ // No-op.
+ }
+
+ /** Build the final result. */
+ public IdleVerifyResult build() {
+ if (partHashes == null)
+ partHashes = Collections.emptyMap();
+
+ if (exceptions == null)
+ exceptions = Collections.emptyMap();
+
+ return new IdleVerifyResult(partHashes, txHashConflicts,
partiallyCommittedTxs, exceptions);
+ }
+
+ /** Stores an exception if none is assigned for {@code node}. */
+ public Builder addException(ClusterNode node, Exception e) {
+ assert e != null;
+
+ if (exceptions == null)
+ exceptions = new HashMap<>();
+
+ exceptions.putIfAbsent(node, e);
+
+ return this;
+ }
+
+ /** Stores a collection of partition hashes for partition key {@code
key}. */
+ private Builder addPartitionHashes(PartitionKey key,
Collection<PartitionHashRecord> newHashes) {
+ if (partHashes == null)
+ partHashes = new HashMap<>();
+
+ partHashes.compute(key, (key0, hashes0) -> {
+ if (hashes0 == null)
+ hashes0 = new ArrayList<>();
+
+ hashes0.addAll(newHashes);
+
+ return hashes0;
+ });
+
+ return this;
+ }
+
+ /** Stores a partition hashes map. */
+ public void addPartitionHashes(Map<PartitionKey, PartitionHashRecord>
newHashes) {
+ newHashes.forEach((key, hash) -> addPartitionHashes(key,
Collections.singletonList(hash)));
+ }
+
+ /** Stores a single partition hash for partition key {@code key}. */
+ public Builder addPartitionHash(PartitionKey key, PartitionHashRecord
newHash) {
+ addPartitionHashes(key, Collections.singletonList(newHash));
+
+ return this;
+ }
+
+ /** Sets partition hashes. */
+ public Builder partitionHashes(Map<PartitionKey,
List<PartitionHashRecord>> partHashes) {
Review Comment:
This method isn't used
##########
modules/core/src/main/java/org/apache/ignite/internal/management/cache/IdleVerifyResult.java:
##########
@@ -414,4 +405,128 @@ private void printConflicts(Consumer<String> printer) {
@Override public String toString() {
return S.toString(IdleVerifyResult.class, this);
}
+
+ /** */
+ public static IdleVerifyResult ofErrors(Map<ClusterNode, Exception>
exceptions) {
+ return new IdleVerifyResult(exceptions);
+ }
+
+ /** @return A fresh result builder. */
+ public static Builder builder() {
+ return new Builder();
+ }
+
+ /** Builder of {@link IdleVerifyResult}. Is not thread-safe. */
+ public static final class Builder {
+ /** */
+ private @Nullable Map<PartitionKey, List<PartitionHashRecord>>
partHashes;
+
+ /** */
+ private @Nullable List<List<TransactionsHashRecord>> txHashConflicts;
+
+ /** */
+ private @Nullable Map<ClusterNode, Collection<GridCacheVersion>>
partiallyCommittedTxs;
+
+ /** */
+ private Map<ClusterNode, Exception> exceptions;
+
+ /** */
+ private Builder() {
+ // No-op.
+ }
+
+ /** Build the final result. */
+ public IdleVerifyResult build() {
+ if (partHashes == null)
+ partHashes = Collections.emptyMap();
+
+ if (exceptions == null)
+ exceptions = Collections.emptyMap();
+
+ return new IdleVerifyResult(partHashes, txHashConflicts,
partiallyCommittedTxs, exceptions);
+ }
+
+ /** Stores an exception if none is assigned for {@code node}. */
+ public Builder addException(ClusterNode node, Exception e) {
+ assert e != null;
+
+ if (exceptions == null)
+ exceptions = new HashMap<>();
+
+ exceptions.putIfAbsent(node, e);
+
+ return this;
+ }
+
+ /** Stores a collection of partition hashes for partition key {@code
key}. */
+ private Builder addPartitionHashes(PartitionKey key,
Collection<PartitionHashRecord> newHashes) {
+ if (partHashes == null)
+ partHashes = new HashMap<>();
+
+ partHashes.compute(key, (key0, hashes0) -> {
+ if (hashes0 == null)
+ hashes0 = new ArrayList<>();
+
+ hashes0.addAll(newHashes);
+
+ return hashes0;
+ });
+
+ return this;
+ }
+
+ /** Stores a partition hashes map. */
+ public void addPartitionHashes(Map<PartitionKey, PartitionHashRecord>
newHashes) {
+ newHashes.forEach((key, hash) -> addPartitionHashes(key,
Collections.singletonList(hash)));
+ }
+
+ /** Stores a single partition hash for partition key {@code key}. */
+ public Builder addPartitionHash(PartitionKey key, PartitionHashRecord
newHash) {
Review Comment:
This method isn't used
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: notifications-unsubscr...@ignite.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
