Synnefo » snf-ganeti

import Control.Concurrent

import Control.Exception

import qualified Data.ByteString as B

import Data.IORef

import Data.List

import qualified Data.Map as M

import qualified Network.Socket as S

import Prelude hiding (catch)

import System.Posix.Files

buildResponse cdata (ConfdRequest { confdRqType = ReqNodePipByInstPip

                                  , confdRqQuery = DictQuery query}) =

  let (cfg, linkipmap) = cdata

  in case confdReqQIp query of

       Just ip -> return $ getNodePipByInstanceIp cfg linkipmap link ip

       Nothing -> return (ReplyStatusOk,

-- | Wrapper over 'buildFileStatus'. This reads the data from the

-- filesystem and then builds our cache structure.

getFStat :: FilePath -> IO FStat

-- | Check if the file needs reloading

needsReload :: FStat -> FilePath -> IO (Maybe FStat)

onReloadTimer :: IO Bool -> FilePath -> CRef -> MVar ServerState -> IO ()

onReloadTimer inotiaction path cref state = do

  continue <- modifyMVar state (onReloadInner inotiaction path cref)

-- | Inner onReload handler.

--

                   _            -> True

  return (state' { reloadModel = newmode }, continue)

-- | Setup inotify watcher.

--

-- This tries to setup the watch descriptor; in case of any IO errors,