| Server IP : 77.50.203.18 / Your IP : 192.168.0.10 Web Server : Apache/2.4.62 (CentOS Stream) OpenSSL/3.5.7 mpm-itk/2.4.7-04 PHP/8.4.23 System : Linux web2 5.14.0-722.el9.x86_64 #1 SMP PREEMPT_DYNAMIC Mon Jul 6 09:07:51 UTC 2026 x86_64 User : warsnews.ru ( 1001) PHP Version : 8.4.23 Disable Function : NONE MySQL : ON | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /usr/lib/python3.9/site-packages/cockpit/__pycache__/ |
Upload File : |
a
7(=j�2 � @ s� d dl Z d dlZd dlZd dlmZmZmZ ddlmZm Z ddl
m Z m Z m
Z
e�e�ZG dd� d�ZG dd � d �ZG d
d � d e �ZG d d
� d
�ZG dd� d�ZG dd� de
�ZdS )� N)�Dict�List�Optional� )�
JsonObject� JsonValue)�CockpitProblem�CockpitProtocolError�CockpitProtocolServerc @ s. e Zd ZdZdd� Zdd� Zdd�dd �ZdS )
�ExecutionQueueaw Temporarily delay calls to a given set of class methods.
Functions by replacing the named function at the instance __dict__
level, effectively providing an override for exactly one instance
of `method`'s object.
Queues the invocations. Run them later with .run(), which also reverses
the redirection by deleting the named methods from the instance.
c C s* t �� | _|| _| jD ]}| �|� qd S �N)� collections�deque�queue�methods�_wrap)�selfr �method� r �2/usr/lib/python3.9/site-packages/cockpit/router.py�__init__ s
zExecutionQueue.__init__c s t � j� jj� �fdd�� d S )Nc s �j �� | f�S r )r �append)�args�r r r r �<lambda>% � z&ExecutionQueue._wrap.<locals>.<lambda>)�setattr�__self__�__func__�__name__)r r r r r r ! s zExecutionQueue._wrapN��returnc C sJ t �dt| j�� | jD ]\}}||� q| jD ]}t|j|jj� q0d S )Nz.ExecutionQueue: Running %d queued method calls) �logger�debug�lenr r �delattrr r r )r r r r r r �run' s
zExecutionQueue.run)r �
__module__� __qualname__�__doc__r r r& r r r r r s r c @ s� e Zd ZU ded< dZee ed< dd�dd�Zdd�d d
�Zdd�d d �Z dd�d
d�Z
e e e dd�dd�Z
e edd�dd�Zdde dd�dd�Ze edd�dd�Ze e dedd �d d �Zd"dedd �d d!�ZdS )#�Endpoint�Router�routerN� _Endpoint__endpoint_frozen_queue�r, c C s |� | � || _d S r )� add_endpointr, �r r, r r r r 4 s
zEndpoint.__init__r c C s& t �d| � t| j| j| jh�| _d S )NzFreezing endpoint %s)r" r# r �do_channel_control�do_channel_data�do_killr- �r r r r �freeze_endpoint8 s zEndpoint.freeze_endpointc C s t �d| � | j�� d | _d S )NzThawing endpoint %s)r" r# r- r& r4 r r r �
thaw_endpoint= s
zEndpoint.thaw_endpointc C s t �d S r ��NotImplementedErrorr4 r r r �do_closeD s zEndpoint.do_close��channel�command�messager! c C s t �d S r r7 )r r; r< r= r r r r1 G s zEndpoint.do_channel_control�r; �datar! c C s t �d S r r7 �r r; r? r r r r2 J s zEndpoint.do_channel_data�
str | None��host�groupr= r! c C s t �d S r r7 )r rC rD r= r r r r3 M s zEndpoint.do_killc C s | j �||� d S r )r, Zwrite_channel_datar@ r r r �send_channel_dataQ s zEndpoint.send_channel_data�JsonObject | None)r; r< �msg�kwargsr! c K sD | j j|f||d�|�� |dkr@| j j| �|� | j �|� d S )N�r; r< �close)r, �
write_control� endpoints�remove� drop_channel)r r; r< rG rH r r r �send_channel_controlT s z Endpoint.send_channel_control)rG rH r! c K s | j j| |fi |�� d S r )r, �shutdown_endpoint)r rG rH r r r rP \ s zEndpoint.shutdown_endpoint)N)r r' r( �__annotations__r- r r r r5 r6 r9 �strr r1 �bytesr2 r3 rE r rO rP r r r r r* 0 s
� r* c @ s e Zd ZdS )� RoutingErrorN)r r' r( r r r r rT ` s rT c @ sF e Zd ZU ded< dd�dd�Zeee d�dd�Zd d
�d d �Z d S )
� RoutingRuler+ r, r. c C s
|| _ d S r r. r0 r r r r g s zRoutingRule.__init__��optionsr! c C s t �dS )a] Check if a routing rule applies to a given 'open' message.
This should inspect the options dictionary and do one of the following three things:
- return an Endpoint to handle this channel
- raise a RoutingError to indicate that the open should be rejected
- return None to let the next rule run
Nr7 )r rW r r r �
apply_rulej s zRoutingRule.apply_ruleNr c C s t �d S r r7 r4 r r r �shutdownu s zRoutingRule.shutdown)
r r' r( rQ r r r r* rX rY r r r r rU d s
rU c @ s� e Zd ZU ded< ded< eed< ded< ded < ed
d �d d
�Zed
d�dd�Zed
d�dd�Zd
d�dd�Z dd� Z
d
d�dd
d �dd�Z d
S ) �SessionControllerr+ r, zset[str]�channels�timeoutz float | None�deadlinezasyncio.TimerHandle | None�timerN)r\ r! c C s$ t � | _|| _d | _d | _|| _d S r )�setr[ r\ r] r^ r, )r r\ r, r r r r � s
zSessionController.__init__�r; r! c C s( | j �|� | jd u r$| j| jd� d S �N�r\ )r[ �addr] �_updater\ �r r; r r r � add_channel� s
z SessionController.add_channelc C s" | j �|� | j s | jdd� d S )Nr rb )r[ rM rd re r r r �remove_channel� s z SessionController.remove_channelr c C s | j d ur| j| jd� d S ra )r] rd r\ r4 r r r �reset_session_timeout� s
z'SessionController.reset_session_timeoutc K s( | j D ] }| jjf ||d�|�� qd S )NrI )r[ r, rK )r r< rH �cr r r �
_send_message� s
z SessionController._send_messagerb �
int | Nonec C s� | j d ur| j �� d | _ t�� }|�� }|dkr:d | _n|d urL|| | _| jd u rZd S | j| }t�d|� |dkr~d}nT|dkr�t|�}| j d|d� t
|d d�}n&|dkr�| � d� d}n| j � � d S | j| }|�
|| j�| _ d S ) Nr z.SessionController: update with %.2fs remaining� Z countdown)�counterr i����Zlogout)r^ �cancel�asyncio�get_running_loop�timer] r" r# �roundrj �maxr, rJ Zcall_atrd )r r\ ZloopZnowZ remainingZnext_remainingrm Zwake_atr r r rd � s4
zSessionController._update) r r' r( rQ �intr rR rf rg rh rj rd r r r r rZ y s
rZ c @ s: e Zd ZU ee ed< eeef ed< ded< e j
ed< ded< dZ e ed < d
d �ee d d
�dd�Z
ed�dd�Zeed�dd�Zed
d�dd�Zed
d�dd�Zd2ed ed
d �d d �Zd d ed
d!�d"d#�Zeeed
d$�d%d&�Zeed
d'�d(d)�Ze d�d*d+�Zd
Zee j ed,< ee d
d-�d.d/�Z d
d�d0d1�Z d
S )3r+ �
routing_rules�
open_channelszdict[Endpoint, set[str]]rL � no_endpointszSessionController | None�session_controllerF�_eofN)�session_timeoutrk )ru rz c C sT |D ]
}| |_ q|| _i | _i | _t�� | _| j�� d | _|d urPt || �| _d S r )
r, ru rv rL ro �Eventrw r_ rx rZ )r ru rz �ruler r r r � s
zRouter.__init__r c C s i S )z7Used by the 'info' channel. Gets overridden in Bridge.r r4 r r r �info� s z Router.inforV c C sT | j D ]6}t�d|� |�|�}|d urt�d|� | S qt�d� td��d S )Nz applying rule %sz resulting endpoint is %sz No rules matchedz
not-supported)ru r" r# rX rT )r rW r| �endpointr r r � check_rules� s
zRouter.check_rulesr` c C sD z | j �|� t�d|� W n" ty> t�d|| j � Y n0 d S )Nzrouter dropped channel %sz.trying to drop non-existent channel %s from %s)rv �popr" r# �KeyError�errorre r r r rN � s
zRouter.drop_channel)r~ r! c C s t � | j|< | j�� d S r )r_ rL rw �clear)r r~ r r r r/ � s zRouter.add_endpointrF )r~ rG rH r! c K s� | j �|�}t�d|||� |D ]&}| j|fd|d�|�� | �|� q | j sX| j�� | jr�t�d| j � | j s�| j r�t�d� | j �
� d S )Nz'shutdown_endpoint(%s, %s) will close %srJ �r< r; � endpoints remaining: %rz close transport) rL r� r" r# rK rN rw r_ ry Z transportrJ )r r~ rG rH r[ r; r r r rP � s
zRouter.shutdown_endpointrA rB c C s: t | j�}t�d||t|�� |D ]}|�|||� q"d S )Nz+do_kill(%s, %s). Considering %d endpoints.)r_ rL r" r# r$ r3 )r rC rD r= rL r~ r r r r3
s
zRouter.do_killr: c
C s� | j d u rtd��|dkr�|| jv r,td��z"t�d||�d�� | �|�}W n: ty� } z"| j|� � d|d� W Y d }~d S d }~0 0 || j|< | j
| � |� n$z| j| }W n t y� Y d S 0 |�
|||� d S )Nz,channel control message received before init�openzchannel is already openz5Trying to find endpoint for new channel %s payload=%sZpayloadrJ r� )� init_hostr rv r" r# �getr rT rK Z get_attrsrL rc r� r1 )r r; r< r= r~ �excr r r �channel_control_received s$
z Router.channel_control_receivedr> c C sF | j d u rtd��z| j| }W n ty4 Y d S 0 |�||� d S )Nz)channel data message received before init)r� r rv r� r2 )r r; r? r~ r r r �channel_data_received. s
z Router.channel_data_receivedc C sF t �d| � t| j�}|D ] }|�� qd| _t �d| j� t| j�S )Nzeof_received(%r)Tr� )r" r# r_ rL r9 ry �bool)r rL r~ r r r � eof_received9 s
zRouter.eof_received�_communication_done)r� r! c C s> | j s| �� | jd ur:|d u r.| j�d � n | j�|� d S r )ry r� r� Z
set_resultZ
set_exception)r r� r r r � do_closedF s
zRouter.do_closedc � sn t �� �� | _zBz| jI dH W n ttfy6 Y n0 W d| _| j�� I dH nd| _| j�� I dH 0 dS )zNWait until communication is complete on the router and all endpoints are done.N)ro rp Z
create_futurer� �BrokenPipeError�ConnectionResetErrorrw �waitr4 r r r � communicateQ s �zRouter.communicate)N) r r' r( r rU rQ r rR r* ro r{ ry r� r r r} r rN r/ r rP r3 r� rS r� r� r� r ZFuture� Exceptionr� r� r r r r r+ � s&
r+ )ro r
Zlogging�typingr r r Zjsonutilr r Zprotocolr r r
Z getLoggerr r" r r* rT rU rZ r+ r r r r �<module> s
0Q