extend response queue size x 100.

response queue should not drop responses as much as possible.
kayac · Oct 29, 2020 · 1449698 · 1449698
1 parent 5993f85
commit 1449698
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/supervisor.go b/supervisor.go
@@ -192,7 +192,7 @@ func StartSupervisor(conf *config.Config) (Supervisor, error) {
 		worker := Worker{
 			id:    i,
 			queue: make(chan Request, wqSize),
-			respq: make(chan SenderResponse, wqSize),
+			respq: make(chan SenderResponse, wqSize*100),
 			wgrp:  &sync.WaitGroup{},
 			sn:    SenderNum,
 			ac:    ac,