asda?‰PNG
IHDR ? f ??C1 sRGB ?? é gAMA ±? üa pHYs ? ??o¨d GIDATx^íüL”÷ e÷Y?a?("Bh?_ò???￠§?q5k?*:t0A-o??￥]VkJ￠M??f?±8\k2íll￡1]q?ù???T
PK He[I3 files.pynu [ # -*- coding: utf-8 -*-
# slip.util.files -- file helper functions
#
# Copyright © 2009, 2010, 2012, 2015 Red Hat, Inc.
#
# This program is free software; you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation; either version 2 of the License, or
# (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program. If not, see .
#
# Authors:
# Nils Philippsen
"""This module contains helper functions for dealing with files."""
from __future__ import absolute_import
# ensure range() returns a generator
if 'xrange' in dir(__builtins__):
range = xrange
__all__ = ["issamefile", "linkfile", "copyfile", "linkorcopyfile",
"overwrite_safely"]
import os
import selinux
import tempfile
import errno
import stat
BLOCKSIZE = 1024
def _issamefile(path1, path2):
s1 = os.stat(path1)
s2 = os.stat(path2)
return os.path.samestat(s1, s2)
def issamefile(path1, path2, catch_stat_exceptions=[]):
"""Check whether two paths point to the same file (i.e. are hardlinked)."""
if catch_stat_exceptions is True:
catch_stat_exceptions = Exception
try:
return _issamefile(path1, path2)
except catch_stat_exceptions:
return False
def linkfile(srcpath, dstpath):
"""Hardlink srcpath to dstpath.
Attempt to atomically replace dstpath if it exists."""
if issamefile(srcpath, dstpath, catch_stat_exceptions=OSError):
return
dstpath = os.path.abspath(dstpath)
dstdname = os.path.dirname(dstpath)
dstbname = os.path.basename(dstpath)
hardlinked = False
for attempt in range(tempfile.TMP_MAX):
_dsttmp = tempfile.mktemp(prefix=dstbname + os.extsep, dir=dstdname)
try:
os.link(srcpath, _dsttmp)
except OSError as e:
if e.errno == errno.EEXIST:
# try another name
pass
else:
raise
else:
hardlinked = True
break
if hardlinked:
os.rename(_dsttmp, dstpath)
def copyfile(srcpath, dstpath, copy_mode_from_dst=True, run_restorecon=True):
"""Copy srcpath to dstpath.
Abort operation if e.g. not enough space is available. Attempt to
atomically replace dstpath if it exists."""
if issamefile(srcpath, dstpath, catch_stat_exceptions=OSError):
return
dstpath = os.path.abspath(dstpath)
dstdname = os.path.dirname(dstpath)
dstbname = os.path.basename(dstpath)
srcfile = open(srcpath, "rb")
dsttmpfile = tempfile.NamedTemporaryFile(
prefix=dstbname + os.path.extsep, dir=dstdname, delete=False)
s = os.stat(srcpath)
if copy_mode_from_dst:
# attempt to copy mode from destination file (if it exists,
# otherwise fall back to copying it from the source file below)
try:
s = os.stat(dstpath)
except OSError:
pass
os.fchmod(dsttmpfile.fileno(), stat.S_IMODE(s.st_mode))
data = None
while data != "":
data = srcfile.read(BLOCKSIZE)
try:
dsttmpfile.write(data)
except:
srcfile.close()
dsttmpfile.close()
os.unlink(dsttmpfile.name)
raise
srcfile.close()
dsttmpfile.close()
os.rename(dsttmpfile.name, dstpath)
if run_restorecon and selinux.is_selinux_enabled() > 0:
selinux.restorecon(dstpath)
def linkorcopyfile(
srcpath, dstpath, copy_mode_from_dst=True, run_restorecon=True):
"""First attempt to hardlink srcpath to dstpath, if hardlinking isn't
possible, attempt copying srcpath to dstpath."""
try:
linkfile(srcpath, dstpath)
return
except OSError as e:
if e.errno not in (errno.EMLINK, errno.EPERM, errno.EXDEV):
# don't bother copying
raise
else:
# try copying
pass
copyfile(srcpath, dstpath, copy_mode_from_dst, run_restorecon)
def symlink_atomically(srcpath, dstpath, force=False, preserve_context=True):
"""Create a symlink, optionally replacing dstpath atomically, optionally
setting or preserving SELinux context."""
dstdname = os.path.dirname(dstpath)
dstbname = os.path.basename(dstpath)
run_restorecon = False
ctx = None
if preserve_context and selinux.is_selinux_enabled() <= 0:
preserve_context = False
else:
try:
ret, ctx = selinux.lgetfilecon(dstpath)
if ret < 0:
raise RuntimeError("getfilecon(%r) failed" % dstpath)
except OSError as e:
if e.errno == errno.ENOENT:
run_restorecon = True
else:
raise
if not force:
os.symlink(srcpath, dstpath)
if preserve_context:
selinux.restorecon(dstpath)
else:
dsttmp = None
for attempt in range(tempfile.TMP_MAX):
_dsttmp = tempfile.mktemp(
prefix=dstbname + os.extsep, dir=dstdname)
try:
os.symlink(srcpath, _dsttmp)
except OSError as e:
if e.errno == errno.EEXIST:
# try again
continue
raise
else:
dsttmp = _dsttmp
break
if dsttmp is None:
raise IOError(
errno.EEXIST,
"No suitable temporary symlink could be created.")
if preserve_context and not run_restorecon:
selinux.lsetfilecon(dsttmp, ctx)
try:
os.rename(dsttmp, dstpath)
except:
# clean up
os.remove(dsttmp)
raise
if run_restorecon:
selinux.restorecon(dstpath)
def overwrite_safely(
path, content, preserve_mode=True, preserve_context=True,
preserve_ownership=True):
"""Safely overwrite a file by creating a temporary file in the same
directory, writing it, moving it over the original file, eventually
preserving file mode, SELinux context and ownership."""
path = os.path.realpath(path)
dir_ = os.path.dirname(path)
base = os.path.basename(path)
fd = None
f = None
tmpname = None
exists = os.path.exists(path)
if preserve_context and selinux.is_selinux_enabled() <= 0:
preserve_context = False
try:
fd, tmpname = tempfile.mkstemp(prefix=base + os.path.extsep,
dir=dir_)
if exists:
s = os.stat(path)
if preserve_ownership:
os.fchown(fd, s.st_uid, s.st_gid)
if preserve_mode:
os.fchmod(fd, stat.S_IMODE(s.st_mode))
if preserve_context:
ret, ctx = selinux.getfilecon(path)
if ret < 0:
raise RuntimeError("getfilecon(%r) failed" % path)
f = os.fdopen(fd, "w")
fd = None
f.write(content)
f.close()
f = None
os.rename(tmpname, path)
if preserve_context:
if exists:
selinux.setfilecon(path, ctx)
else:
selinux.restorecon(path)
finally:
if f:
f.close()
elif fd:
os.close(fd)
if tmpname and os.path.isfile(tmpname):
try:
os.unlink(tmpname)
except:
pass
PK He[ɫ # __pycache__/__init__.cpython-36.pycnu [ 3
uAcl @ s( d dl mZ ddlmZ ddlmZ dS ) )absolute_import )hookable)filesN)Z
__future__r r r r r /usr/lib/python3.6/__init__.py s PK He[ɫ ) __pycache__/__init__.cpython-36.opt-1.pycnu [ 3
uAcl @ s( d dl mZ ddlmZ ddlmZ dS ) )absolute_import )hookable)filesN)Z
__future__r r r r r /usr/lib/python3.6/__init__.py s PK He[og0 ) __pycache__/hookable.cpython-36.opt-1.pycnu [ 3
uAc^ @ sl d Z ddlZddlmZ ddgZG dd deZG dd d eZG d
d deeeZ G d d de
e Z dS ) z[This module contains variants of certain base types which call registered
hooks on changes. N)with_metaclassHookable HookableSetc @ s e Zd Zdd Zedd ZdS ) HookableTypec
C s d|kry |d }W nJ t k
r^ d }x0dd |D D ] }|rRtdt| q8|}q8W Y nX x |d D ]}tj||||< qjW tj| |||S )N_hookable_change_methodsZ_hookable_base_classc s s | ]}|t kr|V qd S )N)r ).0x r /usr/lib/python3.6/hookable.py ) s z'HookableType.__new__..ztoo many base classes: %s)KeyError TypeErrorstrr wrap_methodtype__new__)clsnamebasesZdctbaseZbase_candidate
methodnamer r r
r " s zHookableType.__new__c s t || fdd}||_|S )Nc s | f||}| j |S )N)
_run_hooks)selfpkZretval)funcr r
methodwrapper9 s z/HookableType.wrap_method..methodwrapper)getattr__name__)r r r r r )r r
r 5 s
zHookableType.wrap_methodN)r
__module__ __qualname__r classmethodr r r r r
r s r c @ s6 e Zd Zd ddZdd Zdd Zdd Zd
d ZdS )
_HookEntryNc C s xFt |D ]:\}}y t| W q
tk
rB td||f Y q
X q
W xF|j D ]:\}}y t| W qR tk
r td||f Y qRX qRW t|tst|}|| _|| _|| _|| _ d | _
d S )Nz*Positional argument %d is not hashable: %rz'Keyword argument %r is not hashable: %r) enumeratehashr
items
isinstancetuple_HookEntry__hook_HookEntry__args_HookEntry__kwargs_HookEntry__hookable_HookEntry__hash)r hookargskwargshookablenr r r r r
__init__D s*
z_HookEntry.__init__c C s$ | j |j ko"| j|jko"| j|jkS )N)r( r) r* )r objr r r
__cmp__c s z_HookEntry.__cmp__c C s | j s| j | _ | j S )N)r,
_compute_hash)r r r r
__hash__i s
z_HookEntry.__hash__c C s> t | j}t |t | jA }t |t tt| jj A }|S )N)r$ r( r) r' sortedr* r% )r hashvaluer r r
r5 n s
z_HookEntry._compute_hashc C s4 | j r | j| j f| j| j n| j| j| j d S )N)r+ r( r) r* )r r r r
runu s z_HookEntry.run)N)r r r r2 r4 r6 r5 r9 r r r r
r" B s
r" c @ s e Zd ZdZedd Zdd Zdd ZeeeZdd Z d
d Z
ee e
Z d d
Z dd Z
dd Zdd Zdd Zdd Zdd ZdS )r z2An object which calls registered hooks on changes.c O s t | dst | _| jS )N__real_hooks__)hasattrsetr: )r r r r r r
__hooks__ s
zHookable.__hooks__c C s t | dsd| _| jS )N__hooks_enabled__T)r; r> )r r r r
_get_hooks_enabled s
zHookable._get_hooks_enabledc C s
|| _ d S )N)r> )r Zenabledr r r
_set_hooks_enabled s zHookable._set_hooks_enabledc C s t | dsd| _| jS )N__hooks_frozen__F)r; rA )r r r r
_get_hooks_frozen s
zHookable._get_hooks_frozenc C sB || j krd S || _|r"t | _n x| jD ] }|j q*W | `d S )N) hooks_frozenrA r< __hooks_frozen_entries__r9 )r Zfreeze hookentryr r r
_set_hooks_frozen s
zHookable._set_hooks_frozenc C s
d| _ d S )NT)rC )r r r r
freeze_hooks s zHookable.freeze_hooksc C s
d| _ d S )NF)rC )r r r r
thaw_hooks s zHookable.thaw_hooksc O s | j |d f|| d S )N)_Hookable__add_hook)r r- r. r/ r r r
add_hook s zHookable.add_hookc O s | j || f|| d S )N)rI )r r- r. r/ r r r
add_hook_hookable s zHookable.add_hook_hookablec O s t ||||d}| jj| d S )N)r0 )r" r= add)r r- Z _hookabler. r/ rE r r r
Z
__add_hook s zHookable.__add_hookc O s | j jt||| d S )N)r= remover" )r r- r. r/ r r r
remove_hook s zHookable.remove_hookc C s8 | j r4| js&x&| jD ] }|j qW n| jj| j d S )N)
hooks_enabledrC r= r9 rD update)r rE r r r
r s
zHookable._run_hooksN)r r r __doc__propertyr= r? r@ rO rB rF rC rG rH rJ rK rI rN r r r r r
r | s
c @ s e Zd ZdZdZd d Zd
S )r z5A set object which calls registered hooks on changes.rL cleardifference_updatediscardintersection_updatepoprM symmetric_difference_updaterP c C s t j| }t |_|S )N)r< copyr: )r r3 r r r
rY s
zHookableSet.copyN) rL rS rT rU rV rW rM rX rP )r r r rQ r rY r r r r
r s ) rQ collectionsZsixr __all__r r objectr" r r< r r r r r
s ":GPK He[[ U U & __pycache__/files.cpython-36.opt-1.pycnu [ 3
uAc @ s d Z ddlmZ deekr eZdddddgZdd lZdd l Z dd l
Z
dd l Z dd l Z d
Z
d d Zg fd
dZdd ZdddZdddZdddZdddZd S )z=This module contains helper functions for dealing with files. )absolute_importxrange
issamefilelinkfilecopyfilelinkorcopyfileoverwrite_safelyNi c C s" t j| }t j|}t jj||S )N)osstatpathsamestat)path1path2s1s2 r /usr/lib/python3.6/files.py _issamefile+ s
r c C s0 |dkr t }y
t| |S |k
r* dS X dS )zECheck whether two paths point to the same file (i.e. are hardlinked).TFN) Exceptionr )r
r catch_stat_exceptionsr r r r 2 s
c C s t | |tdrdS tjj|}tjj|}tjj|}d}xpttj D ]b}tj
|tj |d}ytj | | W n2 tk
r } z|j
t
jkrn W Y dd}~X qFX d}P qFW |rtj|| dS )zUHardlink srcpath to dstpath.
Attempt to atomically replace dstpath if it exists.)r NF)prefixdirT)r OSErrorr r abspathdirnamebasenamerangetempfileTMP_MAXmktempextseplinkerrnoEEXISTrename)srcpathdstpathdstdnamedstbnameZ
hardlinkedattempt_dsttmper r r r > s$ Tc
C s8 t | |tdrdS tjj|}tjj|}tjj|}t| d}tj |tjj
|dd}tj | }|rytj |}W n tk
r Y nX tj |j
t j|j d} xP| dkr|jt} y|j| W q |j |j tj|j Y qX qW |j |j tj|j| |r4tj dkr4tj| dS )zCopy srcpath to dstpath.
Abort operation if e.g. not enough space is available. Attempt to
atomically replace dstpath if it exists.)r NrbF)r r delete r )r r r r r r r openr ZNamedTemporaryFiler r
fchmodfilenoS_IMODEst_moderead BLOCKSIZEwritecloseunlinknamer$ selinuxis_selinux_enabled
restorecon)
r% r& copy_mode_from_dstrun_restoreconr' r( ZsrcfileZ
dsttmpfilesdatar r r r _ s<
c C s^ yt | | dS tk
rJ } z |jtjtjtjfkr: n W Y dd}~X nX t| ||| dS )ztFirst attempt to hardlink srcpath to dstpath, if hardlinking isn't
possible, attempt copying srcpath to dstpath.N)r r r" ZEMLINKZEPERMZEXDEVr )r% r& r= r> r+ r r r r s
Fc
C s t jj|}t jj|}d}d}|r6tj dkr6d}n^y&tj|\}}|dk rZtd| W n6 tk
r } z| j t j
krd}n W Y dd} ~ X nX |st j | | |rtj | nd}
xtt
tjD ]f} tj|t j |d} yt j | | W n6 tk
r" } z| j t jkrwĂ W Y dd} ~ X qX | }
P qW |
dkrDtt jd|r^| r^tj|
| yt j|
| W n t j|
Y nX |rtj | dS )zpCreate a symlink, optionally replacing dstpath atomically, optionally
setting or preserving SELinux context.FNr zgetfilecon(%r) failedT)r r z/No suitable temporary symlink could be created.)r r r r r: r; Z lgetfilecon RuntimeErrorr r" ENOENTsymlinkr< r r r r r r# IOErrorZ lsetfileconr$ remove)
r% r& forcepreserve_contextr' r( r> ctxretr+ Zdsttmpr) r* r r r symlink_atomically sV
rJ c C s~ t jj| } t jj| }t jj| }d}d}d} t jj| }
|rPtj dkrPd}ztj |t jj
|d\}} |
rt j | } |rt j || j
| j |rt j|t j| j |rtj| \} }
| dk rtd| t j|d}d}|j| |j d}t j| | |r$|
rtj| |
n
tj| W d|r8|j n|rHt j| | rxt jj| rxyt j| W n Y nX X dS )zSafely overwrite a file by creating a temporary file in the same
directory, writing it, moving it over the original file, eventually
preserving file mode, SELinux context and ownership.Nr F)r r zgetfilecon(%r) failedw) r r realpathr r existsr: r; r Zmkstempr r
fchownst_uidst_gidr0 r2 r3 Z
getfileconrA fdopenr6 r7 r$ Z
setfileconr< isfiler8 )r ZcontentZ
preserve_moderG Zpreserve_ownershipZdir_basefdfZtmpnamerM r? rI rH r r r r sR
)TT)TT)FT)TTT)__doc__Z
__future__r r __builtins__r r __all__r r: r r" r
r5 r r r r r rJ r r r r r s& !
5
? PK He[[ U U __pycache__/files.cpython-36.pycnu [ 3
uAc @ s d Z ddlmZ deekr eZdddddgZdd lZdd l Z dd l
Z
dd l Z dd l Z d
Z
d d Zg fd
dZdd ZdddZdddZdddZdddZd S )z=This module contains helper functions for dealing with files. )absolute_importxrange
issamefilelinkfilecopyfilelinkorcopyfileoverwrite_safelyNi c C s" t j| }t j|}t jj||S )N)osstatpathsamestat)path1path2s1s2 r /usr/lib/python3.6/files.py _issamefile+ s
r c C s0 |dkr t }y
t| |S |k
r* dS X dS )zECheck whether two paths point to the same file (i.e. are hardlinked).TFN) Exceptionr )r
r catch_stat_exceptionsr r r r 2 s
c C s t | |tdrdS tjj|}tjj|}tjj|}d}xpttj D ]b}tj
|tj |d}ytj | | W n2 tk
r } z|j
t
jkrn W Y dd}~X qFX d}P qFW |rtj|| dS )zUHardlink srcpath to dstpath.
Attempt to atomically replace dstpath if it exists.)r NF)prefixdirT)r OSErrorr r abspathdirnamebasenamerangetempfileTMP_MAXmktempextseplinkerrnoEEXISTrename)srcpathdstpathdstdnamedstbnameZ
hardlinkedattempt_dsttmper r r r > s$ Tc
C s8 t | |tdrdS tjj|}tjj|}tjj|}t| d}tj |tjj
|dd}tj | }|rytj |}W n tk
r Y nX tj |j
t j|j d} xP| dkr|jt} y|j| W q |j |j tj|j Y qX qW |j |j tj|j| |r4tj dkr4tj| dS )zCopy srcpath to dstpath.
Abort operation if e.g. not enough space is available. Attempt to
atomically replace dstpath if it exists.)r NrbF)r r delete r )r r r r r r r openr ZNamedTemporaryFiler r
fchmodfilenoS_IMODEst_moderead BLOCKSIZEwritecloseunlinknamer$ selinuxis_selinux_enabled
restorecon)
r% r& copy_mode_from_dstrun_restoreconr' r( ZsrcfileZ
dsttmpfilesdatar r r r _ s<
c C s^ yt | | dS tk
rJ } z |jtjtjtjfkr: n W Y dd}~X nX t| ||| dS )ztFirst attempt to hardlink srcpath to dstpath, if hardlinking isn't
possible, attempt copying srcpath to dstpath.N)r r r" ZEMLINKZEPERMZEXDEVr )r% r& r= r> r+ r r r r s
Fc
C s t jj|}t jj|}d}d}|r6tj dkr6d}n^y&tj|\}}|dk rZtd| W n6 tk
r } z| j t j
krd}n W Y dd} ~ X nX |st j | | |rtj | nd}
xtt
tjD ]f} tj|t j |d} yt j | | W n6 tk
r" } z| j t jkrwĂ W Y dd} ~ X qX | }
P qW |
dkrDtt jd|r^| r^tj|
| yt j|
| W n t j|
Y nX |rtj | dS )zpCreate a symlink, optionally replacing dstpath atomically, optionally
setting or preserving SELinux context.FNr zgetfilecon(%r) failedT)r r z/No suitable temporary symlink could be created.)r r r r r: r; Z lgetfilecon RuntimeErrorr r" ENOENTsymlinkr< r r r r r r# IOErrorZ lsetfileconr$ remove)
r% r& forcepreserve_contextr' r( r> ctxretr+ Zdsttmpr) r* r r r symlink_atomically sV
rJ c C s~ t jj| } t jj| }t jj| }d}d}d} t jj| }
|rPtj dkrPd}ztj |t jj
|d\}} |
rt j | } |rt j || j
| j |rt j|t j| j |rtj| \} }
| dk rtd| t j|d}d}|j| |j d}t j| | |r$|
rtj| |
n
tj| W d|r8|j n|rHt j| | rxt jj| rxyt j| W n Y nX X dS )zSafely overwrite a file by creating a temporary file in the same
directory, writing it, moving it over the original file, eventually
preserving file mode, SELinux context and ownership.Nr F)r r zgetfilecon(%r) failedw) r r realpathr r existsr: r; r Zmkstempr r
fchownst_uidst_gidr0 r2 r3 Z
getfileconrA fdopenr6 r7 r$ Z
setfileconr< isfiler8 )r ZcontentZ
preserve_moderG Zpreserve_ownershipZdir_basefdfZtmpnamerM r? rI rH r r r r sR
)TT)TT)FT)TTT)__doc__Z
__future__r r __builtins__r r __all__r r: r r" r
r5 r r r r r rJ r r r r r s& !
5
? PK He[Rg # __pycache__/hookable.cpython-36.pycnu [ 3
uAc^ @ sl d Z ddlZddlmZ ddgZG dd deZG dd d eZG d
d deeeZ G d d de
e Z dS ) z[This module contains variants of certain base types which call registered
hooks on changes. N)with_metaclassHookable HookableSetc @ s e Zd Zdd Zedd ZdS ) HookableTypec
C s d|kry |d }W nJ t k
r^ d }x0dd |D D ] }|rRtdt| q8|}q8W Y nX x |d D ]}tj||||< qjW tj| |||S )N_hookable_change_methodsZ_hookable_base_classc s s | ]}|t kr|V qd S )N)r ).0x r /usr/lib/python3.6/hookable.py ) s z'HookableType.__new__..ztoo many base classes: %s)KeyError TypeErrorstrr wrap_methodtype__new__)clsnamebasesZdctbaseZbase_candidate
methodnamer r r
r " s zHookableType.__new__c s t || fdd}||_|S )Nc s | f||}| j |S )N)
_run_hooks)selfpkZretval)funcr r
methodwrapper9 s z/HookableType.wrap_method..methodwrapper)getattr__name__)r r r r r )r r
r 5 s
zHookableType.wrap_methodN)r
__module__ __qualname__r classmethodr r r r r
r s r c @ s6 e Zd Zd ddZdd Zdd Zdd Zd
d ZdS )
_HookEntryNc C s t |tjstt |ts txFt|D ]:\}}y t| W q( tk
r` td||f Y q(X q(W xF|j D ]:\}}y t| W qp tk
r td||f Y qpX qpW t |t st |}|| _
|| _ || _ || _
d | _d S )Nz*Positional argument %d is not hashable: %rz'Keyword argument %r is not hashable: %r)
isinstance collectionsCallableAssertionErrorr enumeratehashr
itemstuple_HookEntry__hook_HookEntry__args_HookEntry__kwargs_HookEntry__hookable_HookEntry__hash)r hookargskwargshookablenr r r r r
__init__D s.
z_HookEntry.__init__c C s$ | j |j ko"| j|jko"| j|jkS )N)r+ r, r- )r objr r r
__cmp__c s z_HookEntry.__cmp__c C s | j s| j | _ | j S )N)r/
_compute_hash)r r r r
__hash__i s
z_HookEntry.__hash__c C s> t | j}t |t | jA }t |t tt| jj A }|S )N)r( r+ r, r* sortedr- r) )r hashvaluer r r
r8 n s
z_HookEntry._compute_hashc C s4 | j r | j| j f| j| j n| j| j| j d S )N)r. r+ r, r- )r r r r
runu s z_HookEntry.run)N)r r r r5 r7 r9 r8 r< r r r r
r" B s
r" c @ s e Zd ZdZedd Zdd Zdd ZeeeZdd Z d
d Z
ee e
Z d d
Z dd Z
dd Zdd Zdd Zdd Zdd ZdS )r z2An object which calls registered hooks on changes.c O s t | dst | _| jS )N__real_hooks__)hasattrsetr= )r r r r r r
__hooks__ s
zHookable.__hooks__c C s t | dsd| _| jS )N__hooks_enabled__T)r> rA )r r r r
_get_hooks_enabled s
zHookable._get_hooks_enabledc C s
|| _ d S )N)rA )r Zenabledr r r
_set_hooks_enabled s zHookable._set_hooks_enabledc C s t | dsd| _| jS )N__hooks_frozen__F)r> rD )r r r r
_get_hooks_frozen s
zHookable._get_hooks_frozenc C sB || j krd S || _|r"t | _n x| jD ] }|j q*W | `d S )N) hooks_frozenrD r? __hooks_frozen_entries__r< )r Zfreeze hookentryr r r
_set_hooks_frozen s
zHookable._set_hooks_frozenc C s
d| _ d S )NT)rF )r r r r
freeze_hooks s zHookable.freeze_hooksc C s
d| _ d S )NF)rF )r r r r
thaw_hooks s zHookable.thaw_hooksc O s | j |d f|| d S )N)_Hookable__add_hook)r r0 r1 r2 r r r
add_hook s zHookable.add_hookc O s | j || f|| d S )N)rL )r r0 r1 r2 r r r
add_hook_hookable s zHookable.add_hook_hookablec O s> t |tjstt |ts tt||||d}| jj| d S )N)r3 )r# r$ r% r& r r" r@ add)r r0 Z _hookabler1 r2 rH r r r
Z
__add_hook s zHookable.__add_hookc O s | j jt||| d S )N)r@ remover" )r r0 r1 r2 r r r
remove_hook s zHookable.remove_hookc C s8 | j r4| js&x&| jD ] }|j qW n| jj| j d S )N)
hooks_enabledrF r@ r< rG update)r rH r r r
r s
zHookable._run_hooksN)r r r __doc__propertyr@ rB rC rR rE rI rF rJ rK rM rN rL rQ r r r r r
r | s
c @ s e Zd ZdZdZd d Zd
S )r z5A set object which calls registered hooks on changes.rO cleardifference_updatediscardintersection_updatepoprP symmetric_difference_updaterS c C s t j| }t |_|S )N)r? copyr= )r r6 r r r
r\ s
zHookableSet.copyN) rO rV rW rX rY rZ rP r[ rS )r r r rT r r\ r r r r
r s ) rT r$ Zsixr __all__r r objectr" r r? r r r r r
s ":GPK He[ECyH^ ^ hookable.pynu [ # -*- coding: utf-8 -*-
# slip.util.hookable -- run hooks on changes in objects
#
# Copyright © 2008 Red Hat, Inc.
#
# This program is free software; you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation; either version 2 of the License, or
# (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program. If not, see .
#
# Authors:
# Nils Philippsen
"""This module contains variants of certain base types which call registered
hooks on changes."""
import collections
from six import with_metaclass
__all__ = ["Hookable", "HookableSet"]
class HookableType(type):
def __new__(cls, name, bases, dct):
if '_hookable_change_methods' in dct:
try:
base = dct["_hookable_base_class"]
except KeyError:
base = None
for base_candidate in (x for x in bases if x != Hookable):
if base:
raise TypeError(
"too many base classes: %s" % str(bases))
else:
base = base_candidate
for methodname in dct["_hookable_change_methods"]:
dct[methodname] = HookableType.wrap_method(base, methodname)
return type.__new__(cls, name, bases, dct)
@classmethod
def wrap_method(cls, base, methodname):
func = getattr(base, methodname)
def methodwrapper(self, *p, **k):
retval = func(self, *p, **k)
self._run_hooks()
return retval
methodwrapper.__name__ = methodname
return methodwrapper
class _HookEntry(object):
def __init__(self, hook, args, kwargs, hookable=None):
assert(isinstance(hook, collections.Callable))
assert(isinstance(hookable, Hookable))
for n, x in enumerate(args):
try:
hash(x)
except TypeError:
raise TypeError(
"Positional argument %d is not hashable: %r" %
(n, x))
for k, x in kwargs.items():
try:
hash(x)
except TypeError:
raise TypeError(
"Keyword argument %r is not hashable: %r" %
(k, x))
if not isinstance(args, tuple):
args = tuple(args)
self.__hook = hook
self.__args = args
self.__kwargs = kwargs
self.__hookable = hookable
self.__hash = None
def __cmp__(self, obj):
return (
self.__hook == obj.__hook and
self.__args == obj.__args and
self.__kwargs == obj.__kwargs)
def __hash__(self):
if not self.__hash:
self.__hash = self._compute_hash()
return self.__hash
def _compute_hash(self):
hashvalue = hash(self.__hook)
hashvalue = hash(hashvalue) ^ hash(self.__args)
hashvalue = hash(hashvalue) ^ hash(
tuple(sorted(self.__kwargs.items())))
return hashvalue
def run(self):
if self.__hookable:
self.__hook(self.__hookable, *self.__args, **self.__kwargs)
else:
self.__hook(*self.__args, **self.__kwargs)
class Hookable(with_metaclass(HookableType, object)):
"""An object which calls registered hooks on changes."""
@property
def __hooks__(self, *p, **k):
if not hasattr(self, "__real_hooks__"):
self.__real_hooks__ = set()
return self.__real_hooks__
def _get_hooks_enabled(self):
if not hasattr(self, "__hooks_enabled__"):
self.__hooks_enabled__ = True
return self.__hooks_enabled__
def _set_hooks_enabled(self, enabled):
self.__hooks_enabled__ = enabled
hooks_enabled = property(_get_hooks_enabled, _set_hooks_enabled)
def _get_hooks_frozen(self):
if not hasattr(self, "__hooks_frozen__"):
self.__hooks_frozen__ = False
return self.__hooks_frozen__
def _set_hooks_frozen(self, freeze):
if freeze == self.hooks_frozen:
return
self.__hooks_frozen__ = freeze
if freeze:
self.__hooks_frozen_entries__ = set()
else:
for hookentry in self.__hooks_frozen_entries__:
hookentry.run()
del self.__hooks_frozen_entries__
hooks_frozen = property(_get_hooks_frozen, _set_hooks_frozen)
def freeze_hooks(self):
self.hooks_frozen = True
def thaw_hooks(self):
self.hooks_frozen = False
def add_hook(self, hook, *args, **kwargs):
self.__add_hook(hook, None, *args, **kwargs)
def add_hook_hookable(self, hook, *args, **kwargs):
self.__add_hook(hook, self, *args, **kwargs)
def __add_hook(self, hook, _hookable, *args, **kwargs):
assert isinstance(hook, collections.Callable)
assert isinstance(_hookable, Hookable)
hookentry = _HookEntry(hook, args, kwargs, hookable=_hookable)
self.__hooks__.add(hookentry)
def remove_hook(self, hook, *args, **kwargs):
self.__hooks__.remove(_HookEntry(hook, args, kwargs))
def _run_hooks(self):
if self.hooks_enabled:
if not self.hooks_frozen:
for hookentry in self.__hooks__:
hookentry.run()
else:
self.__hooks_frozen_entries__.update(self.__hooks__)
class HookableSet(set, Hookable):
"""A set object which calls registered hooks on changes."""
_hookable_change_methods = (
"add", "clear", "difference_update", "discard", "intersection_update",
"pop", "remove", "symmetric_difference_update", "update")
def copy(self):
obj = set.copy(self)
obj.__real_hooks__ = set()
return obj
PK He[`JwQl l __init__.pynu [ # -*- coding: utf-8 -*-
from __future__ import absolute_import
from . import hookable
from . import files
PK He[I3 files.pynu [ PK He[ɫ # __pycache__/__init__.cpython-36.pycnu [ PK He[ɫ ) __pycache__/__init__.cpython-36.opt-1.pycnu [ PK He[og0 ) ]! __pycache__/hookable.cpython-36.opt-1.pycnu [ PK He[[ U U & 8 __pycache__/files.cpython-36.opt-1.pycnu [ PK He[[ U U _L __pycache__/files.cpython-36.pycnu [ PK He[Rg # ` __pycache__/hookable.cpython-36.pycnu [ PK He[ECyH^ ^ w hookable.pynu [ PK He[`JwQl l o __init__.pynu [ PK <