Skip to content

Commit 1bb2473

Browse files
committed
Issue with exit callback
1 parent 6e0bb22 commit 1bb2473

File tree

1 file changed

+8
-7
lines changed
  • src/main/java/oracle/kubernetes/operator/work

1 file changed

+8
-7
lines changed

src/main/java/oracle/kubernetes/operator/work/Fiber.java

Lines changed: 8 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -453,6 +453,14 @@ public void run() {
453453
if (!doRun(next)) {
454454
completionCheck();
455455
}
456+
457+
// Trigger exitCallback
458+
synchronized (this) {
459+
if (exitCallback != null && exitCallback != PLACEHOLDER) {
460+
exitCallback.onExit();
461+
}
462+
exitCallback = PLACEHOLDER;
463+
}
456464
} finally {
457465
ContainerResolver.getDefault().exitContainer(oldContainer);
458466
CURRENT_FIBER.set(oldFiber);
@@ -478,13 +486,6 @@ private void completionCheck() {
478486
completionCallback.onCompletion(packet);
479487
}
480488
}
481-
// Trigger exitCallback
482-
synchronized (this) {
483-
if (exitCallback != null && exitCallback != PLACEHOLDER) {
484-
exitCallback.onExit();
485-
}
486-
exitCallback = PLACEHOLDER;
487-
}
488489
}
489490
} finally {
490491
lock.unlock();

0 commit comments

Comments
 (0)