Qh=B6SrSSKrSSKrSSKrSSKrSSKrSSKJrJrJ r J r J r J r \ "S5r SrSr/SQr"SS \5r"S S \5r"S S \5r"SS\5r"SS\5r"SS\5rSqS\ \4SjrSS\R6S\4Sjjrg)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+)getCurrentImplvirEventAsyncIOImplvirEventRegisterAsyncIOImplc ^\rSrSrSr\R "5rSSS\\ \ /S4S\ S\ S \ S S4 U4S jjr S \ 4S jrSS jrSrU=r$)CallbackEzBase 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 implr cbNopaqueargskwargsreturnc~>[TU]"U0UD6 [UR5UlXlX lX0lgN)super__init__next _iden_counteridenrrr)selfrrrrr __class__s ,/usr/lib/python3/dist-packages/libvirtaio.pyrCallback.__init__Ps6 $)&)++,   cbSRURRUR5$)Nz <{} iden={}>)formatr__name__rrs r__repr__Callback.__repr__Ws#$$T^^%<%r!)rrrrrN)r$ __module__ __qualname____firstlineno____doc__ itertoolscountrrintr rrstrr&r,__static_attributes__ __classcell__rs@rrrEssOO%M2#rD8Q[]fiux~BI#I??r!rcf\rSrSrSrSSS\SS4SjrS \SS4S jrSS jrSS jr S \SS4Sjr Sr g) DescriptordzManager of one file descriptor :param virEventAsyncIOImpl impl: the implementation in which we run :param int fd: the file descriptor rr fdrNc*XlX l0Ulgr)rr= callbacks)rrr=s rrDescriptor.__init__js r!eventc[URR55HYnURcMURU-(dM(UR UR UR XR5 M[ g)zoDispatch the event to the descriptors :param int event: The event (from libvirt's constants) being dispatched N)listr?valuesrArrr=r)rrAcallbacks r_handleDescriptor._handleosT T^^2245H~~)hnnu.D.D HMM477E??K6r!c8[SURR555(a[R"S[ 5 [SURR555(aJUR RRURUR[R5 O/UR RRUR5 [SURR555(aJUR RRURUR[R5 gUR RR!UR5 g)zsRegister or unregister callbacks at event loop This should be called after change of any ``.event`` in callbacks. c3# UH4nUR[R[R-)-v M6 g7fr)rAlibvirtVIR_EVENT_HANDLE_READABLEVIR_EVENT_HANDLE_WRITABLE.0rEs r $Descriptor.update..s@9!8H~~  - -  - - .!//!8s<>zTThe only event supported are VIR_EVENT_HANDLE_READABLE and VIR_EVENT_HANDLE_WRITABLEc3\# UH"nUR[R-v M$ g7fr)rArJrKrMs rrOrP&9 7H~~ A AA 7*,c3\# UH"nUR[R-v M$ g7fr)rArJrLrMs rrOrPrRrSN)anyr?rDwarningswarn UserWarningrloop add_readerr=rFrJrK remove_reader add_writerrL remove_writerr%s rupdateDescriptor.updatexs# 9!% 5 5 79 9 9 MM0  9 $ 5 5 79 9 9 IINN % %w'H'H J IINN ( ( 1 9 $ 5 5 79 9 9 IINN % %w'H'H J IINN ( ( 1r!cTXRUR'UR5 g)zAdd a callback to the descriptor :param FDCallback callback: the callback to add :rtype: None After adding the callback, it is immediately watched. N)r?rr^)rrEs r add_handleDescriptor.add_handles)1x}}% r!rc\URRU5nUR5 U$)zRemove 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^)rrrEs r remove_handleDescriptor.remove_handles&>>%%d+ r!)r?r=rr.)rE FDCallbackrN) r$r/r0r1r2r5rrFr^rarer7r!rr;r;dsV 2 LSLTL 2D  # $ r!r;cB^\rSrSrSrSU4SjjrS\S\4SjrSr U=r $) DescriptorDictz\Descriptors collection This is used internally by virEventAsyncIOImpl to hold descriptors. rc.>[TU]5 Xlgr)rrr)rrrs rrDescriptorDict.__init__s  r!r=c:[URU5nX U'U$r)r;r)rr= descriptors r __missing__DescriptorDict.__missing__s 2. Rr!)r)rr rN) r$r/r0r1r2rr5r;rpr7r8r9s@rrjrjs%cjr!rjc d^\rSrSrSrS\S\S\S\SS4 U4S jjrS\ 4S jr S\SS4S jr S r U=r $) rgzCallback for file descriptor (watcher) :param Descriptor descriptor: the descriptor manager :param int event: bitset of events on which to fire the callback rrorArrNc>>[TU]"U0UD6 XlX lgr)rrrorA)rrorArrrs rrFDCallback.__init__s $)&)$ r!cSRURRURURR UR 5$)Nz<{} iden={} fd={} event={}>)r#rr$rror=rAr%s rr&FDCallback.__repr__s<,33 NN # #TYY0B0BDJJP Pr!cDXlURR5 g)z1Update the callback and fix descriptor's watchersN)rAror^)rrAs rr^FDCallback.updates   r!rorA)r$r/r0r1r2rr;r5rr6r&r^r7r8r9s@rrgrgsXcz#QTY] P#P!C!D!!r!rgc^\rSrSrSrS\S\SS4U4SjjrS\4SjrS\ \SS44S jr S \ SS4S jr SU4S jjr S rU=r$)TimeoutCallbackzCallback for timerrrrNcB>[TU]"U0UD6 SUlSUlg)N)rrtimeout_task)rrrrs rrTimeoutCallback.__init__s# $)&)  r!cxSRURRURUR5$)Nz<{} iden={} timeout={}>)r#rr$rrr%s rr&TimeoutCallback.__repr__s.(// NN # #TYY > >r!c`# URS:aTURS-nURRRSU5 [R "U5IShvN O[R "S5IShvN URURUR5 URRRSUR5 MN|N_![R a3 URRRSUR5 gf=f7f)zAAn actual timer running on the event loop. This is a coroutine. rgMbP?z sleeping %rNztimer %d cancelledztimer %r callback ended) rrr)r*asynciosleepCancelledErrorrrrrrs r_timerTimeoutCallback._timers  <URSS9 [[U]5 g)z#Stop the timer and call ff callbackrrN)r^rr|r,)rrs rr,TimeoutCallback.close s B  ot*,r!)rrr.)r$r/r0r1r2rrr6r&rrr5r^r,r7r8r9s@rr|r|sbcST >#>FiT48F, c d --r!r|c b\rSrSrSrSS\R SS4SjjrS\4Sjr SSjr SS jr S S jr S \ S \SS4S jrS \ S \SS4SjrSSjrS\4SjrS\ S\ S\R*S \S\ 4 SjrS\ S\ SS4SjrS\ S\ 4SjrS\ S\R2S \S\ 4SjrS\ S\ SS4SjrS\ S\ 4SjrSrg)!r izLibvirt event adapter to asyncio. :param loop: asyncio's event loop If *loop* is not specified, the current (or default) event loop is used. NrYrcU=(d [R"5Ul0Ul[ U5Ul[ R"URR5Ul SUl SUl g)Nr) rget_event_looprYr?rj descriptorslogging getLoggerrr$r)_pending _finished)rrYs rrvirEventAsyncIOImpl.__init__sW4G224 )$/$$T^^%<%<= r!cvSR[U5RURUR5$)Nz <{} callbacks={} descriptors={}>)r#typer$r?rr%s rr&virEventAsyncIOImpl.__repr__+s2188 J  1A1AC Cr!c~U=RS- slURbURR5 gg)z;Increase the count of pending affairs. Do not use directly.N)rrclearr%s r _pending_inc virEventAsyncIOImpl._pending_inc/s/  >> % NN " &r!cURS:deU=RS-slURS:Xa)URbURR5 ggg)z;Decrease the count of pending affairs. Do not use directly.rrN)rrsetr%s r _pending_dec virEventAsyncIOImpl._pending_dec5sO}}q     ==A $.."< NN   #= r!cURRS5 [R"URUR UR URURUR5 U$)z3Register this instance as event loop implementationz register()) r)r*rJvirEventRegisterImpl _add_handle_update_handle_remove_handle _add_timeout_update_timeout_remove_timeoutr%s rregistervirEventAsyncIOImpl.register<s\ |$$$   d1143F3F   t33T5I5I K r!rrc`[R"URX5URS9 g)z8Schedule a ff callback from one of the handles or timersrN)rr _ff_callbackrYrrrs rr+(virEventAsyncIOImpl.schedule_ff_callbackEs!d//=DIINr!c# URRSU5 [R"U5 UR 5 g7f)z6Directly free the opaque object This is a coroutine. z ff_callback(iden=%d, opaque=...)N)r)r*rJvirEventInvokeFreeCallbackrrs rr virEventAsyncIOImpl._ff_callbackIs4 94@**62 sAAcf# URRS5 UR(adURbe[R "5UlURR 5IShvN SUlURS:XdeURRS5 gN97f)zBWait for the implementation to become idle. This is a coroutine. zdrain()Nrz drain ended)r)r*rrrEventwaitr%s rdrainvirEventAsyncIOImpl.drainRs y! ==>>) ))$]]_DN..%%' ' '!DN==A% %% }% (sA3B15B/6:B1cTUR(+=(a UR(+$)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(). )r?rr%s ris_idlevirEventAsyncIOImpl.is_idle`s >>!7$--&77r!r=rArc^[XUURUUS9nURUR;deURR SXUR5 XPRUR'URUR U5 UR5 UR$)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 rzz4add_handle(fd=%d, event=%d, cb=..., opaque=...) = %d)rgrrr?r)r*rar)rr=rArrrEs rrvirEventAsyncIOImpl._add_handlehsd)-)9)9")=UL}}DNN222 M(-- 1(0x}}% ''1 }}r!watchcURRSX5 URUn[U[5(deUR US9 g)zChange 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))rAN)r)r*r? isinstancergr^)rrrArEs rr"virEventAsyncIOImpl._update_handlesF :EI>>%((J////e$r!cURRSU5 URRU5n[U[5(deURRnX RURU5Lde[URUR5S:Xa URU UR5 g![a3nURR SUR S5 SnAgSnAff=f)zUnregister 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: %rrNr)r)r*r?rdKeyErrorwarningrrrgror=rrelenr,)rrrEerrr=s rr"virEventAsyncIOImpl._remove_handles 0%8 ~~))%0H(J////  # #++B/==eDDDD t#-- .! 3  $  HH  BCHHQK P sC D )DD rc$[XU5nURUR;deURR SXR5 X@RUR'UR US9 UR 5 UR$)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=...) = %dr)r|rr?r)r*r^r)rrrrrEs rr virEventAsyncIOImpl._add_timeoutst#4V4}}DNN222 I  /(0x}}%( }}r!timercURRSX5 URUn[U[5(deUR US9 g)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)rN)r)r*r?rr|r^)rrrrEs rr#virEventAsyncIOImpl._update_timeoutsF =uN>>%((O4444(r!cURRSU5 URRU5nUR5 g![a3nURR SUR S5 SnAgSnAff=f)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: %rrNr)r)r*r?rdrrrr,)rrrErs rr#virEventAsyncIOImpl._remove_timeoutsq 159 ~~))%0H    HH  Dchhqk R sA B)BB)rrr?rr)rYrr.)rr )r$r/r0r1r2rAbstractEventLooprr6r&rrrr5r r+rrboolrrJ_EventCBrrr_TimerCBrrrr7rhr!rr r s6 W66 $ C#C# !OObOTOsB4 &88c#73C3CRTW0 %C % % %CC.CW-=-=rc, )S )3 )4 )SSr!r rc[$)z@Return the current implementation, or None if not yet registered) _current_implrhr!rr r s r!rYc<[US9R5q[$)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. r)r rrrs rr r s(T2;;=M r!r)r2rr3rrVrJtypingrrrrrrr __author__ __license____all__objectrr;dictrjrgr|r rr rr rhr!rrs(<DD T] ;   ?v?>MM` T !!62-h2-rB&BJ !45 g&?&?K^r!