give default configuration value for QueueCount

2022-04-21 12:29:43 +08:00 · 2022-04-21 12:29:43 +08:00 · e00f102703
parent 3921627fa2
commit e00f102703
1 changed files with 4 additions and 0 deletions
--- a/src/server/config/config.go
+++ b/src/server/config/config.go
@ -109,6 +109,10 @@ func MustLoad(fpaths ...string) {
 			C.WriterOpt.QueuePopSize = 1000
 		}

+		if C.WriterOpt.QueueCount <= 0 {
+			C.WriterOpt.QueueCount = 100
+		}
+
 		fmt.Println("heartbeat.ip:", C.Heartbeat.IP)
 		fmt.Printf("heartbeat.interval: %dms\n", C.Heartbeat.Interval)
 	})