public void setup()

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);
        }
    }