goflow2: zero queue_size means blocking

2024-05-06 15:54:52 +00:00 · 2024-01-06 00:58:36 -08:00
parent ff4ddca5d5
commit f9b9fdb195
1 changed files with 4 additions and 0 deletions
@@ -226,6 +226,10 @@ func main() {
 			queueSize = 1000000
 		}

+		if queueSize == 0 {
+			isBlocking = true
+		}
+
 		hostname := listenAddrUrl.Hostname()
 		port, err := strconv.ParseUint(listenAddrUrl.Port(), 10, 64)
 		if err != nil {