Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
Repository URL to install this package:
|
Version:
5.2.8-5.2 ▾
|
python3-dmapi-el9
/
usr
/
lib
/
python3.9
/
site-packages
/
dmapi
/
__pycache__
/
rpc.cpython-39.pyc
|
|---|
a
[r`e¸- ã @ sv g d ¢Z ddlZddlmZ ddlZddlmZ ddl m
Z
ddl m Z ddl
ZddlZddlmZ ejjZe e¡ZdadadadaejjgZ g Z dd d
d Z d d
Z ddl m!Z! dd Z"dd Z#dd Z$dd Z%dd Z&dd Z'G dd d ej(Z)G d d d ej*Z+d1d d Z,d2d!d"Z-d3d#d$Z.d4d%d&Z/d'd( Z0d)d* Z1G d+d, d,e2Z3G d-d. d.e2Z4G d/d0 d0e
j5Z6dS )5) ÚinitÚcleanupÚ set_defaultsÚadd_extra_exmodsÚclear_extra_exmodsÚget_allowed_exmodsÚRequestContextSerializerÚ
get_clientÚ
get_serverÚ get_notifierÚTRANSPORT_ALIASESé N)Úlog)Ú jsonutils)Ú
periodic_task)Ú timeutils)Ú_ZrabbitZqpidZzmq)zdmapi.rpc.impl_kombuzdmapi.rpc.impl_qpidzdmapi.rpc.impl_zmqc C s t | ¡ d S ©N)Ú messagingZset_transport_defaults)Zcontrol_exchange© r ú-/usr/lib/python3.9/site-packages/dmapi/rpc.pyr 7 s r )Úcfgc C s8 t jdg d¢ddddt jddd g}|}| |¡ d S )
NÚnotification_format)Ú unversionedZ versionedÚbothr ZDEFAULTÚ )ÚchoicesÚdefaultZdeprecated_groupÚhelpÚhostz )r )r ZStrOptZHostAddressOptÚ
register_opts)ÚconfZnotification_optsZALL_OPTSr r r r = s ûÿø
r c C s° t | t }tj| |datj| |datt }| j dkr^tj
t|da tj
t|dda nN| j dkrtj
t|da tj
t|dgda n"tj
t|dda tj
t|dgda d S ) N©Úallowed_remote_exmodsr )Ú
serializerZnoop)r# Zdriverr Zversioned_notifications)r# Ztopics)
r r r Ú
get_transportÚ TRANSPORTZget_notification_transportÚNOTIFICATION_TRANSPORTr ÚJsonPayloadSerializerr ZNotifierÚLEGACY_NOTIFIERÚNOTIFIER)r Úexmodsr# r r r r O s< ÿ
ÿÿ
ÿþþþr c C sT t d us J td usJ td us$J td us0J t ¡ t ¡ d a a aad S r )r% r& r( r) r r r r r r l s r c G s t | ¡ d S r )Ú EXTRA_EXMODSÚextend)Úargsr r r r z s r c C s t d d
= d S r )r+ r r r r r ~ s r c C s t t S r )ÚALLOWED_EXMODSr+ r r r r r s r c @ s e Zd Zedd ZdS )r' c C s t j|ddS )NT)Zconvert_instances)r Z to_primitive)ÚcontextÚentityr r r Úserialize_entity s z&JsonPayloadSerializer.serialize_entityN)Ú__name__Ú
__module__Ú __qualname__Ú staticmethodr1 r r r r r' s r' c @ s4 e Zd Zdd Zdd Zdd Zdd Zd d
Zd S ) r c C s
|| _ d S r )Ú_base)ÚselfÚbaser r r Ú__init__ s z!RequestContextSerializer.__init__c C s | j s
|S | j ||¡S r )r6 r1 ©r7 r/ r0 r r r r1 s z)RequestContextSerializer.serialize_entityc C s | j s
|S | j ||¡S r )r6 Údeserialize_entityr: r r r r; s z+RequestContextSerializer.deserialize_entityc C s | ¡ S r )Zto_dict©r7 r/ r r r Úserialize_context s z*RequestContextSerializer.serialize_contextc C s t jj |¡S r )Údmapir/ ÚRequestContextZ from_dictr< r r r Údeserialize_context s z,RequestContextSerializer.deserialize_contextN)r2 r3 r4 r9 r1 r; r= r@ r r r r r s
r c C s t j t| t¡S r )r Z TransportURLÚparseÚCONFr )Zurl_strr r r Úget_transport_url¢ s rC c C sJ t jj}t jjgg }tj||d}|d us0J t|}tj|| ||dS )Nr! ©Ú version_capr# ) r> r rB Ú exceptionr2 r r$ r Ú RPCClient)ÚtargetrE r# r r* r% r r r r ¦ s ýr c C s( t d us J t|}tjt | |d|dS )NZeventlet)Úexecutorr# )r% r r Zget_rpc_server)rH Z endpointsr# r r r r ³ s ür c C s2 t d us J |s"d| |p tjf }tt j|dS )Nz%s.%s©Ú publisher_id)r( rB r ÚLegacyValidatingNotifierÚprepare)Zservicer rK r r r r
½ s
ÿr
c C s t d us J t j| dS )NrJ )r) rM rJ r r r Úget_versioned_notifierÅ s rN c C s t }tjt| |dS )N)Úurlr" )r r r$ rB )rO r* r r r Úcreate_transportÊ s
þrP c @ s: e Zd ZdZdZdgZedZdd Zdd Z d d
Z
d S ) rL zDWraps an oslo.messaging Notifier and checks for allowed event_types.Fzaggregate.addhost.endze%(event_type)s is not a versioned notification and not whitelisted. See ./doc/source/notification.rstc C s* || _ dD ]}t| |t | j|¡ q
d S )N)ÚdebugÚinfoÚwarnÚerrorZcritical)ÚnotifierÚsetattrÚ functoolsÚpartialÚ_notify)r7 rU Úpriorityr r r r9 å s
ÿz!LegacyValidatingNotifier.__init__c C s ddht | ¡ kS )NrF r- )ÚsetÚkeys)r7 Úpayloadr r r Ú _is_wrap_exception_notificationë s z8LegacyValidatingNotifier._is_wrap_exception_notificationc C sX || j vr@| |¡s@| jr.t| jd|i nt | jd|i¡ t| j|||| d S )NÚ
event_type) Ú'allowed_legacy_notification_event_typesr^ ÚfatalÚAssertionErrorÚmessageÚLOGZwarningÚgetattrrU )r7 rZ Zctxtr_ r] r r r rY ô s
ÿz LegacyValidatingNotifier._notifyN) r2 r3 r4 Ú__doc__ra r` r rc r9 r^ rY r r r r rL Ñ s ÿ rL c @ s e Zd Zdd Zedd ZdS )Ú
ClientWrapperc C s || _ t ¡ | _d S r )Ú_clientr ÚutcnowÚlast_access_time)r7 Úclientr r r r9 s zClientWrapper.__init__c C s t ¡ | _| jS r )r ri rj rh )r7 r r r rk s
zClientWrapper.clientN)r2 r3 r4 r9 Úpropertyrk r r r r rg ÿ s rg c s8 e Zd ZdZ fddZd ddZejdd Z ZS )
Ú ClientRouterzËCreates and caches RPC clients that route to cells or the default.
The default client connects to the API cell message queue. The rest of the
clients connect to compute cell message queues.
c sZ t t| t¡ i | _t|| jd< |j| _|j| _t|dd | _ |
t j j
dd¡ d S )Nr r# F)Z overwrite)Úsuperrm r9 rB Úclientsrg rH rE re r# Zrun_periodic_tasksr> r/ r? )r7 Zdefault_client©Ú __class__r r r9 s zClientRouter.__init__Nc C sh |r |j }nd}z| j| j}W nB tyb t|j}tj|| j| j | j
d}t || j|< Y n0 |S )Nr rD ) Zuuidro rk ÚKeyErrorrP Z
transport_urlr rG rH rE r# rg )r7 r/ Z cell_mappingÚ client_idrk Z transportr r r rh s
þzClientRouter._clientc sL d fdd}t | j ¡ }|D ]$\}}|dkr"|||jr"| j|= q"d S )Né< c s" t | ¡r t d| |¡ dS dS )Nz;Removing stale RPC client: %s as it was last accessed at %sTF)r Z
is_older_thanrd rQ )rs rj ©Útimeoutr r Ústale2 s ÿz1ClientRouter._remove_stale_clients.<locals>.staler )Úlistro Úitemsrj )r7 r/ rw Z
items_copyrs Zclient_wrapperr ru r Ú_remove_stale_clients. s
ÿz"ClientRouter._remove_stale_clients)N) r2 r3 r4 rf r9 rh r rz Ú
__classcell__r r rp r rm
s
rm )N)NN)N)NN)7Ú__all__rW Zoslo_logr
ZloggingZoslo_messagingr Zoslo_serializationr Z oslo_servicer Z
oslo_utilsr Z
dmapi.confr> Zdmapi.exceptionZ
dmapi.i18nr r rB Z getLoggerr2 rd r% r( r& r) rF r. r+ r r Z oslo_configr r r r r r r ZNoOpSerializerr' Z
Serializerr rC r r r
rN rP ÚobjectrL rg Z
PeriodicTasksrm r r r r Ú<module> sP
ý
.