plandesc.py revision 2910
#
# CDDL HEADER START
#
# The contents of this file are subject to the terms of the
# Common Development and Distribution License (the "License").
# You may not use this file except in compliance with the License.
#
# You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
# See the License for the specific language governing permissions
# and limitations under the License.
#
# When distributing Covered Code, include this CDDL HEADER in each
# file and include the License file at usr/src/OPENSOLARIS.LICENSE.
# If applicable, add the following below this CDDL HEADER, with the
# fields enclosed by brackets "[]" replaced with your own identifying
# information: Portions Copyright [yyyy] [name of copyright owner]
#
# CDDL HEADER END
#
#
#
"""
PlanDescription and _ActionPlan classes
These classes are part of the public API, and any changes here may require
bumping CURRENT_API_VERSION in pkg.api
The PlanDescription class is a public interface which contains all the data
associated with an image-modifying operation.
The _ActionPlan class is a private interface used to keep track of actions
modified within an image during an image-modifying operation.
"""
import collections
import itertools
import operator
import simplejson as json
"""A named tuple used to keep track of all the actions that will be
executed during an image-modifying procecure."""
# Class has no __init__ method; pylint: disable=W0232
# Use __slots__ on an old style class; pylint: disable=E1001
__slots__ = []
__state__desc = tuple([
])
"""Returns the serialized state of this object in a format
that that can be easily stored using JSON, pickle, etc."""
"""Allocate a new object using previously serialized state
obtained via getstate()."""
# Access to protected member; pylint: disable=W0212
# get the name of the object we're dealing with
# decode serialized state into python objects
return _ActionPlan(*state)
class PlanDescription(object):
"""A class which describes the changes the plan will make."""
__state__desc = {
"_cfg_mediators": {
str: {
}
},
str: {
}
}),
"_removed_facets": set(),
"install_actions": [ _ActionPlan ],
"release_notes": (bool, []),
"removal_actions": [ _ActionPlan ],
"update_actions": [ _ActionPlan ],
}
])
#
# Properties set when state >= EVALUATED_PKGS
#
self._cfg_mediators = {}
self._new_variants = None
self._new_facets = None
# remove (oldfmri, None)
# update (oldfmri, newfmri|oldfmri)
self._solver_summary = []
self._solver_errors = None
#
# Properties set when state >= EVALUATED_OK
#
# raw actions
# merged actions
self.removal_actions = []
self.update_actions = []
self.install_actions = []
# smf and other actuators (driver actions get added during
# execution stage).
# Used to track users and groups that are part of operation.
self.added_groups = {}
self.added_users = {}
self.removed_groups = {}
self.removed_users = {}
# release notes that are part of this operation
# plan properties
self._need_boot_archive = None
# child properties
self.child_kwargs = {}
self.children_ignored = None
self.children_planned = []
self.children_nop = []
# driver aliases to remove
self._rm_aliases = {}
#
# Properties set when state >= EXECUTED_OK
#
self.release_notes_name = None
#
# Set by imageplan.set_be_options()
#
self._backup_be = None
self._backup_be_name = None
# Accessed via imageplan.update_index
# stats about the current image
"""Returns the serialized state of this object in a format
that that can be easily stored using JSON, pickle, etc."""
# Access to protected member; pylint: disable=W0212
if reset_volatiles:
# backup and clear volatiles
# add a state version encoding identifier
if reset_volatiles:
return state
"""Update the state of this object using previously serialized
state obtained via getstate()."""
# Access to protected member; pylint: disable=W0212
# get the name of the object we're dealing with
# version check and delete the encoding identifier
# decode serialized state into python objects
# bulk update
# clear volatiles
"""Allocate a new object using previously serialized state
obtained via getstate()."""
rv = PlanDescription()
return rv
"""Save a json encoded representation of this plan
description objects into the specified file object."""
try:
except OSError, e:
# Access to protected member; pylint: disable=W0212
raise apx._convert_error(e)
del state
"""Load a json encoded representation of a plan description
from the specified file object."""
try:
except OSError, e:
# Access to protected member; pylint: disable=W0212
raise apx._convert_error(e)
del state
def _executed_ok(self):
"""A private interface used after a plan is successfully
invoked to free up memory."""
# reduce memory consumption
self._fmri_changes = []
self.added_groups = {}
self.added_users = {}
self.removed_groups = {}
self.removed_users = {}
"""A boolean indicating if we attempted to execute this
plan."""
"""Returns a list of string tuples describing affected services
(action, SMF FMRI)."""
return sorted(
)
"""Returns a list of three-tuples containing information about
the mediators. The first element in the tuple is the name of
the mediator. The second element is a tuple containing the
original version and source and the new version and source of
the mediator. The third element is a tuple containing the
original implementation and source and new implementation and
source."""
ret = []
if not self._mediators_change or \
return ret
def get_mediation(mediators, m):
# Missing docstring; pylint: disable=C0111
mver_source = None
if m in mediators:
"implementation")
"implementation-version")
if mimpl_ver:
mimpl_ver = \
"implementation-source")
if mver:
"version-source")
self._cfg_mediators, m)
orig_ver_source == new_ver_source and \
# Mediation not changed.
continue
out = (m,
((orig_ver, orig_ver_source),
(new_ver, new_ver_source)),
(new_impl, new_impl_source)))
return ret
def get_mediators(self):
"""Returns list of strings describing mediator changes."""
ret = []
((orig_ver, orig_ver_source),
out = "mediator %s:\n" % m
out += " version: %s (%s default) " \
"-> %s (%s default)\n" % (orig_ver,
elif orig_ver:
out += " version: %s (%s default) " \
elif new_ver:
out += " version: None -> " \
"%s (%s default)\n" % (new_ver,
out += " implementation: %s (%s default) " \
"-> %s (%s default)\n" % (orig_impl,
elif orig_impl:
out += " implementation: %s (%s default) " \
elif new_impl:
out += " implementation: None -> " \
"%s (%s default)\n" % (new_impl,
return ret
"""Get the proposed fmri changes."""
return self._fmri_changes
"""A list of tuples of items that were salvaged during plan
execution. Each tuple is of the form (original_path,
salvage_path). Where 'original_path' is the path of the item
before it was salvaged, and 'salvage_path' is where the item was
moved to. This property is only valid after plan execution
has completed."""
"""Returns a tuple of two lists containing the facet and variant
changes in this plan."""
vs = []
if self._new_variants:
fs = []
def get_varcets(self):
"""Returns a formatted list of strings representing the
), (
)))
def get_changes(self):
"""A generation function that yields tuples of PackageInfo
objects of the form (src_pi, dest_pi).
If 'src_pi' is None, then 'dest_pi' is the package being
installed.
If 'src_pi' is not None, and 'dest_pi' is None, 'src_pi'
is the package being removed.
If 'src_pi' is not None, and 'dest_pi' is not None,
then 'src_pi' is the original version of the package,
and 'dest_pi' is the new version of the package it is
being upgraded to."""
else:
def get_actions(self):
"""A generator function that yields action change descriptions
in the order they will be performed."""
# Unused variable '%s'; pylint: disable=W0612
# pylint: enable=W0612
def has_release_notes(self):
"""True if there are release notes for this plan"""
def must_display_notes(self):
"""True if the release notes must be displayed"""
def get_release_notes(self):
"""A generator that returns the release notes for this plan"""
yield notes
"""A generator function that yields information about the
licenses related to the current plan in tuples of the form
(dest_fmri, src, dest, accepted, displayed) for the given
package FMRI or all packages in the plan. This is only
available for licenses that are being installed or updated.
'dest_fmri' is the FMRI of the package being installed.
'src' is a LicenseInfo object if the license of the related
package is being updated; otherwise it is None.
'dest' is the LicenseInfo object for the license that is being
installed.
'accepted' is a boolean value indicating that the license has
been marked as accepted for the current plan.
'displayed' is a boolean value indicating that the license has
been marked as displayed for the current plan."""
continue
# Unused variable; pylint: disable=W0612
src_li = None
if src:
dest_li = None
if dest:
if pfmri:
break
def get_solver_errors(self):
"""Returns a list of strings for all FMRIs evaluated by the
solver explaining why they were rejected. (All packages
found in solver's trim database.) Only available if
DebugValues["plan"] was set when the plan was created.
"""
# in case this operation doesn't use solver
if self._solver_errors is None:
return []
return self._solver_errors
"""Return the type of plan that was created (ex:
API_OP_UPDATE)."""
def update_index(self):
"""Boolean indicating if indexes will be updated as part of an
image-modifying operation."""
return self._update_index
"""Either None, True, or False. If None then executing this
plan may create a backup BE. If False, then executing this
plan will not create a backup BE. If True, then executing
this plan will create a backup BE."""
return self._backup_be
"""The name of a new BE that will be created if this plan is
executed."""
def backup_be_name(self):
"""The name of a new backup BE that will be created if this
plan is executed."""
return self._backup_be_name
def activate_be(self):
"""A boolean value indicating whether any new boot environment
will be set active on next boot."""
return self._be_activate
def reboot_needed(self):
"""A boolean value indicating that execution of the plan will
require a restart of the system to take effect if the target
image is an existing boot environment."""
"""A boolean value indicating that execution of the plan will
take place in a clone of the current live environment"""
def update_boot_archive(self):
"""A boolean value indicating whether or not the boot archive
will be rebuilt"""
return self._need_boot_archive
def bytes_added(self):
"""Estimated number of bytes added"""
return self._bytes_added
def cbytes_added(self):
"""Estimated number of download cache bytes added"""
return self._cbytes_added
def bytes_avail(self):
"""Estimated number of bytes available in image /"""
return self._bytes_avail
def cbytes_avail(self):
"""Estimated number of bytes available in download cache"""
return self._cbytes_avail