Synnefo » snf-ganeti

# empty file for package definition

        # we need the children open in case the device itself has to

        # be assembled

        try:

          crdev.Open()

        except errors.BlockDeviceError, err:

          errmsg = "Can't make child '%s' read-write: %s" % (child, err)

  try:

    result = _RecursiveAssembleBD(disk, owner, as_primary)

    if isinstance(result, bdev.BlockDev):

      result = result.dev_path

  except errors.BlockDeviceError, err:

    result = "Error while assembling disk: %s" % str(err)

    """

    if hooks_base_dir is None:

      hooks_base_dir = constants.HOOKS_BASE_DIR

  @staticmethod

  def ExecHook(script, env):

      self.est_time = None

  """Base DRBD class.

  This class contains a few bits of common functionality between the

                       " in order to ensure more consistent results")

  """Macro-like function denoting a fixed number of arguments"""

  return -val

  """Macro-like function denoting a minimum number of arguments"""

  return val

  if unitfields is None:

    unitfields = []

  format_fields = []

  for field in fields:

    self.recalculate_locks = {}

    self.__ssh = None

    # logging

    for attr_name in self._OP_REQP:

      attr_val = getattr(op, attr_name, None)

    del self.recalculate_locks[locking.LEVEL_NODE]

  """Simple LU which runs no hooks.

  This LU is intended as a parent for other LogicalUnits which will

                  " Domain Name.")

  """Generic tags LU.

  This is an abstract class which is the parent of all the other tags LUs.

    # Do the secret SSL handshake

    if self.using_ssl:

      try:

        http.Handshake(self.sock, self.WRITE_TIMEOUT)

      except http.HttpSessionHandshakeUnexpectedEOF:

      if serial is None:

        # There must be a serious problem

      if not must_lock:

        queue_lock.Unlock()

  except:

    # the test cases.

    return utils.any((self._is_owned(l) for l in LEVELS[level + 1:]))

    """Check if the current thread owns the BGL.

    Both an exclusive or a shared acquisition work.

    """

    return BGL in self.__keyring[LEVEL_CLUSTER]._list_owned()

    """Check if the level contains the BGL.

    Check if acting on the given level and set of names will change

    """

    self.context = context

    self._feedback_fn = None

    self.rpc = rpc.RpcRunner(context.cfg)

  def _ExecLU(self, lu):

    """Fill defaults for missing configuration values.

    """

    if self.hvparams is None:

      self.hvparams = constants.HVC_DEFAULTS

    else:

"""

import logging

from ganeti import luxi

"""

import cgi

import re

"""

from ganeti import opcodes

from ganeti import http

from ganeti import constants

from ganeti.rapi import baserlib

I_FIELDS = ["name", "admin_state", "os",

            "pnode", "snodes",

            "disk_template",

from ganeti import constants

from ganeti import errors

# Module level variable

  Must be called before using any RPC function.

  """

  assert not _http_manager, "RPC module initialized more than once"

  Must be called before quitting the program.

  """

  if _http_manager:

    _http_manager.Shutdown()

backend (currently json).

"""

import simplejson

import re