We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f380b4f commit 8aecdb8Copy full SHA for 8aecdb8
hitless/handoff_worker.go
@@ -117,6 +117,12 @@ func (hwm *handoffWorkerManager) ensureWorkerAvailable() {
117
// onDemandWorker processes handoff requests and exits when idle
118
func (hwm *handoffWorkerManager) onDemandWorker() {
119
defer func() {
120
+ // Handle panics to ensure proper cleanup
121
+ if r := recover(); r != nil {
122
+ internal.Logger.Printf(context.Background(),
123
+ "hitless: worker panic recovered: %v", r)
124
+ }
125
+
126
// Decrement active worker count when exiting
127
hwm.activeWorkers.Add(-1)
128
hwm.workerWg.Done()
0 commit comments