nizhikov commented on code in PR #9907:
URL: https://github.com/apache/ignite/pull/9907#discussion_r880331972
##########
modules/control-utility/src/main/java/org/apache/ignite/internal/commandline/consistency/ConsistencyCommand.java:
##########
@@ -52,43 +57,64 @@ public class ConsistencyCommand extends
AbstractCommand<Object> {
/** Strategy. */
public static final String STRATEGY = "--strategy";
+ /** Parallel check. */
+ public static final String PARALLEL = "--parallel";
+
/** Command argument. */
private VisorConsistencyRepairTaskArg cmdArg;
/** Consistency sub-command to execute. */
private ConsistencySubCommand cmd;
+ /** Parallel check.*/
+ private boolean parallel;
+
+ /** Predicate to filter server nodes. */
+ private static final Predicate<GridClientNode> SRV_NODES = node ->
!node.isClient() && !node.isDaemon();
+
/** {@inheritDoc} */
@Override public Object execute(GridClientConfiguration clientCfg, Logger
log) throws Exception {
boolean failed = false;
StringBuilder sb = new StringBuilder();
try (GridClient client = Command.startClient(clientCfg)) {
- VisorConsistencyTaskResult res = executeTaskByNameOnNode(
- client,
- cmd.taskName(),
- arg(),
- BROADCAST_UUID,
- clientCfg
- );
-
- if (res.cancelled()) {
- sb.append("Operation execution cancelled.\n\n");
-
- failed = true;
- }
+ Set<UUID> nodeIds = parallel ?
Review Comment:
Code style.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
