LineBuffering

diff --git a/agitprop.hs b/agitprop.hs
index 0b6399dd85ccb33cd049233d9b707a986eb1a7ca..96669e181add1970ecba44b3b53f6adeeb4ce915 100644 (file)
--- 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.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'
 
 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
   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 df5228e751c6f8b53a0cbfa158257e35a24e14cf..b9fb32d50d6c778dcd032086e84cd80b16dbc7d1 100644 (file)
--- 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           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'
 
 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")
   X.onException
     (printparam "worker" $ fromJust $ fileProcess args)
     (error "-X option required")

diff --git a/konsum.hs b/konsum.hs
index 843757fc6eace3cf67c073d6bd2317ffccbff881..5264373a8499de7e12da810004eb3497cfddeeac 100644 (file)
--- 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 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'
 
 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
   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 a95e90298e2c685cb99c153710094afbda5520e9..52266a75fe4048eb46bc9decb5058fdaa30e5001 100644 (file)
--- a/plane.hs
+++ b/plane.hs
@@ -27,6 +27,8 @@ main = do
   hr "starting"
   tid <- myThreadId
   args <- getArgs >>= parseargs 'p'
   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")
   X.onException
     (printparam "rpc_timeout" [show (rpc_timeout args), "s"])
     (error $ "invalid rpc_timeout")