File tree Expand file tree Collapse file tree 2 files changed +4
-0
lines changed
JShellAPI/src/main/java/org/togetherjava/jshellapi/service Expand file tree Collapse file tree 2 files changed +4
-0
lines changed Original file line number Diff line number Diff line change @@ -206,6 +206,7 @@ public String id() {
206
206
207
207
@ Override
208
208
public void close () {
209
+ LOGGER .debug ("Close called for session {}." , id );
209
210
try {
210
211
dockerService .killContainerByName (containerName ());
211
212
try {
Original file line number Diff line number Diff line change @@ -28,6 +28,7 @@ public class JShellSessionService {
28
28
private void initScheduler () {
29
29
scheduler = Executors .newSingleThreadScheduledExecutor ();
30
30
scheduler .scheduleAtFixedRate (() -> {
31
+ LOGGER .info ("Scheduler heartbeat: started." );
31
32
jshellSessions .keySet ()
32
33
.stream ()
33
34
.filter (id -> jshellSessions .get (id ).isClosed ())
@@ -36,6 +37,7 @@ private void initScheduler() {
36
37
.stream ()
37
38
.filter (id -> jshellSessions .get (id ).shouldDie ())
38
39
.toList ();
40
+ LOGGER .info ("Scheduler heartbeat: sessions ready to die: {}" , toDie );
39
41
for (String id : toDie ) {
40
42
try {
41
43
deleteSession (id );
@@ -81,6 +83,7 @@ public JShellService oneTimeSession(@Nullable StartupScriptId startupScriptId)
81
83
}
82
84
83
85
public void deleteSession (String id ) throws DockerException {
86
+ LOGGER .debug ("Soft delete called for session {}." , id );
84
87
JShellService service = jshellSessions .remove (id );
85
88
service .stop ();
86
89
scheduler .schedule (service ::close , 500 , TimeUnit .MILLISECONDS );
You can’t perform that action at this time.
0 commit comments