| Server IP : 192.250.235.158 / Your IP : 216.73.216.143 Web Server : LiteSpeed System : Linux s4099.sgp1.stableserver.net 5.14.0-503.21.1.el9_5.x86_64 #1 SMP PREEMPT_DYNAMIC Sun Jan 12 09:45:05 EST 2025 x86_64 User : vmxfzbqj ( 1905) PHP Version : 8.3.31 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /lib/python3.9/site-packages/supervisor/__pycache__/ |
Upload File : |
a
0�g]K � @ s� d dl Z d dlmZ d dlmZ d dlmZ d dlmZ d dlm Z d dlm
Z
d dlm Z d d l m
Z
d d
l mZ d d lmZ G d d
� d
�ZG dd� de�ZG dd� de�ZG dd� de�ZdZdZdd� ZG dd� de�Zdd� ZdS ) � N)�find_prefix_at_end)�compact_traceback)� as_string)�notify)�EventRejectedEvent)�ProcessLogStderrEvent)�ProcessLogStdoutEvent)�EventListenerStates)� getEventListenerStateDescription)�loggersc @ s\ e Zd ZdZdZdd� Zdd� Zdd� Zd d
� Zd d � Z d
d� Z
dd� Z dd� Z dd� Z
dS )� PDispatcherz{ Asyncore dispatcher for mainloop, representing a process channel
(stdin, stdout, or stderr). This class is abstract. Fc C s || _ || _|| _d| _d S �NF)�process�channel�fd�closed��selfr r r � r �:/usr/lib/python3.9/site-packages/supervisor/dispatchers.py�__init__ s zPDispatcher.__init__c C s d| j jt| �| j| jf S )Nz<%s at %s for %s (%s)>)� __class__�__name__�idr r �r r r r �__repr__ s
�zPDispatcher.__repr__c C s t �d S �N��NotImplementedErrorr r r r �readable s zPDispatcher.readablec C s t �d S r r r r r r �writable# s zPDispatcher.writablec C s t �d S r r r r r r �handle_read_event& s z PDispatcher.handle_read_eventc C s t �d S r r r r r r �handle_write_event) s z PDispatcher.handle_write_eventc C s< t � \}}}}| jjjj�dt| �|||f � | �� d S )Nz:uncaptured python exception, closing channel %s (%s:%s %s))r r �config�options�loggerZcritical�repr�close)r Znil�t�vZtbinfor r r � handle_error, s ��zPDispatcher.handle_errorc C s, | j s(| jjjj�d| j| f � d| _ d S )Nz#fd %s closed, stopped monitoring %sT)r r r# r$ r% �debugr r r r r r' 9 s
�zPDispatcher.closec C s d S r r r r r r �flush? s zPDispatcher.flushN)r �
__module__� __qualname__�__doc__r r r r r r! r" r* r' r, r r r r r s
r c @ s| e Zd ZdZdZdZdZdZdZdd� Z dd� Z
d d
� Z d d � Z d
d� Z
dd� Zdd� Zdd� Zdd� Zdd� Zdd� ZdS )�POutputDispatcherae
Dispatcher for one channel (stdout or stderr) of one process.
Serves several purposes:
- capture output sent within <!--XSUPERVISOR:BEGIN--> and
<!--XSUPERVISOR:END--> tags and signal a ProcessCommunicationEvent
by calling notify(event).
- route the output to the appropriate log handlers as specified in the
config.
NF� c C s� || _ || _|| _| jj| _| �� | �� | j| _| jj}| jj }|t
|�f| _ |t
|�f| _ t
jj| _| j j}|jj| jk| _|j| _|j| _dS )z�
Initialize the dispatcher.
`event_type` should be one of ProcessLogStdoutEvent or
ProcessLogStderrEvent
N)r �
event_typer r �_init_normallog�_init_capturelog� normallog�childlogZ BEGIN_TOKENZ END_TOKEN�len�begintoken_data�
endtoken_datar Z LevelsByNameZDEBG�
mainlog_levelr# r$ Zloglevel�log_to_mainlog�stdout_events_enabled�stderr_events_enabled)r r r2 r Z
begintokenZendtokenr# r r r r T s
zPOutputDispatcher.__init__c C s� | j j}| j}t|d| �}t|d| �}t|d| �}t|d| �}|sN|rZ|j�� | _|rztj| j|d| ||d� |r�tj | j|j
d d� d S )
z�
Configure the "normal" (non-capture) log for this channel of this
process. Sets self.normallog if logging is enabled.
�
%s_logfile�%s_logfile_maxbytes�%s_logfile_backupsz %s_syslog� %(message)s)�filename�fmt�rotating�maxbytes�backupsz %(message)s)rC N) r r# r �getattrr$ � getLoggerr5 r � handle_fileZ
handle_syslog�name)r r# r �logfilerE rF Z to_syslogr r r r3 p s, � �z!POutputDispatcher._init_normallogc C s> t | jjd| j �}|r:| jjj�� | _tj| jd|d� dS )z�
Configure the capture log for this process. This log is used to
temporarily capture output when special output is detected.
Sets self.capturelog if capturing is enabled.
z%s_capture_maxbytesrA )rC rE N) rG r r# r r$ rH �
capturelogr Zhandle_boundIO)r Zcapture_maxbytesr r r r4 � s ��z"POutputDispatcher._init_capturelogc C s: | j | jfD ](}|d ur |jD ]}|�� |�� q q d S r )r5 rL �handlers�remove�reopen�r �log�handlerr r r �
removelogs� s
z POutputDispatcher.removelogsc C s2 | j | jfD ] }|d ur |jD ] }|�� q q d S r )r5 rL rM rO rP r r r �
reopenlogs� s
z POutputDispatcher.reopenlogsc C s� |r�| j j}|jjr t|�}| jr.| j�|� | jr�t|t �sD|}n*z|�
d�}W n t yl d| }Y n0 d}|jj j
| j||j| j|d� | jdkr�| jr�tt| j | j j|�� n | jr�tt| j | j j|�� d S )Nzutf-8�Undecodable: %rz%%(name)r %(channel)s output:
%(data)s)rJ r �data�stdout)r r# r$ �
strip_ansi� stripEscapesr6 �infor; �
isinstance�bytes�decode�UnicodeDecodeErrorr% rQ r: rJ r r< r r �pidr= r )r rV r# �text�msgr r r �_log� s>
�
����zPOutputDispatcher._logc C s� | j d u r$| j}d| _| �|� d S | jr6| j\}}n
| j\}}t| j�|krRd S | j}d| _z|�|d�\}}W nR ty� d }t ||�}|r�| j|| d � | _|d | � }| �|� Y n0 | �|� | �
� || _|r�| � � d S )Nr1 � ) rL �
output_bufferrb � capturemoder9 r8 r7 �split�
ValueErrorr �toggle_capturemode�
record_output)r rV �token�tokenlen�beforeZafter�indexr r r ri � s4
z POutputDispatcher.record_outputc C s� | j | _ | jd ur�| j r$| j| _n�| jjD ] }|�� q,| j�� }| j}| jjj }| �
| j| jj |�}t |� d}| jjj
jj|||d� | jjD ]}|�� |�� q�| j| _d S )Nz-%(procname)r %(channel)s emitted a comm event)�procnamer )re rL r6 rM r, �getvaluer r r# rJ r2 r_ r r$ r% r+ rN rO r5 )r rR rV r rn �eventra r r r rh � s(
�
z$POutputDispatcher.toggle_capturemodec C s dS r
r r r r r r s zPOutputDispatcher.writablec C s | j r
dS dS �NFT�r r r r r r s zPOutputDispatcher.readablec C s8 | j jj�| j�}| j|7 _| �� |s4| �� d S r )r r# r$ �readfdr rd ri r' )r rV r r r r! s
z#POutputDispatcher.handle_read_event)r r- r. r/ r6 r5 rL re rd r r3 r4 rS rT rb ri rh r r r! r r r r r0 B s" $r0 c @ sx e Zd ZdZdZdZdZdZee�Z ee�Z
dd� Z dd � Z d
d � Z
d d
� Zdd� Zdd� Zdd� Zdd� Zdd� ZdS )�PEventListenerDispatcherzN An output dispatcher that monitors and changes a process'
listener_state Nr1 s READY
s RESULT c C s� t �| |||� tj| j_d | j_d| _d | _t |j
d| �}|r�t |j
d| �}t |j
d| �}|j
j � � | _
tj| j
|d| ||d� d S )Nr1 r> r? r@ rA )rD rE rF )r r r � ACKNOWLEDGEDr �listener_staterp �result� resultlenrG r# r$ rH r6 r rI )r r r r rK rE rF r r r r & s$
�z!PEventListenerDispatcher.__init__c C s, | j d ur(| j jD ]}|�� |�� qd S r )r6 rM rN rO �r rR r r r rS > s
z#PEventListenerDispatcher.removelogsc C s$ | j d ur | j jD ] }|�� qd S r )r6 rM rO ry r r r rT D s
z#PEventListenerDispatcher.reopenlogsc C s dS r
r r r r r r J s z!PEventListenerDispatcher.writablec C s | j r
dS dS rq rr r r r r r M s z!PEventListenerDispatcher.readablec C s� | j jj�| j�}|rx| j|7 _| j jj}d|| j|f }| j jjj� |� | j
r�| j jjj rjt |�}| j
�
|� n| �� | �� d S )Nz%r %s output:
%s)r r# r$ rs r � state_bufferrJ r r% r+ r6 rX rY rZ r' � handle_listener_state_change)r rV rn ra r r r r! R s
z*PEventListenerDispatcher.handle_read_eventc
C sX | j }|sd S | j}|jj}|j}|tjkr6d| _ d S |tjkr�t|�| j k rRd S |�
| j �r�| � tj
� | j }| j |d � | _ d |_n| � tj� d| _ d |_| j r�| �� nd S �n�|tj
kr�| � tj� d| _ d |_d S |tjk�rT| jd u �r�|�d�}|dk�rd S | j d |� }| j |d d � | _ || jd � }zt|�| _W n� t�y� z t|�}W n t�y� d| }Y n0 |jjj�d||f � | � tj� d| _ tt ||j�� d |_Y d S 0 nt| jt| j � } | �r | j | j d | � 7 _ | j | d � | _ | jt| j � } | �sD| � | j � d | j_d| _ d | _| j �rT| �� d S )Nr1 �
���rc rU z%s: bad result line: '%s') rz r r# rJ rv r �UNKNOWNru r7 �READY_FOR_EVENTS_LEN�
startswith�READY_FOR_EVENTS_TOKEN�_change_listener_stateZREADYrp r{ ZBUSYrx �find�RESULT_TOKEN_START_LEN�intrg r r^ r$ r% �warnr r rw �
handle_result)
r rV r rn �staterk �posZ result_linerx Zneededr r r r{ f s~
�
z5PEventListenerDispatcher.handle_listener_state_changec C s� | j }|jj}|jjj}z2| j jj�|j|� |�d| � | � t
j � W np t y� |�
d| � | � t
j � tt||j�� Y n6 |�
d| � | � t
j� tt||j�� Y n0 d S )Nz%s: event was processedz%s: event was rejectedz%s: event caused an error)r r# rJ r$ r% �groupZresult_handlerrp r+ r� r ru � RejectEventr� r r r~ )r rw r rn r% r r r r� � s
z&PEventListenerDispatcher.handle_resultc C sf | j }|jj}|j}d|t|�t|�f }|jjj�|� ||_|tj krbd| }|jjj�
|� d S )Nz %s: %s -> %sz�%s: has entered the UNKNOWN state and will no longer receive events, this usually indicates the process violated the eventlistener protocol) r r# rJ rv r
r$ r% r+ r r~ r� )r Z new_stater rn Z old_statera r r r r� � s �
�z/PEventListenerDispatcher._change_listener_state)r r- r. r/ r6 rz r� ZRESULT_TOKEN_STARTr7 r r� r rS rT r r r! r{ r� r� r r r r rt s Wrt c @ s8 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd S )
�PInputDispatcherz Input (stdin) dispatcher c C s t �| |||� d| _d S )Nr1 )r r � input_bufferr r r r r � s zPInputDispatcher.__init__c C s | j r| jsdS dS )NTF)r� r r r r r r � s zPInputDispatcher.writablec C s dS r
r r r r r r � s zPInputDispatcher.readablec C s* | j jj�| j| j�}| j|d � | _d S r )r r# r$ �writer r� )r �sentr r r r, � s �zPInputDispatcher.flushc
C s^ | j rZz | �� W nF tyX } z.|jd tjkrBd| _ | �� n� W Y d }~n
d }~0 0 d S )Nr r1 )r� r, �OSError�args�errnoZEPIPEr' )r �whyr r r r" � s
z#PInputDispatcher.handle_write_eventN) r r- r. r/ r r r r, r" r r r r r� � s r� s [)� H� f� A� B� C� D� R� s� u� J� K� h� l� p� mc C s� d}d}d}t | �}||k r�|dkr>| ||d � tv r>d}n@|r~| �t|�}|dkrf|| |d� S || ||� }|}d}|d7 }q|S )z>
Remove all ANSI color escapes from the given string.
r1 rc r r} N)r7 �ANSI_TERMINATORSr� �ANSI_ESCAPE_BEGIN)�srw Zshow�i�L�nr r r rY s
rY c @ s e Zd ZdZdS )r� zY The exception type expected by a dispatcher when a handler wants
to reject an event N)r r- r. r/ r r r r r� s r� c C s |dkrt |��d S )Ns OK)r� )rp Zresponser r r �default_handler s r� )r� Z supervisor.medusa.asynchat_25r Z supervisor.medusa.asyncore_25r Zsupervisor.compatr Zsupervisor.eventsr r r r Zsupervisor.statesr r
Z
supervisorr r r0 rt r� r� r� rY � Exceptionr� r� r r r r �<module> s* 4 Z H