X-Git-Url: https://git.argeo.org/?a=blobdiff_plain;f=org.argeo.cms.jshell%2Fsrc%2Forg%2Fargeo%2Fcms%2Fjshell%2FSocketPipeMirror.java;h=7a2332bed1a38c6dbb202a349b5888493fe3db59;hb=9a975983b2f3509a287dfb5751799544ec97ce70;hp=f763d54b6067cb4cfbf4015fc208911fa56cc461;hpb=2c5da70747629282585d5515720dcb1515a0011c;p=lgpl%2Fargeo-commons.git

diff --git a/org.argeo.cms.jshell/src/org/argeo/cms/jshell/SocketPipeMirror.java b/org.argeo.cms.jshell/src/org/argeo/cms/jshell/SocketPipeMirror.java
index f763d54b6..7a2332bed 100644
--- a/org.argeo.cms.jshell/src/org/argeo/cms/jshell/SocketPipeMirror.java
+++ b/org.argeo.cms.jshell/src/org/argeo/cms/jshell/SocketPipeMirror.java
@@ -20,7 +20,10 @@ class SocketPipeMirror implements Closeable {
 	private Thread readInThread;
 	private Thread writeOutThread;
 
-	public SocketPipeMirror() throws IOException {
+	private final String id;
+
+	public SocketPipeMirror(String id) throws IOException {
+		this.id = id;
 		inPipe = Pipe.open();
 		outPipe = Pipe.open();
 		in = Channels.newInputStream(inPipe.source());
@@ -45,7 +48,7 @@ class SocketPipeMirror implements Closeable {
 			} catch (IOException e) {
 				e.printStackTrace();
 			}
-		}, "Read in");
+		}, "JShell read " + id);
 		readInThread.start();
 
 		writeOutThread = new Thread(() -> {
@@ -62,7 +65,7 @@ class SocketPipeMirror implements Closeable {
 			} catch (IOException e) {
 				e.printStackTrace();
 			}
-		}, "Write out");
+		}, "JShell write " + id);
 		writeOutThread.start();
 
 	}
@@ -70,10 +73,20 @@ class SocketPipeMirror implements Closeable {
 	@Override
 	public void close() throws IOException {
 		// TODO make it more robust
-		readInThread.interrupt();
-		writeOutThread.interrupt();
+//		readInThread.interrupt();
+//		writeOutThread.interrupt();
 		in.close();
 		out.close();
+		try {
+			readInThread.join();
+		} catch (InterruptedException e) {
+			// silent
+		}
+		try {
+			writeOutThread.join();
+		} catch (InterruptedException e) {
+			// silent
+		}
 	}
 
 	public InputStream getInputStream() {