Mirrors/go-inbucket
1
0
Fork 0
mirror of https://github.com/jhillyerd/inbucket.git synced 2025-12-18 01:57:02 +00:00
Code Issues Releases Wiki Activity

msghub: Recover and log panics (#336)

Browse Source 
Signed-off-by: James Hillyerd <james@hillyerd.com>
This commit is contained in:
James Hillyerd
2023-02-14 14:00:13 -08:00
committed by GitHub
parent de617b6a73
commit ef12d02b83
1 changed files with 16 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
pkg/msghub/hub.go
View File

@@ -6,6 +6,7 @@ import (
"github.com/inbucket/inbucket/pkg/extension" "github.com/inbucket/inbucket/pkg/extension"
"github.com/inbucket/inbucket/pkg/extension/event" "github.com/inbucket/inbucket/pkg/extension/event"
"github.com/rs/zerolog/log"
) )
// Length of msghub operation queue // Length of msghub operation queue
@@ -53,7 +54,7 @@ func (hub *Hub) Start(ctx context.Context) {
close(hub.opChan) close(hub.opChan)
return return
case op := <-hub.opChan: case op := <-hub.opChan:
op(hub) hub.runOp(op)
} }
} }
} }
@@ -108,3 +109,17 @@ func (hub *Hub) Sync() {
} }
<-done <-done
} }
func (hub *Hub) runOp(op func(*Hub)) {
defer func() {
if r := recover(); r != nil {
if err, ok := r.(error); ok {
log.Error().Str("module", "msghub").Err(err).Msg("Operation panicked")
} else {
log.Error().Str("module", "msghub").Err(err).Msgf("Operation panicked: %s", r)
}
}
}()
op(hub)
}