From 632ca8ddf492c5611f9b48845c6fa5625b65fe51 Mon Sep 17 00:00:00 2001
From: Wangjunqi123 <wangjunqi@kylinos.cn>
Date: Tue, 9 Apr 2024 17:33:08 +0800
Subject: [PATCH] use for-channel in errormanager.initerrormanager()

---
 server/errormanager/errormanager.go | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/server/errormanager/errormanager.go b/server/errormanager/errormanager.go
index ab0cf75..f0690ee 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(), "**")
-- 
Gitee