summaryrefslogtreecommitdiff
path: root/clientserver/src/mill/clientserver/Client.scala
diff options
context:
space:
mode:
Diffstat (limited to 'clientserver/src/mill/clientserver/Client.scala')
-rw-r--r--clientserver/src/mill/clientserver/Client.scala9
1 files changed, 8 insertions, 1 deletions
diff --git a/clientserver/src/mill/clientserver/Client.scala b/clientserver/src/mill/clientserver/Client.scala
index dcf65271..b7a39cb2 100644
--- a/clientserver/src/mill/clientserver/Client.scala
+++ b/clientserver/src/mill/clientserver/Client.scala
@@ -34,14 +34,17 @@ class Client(lockBase: String,
stdout: OutputStream,
stderr: OutputStream) extends ClientServer(lockBase){
def run(args: Array[String]) = {
-
+ println("Client Run")
val f = new FileOutputStream(runFile)
ClientServer.writeArgs(System.console() != null, args, f)
f.close()
if (locks.processLock.probe()) initServer()
while(locks.processLock.probe()) Thread.sleep(3)
+ println("Client Connect Socket")
+
val ioSocket = ClientServer.retry(1000, new UnixDomainSocket(ioPath))
+ println("Client Connected Socket")
val outErr = ioSocket.getInputStream
val in = ioSocket.getOutputStream
val outPump = new ClientOutputPumper(outErr, stdout, stderr)
@@ -52,6 +55,10 @@ class Client(lockBase: String,
inThread.setDaemon(true)
outThread.start()
inThread.start()
+ println("Client Await Server Lock")
+
locks.serverLock.await()
+ println("Client End")
+
}
}