Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/zmq/eventloop/minitornado/__pycache__/stack_context.cpython-39.pyc
Ðазад
a a�ho3 � @ s� d Z ddlmZmZmZmZ ddlZddlZddlm Z G dd� de �Z G dd � d ej �Z e � ZG d d � d e�ZG d d � d e�ZG dd� de�Zdd� Zdd� Zdd� Zdd� ZdS )a `StackContext` allows applications to maintain threadlocal-like state that follows execution as it moves to other execution contexts. The motivating examples are to eliminate the need for explicit ``async_callback`` wrappers (as in `tornado.web.RequestHandler`), and to allow some additional context to be kept for logging. This is slightly magic, but it's an extension of the idea that an exception handler is a kind of stack-local state and when that stack is suspended and resumed in a new context that state needs to be preserved. `StackContext` shifts the burden of restoring that state from each call site (e.g. wrapping each `.AsyncHTTPClient` callback in ``async_callback``) to the mechanisms that transfer control from one context to another (e.g. `.AsyncHTTPClient` itself, `.IOLoop`, thread pools, etc). Example usage:: @contextlib.contextmanager def die_on_error(): try: yield except Exception: logging.error("exception in asynchronous operation",exc_info=True) sys.exit(1) with StackContext(die_on_error): # Any exception thrown here *or in callback and its descendants* # will cause the process to exit instead of spinning endlessly # in the ioloop. http_client.fetch(url, callback) ioloop.start() Most applications shouldn't have to work with `StackContext` directly. Here are a few rules of thumb for when it's necessary: * If you're writing an asynchronous library that doesn't rely on a stack_context-aware library like `tornado.ioloop` or `tornado.iostream` (for example, if you're writing a thread pool), use `.stack_context.wrap()` before any asynchronous operations to capture the stack context from where the operation was started. * If you're writing an asynchronous library that has some shared resources (such as a connection pool), create those shared resources within a ``with stack_context.NullContext():`` block. This will prevent ``StackContexts`` from leaking from one request to another. * If you want to write something like an exception handler that will persist across asynchronous calls, create a new `StackContext` (or `ExceptionStackContext`), and make your asynchronous calls in a ``with`` block that references your `StackContext`. � )�absolute_import�division�print_function�with_statementN� )�raise_exc_infoc @ s e Zd ZdS )� StackContextInconsistentErrorN)�__name__� __module__� __qualname__� r r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/zmq/eventloop/minitornado/stack_context.pyr N s r c @ s e Zd Zdd� ZdS )�_Statec C s t � d f| _d S �N)�tuple�contexts��selfr r r �__init__S s z_State.__init__N)r r r r r r r r r R s r c @ s@ e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dS )� StackContexta Establishes the given context as a StackContext that will be transferred. Note that the parameter is a callable that returns a context manager, not the context itself. That is, where for a non-transferable context manager you would say:: with my_context(): StackContext takes the function itself rather than its result:: with StackContext(my_context): The result of ``with StackContext() as cb:`` is a deactivation callback. Run this callback when the StackContext is no longer needed to ensure that it is not propagated any further (note that deactivating a context does not affect any instances of that context that are currently pending). This is an advanced feature and not necessary in most applications. c C s || _ g | _d| _d S �NT)�context_factoryr �active)r r r r r r l s zStackContext.__init__c C s d| _ d S �NF�r r r r r � _deactivateq s zStackContext._deactivatec C s | � � }| j�|� |�� d S r )r r �append� __enter__)r �contextr r r �enteru s zStackContext.enterc C s | j �� }|�|||� d S r )r �pop�__exit__)r �type�value� tracebackr r r r �exitz s zStackContext.exitc C sP t j| _| jd | f | f| _| jt _z | �� W n | jt _� Y n0 | jS �Nr )�_stater � old_contexts� new_contextsr r r r r r r � s zStackContext.__enter__c C sf z8| � |||� W tj}| jt_|| jur2td��d | _n(tj}| jt_|| jurZtd��d | _0 d S �NzWstack_context inconsistency (may be caused by yield within a "with StackContext" block))r% r' r r( r) r �r r" r# r$ Zfinal_contextsr r r r! � s �� �zStackContext.__exit__N) r r r �__doc__r r r r% r r! r r r r r X s r c @ s8 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd S ) �ExceptionStackContextaA Specialization of StackContext for exception handling. The supplied ``exception_handler`` function will be called in the event of an uncaught exception in this context. The semantics are similar to a try/finally clause, and intended use cases are to log an error, close a socket, or similar cleanup actions. The ``exc_info`` triple ``(type, value, traceback)`` will be passed to the exception_handler function. If the exception handler returns true, the exception will be consumed and will not be propagated to other exception handlers. c C s || _ d| _d S r )�exception_handlerr )r r. r r r r � s z ExceptionStackContext.__init__c C s d| _ d S r r r r r r r � s z!ExceptionStackContext._deactivatec C s |d ur| � |||�S d S r )r. �r r" r# r$ r r r r% � s zExceptionStackContext.exitc C s& t j| _| jd | f| _| jt _| jS r& )r' r r( r) r r r r r r � s z ExceptionStackContext.__enter__c C s� zh|d ur@| � |||�W tj}| jt_|| jur8td��d | _S W tj}| jt_|| jurbtd��d | _n(tj}| jt_|| jur�td��d | _0 d S r* )r. r' r r( r) r r+ r r r r! � s2 �� �� �z ExceptionStackContext.__exit__N) r r r r, r r r% r r! r r r r r- � s r- c @ s e Zd ZdZdd� Zdd� ZdS )� NullContextz�Resets the `StackContext`. Useful when creating a shared resource on demand (e.g. an `.AsyncHTTPClient`) where the stack that caused the creating is not relevant to future operations. c C s t j| _t� d ft _d S r )r' r r( r r r r r r � s zNullContext.__enter__c C s | j t_d S r )r( r' r r/ r r r r! � s zNullContext.__exit__N)r r r r, r r! r r r r r0 � s r0 c C s� t dd� | d D ��}| d }|dur8|js8|jd }q |}|durx|jd }|durr|jr^qr|j|_|jd }qN|}q<||fS )z*Remove deactivated handlers from the chainc S s g | ]}|j r|�qS r r )�.0�hr r r � <listcomp>� � z'_remove_deactivated.<locals>.<listcomp>r r N)r r r( )r Zstack_contexts�head�ctx�parentr r r �_remove_deactivated� s r8 c sf �du st �d�r�S tjg� � d d sN� d d sN� �fdd�}d|_|S � �fdd �}d|_|S ) a Returns a callable object that will restore the current `StackContext` when executed. Use this whenever saving a callback to be executed later in a different execution context (either in a different thread or asynchronously in the same thread). N�_wrappedr r c s4 z&t j}� d t _�| i |��W |t _S |t _0 d S r& )r' r )�args�kwargs� current_state�Z cap_contexts�fnr r � null_wrapper s �zwrap.<locals>.null_wrapperTc sV d }�zBt j}t� d � � d< }|t _d}d }d}|d }|D ]8} z| �� |d7 }W q@ t�� }| jd }Y q@0 q@|d u r�z�| i |��}W n t�� }|d }Y n0 |d ur�t||�}nh|dk�r|d8 }|| } z| j|� W q� t�� }| jd }Y �qY q�0 q�d }|d u�r.t||�}|dk�r@t |� W |t _n|t _0 |S )Nr �NNNr ) r' r r8 r �sys�exc_infor( �_handle_exceptionr% r ) r: r; �retr< r �exc�topZlast_ctx�stack�n�cr= r r �wrapped sP zwrap.<locals>.wrapped)�hasattrr' r r9 )r> r? rJ r r= r �wrap� s CrL c C s@ | d ur<z| j |� rd}W n t�� }Y n0 | jd } q |S )Nr@ r )r% rA rB r( )�tailrE r r r rC ` s rC c C s. | � |� W d � S 1 s 0 Y dS )a� Run a coroutine ``func`` in the given `StackContext`. It is not safe to have a ``yield`` statement within a ``with StackContext`` block, so it is difficult to use stack context with `.gen.coroutine`. This helper function runs the function in the correct context while keeping the ``yield`` and ``with`` statements syntactically separate. Example:: @gen.coroutine def incorrect(): with StackContext(ctx): # ERROR: this will raise StackContextInconsistentError yield other_coroutine() @gen.coroutine def correct(): yield run_with_stack_context(StackContext(ctx), other_coroutine) .. versionadded:: 3.1 Nr )r �funcr r r �run_with_stack_contextm s rO )r, � __future__r r r r rA � threading�utilr � Exceptionr �localr r' �objectr r- r0 r8 rL rC rO r r r r �<module> s 5 L0c
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка