From e476438c8c6bc50f3d19067f6b816309ac240743 Mon Sep 17 00:00:00 2001 From: Aidan Hahn Date: Fri, 17 May 2019 01:35:55 -0700 Subject: [PATCH] Server builds --- src/main/java/JobServ/JobServServer.java | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/src/main/java/JobServ/JobServServer.java b/src/main/java/JobServ/JobServServer.java index 135760d..985db88 100644 --- a/src/main/java/JobServ/JobServServer.java +++ b/src/main/java/JobServ/JobServServer.java @@ -16,12 +16,12 @@ public class JobServServer { private void start() throws IOException { // TODO: this should be passed in from a configuration manager int port = 8448; - server = ServerBUilder.forPort(port) - .addService(new JobServImpl()) + server = ServerBuilder.forPort(port) + .addService(new ShellServerImpl()) .build() .start(); logger.info("Server initialized without tls"); - Runtime.getRuntime().addShutdownHook(new thread() { + Runtime.getRuntime().addShutdownHook(new Thread() { @Override public void run() { // JVM shutdown might break logger functionality @@ -53,7 +53,7 @@ public class JobServServer { } // wrap around stub code generated by GRPC - static class JobServImpl extends JobServ.JobServImplBase { + static class ShellServerImpl extends ShellServerGrpc.ShellServerImplBase { @Override public void getStatusDetail(RequestMessage request, @@ -72,7 +72,6 @@ public class JobServServer { StreamObserver responder) { // TODO: Implement job controller, get output, do the thing OutputMessage reply = OutputMessage.newBuilder() - .setPID(-1) .build(); responder.onNext(reply); responder.onCompleted(); @@ -84,7 +83,7 @@ public class JobServServer { // TODO: Implement job controller, Start Job, do the thing JobStatusMessage reply = JobStatusMessage.newBuilder() .setPID(-1) - .setJobStatus(-1) + .setProcessStatus(-1) .build(); responder.onNext(reply); responder.onCompleted();