ruạṛ
a ���fK � @ sd d dl Z d dlZd dlZG dd� de j�ZG dd� dej�Zdd� Zdd d �Zdd d�Z dd� Z dS )� Nc @ s e Zd ZdZdZdZdZdS )� PluginState� � � � N)�__name__� __module__� __qualname__�starting�running�stopped�error� r r �1/sparta/input/plugins/osms/agent/shared/common.pyr s r c s$ e Zd Z� fdd�Zdd� Z� ZS )�StoppableThreadc s& t � j|i |�� d| _t�� | _d S )NT)�super�__init__�daemon� threading�Event� _stop_event)�self�args�kwargs�� __class__r r r s zStoppableThread.__init__c C s | j �� d S �N)r �set)r r r r �stop s zStoppableThread.stop)r r r r r � __classcell__r r r r r s r c C s2 d}d}dt | �v r"||kr.|}n ||kr.|}|S )Ni� i�: z403 Client Error)�repr)r �check_interval� default_circuit_breaker_timeout�!no_policy_circuit_breaker_timeoutr r r �circuit_breaker s r$ � � �G� c C s� t � � �`}| |krZz*|�d| f� |�� d W W d � S tyV | d7 } Y q 0 q W d � n1 sn0 Y td��d S )N� r zNo free ports in range.)�socket�bind� getsockname�OSError�IOError)�port�max_port� new_socketr r r �get_random_open_port' s .r0 r c C s | d ur| � � | �|� d S r )r �join)�thread�timeoutr r r � stop_thread2 s r4 c C sB | � di �� dg �}|D ]$}|� d�dkr|� d�dk S qdS )N� agentConfig� pluginsConfig�namezOS Management Hub Agent� desiredState�ENABLEDF)�get)�instance_metadata�plugins_config� plugin_configr r r �is_plugin_oci_osmh_enabled8 s r> )r% r& )r ) �enumr( r �Enumr �Threadr r$ r0 r4 r> r r r r �<module> s
cải xoăn