| Server IP : 162.144.4.212 / Your IP : 216.73.216.108 Web Server : Apache System : Linux gator2125.hostgator.com 5.14.0-162.23.1.9991722448259.nf.el9.x86_64 #1 SMP PREEMPT_DYNAMIC Wed Jul 31 18:11:45 UTC 2024 x86_64 User : cozeellc ( 2980) PHP Version : 8.3.31 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /usr/libexec/oracle-cloud-agent/plugins/osms/agent/linux/ |
Upload File : |
a
���f�@ � @ s� d dl Zd dlZd dlZd dlZd dlZd dlZd dlZd dlm Z d dl
Z
d dl Z d dl Z d dl
Z
d dlZd dlmZmZ d dlmZ d dlZd dlZd dlmZmZ d dlmZ d dl Z d dl Z d dl Z d dl Z d dl!m"Z" dd l#m$Z$ dd
l%m&Z& dd l%m'Z' dd l%m(Z( dd
l)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/ e j0�1d�Z0ej0�2e0�3d��3d�� e0�3d��3d��3d��3d��3d�Z4e�5d�Z6e j7�8e6�Z7e(�9e�:� e$j;e7e6�Z<e"e6� da=da>da?dZ@daAdaBdZCddgZDe �E� ZFG dd� de e�ZGdd� ZHG dd � d e,�ZIG d d � d e jJ�ZKG d d � d e'jL�ZMdId"d#�ZNd$d%� ZOd&d'� ZPdJd)d*�ZQd+d,� ZRd-d.� ZSd/d0� ZTd1d2� ZUd3d4� ZVd5d6� ZWd7d8� ZXd9d:� ZYd;d<� ZZd=d>� Z[d?d@� Z\dAdB� Z]dCdD� Z^dEdF� Z_dGdH� Z`dS )K� N)�ThreadingMixIn)� make_server�
WSGIServer��
is_hop_by_hop)�
health_pb2�health_pb2_grpc)�HealthServicer)�is_fips_enabled� )�version)� oracle_cloud_agent_plugin_pb2)�"oracle_cloud_agent_plugin_pb2_grpc)� osmsx_ctl)� PluginState�circuit_breaker�StoppableThread�get_random_open_port� stop_thread�is_plugin_oci_osmh_enabledz//etc/oracle-cloud-agent/plugins/osms/config.yml�logging�agent�loggers�leveli�Q z6/var/lib/oracle-cloud-agent/plugins/osms/ca-bundle.crtz /etc/pki/tls/certs/ca-bundle.crtz"/etc/ssl/certs/ca-certificates.crtc @ s e Zd ZdS )�ThreadingWSGIServerN)�__name__�
__module__� __qualname__� r r �4/sparta/input/plugins/osms/agent/linux/osms_agent.pyr > s r c C sb t j�d�r^tdd��}|�� }W d � n1 s40 Y t�d|�}t�d| |�r^dS dS )Nz-/etc/oracle-cloud-agent/plugins/osms/systemid�rzOCID:(.*)</string>zOCID: %sTF)�os�path�isfile�open�read�re�search)�
instance_ocid� system_file� file_string�registered_ocidr r r �
ocid_checkB s & r, c @ s e Zd Zdd� Zdd� ZdS )�
ActionCheckerc
C s� t �d��d�}|}| j�� s�z"| �� |}t�d|� t� W n� ty� } z�|d9 }t ||�}dt
|�v r�t� d� zt ddg� W n0 ty� } zt�
d |� W Y d }~n
d }~0 0 t�
d
||� W Y d }~n
d }~0 0 | j�|� qd S ) Nr �check_intervalz<OSMS check completed successfully. Next check in %s seconds.r zFault -9z/Registration error. Attempting un-registration.�osms�
unregisterzUn-registration failed: %sz5Error checking actions (next check in %s seconds): %s)�config�get� _stop_event�is_set�check�logger�info�check_osmsx_ctl� Exceptionr �repr�debug�run_cmd�error�wait)�self�default_check_intervalr. �e�errr r r �runM s&
"$zActionChecker.runc C sh t � s&t�d� tddtddt� g� ttd �rNt�d� tddtdg� nt�d � tdd
g� d S ) Nzregister instancer/ z --log-level�registerz --server-url�idzCheck for actionsr5 zCOCID mismatch or systemid not detected. Attempting re-registration.r0 ) �instance_registeredr6 r; r< �loglevel�get_server_urlr, �instance_metadatar7 �r? r r r r5 e s
zActionChecker.checkN)r r r rC r5 r r r r r- L s r- c s, e Zd Z� fdd�Zdd� Zdd� Z� ZS )� ProxyServerc s" t � j|i |�� d| _d | _d S )NT)�super�__init__�daemon�_server)r? �args�kwargs�� __class__r r rM r s zProxyServer.__init__c C s� t �d��d�}|sd S tdkr8ttjd�}|t_|t_t �
� }|� t t
� |�t� t �d��d��d�}t �d��d��d�}t|||t�| _| j�� d S )Nr �proxy�DEBUG�w�host�port)r1 r2 rG r$ r! �devnull�sys�stdout�stderr�falcon�API�add_error_handlerr9 �internal_error_handler�add_sinkrT r r rO �
serve_forever)r? � agent_proxyrY � applicationrW rX r r r rC w s
zProxyServer.runc C s | j r| j �� | j �� d S �N)rO �shutdown� server_closerJ r r r �stop� s
zProxyServer.stop)r r r rM rC rh �
__classcell__r r rR r rK q s rK c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
�OsmsAgentPluginServicerc C s t �� | _tj| _g | _d S re )� threading�Lock� _state_lockr �stopped�_state� _messagesrJ r r r rM � s
z OsmsAgentPluginServicer.__init__c C s� t �d� t�� }d|_| jtjkr(|S | j�� zN| jtjkr|t t
�r^d}|g| _ t �|� nt � g | _ t �d� tj| _W n8 t
y� } z t �d|� t�� W Y d }~n
d }~0 0 W d � n1 s�0 Y |S )Nz'gRPC Start: starting OSMS Agent serviceTz8plugin osms does nothing when plugin oci-osmh is enabledz&gRPC Start: OSMS Agent service startedz&Failed to start OSMS Agent service: %s)r6 r7 r
�
StartResponse�successro r �runningrm r rI rp �start_osms_agent_serverr9 � exception�
EXIT_EVENT�set)r? �request�context�resp�messagerA r r r �Start� s(
<z OsmsAgentPluginServicer.Startc C s� t �d� t�� }d|_| j�t z*dg| _t� tj | _
g | _t �d� W n0 t yz } zt � d|� W Y d }~n
d }~0 0 t
�� W d � n1 s�0 Y |S )Nz&gRPC Stop: stopping OSMS Agent serviceT�Stopping OSMS Agent servicez%gRPC Stop: OSMS Agent service stoppedz%Failed to stop OSMS Agent service: %s)r6 r7 r
rq rr rm rp �stop_osms_agent_serverr rn ro r9 ru rv rw )r? rx ry rz rA r r r �Stop� s
"&z OsmsAgentPluginServicer.Stopc C sT t �dtj| jj| j� t�� }d|_tj|_| jj|_ | jD ]}|j
� |� q>|S )Nz2gRPC Status: version: %s, status: %s, messages: %sr/ ) r6 r; r � __version__ro �namerp r
�StatusResponse�status�messages�append)r? rx ry rz r{ r r r �Status� s �
z OsmsAgentPluginServicer.StatusN)r r r rM r| r r� r r r r rj � s rj �./etc/oracle-cloud-agent/plugins/osms/devconfigc
C s� i }t j�| �s|S zrt| ��V}|D ]@}|�d�r4q$|�dd�}t|�dkr$|d �� ||d �� < q$W d � n1 sz0 Y W n0 ty� } zt �
d|� W Y d }~n
d }~0 0 |S )N�#�=� r r zError getting devconfig: %s) r! r" �existsr$ �
startswith�split�len�stripr9 r6 r= )�cfg_file�cfg�f�line�fieldsrA r r r �
get_devconfig� s
<"r� c C s4 t | tjtjf�s"tjt| �d�} t�| � | �d S )N)� description)�
isinstancer] � HTTPError�
HTTPStatus�HTTPInternalServerError�strr6 ru )rA �reqrz �paramsr r r r` � s
r` c C s t �d��d�}| j�|�s$t�� �tj�t | j�}t
� }t j �
tt|d i �}dd� | j�� D �}tj| j|||| j�� |dd�}d�|j|j�|_|j|_ dd� |j�� D �}|� |� t� d |jj|jj � t� d
|jj� t� d |j� t� d |j� d S )
Nr �
endpoint_pathc S s* i | ]"\}}t |�s|�� d kr||�qS )rW )r �lower��.0�k�vr r r �
<dictcomp>� � zproxy.<locals>.<dictcomp>�x )�auth�verify�data�headers�timeoutz{} {}c S s i | ]\}}t |�s||�qS r r r� r r r r� � r� z request method and url: %s %szrequest headers: %szresponse status code: %szresponse headers: %s) r1 r2 � relative_urir� r] � HTTPNotFound�urllib�parse�urljoin�ENDPOINT�
get_ca_bundle�oci_agent_utils�instance_principal� get_instance_principal_signerr6 rI r� �items�requestsrx �method�bounded_streamr% �format� status_code�reasonr� �content�body� set_headersr; �url)r� rz r� �uri� ca_bundle�signerr� �responser r r rT � s0 �
rT �r c C s� |p| }t �d|� tj�� }d|v r4|d |d< n |�dd � tj| tjtjd|d�}|� � \}}|j
|vr�t d||j
||f ��t �d||� |� d�S ) Nzrun_cmd args: %s�LD_LIBRARY_PATH_ORIG�LD_LIBRARY_PATHT)r[ r\ � close_fds�envz.Command: %s failed (%s): stderr: %s stdout: %sz run_cmd stdout: %s, stderr: %s�utf-8)
r6 r; r! �environ�copy�pop�
subprocess�Popen�PIPE� communicate�
returncoder9 �decode)rP �success_return_code�logargs�new_env�proc�
stdoutdata�
stderrdatar r r r< s,
�
��r< c
C s` d} z&t � }t� }t�d||� ||k} W n0 tyZ } zt�d|� W Y d }~n
d }~0 0 | S )NFz%stored_server_url: %s, server_url: %sz%Error check instance registration: %s)rH �get_stored_server_urlr6 r; r9 )�
registered�
server_url�stored_server_urlrB r r r rF s "rF c C sX t �d�} | r| S td }t�d�r2td d }nt�d� d}t�d��d��||�S ) N�endpoint�canonicalRegionName�
regionInfo�realmDomainComponentz=No regionInfo key detected. Defaulting to oraclecloud domain.zoraclecloud.comr �endpoint_format)� DEVCONFIGr2 rI r6 �warningr1 r� )� dev_endpoint�region� realm_domainr r r � get_endpoint( s
r� c C sr t �d��d�} t �d��d�}|r>d�|�d�|�d��}n,t�d�}|sjtd }t �d��d ��|�}|| S )
Nr r� rT z http://{}:{}rW rX r� r� r� )r1 r2 r� r� rI )r� rc r� r� r r r rH 5 s
rH c C sT d } t d��4}|D ] }t�d|�}|r|�d�} qW d � n1 sF0 Y | S )Nz,/etc/oracle-cloud-agent/plugins/osms/up2datez ^serverURL=(?P<server_url>.*)$r� )r$ r& �match�group)r� �fobjr� r� r r r r� B s
*r� c
C sF zt �| � W n2 ty@ } z|jtjkr,� W Y d }~n
d }~0 0 d S re )r! �unlink�OSError�errno�ENOENT)�filepathrB r r r � remove_fileL s
r� c
C s8 t t� tD ]~} t�| tj�r ttddd��J}t| dd�� }|�|�� � W d � n1 s^0 Y W d � n1 s|0 Y q�q t �
d�t �
d��
d��
d�fD ]�}|r�t�|tj�r�ttddd��P}t|dd��"}|�d|�� � W d � n1 �s0 Y W d � q�1 �s(0 Y q�d S ) NrV r� )�encodingr� r �linux�a�
) r� �OSMS_CA_BUNDLE�SYSTEM_CA_BUNDLESr! �access�R_OKr$ �writer% r� r2 r1 )�system_ca_bundle� osms_bundle�
sys_bundle�
dev_ca_bundle�
dev_bundler r r �update_ca_bundleT s
�J$
�r c C s t �tt j�rtS d S re )r! r� r� r� r r r r r� e s r� c C s* zt g d�� W n ty$ Y dS 0 dS )N)�rpmz-qz al-configFT)r< r9 r r r r �is_autonomous_linuxk s
r c C s� t �d� t� } | �dtjj�d�� t� t
j j dd��a
t�t� t
� t�| t
� t� }t �d�|�� t
�d�|�� t
�� tj�d�|�� tj�� d S ) NzStarting gRPC serverr/ �SERVING�
)� max_workersz Binding to ephemeral port {} z 127.0.0.1:{}z1|1|tcp|127.0.0.1:{}|grpc
) r6 r7 r rw r �HealthCheckResponse�
ServingStatus�Value�grpc�server�
concurrent�futures�ThreadPoolExecutor� GRPC_SERVERr � add_pluginServicer_to_serverrj r � add_HealthServicer_to_serverr r; r� �add_insecure_port�startrZ r[ r� �flush)�healthrX r r r �start_grpc_servers s
r c C s& t d ur"t� t�d� t �d � d S )NzStopping gRPC server)r r~ r6 r7 rh r r r r �stop_grpc_server� s
r c C sR t � rt�d� d S t�d� t� at�� t�d� t�d� t� a t �� d S )Nz*Autonomous Linux is not supported by OSMS.zStarting proxy serverr� zStarting action checker)
r r6 r7 rK � PROXY_SERVERr �time�sleepr- �ACTION_CHECKERr r r r rt � s
rt c C s0 t �d� ttt� t �d� tt� t� d S )NzStopping action checkerzStopping proxy server)r6 r7 r r �ACTION_CHECKER_TIMEOUTr �disable_osmsx_ctlr r r r r~ � s
r~ c
C s\ z&t �dt�\} }|dkr$t�| � W n0 tyV } zt�d|� W Y d }~n
d }~0 0 d S )N�allr� zCheck osmsx_ctl failed: %s)r r5 � osmsx_paramsr6 r= r9 ��
osmsx_ctl_err�osmsx_ctl_exit_coderB r r r r8 � s r8 c
C sf z0t �d� t�dt�\} }|dkr.t �| � W n0 ty` } zt �d|� W Y d }~n
d }~0 0 d S )NzDisabling osmsx_ctlr r� z Disable osmsx_ctl failed: %s)r6 r7 r �disabler r= r9 r r r r r � s
r c C sr t � at� at� ddd�} t�tj| � t�tj| � t� d� t� dt
j � t � t
�� t� d� t� d S )Nc S s t �� d S re )rv rw )�sig�framer r r �signal_handler� s z main.<locals>.signal_handlerzStarting OSMS Agent servicezOSMS Version: %sr} )N)r� r� r� r� r �signal�SIGINT�SIGTERMr6 r7 r r� r rv r> r )r% r r r �main� s
r) )r� )r� N)a�concurrent.futuresr r� r �logging.configr! r& r& � socketserverr r� rZ rk r � urllib.parser� �wsgiref.simple_serverr r � wsgiref.utilr r] r �grpc_health.v1r r �grpc_health.v1.healthr r� �oci_agent_utils.configr� �!oci_agent_utils.instance_metadata�"oci_agent_utils.instance_principal�oci_agent_utils.fips.fipsr
� r �sharedr
r r �
shared.commonr r r r r r r1 � from_file�
dictConfigr2 rG � getLoggerr6 rI �InstanceMetadata� OsmsxParams�getpidr� r r� r� r r r r r� r� �Eventrv r r, r- �ThreadrK �pluginServicerrj r� r` rT r< rF r� rH r� r� r r� r r r rt r~ r8 r r) r r r r �<module> s� "
�
% =