File manager - Edit - /home/newsbmcs.com/public_html/static/img/logo/daemon.tar
Back
__pycache__/poll_for_pro_license.cpython-310.pyc 0000644 00000006070 15027667671 0015677 0 ustar 00 o �ϴf� � @ s� d dl Z d dlZd dlmZmZmZmZmZ d dlm Z d dl m Z d dl m Z d dlmZ d dlmZ d dlmZ d d lmZ e �e�e��Zd ed e fd d �Zd efdd�ZdS )� N)�actions� exceptions�lock�system�util)� _is_attached)�AutoAttachCloudInstance)�UAAutoAttachAzureInstance)�UAAutoAttachGCPInstance)�cloud_instance_factory)�UAConfig)�retry_auto_attach�cfg�cloudc C s� z t jdd�� t�| |� W d � n1 sw Y W n' tyE } zt�|� t �� t�d� t � t j � W Y d }~d S d }~ww t�d� d S )Nz pro.daemon.attempt_auto_attach)� lock_holderz%creating flag file to trigger retrieszSuccessful auto attach) r � RetryLockr � auto_attach� Exception�LOG�error�clear_lock_file_if_present�infor � create_filer �FLAG_FILE_PATH)r r �e� r �F/usr/lib/python3/dist-packages/uaclient/daemon/poll_for_pro_license.py�attempt_auto_attach s �� ��r c s� t j| jdd�rt�d� d S t| �jrt�d� d S t�� s&t�d� d S zt � � W n t j y; t�d� Y d S w t � fdd�t tfD ��}|sRt�d � d S � �� s]t�d � d S z� jd d �}W n t jyu t�d � Y d S t jy~ Y n w |r�t| � � d S | js�t�d� d S zt�� }� jdd �}t�� }W n t jy� t�d � Y d S t jy� t�| j� Y q�w t| �jr�t�d� d S |r�t| � � d S || dk r�t�d| j� t�| j� q�q�)Nz features.disable_auto_attach)�config� path_to_valuez,Configured to not auto attach, shutting downz Already attached, shutting downzNot on LTS, shutting downzNot on cloud, shutting downc 3 s � | ]}t � |�V qd S )N)� isinstance)�.0�cloud_instance�r r r � <genexpr>0 s � � �z'poll_for_pro_license.<locals>.<genexpr>z.Not on supported cloud platform, shutting downz(Not on supported instance, shutting downF)�wait_for_changezCancelling pollingz5Configured to not poll for pro license, shutting downT� zdwait_for_change returned quickly and no pro license present. Waiting %d seconds before polling again)r �is_config_value_truer r r r � is_attachedr �is_current_series_ltsr r �CloudFactoryError�anyr r �should_poll_for_pro_license�is_pro_license_present�CancelProLicensePolling�DelayProLicensePollingr �poll_for_pro_license�time�sleep�polling_error_retry_delay)r �is_supported_cloud�pro_license_present�start�endr r# r r0 s� � � �� � � � � � �r0 ) �loggingr1 �uaclientr r r r r �(uaclient.api.u.pro.status.is_attached.v1r �uaclient.cloudsr �uaclient.clouds.azurer �uaclient.clouds.gcpr �uaclient.clouds.identityr �uaclient.configr �uaclient.daemonr � getLogger� replace_top_level_logger_name�__name__r r r0 r r r r �<module> s __pycache__/__init__.cpython-310.pyc 0000644 00000002320 15027667671 0013232 0 ustar 00 o �ϴf� � @ s� d dl Z d dlZd dlmZ d dlmZmZmZ d dlm Z d dl m Z e � e� e��Zej�e dd�Zdd � Zd d � Zd e fd d�ZdS )� N)�TimeoutExpired)� exceptions�system�util)�UAConfig)�DEFAULT_DATA_DIR�messageszmotd-auto-attach-statusc C �T z t jg d�dd� W d S tjtfy) } ztj| | d� W Y d } ~ d S d } ~ ww )N)� systemctl�start�ubuntu-advantage.service� @��timeout��exc_info�r �subpr �ProcessExecutionErrorr �LOG�warning��e� r �:/usr/lib/python3/dist-packages/uaclient/daemon/__init__.pyr � � ��r c C r )N)r �stopr r r r r r r r r r r r �cfgc C s ddl m} |�| � d S )Nr )�retry_auto_attach)�uaclient.daemonr �cleanup)r r r r r r " s r )�logging�os� subprocessr �uaclientr r r �uaclient.configr �uaclient.defaultsr � getLogger� replace_top_level_logger_name�__name__r �path�join� AUTO_ATTACH_STATUS_MOTD_FILEr r r r r r r �<module> s � __pycache__/retry_auto_attach.cpython-310.pyc 0000644 00000010142 15027667671 0015215 0 ustar 00 o �ϴfU � @ s� d dl Z d dlZd dlZd dlmZmZmZmZmZ d dl mZ d dl m Z m Z d dlmZ d dlmZ d dlmZ d dlmZmZ e�e�e��Zg d �Zd Z d e d e fd d�Z defdd�Z ded dfdd�Z!dS )� N)� exceptions�lock�messages�system�util)r )�FullAutoAttachOptions�full_auto_attach)� _is_attached)�UAConfig)� AUTO_ATTACH_STATUS_MOTD_FILE)�notices� state_files)� r i i i i@8 �p r �Q r � � r �� r � F r 逗 r z./run/ubuntu-advantage/flags/auto-attach-failed�e�returnc C s� t | tj�rtjj| jd�S t | tj�rtjS t | tj �r%tj j| j d�S t | tj �r3tj j| jd�S t | tj�rItjj| jd�d�t| j�� S t | tj�rUd�| j�S tjd| d� t| �pbtjS ) N)�detail)�pid)� error_msg)�urlz: "{}"z"{}"zUnexpected exception)�exc_info)� isinstance�api_exceptions�InvalidProImager �$RETRY_ERROR_DETAIL_INVALID_PRO_IMAGE�formatr �NonAutoAttachImageError�(RETRY_ERROR_DETAIL_NON_AUTO_ATTACH_IMAGE� LockHeldError� RETRY_ERROR_DETAIL_LOCK_HELDr �ContractAPIError�%RETRY_ERROR_DETAIL_CONTRACT_API_ERROR�body�ConnectivityError� RETRY_ERROR_DETAIL_URL_ERROR_URLr �str� cause_error�UbuntuProError�msg�LOG�error� UNKNOWN_ERROR)r � r1 �C/usr/lib/python3/dist-packages/uaclient/daemon/retry_auto_attach.py�,full_auto_attach_exception_to_failure_reason) s, � � �� r3 �cfgc C s> t j�� t j�� t�t� t�tj j � t�tj j � d S )N) r � retry_auto_attach_state_file�delete� retry_auto_attach_options_filer �ensure_file_absentr r �remove�Notice� AUTO_ATTACH_RETRY_FULL_NOTICE� AUTO_ATTACH_RETRY_TOTAL_FAILURE)r4 r1 r1 r2 �cleanupA s ��r= c C s� t | �jrd S tj�� }|d ur |j}t|d � }|j}nd}t}d }t|�D ]�\}}t j � t j j �}|t j |d� }|jddd�}tj�tj|| |d�� |} | d u rXtj} z|�� }W n tyg Y nw tjj|| d | |�� d�} t�td| d � z)tj d d �� t j t j j || d | |�� d� W d � n1 s�w Y W n t!j"y� Y nw t#�$|� t | �jr� naztj%�� } t&� } | d ur�| j'| _'| j(| _(t)| � W nE t*j+y� t,�-d � Y n6 t*j.�y } z t,�/| j0� W Y d } ~ n d } ~ w t�y! } zt1| �}t,�2| � W Y d } ~ q'd } ~ ww t3| � t | �j�sitj�tjt4t�|d�� |} | d u �rCtj} tj5jt4t�d | d �} t�td| d � t j t j j6t4t�d | d � d S d S ) Nr )�seconds)�second� microsecond)�interval_index�failure_reason� )� num_attempts�reason�next_run_datestring� z z+pro.daemon.retry_auto_attach.notice_updates)� lock_holderz&already attached, ending retry service)rD rE )7r � is_attachedr r5 �readrA �RETRY_INTERVALSrB � enumerate�datetime�now�timezone�utc� timedelta�replace�write�RetryAutoAttachStater r0 � astimezone� Exception�AUTO_ATTACH_RETRY_NOTICEr � isoformatr � write_filer r � RetryLockr �addr: r; r r# �time�sleepr7 r �enable� enable_betar r �AlreadyAttachedErrorr. �info�EntitlementsNotEnabledError�warningr- r3 r/ r= �len�&AUTO_ATTACH_RETRY_TOTAL_FAILURE_NOTICEr< )r4 �persisted_state�offset� intervalsrB �index�interval� last_attempt� next_attempt� msg_reason�auto_attach_status_msg�persisted_options�optionsr r1 r1 r2 �retry_auto_attachM s� �� � � �� � �� � � ��� �� �� � ��rq )"rM �loggingr\ �uaclientr r r r r � uaclient.apir �2uaclient.api.u.pro.attach.auto.full_auto_attach.v1r r �(uaclient.api.u.pro.status.is_attached.v1r �uaclient.configr �uaclient.daemonr �uaclient.filesr r � getLogger� replace_top_level_logger_name�__name__r. rK �FLAG_FILE_PATHrV r* r3 r= rq r1 r1 r1 r2 �<module> s poll_for_pro_license.py 0000644 00000007257 15027667671 0011350 0 ustar 00 import logging import time from uaclient import actions, exceptions, lock, system, util from uaclient.api.u.pro.status.is_attached.v1 import _is_attached from uaclient.clouds import AutoAttachCloudInstance from uaclient.clouds.azure import UAAutoAttachAzureInstance from uaclient.clouds.gcp import UAAutoAttachGCPInstance from uaclient.clouds.identity import cloud_instance_factory from uaclient.config import UAConfig from uaclient.daemon import retry_auto_attach LOG = logging.getLogger(util.replace_top_level_logger_name(__name__)) def attempt_auto_attach(cfg: UAConfig, cloud: AutoAttachCloudInstance): try: with lock.RetryLock(lock_holder="pro.daemon.attempt_auto_attach"): actions.auto_attach(cfg, cloud) except Exception as e: LOG.error(e) lock.clear_lock_file_if_present() LOG.info("creating flag file to trigger retries") system.create_file(retry_auto_attach.FLAG_FILE_PATH) return LOG.info("Successful auto attach") def poll_for_pro_license(cfg: UAConfig): if util.is_config_value_true( config=cfg.cfg, path_to_value="features.disable_auto_attach" ): LOG.info("Configured to not auto attach, shutting down") return if _is_attached(cfg).is_attached: LOG.info("Already attached, shutting down") return if not system.is_current_series_lts(): LOG.info("Not on LTS, shutting down") return try: cloud = cloud_instance_factory() except exceptions.CloudFactoryError: LOG.info("Not on cloud, shutting down") return is_supported_cloud = any( isinstance(cloud, cloud_instance) for cloud_instance in ( UAAutoAttachGCPInstance, UAAutoAttachAzureInstance, ) ) if not is_supported_cloud: LOG.info("Not on supported cloud platform, shutting down") return if not cloud.should_poll_for_pro_license(): LOG.info("Not on supported instance, shutting down") return try: pro_license_present = cloud.is_pro_license_present( wait_for_change=False ) except exceptions.CancelProLicensePolling: LOG.info("Cancelling polling") return except exceptions.DelayProLicensePolling: # Continue to polling loop anyway and handle error there if it occurs # again pass else: if pro_license_present: attempt_auto_attach(cfg, cloud) return if not cfg.poll_for_pro_license: LOG.info("Configured to not poll for pro license, shutting down") return while True: try: start = time.time() pro_license_present = cloud.is_pro_license_present( wait_for_change=True ) end = time.time() except exceptions.CancelProLicensePolling: LOG.info("Cancelling polling") return except exceptions.DelayProLicensePolling: time.sleep(cfg.polling_error_retry_delay) continue else: if _is_attached(cfg).is_attached: # This could have changed during the long poll or sleep LOG.info("Already attached, shutting down") return if pro_license_present: attempt_auto_attach(cfg, cloud) return if end - start < 10: LOG.info( "wait_for_change returned quickly and no pro license" " present. Waiting %d seconds before polling again", cfg.polling_error_retry_delay, ) time.sleep(cfg.polling_error_retry_delay) continue retry_auto_attach.py 0000644 00000014525 15027667671 0010667 0 ustar 00 import datetime import logging import time from uaclient import exceptions, lock, messages, system, util from uaclient.api import exceptions as api_exceptions from uaclient.api.u.pro.attach.auto.full_auto_attach.v1 import ( FullAutoAttachOptions, full_auto_attach, ) from uaclient.api.u.pro.status.is_attached.v1 import _is_attached from uaclient.config import UAConfig from uaclient.daemon import AUTO_ATTACH_STATUS_MOTD_FILE from uaclient.files import notices, state_files LOG = logging.getLogger(util.replace_top_level_logger_name(__name__)) RETRY_INTERVALS = [ 900, # 15m (T+15m) 900, # 15m (T+30m) 1800, # 30m (T+1h) 3600, # 1h (T+2h) 7200, # 2h (T+4h) 14400, # 4h (T+8h) 28800, # 8h (T+16h) 28800, # 8h (T+1d) 86400, # 1d (T+2d) 86400, # 1d (T+3d) 172800, # 2d (T+5d) 172800, # 2d (T+7d) 259200, # 3d (T+10d) 259200, # 3d (T+13d) 345600, # 4d (T+17d) 345600, # 4d (T+21d) 432000, # 5d (T+26d) 432000, # 5d (T+31d) ] FLAG_FILE_PATH = "/run/ubuntu-advantage/flags/auto-attach-failed" def full_auto_attach_exception_to_failure_reason(e: Exception) -> str: if isinstance(e, api_exceptions.InvalidProImage): return messages.RETRY_ERROR_DETAIL_INVALID_PRO_IMAGE.format( detail=e.error_msg ) elif isinstance(e, api_exceptions.NonAutoAttachImageError): return messages.RETRY_ERROR_DETAIL_NON_AUTO_ATTACH_IMAGE elif isinstance(e, api_exceptions.LockHeldError): return messages.RETRY_ERROR_DETAIL_LOCK_HELD.format(pid=e.pid) elif isinstance(e, api_exceptions.ContractAPIError): return messages.RETRY_ERROR_DETAIL_CONTRACT_API_ERROR.format( error_msg=e.body ) elif isinstance(e, api_exceptions.ConnectivityError): return messages.RETRY_ERROR_DETAIL_URL_ERROR_URL.format( url=e.url ) + ': "{}"'.format(str(e.cause_error)) elif isinstance(e, api_exceptions.UbuntuProError): return '"{}"'.format(e.msg) else: LOG.error("Unexpected exception", exc_info=e) return str(e) or messages.UNKNOWN_ERROR def cleanup(cfg: UAConfig): state_files.retry_auto_attach_state_file.delete() state_files.retry_auto_attach_options_file.delete() system.ensure_file_absent(AUTO_ATTACH_STATUS_MOTD_FILE) notices.remove( notices.Notice.AUTO_ATTACH_RETRY_FULL_NOTICE, ) notices.remove( notices.Notice.AUTO_ATTACH_RETRY_TOTAL_FAILURE, ) def retry_auto_attach(cfg: UAConfig) -> None: # in case we got started while already attached somehow if _is_attached(cfg).is_attached: return # pick up where we left off persisted_state = state_files.retry_auto_attach_state_file.read() if persisted_state is not None: # skip intervals we've already waited offset = persisted_state.interval_index intervals = RETRY_INTERVALS[offset:] failure_reason = persisted_state.failure_reason else: offset = 0 intervals = RETRY_INTERVALS failure_reason = None for index, interval in enumerate(intervals): last_attempt = datetime.datetime.now(datetime.timezone.utc) next_attempt = last_attempt + datetime.timedelta(seconds=interval) next_attempt = next_attempt.replace(second=0, microsecond=0) state_files.retry_auto_attach_state_file.write( state_files.RetryAutoAttachState( interval_index=offset + index, failure_reason=failure_reason, ) ) msg_reason = failure_reason if msg_reason is None: msg_reason = messages.UNKNOWN_ERROR try: next_attempt = next_attempt.astimezone() except Exception: pass auto_attach_status_msg = messages.AUTO_ATTACH_RETRY_NOTICE.format( num_attempts=offset + index + 1, reason=msg_reason, next_run_datestring=next_attempt.isoformat(), ) system.write_file( AUTO_ATTACH_STATUS_MOTD_FILE, "\n" + auto_attach_status_msg + "\n\n", ) try: with lock.RetryLock( lock_holder="pro.daemon.retry_auto_attach.notice_updates", ): notices.add( notices.Notice.AUTO_ATTACH_RETRY_FULL_NOTICE, num_attempts=offset + index + 1, reason=msg_reason, next_run_datestring=next_attempt.isoformat(), ) except exceptions.LockHeldError: pass time.sleep(interval) if _is_attached(cfg).is_attached: # We attached while sleeping - hooray! break try: persisted_options = ( state_files.retry_auto_attach_options_file.read() ) options = FullAutoAttachOptions() if persisted_options is not None: options.enable = persisted_options.enable options.enable_beta = persisted_options.enable_beta full_auto_attach(options) break except api_exceptions.AlreadyAttachedError: LOG.info("already attached, ending retry service") break except api_exceptions.EntitlementsNotEnabledError as e: LOG.warning(e.msg) break except Exception as e: failure_reason = full_auto_attach_exception_to_failure_reason(e) LOG.error(e) cleanup(cfg) if not _is_attached(cfg).is_attached: # Total failure!! state_files.retry_auto_attach_state_file.write( state_files.RetryAutoAttachState( interval_index=len(RETRY_INTERVALS), failure_reason=failure_reason, ) ) msg_reason = failure_reason if msg_reason is None: msg_reason = messages.UNKNOWN_ERROR auto_attach_status_msg = ( messages.AUTO_ATTACH_RETRY_TOTAL_FAILURE_NOTICE.format( num_attempts=len(RETRY_INTERVALS) + 1, reason=msg_reason ) ) system.write_file( AUTO_ATTACH_STATUS_MOTD_FILE, "\n" + auto_attach_status_msg + "\n\n", ) notices.add( notices.Notice.AUTO_ATTACH_RETRY_TOTAL_FAILURE, num_attempts=len(RETRY_INTERVALS) + 1, reason=msg_reason, ) __init__.py 0000644 00000001673 15027667671 0006705 0 ustar 00 import logging import os from subprocess import TimeoutExpired from uaclient import exceptions, system, util from uaclient.config import UAConfig from uaclient.defaults import DEFAULT_DATA_DIR LOG = logging.getLogger(util.replace_top_level_logger_name(__name__)) AUTO_ATTACH_STATUS_MOTD_FILE = os.path.join( DEFAULT_DATA_DIR, "messages", "motd-auto-attach-status" ) def start(): try: system.subp( ["systemctl", "start", "ubuntu-advantage.service"], timeout=2.0 ) except (exceptions.ProcessExecutionError, TimeoutExpired) as e: LOG.warning(e, exc_info=e) def stop(): try: system.subp( ["systemctl", "stop", "ubuntu-advantage.service"], timeout=2.0 ) except (exceptions.ProcessExecutionError, TimeoutExpired) as e: LOG.warning(e, exc_info=e) def cleanup(cfg: UAConfig): from uaclient.daemon import retry_auto_attach retry_auto_attach.cleanup(cfg)
| ver. 1.4 |
Github
|
.
| PHP 8.2.28 | Generation time: 0.02 |
proxy
|
phpinfo
|
Settings