grthtrhthjhtyjytjytkergtrhtrjytjerhrfh4:24 29/09/2026a cei=B@sdZddlZddlZddlZddlZddlZddlmZmZm Z m Z m Z m Z e dZ dZdZgdZGdd d eZGd d d eZGd d d eZGdddeZGdddeZGdddeZdae edddZdejedddZdS)aILibvirt event loop implementation using asyncio Register the implementation of default loop: import asyncio import libvirtaio async def myapp(): libvirtaio.virEventRegisterAsyncIOImpl() conn = libvirt.open("test:///default") For compatibility with Python < 3.7: loop = asyncio.new_event_loop() asyncio.set_event_loop(loop) loop.run_until_complete(myapp()) asyncio.set_event_loop(None) loop.close() If Python >= 3.7 can be required then asyncio.run(myapp()) .. seealso:: https://libvirt.org/html/libvirt-libvirt-event.html N)AnyCallableDict GeneratorOptionalTypeVar_Tz,Wojtek Porczyk z LGPL-2.1+)getCurrentImplvirEventAsyncIOImplvirEventRegisterAsyncIOImplcs`eZdZdZeZdeee gdfe e e ddfdd Z e ddd Z ddd d ZZS) CallbackzBase 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)implcbopaqueargskwargsreturncs4tj|i|t|j|_||_||_||_dSN)super__init__next _iden_counteridenr rr)selfr rrrr __class__0/usr/lib64/python3.9/site-packages/libvirtaio.pyrPs  zCallback.__init__rcCsd|jj|jS)Nz <{} iden={}>)formatr__name__rrrrr__repr__WszCallback.__repr__cCs(|jjd|j|j|j|jdS)zSchedule *ff* callbackz"callback %d close(), scheduling ffN)r logdebugrschedule_ff_callbackrr!rrrcloseZszCallback.close)r __module__ __qualname____doc__ itertoolscountrrintrrrstrr"r& __classcell__rrrrr Es (r c@s`eZdZdZdeddddZedddd Zdd d d Zd ddddZeddddZ dS) DescriptorzManager of one file descriptor :param virEventAsyncIOImpl impl: the implementation in which we run :param int fd: the file descriptor r N)r fdrcCs||_||_i|_dSr)r r0 callbacks)rr r0rrrrjszDescriptor.__init__eventrcCsBt|jD].}|jdur|j|@r||j|j||jqdS)zDispatch the event to the descriptors :param int event: The event (from libvirt's constants) being dispatched N)listr1valuesr3rrr0r)rr3callbackrrr_handleoszDescriptor._handlercCstdd|jDr$tdttdd|jDrV|jj|j |j t j n|jj |j tdd|jDr|jj|j |j t jn|jj|j dS)zRegister or unregister callbacks at event loop This should be called after change of any ``.event`` in callbacks. css"|]}|jtjtjB@VqdSr)r3libvirtVIR_EVENT_HANDLE_READABLEVIR_EVENT_HANDLE_WRITABLE.0r6rrr s z$Descriptor.update..zTThe only event supported are VIR_EVENT_HANDLE_READABLE and VIR_EVENT_HANDLE_WRITABLEcss|]}|jtj@VqdSr)r3r8r9r;rrrr=scss|]}|jtj@VqdSr)r3r8r:r;rrrr=sN)anyr1r5warningswarn UserWarningr loopZ add_readerr0r7r8r9Z remove_readerZ add_writerr:Z remove_writerr!rrrupdatexs*   zDescriptor.update FDCallback)r6rcCs||j|j<|dS)zAdd a callback to the descriptor :param FDCallback callback: the callback to add :rtype: None After adding the callback, it is immediately watched. N)r1rrC)rr6rrr add_handles zDescriptor.add_handle)rrcCs|j|}||S)aRemove 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. )r1poprC)rrr6rrr remove_handles zDescriptor.remove_handle) r r'r(r)r,rr7rCrErGrrrrr/ds  " r/cs8eZdZdZdddfdd Zeeddd ZZS) DescriptorDictzdDescriptors collection This is used internally by virEventAsyncIOImpl to hold descriptors. r N)r rcst||_dSr)rrr )rr rrrrs zDescriptorDict.__init__)r0rcCst|j|}|||<|Sr)r/r )rr0 descriptorrrr __missing__s zDescriptorDict.__missing__) r r'r(r)rr,r/rJr.rrrrrHsrHcsLeZdZdZeeeeddfdd ZedddZ edd d d Z Z S) rDzCallback for file descriptor (watcher) :param Descriptor descriptor: the descriptor manager :param int event: bitset of events on which to fire the callback N)rrIr3rrcs"tj|i|||_||_dSr)rrrIr3)rrIr3rrrrrrszFDCallback.__init__rcCsd|jj|j|jj|jS)Nz<{} iden={} fd={} event={}>)rrr rrIr0r3r!rrrr"szFDCallback.__repr__r2cCs||_|jdS)z1Update the callback and fix descriptor's watchersN)r3rIrC)rr3rrrrCszFDCallback.update) r r'r(r)rr/r,rr-r"rCr.rrrrrDsrDcsreZdZdZeeddfdd ZedddZeeddfdd d Z e dd d d Z ddfdd Z Z S)TimeoutCallbackzCallback for timerN)rrrcs"tj|i|d|_d|_dS)N)rrtimeout_task)rrrrrrrszTimeoutCallback.__init__rcCsd|jj|j|jS)Nz<{} iden={} timeout={}>)rrr rrMr!rrrr"szTimeoutCallback.__repr__cszJ|jdkr8|jd}|jjd|t|IdHntdIdHWn*tjyt|jjd|jYqYn0||j|j |jjd|jqdS)zQAn actual timer running on the event loop. This is a coroutine. rgMbP?z sleeping %rNztimer %d cancelledztimer %r callback ended) rMr r#r$asynciosleepZCancelledErrorrrrrrMrrr_timers   zTimeoutCallback._timer)rMrcCs||_|jdkrF|jdurF|jjd|jtj||jj d|_n6|jdkr||jdur||jjd|j|j d|_dS)z-Start or the timer, possibly updating timeoutrNztimer %r startrBz timer %r stop) rMrNr r#r$rrO ensure_futurerRrBcancelrQrrrrCs   zTimeoutCallback.updatecs|jddtt|dS)z#Stop the timer and call ff callbackrLrMN)rCrrKr&r!rrrr& s zTimeoutCallback.close)r r'r(r)rrr-r"rrRr,rCr&r.rrrrrKs rKc@seZdZdZd*ejddddZedddZddd d Z ddd d Z ddd dZ e e ddddZe e ddddZddddZedddZe e eje e dddZe e ddddZe e ddd Ze eje e d!d"d#Ze e dd$d%d&Ze e d'd(d)ZdS)+r zLibvirt event adapter to asyncio. :param loop: asyncio's event loop If *loop* is not specified, the current (or default) event loop is used. NrBrcCs>|p t|_i|_t||_t|jj |_ d|_ d|_ dS)Nr) rOZget_event_looprBr1rH descriptorsloggingZ getLoggerrr r#_pending _finished)rrBrrrrs  zvirEventAsyncIOImpl.__init__rcCsdt|j|j|jS)Nz <{} callbacks={} descriptors={}>)rtyper r1rXr!rrrr"+szvirEventAsyncIOImpl.__repr__cCs&|jd7_|jdur"|jdS)z;Increase the count of pending affairs. Do not use directly.N)rZr[clearr!rrr _pending_inc/s z virEventAsyncIOImpl._pending_inccCs0|jd8_|jdkr,|jdur,|jdS)z;Decrease the count of pending affairs. Do not use directly.r]rN)rZr[setr!rrr _pending_dec5sz virEventAsyncIOImpl._pending_deccCs0|jdt|j|j|j|j|j|j |S)z3Register this instance as event loop implementationz register()) r#r$r8ZvirEventRegisterImpl _add_handle_update_handle_remove_handle _add_timeout_update_timeout_remove_timeoutr!rrrregister<s    zvirEventAsyncIOImpl.register)rrrcCstj||||jddS)z8Schedule a ff callback from one of the handles or timersrSN)rOrT _ff_callbackrBrrrrrrr%Esz(virEventAsyncIOImpl.schedule_ff_callbackcs$|jd|t||dS)zFDirectly free the opaque object This is a coroutine. z ff_callback(iden=%d, opaque=...)N)r#r$r8ZvirEventInvokeFreeCallbackrarjrrrriIs z virEventAsyncIOImpl._ff_callbackcsB|jd|jr2t|_|jIdHd|_|jddS)zRWait for the implementation to become idle. This is a coroutine. zdrain()Nz drain ended)r#r$rZrOEventr[waitr!rrrdrainRs   zvirEventAsyncIOImpl.draincCs|j o|j S)zReturns 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(). )r1rZr!rrris_idle`szvirEventAsyncIOImpl.is_idle)r0r3rrrcCsVt||||j||d}|jd|||j||j|j<|j||||jS)aRegister 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 )rIr3z4add_handle(fd=%d, event=%d, cb=..., opaque=...) = %d)rDrXr#r$rr1rEr_)rr0r3rrr6rrrrbhs   zvirEventAsyncIOImpl._add_handle)watchr3rcCs*|jd|||j|}|j|ddS)aChange 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))r3Nr#r$r1rC)rror3r6rrrrcs  z"virEventAsyncIOImpl._update_handle)rorc Cs|jd|z|j|}Wn:tyX}z"|jd|jdWYd}~dSd}~00|jj}t |j |jdkr~|j |=| dS)aUnregister 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: %rrNrL) r#r$r1rFKeyErrorwarningrrIr0lenrXr&)rror6errr0rrrrds z"virEventAsyncIOImpl._remove_handle)rMrrrcCsDt|||}|jd||j||j|j<|j|d||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=...) = %drV)rKr#r$rr1rCr_)rrMrrr6rrrres   z virEventAsyncIOImpl._add_timeout)timerrMrcCs*|jd|||j|}|j|ddS)zChange 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)rVNrp)rrurMr6rrrrfs  z#virEventAsyncIOImpl._update_timeout)rurc Csf|jd|z|j|}Wn:tyX}z"|jd|jdWYd}~dSd}~00|dS)zUnregister 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: %rrNrL)r#r$r1rFrqrrrr&)rrur6rtrrrrgs z#virEventAsyncIOImpl._remove_timeout)N)r r'r(r)rOAbstractEventLooprr-r"r_rarhr,rr%rirmboolrnr8Z_EventCBrbrcrdZ_TimerCBrerfrgrrrrr s    r rcCstS)z@Return the current implementation, or None if not yet registered) _current_implrrrrr sr rWcCst|datS)zArrange 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. rS)r rhrxrSrrrr sr )N)r)rOr*rYr?r8typingrrrrrrr __author__Z __license____all__objectr r/dictrHrDrKr rxr rvr rrrrs( P9F