in lifecycle/src/main/java/org/apache/shardingsphere/elasticjob/lifecycle/internal/operate/JobOperateAPIImpl.java [60:81]
private void disableOrEnableJobs(final String jobName, final String serverIp, final boolean disabled) {
Preconditions.checkArgument(null != jobName || null != serverIp, "At least indicate jobName or serverIp.");
if (null != jobName && null != serverIp) {
persistDisabledOrEnabledJob(jobName, serverIp, disabled);
} else if (null != jobName) {
JobNodePath jobNodePath = new JobNodePath(jobName);
for (String each : regCenter.getChildrenKeys(jobNodePath.getServerNodePath())) {
if (disabled) {
regCenter.persist(jobNodePath.getServerNodePath(each), ServerStatus.DISABLED.name());
} else {
regCenter.persist(jobNodePath.getServerNodePath(each), ServerStatus.ENABLED.name());
}
}
} else {
List<String> jobNames = regCenter.getChildrenKeys("/");
for (String each : jobNames) {
if (regCenter.isExisted(new JobNodePath(each).getServerNodePath(serverIp))) {
persistDisabledOrEnabledJob(each, serverIp, disabled);
}
}
}
}