From 86e48bf0dea70d58d2577b19635f939e7e0c8fe1 Mon Sep 17 00:00:00 2001 From: Jens Nolte <jens@nightmarestudio.de> Date: Sun, 20 Sep 2020 23:11:17 +0200 Subject: [PATCH] Minor changes --- src/QBar/Blocks/CpuUsage.hs | 6 +++--- src/QBar/ControlSocket.hs | 18 ++++++++++-------- 2 files changed, 13 insertions(+), 11 deletions(-) diff --git a/src/QBar/Blocks/CpuUsage.hs b/src/QBar/Blocks/CpuUsage.hs index 505ed4e..e117733 100644 --- a/src/QBar/Blocks/CpuUsage.hs +++ b/src/QBar/Blocks/CpuUsage.hs @@ -3,15 +3,15 @@ module QBar.Blocks.CpuUsage where import QBar.BlockHelper +import QBar.BlockOutput +import QBar.Blocks.Utils +import QBar.Core import Control.Applicative ((<|>)) import Control.Lens import Control.Monad.State (StateT, evalStateT, lift) import qualified Data.Attoparsec.Text.Lazy as AT import qualified Data.Text.Lazy as T -import QBar.BlockOutput -import QBar.Blocks.Utils -import QBar.Core {- For time accounting the guest fields need to be ignored according to the kernel source code diff --git a/src/QBar/ControlSocket.hs b/src/QBar/ControlSocket.hs index 3095aa6..7402cd7 100644 --- a/src/QBar/ControlSocket.hs +++ b/src/QBar/ControlSocket.hs @@ -76,7 +76,7 @@ data ReconnectMode a = ReconnectNoResend | ReconnectSendLatest a reconnectClient :: forall up down. ReconnectMode up -> BarIO (Consumer up IO (), Producer down IO ()) -> BarIO (Consumer up IO (), Producer down IO ()) reconnectClient reconnectMode connectClient = do (upConsumer, upProducer) <- case reconnectMode of - ReconnectNoResend -> liftIO $ mkBroadcastP + ReconnectNoResend -> liftIO mkBroadcastP ReconnectSendLatest initial -> liftIO $ mkBroadcastCacheP initial (downOutput, downInput) <- liftIO $ spawn unbounded @@ -234,13 +234,6 @@ connectIpcSocket options = do connect sock $ SockAddrUnix socketPath return sock -$(deriveJSON defaultOptions ''Request) -$(deriveJSON defaultOptions ''Command) -$(deriveJSON defaultOptions ''CommandResult) -$(deriveJSON defaultOptions ''StreamType) -$(deriveJSON defaultOptions ''BlockStream) -$(deriveJSON defaultOptions ''MirrorStream) - sendIpc :: Command -> MainOptions -> IO () sendIpc command options@MainOptions{verbose} = do result <- sendIpc' command options @@ -380,3 +373,12 @@ listenUnixSocket options@MainOptions{verbose} bar commandHandler = do handleError = encode . Error . pack . show errorResponse :: Text -> Producer ByteString IO () errorResponse message = encode $ Error message + + +$(deriveJSON defaultOptions ''Request) +$(deriveJSON defaultOptions ''Command) +$(deriveJSON defaultOptions ''CommandResult) +$(deriveJSON defaultOptions ''StreamType) +$(deriveJSON defaultOptions ''BlockStream) +$(deriveJSON defaultOptions ''MirrorStream) + -- GitLab