affine/jobserv
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

log all connections

Browse source
This commit is contained in:
Aidan Hahn 2019-05-26 22:00:52 -07:00
parent 97e2310c22
commit da4d92de60
No known key found for this signature in database
GPG key ID: 327711E983899316
2 changed files with 7 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

2
src/main/java/JobServ/ProcessController.java
View file

@ -50,6 +50,8 @@ class ProcessController {
this.input = this.process.getInputStream(); this.input = this.process.getInputStream();
this.inputIntermediateStream = new InputStreamReader(this.input); this.inputIntermediateStream = new InputStreamReader(this.input);
this.reader = new BufferedReader(this.inputIntermediateStream); this.reader = new BufferedReader(this.inputIntermediateStream);
JobServServer.logger.write("Job " + String.valueOf(this.pid) + ": " + command);
} }
/* /*

5
src/main/java/JobServ/ShellServerService.java
View file

@ -33,6 +33,7 @@ class ShellServerService extends ShellServerGrpc.ShellServerImplBase {
public void getStatus(PIDMessage request, public void getStatus(PIDMessage request,
StreamObserver<StatusMessage> responder) { StreamObserver<StatusMessage> responder) {
JobServServer.logger.write("New status request for pid: " + String.valueOf(request.getPid()));
int status = manager.getProcessStatus(request.getPid()); int status = manager.getProcessStatus(request.getPid());
StatusMessage reply = StatusMessage.newBuilder() StatusMessage reply = StatusMessage.newBuilder()
@ -50,6 +51,7 @@ class ShellServerService extends ShellServerGrpc.ShellServerImplBase {
public void getOutput(OutputRequestMessage request, public void getOutput(OutputRequestMessage request,
StreamObserver<OutputMessage> responder) { StreamObserver<OutputMessage> responder) {
JobServServer.logger.write("New Output request for pid: " + String.valueOf(request.getPid()));
String output = manager.getProcessOutput(request.getPid(), String output = manager.getProcessOutput(request.getPid(),
request.getLines()); request.getLines());
@ -69,6 +71,7 @@ class ShellServerService extends ShellServerGrpc.ShellServerImplBase {
StreamObserver<PIDMessage> responder) { StreamObserver<PIDMessage> responder) {
String command = request.getCommand(); String command = request.getCommand();
JobServServer.logger.write("New job request: " + command);
int newPid = manager.newProcess(command); int newPid = manager.newProcess(command);
PIDMessage reply = PIDMessage.newBuilder() PIDMessage reply = PIDMessage.newBuilder()
@ -86,6 +89,7 @@ class ShellServerService extends ShellServerGrpc.ShellServerImplBase {
public void getReturn(PIDMessage request, public void getReturn(PIDMessage request,
StreamObserver<ReturnMessage> responder) { StreamObserver<ReturnMessage> responder) {
JobServServer.logger.write("New request for return from job: " + String.valueOf(request.getPid()));
int retVal = manager.getProcessReturn(request.getPid()); int retVal = manager.getProcessReturn(request.getPid());
ReturnMessage reply = ReturnMessage.newBuilder() ReturnMessage reply = ReturnMessage.newBuilder()
@ -103,6 +107,7 @@ class ShellServerService extends ShellServerGrpc.ShellServerImplBase {
public void killJob(PIDMessage request, public void killJob(PIDMessage request,
StreamObserver<StatusMessage> responder) { StreamObserver<StatusMessage> responder) {
JobServServer.logger.write("New Request to kill job: " + String.valueOf(request.getPid()));
int status = manager.killProcess(request.getPid()); int status = manager.killProcess(request.getPid());
StatusMessage reply = StatusMessage.newBuilder() StatusMessage reply = StatusMessage.newBuilder()