Spring/spring-tools
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

More debug info re closing docker client connections

Browse Source
This commit is contained in:
Kris De Volder
2020-10-01 12:11:43 -07:00
parent 7fa87a2203
commit afe842bcd1
1 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
eclipse-extensions/org.springframework.ide.eclipse.boot.dash.docker/src/org/springframework/ide/eclipse/boot/dash/docker/runtarget/DockerContainer.java
View File

@@ -420,6 +420,13 @@ public class DockerContainer implements App, RunStateProvider, JmxConnectable, S
*/
private static AtomicInteger activeLogHandlers = new AtomicInteger();
/**
* For debugging purposes. Keep track of number of calls to start for which there
* isn't yet a corresponding 'close' call.
*/
private static AtomicInteger startedLogHandlers = new AtomicInteger();
private static class LogHandler implements ResultCallback<Frame>{
private AtomicBoolean isClosed = new AtomicBoolean();
@@ -455,6 +462,7 @@ public class DockerContainer implements App, RunStateProvider, JmxConnectable, S
public void close() {
if (isClosed.compareAndSet(false, true)) {
closeable.thenAccept(c -> {
Log.info("Closing ResultCallback. Now active: "+startedLogHandlers.decrementAndGet());
try {
c.close();
} catch (IOException e) {
@@ -479,6 +487,7 @@ public class DockerContainer implements App, RunStateProvider, JmxConnectable, S
@Override
public void onStart(Closeable closeable) {
Log.info("ResultCallback.onStart. Now active: "+startedLogHandlers.incrementAndGet());
this.closeable.complete(closeable);
}