}
// Propagate towards parent if there is one
+ sweepParent();
+ }
+
+ private void sweepParent() {
final ReactorStmtCtx<?, ?, ?> parent = getParentContext();
if (parent != null) {
parent.sweepOnChildDecrement();
// parent is potentially reclaimable
if (noParentRef()) {
- LOG.trace("Cleanup {} of parent {}", refcount, this);
+ LOG.trace("Cleanup {} of parent {}", refs, this);
if (sweepState()) {
- final ReactorStmtCtx<?, ?, ?> parent = getParentContext();
- if (parent != null) {
- parent.sweepOnChildDecrement();
- }
+ sweepParent();
}
}
}