Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/gunicorn/__pycache__/arbiter.cpython-39.pyc
Ðазад
a j�h�N � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlm Z m Z d dl m Z d dl mZmZmZ d dl mZmZ G dd� de�ZdS )� N)� HaltServer�AppImportError)�Pidfile)�sock�systemd�util)� __version__�SERVER_SOFTWAREc @ sb e Zd ZdZdZdZi Zg Zi Zg Z g Z dd� d� � D �Z e dd� ee�D ��Zd d � Zd d � Zd d� Zeee�Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd � Zd d � Z d d � Z d!d"� Z d#d$� Z d%d&� Z d'd(� Z!d)d*� Z"d+d,� Z#d-d.� Z$d/d0� Z%dLd3d4�Z&d5d6� Z'dMd8d9�Z(d:d;� Z)d<d=� Z*d>d?� Z+d@dA� Z,dBdC� Z-dDdE� Z.dFdG� Z/dHdI� Z0dJdK� Z1d1S )N�Arbiterz� Arbiter maintain the workers processes alive. It launches or kills them if needed. It also manages application reloading via SIGHUP/USR2. � � c C s g | ]}t td | ��qS )zSIG%s)�getattr�signal)�.0�x� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/gunicorn/arbiter.py� <listcomp>, s �zArbiter.<listcomp>z+HUP QUIT INT TERM TTIN TTOU USR1 USR2 WINCHc c sD | ]<}|d d� dkr|d dkrt t|�|dd � �� fV qd S )Nr ZSIG�_)r r �lower)r �namer r r � <genexpr>. s �zArbiter.<genexpr>c C s� t tjd< d | _d | _d | _| �|� d | _d| _d| _ d| _ d| _ d| _ t �� }tjd d � }|�dtj� ||tjd�| _d S )Nr Fr �Master)�args�cwdr )r �os�environ� _num_workers� _last_logged_active_worker_count�log�setup�pidfiler � worker_age� reexec_pid� master_pid� master_namer �getcwd�sys�argv�insert� executable� START_CTX)�self�appr r r r r �__init__3 s$ �zArbiter.__init__c C s | j S �N)r �r, r r r �_get_num_workersO s zArbiter._get_num_workersc C s | j }|| _ | j�| ||� d S r/ )r �cfgZnworkers_changed)r, �value� old_valuer r r �_set_num_workersR s zArbiter._set_num_workersc C s� || _ |j| _| jd u r(| j�|j�| _dtjv r<| j�� | jj| _| jj| _| jj | _ | jj | _ | jj | _ | j� d�d�dd� t| jj�� dd� d�D ���� | jjr�| jj�� D ]\}}|tj|< q�| jjr�| j �� d S ) N� GUNICORN_FDzCurrent configuration: {0}� c s s | ]\}}d � ||j�V qdS )z {0}: {1}N)�formatr3 )r �configr3 r r r r j s �z Arbiter.setup.<locals>.<genexpr>c S s | d S �N� r )Zsettingr r r �<lambda>n � z Arbiter.setup.<locals>.<lambda>��key)r- r2 r Z logger_classr r � reopen_files� worker_class�address�workers� num_workers�timeout� proc_name�debugr8 �join�sorted�settings�items�envZ preload_appZwsgi)r, r- �k�vr r r r X s. ��� z Arbiter.setupc C s� | j �dt� dtjv r<ttj�d��| _| jd | _d| _ t� � | _ | j j dur�| j j }| jdkrl|d7 }t|�| _ | j �| j � | j �| � | �� | j�sd}t�� }|r�d| _ttjtj| �}n0| jr�g }tj�d��d �D ]}|�t|�� q�t�| j | j |�| _d � d d � | jD ��}| j � d � | j �d || j � | j �d| j j � t� d| j � t | j!d��r�| j!�"| j | j � | j �#| � dS )zS Initialize the arbiter. Start listening and set pidfile if needed. zStarting gunicorn %s� GUNICORN_PIDz.2zMaster.2Nr Tr6 �,c S s g | ] }t |��qS r ��str�r �lr r r r � r= z!Arbiter.start.<locals>.<listcomp>zArbiter bootedzListening at: %s (%s)zUsing worker: %sz&READY=1 STATUS=Gunicorn arbiter booted� check_config)$r �infor r r �int�getr$ rF r% �getpid�pidr2 r! r �createZ on_starting� init_signals� LISTENERSr � listen_fds�rangeZSD_LISTEN_FDS_START�pop�split�appendr �create_socketsrH rG Zworker_class_strZ sd_notify�hasattrrA rU Z when_ready)r, Zpidname�fdsr^ �fd� listeners_strr r r �startx sF � z Arbiter.startc C sz | j D ]}t�|� qt�� | _ }|D ]}t�|� t�|� q(| j�� | jD ]}t � || j � qRt � t j | j � dS )z� Initialize master signal handling. Most of the signals are queued. Child signals only wake up the master. N) �PIPEr �close�piper Zset_non_blockingZ close_on_execr �SIGNALSr �SIGCHLD� handle_chld)r, �p�pair�sr r r r\ � s zArbiter.init_signalsc C s& t | j�dk r"| j�|� | �� d S )N� )�len� SIG_QUEUErb �wakeup�r, �sig�framer r r r � s zArbiter.signalc C s� | � � t�d| j � z�| �� | �� | jr<| j�d�nd}|du rb| �� | � � | �� q"|| j vr|| j � d|� q"| j � |�}t| d| d�}|s�| j �d|� q"| j � d|� |� | �� q"W n� ttfy� | �� Y n� t�y } z | j|j|jd� W Y d}~njd}~0 t�y4 � Y nN t�y� | j j d d d � | �d � | jdu�rr| j�� t � d � Y n0 dS )zMain master loop.� master [%s]r NzIgnoring unknown signal: %sz handle_%szUnhandled signal: %szHandling signal: %s)�reason� exit_statusz Unhandled exception in main loopT��exc_infoF���) rh r � _setproctitlerF �manage_workers�maybe_promote_masterrt r` �sleep�murder_workers� SIG_NAMESr rV rX r �errorru � StopIteration�KeyboardInterrupt�haltr rz r{ � SystemExit� Exception�stopr! �unlinkr' �exit)r, rw �signame�handler�instr r r �run� sH &� z Arbiter.runc C s | � � | �� dS )zSIGCHLD handlingN)� reap_workersru rv r r r rn � s zArbiter.handle_chldc C s | j �d| j� | �� dS )z� HUP handling. - Reload configuration - Start the new worker processes with a new configuration - Gracefully shutdown the old worker processes z Hang up: %sN)r rV r% �reloadr0 r r r � handle_hup� s zArbiter.handle_hupc C s t �dS )zSIGTERM handlingN)r� r0 r r r � handle_term� s zArbiter.handle_termc C s | � d� t�dS )zSIGINT handlingFN�r� r� r0 r r r � handle_int s zArbiter.handle_intc C s | � d� t�dS )zSIGQUIT handlingFNr� r0 r r r � handle_quit s zArbiter.handle_quitc C s | j d7 _ | �� dS )zR SIGTTIN handling. Increases the number of workers by one. r; N�rD r� r0 r r r � handle_ttin s zArbiter.handle_ttinc C s( | j dkrdS | j d8 _ | �� dS )zR SIGTTOU handling. Decreases the number of workers by one. r; Nr� r0 r r r � handle_ttou s zArbiter.handle_ttouc C s | j �� | �tj� dS )zU SIGUSR1 handling. Kill all workers by sending them a SIGUSR1 N)r r@ � kill_workersr �SIGUSR1r0 r r r � handle_usr1 s zArbiter.handle_usr1c C s | � � dS )z� SIGUSR2 handling. Creates a new master/worker set as a slave of the current master without affecting old workers. Use this to do live deployment with the ability to backout a change. N)�reexecr0 r r r � handle_usr2' s zArbiter.handle_usr2c C s8 | j jr(| j�d� d| _| �tj� n | j�d� dS )zSIGWINCH handlingzgraceful stop of workersr z SIGWINCH ignored. Not daemonizedN) r2 �daemonr rV rD r� r �SIGTERMrG r0 r r r � handle_winch0 s zArbiter.handle_winchc C st | j dkrd S | j t�� krp| j�d� d| _d| _ | jj| _tjd= | j d ur`| j � | jj � t � d| j � d S )Nr zMaster has been promoted.r rO ry ) r$ r �getppidr rV r% r2 rF r r! �renamer r r0 r r r r� 9 s z Arbiter.maybe_promote_masterc C sT zt �| jd d� W n8 tyN } z |jtjtjfvr:� W Y d}~n d}~0 0 dS )z; Wake up the arbiter by writing to the PIPE r; � .N)r �writeri �IOError�errno�EAGAIN�EINTR)r, �er r r ru J s zArbiter.wakeupNr c C s\ | � � | j�d| j� |dur.| j�d|� | jdurB| j�� | j�| � t� |� dS )z halt arbiter zShutting down: %sNz Reason: %s) r� r rV r% r! r� r2 Zon_exitr' r� )r, rz r{ r r r r� T s z Arbiter.haltc C s� z>t � | jd gg g d�}|d s(W dS t�| jd d�r<q(W nf t jtfy� } z0t|d|jd �}|tj tj fvrx� W Y d}~n"d}~0 t y� t � � Y n0 dS )zm Sleep until PIPE is readable or we timeout. A readable PIPE means a signal occurred. r g �?Nr; r� )�selectri r �readr� �OSErrorr r r� r� r� r� r' r� )r, �readyr� Z error_numberr r r r� _ s z Arbiter.sleepTc C s� | j | j kodkn o,| j o,| jj }t�| j|� g | _tj }|sRtj }t � � | jj }| � |� | jr�t � � |k r�t �d� ql| � tj� dS )z� Stop workers :attr graceful: boolean, If True (the default) workers will be killed gracefully (ie. trying to wait for the current connection) r 皙�����?N)r# r$ r r2 � reuse_portr Z close_socketsr] r r� �SIGQUIT�timeZgraceful_timeoutr� �WORKERSr� �SIGKILL)r, Zgracefulr� rw �limitr r r r� r s �� z Arbiter.stopc C s� | j dkr| j�d� dS | jdkr4| j�d� dS t�� }t�� | _ | j dkrTdS | j�| � | jj � � }t |�|d< | j r�t t�� �|d< t t | j��|d< nd�d d � | jD ��|d < t�| jd � t�| jd | jd |� dS )z1 Relaunch the master and workers. r z"USR2 signal ignored. Child exists.Nz#USR2 signal ignored. Parent exists.rO Z LISTEN_PIDZ LISTEN_FDSrP c s s | ]}t |�� �V qd S r/ )rR �filenorS r r r r � s z!Arbiter.reexec.<locals>.<genexpr>r6 r r )r# r �warningr$ r rY �forkr2 Zpre_exec�env_orig�copyrR r rs r] rH �chdirr+ �execvpe)r, r$ r r r r r� � s* � zArbiter.reexecc C sN | j j}| j jD ]D}|| j jv r4| j j| tj|< qz tj|= W q tyR Y q0 q| j�� | � | j� | j � � || j jkr�| j D ] }|� � q�t�| j | j �| _ d�dd� | j D ��}| j �d|� | j �| � | jd ur�| j�� | j jd u�rt| j j�| _| j�| j� t�d| j � t| j j �D ]}| � � �q2| � � d S )NrP c S s g | ] }t |��qS r rQ rS r r r r � r= z"Arbiter.reload.<locals>.<listcomp>zListening at: %sry ) r2 rB rL r� r r �KeyErrorr- r� r r r@ r] rj r rc rH rV Z on_reloadr! r� r r[ rZ r r rF r_ rC � spawn_workerr� )r, Z old_addressrM rT rg r r r r r� � s6 zArbiter.reloadc C s� | j s dS t| j�� �}|D ]|\}}z t�� |j�� | j krBW q W n ttfy^ Y q Y n0 |j s�| j � d|� d|_ | � |t j� q | � |t j� q dS )z) Kill unused/idle workers NzWORKER TIMEOUT (pid:%s)T)rE �listr� rK r� �tmpZ last_updater� � ValueErrorZabortedr �critical� kill_workerr �SIGABRTr� )r, rC rZ �workerr r r r� � s zArbiter.murder_workersc C s� z�t �dt j�\}}|sq�| j|kr,d| _q|d? }|| jkrNd}t|| j��|| jkrhd}t|| j��| j�|d�}|s|q|j � � | j � | |� qW n2 t y� } z|jtjkr�� W Y d}~n d}~0 0 dS )z7 Reap workers to avoid zombie processes r~ r � zWorker failed to boot.zApp failed to load.N)r �waitpid�WNOHANGr# �WORKER_BOOT_ERRORr �APP_LOAD_ERRORr� r` r� rj r2 Z child_exitr� r� ZECHILD)r, �wpid�status�exitcoderz r� r� r r r r� � s* zArbiter.reap_workersc C s� t | j�| jk r| �� | j�� }t|dd� d�}t |�| jkr^|�d�\}}| �|tj � q2t |�}| j |kr�|| _ | j j d� |�d|dd�d � d S ) z[ Maintain the number of workers by spawning or killing as required. c S s | d j S r: )Zage)�wr r r r< $ r= z(Arbiter.manage_workers.<locals>.<lambda>r> r z {0} workerszgunicorn.workersZgauge)Zmetricr3 �mtype)�extraN)rs r� rD � spawn_workersrK rI r` r� r r� r r rG r8 )r, rC rZ r Zactive_worker_countr r r r� s ��zArbiter.manage_workersc C s | j d7 _ | �| j | j| j| j| jd | j| j�}| j�| |� t � � }|dkrh||_|| j |< |S | j � � D ]}|j �� qrt �� |_�z:zDt�d| j � | j�d|j� | j�| |� |�� t�d� W n� ty� � Y n� t�yD } zD| jjddd� td | tj d � tj � � t�| j � W Y d }~n>d }~0 | j� d � |j �sjt�| j!� t�d � Y n0 W | j�d |j� z |j �� | j�"| |� W n | j�#dt$�%� � Y n0 nN| j�d |j� z |j �� | j�"| |� W n | j�#dt$�%� � Y n0 0 d S )Nr; g @r z worker [%s]zBooting worker with pid: %sz'Exception while loading the applicationTr| z%s)�filezException in worker processr~ zWorker exiting (pid: %s)z Exception during worker exit: %s)&r" rA rZ r] r- rE r2 r Zpre_forkr r� r� �valuesr� rj rY r r rF rV Z post_forkZ init_processr' r� r� r rG �print�stderr�flushr� � exceptionZbootedr� � worker_exitr� � traceback� format_exc)r, r� rZ Zsiblingr� r r r r� 1 sd � � � � �zArbiter.spawn_workerc C s8 t | jt| j� �D ] }| �� t�dt�� � qdS )z� Spawn new workers as needed. This is where a worker process leaves the main loop of the master process. r� N)r_ rD rs r� r� r� r� �random)r, r r r r r� _ s zArbiter.spawn_workersc C s( t | j�� �}|D ]}| �||� qdS )z^ Kill all workers with the signal `sig` :attr sig: `signal.SIG*` value N)r� r� �keysr� )r, rw Z worker_pidsrZ r r r r� k s zArbiter.kill_workersc C s� zt �||� W n� ty� } zr|jtjkr�z4| j�|�}|j�� | j � | |� W W Y d}~dS t tfy� Y W Y d}~dS 0 � W Y d}~n d}~0 0 dS )zj Kill a worker :attr pid: int, worker pid :attr sig: `signal.SIG*` value N) r �killr� r� ZESRCHr� r` r� rj r2 r� r� )r, rZ rw r� r� r r r r� t s zArbiter.kill_worker)Nr )T)2�__name__� __module__� __qualname__�__doc__r� r� r+ r] r� ri rt ra rl �dict�dirr r� r. r1 r5 �propertyrD r rh r\ r� rn r� r� r� r� r� r� r� r� r� r� ru r� r� r� r� r� r� r� r� r� r� r� r� r r r r r s^ �� 1, "7 . r )r� r r� r� r r' r� r� Zgunicorn.errorsr r Zgunicorn.pidfiler Zgunicornr r r r r �objectr r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка