diff --git a/server/errormanager/errormanager.go b/server/errormanager/errormanager.go index ab0cf75bda450a9c134b0495a2b9ed374e5a68ae..f0690ee5de001305afc7af8ca1602b5f03c027b3 100644 --- a/server/errormanager/errormanager.go +++ b/server/errormanager/errormanager.go @@ -21,7 +21,7 @@ type ErrorManager struct { func InitErrorManager() { GlobalErrorManager = &ErrorManager{ - ErrCh: make(chan *Topoerror, 10), + ErrCh: make(chan *Topoerror, 20), } switch conf.Config().Logopts.Driver { @@ -36,11 +36,11 @@ func InitErrorManager() { } go func(ch <-chan *Topoerror) { - for { - topoerr, ok := <-ch - if !ok { - break - } + for topoerr := range ch { + // topoerr, ok := <-ch + // if !ok { + // break + // } if topoerr.Err != nil { errarr := strings.Split(errors.Cause(topoerr.Err).Error(), "**")