diff --git a/src/QBar/Blocks/CpuUsage.hs b/src/QBar/Blocks/CpuUsage.hs index 505ed4edfd3e4dbee67b69702cc275138a789b9a..e1177337447ecc7aa1c3306e4d55eb7401988dba 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 3095aa6f06151dc5d16300c1c5d906bb9ce8f41e..7402cd74be74f48d834e9241f5c81aaee74bc4fa 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) +