/ - Diff - snf-ganeti - Greek Research and Technology Network's projects

       """
     def GetInstReasonFilename(instance_name):
       """Path of the file containing the reason of the instance status change.
       @type instance_name: string
       @param instance_name: The name of the instance
       @rtype: string
       @return: The path of the file
       """
       return utils.PathJoin(pathutils.INSTANCE_REASON_DIR, instance_name)
     class InstReason(object):
       """Class representing the reason for a change of state of a VM.
       It is used to allow an easy serialization of the reason, so that it can be
       written on a file.
       """
       def __init__(self, source, text):
         """Initialize the class with all the required values.
         @type text: string
         @param text: The textual description of the reason for changing state
         @type source: string
         @param source: The source of the state change (RAPI, CLI, ...)
         """
         self.source = source
         self.text = text
       def GetJson(self):
         """Get the JSON representation of the InstReason.
         @rtype: string
         @return : The JSON representation of the object
         """
         return serializer.DumpJson(dict(source=self.source, text=self.text))
       def Store(self, instance_name):
         """Serialize on a file the reason for the last state change of an instance.
         The exact location of the file depends on the name of the instance and on
         the configuration of the Ganeti cluster defined at deploy time.
         @type instance_name: string
         @param instance_name: The name of the instance
         @rtype: None
         """
         filename = GetInstReasonFilename(instance_name)
         utils.WriteFile(filename, data=self.GetJson())
     def _Fail(msg, *args, **kwargs):
       """Log an error and the raise an RPCFail exception.

       "PRIORITY_OPT",
       "RAPI_CERT_OPT",
       "READD_OPT",
       "REASON_OPT",
       "REBOOT_TYPE_OPT",
       "REMOVE_INSTANCE_OPT",
       "REMOVE_RESERVED_IPS_OPT",
-...
                                   help=("Hide successful results and show failures"
                                         " only (determined by the exit code)"))
     REASON_OPT = cli_option("--reason", default=None,
                             help="The reason for executing a VM-state-changing"
                                  " operation")
     def _PriorityOptionCb(option, _, value, parser):
       """Callback for processing C{--priority} option.

       return opcodes.OpInstanceReboot(instance_name=name,
                                       reboot_type=opts.reboot_type,
                                       ignore_secondaries=opts.ignore_secondaries,
                                       shutdown_timeout=opts.shutdown_timeout)
                                       shutdown_timeout=opts.shutdown_timeout,
                                       reason=(constants.INSTANCE_REASON_SOURCE_CLI,
                                               opts.reason))
     def _ShutdownInstance(name, opts):

     # The version identifier for builtin data collectors
     BUILTIN_DATA_COLLECTOR_VERSION = "B"
     # The source reasons for the change of state of an instance
     INSTANCE_REASON_SOURCE_CLI = "cli"
     INSTANCE_REASON_SOURCE_RAPI = "rapi"
     INSTANCE_REASON_SOURCE_UNKNOWN = "unknown"
     INSTANCE_REASON_SOURCES = compat.UniqueFrozenset([
       INSTANCE_REASON_SOURCE_CLI,
       INSTANCE_REASON_SOURCE_RAPI,
       INSTANCE_REASON_SOURCE_UNKNOWN,
       ])
     # Do not re-export imported modules
     del re, _vcsversion, _autoconf, socket, pathutils, compat

b/lib/pathutils.py
71	71	CRYPTO_KEYS_DIR = RUN_DIR + "/crypto"
72	72	IMPORT_EXPORT_DIR = RUN_DIR + "/import-export"
73	73	INSTANCE_STATUS_FILE = RUN_DIR + "/instance-status"
	74	INSTANCE_REASON_DIR = RUN_DIR + "/instance-reason"
74	75	#: User-id pool lock directory (used user IDs have a corresponding lock file in
75	76	#: this directory)
76	77	UIDPOOL_LOCKDIR = RUN_DIR + "/uid-pool"

         (pathutils.LOG_OS_DIR, DIR, 0750, getent.masterd_uid, getent.daemons_gid),
         (cleaner_log_dir, DIR, 0750, getent.noded_uid, getent.noded_gid),
         (master_cleaner_log_dir, DIR, 0750, getent.masterd_uid, getent.masterd_gid),
         (pathutils.INSTANCE_REASON_DIR, DIR, 0755, getent.noded_uid,
          getent.noded_gid),
         ])
       return paths

       , pOpPriority
       , pDependencies
       , pComment
       , pReason
       , dOldQuery
       , dOldQueryNoLocking
       ) where
-...
     pComment :: Field
     pComment = optionalNullSerField $ stringField "comment"
     -- | The description of the state change reason.
     pReason :: Field
     pReason = simpleField "reason" [t| (InstReasonSrc, NonEmptyString) |]
     -- * Entire opcode parameter list
     -- | Old-style query opcode, with locking.

       , opStatusToRaw
       , opStatusFromRaw
       , ELogType(..)
       , InstReasonSrc(..)
       ) where
     import Control.Monad (liftM)
-...
       , ("ELogJqueueTest",   'C.elogJqueueTest)
       ])
     $(THH.makeJSONInstance ''ELogType)
     -- | Type for the source of the state change of instances.
     $(THH.declareSADT "InstReasonSrc"
       [ ("IRSCli", 'C.instanceReasonSourceCli)
       , ("IRSRapi",  'C.instanceReasonSourceRapi)
       ])
     $(THH.makeJSONInstance ''InstReasonSrc)

     $(genArbitrary ''DiskAccess)
     $(genArbitrary ''InstReasonSrc)
     instance Arbitrary OpCodes.DiskIndex where
       arbitrary = choose (0, C.maxDisks - 1) >>= OpCodes.mkDiskIndex

     from ganeti import backend
     from ganeti import netutils
     from ganeti import errors
     from ganeti import serializer
     import testutils
     import mocks
-...
           self._Test("inst1.example.com", idx)
     class TestInstReason(unittest.TestCase):
       def testGetJson(self):
         reason_text = "OS Update"
         reason_source = constants.INSTANCE_REASON_SOURCE_CLI
         origDict = dict(text=reason_text, source=reason_source)
         reason = backend.InstReason(reason_source, reason_text)
         json = reason.GetJson()
         resultDict = serializer.LoadJson(json)
         self.assertEqual(origDict, resultDict)
     if __name__ == "__main__":
       testutils.GanetiTestProgram()

Synnefo » snf-ganeti

Revision a59d5fa1