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:
5.2.8-5.2 ▾
|
python3-dmapi-el9
/
usr
/
lib
/
python3.9
/
site-packages
/
dmapi
/
objects
/
__pycache__
/
service.cpython-39.pyc
|
|---|
a
[r`eµ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
e e¡Zd 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|v rt jdddt| _d S ©NÚversionÚinitzVersion field is immutable©ÚactionÚreason)r ÚObjectActionErrorÚSERVICE_VERSIONr ©ÚselfÚargsÚkwargs© r ú9/usr/lib/python3.9/site-packages/dmapi/objects/service.pyÚ__init__& s
þúService.__init__N)Ú__name__Ú
__module__Ú __qualname__ÚVERSIONÚ_MIN_VERSION_CACHEÚ_SERVICE_VERSION_CACHINGr r r r r r r s
r c sº e Zd ZdZejdde ¡ ejddejddejdde ¡ e ¡ ejddejdde d¡ej
dde ¡ e ¡ 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 s6 d|v rt jdddtt| j|i |¤ t| _d S r
)r r Úsuperr r r r r ©Ú __class__r r r Q s þr c s t t| |||¡ t |¡}|dk r4d|v r4|d= |dk rJd|v rJ|d= |dk r`d|v r`|d= |dk rvd|v rv|d= |d k r| | j||¡ d S )
N)é é r% )r2 é r )r2 é r. )r2 é
r- )r2 é
)r/ r Ú!obj_make_compatible_from_manifestr Zconvert_version_to_tupleÚ_do_compute_nodeÚ_context)r Ú primitiveÚtarget_versionÚversion_manifestZ_target_versionr0 r r r8 Z s
ÿ
ÿz)Service.obj_make_compatible_from_manifestc C sN z"|d }t j ||d ¡d }W n ty6 Y d S 0 |j||d|d< d S )Nr# r& r )r< r= r, )r ÚComputeNodeListÚget_all_by_hostÚ ExceptionZobj_to_primitive)r Úcontextr; r= r< Zcomputer r r r9 k s ÿÿ þzService._do_compute_nodec C s d}|j D ]d}||v r ||vr q
|dkr,q
q
|dkrLt|t |¡|| q
|dkrb| |¡sbq
q
|| ||< q
| |_| ¡ |S )N)r+ r, r r% )r Úsetattrr Z get_attrnameÚgetr: Zobj_reset_changes)rA ÚserviceÚ
db_serviceZ
allow_missingÚkeyr r r Ú_from_db_objectv s
zService._from_db_objectc C s | j stjd| ¡ dt d|| ¡ | jd¡ |dkrLtjdd| d| jdkrjt 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-loadabler ztvault-contego)Ú
service_idr )r: r ZOrphanedObjectErrorZobj_nameÚLOGÚdebugr$ r r' r r> r? r& ZServiceNotFoundr, )r ÚattrnameZ
compute_nodesr r r rH s* ÿþÿþ
ÿzService.obj_load_attrc C s t ||¡}| || |¡S ©N)r Z service_getrG )ÚclsrA rL rE r r r Ú get_by_id s zService.get_by_idc C s t ||¡}| || |¡S rP )r Zservice_get_by_uuidrG )rQ rA Z service_uuidrE r r r Ú get_by_uuid¤ s zService.get_by_uuidc C s t |||¡}| || |¡S rP )r Z service_get_by_host_and_topicrG )rQ rA r& r( rE r r r Úget_by_host_and_topic© s z Service.get_by_host_and_topicc C s: zt |||¡}W n tjy( Y d S 0 | || |¡S rP )r Ú service_get_by_host_and_binaryr ZHostBinaryNotFoundrG ©rQ rA r& r' rE r r r Úget_by_host_and_binary® s ÿz Service.get_by_host_and_binaryc C s t | |¡S rP )r Zservice_get_by_compute_host)rA r& Ú use_slaver r r Ú _db_service_get_by_compute_host· s z'Service._db_service_get_by_compute_hostc C s | j |||d}| || |¡S ©N©rX )rY rG )rQ rA r& rX rE r r r Úget_by_compute_host¼ s ÿzService.get_by_compute_hostc C s t |||¡}| || |¡S rP )r rU rG rV r r r Ú get_by_args s zService.get_by_argsc C sJ | d¡sdS | d¡s dS | | 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_versionr: r' r r Z
ServiceTooOld)r r^ r r r Ú_check_minimum_versionÇ s
ÿz Service._check_minimum_versionc C sv | d¡rtjddd| ¡ | ¡ }d|vrFt ¡ |d< |d | _t | j
|¡}| | j
| |¡ | t
jj¡ d S )Nr$ Úcreatezalready createdr r% )r_ r r ra Úobj_get_changesZ uuidutilsZ
generate_uuidr% r Zservice_creater: rG Ú_send_notificationr ÚNotificationActionZCREATE©r ÚupdatesrE r r r rb Ý s
ÿ
zService.createc C sL | ¡ }| dd ¡ | ¡ t | j| j|¡}| | j| |¡ | |¡ d S )Nr$ ) rc Úpopra r Zservice_updater: r$ rG Ú _send_status_update_notificationrf r r r Úsaveí s z Service.savec C s( t | ¡ h d£¡r$| tjj¡ d S )N> r* r) r. )ÚsetÚkeysÚ intersectionrd r re ZUPDATE)r rg r r r ri ÷ s ÿz(Service._send_status_update_notificationc C s> t | ¡}t jtj | ¡tjd|dtjj |d
| j ¡ d S )NrD )Úobjectr )Z publisherZ
event_typeÚpriorityÚpayload) Zservice_notificationZServiceStatusPayloadZServiceStatusNotificationZ notificationZNotificationPublisherZfrom_service_objZ EventTyper ZNotificationPriorityÚINFOÚemitr: )r r rp r r r rd ü s
ÿþùùzService._send_notificationc C s" t | j| j¡ | tjj¡ d S rP )r Zservice_destroyr: r$ rd r re ZDELETE)r r r r Údestroy s zService.destroyc C s | ¡ d| _d S )NT)Úclear_min_version_cacher" ©rQ r r r Úenable_min_version_cache s z Service.enable_min_version_cachec C s
i | _ d S rP ©r! ru r r r rt s z Service.clear_min_version_cachec C s t | |¡S rP )r Zservice_get_minimum_version)rA ÚbinariesrX r r r Ú _db_service_get_minimum_version s z'Service._db_service_get_minimum_versionc s¶ t dd |D s2t dd |¡¡ tjddd jrNt fdd|D r j|||d }|rd
d | ¡ D } j
|¡ n fd d |D }|r¦t |
¡ }nd
}t|}|S )Nc s s | ]}| d ¡V qdS )znova-N)Ú
startswith©Ú.0r' r r r Ú <genexpr> ó z4Service.get_minimum_version_multi.<locals>.<genexpr>z>get_minimum_version called with likely-incorrect binaries `%s'ú,r` zInvalid binary prefixr c 3 s | ]}| j vV qd S rP rw r{ ru r r r} # s ÿr[ c S s i | ]\}}||pd qS )r r )r| r' r r r r Ú
<dictcomp>( s ÿz5Service.get_minimum_version_multi.<locals>.<dictcomp>c s i | ]}| j | qS r rw r{ ru r r r - s ÿr )ÚallrM ZwarningÚjoinr r r" Úanyry Úitemsr! ÚupdateÚminÚvaluesÚint)rQ rA rx rX Z min_versionsr r ru r Úget_minimum_version_multi s8 ÿÿ ÿÿÿþ
ÿz!Service.get_minimum_version_multic C s | j ||g|dS rZ )r )rQ rA r' rX r r r r` 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 r8 r9 Ú staticmethodrG rH r Úremotable_classmethodrR rS rT rW r Zselect_db_reader_moderY r\ r] ra Z remotablerb rj ri rd rs Ú classmethodrv rt ry r r` Ú
__classcell__r r r0 r r 9 st
ó
c @ sh e Zd ZdZde d¡iZejdd ZejdddZ ejd d
Z
ejdd d
Z ejdd Z d S )Ú ServiceListz1.0r r c C s" t ||¡}t || |tj|¡S rP )r Zservice_get_all_by_topicr Ú
obj_make_listr r )rQ rA r( Ú db_servicesr r r Ú get_by_topicG s ÿzServiceList.get_by_topicFc C s& t j|||d}t || |tj|¡S )N©Úinclude_disabled)r Zservice_get_all_by_binaryr r r r )rQ rA r' r r r r r Ú
get_by_binaryM s ÿÿzServiceList.get_by_binaryc C s" t ||¡}t || |tj|¡S rP )r Zservice_get_all_by_hostr r r r )rQ rA r& r r r r Ú get_by_hostT s ÿzServiceList.get_by_hostNc C s4 t j||d}|r t ||¡}t || |tj|¡S )N)r) )r Zservice_get_allZavailability_zonesZset_availability_zonesr r r r )rQ rA r) Z set_zonesr r r r Úget_allZ s ÿÿzServiceList.get_allc C s& t j||dd}t || |tj|¡S )NFr )r Z#service_get_all_computes_by_hv_typer r r r )rQ rA 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 rM r ZSERVICE_VERSION_HISTORYr ZContegoObjectRegistryÚregisterZContegoPersistentObjectZ
ContegoObjectZContegoObjectDictCompatZObjectListBaser r r r r Ú<module> s(
þ ÿ