| Server IP : 184.154.167.98 / Your IP : 3.135.219.165 Web Server : Apache System : Linux pink.dnsnetservice.com 4.18.0-553.22.1.lve.1.el8.x86_64 #1 SMP Tue Oct 8 15:52:54 UTC 2024 x86_64 User : puertode ( 1767) PHP Version : 8.2.26 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON Directory : /lib64/python3.6/site-packages/__pycache__/ |
Upload File : |
3
�rkc^A � @ s d Z ddlZddlZddlZddlZddlZddlmZmZm Z m
Z
m Z m Z e d�Z
dZdZddd gZeed
d�Zes�eed �ZG d d
� d
e�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de�Zdae e d�dd�Z dej ed�dd �Z dS ) z�Libvirt event loop implementation using asyncio
Register the implementation of default loop:
>>> import libvirtaio
>>> libvirtaio.virEventRegisterAsyncIOImpl()
.. seealso::
https://libvirt.org/html/libvirt-libvirt-event.html
� N)�Any�Callable�Dict� Generator�Optional�TypeVar�_Tz,Wojtek Porczyk <woju@invisiblethingslab.com>z LGPL-2.1+�getCurrentImpl�virEventAsyncIOImpl�virEventRegisterAsyncIOImpl�
ensure_future�asyncc s` e Zd ZdZej� Zdeee gdf e e
e
dd�� fdd� Z e d�dd �Z
dd�d
d �Z� ZS ) �Callbackz�Base class for holding callback
:param virEventAsyncIOImpl impl: the implementation in which we run
:param cb: the callback itself
:param opaque: the opaque tuple passed by libvirt
r
N)�impl�cb�opaque�args�kwargs�returnc s0 t � j||� t| j�| _|| _|| _|| _d S )N)�super�__init__�next�
_iden_counter�idenr r r )�selfr r r r r )� __class__� �"/usr/lib64/python3.6/libvirtaio.pyr E s
zCallback.__init__)r c C s dj | jj| j�S )Nz <{} iden={}>)�formatr �__name__r )r r r r �__repr__L s zCallback.__repr__c C s( | j jjd| j� | j j| j| j� dS )zSchedule *ff* callbackz"callback %d close(), scheduling ffN)r �log�debugr �schedule_ff_callbackr )r r r r �closeO s zCallback.close)r �
__module__� __qualname__�__doc__� itertools�countr r �intr r r �strr r$ �
__classcell__r r )r r r : s
(r c @ s` e Zd ZdZdedd�dd�Zedd�dd �Zdd
�d d �Zd
dd�dd�Zedd�dd�Z dS )�
Descriptorz�Manager of one file descriptor
:param virEventAsyncIOImpl impl: the implementation in which we run
:param int fd: the file descriptor
r
N)r �fdr c C s || _ || _i | _d S )N)r r. � callbacks)r r r. r r r r _ s zDescriptor.__init__)�eventr c C sF x@t | jj� �D ].}|jdk r|j|@ r|j|j| j||j� qW dS )zDispatch the event to the descriptors
:param int event: The event (from libvirt's constants) being dispatched
N)�listr/ �valuesr0 r r r. r )r r0 �callbackr r r �_handled s zDescriptor._handle)r c C s� t dd� | jj� D ��r$tjdt� t dd� | jj� D ��rV| jjj| j | j
t j � n| jjj
| j � t dd� | jj� D ��r�| jjj| j | j
t j� n| jjj| j � dS )z�Register or unregister callbacks at event loop
This should be called after change of any ``.event`` in callbacks.
c s s" | ]}|j tjtjB @ V qd S )N)r0 �libvirt�VIR_EVENT_HANDLE_READABLE�VIR_EVENT_HANDLE_WRITABLE)�.0r3 r r r � <genexpr>x s z$Descriptor.update.<locals>.<genexpr>zTThe only event supported are VIR_EVENT_HANDLE_READABLE and VIR_EVENT_HANDLE_WRITABLEc s s | ]}|j tj@ V qd S )N)r0 r5 r6 )r8 r3 r r r r9 � s c s s | ]}|j tj@ V qd S )N)r0 r5 r7 )r8 r3 r r r r9 � s N)�anyr/ r2 �warnings�warn� UserWarningr �loopZ
add_readerr. r4 r5 r6 Z
remove_readerZ
add_writerr7 Z
remove_writer)r r r r �updatem s zDescriptor.update�
FDCallback)r3 r c C s || j |j< | j� dS )z�Add a callback to the descriptor
:param FDCallback callback: the callback to add
:rtype: None
After adding the callback, it is immediately watched.
N)r/ r r? )r r3 r r r �
add_handle� s zDescriptor.add_handle)r r c C s | j j|�}| j� |S )a Remove a callback from the descriptor
:param int iden: the identifier of the callback
:returns: the callback
:rtype: FDCallback
After removing the callback, the descriptor may be unwatched, if there
are no more handles for it.
)r/ �popr? )r r r3 r r r �
remove_handle� s
zDescriptor.remove_handle)
r r% r& r' r* r r4 r? rA rC r r r r r- Y s " r- c s8 e Zd ZdZddd�� fdd� Zeed�dd �Z� ZS )
�DescriptorDictzdDescriptors collection
This is used internally by virEventAsyncIOImpl to hold descriptors.
r
N)r r c s t � j� || _d S )N)r r r )r r )r r r r � s
zDescriptorDict.__init__)r. r c C s t | j|�}|| |< |S )N)r- r )r r. �
descriptorr r r � __missing__� s zDescriptorDict.__missing__) r r% r& r' r r* r- rF r, r r )r r rD � s rD c sL e Zd ZdZeeeedd�� fdd� Zed�dd�Z edd �d
d �Z
� Z S ) r@ z�Callback for file descriptor (watcher)
:param Descriptor descriptor: the descriptor manager
:param int event: bitset of events on which to fire the callback
N)r rE r0 r r c s t � j||� || _|| _d S )N)r r rE r0 )r rE r0 r r )r r r r � s zFDCallback.__init__)r c C s dj | jj| j| jj| j�S )Nz<{} iden={} fd={} event={}>)r r r r rE r. r0 )r r r r r � s zFDCallback.__repr__)r0 r c C s || _ | jj� dS )z1Update the callback and fix descriptor's watchersN)r0 rE r? )r r0 r r r r? � s zFDCallback.update) r r% r& r' r r- r* r r+ r r? r, r r )r r r@ � s r@ c sx e Zd ZdZeedd�� fdd� Zed�dd�Zej e
eddf d�d d
��Z e dd �d d
�Z
dd�� fdd� Z� ZS )�TimeoutCallbackzCallback for timerN)r r r c s t � j||� d| _d | _d S )N� ���)r r �timeout�_task)r r r )r r r r � s zTimeoutCallback.__init__)r c C s dj | jj| j| j�S )Nz<{} iden={} timeout={}>)r r r r rJ )r r r r r � s zTimeoutCallback.__repr__c c s� x�y@| j dkr:| j d }| jjjd|� tj|�E dH ndV W n* tjk
rl | jjjd| j� P Y nX | j| j| j � | jjjd| j� qW dS )zQAn actual timer running on the event loop.
This is a coroutine.
r g����MbP?z sleeping %rNztimer %d cancelledztimer %r callback ended)
rJ r r! r" �asyncioZsleepZCancelledErrorr r r )r rJ r r r �_timer� s
zTimeoutCallback._timer)rJ r c C s~ || _ | j dkrD| jdkrD| jjjd| j� t| j� | jjd�| _n6| j dk rz| jdk rz| jjjd| j� | jj � d| _dS )z-Start or the timer, possibly updating timeoutr Nztimer %r start)r> z
timer %r stop)
rJ rK r r! r" r r rM r> Zcancel)r rJ r r r r? � s
zTimeoutCallback.updatec s | j dd� tt| �j� dS )z#Stop the timer and call ff callbackrH )rJ NrI )r? r rG r$ )r )r r r r$ s zTimeoutCallback.close)r r% r& r' r r r+ r rL � coroutiner rM r* r? r$ r, r r )r r rG � s rG c @ s$ e Zd ZdZd*ejdd�dd�Zed�dd�Zdd�d d
�Z dd�d d �Z
d d�d
d�Z e e
dd�dd�Zeje e
dd�dd��Zejeeddf d�dd��Zed�dd�Ze e eje
e d�dd�Ze e dd�d d �Ze e d �d d �Ze eje
e d!�d"d#�Z e e dd$�d%d&�Z e e d'�d(d)�Z dS )+r
z�Libvirt event adapter to asyncio.
:param loop: asyncio's event loop
If *loop* is not specified, the current (or default) event loop is used.
N)r> r c C sP |p
t j� | _i | _t| �| _tj| jj �| _
d| _ t j |d�| _
| j
j� d S )Nr )r> )rL Zget_event_loopr> r/ rD � descriptors�loggingZ getLoggerr r r! �_pendingZEvent� _finished�set)r r> r r r r s
z virEventAsyncIOImpl.__init__)r c C s dj t| �j| j| j�S )Nz <{} callbacks={} descriptors={}>)r �typer r/ rO )r r r r r s z virEventAsyncIOImpl.__repr__c C s | j d7 _ | jj� dS )z;Increase the count of pending affairs. Do not use directly.rH N)rQ rR �clear)r r r r � _pending_inc$ s z virEventAsyncIOImpl._pending_incc C s4 | j dkst�| j d8 _ | j dkr0| jj� dS )z;Decrease the count of pending affairs. Do not use directly.r rH N)rQ �AssertionErrorrR rS )r r r r � _pending_dec) s
z virEventAsyncIOImpl._pending_decc C s0 | j jd� tj| j| j| j| j| j| j � | S )z3Register this instance as event loop implementationz
register())
r! r" r5 ZvirEventRegisterImpl� _add_handle�_update_handle�_remove_handle� _add_timeout�_update_timeout�_remove_timeout)r r r r �register0 s
z virEventAsyncIOImpl.register)r r r c C s t | j||�| jd� dS )z8Schedule a ff callback from one of the handles or timers)r> N)r � _ff_callbackr> )r r r r r r r# 9 s z(virEventAsyncIOImpl.schedule_ff_callbackc C s$ | j jd|� tj|� | j� dS )zFDirectly free the opaque object
This is a coroutine.
z ff_callback(iden=%d, opaque=...)N)r! r" r5 ZvirEventInvokeFreeCallbackrX )r r r r r r r` = s
z virEventAsyncIOImpl._ff_callbackc c s2 | j jd� | jr"| jj� E dH | j jd� dS )zRWait for the implementation to become idle.
This is a coroutine.
zdrain()Nz drain ended)r! r" rQ rR �wait)r r r r �drainG s zvirEventAsyncIOImpl.drainc C s | j o| j S )z�Returns False if there are leftovers from a connection
Those may happen if there are sematical problems while closing
a connection. For example, not deregistered events before .close().
)r/ rQ )r r r r �is_idleR s zvirEventAsyncIOImpl.is_idle)r. r0 r r r c C sf t | ||| j| |d�}|j| jks(t�| jjd|||j� || j|j< | j| j|� | j� |jS )a Register a callback for monitoring file handle events
:param int fd: file descriptor to listen on
:param int event: bitset of events on which to fire the callback
:param cb: the callback to be called when an event occurrs
:param opaque: user data to pass to the callback
:rtype: int
:returns: handle watch number to be used for updating and unregistering for events
.. seealso::
https://libvirt.org/html/libvirt-libvirt-event.html#virEventAddHandleFuncFunc
)rE r0 z4add_handle(fd=%d, event=%d, cb=..., opaque=...) = %d) r@ rO r r/ rW r! r" rA rV )r r. r0 r r r3 r r r rY Z s
z virEventAsyncIOImpl._add_handle)�watchr0 r c C s8 | j jd||� | j| }t|t�s(t�|j|d� dS )a Change event set for a monitored file handle
:param int watch: file descriptor watch to modify
:param int event: new events to listen on
.. seealso::
https://libvirt.org/html/libvirt-libvirt-event.html#virEventUpdateHandleFunc
z!update_handle(watch=%d, event=%d))r0 N)r! r" r/ �
isinstancer@ rW r? )r rd r0 r3 r r r rZ r s
z"virEventAsyncIOImpl._update_handle)rd r c C s� | j jd|� y| jj|�}W n4 tk
rR } z| j jd|jd � dS d}~X nX t|t�sbt �|j
j }|| j | j
|�ks�t �t| j | j�dkr�| j |= |j� dS )a Unregister a callback from a file handle.
:param int watch: file descriptor watch to stop listening on
:returns: -1 on error, 0 on success
.. seealso::
https://libvirt.org/html/libvirt-libvirt-event.html#virEventRemoveHandleFunc
zremove_handle(watch=%d)z#remove_handle(): no such handle: %rr rH NrI )r! r" r/ rB �KeyError�warningr re r@ rW rE r. rO rC �lenr$ )r rd r3 �errr. r r r r[ � s z"virEventAsyncIOImpl._remove_handle)rJ r r r c C sT t | ||�}|j| jks t�| jjd||j� || j|j< |j|d� | j� |jS )a} Register a callback for a timer event
:param int timeout: the timeout to monitor
:param cb: the callback to call when timeout has expired
:param opaque: user data to pass to the callback
:rtype: int
:returns: a timer value
.. seealso::
https://libvirt.org/html/libvirt-libvirt-event.html#virEventAddTimeoutFunc
z0add_timeout(timeout=%d, cb=..., opaque=...) = %d)rJ )rG r r/ rW r! r" r? rV )r rJ r r r3 r r r r\ � s
z virEventAsyncIOImpl._add_timeout)�timerrJ r c C s8 | j jd||� | j| }t|t�s(t�|j|d� dS )z�Change frequency for a timer
:param int timer: the timer to modify
:param int timeout: the new timeout value in ms
.. seealso::
https://libvirt.org/html/libvirt-libvirt-event.html#virEventUpdateTimeoutFunc
z$update_timeout(timer=%d, timeout=%d))rJ N)r! r" r/ re rG rW r? )r rj rJ r3 r r r r] � s
z#virEventAsyncIOImpl._update_timeout)rj r c C s` | j jd|� y| jj|�}W n4 tk
rR } z| j jd|jd � dS d}~X nX |j� dS )z�Unregister a callback for a timer
:param int timer: the timer to remove
:returns: -1 on error, 0 on success
.. seealso::
https://libvirt.org/html/libvirt-libvirt-event.html#virEventRemoveTimeoutFunc
zremove_timeout(timer=%d)z%remove_timeout(): no such timeout: %rr rH NrI )r! r" r/ rB rf rg r r$ )r rj r3 ri r r r r^ � s z#virEventAsyncIOImpl._remove_timeout)N) r r% r& r' rL �AbstractEventLoopr r+ r rV rX r_ r* r r# rN r` r r rb �boolrc r5 Z_EventCBrY rZ r[ Z_TimerCBr\ r] r^ r r r r r
s$
)r c C s t S )z@Return the current implementation, or None if not yet registered)�
_current_implr r r r r � s )r> r c C s t | d�j� atS )z�Arrange for libvirt's callbacks to be dispatched via asyncio event loop
The implementation object is returned, but in normal usage it can safely be
discarded.
)r> )r
r_ rm )r> r r r r � s )N) r' rL r( rP r; r5 Ztypingr r r r r r r �
__author__Z __license__�__all__�getattrr �objectr r- �dictrD r@ rG r
rm r rk r r r r r �<module> s2
P: B