From f9b9fdb195f67298ae1ba2236dd4986360d8ade2 Mon Sep 17 00:00:00 2001
From: lspgn <lspgn@users.noreply.github.com>
Date: Sat, 6 Jan 2024 00:58:36 -0800
Subject: [PATCH] goflow2: zero queue_size means blocking

---
 cmd/goflow2/main.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/cmd/goflow2/main.go b/cmd/goflow2/main.go
index 1e68f69..9697c0a 100644
--- a/cmd/goflow2/main.go
+++ b/cmd/goflow2/main.go
@@ -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 {