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:
4.2.29-4.2 ▾
|
python3-dmapi
/
usr
/
lib
/
python3.6
/
site-packages
/
dmapi
/
__pycache__
/
rpc.cpython-36.opt-1.pyc
|
|---|
3
ÿna¸- ã @ s d ddddddddd d
g Z d d lZd d
lmZ d d lZd dlmZ d dl m
Z
d dl m Z d d l
Zd d lZd dlmZ ejjZejeZd ad ad ad aejjgZ g Z ddddZ dd Z d dl m!Z! dd Z"dd Z#dd Z$d d Z%d d Z&d d Z'G d d d ej(Z)G d!d dej*Z+d1d"d#Z,d2d$dZ-d3d%dZ.d4d&d Z/d'd( Z0d)d* Z1G d+d, d,e2Z3G d-d. d.e2Z4G d/d0 d0e
j5Z6d S )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 j| d S )N)Ú messagingZset_transport_defaults)Zcontrol_exchange© r ú/usr/lib/python3.6/rpc.pyr 7 s )Úcfgc C s: t jddddgddddt jdd d
g}|}| j| d S ) NÚnotification_formatÚ unversionedZ versionedÚbothZDEFAULTÚ )Ú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.
c C s$ t j tj d a a aad S )N)r# r r$ r& r' r r r r r l s c G s t j| d S )N)Ú EXTRA_EXMODSÚextend)Úargsr r r r z s c C s t d d
= d S )N)r) r r r r r ~ s c C s t t S )N)ÚALLOWED_EXMODSr) r r r r r s 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__Ú staticmethodr/ 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 )N)Ú_base)ÚselfÚbaser r r Ú__init__ s z!RequestContextSerializer.__init__c C s | j s
|S | j j||S )N)r4 r/ )r5 r- r. r r r r/ s z)RequestContextSerializer.serialize_entityc C s | j s
|S | j j||S )N)r4 Údeserialize_entity)r5 r- r. r r r r8 s z+RequestContextSerializer.deserialize_entityc C s |j S )N)Zto_dict)r5 r- r r r Úserialize_context s z*RequestContextSerializer.serialize_contextc C s t jjj|S )N)Údmapir- ÚRequestContextZ from_dict)r5 r- r r r Údeserialize_context s z,RequestContextSerializer.deserialize_contextN)r0 r1 r2 r7 r/ r8 r9 r< r r r r r s
c C s t jjt| tS )N)r Z TransportURLÚparseÚCONFr )Zurl_strr r r Úget_transport_url¢ s r? c C s> t jj}t jjgg }tj||d}t|}tj|| ||dS )N)r )Ú version_capr! ) r: r r> Ú exceptionr0 r r" r Ú RPCClient)Útargetr@ r! r r( r# r r r r ¦ s c C s t |}tjt| |d|dS )NZeventlet)Úexecutorr! )r r Zget_rpc_serverr# )rC Z endpointsr! r r r r ³ s c C s& |sd| |pt jf }ttj|dS )Nz%s.%s)Ú publisher_id)r> r ÚLegacyValidatingNotifierr& Úprepare)Zservicer rE r r r r
½ s c C s t j| dS )N)rE )r' rG )rE r r r Úget_versioned_notifierÅ s rH c C s t }tjt| |dS )N)Úurlr )r r r" r> )rI r( r r r Úcreate_transportÊ s rJ c @ s: e Zd ZdZdZdgZedZdd Zdd Z d d
Z
d S ) rF 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. || _ x"dD ]}t| |tj| j| q W d S )NÚdebugÚinfoÚwarnÚerrorÚcritical)rK rL rM rN rO )ÚnotifierÚsetattrÚ functoolsÚpartialÚ_notify)r5 rP Úpriorityr r r r7 å s
z!LegacyValidatingNotifier.__init__c C s ddht |j kS )NrA r+ )ÚsetÚkeys)r5 Úpayloadr r r Ú _is_wrap_exception_notificationë s z8LegacyValidatingNotifier._is_wrap_exception_notificationc C sZ || j krB| j| rB| jr0t| jd|i ntj| jd|i t| j|||| d S )NÚ
event_type) Ú'allowed_legacy_notification_event_typesrY ÚfatalÚAssertionErrorÚmessageÚLOGZwarningÚgetattrrP )r5 rU ZctxtrZ rX r r r rT ô s
z LegacyValidatingNotifier._notifyN) r0 r1 r2 Ú__doc__r\ r[ r r^ r7 rY rT r r r r rF Ñ s rF c @ s e Zd Zdd Zedd ZdS )Ú
ClientWrapperc C s || _ tj | _d S )N)Ú_clientr ÚutcnowÚlast_access_time)r5 Úclientr r r r7 s zClientWrapper.__init__c C s t j | _| jS )N)r rd re rc )r5 r r r rf s
zClientWrapper.clientN)r0 r1 r2 r7 Úpropertyrf r r r r rb ÿ s rb 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| jt i | _t|| jd< |j| _|j| _t|dd | _ | j
t j j
dd d S )Nr r! F)Z overwrite)Úsuperrh r7 r> Úclientsrb rC r@ r` r! Zrun_periodic_tasksr: r- r; )r5 Zdefault_client)Ú __class__r r r7 s zClientRouter.__init__Nc C sj |r |j }nd}y| j| j}W nD tk
rd t|j}tj|| j| j | j
d}t || j|< Y nX |S )Nr )r@ r! ) Zuuidrj rf ÚKeyErrorrJ Z
transport_urlr rB rC r@ r! rb )r5 r- Z cell_mappingÚ client_idrf Z transportr r r rc s
zClientRouter._clientc sP d fdd}t | jj }x,|D ]$\}}|dkr$|||jr$| j|= q$W d S )Né< c s" t j| r tjd| | dS dS )Nz;Removing stale RPC client: %s as it was last accessed at %sTF)r Z
is_older_thanr_ rK )rm re )Útimeoutr r Ústale2 s
z1ClientRouter._remove_stale_clients.<locals>.staler )Úlistrj Úitemsre )r5 r- rp Z
items_copyrm Zclient_wrapperr )ro r Ú_remove_stale_clients. s z"ClientRouter._remove_stale_clients)N) r0 r1 r2 ra r7 rc r rs Ú
__classcell__r r )rk r rh
s
rh )N)NN)N)NN)7Ú__all__rR Zoslo_logr
ZloggingZoslo_messagingr Zoslo_serializationr Z oslo_servicer Z
oslo_utilsr Z
dmapi.confr: Zdmapi.exceptionZ
dmapi.i18nr r r> Z getLoggerr0 r_ r# r& r$ r' rA r, r) r r Z oslo_configr r r r r r r ZNoOpSerializerr% Z
Serializerr r? r r r
rH rJ ÚobjectrF rb Z
PeriodicTasksrh r r r r Ú<module> sb
.