?????????? ????????? - ??????????????? - /home/agenciai/public_html/cd38d8/_os.tar
???????
__pycache__/pipe.cpython-39.opt-1.pyc 0000644 00000007764 15126121567 0013325 0 ustar 00 a 8g+^� � @ s� d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlZddlZddlm Z ddl m Z dd l m Z dd l m Z dd lmZ eed d �Zdd� Zdd� Zdd� Ze� Zdd� Zdd� ZG dd� de�ZdS )a# pyudev._os.pipe =============== Fallback implementations for pipe. 1. pipe2 from python os module 2. pipe2 from libc 3. pipe from python os module The Pipe class wraps the chosen implementation. .. moduleauthor:: Sebastian Wiesner <lunaryorn@gmail.com> � )�absolute_import)�division)�print_function)�unicode_literalsN)�partial)�ERROR_CHECKERS)�FD_PAIR)� SIGNATURES)�load_ctypes_library� O_CLOEXECi c C s" t � }| �||� |d |d fS )z�A ``pipe2`` implementation using ``pipe2`` from ctypes. ``libc`` is a :class:`ctypes.CDLL` object for libc. ``flags`` is an integer providing the flags to ``pipe2``. Return a pair of file descriptors ``(r, w)``. r � )r �pipe2)�libc�flags�fds� r �3/usr/lib/python3.9/site-packages/pyudev/_os/pipe.py� _pipe2_ctypes2 s r c C sP t �� }| t j@ dkr,|D ]}t|t j� q| t@ dkrL|D ]}t|t� q<|S )z�A ``pipe2`` implementation using :func:`os.pipe`. ``flags`` is an integer providing the flags to ``pipe2``. .. warning:: This implementation is not atomic! Return a pair of file descriptors ``(r, w)``. r )�os�pipe� O_NONBLOCK�set_fd_status_flagr � set_fd_flag)r r �fdr r r �_pipe2_by_pipe@ s r c C sR t td�rtjS z&tdtt�} t | d�r2tt| �ntW S t yL t Y S 0 dS )z]Find the appropriate implementation for ``pipe2``. Return a function implementing ``pipe2``.r r N) �hasattrr r r r r r r r � ImportError)r r r r �_get_pipe2_implementationV s � � r c C s( t � | t jd�}t � | t j||B � dS )zwSet a flag on a file descriptor. ``fd`` is the file descriptor or file object, ``flag`` the flag as integer. r N)�fcntlZF_GETFDZF_SETFD�r �flagr r r r r h s r c C s( t � | t jd�}t � | t j||B � dS )z~Set a status flag on a file descriptor. ``fd`` is the file descriptor or file object, ``flag`` the flag as integer. r N)r ZF_GETFLZF_SETFLr r r r r r s r c @ s, e Zd ZdZedd� �Zdd� Zdd� ZdS ) �Pipez�A unix pipe. A pipe object provides two file objects: :attr:`source` is a readable file object, and :attr:`sink` a writeable. Bytes written to :attr:`sink` appear at :attr:`source`. Open a pipe with :meth:`open()`. c C s t tjtB �\}}| ||�S )zLOpen and return a new :class:`Pipe`. The pipe uses non-blocking IO.)�_PIPE2r r r )�cls�source�sinkr r r �open� s z Pipe.openc C s$ t �|dd�| _t �|dd�| _dS )z�Create a new pipe object from the given file descriptors. ``source_fd`` is a file descriptor for the readable side of the pipe, ``sink_fd`` is a file descriptor for the writeable side.�rbr �wbN)r �fdopenr$ r% )�selfZ source_fdZsink_fdr r r �__init__� s z Pipe.__init__c C s* z| j �� W | j�� n | j�� 0 dS )z Closes both sides of the pipe.N)r$ �closer% )r* r r r r, � s z Pipe.closeN)�__name__� __module__� __qualname__�__doc__� classmethodr& r+ r, r r r r r! | s r! )r0 Z __future__r r r r r r � functoolsr Zpyudev._ctypeslib.libcr r r Zpyudev._ctypeslib.utilsr �getattrr r r r r" r r �objectr! r r r r �<module> s& __pycache__/poll.cpython-39.opt-1.pyc 0000644 00000006523 15126121567 0013326 0 ustar 00 a 8g+^ � @ s\ d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlZddlmZ G dd � d e �Z dS ) z� pyudev._os.poll =============== Operating system interface for pyudev. .. moduleauthor:: Sebastian Wiesner <lunaryorn@gmail.com> � )�absolute_import)�division)�print_function)�unicode_literalsN)�eintr_retry_callc @ sP e Zd ZdZejejd�Zedd� �Z e dd� �Z dd� Z dd d �Z d d � Zd S )�PollzwA poll object. This object essentially provides a more convenient interface around :class:`select.poll`. )�r�wc C s | |@ dkS )Nr � )�events�eventr r �3/usr/lib/python3.9/site-packages/pyudev/_os/poll.py� _has_event. s zPoll._has_eventc G sJ t tj�}|D ]2\}}| j�|�}|s4td�|���|�||� q| |�S )aG Listen for ``events``. ``events`` is a list of ``(fd, event)`` pairs, where ``fd`` is a file descriptor or file object and ``event`` either ``'r'`` or ``'w'``. If ``r``, listen for whether that is ready to be read. If ``w``, listen for whether the channel is ready to be written to. zUnknown event type: {0!r})r �select�poll�_EVENT_TO_MASK�get� ValueError�format�register)�clsr �notifier�fdr �maskr r r � for_events2 s zPoll.for_eventsc C s || _ dS )z�Create a poll object for the given ``notifier``. ``notifier`` is the :class:`select.poll` object wrapped by the new poll object. N)� _notifier)�selfr r r r �__init__D s z Poll.__init__Nc C s t | �t| jj|���S )a{ Poll for events. ``timeout`` is an integer specifying how long to wait for events (in milliseconds). If omitted, ``None`` or negative, wait until an event occurs. Return a list of all events that occurred before ``timeout``, where each event is a pair ``(fd, event)``. ``fd`` is the integral file descriptor, and ``event`` a string indicating the event type. If ``'r'``, there is data to read from ``fd``. If ``'w'``, ``fd`` is writable without blocking now. If ``'h'``, the file descriptor was hung up (i.e. the remote side of a pipe was closed). )�list� _parse_eventsr r r )r �timeoutr r r r M s �z Poll.pollc c s� |D ]�\}}| � |tj�r*td�|���n | � |tj�rFtd�|���| � |tj�r^|dfV | � |tj�rv|dfV | � |tj�r|dfV qdS )z�Parse ``events``. ``events`` is a list of events as returned by :meth:`select.poll.poll()`. Yield all parsed events. z File descriptor not open: {0!r}z Error while polling fd: {0!r}r r �hN) r r ZPOLLNVAL�IOErrorr ZPOLLERR�POLLIN�POLLOUTZPOLLHUP)r r r Z event_maskr r r r a s zPoll._parse_events)N)�__name__� __module__� __qualname__�__doc__r r# r$ r � staticmethodr � classmethodr r r r r r r r r $ s r ) r( Z __future__r r r r r Z pyudev._utilr �objectr r r r r �<module> s __pycache__/__init__.cpython-39.opt-1.pyc 0000644 00000000561 15126121567 0014113 0 ustar 00 a 8g+^� � @ s d Z ddlmZ ddlmZ dS )z� pyudev._os ========== Extras to compensate for deficiencies in python os module. .. moduleauthor:: mulhern <amulhern@redhat.com> � )�pipe)�pollN)�__doc__� r r � r r �7/usr/lib/python3.9/site-packages/pyudev/_os/__init__.py�<module> s __pycache__/pipe.cpython-39.pyc 0000644 00000007764 15126121567 0012366 0 ustar 00 a 8g+^� � @ s� d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlZddlZddlm Z ddl m Z dd l m Z dd l m Z dd lmZ eed d �Zdd� Zdd� Zdd� Ze� Zdd� Zdd� ZG dd� de�ZdS )a# pyudev._os.pipe =============== Fallback implementations for pipe. 1. pipe2 from python os module 2. pipe2 from libc 3. pipe from python os module The Pipe class wraps the chosen implementation. .. moduleauthor:: Sebastian Wiesner <lunaryorn@gmail.com> � )�absolute_import)�division)�print_function)�unicode_literalsN)�partial)�ERROR_CHECKERS)�FD_PAIR)� SIGNATURES)�load_ctypes_library� O_CLOEXECi c C s" t � }| �||� |d |d fS )z�A ``pipe2`` implementation using ``pipe2`` from ctypes. ``libc`` is a :class:`ctypes.CDLL` object for libc. ``flags`` is an integer providing the flags to ``pipe2``. Return a pair of file descriptors ``(r, w)``. r � )r �pipe2)�libc�flags�fds� r �3/usr/lib/python3.9/site-packages/pyudev/_os/pipe.py� _pipe2_ctypes2 s r c C sP t �� }| t j@ dkr,|D ]}t|t j� q| t@ dkrL|D ]}t|t� q<|S )z�A ``pipe2`` implementation using :func:`os.pipe`. ``flags`` is an integer providing the flags to ``pipe2``. .. warning:: This implementation is not atomic! Return a pair of file descriptors ``(r, w)``. r )�os�pipe� O_NONBLOCK�set_fd_status_flagr � set_fd_flag)r r �fdr r r �_pipe2_by_pipe@ s r c C sR t td�rtjS z&tdtt�} t | d�r2tt| �ntW S t yL t Y S 0 dS )z]Find the appropriate implementation for ``pipe2``. Return a function implementing ``pipe2``.r r N) �hasattrr r r r r r r r � ImportError)r r r r �_get_pipe2_implementationV s � � r c C s( t � | t jd�}t � | t j||B � dS )zwSet a flag on a file descriptor. ``fd`` is the file descriptor or file object, ``flag`` the flag as integer. r N)�fcntlZF_GETFDZF_SETFD�r �flagr r r r r h s r c C s( t � | t jd�}t � | t j||B � dS )z~Set a status flag on a file descriptor. ``fd`` is the file descriptor or file object, ``flag`` the flag as integer. r N)r ZF_GETFLZF_SETFLr r r r r r s r c @ s, e Zd ZdZedd� �Zdd� Zdd� ZdS ) �Pipez�A unix pipe. A pipe object provides two file objects: :attr:`source` is a readable file object, and :attr:`sink` a writeable. Bytes written to :attr:`sink` appear at :attr:`source`. Open a pipe with :meth:`open()`. c C s t tjtB �\}}| ||�S )zLOpen and return a new :class:`Pipe`. The pipe uses non-blocking IO.)�_PIPE2r r r )�cls�source�sinkr r r �open� s z Pipe.openc C s$ t �|dd�| _t �|dd�| _dS )z�Create a new pipe object from the given file descriptors. ``source_fd`` is a file descriptor for the readable side of the pipe, ``sink_fd`` is a file descriptor for the writeable side.�rbr �wbN)r �fdopenr$ r% )�selfZ source_fdZsink_fdr r r �__init__� s z Pipe.__init__c C s* z| j �� W | j�� n | j�� 0 dS )z Closes both sides of the pipe.N)r$ �closer% )r* r r r r, � s z Pipe.closeN)�__name__� __module__� __qualname__�__doc__� classmethodr& r+ r, r r r r r! | s r! )r0 Z __future__r r r r r r � functoolsr Zpyudev._ctypeslib.libcr r r Zpyudev._ctypeslib.utilsr �getattrr r r r r" r r �objectr! r r r r �<module> s& __pycache__/poll.cpython-39.pyc 0000644 00000006523 15126121567 0012367 0 ustar 00 a 8g+^ � @ s\ d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlZddlmZ G dd � d e �Z dS ) z� pyudev._os.poll =============== Operating system interface for pyudev. .. moduleauthor:: Sebastian Wiesner <lunaryorn@gmail.com> � )�absolute_import)�division)�print_function)�unicode_literalsN)�eintr_retry_callc @ sP e Zd ZdZejejd�Zedd� �Z e dd� �Z dd� Z dd d �Z d d � Zd S )�PollzwA poll object. This object essentially provides a more convenient interface around :class:`select.poll`. )�r�wc C s | |@ dkS )Nr � )�events�eventr r �3/usr/lib/python3.9/site-packages/pyudev/_os/poll.py� _has_event. s zPoll._has_eventc G sJ t tj�}|D ]2\}}| j�|�}|s4td�|���|�||� q| |�S )aG Listen for ``events``. ``events`` is a list of ``(fd, event)`` pairs, where ``fd`` is a file descriptor or file object and ``event`` either ``'r'`` or ``'w'``. If ``r``, listen for whether that is ready to be read. If ``w``, listen for whether the channel is ready to be written to. zUnknown event type: {0!r})r �select�poll�_EVENT_TO_MASK�get� ValueError�format�register)�clsr �notifier�fdr �maskr r r � for_events2 s zPoll.for_eventsc C s || _ dS )z�Create a poll object for the given ``notifier``. ``notifier`` is the :class:`select.poll` object wrapped by the new poll object. N)� _notifier)�selfr r r r �__init__D s z Poll.__init__Nc C s t | �t| jj|���S )a{ Poll for events. ``timeout`` is an integer specifying how long to wait for events (in milliseconds). If omitted, ``None`` or negative, wait until an event occurs. Return a list of all events that occurred before ``timeout``, where each event is a pair ``(fd, event)``. ``fd`` is the integral file descriptor, and ``event`` a string indicating the event type. If ``'r'``, there is data to read from ``fd``. If ``'w'``, ``fd`` is writable without blocking now. If ``'h'``, the file descriptor was hung up (i.e. the remote side of a pipe was closed). )�list� _parse_eventsr r r )r �timeoutr r r r M s �z Poll.pollc c s� |D ]�\}}| � |tj�r*td�|���n | � |tj�rFtd�|���| � |tj�r^|dfV | � |tj�rv|dfV | � |tj�r|dfV qdS )z�Parse ``events``. ``events`` is a list of events as returned by :meth:`select.poll.poll()`. Yield all parsed events. z File descriptor not open: {0!r}z Error while polling fd: {0!r}r r �hN) r r ZPOLLNVAL�IOErrorr ZPOLLERR�POLLIN�POLLOUTZPOLLHUP)r r r Z event_maskr r r r a s zPoll._parse_events)N)�__name__� __module__� __qualname__�__doc__r r# r$ r � staticmethodr � classmethodr r r r r r r r r $ s r ) r( Z __future__r r r r r Z pyudev._utilr �objectr r r r r �<module> s __pycache__/__init__.cpython-39.pyc 0000644 00000000561 15126121567 0013154 0 ustar 00 a 8g+^� � @ s d Z ddlmZ ddlmZ dS )z� pyudev._os ========== Extras to compensate for deficiencies in python os module. .. moduleauthor:: mulhern <amulhern@redhat.com> � )�pipe)�pollN)�__doc__� r r � r r �7/usr/lib/python3.9/site-packages/pyudev/_os/__init__.py�<module> s poll.py 0000644 00000010020 15126121567 0006063 0 ustar 00 # -*- coding: utf-8 -*- # Copyright (C) 2013 Sebastian Wiesner <lunaryorn@gmail.com> # This library is free software; you can redistribute it and/or modify it # under the terms of the GNU Lesser General Public License as published by the # Free Software Foundation; either version 2.1 of the License, or (at your # option) any later version. # This library 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 Lesser General Public License # for more details. # You should have received a copy of the GNU Lesser General Public License # along with this library; if not, write to the Free Software Foundation, # Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA """ pyudev._os.poll =============== Operating system interface for pyudev. .. moduleauthor:: Sebastian Wiesner <lunaryorn@gmail.com> """ from __future__ import absolute_import from __future__ import division from __future__ import print_function from __future__ import unicode_literals import select from pyudev._util import eintr_retry_call class Poll(object): """A poll object. This object essentially provides a more convenient interface around :class:`select.poll`. """ _EVENT_TO_MASK = {'r': select.POLLIN, 'w': select.POLLOUT} @staticmethod def _has_event(events, event): return events & event != 0 @classmethod def for_events(cls, *events): """Listen for ``events``. ``events`` is a list of ``(fd, event)`` pairs, where ``fd`` is a file descriptor or file object and ``event`` either ``'r'`` or ``'w'``. If ``r``, listen for whether that is ready to be read. If ``w``, listen for whether the channel is ready to be written to. """ notifier = eintr_retry_call(select.poll) for fd, event in events: mask = cls._EVENT_TO_MASK.get(event) if not mask: raise ValueError('Unknown event type: {0!r}'.format(event)) notifier.register(fd, mask) return cls(notifier) def __init__(self, notifier): """Create a poll object for the given ``notifier``. ``notifier`` is the :class:`select.poll` object wrapped by the new poll object. """ self._notifier = notifier def poll(self, timeout=None): """Poll for events. ``timeout`` is an integer specifying how long to wait for events (in milliseconds). If omitted, ``None`` or negative, wait until an event occurs. Return a list of all events that occurred before ``timeout``, where each event is a pair ``(fd, event)``. ``fd`` is the integral file descriptor, and ``event`` a string indicating the event type. If ``'r'``, there is data to read from ``fd``. If ``'w'``, ``fd`` is writable without blocking now. If ``'h'``, the file descriptor was hung up (i.e. the remote side of a pipe was closed). """ # Return a list to allow clients to determine whether there are any # events at all with a simple truthiness test. return list( self._parse_events(eintr_retry_call(self._notifier.poll, timeout))) def _parse_events(self, events): """Parse ``events``. ``events`` is a list of events as returned by :meth:`select.poll.poll()`. Yield all parsed events. """ for fd, event_mask in events: if self._has_event(event_mask, select.POLLNVAL): raise IOError('File descriptor not open: {0!r}'.format(fd)) elif self._has_event(event_mask, select.POLLERR): raise IOError('Error while polling fd: {0!r}'.format(fd)) if self._has_event(event_mask, select.POLLIN): yield fd, 'r' if self._has_event(event_mask, select.POLLOUT): yield fd, 'w' if self._has_event(event_mask, select.POLLHUP): yield fd, 'h' pipe.py 0000644 00000010656 15126121567 0006071 0 ustar 00 # -*- coding: utf-8 -*- # Copyright (C) 2013 Sebastian Wiesner <lunaryorn@gmail.com> # This library is free software; you can redistribute it and/or modify it # under the terms of the GNU Lesser General Public License as published by the # Free Software Foundation; either version 2.1 of the License, or (at your # option) any later version. # This library 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 Lesser General Public License # for more details. # You should have received a copy of the GNU Lesser General Public License # along with this library; if not, write to the Free Software Foundation, # Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA """ pyudev._os.pipe =============== Fallback implementations for pipe. 1. pipe2 from python os module 2. pipe2 from libc 3. pipe from python os module The Pipe class wraps the chosen implementation. .. moduleauthor:: Sebastian Wiesner <lunaryorn@gmail.com> """ from __future__ import absolute_import from __future__ import division from __future__ import print_function from __future__ import unicode_literals import os import fcntl from functools import partial from pyudev._ctypeslib.libc import ERROR_CHECKERS from pyudev._ctypeslib.libc import FD_PAIR from pyudev._ctypeslib.libc import SIGNATURES from pyudev._ctypeslib.utils import load_ctypes_library # Define O_CLOEXEC, if not present in os already O_CLOEXEC = getattr(os, 'O_CLOEXEC', 0o2000000) def _pipe2_ctypes(libc, flags): """A ``pipe2`` implementation using ``pipe2`` from ctypes. ``libc`` is a :class:`ctypes.CDLL` object for libc. ``flags`` is an integer providing the flags to ``pipe2``. Return a pair of file descriptors ``(r, w)``. """ fds = FD_PAIR() libc.pipe2(fds, flags) return fds[0], fds[1] def _pipe2_by_pipe(flags): """A ``pipe2`` implementation using :func:`os.pipe`. ``flags`` is an integer providing the flags to ``pipe2``. .. warning:: This implementation is not atomic! Return a pair of file descriptors ``(r, w)``. """ fds = os.pipe() if flags & os.O_NONBLOCK != 0: for fd in fds: set_fd_status_flag(fd, os.O_NONBLOCK) if flags & O_CLOEXEC != 0: for fd in fds: set_fd_flag(fd, O_CLOEXEC) return fds def _get_pipe2_implementation(): """Find the appropriate implementation for ``pipe2``. Return a function implementing ``pipe2``.""" if hasattr(os, 'pipe2'): return os.pipe2 # pylint: disable=no-member else: try: libc = load_ctypes_library("libc", SIGNATURES, ERROR_CHECKERS) return (partial(_pipe2_ctypes, libc) if hasattr(libc, 'pipe2') else _pipe2_by_pipe) except ImportError: return _pipe2_by_pipe _PIPE2 = _get_pipe2_implementation() def set_fd_flag(fd, flag): """Set a flag on a file descriptor. ``fd`` is the file descriptor or file object, ``flag`` the flag as integer. """ flags = fcntl.fcntl(fd, fcntl.F_GETFD, 0) fcntl.fcntl(fd, fcntl.F_SETFD, flags | flag) def set_fd_status_flag(fd, flag): """Set a status flag on a file descriptor. ``fd`` is the file descriptor or file object, ``flag`` the flag as integer. """ flags = fcntl.fcntl(fd, fcntl.F_GETFL, 0) fcntl.fcntl(fd, fcntl.F_SETFL, flags | flag) class Pipe(object): """A unix pipe. A pipe object provides two file objects: :attr:`source` is a readable file object, and :attr:`sink` a writeable. Bytes written to :attr:`sink` appear at :attr:`source`. Open a pipe with :meth:`open()`. """ @classmethod def open(cls): """Open and return a new :class:`Pipe`. The pipe uses non-blocking IO.""" source, sink = _PIPE2(os.O_NONBLOCK | O_CLOEXEC) return cls(source, sink) def __init__(self, source_fd, sink_fd): """Create a new pipe object from the given file descriptors. ``source_fd`` is a file descriptor for the readable side of the pipe, ``sink_fd`` is a file descriptor for the writeable side.""" self.source = os.fdopen(source_fd, 'rb', 0) self.sink = os.fdopen(sink_fd, 'wb', 0) def close(self): """Closes both sides of the pipe.""" try: self.source.close() finally: self.sink.close() __init__.py 0000644 00000001740 15126121567 0006665 0 ustar 00 # -*- coding: utf-8 -*- # Copyright (C) 2015 mulhern <amulhern@redhat.com> # This library is free software; you can redistribute it and/or modify it # under the terms of the GNU Lesser General Public License as published by the # Free Software Foundation; either version 2.1 of the License, or (at your # option) any later version. # This library 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 Lesser General Public License # for more details. # You should have received a copy of the GNU Lesser General Public License # along with this library; if not, write to the Free Software Foundation, # Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA """ pyudev._os ========== Extras to compensate for deficiencies in python os module. .. moduleauthor:: mulhern <amulhern@redhat.com> """ from . import pipe from . import poll
| ver. 1.6 |
Github
|
.
| PHP 8.2.30 | ??????????? ?????????: 0 |
proxy
|
phpinfo
|
???????????