From edcf69f3fc94db1883be556ef2f427d0da48ae24 Mon Sep 17 00:00:00 2001
From: Frank Doepper <woffs@woffs.de>
Date: Mon, 8 Jul 2024 13:52:24 +0200
Subject: [PATCH] LineBuffering

---
 agitprop.hs | 3 +++
 arbeite.hs  | 3 +++
 konsum.hs   | 3 +++
 plane.hs    | 2 ++
 4 files changed, 11 insertions(+)

diff --git a/agitprop.hs b/agitprop.hs
index 0b6399d..96669e1 100644
--- a/agitprop.hs
+++ b/agitprop.hs
@@ -33,12 +33,15 @@ import           System.FilePath.Posix.ByteString
 import           System.INotify
 #endif
 import qualified System.Posix.Files.ByteString    as F
+import           System.IO
 
 main :: IO ()
 main = do
   hr "starting"
   tid <- myThreadId
   args <- getArgs >>= parseargs 'a'
+  hSetBuffering stdout LineBuffering
+  hSetBuffering stderr LineBuffering
   printparam "client version" ["amqp-utils", showVersion version]
   printparam "routing key" $ rKey args
   printparam "exchange" $ currentExchange args
diff --git a/arbeite.hs b/arbeite.hs
index df5228e..b9fb32d 100644
--- a/arbeite.hs
+++ b/arbeite.hs
@@ -21,12 +21,15 @@ import           Network.AMQP.Utils.Helpers
 import           Network.AMQP.Utils.Options
 import           Paths_amqp_utils              (version)
 import           System.Environment
+import           System.IO
 
 main :: IO ()
 main = do
   hr "starting"
   tid <- myThreadId
   args <- getArgs >>= parseargs 'r'
+  hSetBuffering stdout LineBuffering
+  hSetBuffering stderr LineBuffering
   X.onException
     (printparam "worker" $ fromJust $ fileProcess args)
     (error "-X option required")
diff --git a/konsum.hs b/konsum.hs
index 843757f..5264373 100644
--- a/konsum.hs
+++ b/konsum.hs
@@ -14,12 +14,15 @@ import Network.AMQP.Utils.Helpers
 import Network.AMQP.Utils.Options
 import Paths_amqp_utils (version)
 import System.Environment
+import System.IO
 
 main :: IO ()
 main = do
   hr "starting"
   tid <- myThreadId
   args <- getArgs >>= parseargs 'k'
+  hSetBuffering stdout LineBuffering
+  hSetBuffering stderr LineBuffering
   let addiArgs = reverse $ additionalArgs args
   printparam "client version" ["amqp-utils", showVersion version]
   (conn, chan) <- connect args
diff --git a/plane.hs b/plane.hs
index a95e902..52266a7 100644
--- a/plane.hs
+++ b/plane.hs
@@ -27,6 +27,8 @@ main = do
   hr "starting"
   tid <- myThreadId
   args <- getArgs >>= parseargs 'p'
+  hSetBuffering stdout LineBuffering
+  hSetBuffering stderr LineBuffering
   X.onException
     (printparam "rpc_timeout" [show (rpc_timeout args), "s"])
     (error $ "invalid rpc_timeout")
-- 
2.39.5