Synnefo » snf-ganeti

import Control.Applicative

import Control.Concurrent (forkIO)

import Control.Exception (catch)

import qualified Data.ByteString as B

import qualified Data.ByteString.Lazy as BL

import qualified Data.ByteString.UTF8 as UTF8

import qualified Data.ByteString.Lazy.UTF8 as UTF8L

import Data.Word (Word8)

import qualified Network.Socket as S

import System.Directory (removeFile)

import System.IO (hClose, hFlush, hWaitForInput, Handle, IOMode(..))

import Ganeti.Runtime (GanetiDaemon(..), MiscGroup(..), GanetiGroup(..))

import Ganeti.THH

import Ganeti.Utils

-- * Utility functions

        let (status, response) = prepareMsg call_result_json

        return (close, buildResponse status response)

-- | Reads a request, passes it to a handler and sends a response back to the

-- client.

handleClient

    -> IO Bool

handleClient handler client = do

  msg <- recvMsgExt client

  logDebug $ "Received message: " ++ show msg

  case msg of

    RecvConnClosed -> logDebug "Connection closed" >>

                      return False

      sendMsg client outMsg

      return close

-- | Main client loop: runs one loop of 'handleClient', and if that

-- doesn't report a finished (closed) connection, restarts itself.

clientLoop