Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
triliodata-3-3 / python3-dmapi deb
Repository URL to install this package:
|
Version:
3.3.35 ▾
|
èáþ\¸- ã @ s@ d d d d d d d d d d d
g Z d d l Z d d
l m Z d d l Z d d l m Z d d l m
Z
d d l m Z d d l
Z d d l Z d d l m Z e j j Z e j e Z d a d a d a d a e j j g Z g Z d d d d d d i Z d d Z d d l m! Z! d d Z" d d Z# d d Z$ d d Z% d d Z& d d Z' Gd! d" d" e j( Z) Gd# d d e j* Z+ d d$ d% Z, d d d& d Z- d d' d Z. d d d( d Z/ d) d* Z0 d+ d, Z1 Gd- d. d. e2 Z3 Gd/ d0 d0 e2 Z4 Gd1 d2 d2 e
j5 Z6 d S)3Ú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)Ú_zdmapi.rpc.impl_kombuZrabbitzdmapi.rpc.impl_qpidZqpidzdmapi.rpc.impl_zmqZzmqc C s t j | d S)N)Ú messagingZset_transport_defaults)Zcontrol_exchange© r ú+/usr/lib/python3/dist-packages/dmapi/rpc.pyr 7 s )Úcfgc
C s\ t j d d d d d g d d d d d d
t j d d d g } | } | j | d S)
NÚnotification_formatÚchoicesÚ unversionedZ versionedÚbothÚdefaultZdeprecated_groupÚDEFAULTÚhelpÚ Úhostz )r ZStrOptZHostAddressOptÚ
register_opts)ÚconfZnotification_optsZALL_OPTSr r r r = s r c C s t | t } t j | d | a t j | d | a t t } | j d k r t j
t d | a t j
t d | d d a n~ | j d k rÓ t j
t d | a t j
t d | d d g a n9 t j
t d | d d a t j
t d | d d g a d S) NÚallowed_remote_exmodsr Ú
serializerÚdriverZnoopr ZtopicsZversioned_notifications)
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 sr t d k s t t d k s$ t t d k s6 t t d k sH t t j t j d a a a a d S)N)r% ÚAssertionErrorr& 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 Z d Z e d d Z d S)r' c C s t j | d d S)NZconvert_instancesT)r Z to_primitive)ÚcontextÚentityr r r Úserialize_entity s z&JsonPayloadSerializer.serialize_entityN)Ú__name__Ú
__module__Ú __qualname__Ú staticmethodr2 r r r r r' s r' c @ sL e Z d Z d d Z d d Z d d Z d d Z d d
Z d 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)r7 r2 )r8 r0 r1 r r r r2 s z)RequestContextSerializer.serialize_entityc C s | j s
| S| j j | | S)N)r7 Údeserialize_entity)r8 r0 r1 r r r r; s z+RequestContextSerializer.deserialize_entityc C s
| j S)N)Zto_dict)r8 r0 r r r Úserialize_context s z*RequestContextSerializer.serialize_contextc C s t j j j | S)N)Údmapir0 ÚRequestContextZ from_dict)r8 r0 r r r Údeserialize_context s z,RequestContextSerializer.deserialize_contextN)r3 r4 r5 r: r2 r; r< r? r r r r r s
c C s t j j t | t S)N)r Z TransportURLÚparseÚCONFr )Zurl_strr r r Úget_transport_url¢ s rB c C sn t j j } t j j g g } t j | d | } | d k sF t t | } t j | | d | d | S)Nr! Ú version_capr" )
r= r rA Ú exceptionr3 r r$ r+ r Ú RPCClient)ÚtargetrC r" r r* r% r r r r ¦ s c C s= t d k s t t | } t j t | | d d d | S)NZexecutorZeventletr" )r% r+ r r Zget_rpc_server)rF Z endpointsr" r r r r ³ s c C sG t d k s t | s1 d | | p* t j f } t t j d | S)Nz%s.%sÚ publisher_id)r( r+ rA r ÚLegacyValidatingNotifierÚprepare)Úservicer rG r r r r
½ s
c C s" t d k s t t j d | S)NrG )r) r+ rI )rG r r r Úget_versioned_notifierÅ s rK c C s" t } t j t d | d | S)NÚurlr! )r r r$ rA )rL r* r r r Úcreate_transportÊ s rM c @ sU e Z d Z d Z d Z d g Z e d Z d d Z d d Z d d
Z
d S) rH 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 sL | | _ x< d d d d d g D]% } t | | t j | j | q Wd S)NÚdebugÚinfoÚwarnÚerrorÚcritical)ÚnotifierÚsetattrÚ functoolsÚpartialÚ_notify)r8 rS Úpriorityr r r r: å s z!LegacyValidatingNotifier.__init__c C s d d h t | j k S)NrD r. )ÚsetÚkeys)r8 Úpayloadr r r Ú _is_wrap_exception_notificationë s z8LegacyValidatingNotifier._is_wrap_exception_notificationc C s} | | j k r] | j | r] | j rD t | j d | i n t j | j d | i t | j | | | | d S)NÚ
event_type) Ú'allowed_legacy_notification_event_typesr\ Úfatalr+ ÚmessageÚLOGÚwarningÚgetattrrS )r8 rX Zctxtr] r[ r r r rW ô s z LegacyValidatingNotifier._notifyN) r3 r4 r5 Ú__doc__r_ r^ r r` r: r\ rW r r r r rH Ñ s rH c @ s. e Z d Z d d Z e d d Z d S)Ú
ClientWrapperc C s | | _ t j | _ d S)N)Ú_clientr ÚutcnowÚlast_access_time)r8 Úclientr r r r: s zClientWrapper.__init__c C s t j | _ | j S)N)r rg rh rf )r8 r r r ri s zClientWrapper.clientN)r3 r4 r5 r: Úpropertyri r r r r re ÿ s re c sL e Z d Z d Z f d d Z d d d Z e j d d Z S) Ú 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 s t t | j t i | _ t | | j d <| j | _ | j | _ t | d d | _ | j
t j j
d d d S)Nr r" Z overwriteF)Úsuperrk r: rA Úclientsre rF rC rc r" Zrun_periodic_tasksr= r0 r> )r8 Zdefault_client)Ú __class__r r r: s zClientRouter.__init__Nc
C s | r | j } n d } y | j | j } Wn[ t k
r t | j } t j | | j d | j d | j
} t | | j | <Yn X| S)Nr rC r" ) Zuuidrm ri ÚKeyErrorrM Z
transport_urlr rE rF rC r" re )r8 r0 Z cell_mappingÚ client_idri Z transportr r r rf s
zClientRouter._clientc sp d f d d } t | j j } x< | D]4 \ } } | d k r4 | | | j r4 | j | =q4 Wd S)Né< c s- t j | r) t j d | | d Sd S)Nz;Removing stale RPC client: %s as it was last accessed at %sTF)r Z
is_older_thanra rN )rp rh )Útimeoutr r Ústale2 s
z1ClientRouter._remove_stale_clients.<locals>.staler )Úlistrm Úitemsrh )r8 r0 rs Z
items_copyrp Zclient_wrapperr )rr r Ú_remove_stale_clients. s z"ClientRouter._remove_stale_clients)r3 r4 r5 rd r: rf r rv r r )rn r rk
s
rk )7Ú__all__rU Zoslo_logr
ÚloggingZoslo_messagingr Zoslo_serializationr Z oslo_servicer Z
oslo_utilsr Z
dmapi.confr= Zdmapi.exceptionZ
dmapi.i18nr r rA Ú getLoggerr3 ra r% r( r& r) rD r/ r, r r Z oslo_configr r r r r r r ZNoOpSerializerr' Z
Serializerr rB r r r
rK rM ÚobjectrH re Z
PeriodicTasksrk r r r r Ú<module> sb
.