/usr/lib/python3/dist-packages/landscape/lib/__pycache__
Edit: /usr/lib/python3/dist-packages/landscape/lib/__pycache__/persist.cpython-310.pyc (17787B)
o
cR @ s d dl Z d dlZd dlZd dlZd dlmZ g dZe ZG dd de Z
G dd de
Z G dd d eZ G d
d d eZ
ed jZd
d Zdd ZG dd deZG dd deZG dd deZdS ) N)
StringType)Persist
PickleBackendBPickleBackendpath_string_to_tuplepath_tuple_to_string
RootedPersist PersistErrorPersistReadOnlyErrorc @ e Zd ZdS )r N__name__
__module__ __qualname__ r r 7/usr/lib/python3/dist-packages/landscape/lib/persist.pyr % r c @ r )r
Nr r r r r r
) r r
c @ s e Zd ZdZd(ddZdd Zdd Zd d
ZeeeZ eeZ
d d Z d
d Z dd Z
d)ddZeefddZd*ddZedddfddZd*ddZd+d d Zd,d d Zd*d d!Zeddfd"d#Zd,d$d%Zd&d' ZdS )-r a Persist a hierarchical database of key=>value pairs.
There are three different kinds of option maps, regarding the
persistence and priority that maps are queried.
- hard - Options are persistent.
- soft - Options are not persistent, and have a higher priority
than persistent options.
- weak - Options are not persistent, and have a lower priority
than persistent options.
@ivar filename: The name of the file where persist data is saved
or None if no filename is available.
Nc C sl |du rt }|| _| | _i | _i | _d| _d| _| | _|| _ |dur2t
j |r4|
| dS dS dS )a
@param backend: The backend to use. If none is specified,
L{BPickleBackend} will be used.
@param filename: The default filename to save to and load from. If
specified, and the file exists, it will be immediately
loaded. Specifying this will also allow L{save} to be called
without any arguments to save the persist.
NF)r _backendnew_hardmap_softmap_weakmap _readonly _modified_configfilenameospathexistsload)selfbackendr r r r __init__? s
zPersist.__init__c C | j S N)r r r r r
_get_readonlyU zPersist._get_readonlyc C s t || _d S r$ )boolr )r flagr r r
_set_readonlyX zPersist._set_readonlyc C r# r$ r r% r r r
_get_modified[ r' zPersist._get_modifiedc C s
d| _ dS )z(Set the database status as non-modified.FNr, r% r r r reset_modifieda s
zPersist.reset_modifiedc C s | j rtddS )zRAssert if the object is writable
@raise: L{PersistReadOnlyError}
z"Configuration is in readonly mode.N)r r
r% r r r assert_writablee s zPersist.assert_writablec s fdd}t j t j s | rdS td t j dkr+| dS z
j _W dS t yH | rBY dS td w )zLoad a persisted database.c sX d } t j| r*t j| dkr*z
j| _W dS ty) td| w dS )N.oldr Broken configuration file at %sTF) r r isfilegetsizer r r Exceptionr ) filepatholdfilepathr r r load_oldp s z Persist.load.
.load_oldNzFile not found: %sr r1 )
r r
expanduserr2 r r3 r r r r4 )r r7 r8 r r6 r r m s z Persist.loadc C s |du r| j du r
td| j }tj|}tj|r$t||d tj|}|r7tj|s7t | | j
|| j dS )zSave the persist to the given C{filepath}.
If None is specified, then the filename passed during construction will
be used.
If the destination file already exists, it will be renamed
to C{.old}.
NzNeed a filename!r0 )
r r r r r9 r2 renamedirnameisdirmakedirsr saver )r r7 r; r r r r> s
z Persist.savec
C s: |t ur
| j|}t|}t }|}|rG|}|d}| j||}|tu r@|r1|d t| }tdt |t
|t |f ||u rEn|s||urY||urW| j |||}|S ||u ra|}|S t|dkrvt |d t
u rsg } ni } n|} | j ||| }|tu rtdt |t |f |s |S |}|d}qb)Nr zCan't traverse %r (%r): %rTzCan't traverse %r with %r)NOTHINGr copylistpopgetNotImplementedlenr typer strsetint)
r objr defaultsetvaluequeuemarkernewobjelemnewvaluer r r _traverse sX
zPersist._traverseFc C s t |tr t|}t}|r| | j||}|S |r#| | j||}|S |r/| | j||}|S | | j||}||u rO| | j||}||u rO| | j||}|S r$ )
isinstancer r r? rR r r r )r r softhardweakrN valuer r r _getvalue s$
zPersist._getvaluec C sV | ||||}t}||u rdS ||u rdS | j||}|tu r)tdt| |S )NFTz Can't check %r for containment)rX r? r hasrD r rF ) r r rW rT rU rV rJ rN resultr r r rY s z Persist.hasc C sD | ||||}|tu rg S | j|}|tu r tdt| |S )NzCan't return keys for %s)rX r? r keysrD r rF )r r rT rU rV rJ rZ r r r r[ s z Persist.keysc C s( | ||||}|tu r|S | j|S r$ )rX r? r r@ )r r rK rT rU rV rW r r r rC s z Persist.getc C sZ |sJ t |tr
t|}|r| j}n|r| j}n
| d| _| j}| j|||d d S NT)rL ) rS r r r r r/ r r rR )r r rW rT rV mapr r r rH s
z Persist.setc C s |sJ t |tr
t|}|r| j}n|r| j}n
| d| _| j}|r7| ||}t |t
u r7||v r7d S |t j f }| j|||d d S r\ )
rS r r r r r/ r r rR rF rA sysmaxsize)r r rW uniquerT rV r] currentr r r add
s
z Persist.addc C s |sJ t |tr
t|}|r| j}n|r| j}n
| d| _| j}t}|r{||u r<| ||d d }|d }d} n
| ||}|}d} d}
||urb| j
||| }
|
t u rbt
d|t|f | j
|rv||uro|}n
|d d }n |
S |s'|
S )NTFzCan't remove %r from %r)rS r r r r r/ r r r? rR r removerD r rF empty) r r rW rT rV r] rN rJ rP isvaluerZ r r r rd sD
zPersist.removec C s |s|s| t|trt|}t|trt|}d}t}| |||p%| |}||ur?| j|||d | |||| d}|S )NF)rT rV T)r/ rS r r r? rX rd rH )r oldpathnewpathrT rV rZ rN rW r r r moveB s
z Persist.movec C s
t | |S )zv
Rebase the database hierarchy.
@return: A L{RootedPersist} using this L{Persist} as parent.
)r r r r r r root_atR s
zPersist.root_at)NNr$ FFFNFFFFF)r
r r __doc__r" r& r* r- propertyreadonlymodifiedr. r/ r r> r? rR rX rY r[ rC rH rb rd ri rk r r r r r - s,
"
+
% r c @ s e Zd ZdZdd Zedd Zedd Zdd Ze d d d fd
d Z
dd d
Z d ddZ d ddZ
dddZe d d fddZd ddZdd ZdS ) r ax Root a L{Persist}'s tree at a particular branch.
This class shares the same interface of L{Persist} and provides a shortcut
to access the nodes of a particular branch in a L{Persist}'s tree.
The chosen branch will be viewed as the root of the tree of the
L{RootedPersist} and all operations will be forwarded to the parent
L{Persist} as appropriate.
c C s( || _ t|trt|| _dS || _dS )z
@param parent: the parent L{Persist}.
@param root: a branch of the parent L{Persist}'s tree, that
will be used as root of this L{RootedPersist}.
N)parentrS r r root)r rs rt r r r r" f s
zRootedPersist.__init__c C | j jS r$ )rs rq r% r r r r zRootedPersist.c C ru r$ )rs rr r% r r r rv s rw c C s | j d S r$ )rs r/ r% r r r r/ u r+ z RootedPersist.assert_writableFc C , t |tr t|}| j| j| ||||S r$ )rS r r rs rY rt )r r rW rT rU rV r r r rY x
zRootedPersist.hasc C * t |tr t|}| j| j| |||S r$ )rS r r rs r[ rt )r r rT rU rV r r r r[ }
zRootedPersist.keysNc C rx r$ )rS r r rs rC rt )r r rK rT rU rV r r r rC ry zRootedPersist.getc C rz r$ )rS r r rs rH rt r r rW rT rV r r r rH r{ zRootedPersist.setc C rx r$ )rS r r rs rb rt )r r rW r` rT rV r r r rb ry zRootedPersist.addc C rz r$ )rS r r rs rd rt r| r r r rd r{ zRootedPersist.removec C sB t |tr t|}t |trt|}| j| j| | j| ||S r$ )rS r r rs ri rt )r rg rh rT rV r r r ri s
zRootedPersist.movec C s$ t |tr t|}| j| j| S r$ )rS r r rs rk rt rj r r r rk s
zRootedPersist.root_atrl rm rn )r
r r ro r" rp rq rr r/ r? rY r[ rC rH rb rd ri rk r r r r r [ s
r z(\[-?\d+\])|(?|d dkr>z
|t|dd W q ty= td| w ||dd qt|S ) a Convert a L{Persist} path string to a path tuple.
Examples:
>>> path_string_to_tuple("ab")
("ab",)
>>> path_string_to_tuple("ab.cd")
("ab", "cd"))
>>> path_string_to_tuple("ab[0][1]")
("ab", 0, 1)
>>> path_string_to_tuple("ab[0].cd[1]")
("ab", 0, "cd", 1)
Raises L{PersistError} if the given path string is invalid.
.[r rc ] zInvalid path index: %r\.)
_splitpathappendrI
ValueErrorr replacetuple)r rZ tokenstokenr r r r s r c C sP g }| D ] }t |tu r|d d| 7 < q|t|dd qd|S )Nrc z[%d]r} r )rF rI r rG r join)r rZ rP r r r r s
r c @ sd e Zd ZdZdd Zdd Zdd Zefdd Zd
d Z d d
Z
dd Z dd Z dd Z
dd ZdS )BackendaD
Base class for L{Persist} backends implementing hierarchical storage
functionality.
Each node of the hierarchy is an object of type C{dict}, C{list}
or C{tuple}. A node can have zero or more children, each child can be
another node or a leaf value compatible with the backend's serialization
mechanism.
Each child element is associated with a unique key, that can be used to
get, set or remove the child itself from its containing node. If the node
object is of type C{dict}, then the child keys will be the keys of the
dictionary, otherwise if the node object is of type C{list} or C{tuple}
the child element keys are the indexes of the available items, or the value
of items theselves.
The root node object is always a C{dict}.
For example:
>>> backend = Backend()
>>> root = backend.new()
>>> backend.set(root, "foo", "bar")
'bar'
>>> egg = backend.set(root, "egg", [1, 2, 3])
>>> backend.set(egg, 0, 10)
10
>>> root
{'foo': 'bar', 'egg': [10, 2, 3]}
c C t r$ NotImplementedErrorr% r r r r z Backend.newc C r r$ r )r r7 r r r r r z Backend.loadc C r r$ r )r r7 r] r r r r> r z Backend.savec C s t |tu r|||}|S t |ttfv r1 s z"Backend.remove..N)rF r rA rI r rD )r rJ rP rf rZ r r r rd s,
zBackend.removec C s t |ttfv r
t|S |S )zCopy a node or a value.)rF r rA r@ deepcopy)r rW r r r r@ 7 s
z Backend.copyc C s | S )z.Whether the given node object has no children.r )r rJ r r r re = s z
Backend.emptyc C s t |dd}|r ||S tS )z?Whether the given node object contains the given child element. __contains__N)getattrrD )r rJ rP containsr r r rY A s z Backend.hasc C s2 t |dd}|r | S t|tu rtt|S tS )z?Return the keys of the child elements of the given node object.r[ N)r rF rA rangerE rD )r rJ r[ r r r r[ H s z Backend.keysN)r
r r ro r r r> r? rC rH rd r@ re rY r[ r r r r r s r c @ , e Zd Zdd Zdd Zdd Zdd Zd S )
r c C ddl m} || _d S )Nr )cPickle)landscape.lib.compatr _pickle)r r r r r r" T
zPickleBackend.__init__c C i S r$ r r% r r r r X r zPickleBackend.newc C s: t |d}| j|W d S 1 sw Y d S Nrb)openr r r r7 fdr r r r [ s
$zPickleBackend.loadc C s@ t |d}| j||d W d d S 1 sw Y d S )Nwb )r r dumpr r7 r] r r r r r> _ s "zPickleBackend.saveNr
r r r" r r r> r r r r r R
r c @ r )
r c C r )Nr )bpickle)
landscape.libr _bpickle)r r r r r r" f r zBPickleBackend.__init__c C r r$ r r% r r r r j r zBPickleBackend.newc C s> t |d}| j| W d S 1 sw Y d S r )r r loadsreadr r r r r m s $zBPickleBackend.loadc C sB t |d}|| j| W d d S 1 sw Y d S )Nr )r writer dumpsr r r r r> q s "zBPickleBackend.saveNr r r r r r d r r )r r^ r@ retwisted.python.compatr __all__objectr? r4 r r
r r compilesplitr r r r r r r r r r s( 0 I