Skip to content

Commit

Permalink
fix recoverpanic
Browse files Browse the repository at this point in the history
  • Loading branch information
zyxkad committed Apr 5, 2024
1 parent f95d938 commit e64d6cf
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions notify/manager.go
Original file line number Diff line number Diff line change
Expand Up @@ -99,7 +99,7 @@ func (m *Manager) OnEnabled() {
res := make(chan error, 0)
for _, p := range m.plugins {
go func(p Plugin) {
defer log.RecoverPanic()
defer log.RecoverPanic(nil)
res <- p.OnEnabled(e)
}(p)
}
Expand All @@ -117,7 +117,7 @@ func (m *Manager) OnDisabled() {
res := make(chan error, 0)
for _, p := range m.plugins {
go func(p Plugin) {
defer log.RecoverPanic()
defer log.RecoverPanic(nil)
res <- p.OnDisabled(e)
}(p)
}
Expand All @@ -139,7 +139,7 @@ func (m *Manager) OnSyncBegin(count int, size int64) {
res := make(chan error, 0)
for _, p := range m.plugins {
go func(p Plugin) {
defer log.RecoverPanic()
defer log.RecoverPanic(nil)
res <- p.OnSyncBegin(e)
}(p)
}
Expand All @@ -157,7 +157,7 @@ func (m *Manager) OnSyncDone() {
res := make(chan error, 0)
for _, p := range m.plugins {
go func(p Plugin) {
defer log.RecoverPanic()
defer log.RecoverPanic(nil)
res <- p.OnSyncDone(e)
}(p)
}
Expand All @@ -180,7 +180,7 @@ func (m *Manager) OnUpdateAvaliable(release *update.GithubRelease) {
res := make(chan error, 0)
for _, p := range m.plugins {
go func(p Plugin) {
defer log.RecoverPanic()
defer log.RecoverPanic(nil)
res <- p.OnUpdateAvaliable(e)
}(p)
}
Expand Down Expand Up @@ -213,7 +213,7 @@ func (m *Manager) OnReportStatus(stats *Stats) {
res := make(chan error, 0)
for _, p := range m.plugins {
go func(p Plugin) {
defer log.RecoverPanic()
defer log.RecoverPanic(nil)
res <- p.OnReportStatus(e)
}(p)
}
Expand Down

0 comments on commit e64d6cf

Please sign in to comment.