Synnefo » snf-ganeti

-- | Server state data type.

data ServerState = ServerState

  { reloadModel  :: ReloadModel

  , reloadFStat  :: FStat

  }

-- | Ratelimit timeout in microseconds.

configReloadRatelimit :: Int

-- | Initial poll round.

initialPoll :: ReloadModel

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

onTimeoutTimer inotiaction path cref state = do

  threadDelay configReloadTimeout

  modifyMVar_ state (onTimeoutInner path cref)

  _ <- inotiaction

  onTimeoutTimer inotiaction path cref state

-- notification.

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

onReloadTimer inotiaction path cref state = do

  continue <- modifyMVar state (onReloadInner inotiaction path cref)

  when continue $

    do threadDelay configReloadRatelimit

  modifyMVar_ mstate $ \state ->

    if reloadModel state == ReloadNotify

       then do

         (newfstat, _) <- safeUpdateConfig path (reloadFStat state) cref

         let state' = state { reloadFStat = newfstat, reloadTime = ctime }

           then do

             mode <- moveToPolling "too many reloads" inotify path cref mstate

             return state' { reloadModel = mode }