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
/
objects
/
__pycache__
/
service.cpython-36.opt-1.pyc
|
|---|
3
ÿnaµ7 ã @ sÊ d dl mZ d dlmZ d dlmZ d dlmZ d dl m
Z
d dl m Z d dlm Z d dlm
Z
ejeZd Zd
d ifZG d d
d
Ze
jjG dd
d
e
je
je
jZe
jjG dd de
je
jZdS )é )Úlog)Ú versionutils)Ú exception)Ú_LW)Úbase)Úfields)Údb)Úobjectsé Z compute_rpcz4.13c @ s$ e Zd ZdZi ZdZdZdd ZdS )ÚServicez1.20Fé c O s d|krt jdddt| _d S )NÚversionÚinitzVersion field is immutable)ÚactionÚreason)r ÚObjectActionErrorÚSERVICE_VERSIONr
)ÚselfÚargsÚkwargs© r ú /usr/lib/python3.6/service.pyÚ__init__& s
zService.__init__N)Ú__name__Ú
__module__Ú __qualname__ÚVERSIONÚ_MIN_VERSION_CACHEÚ_SERVICE_VERSION_CACHINGr r r r r r r s
r c sº e Zd ZdZejddej ejddejddejddej ej ejddejddej dej
ddej ej d
Zi Z dZ fdd Z
fd
d Zd d
Zedd Zdd Zejdd Zejdd Zejdd Zejdd Zeejd6ddZejd7d d Z ejd d Z d d! Z ej d"d# Z ej d$d% Z!d&d' Z"d(d) Z#ej d*d+ Z$e%d,d- Z&e%d.d/ Z'eejd8d0d1Z(ejd9d2d3Z)ejd:d4d5Z* Z+S );r z2.0T)Z read_only)ZnullableÚ ComputeNode)
ÚidÚuuidÚhostÚbinaryÚtopicZ report_countÚdisabledÚdisabled_reasonÚavailability_zoneÚ compute_nodeÚ last_seen_upÚ forced_downr
Fc s2 d|krt jdddtt| j|| t| _d S )Nr
r zVersion field is immutable)r r )r r Úsuperr r r r
)r r r )Ú __class__r r r Q s zService.__init__c s t t| j||| tj|}|d k r4d|kr4|d= |d k rJd|krJ|d= |d
k r`d|kr`|d= |dk rvd |krv|d = |dk r| j| j|| d S )Né é r! é r
é r* é
r) é
)r- r. )r- r/ )r- r0 )r- r1 )r- r2 )r+ r Ú!obj_make_compatible_from_manifestr Zconvert_version_to_tupleÚ_do_compute_nodeÚ_context)r Ú primitiveÚtarget_versionÚversion_manifestZ_target_version)r, r r r3 Z s
z)Service.obj_make_compatible_from_manifestc C sN y"|d }t jj||d d }W n tk
r6 d S X |j||d|d< d S )Nr r" r )r7 r8 r( )r ÚComputeNodeListÚget_all_by_hostÚ ExceptionZobj_to_primitive)r Úcontextr6 r8 r7 Zcomputer r r r4 k s zService._do_compute_nodec C s d}xp|j D ]f}||kr"||kr"q |dkr.q q |dkrNt|tj||| q |dkrf|j| rfq q || ||< q W | |_|j |S )Nr' r( r
r! )r' )r Úsetattrr Z get_attrnameÚgetr5 Zobj_reset_changes)r< ÚserviceÚ
db_serviceZ
allow_missingÚkeyr r r Ú_from_db_objectv s zService._from_db_objectc C s | j stjd| j dtjd|| j | jd |dkrLtjdd| d| jdkrjt j
j | j | j }ntj
| jd |d
| _d S ) NÚ
obj_load_attr)ÚmethodZobjtypez-Lazy-loading '%(attr)s' on %(name)s id %(id)s)ÚattrÚnamer r( z attribute %s not lazy-loadable)r r ztvault-contego)Ú
service_idr )r5 r ZOrphanedObjectErrorZobj_nameÚLOGÚdebugr r r# r r9 r: r" ZServiceNotFoundr( )r ZattrnameZ
compute_nodesr r r rC s
zService.obj_load_attrc C s t j||}| j|| |S )N)r Z service_getrB )Úclsr< rG r@ r r r Ú get_by_id s zService.get_by_idc C s t j||}| j|| |S )N)r Zservice_get_by_uuidrB )rJ r< Z service_uuidr@ r r r Ú get_by_uuid¤ s zService.get_by_uuidc C s t j|||}| j|| |S )N)r Z service_get_by_host_and_topicrB )rJ r< r" r$ r@ r r r Úget_by_host_and_topic© s z Service.get_by_host_and_topicc C s: yt j|||}W n tjk
r( d S X | j|| |S )N)r Ú service_get_by_host_and_binaryr ZHostBinaryNotFoundrB )rJ r< r" r# r@ r r r Úget_by_host_and_binary® s z Service.get_by_host_and_binaryc C s t j| |S )N)r Zservice_get_by_compute_host)r< r" Ú use_slaver r r Ú _db_service_get_by_compute_host· s z'Service._db_service_get_by_compute_hostc C s | j |||d}| j|| |S )N)rP )rQ rB )rJ r< r" rP r@ r r r Úget_by_compute_host¼ s zService.get_by_compute_hostc C s t j|||}| j|| |S )N)r rN rB )rJ r< r" r# r@ r r r Ú get_by_args s zService.get_by_argsc C sJ | j dsdS | j ds dS | j| j| j}|| jkrFtj| j|ddS )a Enforce that we are not older that the minimum version.
This is a loose check to avoid creating or updating our service
record if we would do so with a version that is older that the current
minimum of all services. This could happen if we were started with
older code by accident, either due to a rollback or an old and
un-updated node suddenly coming back onto the network.
There is technically a race here between the check and the update,
but since the minimum version should always roll forward and never
backwards, we don't need to worry about doing it atomically. Further,
the consequence for getting this wrong is minor, in that we'll just
fail to send messages that other services understand.
r
Nr# )ZthisverÚminver)Úobj_attr_is_setÚget_minimum_versionr5 r# r
r Z
ServiceTooOld)r rT r r r Ú_check_minimum_versionÇ s
z Service._check_minimum_versionc C sv | j drtjddd| j | j }d|krFtj |d< |d | _tj | j
|}| j | j
| | | j t
jj d S )Nr Úcreatezalready created)r r r! )rU r r rW Úobj_get_changesZ uuidutilsZ
generate_uuidr! r Zservice_creater5 rB Ú_send_notificationr ÚNotificationActionZCREATE)r Úupdatesr@ r r r rX Ý s
zService.createc C sL | j }|jdd | j tj| j| j|}| j| j| | | j| d S )Nr ) rY ÚpoprW r Zservice_updater5 r rB Ú _send_status_update_notification)r r\ r@ r r r Úsaveí s z Service.savec C s* t |j jdddhr&| jtjj d S )Nr% r& r* )ÚsetÚkeysÚ intersectionrZ r r[ ZUPDATE)r r\ r r r r^ ÷ s z(Service._send_status_update_notificationc C s> t j| }t jtjj| tjd|dtjj |dj
| j d S )Nr? )Úobjectr )Z publisherZ
event_typeZpriorityÚpayload) Zservice_notificationZServiceStatusPayloadZServiceStatusNotificationZ notificationZNotificationPublisherZfrom_service_objZ EventTyper ZNotificationPriorityÚINFOÚemitr5 )r r rd r r r rZ ü s
zService._send_notificationc C s" t j| j| j | jtjj d S )N)r Zservice_destroyr5 r rZ r r[ ZDELETE)r r r r Údestroy s zService.destroyc C s | j d| _d S )NT)Úclear_min_version_cacher )rJ r r r Úenable_min_version_cache s z Service.enable_min_version_cachec C s
i | _ d S )N)r )rJ r r r rh s z Service.clear_min_version_cachec C s t j| |S )N)r Zservice_get_minimum_version)r< ÚbinariesrP r r r Ú _db_service_get_minimum_version s z'Service._db_service_get_minimum_versionc s¸ t dd |D s2tjddj| tjddd j sPt fdd|D r j|||d }|rd
d |j D } j
j | n fd d |D }|r¨t |j
}nd
}t|}|S )Nc s s | ]}|j d V qdS )znova-N)Ú
startswith)Ú.0r# r r r ú <genexpr> s z4Service.get_minimum_version_multi.<locals>.<genexpr>z>get_minimum_version called with likely-incorrect binaries `%s'ú,rV zInvalid binary prefix)r r c 3 s | ]}| j kV qd S )N)r )rm r# )rJ r r rn # s )rP c S s i | ]\}}|pd |qS )r r )rm r# r
r r r ú
<dictcomp>( s z5Service.get_minimum_version_multi.<locals>.<dictcomp>c s i | ]} j | |qS r )r )rm r# )rJ r r rp - s r )ÚallrH ZwarningÚjoinr r r Úanyrk Úitemsr ÚupdateÚminÚvaluesÚint)rJ r< rj rP Z min_versionsr
r )rJ r Úget_minimum_version_multi s*
z!Service.get_minimum_version_multic C s | j ||g|dS )N)rP )ry )rJ r< r# rP r r r rV 8 s
zService.get_minimum_version)F)F)F)F)F),r r r r r Z IntegerFieldZ UUIDFieldZ StringFieldZ BooleanFieldZ ObjectFieldZ
DateTimeFieldr r r r3 r4 Ú staticmethodrB rC r Úremotable_classmethodrK rL rM rO r Zselect_db_reader_moderQ rR rS rW Z remotablerX r_ r^ rZ rg Ú classmethodri rh rk ry rV Ú
__classcell__r r )r, r r 9 s\
c @ sh e Zd ZdZdejdiZejdd ZejdddZ ejd d
Z
ejdd d
Z ejdd Z d S )Ú ServiceListz1.0r r c C s" t j||}tj|| |tj|S )N)r Zservice_get_all_by_topicr Ú
obj_make_listr r )rJ r< r$ Ú db_servicesr r r Ú get_by_topicG s zServiceList.get_by_topicFc C s& t j|||d}tj|| |tj|S )N)Úinclude_disabled)r Zservice_get_all_by_binaryr r r r )rJ r< r# r r r r r Ú
get_by_binaryM s zServiceList.get_by_binaryc C s" t j||}tj|| |tj|S )N)r Zservice_get_all_by_hostr r r r )rJ r< r" r r r r Ú get_by_hostT s zServiceList.get_by_hostNc C s4 t j||d}|r tj||}tj|| |tj|S )N)r% )r Zservice_get_allZavailability_zonesZset_availability_zonesr r r r )rJ r< r% Z set_zonesr r r r Úget_allZ s zServiceList.get_allc C s& t j||dd}tj|| |tj|S )NF)r )r Z#service_get_all_computes_by_hv_typer r r r )rJ r< Zhv_typer r r r Úget_all_computes_by_hv_typec s z'ServiceList.get_all_computes_by_hv_type)F)NF)
r r r r r ZListOfObjectsFieldr r{ r r r r
r r r r r r~ ? s r~ N)Zoslo_logr ZloggingZ
oslo_utilsr Zdmapir Z
dmapi.i18nr Z
dmapi.objectsr r r r Z getLoggerr rH r ZSERVICE_VERSION_HISTORYr ZContegoObjectRegistryÚregisterZContegoPersistentObjectZ
ContegoObjectZContegoObjectDictCompatZObjectListBaser~ r r r r Ú<module> s$