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
triliodata-3-3 / python3-dmapi deb
Repository URL to install this package:
|
Version:
3.3.11 ▾
|
EÜ\¤4 ã @ sö d Z d d l Z d d l Z d d l Z d d l m 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 m Z d d l m Z d d
l m Z d d l m Z m Z m Z m Z d d l m Z d d
l m Z d d l m Z d d l m Z e j d Z e j d Z e j! e" Z# e j$ j% Z% i 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 Z- d a. d d d! Z/ d" d# Z0 d S)$z:Generic Node base class for all workers that run on hosts.é N)Ú processutils)Úlog)Úservice)Ú importutils)Úbaserpc)Úcontext)Údebugger)Ú exception)Ú_Ú_LEÚ_LIÚ_LW)Úrpc)Úutils)Úversion)ÚwsgiÚ
osprofilerzosprofiler.initializerc C sJ t j | } | j | _ | j | _ | j | _ d | _ | j | S)Nr )ÚobjectsÚServiceÚhostÚbinaryÚtopicZ report_countÚcreate)Z this_servicer r © r ú//usr/lib/python3/dist-packages/dmapi/service.pyÚ_create_service_ref' s
r c
C sf | j t j k rb t j t d d | j d | j d | j d t j i t j | _ | j d S)NzKUpdating service version for %(binary)s on %(host)s from %(old)i to %(new)ir r ÚoldÚnew) r Ú service_objZSERVICE_VERSIONÚLOGÚinfor r r Úsave)r r r r Ú_update_service_ref1 s r" c C s` t r\ t j j r\ t j j d t d t j j d d d | d | t j
t d d S)NÚconfr ÚprojectÚdmapir r zOSProfiler is enabled.) r ÚCONFZprofilerÚenabledÚ initializerZinit_from_confr Úget_admin_contextZto_dictr r r )r r r r r Úsetup_profiler= s r* c C sI d d l j } d d l } | j } | j | j k rE t d d S)Nr zgeventlet hub is not using a monotonic clock - periodic tasks will be affected by drifts of system time.)Z
eventlet.hubsÚhubsÚ monotonicZget_hubÚclockÚ RuntimeError)r+ r, Zhubr r r Ú$assert_eventlet_uses_monotonic_clockH s r/ c sÇ e Z d Z d Z d d d d f d d Z d d Z d d Z d d
Z e d d d d d d d d d d Z d
d Z
f d d Z d d d Z d d Z
d d Z S)r zõService object for binaries running on hosts.
A service takes a manager and enables rpc by listening to queues based
on topic. It also periodically runs tasks on the manager and reports
its state to the database services table.
Nc
sû t t | j | | _ | | _ | | _ | | _ t j | _ t
j | j } | | d | j |
| _ d | _
| | _ | | _ | | _ | | _ | |
| _ | _ d | _ t j j rç t j } | j t j t | | j d S)Nr ) Úsuperr Ú__init__r r r Úmanager_class_nameZ servicegroupZAPIÚservicegroup_apir Ú import_classÚmanagerÚ rpcserverÚreport_intervalÚperiodic_enableÚperiodic_fuzzy_delayÚperiodic_interval_maxZ
saved_argsZ saved_kwargsÚ
backdoor_portÚ objects_baseZ
NovaObjectZindirection_apiZ conductorZwait_until_readyr r) r* )
Úselfr r r r5 r7 r8 r9 r: ÚargsÚkwargsÚ
manager_classZ
conductor_api)Ú __class__r r r1 [ s& zService.__init__c C s/ d d | j j d | j d | j d | j i S)NzP<%(cls_name)s: host=%(host)s, binary=%(binary)s, manager_class_name=%(manager)s>Úcls_namer r r5 )rA Ú__name__r r r2 )r= r r r Ú__repr__r s
zService.__repr__c C sL t t j } t j t d d | j d | i | j | j j d | _
t j } t
j j | | j | j | _ | j r t | j nX y t | | | _ Wn? t j t j f k
rõ t
j j | | j | j | _ Yn X| j j | j d k r!| j | j _ t j d | j t j d | j d | j } | j t j | j j | j g } | j | j j! t" j# } t$ j% | | | | _& | j& j' | j j( t j d | j | j) j* | j | j | | j+ rH| j, r t- j. d | j, } n d } | j/ j0 | j1 d
| d | j2 d S) zuStart the service.
This includes starting an RPC service, initializing
periodic tasks, etc.
z-Starting %(topic)s node (version %(version)s)r r FNz"Creating RPC server for service %sÚserverz0Join ServiceGroup membership for this service %sr Ú
initial_delayr: )3r/ r Zversion_string_with_packager r r r Úbasic_config_checkr5 Z init_hostZmodel_disconnectedr r) r r Zget_by_host_and_binaryr r Ú service_refr" r r ZServiceTopicExistsZServiceBinaryExistsZpre_start_hookr; ÚdebugÚ messagingZTargetr Z
BaseRPCAPIZ service_nameÚextendZadditional_endpointsr< ZNovaObjectSerializerr Z
get_serverr6 ÚstartZpost_start_hookr3 Újoinr8 r9 ÚrandomÚrandintÚtgZadd_dynamic_timerÚperiodic_tasksr: )r= ZverstrÚctxtÚtargetZ endpointsZ
serializerrF r r r rL { sP
z
Service.startc C s" | j j d d } t | | S)Nr5 )Ú__dict__ÚgetÚgetattr)r= Úkeyr5 r r r Ú __getattr__¿ s zService.__getattr__c
C sÖ | s t j } | s. t j j t j d } | sG | j d d } | s\ t j | } | d k rq t j
} | d k r t j } | d k r t j } t
j | | | | | d | d | d | d | } | S) a7 Instantiates class and passes back application object.
:param host: defaults to CONF.host
:param binary: defaults to basename of executable
:param topic: defaults to bin_name - 'dmapi-' part
:param manager: defaults to CONF.<topic>_manager
:param report_interval: defaults to CONF.report_interval
:param periodic_enable: defaults to CONF.periodic_enable
:param periodic_fuzzy_delay: defaults to CONF.periodic_fuzzy_delay
:param periodic_interval_max: if set, the max time to wait between runs
r zdmapi-é Nr7 r8 r9 r: )r& r ÚosÚpathÚbasenameÚsysÚargvÚ
rpartitionÚSERVICE_MANAGERSrU r7 r8 r9 r Úinit)
Úclsr r r r5 r7 r8 r9 r: r r r r r à s*
zService.createc C sJ | j y | j j Wn( t j k
rE t j t d Yn Xd S)zþDestroy the service object in the datastore.
NOTE: Although this method is not used anywhere else than tests, it is
convenient to have it here, so the tests might easily and in clean way
stop and remove the service_ref.
z)Service killed that has no database entryN)ÚstoprH Zdestroyr ZNotFoundr Úwarningr
)r= r r r Úkillì s
z Service.killc s y | j j | j j Wn t k
r2 Yn Xy | j j Wn% t k
rk t j t d Yn Xt t
| j d S)z stop the service and clean up.z*Service error occurred during cleanup_hostN) r6 rc ÚwaitÚ Exceptionr5 Z cleanup_hostr r r r0 r )r= )rA r r rc ú s
z Service.stopFc C s" t j } | j j | d | S)z'Tasks to be run at a periodic interval.Úraise_on_error)r r) r5 rQ )r= rh rR r r r rQ
s zService.periodic_tasksc C sg y t j Wd QRXWnH t k
rb } z( t j t d | t j d WYd d } ~ Xn Xd S)z7Perform basic config checks before starting processing.Nz"Temporary directory is invalid: %sé )r Útempdirrg r Úerrorr r] Úexit)r= Úer r r rG s
zService.basic_config_checkc C s | j j d S)zreset the service.N)r5 Úreset)r= r r r rn s z
Service.reset)rC Ú
__module__Ú __qualname__Ú__doc__r1 rD rL rX Ú classmethodr re rc rQ rG rn r r )rA r r S s D &
r c @ sg e Z d Z d Z d d d d d Z d d Z d d Z d
d Z d d
Z d d Z d S)Ú WSGIServicez<Provides ability to launch API from a 'paste' configuration.NFc C sy | | _ d | | _ d | _ | j | _ | p= t j | _ | j j | | _ | } t
t d | d | _ t
t d | d | _
t
t d | d p¯ t j | _ | j r | j d k r d | } t d d
| d t | j i } t j | | | _ t j | | j d | j d
| j
d | j d | | _ | j j
| _
d | _ t | | j d S)zÝInitialize, but do not start the WSGI server.
:param name: The name of the WSGI server given to the loader.
:param loader: Loads the WSGI application using the given name.
:returns: None
zdmapi-%sNz %s_listenz0.0.0.0z%s_listen_portr z
%s_workersri zG%(worker_name)s value of %(workers)s is invalid, must be greater than 0Ú worker_nameÚworkersr ÚportÚuse_sslÚ max_url_len)Únamer r Ú _get_managerr5 r ÚLoaderÚloaderZload_appZapprV r& r rv r Zget_worker_countru r
Ústrr Z InvalidInputrw ZServerrE r; r* )r= ry r| rw rx Zwnamert Úmsgr r r r1 ! s6
zWSGIService.__init__c C s | j j t j j d S)zcReset server greenpool size to default and service version cache.
:returns: None
N)rE rn r r Zclear_min_version_cache)r= r r r rn G s
zWSGIService.resetc C s8 t j | j } | d k r" d St j | } | S)a$ Initialize a Manager object appropriate for this service.
Use the service name to look up a Manager subclass from the
configuration and initialize an instance. If no class name
is configured, just return None.
:returns: a Manager instance, or None.
N)r` rU r r r4 )r= r5 r@ r r r rz P s
zWSGIService._get_managerc C s | j j d S)zÕStart serving this service using loaded configuration.
Also, retrieve updated port number in case '0' was passed in, which
indicates a random port should be used.
:returns: None
N)rE rL )r= r r r rL a s zWSGIService.startc C s | j j d S)z8Stop serving this API.
:returns: None
N)rE rc )r= r r r rc l s zWSGIService.stopc C s | j j d S)zPWait for the service to stop serving this API.
:returns: None
N)rE rf )r= r r r rf t s zWSGIService.wait)
rC ro rp rq r1 rn rz rL rc rf r r r r rs s & rs c C s t j t d d S)NÚrestart_methodÚmutate)r ZProcessLauncherr& r r r r Úprocess_launcher} s r c C s: t r t t d t j t | d d d d a d S)Nz serve() can only be called onceru ri r r )Ú _launcherr. r
r Zlaunchr& )rE ru r r r Úserve s r c C s t j d S)N)r rf r r r r rf s rf )1rq rZ rN r] Zoslo_concurrencyr Zoslo_logr ÚloggingZoslo_messagingrJ Z oslo_servicer Z
oslo_utilsr r% r Z
dmapi.confr r r Z
dmapi.i18nr
r r r
r r r r Z
try_importr Zosprofiler_initializerÚ getLoggerrC r r# r& r` r r" r* r/ r rs r r r rf r r r r Ú<module> sB "
Ë_