|
| 1 | +{-# LANGUAGE BlockArguments #-} |
1 | 2 | {-# LANGUAGE DataKinds #-} |
2 | 3 | {-# LANGUAGE FlexibleInstances #-} |
3 | 4 | {-# LANGUAGE PackageImports #-} |
@@ -38,6 +39,7 @@ import Control.Monad (void) |
38 | 39 | import Control.Monad.IO.Class |
39 | 40 | import "contra-tracer" Control.Tracer (Tracer, contramap, nullTracer, stdoutTracer) |
40 | 41 | import qualified Data.ByteString.Lazy as LBS |
| 42 | +import Data.Maybe (isNothing) |
41 | 43 | import Data.Void (Void, absurd) |
42 | 44 | import Data.Word (Word16) |
43 | 45 | import qualified Network.Mux as Mux |
@@ -75,7 +77,12 @@ initForwardingDelayed :: forall m. (MonadIO m) |
75 | 77 | -> Maybe (FilePath, ForwarderMode) |
76 | 78 | -> m (ForwardSink TraceObject, DataPointStore, IO ()) |
77 | 79 | initForwardingDelayed iomgr config magic ekgStore tracerSocketMode = liftIO $ do |
78 | | - forwardSink <- initForwardSink tfConfig handleOverflow |
| 80 | + let ignoreOverflow, onOverflow :: [TraceObject] -> IO () |
| 81 | + ignoreOverflow _ = |
| 82 | + pure () |
| 83 | + onOverflow | isNothing tracerSocketMode = ignoreOverflow |
| 84 | + | otherwise = handleOverflow |
| 85 | + forwardSink <- initForwardSink tfConfig onOverflow |
79 | 86 | dpStore <- initDataPointStore |
80 | 87 | let |
81 | 88 | kickoffForwarder = launchForwarders |
|
0 commit comments