Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
triliodata-4-0-patch / dmapi deb
Repository URL to install this package:
|
Version:
4.0.104 ▾
|
ó
ý^c @ 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 Z' d Z( d Z) d Z* d e j+ f d YZ+ d e j+ f d YZ, d Z- d a/ d d Z0 d Z1 d S( s: Generic Node base class for all workers that run on hosts.iÿÿÿÿN( t processutils( t log( t service( t importutils( t baserpc( t context( t debugger( t exception( t _t _LEt _LIt _LW( t rpc( t utils( t version( t wsgit
osprofilers osprofiler.initializerc C sJ t j | } | j | _ | j | _ | j | _ d | _ | j | S( Ni ( t objectst Servicet hostt binaryt topict report_countt create( t this_serviceR R ( ( s1 /usr/lib/python2.7/dist-packages/dmapi/service.pyt _create_service_ref' s
c C sm | j t j k ri t j t d i | j d 6| j d 6| j d 6t j d 6 t j | _ | j n d S( NsK Updating service version for %(binary)s on %(host)s from %(old)i to %(new)iR R t oldt new( R t service_objt SERVICE_VERSIONt LOGt infoR
R R t save( R ( ( s1 /usr/lib/python2.7/dist-packages/dmapi/service.pyt _update_service_ref1 s
c C sc t r_ t j j r_ t j j d t d t j j d d d | d | t j
t d n d S( Nt confR t projectt dmapiR R s OSProfiler is enabled.( R t CONFt profilert enabledt initializert init_from_confR t get_admin_contextt to_dictR R R
( R R ( ( s1 /usr/lib/python2.7/dist-packages/dmapi/service.pyt setup_profiler= s c C sL d d l j } d d l } | j } | j | j k rH t d n d S( Niÿÿÿÿsg eventlet hub is not using a monotonic clock - periodic tasks will be affected by drifts of system time.( t
eventlet.hubst hubst monotonict get_hubt clockt RuntimeError( R. R/ t hub( ( s1 /usr/lib/python2.7/dist-packages/dmapi/service.pyt$ assert_eventlet_uses_monotonic_clockH s R c
B s e Z d Z d d d d d Z d Z d Z d Z e d d d d d d d d d Z d Z
d Z e d Z
d Z d
Z RS( sõ 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.
c
O sþ t t | j | | _ | | _ | | _ | | _ t j | _ t
j | j } | d | j | |
| _ d | _ | | _ | | _ | | _ | | _ | |
| _ | _ d | _ t j j rê t j } | j t j n t | | j d S( NR ( t superR t __init__R R R t manager_class_namet servicegroupt APIt servicegroup_apiR t import_classt managert Nonet rpcservert report_intervalt periodic_enablet periodic_fuzzy_delayt periodic_interval_maxt
saved_argst saved_kwargst
backdoor_portt objects_baset
NovaObjectt indirection_apit conductort wait_until_readyR R* R, (
t selfR R R R< R? R@ RA RB t argst kwargst
manager_classt
conductor_api( ( s1 /usr/lib/python2.7/dist-packages/dmapi/service.pyR6 [ s& c C s3 d i | j j d 6| j d 6| j d 6| j d 6S( NsP <%(cls_name)s: host=%(host)s, binary=%(binary)s, manager_class_name=%(manager)s>t cls_nameR R R< ( t __class__t __name__R R R7 ( RK ( ( s1 /usr/lib/python2.7/dist-packages/dmapi/service.pyt __repr__r s
c C sS t t j } t j t d i | j d 6| d 6 | j | j j t
| _ t j
} t j j | | j | j | _ | j r t | j nW y t | | | _ Wn> t j t j f k
rö t j j | | j | j | _ n X| j j | j d
k r%| j | j _ n 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- rO| j. r$t/ j0 d | j. } n d
} | j1 j2 | j3 d | d | j4 n d
S( su Start the service.
This includes starting an RPC service, initializing
periodic tasks, etc.
s- Starting %(topic)s node (version %(version)s)R R s" Creating RPC server for service %st servers0 Join ServiceGroup membership for this service %si t
initial_delayRB N(5 R4 R t version_string_with_packageR R R
R t basic_config_checkR< t init_hostt Falset model_disconnectedR R* R R t get_by_host_and_binaryR R t service_refR! R R t ServiceTopicExistst ServiceBinaryExistst pre_start_hookRE R= t debugt messagingt TargetR t
BaseRPCAPIt service_namet extendt additional_endpointsRF t NovaObjectSerializerR t
get_serverR> t startt post_start_hookR: t joinR@ RA t randomt randintt tgt add_dynamic_timert periodic_tasksRB ( RK t verstrt ctxtt targett endpointst
serializerRU ( ( s1 /usr/lib/python2.7/dist-packages/dmapi/service.pyRi { sP
c C s" | j j d d } t | | S( NR< ( t __dict__t getR= t getattr( RK t keyR< ( ( s1 /usr/lib/python2.7/dist-packages/dmapi/service.pyt __getattr__¿ s c
C së | s t j } n | s4 t j j t j d } n | sP | j d d } n | sh t j | } n | d k r t j } n | d k r t j } n | d k r° t j
} n t j | | | | | d | d | d | d | } | S( s7 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
i s dmapi-i R? R@ RA RB N( R% R t ost patht basenamet syst argvt
rpartitiont SERVICE_MANAGERSRw R= R? R@ RA R t init(
t clsR R R R< R? R@ RA RB R ( ( s1 /usr/lib/python2.7/dist-packages/dmapi/service.pyR Ã s*
c C sI | j y | j j Wn' t j k
rD t j t d n Xd S( sþ 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.
s) Service killed that has no database entryN( t stopR\ t destroyR t NotFoundR t warningR ( RK ( ( s1 /usr/lib/python2.7/dist-packages/dmapi/service.pyt killì s
c C s y | j j | j j Wn t k
r1 n Xy | j j Wn$ t k
ri t j t d n Xt t
| j d S( s stop the service and clean up.s* Service error occurred during cleanup_hostN( R> R t waitt ExceptionR< t cleanup_hostR R R R5 R ( RK ( ( s1 /usr/lib/python2.7/dist-packages/dmapi/service.pyR ú s
c C s" t j } | j j | d | S( s' Tasks to be run at a periodic interval.t raise_on_error( R R* R< Rp ( RK R Rr ( ( s1 /usr/lib/python2.7/dist-packages/dmapi/service.pyRp
s c C sT y t j Wd QXWn6 t k
rO } t j t d | t j d n Xd S( s7 Perform basic config checks before starting processing.Ns" Temporary directory is invalid: %si ( R
t tempdirR R t errorR R~ t exit( RK t e( ( s1 /usr/lib/python2.7/dist-packages/dmapi/service.pyRW s
c C s | j j d S( s reset the service.N( R< t reset( RK ( ( s1 /usr/lib/python2.7/dist-packages/dmapi/service.pyR s N( RR t
__module__t __doc__R= R6 RS Ri Rz t classmethodR R R RY Rp RW R ( ( ( s1 /usr/lib/python2.7/dist-packages/dmapi/service.pyR S s D &
t WSGIServicec B sM e Z d Z d e d d Z d Z d Z d Z d Z d Z
RS( s< Provides ability to launch API from a 'paste' configuration.c C s~ | | _ 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 rd | } t d i | d 6t | j d
6} t j | n | | _ t j | | j
d | j
d | j d
| j d | | _ | j j | _ d | _ t | | j
d S( sÝ 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
s dmapi-%ss %s_listens 0.0.0.0s %s_listen_porti s
%s_workersi sG %(worker_name)s value of %(workers)s is invalid, must be greater than 0t worker_namet workersR t portt use_sslt max_url_lenN( t nameR R= R t _get_managerR< R t Loadert loadert load_appt appRx R% R R R t get_worker_countR R t strR t InvalidInputR t ServerRT RE R, ( RK R R R R t wnameR t msg( ( s1 /usr/lib/python2.7/dist-packages/dmapi/service.pyR6 ! s6
c C s | j j t j j d S( sc Reset server greenpool size to default and service version cache.
:returns: None
N( RT R R R t clear_min_version_cache( RK ( ( s1 /usr/lib/python2.7/dist-packages/dmapi/service.pyR G s
c C s8 t j | j } | d k r" d St j | } | S( s$ 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 Rw R R= R R; ( RK R< RN ( ( s1 /usr/lib/python2.7/dist-packages/dmapi/service.pyR P s
c C s | j j d S( sÕ 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( RT Ri ( RK ( ( s1 /usr/lib/python2.7/dist-packages/dmapi/service.pyRi a s c C s | j j d S( s8 Stop serving this API.
:returns: None
N( RT R ( RK ( ( s1 /usr/lib/python2.7/dist-packages/dmapi/service.pyR l s c C s | j j d S( sP Wait for the service to stop serving this API.
:returns: None
N( RT R ( RK ( ( s1 /usr/lib/python2.7/dist-packages/dmapi/service.pyR t s N( RR R R R= RY R6 R R Ri R R ( ( ( s1 /usr/lib/python2.7/dist-packages/dmapi/service.pyR s & c C s t j t d d S( Nt restart_methodt mutate( R t ProcessLauncherR% ( ( ( s1 /usr/lib/python2.7/dist-packages/dmapi/service.pyt process_launcher} s c C s= t r t t d n t j t | d d d d a d S( Ns serve() can only be called onceR i R¨ R© ( t _launcherR2 R R t launchR% ( RT R ( ( s1 /usr/lib/python2.7/dist-packages/dmapi/service.pyt serve s c C s t j d S( N( R¬ R ( ( ( s1 /usr/lib/python2.7/dist-packages/dmapi/service.pyR s (2 R R{ Rl R~ t oslo_concurrencyR t oslo_logR t loggingt oslo_messagingRa t oslo_serviceR t
oslo_utilsR R$ R t
dmapi.confR R R t
dmapi.i18nR R R
R R R
R R t
try_importR t osprofiler_initializert getLoggerRR R R" R% R R R! R, R4 R R R« R= R¬ R® R ( ( ( s1 /usr/lib/python2.7/dist-packages/dmapi/service.pyt <module> sB "
Ë_