in bigtop-manager-agent/src/main/java/org/apache/bigtop/manager/agent/grpc/service/SetupJdkServiceGrpcImpl.java [43:78]
public void setup(SetupJdkRequest request, StreamObserver<SetupJdkReply> responseObserver) {
try {
if (Environments.isDevMode()) {
SetupJdkReply reply = SetupJdkReply.newBuilder()
.setCode(MessageConstants.SUCCESS_CODE)
.build();
responseObserver.onNext(reply);
responseObserver.onCompleted();
return;
}
log.info("Setting up cluster jdk...");
ClusterInfo clusterInfo = LocalSettings.cluster();
String toolsHome = clusterInfo.getRootDir() + "/tools";
String user = System.getProperty("user.name");
LinuxFileUtils.createDirectories(toolsHome, user, user, Constants.PERMISSION_755, true);
String jdkHome = toolsHome + "/jdk";
ToolInfo tool = LocalSettings.getTool("jdk8");
PackageInfo packageInfo = new PackageInfo();
packageInfo.setUrl(tool.getBaseUrl());
packageInfo.setName(tool.getPkgName());
packageInfo.setChecksum(tool.getChecksum());
TarballUtils.installPackage(null, toolsHome, jdkHome, packageInfo, 1);
LinuxFileUtils.createDirectories(jdkHome, user, user, Constants.PERMISSION_755, true);
SetupJdkReply reply = SetupJdkReply.newBuilder()
.setCode(MessageConstants.SUCCESS_CODE)
.build();
responseObserver.onNext(reply);
responseObserver.onCompleted();
} catch (Exception e) {
log.error("Error setting up jdk", e);
responseObserver.onError(e);
}
}