D7net
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
home
/
vblioqus
/
karachi777.vip
/
in
/
106014
/
900508
/
Filename :
util.tar
back
Copy
__init__.py 0000644 00000000154 15154265001 0006654 0 ustar 00 # -*- coding: utf-8 -*- from __future__ import absolute_import from . import hookable from . import files __pycache__/hookable.cpython-36.pyc 0000644 00000013577 15154265002 0013203 0 ustar 00 3 �uAc^ � @ sl d Z ddlZddlmZ ddgZG dd� de�ZG dd � d e�ZG d d� deee��Z G d d� de e �Z dS ) z[This module contains variants of certain base types which call registered hooks on changes.� N)�with_metaclass�Hookable� HookableSetc @ s e Zd Zdd� Zedd� �ZdS )� HookableTypec C s� d|kr�y |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 )�.0�x� r � /usr/lib/python3.6/hookable.py� <genexpr>) s z'HookableType.__new__.<locals>.<genexpr>ztoo many base classes: %s)�KeyError� TypeError�strr � wrap_method�type�__new__)�cls�name�basesZdct�baseZbase_candidate� methodnamer r r r " s zHookableType.__new__c s t ||�� � fdd�}||_|S )Nc s � | f|�|�}| j � |S )N)� _run_hooks)�self�p�kZretval)�funcr r � methodwrapper9 s z/HookableType.wrap_method.<locals>.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 dd�Zdd� Zdd� Zdd � Zd d � ZdS ) � _HookEntryNc C s� t |tj�st�t |t�s t�xFt|�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 �s�t |�}|| _ || _ || _ || _ d | _d S )Nz*Positional argument %d is not hashable: %rz'Keyword argument %r is not hashable: %r)� isinstance� collections�Callable�AssertionErrorr � enumerate�hashr �items�tuple�_HookEntry__hook�_HookEntry__args�_HookEntry__kwargs�_HookEntry__hookable�_HookEntry__hash)r �hook�args�kwargs�hookable�nr 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 | j�A }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� Zeee�Zdd � 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 | d�st� | _| jS )N�__real_hooks__)�hasattr�setr= )r r r r r r � __hooks__� s zHookable.__hooks__c C s t | d�sd| _| 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 | d�sd| _| 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 |tj�st�t |t�s t�t||||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 �clear�difference_update�discard�intersection_update�poprP �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 �<module> s ":G __pycache__/hookable.cpython-36.opt-1.pyc 0000644 00000013376 15154265002 0014137 0 ustar 00 3 �uAc^ � @ sl d Z ddlZddlmZ ddgZG dd� de�ZG dd � d e�ZG d d� deee��Z G d d� de e �Z dS ) z[This module contains variants of certain base types which call registered hooks on changes.� N)�with_metaclass�Hookable� HookableSetc @ s e Zd Zdd� Zedd� �ZdS )� HookableTypec C s� d|kr�y |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 )�.0�x� r � /usr/lib/python3.6/hookable.py� <genexpr>) s z'HookableType.__new__.<locals>.<genexpr>ztoo many base classes: %s)�KeyError� TypeError�strr � wrap_method�type�__new__)�cls�name�basesZdct�baseZbase_candidate� methodnamer r r r " s zHookableType.__new__c s t ||�� � fdd�}||_|S )Nc s � | f|�|�}| j � |S )N)� _run_hooks)�self�p�kZretval)�funcr r � methodwrapper9 s z/HookableType.wrap_method.<locals>.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 dd�Zdd� 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|t�s�t|�}|| _|| _|| _|| _ d | _ d S )Nz*Positional argument %d is not hashable: %rz'Keyword argument %r is not hashable: %r) � enumerate�hashr �items� isinstance�tuple�_HookEntry__hook�_HookEntry__args�_HookEntry__kwargs�_HookEntry__hookable�_HookEntry__hash)r �hook�args�kwargs�hookable�nr 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 | j�A }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� Zeee�Zdd � 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 | d�st� | _| jS )N�__real_hooks__)�hasattr�setr: )r r r r r r � __hooks__� s zHookable.__hooks__c C s t | d�sd| _| 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 | d�sd| _| 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 �clear�difference_update�discard�intersection_update�poprM �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 �<module> s ":G __pycache__/files.cpython-36.pyc 0000644 00000011525 15154265003 0012511 0 ustar 00 3 �uAc� � @ s� d Z ddlmZ dee�kr eZdddddgZdd lZdd l Z dd l Z dd l Z dd l Z d Z d d � Zg fd d�Zdd� Zddd�Zddd�Zddd�Zddd�Zd S )z=This module contains helper functions for dealing with files.� )�absolute_import�xrange� issamefile�linkfile�copyfile�linkorcopyfile�overwrite_safelyNi c C s" t j| �}t j|�}t jj||�S )N)�os�stat�path�samestat)�path1�path2�s1�s2� 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 | |td�rdS tjj|�}tjj|�}tjj|�}d}xpttj �D ]b}tj |tj |d�}ytj | |� W n2 tk r� } z|j t jkr�n� W Y dd}~X qFX d}P qFW |r�tj||� dS )zUHardlink srcpath to dstpath. Attempt to atomically replace dstpath if it exists.)r NF)�prefix�dirT)r �OSErrorr r �abspath�dirname�basename�range�tempfile�TMP_MAX�mktemp�extsep�link�errno�EEXIST�rename)�srcpath�dstpath�dstdname�dstbnameZ hardlinked�attempt�_dsttmp�er r r r > s$ Tc C s8 t | |td�rdS tjj|�}tjj|�}tjj|�}t| d�}tj |tjj |dd�}tj | �}|r�ytj |�}W n tk r� Y nX tj |j � t j|j�� d} xP| dkr�|jt�} y|j| � W q� |j� |j� tj|j� � Y q�X q�W |j� |j� tj|j|� |�r4tj� dk�r4tj|� dS )z�Copy srcpath to dstpath. Abort operation if e.g. not enough space is available. Attempt to atomically replace dstpath if it exists.)r N�rbF)r r �delete� r )r r r r r r r �openr ZNamedTemporaryFiler r �fchmod�fileno�S_IMODE�st_mode�read� BLOCKSIZE�write�close�unlink�namer$ �selinux�is_selinux_enabled� restorecon) r% r& �copy_mode_from_dst�run_restoreconr' r( ZsrcfileZ dsttmpfile�s�datar 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 kr�d}n� W Y dd} ~ X nX |s�t j | |� |r�tj |� n�d} xtt tj�D ]f} tj|t j |d�} yt j | | � W n6 tk �r" } z| j t jk�rwĂ W Y dd} ~ X q�X | } P q�W | dk�rDtt jd��|�r^| �r^tj| |� yt j| |� W n t j| � � Y nX |�r�tj |� 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" �ENOENT�symlinkr< r r r r r r# �IOErrorZ lsetfileconr$ �remove) r% r& �force�preserve_contextr' r( r> �ctx�retr+ 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}z�tj |t jj |d�\}} | r�t j | �} |r�t j || j | j� |r�t j|t j| j�� |r�tj| �\} } | dk r�td| ��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 )z�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.Nr F)r r zgetfilecon(%r) failed�w) r r �realpathr r �existsr: r; r Zmkstempr r �fchown�st_uid�st_gidr0 r2 r3 Z getfileconrA �fdopenr6 r7 r$ Z setfileconr< �isfiler8 )r ZcontentZ preserve_moderG Zpreserve_ownershipZdir_�base�fd�fZtmpnamerM 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 �<module> s& ! 5 ? __pycache__/files.cpython-36.opt-1.pyc 0000644 00000011525 15154265003 0013450 0 ustar 00 3 �uAc� � @ s� d Z ddlmZ dee�kr eZdddddgZdd lZdd l Z dd l Z dd l Z dd l Z d Z d d � Zg fd d�Zdd� Zddd�Zddd�Zddd�Zddd�Zd S )z=This module contains helper functions for dealing with files.� )�absolute_import�xrange� issamefile�linkfile�copyfile�linkorcopyfile�overwrite_safelyNi c C s" t j| �}t j|�}t jj||�S )N)�os�stat�path�samestat)�path1�path2�s1�s2� 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 | |td�rdS tjj|�}tjj|�}tjj|�}d}xpttj �D ]b}tj |tj |d�}ytj | |� W n2 tk r� } z|j t jkr�n� W Y dd}~X qFX d}P qFW |r�tj||� dS )zUHardlink srcpath to dstpath. Attempt to atomically replace dstpath if it exists.)r NF)�prefix�dirT)r �OSErrorr r �abspath�dirname�basename�range�tempfile�TMP_MAX�mktemp�extsep�link�errno�EEXIST�rename)�srcpath�dstpath�dstdname�dstbnameZ hardlinked�attempt�_dsttmp�er r r r > s$ Tc C s8 t | |td�rdS tjj|�}tjj|�}tjj|�}t| d�}tj |tjj |dd�}tj | �}|r�ytj |�}W n tk r� Y nX tj |j � t j|j�� d} xP| dkr�|jt�} y|j| � W q� |j� |j� tj|j� � Y q�X q�W |j� |j� tj|j|� |�r4tj� dk�r4tj|� dS )z�Copy srcpath to dstpath. Abort operation if e.g. not enough space is available. Attempt to atomically replace dstpath if it exists.)r N�rbF)r r �delete� r )r r r r r r r �openr ZNamedTemporaryFiler r �fchmod�fileno�S_IMODE�st_mode�read� BLOCKSIZE�write�close�unlink�namer$ �selinux�is_selinux_enabled� restorecon) r% r& �copy_mode_from_dst�run_restoreconr' r( ZsrcfileZ dsttmpfile�s�datar 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 kr�d}n� W Y dd} ~ X nX |s�t j | |� |r�tj |� n�d} xtt tj�D ]f} tj|t j |d�} yt j | | � W n6 tk �r" } z| j t jk�rwĂ W Y dd} ~ X q�X | } P q�W | dk�rDtt jd��|�r^| �r^tj| |� yt j| |� W n t j| � � Y nX |�r�tj |� 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" �ENOENT�symlinkr< r r r r r r# �IOErrorZ lsetfileconr$ �remove) r% r& �force�preserve_contextr' r( r> �ctx�retr+ 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}z�tj |t jj |d�\}} | r�t j | �} |r�t j || j | j� |r�t j|t j| j�� |r�tj| �\} } | dk r�td| ��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 )z�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.Nr F)r r zgetfilecon(%r) failed�w) r r �realpathr r �existsr: r; r Zmkstempr r �fchown�st_uid�st_gidr0 r2 r3 Z getfileconrA �fdopenr6 r7 r$ Z setfileconr< �isfiler8 )r ZcontentZ preserve_moderG Zpreserve_ownershipZdir_�base�fd�fZtmpnamerM 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 �<module> s& ! 5 ? __pycache__/__init__.cpython-36.pyc 0000644 00000000345 15154265003 0013144 0 ustar 00 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�<module> s __pycache__/__init__.cpython-36.opt-1.pyc 0000644 00000000345 15154265004 0014104 0 ustar 00 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�<module> s hookable.py 0000644 00000014136 15154265004 0006711 0 ustar 00 # -*- 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 <http://www.gnu.org/licenses/>. # # Authors: # Nils Philippsen <nils@redhat.com> """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 files.py 0000644 00000017257 15154265004 0006236 0 ustar 00 # -*- 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 <http://www.gnu.org/licenses/>. # # Authors: # Nils Philippsen <nils@redhat.com> """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