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:
6.1.1.dev2-6.1 ▾
|
python3-dmapi-el9
/
usr
/
lib
/
python3.9
/
site-packages
/
dmapi
/
__pycache__
/
rpc.cpython-39.pyc
|
|---|
a
úàÊg3 ã @ s g d ¢Z ddlZddlmZ ddlZddlmZ ddl m
Z
ddl m Z m
Z
ddlZddlZddlmZ ddlmZ dd lmZ ejjZe e¡Zdada da da ej jgZ g Z!d
d d d
Z"dd Z#ddl$m%Z% dd Z&dd Z'dd Z(dd Z)dd Z*dd Z+G d d d ej,Z-G d d d ej.Z/d5d!d"Z0d6d#d$Z1d7d%d&Z2d8d'd(Z3d)d* Z4d+d, Z5G d-d. d.e6Z7G d/d0 d0e6Z8G d1d2 d2e
j9Z:G d3d4 d4Z;dS )9) Ú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Ú uuidutils)Ú_)Údb)Úget_admin_contextZrabbitZqpidZzmq)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 8 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 ÚNotifierÚLEGACY_NOTIFIERÚNOTIFIER)r# Úexmodsr& r r r r P 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 m s r c G s t | ¡ d S r )Ú EXTRA_EXMODSÚextend)Úargsr r r r { 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__Ú staticmethodr5 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 )r: r5 ©r; r3 r4 r r r r5 s z)RequestContextSerializer.serialize_entityc C s | j s
|S | j ||¡S r )r: Údeserialize_entityr> r r r r? s z+RequestContextSerializer.deserialize_entityc C s | ¡ S r )Zto_dict©r; r3 r r r Úserialize_context s z*RequestContextSerializer.serialize_contextc C s t jj |¡S r )Údmapir3 ÚRequestContextZ from_dictr@ r r r Údeserialize_context s z,RequestContextSerializer.deserialize_contextN)r6 r7 r8 r= r5 r? rA rD 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 rG c C sJ t jj}t jjgg }tj||d}|d us0J t|}tj|| ||dS )Nr$ ©Ú version_capr& ) rB r# rF Ú exceptionr6 r r' r Ú RPCClient)ÚtargetrI 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 Úget_rpc_server)rL Ú 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, rF r! ÚLegacyValidatingNotifierÚprepare)Zservicer! rQ r r r r
¾ s
ÿr
c C s t d us J t j| dS )NrP )r- rS rP r r r Úget_versioned_notifierÆ s rT c C s t }tjt| |dS )N)Úurlr% )r r r' rF )rU r. r r r Úcreate_transportË s
þrV c @ s: e Zd ZdZdZdgZedZdd Zdd Z d d
Z
d S ) rR 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)r; r[ Úpriorityr r r r= æ s
ÿz!LegacyValidatingNotifier.__init__c C s ddht | ¡ kS )NrJ r1 )ÚsetÚkeys)r; Ú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_typesrd ÚfatalÚAssertionErrorÚmessageÚLOGZwarningÚgetattrr[ )r; r` Úctxtre rc r r r r_ õ s
ÿz LegacyValidatingNotifier._notifyN) r6 r7 r8 Ú__doc__rg rf r ri r= rd r_ r r r r rR Ò s ÿ rR c @ s e Zd Zdd Zedd ZdS )Ú
ClientWrapperc C s || _ t ¡ | _d S r )Ú_clientr ÚutcnowÚlast_access_time)r; Úclientr r r r= s zClientWrapper.__init__c C s t ¡ | _| jS r )r rp rq ro )r; r r r rr s
zClientWrapper.clientN)r6 r7 r8 r= Úpropertyrr r r r r rn s rn 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)Úsuperrt r= rF Úclientsrn rL rI rk r& Zrun_periodic_tasksrB r3 rC )r; Zdefault_client©Ú __class__r r r= 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 rH ) Úuuidrv rr ÚKeyErrorrV Z
transport_urlr rK rL rI r& rn )r; r3 Z cell_mappingÚ client_idrr Ú transportr r r ro 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_thanrj rW )r{ rq ©Útimeoutr r Ústale3 s ÿz1ClientRouter._remove_stale_clients.<locals>.staler )Úlistrv Úitemsrq )r; r3 r Z
items_copyr{ Zclient_wrapperr r~ r Ú_remove_stale_clients/ s
ÿz"ClientRouter._remove_stale_clients)N) r6 r7 r8 rm r= ro r r Ú
__classcell__r r rw r rt s
rt c @ s$ e Zd Zdd Zdd Zdd ZdS )Ú RPCServerc C s4 d}t j|||d| _t t¡| _t | j¡| _d S )NrB )ÚtopicZexchangeÚserver)r ZTargetrL r' rF r| r+ r[ )r; r r! Zdmapi_exchanger r r r= U s ÿ zRPCServer.__init__c C sâ z>t }t ||d |d ¡}|jd |d< t ||j|¡ W n tjjy z t
¡ |d< t ||¡}W n. tjj tjj
fy t d |¡¡ Y n0 Y n> tyÜ } z&t |¡ t d |¡¡ W Y d }~n
d }~0 0 d S )Nr! Zbinaryé Ú report_country z#service with data {} already existsz)Failed to handle report_state of data: {})r r Z service_get_by_host_and_binaryr Zservice_updateÚidrB rJ ZHostBinaryNotFoundr Z
generate_uuidZservice_createZServiceBinaryExistsZServiceTopicExistsrj ÚformatÚ ExceptionrZ )r; r3 Údatarl Z service_refÚexr r r Ú report_state\ s
zRPCServer.report_statec C s$ | g}t | j| j|¡}| ¡ d S r )r rN r| rL Ústart)r; rO r r r r r m s zRPCServer.startN)r6 r7 r8 r= r r r r r r r
T s r
)N)NN)N)NN)<Ú__all__r] Zoslo_logr
ZloggingZoslo_messagingr Zoslo_serializationr Z oslo_servicer Z
oslo_utilsr r Z
dmapi.confrB Zdmapi.exceptionZ
dmapi.i18nr r Z
dmapi.contextr r# rF Z getLoggerr6 rj r( r, r) r- rJ r2 r/ r r Z oslo_configr r" r r r r r ZNoOpSerializerr* Z
Serializerr rG r r r
rT rV ÚobjectrR rn Z
PeriodicTasksrt r
r r r r Ú<module> sV
ý
. I