Synnefo » snf-ganeti

/src/mon-collector

/src/htools

/src/hconfd

/src/ganeti-confd

/src/ganeti-mond

/src/rpc-test

	$(HS_ALL_PROGS) $(HS_BUILT_SRCS) \

	$(HS_BUILT_TEST_HELPERS) \

	src/ganeti-confd \

	src/ganeti-mond \

	.hpc/*.mix src/*.tix test/hs/*.tix \

	doc/hs-lint.html

if WANT_HTOOLS

HS_GENERATED_FILES += $(HS_PROGS)

if ENABLE_CONFD

endif

if ENABLE_MOND

HS_COMPILE_PROGS= \

	src/ganeti-mond \

	src/hconfd \

	src/rpc-test

# All Haskell non-test programs to be compiled but not automatically installed

src/ganeti-confd: src/hconfd

	cp -f $< $@

nodist_sbin_SCRIPTS += src/ganeti-confd

endif

if ENABLE_MOND

	  echo "RAPI_GROUP = '$(RAPI_GROUP)'"; \

	  echo "CONFD_USER = '$(CONFD_USER)'"; \

	  echo "CONFD_GROUP = '$(CONFD_GROUP)'"; \

	  echo "NODED_USER = '$(NODED_USER)'"; \

	  echo "NODED_GROUP = '$(NODED_GROUP)'"; \

	  echo "MOND_USER = '$(MOND_USER)'"; \

	  echo 's#@''GNTMASTERUSER@#$(MASTERD_USER)#g'; \

	  echo 's#@''GNTRAPIUSER@#$(RAPI_USER)#g'; \

	  echo 's#@''GNTCONFDUSER@#$(CONFD_USER)#g'; \

	  echo 's#@''GNTNODEDUSER@#$(NODED_USER)#g'; \

	  echo 's#@''GNTMONDUSER@#$(MOND_USER)#g'; \

	  echo 's#@''GNTRAPIGROUP@#$(RAPI_GROUP)#g'; \

	  echo 's#@''GNTADMINGROUP@#$(ADMIN_GROUP)#g'; \

	  echo 's#@''GNTCONFDGROUP@#$(CONFD_GROUP)#g'; \

	  echo 's#@''GNTMASTERDGROUP@#$(MASTERD_GROUP)#g'; \

	  echo 's#@''GNTMONDGROUP@#$(MOND_GROUP)#g'; \

	  echo 's#@''GNTDAEMONSGROUP@#$(DAEMONS_GROUP)#g'; \

  [user_masterd="${withval}masterd";

   user_rapi="${withval}rapi";

   user_confd="${withval}confd";

   user_noded="$user_default";

   user_mond="${withval}mond"],

  [user_masterd="$user_default";

   user_rapi="$user_default";

   user_confd="$user_default";

   user_noded="$user_default";

   user_mond="$user_default"])

AC_SUBST(MASTERD_USER, $user_masterd)

AC_SUBST(RAPI_USER, $user_rapi)

AC_SUBST(CONFD_USER, $user_confd)

AC_SUBST(NODED_USER, $user_noded)

AC_SUBST(MOND_USER, $user_mond)

  [group_rapi="${withval}rapi";

   group_admin="${withval}admin";

   group_confd="${withval}confd";

   group_masterd="${withval}masterd";

   group_noded="$group_default";

   group_daemons="${withval}daemons";

  [group_rapi="$group_default";

   group_admin="$group_default";

   group_confd="$group_default";

   group_masterd="$group_default";

   group_noded="$group_default";

   group_daemons="$group_default";

AC_SUBST(RAPI_GROUP, $group_rapi)

AC_SUBST(ADMIN_GROUP, $group_admin)

AC_SUBST(CONFD_GROUP, $group_confd)

AC_SUBST(MASTERD_GROUP, $group_masterd)

AC_SUBST(NODED_GROUP, $group_noded)

AC_SUBST(DAEMONS_GROUP, $group_daemons)

AC_MSG_NOTICE([Running ganeti-masterd as $group_masterd:$group_masterd])

AC_MSG_NOTICE([Running ganeti-rapi as $user_rapi:$group_rapi])

AC_MSG_NOTICE([Running ganeti-confd as $user_confd:$group_confd])

AC_MSG_NOTICE([Group for daemons is $group_daemons])

AC_MSG_NOTICE([Group for clients is $group_admin])

if _confd_enabled; then

  DAEMONS+=( ganeti-confd )

fi

_mond_enabled() {

NODED_ARGS=

MASTERD_ARGS=

CONFD_ARGS=

RAPI_ARGS=

MOND_ARGS=

    confd)

      echo "@GNTCONFDUSER@:@GNTDAEMONSGROUP@"

      ;;

    rapi)

      echo "@GNTRAPIUSER@:@GNTRAPIGROUP@"

      ;;

  local usergroup=$(_daemon_usergroup $plain_name)

  local daemonexec=$(_daemon_executable $name)

    echo 'ganeti-confd disabled at build time' >&2

    return 1

  fi

RAPI_GROUP = _autoconf.RAPI_GROUP

CONFD_USER = _autoconf.CONFD_USER

CONFD_GROUP = _autoconf.CONFD_GROUP

NODED_USER = _autoconf.NODED_USER

NODED_GROUP = _autoconf.NODED_GROUP

MOND_USER = _autoconf.MOND_USER

NODED = "ganeti-noded"

CONFD = "ganeti-confd"

RAPI = "ganeti-rapi"

MASTERD = "ganeti-masterd"

MOND = "ganeti-mond"

DAEMONS = compat.UniqueFrozenset([

  NODED,

  CONFD,

  RAPI,

  MASTERD,

  MOND,

DAEMONS_LOGBASE = {

  NODED: "node-daemon",

  CONFD: "conf-daemon",

  RAPI: "rapi-daemon",

  MASTERD: "master-daemon",

  MOND: "monitoring-daemon",

  @ivar masterd_gid: The resolved gid of the masterd group

  @ivar confd_uid: The resolved uid of the confd user

  @ivar confd_gid: The resolved gid of the confd group

  @ivar rapi_uid: The resolved uid of the rapi user

  @ivar rapi_gid: The resolved gid of the rapi group

  @ivar noded_uid: The resolved uid of the noded user

    self.confd_uid = GetUid(constants.CONFD_USER, _getpwnam)

    self.confd_gid = GetGid(constants.CONFD_GROUP, _getgrnam)

    self.rapi_uid = GetUid(constants.RAPI_USER, _getpwnam)

    self.rapi_gid = GetGid(constants.RAPI_GROUP, _getgrnam)

    self._uid2user = {

      self.masterd_uid: constants.MASTERD_USER,

      self.confd_uid: constants.CONFD_USER,

      self.rapi_uid: constants.RAPI_USER,

      self.noded_uid: constants.NODED_USER,

      }

    self._gid2group = {

      self.masterd_gid: constants.MASTERD_GROUP,

      self.confd_gid: constants.CONFD_GROUP,

      self.rapi_gid: constants.RAPI_GROUP,

      self.noded_gid: constants.NODED_GROUP,

      self.daemons_gid: constants.DAEMONS_GROUP,

    (pathutils.MASTER_SOCKET, FILE, 0660,

     getent.masterd_uid, getent.daemons_gid, False),

    (pathutils.QUERY_SOCKET, FILE, 0660,

    (pathutils.BDEV_CACHE_DIR, DIR, 0755,

     getent.noded_uid, getent.masterd_gid),

    (pathutils.UIDPOOL_LOCKDIR, DIR, 0750,

import Ganeti.Hash

import Ganeti.Logging

import qualified Ganeti.Constants as C

import Ganeti.Utils

-- * Types and constants definitions

    else logDebug "Invalid magic code!" >> return ()

  return ()

-- | Type alias for prepMain results

-- | Check function for confd.

checkMain :: CheckFn (S.Family, S.SockAddr)

prepMain _ (af_family, bindaddr) = do

  s <- S.socket af_family S.Datagram S.defaultProtocol

  S.bindSocket s bindaddr

  cref <- newIORef (Bad "Configuration not yet loaded")

-- | Main function.

main :: MainFn (S.Family, S.SockAddr) PrepResult

  let cfg_transform :: Result ConfigData -> Result (ConfigData, LinkIpMap)

      cfg_transform = liftM (\cfg -> (cfg, buildLinkIpInstnameMap cfg))

  initConfigReader cfg_transform cref

  hmac <- getClusterHmac

  forever $ listener s hmac (responder cref)

import Data.Maybe (fromMaybe)

import Data.Word

import GHC.IO.Handle (hDuplicateTo)

import qualified Network.Socket as Socket

import System.Console.GetOpt

import System.Exit

                    (resolveAddr port saddr)

                    (ioErrorToResult $ "Invalid address " ++ saddr)

-- | Run an I\/O action that might throw an I\/O error, under a

-- handler that will simply annotate and re-throw the exception.

describeError :: String -> Maybe Handle -> Maybe FilePath -> IO a -> IO a

            -> IO ()

genericMain daemon options check_fn prep_fn exec_fn = do

  let progname = daemonName daemon

  (opts, args) <- parseArgs progname options

  exitUnless (null args) "This program doesn't take any arguments"

  unless (optNoUserChecks opts) $ do

-}

module Ganeti.Query.Server

  ) where

import Control.Applicative

import Control.Concurrent

import Control.Exception

import Data.Bits (bitSize)

import qualified Network.Socket as S

import qualified Text.JSON as J

import Text.JSON (showJSON, JSValue(..))

    then clientLoop client creader

    else closeClient client

  client <- acceptClient socket

  _ <- forkIO $ clientLoop client creader

  cleanupSocket socket_path

  s <- describeError "binding to the Luxi socket"

         Nothing (Just socket_path) $ getServer socket_path

  finally

    (closeServer socket_path server)

  , GanetiGroup(..)

  , RuntimeEnts

  , daemonName

  , daemonUser

  , daemonGroup

  , daemonLogFile

                  | GanetiNoded

                  | GanetiRapi

                  | GanetiConfd

                  | GanetiMond

                    deriving (Show, Enum, Bounded, Eq, Ord)

daemonName GanetiNoded   = C.noded

daemonName GanetiRapi    = C.rapi

daemonName GanetiConfd   = C.confd

daemonName GanetiMond    = C.mond

-- | Returns the log file base for a daemon.

daemonLogBase :: GanetiDaemon -> String

daemonLogBase GanetiMasterd = C.daemonsLogbaseGanetiMasterd

daemonLogBase GanetiNoded   = C.daemonsLogbaseGanetiNoded

daemonLogBase GanetiRapi    = C.daemonsLogbaseGanetiRapi

daemonLogBase GanetiConfd   = C.daemonsLogbaseGanetiConfd

daemonLogBase GanetiMond    = C.daemonsLogbaseGanetiMond

-- | Returns the configured user name for a daemon.

daemonUser GanetiNoded   = C.nodedUser

daemonUser GanetiRapi    = C.rapiUser

daemonUser GanetiConfd   = C.confdUser

daemonUser GanetiMond    = C.mondUser

-- | Returns the configured group for a daemon.

daemonGroup (DaemonGroup GanetiNoded)   = C.nodedGroup

daemonGroup (DaemonGroup GanetiRapi)    = C.rapiGroup

daemonGroup (DaemonGroup GanetiConfd)   = C.confdGroup

daemonGroup (DaemonGroup GanetiMond)    = C.mondGroup

daemonGroup (ExtraGroup  DaemonsGroup)  = C.daemonsGroup

daemonGroup (ExtraGroup  AdminGroup)    = C.adminGroup

  , sSKeyFromRaw

  , getPrimaryIPFamily

  , getMasterCandidatesIps

  , keyToFilename

  , sSFilePrefix

  ) where

getMasterCandidatesIps optPath = do

  result <- readSSConfFile optPath Nothing SSMasterCandidatesIps

  return $ liftM lines result

              \         constants.NODED_USER,\n\

              \         constants.RAPI_USER,\n\

              \         constants.CONFD_USER,\n\

              \         constants.MOND_USER,\n\

              \        ]\n\

              \groups = [constants.MASTERD_GROUP,\n\

              \          constants.NODED_GROUP,\n\

              \          constants.RAPI_GROUP,\n\

              \          constants.CONFD_GROUP,\n\

              \          constants.MOND_GROUP,\n\

              \          constants.DAEMONS_GROUP,\n\

              \          constants.ADMIN_GROUP,\n\

STOPDAEMONS_LIST="rapi masterd noded"

if grep -q '^ENABLE_CONFD = True' lib/_autoconf.py; then

fi

if grep -q '^ENABLE_MOND = True' lib/_autoconf.py; then

addgroup --system @GNTMASTERUSER@

addgroup --system @GNTRAPIUSER@

addgroup --system @GNTCONFDUSER@

addgroup --system @GNTMONDUSER@

#Create users

adduser --system --ingroup @GNTMASTERDGROUP@ @GNTMASTERUSER@

adduser --system --ingroup @GNTRAPIGROUP@ @GNTRAPIUSER@

adduser --system --ingroup @GNTCONFDGROUP@ @GNTCONFDUSER@

adduser --system --ingroup @GNTMONDGROUP@ @GNTMONDUSER@

adduser --system @GNTNODEDUSER@

#Add users to extra groups

do

  adduser $u @GNTDAEMONSGROUP@

done

adduser @GNTMASTERUSER@ @GNTCONFDGROUP@

adduser @GNTMONDUSER@ @GNTMASTERDGROUP@

MASTERD_ARGS=''

RAPI_ARGS='$daemon_args'

CONFD_ARGS='$daemon_args'

export GANETI_ROOTDIR='$nodedir'

export GANETI_HOSTNAME='$(node_hostname $number)'