File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/ext/tornado/platform/__pycache__/twisted.cpython-310.pyc
Back
o ;j�V � @ s� d Z ddlmZmZmZ ddlZddlZddlZddlZddl Z ddl Z ddl m Z ddlmZ ddlmZmZmZmZmZ ddlmZmZ ddlmZ ddlZ ddl Z ddl Z ddl Z dd l m Z dd l!m"Z" dd l#m$Z$ dd l%m&Z& ddl'Z(dd l)m*Z* ddl+m,Z, ddl-m.Z.m/Z/ ddl'm0Z0 ddl1m2Z2 e e�G dd� de3��Z4e ee�G dd� de��Z5G dd� de5�Z6d#dd�Z7e ee�G dd� de3��Z8G d d � d e(j9j:j;j0�Z<G d d � d e,�Z=e>e&j?d �r�e&j?�@e �d!d"� �ZAdS dS )$aB Bridges between the Twisted reactor and Tornado IOLoop. This module lets you run applications and libraries written for Twisted in a Tornado application. It can be used in two modes, depending on which library's underlying event loop you want to use. This module has been tested with Twisted versions 11.0.0 and newer. � )�absolute_import�division�print_functionN)�Deferred)�PosixReactorBase)� IReactorFDSet� IDelayedCall� IReactorTime�IReadDescriptor�IWriteDescriptor)�failure�log)�error)� implementer)�Future)�utf8)�gen)�app_log)�Resolver)� NullContext�wrap)�IOLoop)�timedelta_to_secondsc @ sH e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dS )�TornadoDelayedCallz DelayedCall object for Tornado.c O sP || _ tj|g|�R i |��| _| j �� | | _| j j�| j| j�| _ d| _ d S �NT) �_reactor� functools�partial�_func�seconds�_time�_io_loop� add_timeout�_called�_timeout�_active)�self�reactorr �f�args�kw� r+ �U/opt/saltstack/salt/lib/python3.10/site-packages/salt/ext/tornado/platform/twisted.py�__init__< s � zTornadoDelayedCall.__init__c C s< d| _ | j�| � z| �� W d S tjddd� Y d S )NFz_called caught exceptionT)�exc_info)r% r �_removeDelayedCallr r r �r& r+ r+ r, r# D s zTornadoDelayedCall._calledc C � | j S �N)r r0 r+ r+ r, �getTimeL � zTornadoDelayedCall.getTimec C s& d| _ | jj�| j� | j�| � d S �NF)r% r r! �remove_timeoutr$ r/ r0 r+ r+ r, �cancelO s zTornadoDelayedCall.cancelc C s8 | j j�| j� | j|7 _| j j�| j| j�| _d S r2 )r r! r6 r$ r r" r# �r& r r+ r+ r, �delayT s �zTornadoDelayedCall.delayc C s: | j j�| j� | j �� | | _| j j�| j| j�| _d S r2 )r r! r6 r$ r r r" r# r8 r+ r+ r, �resetZ s �zTornadoDelayedCall.resetc C r1 r2 �r% r0 r+ r+ r, �active` r4 zTornadoDelayedCall.activeN) �__name__� __module__� __qualname__�__doc__r- r# r3 r7 r9 r: r< r+ r+ r+ r, r 9 s r c @ s� e Zd ZdZd+dd�Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)d*� ZdS ),�TornadoReactora� Twisted reactor built on the Tornado IOLoop. `TornadoReactor` implements the Twisted reactor interface on top of the Tornado IOLoop. To use it, simply call `install` at the beginning of the application:: import tornado.platform.twisted tornado.platform.twisted.install() from twisted.internet import reactor When the app is ready to start, call ``IOLoop.current().start()`` instead of ``reactor.run()``. It is also possible to create a non-global reactor by calling ``tornado.platform.twisted.TornadoReactor(io_loop)``. However, if the `.IOLoop` and reactor are to be short-lived (such as those used in unit tests), additional cleanup may be required. Specifically, it is recommended to call:: reactor.fireSystemEvent('shutdown') reactor.disconnectAll() before closing the `.IOLoop`. .. versionchanged:: 4.1 The ``io_loop`` argument is deprecated. Nc sh |s t jjjj�� }|� _i � _i � _i � _ i � _ t � � � � � dd� j� � fdd�}� j�|� d S )NZduring�shutdownc s � j s � �d� d S d S )NZstartup)�_started�fireSystemEventr+ r0 r+ r, �start_if_necessary� s �z3TornadoReactor.__init__.<locals>.start_if_necessary)�salt�ext�tornado�ioloopr �currentr! �_readers�_writers�_fds� _delayedCallsr r- ZaddSystemEventTrigger�crash� add_callback)r& �io_looprE r+ r0 r, r- � s zTornadoReactor.__init__c C � | j �� S r2 )r! �timer0 r+ r+ r, r � � zTornadoReactor.secondsc O s( t | ||g|�R i |��}d| j|< |S r )r rN )r& r r( r) r* �dcr+ r+ r, � callLater� s zTornadoReactor.callLaterc C s dd� | j D �S )Nc S s g | ]}|j r|�qS r+ r; )�.0�xr+ r+ r, � <listcomp>� s z2TornadoReactor.getDelayedCalls.<locals>.<listcomp>�rN r0 r+ r+ r, �getDelayedCalls� � z TornadoReactor.getDelayedCallsc C s || j v r | j |= d S d S r2 rZ )r& rU r+ r+ r, r/ � s �z!TornadoReactor._removeDelayedCallc O sZ t |�s J d| ��t� � | jj|g|�R i |�� W d � d S 1 s&w Y d S )Nz%s is not callable)�callabler r! rP )r& r( r) r* r+ r+ r, �callFromThread� s "�z TornadoReactor.callFromThreadc C � d S r2 r+ r0 r+ r+ r, � installWaker� � zTornadoReactor.installWakerc C r_ r2 r+ r0 r+ r+ r, �wakeUp� ra zTornadoReactor.wakeUpc C s || j vrd S | j | \}}|rGd }|�� dkr t�� }n |tj@ r)t�||j�}|d u r6|tj @ r6t�� }|d urG| � |� |� t � |�� |r�d }|�� dkrVt�� }n |tj@ rbt�||j�}|d u ro|tj @ rot�� }|d ur�| �|� |�t � |�� d S d S d S )N���)rM �filenor ZConnectionLostr �READr ZcallWithLogger�doRead�ERROR� removeReaderZreadConnectionLostr �Failure�WRITE�doWrite� removeWriterZwriteConnectionLost)r& �fd�events�reader�writer�errr+ r+ r, �_invoke_callback� s6 �z TornadoReactor._invoke_callbackc C s� || j v rd S |�� }|| j |< || jv r4| j| \}}||f| j|< |r2| j�|tjtjB � d S d S t� � |d f| j|< | j� || j tj� W d � d S 1 sTw Y d S r2 ) rK rd rM r! �update_handlerr re rj r � add_handlerrr �r& ro rm �_rp r+ r+ r, � addReader� s � �"�zTornadoReactor.addReaderc C s� || j v rd S |�� }|| j |< || jv r4| j| \}}||f| j|< |r2| j�|tjtjB � d S d S t� � d |f| j|< | j� || j tj� W d � d S 1 sTw Y d S r2 ) rL rd rM r! rs r re rj r rt rr �r& rp rm ro rv r+ r+ r, � addWriter� s � �"�zTornadoReactor.addWriterc C sf || j v r1| j �|�}| j| \}}|r%d |f| j|< | j�|tj� d S | j|= | j�|� d S d S r2 )rK �poprM r! rs r rj �remove_handlerru r+ r+ r, rh � � �zTornadoReactor.removeReaderc C sf || j v r1| j �|�}| j| \}}|r%|d f| j|< | j�|tj� d S | j|= | j�|� d S d S r2 )rL rz rM r! rs r re r{ rx r+ r+ r, rl r| zTornadoReactor.removeWriterc C s | � | j| j�S r2 )Z _removeAllrK rL r0 r+ r+ r, � removeAll r\ zTornadoReactor.removeAllc C rR r2 )rK �keysr0 r+ r+ r, � getReaders rT zTornadoReactor.getReadersc C rR r2 )rL r~ r0 r+ r+ r, � getWriters rT zTornadoReactor.getWritersc C s( t �| � t�| jd�}| j�|� d S )NrB )r �stopr r rD r! rP )r& Z fire_shutdownr+ r+ r, r� # s zTornadoReactor.stopc C s t �| � | j�� d S r2 )r rO r! r� r0 r+ r+ r, rO ( s zTornadoReactor.crashc C s t d��)N� doIteration)�NotImplementedError)r& r9 r+ r+ r, r� , s zTornadoReactor.doIterationc C � | j �� d S r2 )r! �startr0 r+ r+ r, �mainLoop/ s zTornadoReactor.mainLoopr2 )r= r> r? r@ r- r rV r[ r/ r^ r` rb rr rw ry rh rl r} r r� r� rO r� r� r+ r+ r+ r, rA d s, rA c s< e Zd ZdZ� fdd�Zd � fdd� Zd � fd d � Z� ZS ) � _TestReactorz�Subclass of TornadoReactor for use in unittests. This can't go in the test.py file because of import-order dependencies with the Twisted reactor test builder. c s t t| ��t� � d S r2 )�superr� r- r r0 �� __class__r+ r, r- A s z_TestReactor.__init__�2 � c s |sd}t t| �j||||d�S )N� 127.0.0.1)�backlog� interface)r� r� � listenTCP)r& �port�factoryr� r� r� r+ r, r� E s �z_TestReactor.listenTCP� c s |sd}t t| �j||||d�S )Nr� )r� � maxPacketSize)r� r� � listenUDP)r& r� �protocolr� r� r� r+ r, r� L s �z_TestReactor.listenUDP)r� r� )r� r� )r= r> r? r@ r- r� r� � __classcell__r+ r+ r� r, r� ; s r� c C s4 | s t jjjj�� } t| �}ddlm} ||� |S )aD Install this package as the default Twisted reactor. ``install()`` must be called very early in the startup process, before most other twisted-related imports. Conversely, because it initializes the `.IOLoop`, it cannot be called before `.fork_processes` or multi-process `~.TCPServer.start`. These conflicting requirements make it difficult to use `.TornadoReactor` in multi-process mode, and an external process manager such as ``supervisord`` is recommended instead. .. versionchanged:: 4.1 The ``io_loop`` argument is deprecated. r )�installReactor) rF rG rH rI r rJ rA Ztwisted.internet.mainr� )rQ r' r� r+ r+ r, �installS s r� c @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd S )�_FDc C s( || _ || _|| _d| _d| _d| _d S r5 )rm �fileobj�handler�reading�writing�lost)r& rm r� r� r+ r+ r, r- l s z _FD.__init__c C r1 r2 )rm r0 r+ r+ r, rd t r4 z _FD.filenoc C �& | j s| �| jtjjjjj� d S d S r2 ) r� r� r� rF rG rH rI r re r0 r+ r+ r, rf w � �z _FD.doReadc C r� r2 ) r� r� r� rF rG rH rI r rj r0 r+ r+ r, rk { r� z _FD.doWritec C s, | j s| �| jtjjjjj� d| _ d S d S r ) r� r� r� rF rG rH rI r rg )r& �reasonr+ r+ r, �connectionLost s �z_FD.connectionLostc C s dS )Nr� r+ r0 r+ r+ r, � logPrefix� ra z _FD.logPrefixN) r= r> r? r- rd rf rk r� r� r+ r+ r+ r, r� j s r� c st e Zd ZdZd� fdd� Zddd�Zdd � Zd d � Zd d � Zdd� Z dd� Z dd� Z dd� Z dd� Z dd� Z� ZS ) � TwistedIOLoopa] IOLoop implementation that runs on Twisted. `TwistedIOLoop` implements the Tornado IOLoop interface on top of the Twisted reactor. Recommended usage:: from salt.ext.tornado.platform.twisted import TwistedIOLoop from twisted.internet import reactor TwistedIOLoop().install() # Set up your tornado application as usual using `IOLoop.instance` reactor.run() Uses the global Twisted reactor by default. To create multiple ``TwistedIOLoops`` in the same process, you must pass a unique reactor when constructing each one. Not compatible with `tornado.process.Subprocess.set_exit_callback` because the ``SIGCHLD`` handlers used by Tornado and Twisted conflict with each other. See also :meth:`tornado.ioloop.IOLoop.install` for general notes on installing alternative IOLoops. Nc s> t t| �jdi |�� |d u rdd l}|jj}|| _i | _d S )Nr r+ )r� r� � initializeZtwisted.internet.reactor�internetr' �fds)r& r' �kwargs�twistedr� r+ r, r� � s zTwistedIOLoop.initializeFc C sN | j }| j�� | j�� D ]}|�� q |r#|�� D ] }| �|j� qd S d S r2 )r� r' r} r[ r7 �valuesZclose_fdr� )r& Zall_fdsr� �crm r+ r+ r, �close� s �zTwistedIOLoop.closec C s� || j v r td| ��| �|�\}}t||t|��| j |< |tjjjj j @ r5d| j | _ | j � | j | � |tjjjj j@ rOd| j | _| j �| j | � d S d S )Nzfd %s added twiceT)r� � ValueError�split_fdr� r rF rG rH rI r re r� r' rw rj r� ry )r& rm r� rn r� r+ r+ r, rt � s �zTwistedIOLoop.add_handlerc C s� | � |�\}}|tjjjjj@ r&| j| js%d| j| _| j � | j| � n| j| jr;d| j| _| j � | j| � |tjjjjj @ r]| j| j s[d| j| _ | j �| j| � d S d S | j| j rtd| j| _ | j �| j| � d S d S )NTF)r� rF rG rH rI r re r� r� r' rw rh rj r� ry rl )r& rm rn r� r+ r+ r, rs � s$ � � �z TwistedIOLoop.update_handlerc C sp | � |�\}}|| jvrd S d| j| _| j| jr#| j�| j| � | j| jr2| j�| j| � | j|= d S r )r� r� r� r� r' rh r� rl )r& rm r� r+ r+ r, r{ � s z TwistedIOLoop.remove_handlerc C sf t jdd�}z | �� | �� | j�� W |d u r t �� d S |�� d S |d u r.t �� w |�� w )NF)�instance)r rJ Z_setup_loggingZ make_currentr' �runZ clear_current)r& Z old_currentr+ r+ r, r� � s � zTwistedIOLoop.startc C r� r2 )r' rO r0 r+ r+ r, r� � s zTwistedIOLoop.stopc O sh t |tj�rt|| �� d�}nt |tj�rt|�}ntd��| j � || j t j t|�g|�R i |���S )Nr zUnsupported deadline %r)� isinstance�numbersZReal�maxrS �datetime� timedeltar � TypeErrorr' rV � _run_callbackr r r )r& Zdeadline�callbackr) r� r9 r+ r+ r, r" � s �zTwistedIOLoop.add_timeoutc C s |� � r |�� d S d S r2 )r< r7 )r& �timeoutr+ r+ r, r6 � s �z TwistedIOLoop.remove_timeoutc O s, | j �| jtjt|�g|�R i |��� d S r2 )r' r^ r� r r r �r& r� r) r� r+ r+ r, rP � s �zTwistedIOLoop.add_callbackc O s | j |g|�R i |�� d S r2 )rP r� r+ r+ r, �add_callback_from_signal s z&TwistedIOLoop.add_callback_from_signalr2 )F)r= r> r? r@ r� r� rt rs r{ r� r� r" r6 rP r� r� r+ r+ r� r, r� � s r� c @ s* e Zd ZdZddd�Zejd dd��ZdS ) �TwistedResolvera` Twisted-based asynchronous resolver. This is a non-blocking and non-threaded resolver. It is recommended only when threads cannot be used, since it has limitations compared to the standard ``getaddrinfo``-based `~tornado.netutil.Resolver` and `~tornado.netutil.ThreadedResolver`. Specifically, it returns at most one result, and arguments other than ``host`` and ``family`` are ignored. It may fail to resolve when ``family`` is not ``socket.AF_UNSPEC``. Requires Twisted 12.1 or newer. .. versionchanged:: 4.1 The ``io_loop`` argument is deprecated. Nc C sp |pt �� | _tjjjj�|�| _ tj j � d�}tj j j| j d�}tj jj d| j d�}tj j�|||g�| _d S )Nz /etc/hosts)r' z/etc/resolv.conf)r rJ rQ rF rG rH �platformr� rA r' �names�hostsr �cacheZ CacheResolver�client�resolveZ ResolverChain�resolver)r& rQ Z host_resolverZcache_resolverZ real_resolverr+ r+ r, r� s � �zTwistedResolver.initializer c c s � t jj�|�r|}tj}nUt jj�|�r|}tj}nH| j� t |��}t � |j �V }t|tj�rJz|�� W n, t jjjyI } zt|��d }~ww t jj�|�rUtj}nt jj�|�r`tj}ntj}|tjkrt||krttd||f ��|||ffg}t �|��)Nz%Requested socket family %d but got %d)r� r� ZabstractZ isIPAddress�socket�AF_INETZ isIPv6Address�AF_INET6r� Z getHostByNamer r ZTaskZaddBothr� r ri �raiseExceptionr� r Z DomainError�IOError� AF_UNSPEC� ExceptionZReturn) r& �hostr� �familyZresolvedZresolved_familyZdeferred�e�resultr+ r+ r, r� " s8 � ��� � zTwistedResolver.resolver2 )r )r= r> r? r@ r� r � coroutiner� r+ r+ r+ r, r� s r� �registerc s$ t � � � fdd�}| �� j|� � S )Nc s, z| � � td�� � �t�� � Y d S )Nz errback called without error)r� r� Z set_exc_info�sysr. )r �r( r+ r, �errbackH s z_.<locals>.errback)r Z addCallbacksZ set_result)�dr� r+ r� r, rv D s rv r2 )Br@ � __future__r r r r� r r� r� r� Ztwisted.internet.abstractr� Ztwisted.internet.deferr Ztwisted.internet.posixbaser Ztwisted.internet.interfacesr r r r r Ztwisted.pythonr r Ztwisted.internetr Ztwisted.names.cacheZtwisted.names.clientZtwisted.names.hostsZtwisted.names.resolveZzope.interfacer Zsalt.ext.tornado.concurrentr Zsalt.ext.tornado.escaper Zsalt.ext.tornador Zsalt.ext.tornado.iolooprF Zsalt.ext.tornado.logr Zsalt.ext.tornado.netutilr Z salt.ext.tornado.stack_contextr r r Zsalt.ext.tornado.utilr �objectr rA r� r� r� rG rH rI r� r� �hasattrZconvert_yieldedr� rv r+ r+ r+ r, �<module> sT * W | ? �
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings