509318396 آگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآ 3 ˆuAc م@s¸dZddlmZddlZddlZddlmZddlmZ ddl mZd d dgZda dd „Zeadd„Zdd„Zdd„Zdadadd„ZGdd „d ejjƒZGdd „d eeejjƒƒZdS)zMThis module contains convenience functions for using dbus-activated services.é)عabsolute_importN)عwith_metaclassé)ع_glibé)عpolkitعObjectع InterfaceTypeعset_mainloopcCstjƒdS)N)ع__mainloop__عquit©r r ْ/usr/lib/python3.6/service.pyع__glib_quit_cb__)srcCs|adS)N)r)Zmainloopr r rr 4scCs|adS)N)ع__quit_cb__)عquit_cbr r rعset_quit_cb9srcCs tƒdS)N)rr r r rr>srZ__slip_dbus_service_sender__ع__slip_dbus_service_reply_cb__ع__slip_dbus_service_error_cb__cs²ˆjdk rˆj‰d‰nt‰d‰ˆjdk r4ˆj‰d‰nt‰d‰ˆ‰‡‡‡‡‡‡fdd„}xLdd„tˆƒDƒD]6}|dkr€ˆ|_ql|dkrگˆ|_qlt||tˆ|ƒƒqlWˆj|_|S) NFTcsزˆjˆƒ}|dk rVˆˆd‰ˆˆd‰ˆr4ˆˆ=ˆrLˆˆd=ˆˆd=ˆj|ƒtˆ dtˆddƒƒ‰|dk r²ˆr²‡‡‡‡ ‡ ‡‡‡fdd„}‡‡fdd„}tj|ˆ||d چnˆ ˆfˆ‍ˆژ}ˆjƒ|SdS) NrrZ_slip_polkit_auth_requiredعdefault_polkit_auth_requiredcsœ|r‚ˆrˆˆfˆ‍ˆژqگd}yˆˆfˆ‍ˆژ}Wn&tk rX}z |}WYdd}~XnX|rhˆ|ƒqگ|dkrxˆƒqگˆ|ƒnˆtjˆƒƒˆjƒdS)N)ع ExceptionrZNotAuthorizedExceptionعtimeout_restart)Zis_authعerrorعresultعe)ع action_idعerror_cbعkعmethodعmethod_is_asyncعpعreply_cbعselfr rع reply_handlerqs z:wrap_method..wrapped_method..reply_handlercsˆ|ƒˆjƒdS)N)r)r)rr"r rع error_handler“sz:wrap_method..wrapped_method..error_handler)r#r$)عgetعsender_seenعgetattrrZIsSystemBusNameAuthorizedAsyncr)r"r rعsenderr#r$Zretval)عasync_callbacksعhide_async_callbacksعhide_sender_keywordrrعsender_keyword)rrrr r!r"rعwrapped_method[s, "z#wrap_method..wrapped_methodcss"|]}|dd…dkr|VqdS)NéZ_dbus_r )ع.0عxr r rْ szwrap_method..ع_dbus_sender_keywordع_dbus_async_callbacks)r2عSENDER_KEYWORDr3عASYNC_CALLBACKSعdirعsetattrr'ع__name__)rr-عattrr )r)r*r+rrr,rعwrap_methodHs( Er:cseZdZ‡fdd„Z‡ZS)r csDx,|jƒD] \}}t|ddƒr t|ƒ||<q Wtt|ƒj||||ƒS)NZ_dbus_is_methodF)عitemsr'r:عsuperr ع__new__)عclsعnameعbasesZdctZattrnamer9)ع __class__r rr=±szInterfaceType.__new__)r8ع __module__ع__qualname__r=ع __classcell__r r )rArr ¯scsbeZdZdZdZeZdZeƒZiZ iZ dZd‡fdd„ Zdd„Z dd „Zdd d„Zdd „Z‡ZS)rFéNcs2tt|ƒj|||ƒ|dkr(|jj|_n||_dS)N)r<rع__init__rAع persistent)r"عconnZobject_pathZbus_namerG)rAr rrFةszObject.__init__cCs2|jr ttjƒdkr tƒdSdt_|jt_dS)NrF)rGعlenrعsendersrعcurrent_sourceعdefault_durationعduration)r"r r rع_timeout_cbزszObject._timeout_cbcCs”|j}|rگ||ftjkrگtjj||fƒtj|j|ƒttj|ƒdkrjtj|jƒtj|=tj|=|jrگttjƒdkrگtjdkrگt ƒdS)Nr) ع connectionrrJعremoveعconnections_sendersrIعconnections_smobjsrGrKr)r"r?Z old_ownerZ new_ownerrHr r rع_name_owner_changedـs zObject._name_owner_changedcCsf|s|jj}tjs|tjkr$|t_|js:ttjƒdkrbtjrLtj tjƒtj tjd|jƒt_dS)Nriè)rArLrrMrGrIrJrKعGLibZ source_removeZtimeout_addrN)r"rMr r rrيszObject.timeout_restartcCsp||jftjkrltjj||jfƒ|jtjkrZtƒtj|j<|jj|jdd|dچtj|j<tj|jj|ƒdS)NZNameOwnerChangedzorg.freedesktop.DBus)Zhandler_functionZsignal_nameZdbus_interfaceZarg1) rOrrJعaddrQعsetZadd_signal_receiverrSrR)r"r(r r rr&ùszObject.sender_seen)NNNN)N)r8rBrCrGrLrMrKrVrJrQrRrrFrNrSrr&rDr r )rArr¹s )rr)ع__doc__Z __future__rZdbusZdbus.serviceZsixrZ _wrappersrrTعrع__all__rrrr rrr4r5r:Zservicer rr r r rعs& g