ó
ʍEYc@sæ
dZd
dl
Z
d
dlZd
dlZd
dlZd
dlZd
dlZd
dlm	Z	
d
dlm
Z

d
dlmZ
d
dl
Z
d
dlmZmZ
d
dlmZ
d
dlmZ
ejd	ƒ
Zd
ef
d„ƒYZd„Zd
„Zdef
d„ƒYZd„Zd„Zdef
d„ƒYZdef
d„ƒYZdef
d„ƒYZ dej!f
d„ƒYZ"dej#f
d„ƒYZ$e
j%e
j&ƒ
def
d„ƒYƒ
Z'd„Z(e)d„
Z*d „Z+d!„Z,dS("sCommon internal object modeliÿÿÿÿN(
tencodeutils(
texcutils(
tversionutils(t
_t_LE(
t	exception(
tfieldstobjectt_NotSpecifiedSentinelc
BseZ
RS((t__name__t
__module__(((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyR%s
c

Csd
|S(s>Return the mangled name of the attribute's underlying storage.t_obj_((
tname((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyt
_get_attrname)sc
Cs
t|j
ƒ
|_
xo|jƒd
d!D]Z}
t|
dƒsAq&nx<|
j
jƒD]+\}}||j
krQ||j
|<qQqQWq&Wx“|j
jƒD]‚\}}t|tjƒsÓtj	d|d|j
ƒƒ‚
n|d„
}||d„}|d„
}t||t|||ƒƒ
q”WdS(	Ni
iÿÿÿÿRtfieldtobjnamecSs8t|
ƒ
}t
||ƒs+|j|
ƒ

nt||ƒS(
N(R
thasattrt
obj_load_attrtgetattr(tselfRtattrname((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pytgetter@s



c
Ssìt|ƒ
}|j
|||
ƒ}|jrjt||ƒrjt||ƒ|krctjd
|ƒ
‚
qjdSn|jj|ƒ

yt	|||ƒSWnWt
k
rç


tjƒ8
d|j
ƒ|f}tjtdƒ
i
|d6ƒ
WdQXn
XdS(NRs%s.%ssError setting %(attr)stattr(R
tcoercet	read_onlyRRRtReadOnlyFieldErrort_changed_fieldstaddtsetattrt	ExceptionR
tsave_and_reraise_exceptiontobj_nametLOGR(RtvalueRRRtfield_valueR((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pytsetterFs












cSs?t|
ƒ
}t
||ƒs.td
|
ƒ
‚
nt||ƒ
dS(NsNo such attribute `%s'(R
RtAttributeErrortdelattr(RRR((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pytdeleterZs



(
tdictRtmroRtitemst
isinstancet
obj_fieldstFieldRtObjectFieldInvalidRRtproperty(tclstsuperclsRRRR#R&((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyt_make_class_properties.s








	
tVersionedObjectRegistrycBseeZ
dZd„Zd
„Zd„Zed„ƒ
Zed„ƒ
Z	ed„ƒ
Z
ed„ƒ
ZRS(c
Osatj
s9tjt|
|Ž
t_
tjtƒ
tj
_ntj||
|Ž
}tj
j|_|S(
N(R2t	_registryRt__new__tcollectionstdefaultdicttlistt_obj_classes(R/targstkwargsR((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyR4fs
	




c
CsdS(
N((RR/tindex((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pytregistration_hookps
cCsÕd
„}t|
ƒ

|
j
ƒ}x¯t|j|ƒ
D]v\}}|j|
|ƒ
|
j|jkrv|
|j||<Pn||
ƒ
||ƒ
kr3|j|j||
ƒ
Pq3q3W|j|j|
ƒ

|j|
dƒ
dS(Nc

Sstj
|jƒ
S(
N(tvutilstconvert_version_to_tupletVERSION(
tobj((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyt_vers_tuplets
i(R1Rt	enumerateR8R<R?tinserttappend(RR/RARt
iR@((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyt_register_classss
	


 






cCs|ƒ}|j|
ƒ

|
S(
N(
RF(R/tobj_clstregistry((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pytregisterˆs	


cs‡‡
fd
†}|S(Nc

s&ˆ
rˆj|ƒ
}n
t
|ƒ

|S(
N(RIR1(
RG(R/t	condition(sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pytwrapss



((R/RJRK((R/RJsO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pytregister_ifŽscCs|jt
ƒ
|
ƒ
S(
N(RLtFalse(R/RG((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyt	objectify˜sc

Cs|ƒ}
|
jS(
N(
R8(R/RH((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pytobj_classesœs	
N(R	R
tNoneR3R4R<RFtclassmethodRIRLRNRO(((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyR2cs
	
		
c
s:tj
ˆƒ
‡f
d
†ƒ
}
t|
_ˆ|
_t|
ƒ
S(s%Decorator for remotable classmethods.csÁ|jrt
|jƒƒ
}y.|jj|
|jƒˆj|||ƒ}Wq½tk
r‰


|jj|
|jƒˆj|j||ƒ}q½Xn0ˆ||
||Ž}t|t	ƒr½|
|_
n|S(
N(tindirection_apitobj_tree_get_versionsRtobject_class_action_versionsR	tNotImplementedErrortobject_class_actionR?R*tVersionedObjectt_context(R/tcontextR9R:tversion_manifesttresult(
tfn(sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pytwrapperªs	


	



	




(tsixRKtTruet	remotabletoriginal_fnRQ(R\R]((
R\sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pytremotable_classmethod¨s	
	
c
s4tj
ˆƒ
‡f
d
†ƒ
}
t|
_ˆ|
_|
S(s'Decorator for remotable object methods.c
	s#
|j}|dkr9tjd
ˆjd|jƒƒ‚
n|jr
|jj||ˆj|
|ƒ\}}xz|jƒD]l\}}||j	krv|j	|}t
|tƒrÀt|||ƒ
qât|||j
|||ƒƒ
qvqvW|jƒ
t|jdgƒƒ
|_|Sˆ||
|Ž
SdS(Ntmethodtobjtypetobj_what_changed(RXRPRtOrphanedObjectErrorR	RRRt
object_actionR)RR*RWRtfrom_primitivetobj_reset_changestsettgetR(	RR9R:tctxttupdatesR[tkeyR!R(
R\(sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyR]Ês$	



	
	





	




(R^RKR_R`Ra(R\R]((
R\sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyR`Ès	
	
RWcBsp
eZ
dZdZd
ZdZdZiZgZ	iZ
dd„
Zd„Zd„Z
ed„ƒ
Zed„ƒ
Zed	„ƒ
Zeejd
„
ƒ
Zed„ƒ
Zed„ƒ
Zedd
„
ƒ
Zd„Zd„Zd„Zd„Zd„Zd„Zddd„Zd„Zd„Z d„Z!d„Z"d„Z#de$d„Z%d„Z&e'd„ƒ
Ze'd„ƒ
Z(RS(s\
Base class and object factory.

    This forms the base of all objects that can be remoted or instantiated
    via RPC. Simply defining a class that inherits from this base class
    will make it remotely instantiatable. Objects should implement the
    necessary "get" classmethod routines as well as "save" object methods
    as appropriate.
    s1.0tversioned_objecttversionedobjectscKsDtƒ|_
|
|_x(|jƒD]}t||||ƒ
q"WdS(
N(RjRRXtkeysR(RRYR:Rn((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyt__init__/
s

	

c
Csd
|jƒdj
gt|jjƒƒ
D]C\}
}d|
|j|
ƒ
ra|jt||
ƒƒ
pddf^q(ƒ
f}tj	s™t
j|ddƒ

}n|S(Ns%s(%s)t
,s%s=%ss<?>tincomingsutf-8(RtjointsortedRR)tobj_attr_is_sett	stringifyRR^tPY3Rtsafe_encode(RRRtrepr_str((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyt__repr__5
s

	
	c
	

cCs*y|j|
ƒ
SWnt
k
r%


tSXdS(
N(RwR$RM(RR((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyt__contains__A
s




c
Cs@|jƒ}
id
d6|
d6}|j
tj|
ƒ
jƒƒ

|S(Ns'http://json-schema.org/draft-04/schema#s$schemattitle(RtupdateR+tObjectt
get_schema(R/Rtschema((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pytto_json_schemaG
s




c


Cs|jS(
s‘Return the object's name

        Return a canonical name for this object which will be used over
        the wire for remote hydration.
        (
R	(
R/((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyRQ
scCsd
|j|
fS(Ns%s.%s(
tOBJ_SERIAL_NAMESPACE(R/R((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyt_obj_primitive_keyZ
scCs:|j|ƒ
}|t
jkr&|
|S|
j||ƒSdS(
N(R…R+tUnspecifiedDefaultRk(R/t	primitiveRtdefaultRn((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyt_obj_primitive_field^
s

cCsâ|
tj
ƒkrFtjtd
ƒ
td|
ƒ
ƒ
tjd|
ƒ
‚
nd}xPtj
ƒ|
D]>}|j	|krv|S|r]t
j||j	ƒr]|}q]q]W|r©|Stj
ƒ|
dj	}tjd|
d|d|ƒ‚
dS(s>Returns a class from the registry based on a name and version.s:Unable to instantiate unregistered object type %(objtype)sRdiRtobjvert	supportedN(
R2ROR terrorRR'RtUnsupportedObjectErrorRPR?R=t
is_compatibletIncompatibleObjectVersion(R/RRŠtcompatible_matchtobjclasst
latest_ver((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pytobj_class_from_nameg
s"












c
	CsÉ|ƒ}|
|_||_
|j|d
ƒ}|j|dgƒ}xO|jjƒD]>\}}||krRt|||j||||ƒƒ
qRqRWtg|D]}	|	|jkrž|	^qžƒ
|_|S(Ntdatatchanges(	RXR?R‰RR)RRhRjR(
R/RYRŠR‡RtobjdataR•RRt
x((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyt_obj_from_primitive…
s	
	
	






1
cCs‰|j|
d
ƒ}|j|
dƒ}|j|
dƒ}||j
krdtjdd||fƒ
‚
n|j||ƒ}|j|||
ƒS(s Object field-by-field hydration.t	namespaceRtversionRds%s.%s(R‰tOBJ_PROJECT_NAMESPACERRR“R˜(R/R‡RYtobjnsRRŠR‘((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pytobj_from_primitive“
s


	


cCs|jƒ}||
t
|ƒ
<|j|_xN|jD]C}|j|ƒ
r2tjt||ƒ|
ƒ}t|||ƒ
q2q2Wt	|j
ƒ
|_
|S(
s,Efficiently make a deep copy of this object.(t	__class__tidRXRRwtcopytdeepcopyRRRjR(RtmemotnobjRtnval((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyt__deepcopy__¡
s	






c

Cs
tj
|ƒ
S(
sCreate a copy.(R R¡(
R((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyt	obj_clone¸
scCs˜t|d
ƒs|j
dkray|j|
SWqatk
r]


tjdddd|
ƒ‚
qaXn|j|
j}||j
kr„dS||j
|fg
S(Nt_obj_version_manifesttactiontobj_make_compatibletreasonsNo rule for %s(	RR§RPtobj_relationshipstKeyErrorRtObjectActionErrorRR(RRttarget_versionR((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyt_obj_relationship_for¼
s





	



csaˆjˆ|ƒ}|sd
Sy#t
||‡‡
‡fd†ƒ
Wntjk
r\


ˆ
ˆ=n
Xd
S(sqBacklevel a sub-object based on our versioning rules.

        This is responsible for backporting objects contained within
        this object's primitive according to a set of rules we
        maintain about version dependencies between objects. This
        requires that the obj_relationships table in this object is
        correct and up-to-date.

        :param:primitive: The primitive version of this object
        :param:target_version: The version string requested for this object
        :param:field: The name of the field in this object containing the
                      sub-object to be backported
        Nc

st|ˆˆˆ
ƒS(
N(
t_do_subobject_backport(
tver(RR‡R(sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyt<lambda>ç
s
(R¯t_get_subobject_versionRt%TargetBeforeSubobjectExistedException(RR‡R®Rtrelationship_map((RR‡RsO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyt_obj_make_obj_compatibleÏ
s



cCsmxf|jj
ƒD]U\}}t|tjtjfƒs=qn|j|ƒ
sRqn|j|
||ƒ
qWd
S(s]Make an object representation compatible with a target version.

        This is responsible for taking the primitive representation of
        an object and making it suitable for the given target_version.
        This may mean converting the format of object attributes, removing
        attributes that have been added since the target version, etc. In
        general:

        - If a new version of an object adds a field, this routine
          should remove it for older versions.
        - If a new version changed or restricted the format of a field, this
          should convert it back to something a client knowing only of the
          older version will tolerate.
        - If an object that this object depends on is bumped, then this
          object should also take a version bump. Then, this routine should
          backlevel the dependent object (by calling its obj_make_compatible())
          if the requested version of this object is older than the version
          where the new dependent object was added.

        :param primitive: The result of :meth:`obj_to_primitive`
        :param target_version: The version string requested by the recipient
                               of the object
        :raises: :exc:`oslo_versionedobjects.exception.UnsupportedObjectError`
                 if conversion is not possible for some reason
        N(RR)R*R+tObjectFieldtListOfObjectsFieldRwR¶(RR‡R®RnR((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyR©í
s





cCs2||_z|j
|
|ƒSWdt|d
ƒ
XdS(NR§(R§R©R%(RR‡R®RZ((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyt!obj_make_compatible_from_manifests		

c	Cs…
|
dkr|j
}
ntj|
ƒ
tj|j
ƒ
krNtjd
|
ƒ
‚
ntƒ}xQ|jjƒD]@\}}|j	|ƒ
rg|j
||t||ƒƒ||<qgqgW|
|j
ksÀ|rÖ|j||
|ƒ
ni|j
ƒ|jdƒ
6|j|jdƒ
6|
|jd
ƒ
6||jdƒ
6}|jƒr
|jƒ}g|D]}||krD
|^qD
}|r
|||jdƒ
<q
n|S(sbSimple base-case dehydration.

        This calls to_primitive() for each item in fields.
        RšRR™R”R•N(RPR?R=R>RtInvalidTargetVersionR'RR)Rwtto_primitiveRR¹RR…R›Re(	RR®RZR‡RRR@twhat_changedR•((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pytobj_to_primitives0




	




	







%


c
GsÁ|
sCg|jj
ƒD]$\}}|jtjkr|^q}
nxw|
D]o}tj|j|jƒ
}|tjkr—tjd
ddd|ƒ‚
n|j	|ƒ
sJt
|||ƒ
qJqJWdS(NR¨tset_defaultsRªsNo default set for field %s(RR)RˆR+R†R R¡RR­RwR(RtattrsRRRRˆ((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pytobj_set_defaultsFs


!



	



cCstt
d
ƒ
|
ƒ
‚
dS(s°Load an additional attribute from the real object.

        This should load self.$attrname and cache any data that might
        be useful for future load operations.
        s"Cannot load '%s' in the base classN(RUR(RR((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyRTs
cCstt
d
ƒ
ƒ
‚
dS(s²Save the changed fields back to the store.

        This is optional for subclasses, but is presented here in the base
        class for consistency among those that do.
        s&Cannot save anything in the base classN(RUR(RRY((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pytsave]sc
Cs•tg|j
D]}
|
|jkr
|
^q
ƒ
}x]|jD]R}
|j|
ƒ
r;tt||
ƒtƒr;t||
ƒjƒr;|j|
ƒ

q;q;W|S(
s0Returns a set of fields that have been modified.(	RjRRRwR*RRWReR(RRR•((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyRees






c
Cs4i}
x'|jƒD]}t
||ƒ|
|<qW|
S(
s6Returns a dict of changed fields and their new values.(ReR(RR•Rn((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pytobj_get_changesps


cCs
|r×xÎ|jƒD]½}|
r1||
kr1qn|j
|ƒ
sFqnt||ƒ}|dkrgqnt|j|tjƒr“|jd
t	ƒ

qt|j|tj
ƒrx!|D]}|jd
t	ƒ

q³WqqWn|
rõ|jt|
ƒ
8_n
|jj
ƒ
dS(sä
Reset the list of fields that have been changed.

        :param fields: List of fields to reset, or "all" if None.
        :param recursive: Call obj_reset_changes(recursive=True) on
                          any sub-objects within the list of fields
                          being reset.

        This is NOT "revert to previous values".

        Specifying fields on recursive resets will only be honored at the top
        level. Everything below the top will reset all.
        t	recursiveN(RÂRwRRPR*RR+R·RiR_R¸RRjtclear(RRRÃRR!tthing((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyRiws$












cCsO|
|jkr<t
td
ƒ
i|jƒd6|
d6ƒ
‚
nt|t|
ƒ
ƒS(sÞTest object to see if attrname is present.

        Returns True if the named attribute has a value set, or
        False if not. Raises AttributeError if attrname is not
        a valid attribute for this object.
        s2%(objname)s object has no attribute '%(attrname)s'RR(R+R$RRRR
(RR((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyRw¢s


	
!
c

Cst|j
jƒƒ
|jS(
N(R7RRqtobj_extra_fields(
R((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyR+¯sc


Cs|jS(
N(
RX(
R((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pytobj_context³sN()R	R
t__doc__RPRRR?R„R›RRÆR«RrR|R}RQRƒRR…R+R†R‰R“R˜RR¥R¦R¯R¶R©R¹R½RÀRRÁReRÂRMRiRwR.RÇ(((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyRWésH
		
	

					"	(						+	
tComparableVersionedObjectc
Bs eZ
dZd
„Zd„ZRS(s’Mix-in to provide comparison methods

    When objects are to be compared with each other (in tests for example),
    this mixin can be used.
    cCs)t|
d
ƒr%|j
ƒ|
j
ƒkStS(NR½(RR½tNotImplemented(RR@((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyt__eq__¾s

cCs)t|
d
ƒr%|j
ƒ|
j
ƒkStS(NR½(RR½RÊ(RR@((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyt__ne__Ås


(R	R
RÈRËRÌ(((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyRɸs
	tVersionedObjectDictCompatcBseZ
dZd
„ZeZd„Zd„ZejrKeZ	eZ
eZnd„Z	d„Z
d„Zd„Zd„Z
ed	„
Zd
„ZRS(s<
Mix-in to provide dictionary key access compatibility

    If an object needs to support attribute access using
    dictionary items instead of object attributes, inherit
    from this class. This should only be used as a temporary
    measure until all callers are converted to use modern
    attribute access.
    c
cs>x7|jD],}
|j
|
ƒ
s.|
|jkr
|
V
q
q
WdS(
N(R+RwRÆ(RR((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyt__iter__Õs



c
cs#x|D]}
t||
ƒV
qWdS(
N(
R(RR((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyt
itervaluesÝs


c
cs)x"|D]}
|
t||
ƒfV
qWdS(
N(
R(RR((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyt	iteritemsás


c

Cst|j
ƒƒ
S(
N(R7titerkeys(
R((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyRqís
c

Cst|j
ƒƒ
S(
N(R7RÏ(
R((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pytvaluesðs
c

Cst|j
ƒƒ
S(
N(R7RÐ(
R((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyR)ós
cCs
t||
ƒS(
N(
R(RR((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyt__getitem__ös
cCst||
|ƒ
dS(
N(
R(RRR!((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyt__setitem__ùs
cCs\|
|jkr+t
d
|j|
fƒ
‚
n|tkrK|j|
ƒ
rK|St||
ƒSdS(Ns!'%s' object has no attribute '%s'(R+R$RžRRwR(RRnR!((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyRküs




cCs1x*|
jƒD]\}}t
|||ƒ
q
WdS(
N(R)R(RRmRnR!((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyRs

(R	R
RÈRÎRÑRÏRÐR^RyRqRÒR)RÓRÔRRkR(((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyRÍËs 				

							tObjectListBasecBsxeZ
dZi
ejd
ƒ
d6ZiZd„Zd„Zd„Z	ded„Zd„Z
d„Zd	„Zd
„ZRS(s9
Mixin class for lists of objects.

    This mixin class can be added as a base class for an object that
    is implementing a list of objects. It adds a single field of 'objects',
    which is the list store, and behaves like a list itself. It supports
    serialization of the list of objects automatically.
    RWtobjectsc
OsEtt
|ƒj|
|Ž
d
|krAg|_|jjd
ƒ

ndS(NRÖ(tsuperRÕRrRÖRtdiscard(RR9R:((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyRrs


	
c

Cs
t|j
ƒ
S(
sList length.(tlenRÖ(
R((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyt__len__!scCsPt|
t
ƒrE|jƒ}|j|
|_|jƒ
|j|_|S|j|
S(
sList index access.(R*tsliceRžRÖRiRX(RR;tnew_obj((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyRÓ%s





cCs|jj
d
|
d|ƒ
dS(NRntreverse(RÖtsort(RRnRÝ((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyRÞ0s
cs¬ˆ
jrˆ
jj
ƒ}n3yˆ
jd
|ƒ}Wntjk
rM


i}n
Xy<|rvt||‡‡
fd†ƒ
ntdˆ
d
ˆƒ
Wntjk
r§


ˆd
=n
XdS(NRÖc

st|ˆ
d
ˆƒS(NRÖ(
R°(
R±(R‡R(sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyR²Gs
s1.0(tchild_versionsR)R¯RR­R³R°R´(RR‡R®t
relationships((R‡RsO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyR©3s	

	




	

c
CsCt|j
ƒ
}
x-|jD]"}|jƒr|
jd
ƒ

qqW|
S(NRÖ(RjRRÖReR(RR•tchild((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyReOs





cCs]|j|
jkrMt
|jjjƒƒ
d
g
krM|jd
|j|
jƒ
Stdƒ
‚
dS(NRÖsHList Objects should be of the same type and only have an 'objects' field(RžR7RRqRÖt	TypeError(Rtother((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyt__add__Vs
!
cCsR|j|
jkrBt
|jjjƒƒ
d
g
krBtdƒ
‚
ntdƒ
‚
dS(NRÖs8__radd__ is not implemented for objects of the same typesHList Objects should be of the same type and only have an 'objects' field(RžR7RRqRURâ(RRã((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyt__radd__as

!N(R	R
RÈR+R¸RRßRrRÚRÓRPRMRÞR©ReRäRå(((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyRÕ
s

						tVersionedObjectSerializerc
BsAeZ
dZeZd
„Zd„Zd„Zd„Zd„Z	RS(sJ
A VersionedObject-aware Serializer.

    This implements the Oslo Serializer interface and provides the
    ability to serialize and deserialize VersionedObject entities. Any service
    that needs to accept or return VersionedObjects as arguments or result
    values should pass this to its RPCClient and RPCServer objects.
    cCs`t|j
ƒƒ
}|jj}y|j|
||ƒSWn$tk
r[


|j|
||jƒSXdS(
N(RSRtOBJ_BASE_CLASSRRtobject_backport_versionsRUtobject_backportR?(RRYtobjprimR‘tobj_versionsRR((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyt_do_backportys







c	
Cs
y|jj
|d
|
ƒ

SWnòtjk
r



tjdtƒ
Ê}d|jj}||}|jdƒ
dkr¡dj	|j
dƒ
d ƒ
||<|j|
|ƒSd|jj}||}tj
ƒj|gƒ}|jjrü|rü|j|
||dƒSt|_WdQXn
XdS(NRYtreraises
%s.versiont
.is%s.namei(RçRRRR
RRMR„tcountRutsplitt_process_objectR2RORkRRRìR_Rí(	RRYRêRltverkeyRŠtnamekeyRR‹((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyRñ„s"

	





 





	

cCs|j}t
|tƒrP|g|jƒD]!\}}|||
|ƒf^q(ƒ
S|tkret}n|g|D]}||
|ƒ^qoƒ
Sd
S(sp
Process an iterable, taking an action on each value.

        :param:context: Request context
        :param:action_fn: Action to take on each item in values
        :param:values: Iterable container of things to take action on
        :returns: A new container of the same type (except set) with
                  items from values having had action applied.
        N(Ržt
issubclassR'R)RjR7(RRYt	action_fnRÒtiterablet
kt
vR!((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyt_process_iterableœs		


2
	
cCsgt|t
tttfƒr6|j|
|j|ƒ}n-t|d
ƒrct|j	ƒ
rc|j	ƒ}n|S(NR½(
R*ttupleR7RjR'Rùtserialize_entityRtcallableR½(RRYtentity((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyRû³s






cCszd
|jj
}t|tƒr@||kr@|j|
|ƒ}n6t|ttttfƒrv|j|
|j	|ƒ}n|S(Ns%s.name(
RçR„R*R'RñRúR7RjRùtdeserialize_entity(RRYRýRó((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyRþ¼s






(
R	R
RÈRWRçRìRñRùRûRþ(((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyRæms					tVersionedObjectIndirectionAPIc
Bs5eZ
d„Zd
„Zd„Zd„Zd„ZRS(c
Csd
S(sÇPerform an action on a VersionedObject instance.

        When indirection_api is set on a VersionedObject (to a class
        implementing this interface), method calls on remotable methods
        will cause this to be executed to actually make the desired
        call. This often involves performing RPC.

        :param context: The context within which to perform the action
        :param objinst: The object instance on which to perform the action
        :param objmethod: The name of the action method to call
        :param args: The positional arguments to the action method
        :param kwargs: The keyword arguments to the action method
        :returns: The result of the action method
        N((RRYtobjinstt	objmethodR9R:((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyRgÈsc
Csd
S(sÿ.. deprecated:: 0.10.0

        Use :func:`object_class_action_versions` instead.

        Perform an action on a VersionedObject class.

        When indirection_api is set on a VersionedObject (to a class
        implementing this interface), classmethod calls on
        remotable_classmethod methods will cause this to be executed to
        actually make the desired call. This usually involves performing
        RPC.

        :param context: The context within which to perform the action
        :param objname: The registry name of the object
        :param objmethod: The name of the action method to call
        :param objver: The (remote) version of the object on which the
                       action is being taken
        :param args: The positional arguments to the action method
        :param kwargs: The keyword arguments to the action method
        :returns: The result of the action method, which may (or may not)
                  be an instance of the implementing VersionedObject class.
        N((RRYRR

RŠR9R:((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyRVÙscCs tj
d
tƒ
tdƒ
‚
dS(sÝPerform an action on a VersionedObject class.

        When indirection_api is set on a VersionedObject (to a class
        implementing this interface), classmethod calls on
        remotable_classmethod methods will cause this to be executed to
        actually make the desired call. This usually involves performing
        RPC.

        This differs from object_class_action() in that it is provided
        with object_versions, a manifest of client-side object versions
        for easier nested backports. The manifest is the result of
        calling obj_tree_get_versions().

        NOTE: This was not in the initial spec for this interface, so the
        base class raises NotImplementedError if you don't implement it.
        For backports, this method will be tried first, and if unimplemented,
        will fall back to object_class_action(). New implementations should
        provide this method instead of object_class_action()

        :param context: The context within which to perform the action
        :param objname: The registry name of the object
        :param objmethod: The name of the action method to call
        :param object_versions: A dict of {objname: version} mappings
        :param args: The positional arguments to the action method
        :param kwargs: The keyword arguments to the action method
        :returns: The result of the action method, which may (or may not)
                  be an instance of the implementing VersionedObject class.
        suobject_class_action() is deprecated in favor of object_class_action_versions() and will be removed in a later releases(Multi-version class action not supportedN(twarningstwarntDeprecationWarningRU(RRYRR

tobject_versionsR9R:((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyRTós	
c
Csd
S(sT.. deprecated:: 0.10.0

        Use :func:`object_backport_versions` instead.

        Perform a backport of an object instance to a specified version.

        When indirection_api is set on a VersionedObject (to a class
        implementing this interface), the default behavior of the base
        VersionedObjectSerializer, upon receiving an object with a version
        newer than what is in the lcoal registry, is to call this method to
        request a backport of the object. In an environment where there is
        an RPC-able service on the bus which can gracefully downgrade newer
        objects for older services, this method services as a translation
        mechanism for older code when receiving objects from newer code.

        NOTE: This older/original method is soon to be deprecated. When a
        backport is required, the newer object_backport_versions() will be
        tried, and if it raises NotImplementedError, then we will fall back
        to this (less optimal) method.

        :param context: The context within which to perform the backport
        :param objinst: An instance of a VersionedObject to be backported
        :param target_version: The maximum version of the objinst's class
                               that is understood by the requesting host.
        :returns: The downgraded instance of objinst
        N((RRYR
R®((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyRéscCs tj
d
tƒ
tdƒ
‚
dS(s@Perform a backport of an object instance.

        This method is basically just like object_backport() but instead of
        providing a specific target version for the toplevel object and
        relying on the service-side mapping to handle sub-objects, this sends
        a mapping of all the dependent objects and their client-supported
        versions. The server will backport objects within the tree starting
        at objinst to the versions specified in object_versions, removing
        objects that have no entry. Use obj_tree_get_versions() to generate
        this mapping.

        NOTE: This was not in the initial spec for this interface, so the
        base class raises NotImplementedError if you don't implement it.
        For backports, this method will be tried first, and if unimplemented,
        will fall back to object_backport().

        :param context: The context within which to perform the backport
        :param objinst: An instance of a VersionedObject to be backported
        :param object_versions: A dict of {objname: version} mappings
        smobject_backport() is deprecated in favor of object_backport_versions() and will be removed in a later releases$Multi-version backport not supportedN(R
R
R
RU(RRYR
R
((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyRè3s	
(R	R
RgRVRTRéRè(((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyRÿÆs
			#	cKs\g|
_x9|D]1}|j
||ƒ||}|
jj|ƒ

qW||
_|
jƒ
|
S(
sè
Construct an object list from a list of primitives.

    This calls item_cls._from_db_object() on each item of db_list, and
    adds the resulting object to list_obj.

    :param:context: Request context
    :param:list_obj: An ObjectListBase object
    :param:item_cls: The VersionedObject class of the objects within the list
    :param:db_list: The list of primitives to convert to objects
    :param:extra_args: Extra arguments to pass to _from_db_object()
    :returns: list_obj
    (RÖt_from_db_objectRDRXRi(RYtlist_objtitem_clstdb_listt
extra_argstdb_itemtitem((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyt
obj_make_listNs
	



	

	


cCsÆ|
dkri}
n||
kr%|
St
jƒ|d
}|j|
|<xy|jD]n}|j|}t|tjƒr„|jj	}n*t|tj
ƒrP|jjjj	}nqPt|d|
ƒ


qPW|
S(sBConstruct a mapping of dependent object versions.

    This method builds a list of dependent object versions given a top-
    level object with other objects as fields. It walks the tree recursively
    to determine all the objects (by symbolic name) that could be contained
    within the top-level object, and the maximum versions of each. The result
    is a dict like:

      {'MyObject': '1.23', ... }

    :param objname: The top-level object at which to start
    :param tree: Used internally, pass None here.
    :returns: A dictionary of object names and versions
    ittreeN(
RPR2ROR?RR*R+R·t_typet	_obj_nameR¸t
_element_typeRS(RR
R‘t
field_nameRt	child_cls((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyRSes
	












cCs²tj
|ƒ
}xœt|
ƒ
D]Ž\}}|\}}tj
|ƒ
}||kr|d
krptjd|ƒ
‚
n|
|dd}||ƒ

dS||kr||ƒ

dSqWdS(s	Get the version to which we need to convert a subobject.

    This uses the relationships between a parent and a subobject,
    along with the target parent version, to decide the version we need
    to convert a subobject to. If the subobject did not exist in the parent at
    the target version, TargetBeforeChildExistedException is raised. If there
    is a need to backport, backport_func is called and the subobject version
    to backport to is passed in.

    :param tgt_version: The version we are converting the parent to
    :param relationships: A list of (parent, subobject) version tuples
    :param backport_func: A backport function that takes in the subobject
                          version
    :returns: The version we need to convert the subobject to
    iR®i
N(R=R>RBRR´(ttgt_versionRàt
backport_functtgtR;tversionstparentRá((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyR³‡s




	






c	Cs
t|
|ƒ}t
|
d
ƒr'|
jp*d}t|tƒr‚|j|j||dƒ|d|ƒ

|jdƒ
}||||<nzt|t	ƒrüxht
|ƒ
D]W\}}|j|j|||dƒ|d|ƒ

|jdƒ
}|||||<qžWndS(NR§R”RZRš(RRR§RPR*RWR¹R‰R…R7RB(	t
to_versionR
RR‡R@tmanifesttver_keyREtelement((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyR°­s 

















(-RÈtabcR5R tloggingR
toslo_messagingt	messagingt
oslo_utilsRR
RR=R^toslo_versionedobjects._i18nRRtoslo_versionedobjectsRRR+t	getLoggerR RRR
R1R2RbR`RWRÉRÍtSequenceRÕtNoOpSerializerRæt
add_metaclasstABCMetaRÿR

RPRSR³R°(((sO/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_versionedobjects/base.pyt<module>s@









		5E	 	!ÿÐ?cY
‡	"	&