Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/twisted/web/__pycache__/distrib.cpython-39.pyc
Ðазад
a k�hW. � @ s: d Z ddlZddlZz ddlZW n ey6 dZY n0 ddlmZ ddlmZ ddl m Z m Z ddl m Z ddlmZ ddlmZ dd lmZ dd lmZmZmZmZmZ dd lmZ G d d � d ej �Z G dd� dej ej �Z e� ej e � G dd� d�Z!G dd� dej"�Z#G dd� dej$ej%�Z&G dd� dej"�Z'dS )z� Distributed web servers. This is going to have to be refactored so that argument parsing is done by each subprocess and not by the main web server (i.e. GET, POST etc.). � N)�BytesIO)�getDOMImplementation)�address�reactor)�Logger)�styles)�pb)� SIZE_LIMIT)�http�resource�server�static�util)�Headersc @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S ) � _ReferenceableProducerWrapperc C s || _ d S �N)�producer)�selfr � r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/twisted/web/distrib.py�__init__$ s z&_ReferenceableProducerWrapper.__init__c C s | j �� d S r )r ZresumeProducing�r r r r �remote_resumeProducing' s z4_ReferenceableProducerWrapper.remote_resumeProducingc C s | j �� d S r )r ZpauseProducingr r r r �remote_pauseProducing* s z3_ReferenceableProducerWrapper.remote_pauseProducingc C s | j �� d S r )r Z stopProducingr r r r �remote_stopProducing- s z2_ReferenceableProducerWrapper.remote_stopProducingN)�__name__� __module__� __qualname__r r r r r r r r r # s r c @ s8 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd S ) �Requestzn A request which was received by a L{ResourceSubscription} and sent via PB to a distributed node. c s� dD ]H}|| �ddd��d � � �fdd��fdd�d �� � }|||< qt t|d ��|d < tj�| |� t| j�| _| j� d �| _ | j� d �| _ | j� d �| _ | j� d�| _ | j� d�| _| j� d�| _| j� d�| _dS )z� Initialize this L{twisted.web.distrib.Request} based on the copied state so that it closely resembles a L{twisted.web.server.Request}. )�host�client�TCP�UNIX)ZINETr" r c s t �� �d �d �S )N� � )r � IPv4Addressr �Zaddrdesc�tupr r �<lambda>@ � z*Request.setCopyableState.<locals>.<lambda>c s t �� d �S )Nr# )r Z UNIXAddressr )r' r r r( A r) )r! r" ZrequestHeaders�finish� setHeader� addCookie�setETag�setResponseCode�setLastModified�writeN)r �dictr � RemoteCopy�setCopyableStater Z content_data�content�remoteZ remoteMethodr* r+ r, r- r. r/ �_write)r �state�k�addrr r& r r3 7 s& �� zRequest.setCopyableStatec C s> d}t }| �|||� � |t 7 }|t 7 }|t|�krq:qdS )z� Write the given bytes to the response body. @param bytes: The bytes to write. If this is longer than 640k, it will be split up into smaller pieces. r N)r r6 �len)r �bytes�start�endr r r r0 S s z Request.writec C s | j �dt|�|��| j� d S )N�registerProducer)r5 � callRemoter � addErrback�fail)r r Z streamingr r r r> c s ��zRequest.registerProducerc C s | j �d��| j� d S )N�unregisterProducer)r5 r? r@ rA r r r r rB h s zRequest.unregisterProducerc C s | j jd|d� d S )N� )�failure)�_logrD �r rD r r r rA k s z Request.failN) r r r �__doc__r3 r0 r> rB rA r r r r r 1 s r c @ s* e Zd Ze� Zdd� Zdd� Zdd� ZdS )�Issuec C s || _ d S r )�request)r rI r r r r u s zIssue.__init__c C s6 |t jur2t|t�s J d��| j�|� | j�� d S )Nzreturn value not a string)r � NOT_DONE_YET� isinstance�strrI r0 r* )r �resultr r r �finishedx s zIssue.finishedc C sL t |�}| j�t�tjddt�|� �� | j�� | j� � | j � |� d S )NzServer Connection Lostz&Connection to distributed server lost:) rL rI r0 r Z ErrorPager �INTERNAL_SERVER_ERRORr Z_PRE�renderr* rE �inforF r r r �failed~ s ��� z Issue.failedN)r r r r rE r rN rR r r r r rH r s rH c @ sJ e Zd ZdZdZe� Zdd� Zdd� Zdd� Z d d � Z d d � Z d d� Z dS )�ResourceSubscriptionr# r c C s( t j�| � || _|| _g | _d | _d S r )r �Resourcer r �port�pending� publisher)r r rU r r r r � s z ResourceSubscription.__init__c C s( t � | j�}d|d< d|d< g |d< |S )z3Get persistent state for this ResourceSubscription.NrW r �waitingrV )�copy�__dict__)r r7 r r r � __getstate__� s z!ResourceSubscription.__getstate__c C sF | j �d� |j�| j� || _d| _| jD ]}| �|� q,g | _dS )z=I've connected to a publisher; I'll now send all my requests.zconnected to publisherr N) rE rQ ZbrokerZnotifyOnDisconnect�bootedrW rX rV rP )r rW rI r r r � connected� s z ResourceSubscription.connectedc C sD | j jd|d� d| _d| _| jD ]}|�d� |�� q"g | _dS )zXI can't connect to a publisher; I'll now reply to all pending requests. z3could not connect to distributed web service: {msg})�msgr Nz(Unable to connect to distributed server.)rE rQ rX rW rV r0 r* )r r^ rI r r r � notConnected� s z!ResourceSubscription.notConnectedc C s | � d� d S )Nzconnection dropped)r_ r r r r r\ � s zResourceSubscription.bootedc C s� | j st| j�|� | js�d| _t�� }d}| jdkrFt�| j ||� nt� | j| j ||� |� � }|� | j | j� n"t|�}| j �d|�� |j|j� tjS )a: Render this request, from my server. This will always be asynchronous, and therefore return NOT_DONE_YET. It spins off a request to the pb client, and either adds it to the list of pending issues or requests it immediately, depending on if the client is already connected. r# � �unixrI )rW rV �appendrX r ZPBClientFactoryr r Z connectUNIXrU Z connectTCPZ getRootObjectZ addCallbacksr] r_ rH r? rN rR r rJ )r rI �bf�timeout�d�ir r r rP � s �zResourceSubscription.renderN) r r r ZisLeafrX r rE r r[ r] r_ r\ rP r r r r rS � s rS c @ s: e Zd ZdZe� Zdd� ZdZdd� Zdd� Z d d � Z d S ) �ResourcePublisherz� L{ResourcePublisher} exposes a remote API which can be used to respond to request. @ivar site: The site which will be used for resource lookup. @type site: L{twisted.web.server.Site} c C s || _ d S r )�site)r rh r r r r � s zResourcePublisher.__init__r$ c C s* | j j�d� | j j| j= | `| ` | `d S )NZweb)Z applicationZ authorizerZremoveIdentityZservicesZ serviceNameZperspectiveNamer r r r �upgradeToVersion2� s z#ResourcePublisher.upgradeToVersion2c C s | S r r )r �namer r r �getPerspectiveNamed� s z%ResourcePublisher.getPerspectiveNamedc C sD | j �|�}| j�|� |�|�}|tjur>|�|� |�� tjS )zK Look up the resource for the given request and render it. ) rh ZgetResourceForrE rQ rP r rJ r0 r* )r rI �resrM r r r �remote_request� s z ResourcePublisher.remote_requestN) r r r rG r rE r ZpersistenceVersionri rk rm r r r r rg � s rg c @ s> e Zd ZdZdZdZdZddd�Zdd � Zd d � Z d d � Z dS )� UserDirectoryz� A resource which lists available user resources and serves them as children. @ivar _pwd: An object like L{pwd} which is used to enumerate users and their home directories. Z public_htmlz.twistd-web-pba� <html> <head> <title>twisted.web.distrib.UserDirectory</title> <style> a { font-family: Lucida, Verdana, Helvetica, Arial, sans-serif; color: #369; text-decoration: none; } th { font-family: Lucida, Verdana, Helvetica, Arial, sans-serif; font-weight: bold; text-decoration: none; text-align: left; } pre, code { font-family: "Courier New", Courier, monospace; } p, body, td, ol, ul, menu, blockquote, div { font-family: Lucida, Verdana, Helvetica, Arial, sans-serif; color: #000; } </style> </head> <body> <h1>twisted.web.distrib.UserDirectory</h1> %(users)s </body> </html> Nc C s" t j�| � |d u rt}|| _d S r )r rT r �pwd�_pwd)r Z userDatabaser r r r 7 s zUserDirectory.__init__c C s� g }| j �� D ]�}|\}}}}}}} |�d�d } | s:|} tj�tj�|| j��rd|�|| d f� tj�|| j �} tj�| �r|d } |�| | d f� q|S )z| Return a list of two-tuples giving links to user resources and text to associate with those links. �,r z (file)�.twistdz (twistd)) rp �getpwall�split�os�path�exists�join� userDirNamerb �userSocketName) r �users�userrj �passwd�uid�gidZgecos�dir�shellZrealname� twistdsockZlinkNamer r r �_users= s zUserDirectory._usersc C s� t � }|�ddd�}|j}| �� D ]T\}}|�d�}|�d|d � |�|�}|�|� |�d�} | �|� |�| � q"| jd|� � i } | � d�S ) zm Render as HTML a listing of all known users with links to their personal resources. NZul�a�href�/Zlir{ zutf-8) r ZcreateDocumentZdocumentElementr� Z createElementZ setAttributeZcreateTextNodeZ appendChild�templateZtoxml�encode) r rI ZdomImplZnewDocZlisting�link�textZ linkElementZtextNode�itemZhtmlDocr r r � render_GETP s zUserDirectory.render_GETc C s� |dkr | S d}|t |� d � |kr>|d t |� � }d}n|}d}z | j�|�\}}}} } } } W n ty~ t�� Y S 0 |r�tj�| | j �} t d| �}| � ||� |S tj�| | j �}tj� |�s�t�� S t�|�S d S )NrC rr r# r ra )r: rp �getpwnam�KeyErrorr Z NoResourceru rv rx rz rS ZputChildry rw r �File)r rj rI �td�username�sub�pw_name� pw_passwd�pw_uid�pw_gid�pw_gecos�pw_dir�pw_shellr� �rsrv r r r �getChilde s< �� zUserDirectory.getChild)N) r r r rG ry rz r� r r� r� r� r r r r rn s * rn )(rG rY ru ro � ImportError�ior Zxml.dom.minidomr Ztwisted.internetr r Ztwisted.loggerr Ztwisted.persistedr Ztwisted.spreadr Ztwisted.spread.bananar Z twisted.webr r r r r Ztwisted.web.http_headersr Z Referenceabler r2 r ZsetUnjellyableForClassrH rT rS ZRootZ Versionedrg rn r r r r �<module> s, >N'
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка