fix(qwp): robust pooled store-and-forward slot lifecycle — distinct ids, startup recovery, prompt close() - #53

Merged

bluestreak01 merged 29 commits into

mainfrom

fix/pool-sf-slot-collision

Jun 24, 2026

Commits on Jun 17, 2026

fix(pool): give pooled store-and-forward senders distinct slot ids
bluestreak01
committed

Commits on Jun 18, 2026

Harden pool teardown against Errors + exclude pool slot namespace from orphan drain
bluestreak01
committed
Fix SF pool freeing a slot index while its flock is still held
bluestreak01
committed
Merge remote-tracking branch 'origin/main' into fix/pool-sf-slot-collision
bluestreak01
committed
test(pool): migrate SenderPoolSfTest to ephemeral-port TestWebSocketServer API
bluestreak01
committed
Make leaked SF slots observable + harden pool construction
bluestreak01
committed
fix(pool): catch Throwable on all pool creation paths, not just RuntimeException
bluestreak01
committed
fix(pool): bound orphan-drain exclusion to [0,maxSize) so shrinking maxSize doesn't strand SF data
bluestreak01
committed
fix(pool): discard pooled sender when flush() exits with an Error
bluestreak01
committed
fix(pool): widen QuestDBImpl ctor cleanup catch to Throwable
bluestreak01
committed
fix(pool): recover stranded in-range SF slots at pool startup
bluestreak01
committed
test(pool): cover flush() Error -> discardBroken regression
bluestreak01
committed
test(pool): cover borrow-path SF slot-index release on creation failure
bluestreak01
committed

Commits on Jun 23, 2026