🔐 Sid Gifari File Manager Pro
v8.0.5 | 2026-08-09 06:31:06 | PHP 8.2.33
📂
/ (Root)
/
opt
/
alt
/
python38
/
lib
/
python3.8
/
site-packages
/
timeout_decorator
/
__pycache__
📍 /opt/alt/python38/lib/python3.8/site-packages/timeout_decorator/__pycache__
🔄 Refresh
✏️
Editing: timeout_decorator.cpython-38.pyc
Read Only
U �{�_ � @ s� d Z ddlmZ ddlmZ ddlmZ ddlZddlZddlZddlZddl m Z G dd� de �Z d d � Z dd e dfd d �Zdd� ZG dd� de�ZdS )zk Timeout decorator. :copyright: (c) 2012-2013 by PN. :license: MIT, see LICENSE for more details. � )�print_function)�unicode_literals)�divisionN��wrapsc @ s" e Zd ZdZddd�Zdd� ZdS ) � TimeoutErrorz>Thrown when a timeout occurs in the `timeout` context manager.� Timed Outc C s || _ d S �N)�value)�selfr � r �T/opt/alt/python38/lib/python3.8/site-packages/timeout_decorator/timeout_decorator.py�__init__ s zTimeoutError.__init__c C s t | j�S r )�reprr �r r r r �__str__" s zTimeoutError.__str__N)r )�__name__� __module__� __qualname__�__doc__r r r r r r r s r c C s |dkr| � �n| |��dS )z� This function checks if a exception message is given. If there is no exception message, the default behaviour is maintained. If there is an exception message, the message is passed to the exception with the 'value' keyword. Nr )� exception�exception_messager r r �_raise_exception& s r Tc s � ���fdd�}|S )a� Add a timeout parameter to a function and return it. :param seconds: optional time limit in seconds or fractions of a second. If None is passed, no timeout is applied. This adds some flexibility to the usage: you can disable timing out depending on the settings. :type seconds: float :param use_signals: flag indicating whether signals should be used for timing function out or the multiprocessing When using multiprocessing, timeout granularity is limited to 10ths of a second. :type use_signals: bool :raises: TimeoutError if time limit is reached It is illegal to pass anything other than a function as the first parameter. The function is wrapped and returned to the caller. c sP �r.��fdd��t � �� ��fdd��}|S t � ��� ��fdd��}|S d S )Nc s t �� � d S r )r )�signum�frame)r �timeout_exceptionr r �handlerD s z*timeout.<locals>.decorate.<locals>.handlerc sp |� d��}|r,t�tj��}t�tj|� �s:� | |�S z� | |�W �S |rjt�tjd� t�tj|� X d S )N�timeoutr )�pop�signal�SIGALRM� setitimer� ITIMER_REAL)�args�kwargsZ new_seconds�old)�functionr �secondsr r � new_functionG s z/timeout.<locals>.decorate.<locals>.new_functionc s t ��� ��}|| |�S r )�_Timeout)r# r$ Ztimeout_wrapper)r r& r' r r r r( Y s r )r& r( �r r' r � use_signals)r& r r �decorateA s ztimeout.<locals>.decorater )r' r+ r r r, r r* r r 2 s r c O s@ z| � d|||�f� W n" | � dt�� d f� Y nX dS )al Run a function with arguments and return output via a queue. This is a helper function for the Process created in _Timeout. It runs the function with positional arguments and keyword arguments and then returns the function's output by way of a queue. If an exception gets raised, it is returned to _Timeout to be raised by the value property. TF� N)�put�sys�exc_info)�queuer& r# r$ r r r �_targetb s r2 c @ s@ e Zd ZdZdd� Zdd� Zdd� Zedd � �Zed d � �Z d S ) r) a Wrap a function and add a timeout (limit) attribute to it. Instances of this class are automatically generated by the add_timeout function defined above. Wrapping a function allows asynchronous calls to be made and termination of execution after a timeout has passed. c C sJ || _ || _|| _|| _|j| _|j| _t�� | _t� � | _ t� � | _ dS )z4Initialize instance in preparation for being called.N) �_Timeout__limit�_Timeout__function�_Timeout__timeout_exception�_Timeout__exception_messager r �time�_Timeout__timeout�multiprocessing�Process�_Timeout__process�Queue�_Timeout__queue)r r& r r �limitr r r r y s z_Timeout.__init__c O s� |� d| j�| _t�d�| _| j| jf| }tjt||d�| _d| j_ | j� � | jdk rj| jt � � | _ | j s|t �d� qj| jS )a Execute the embedded function object asynchronously. The function given to the constructor is transparently called and requires that "ready" be intermittently polled. If and when it is True, the "value" property may then be checked for returned data. r r- )�targetr# r$ TNg{�G�z�?)r r3 r9 r< r= r4 r: r2 r; �daemon�startr7 r8 �ready�sleepr )r r# r$ r r r �__call__� s � z_Timeout.__call__c C s& | j �� r| j �� t| j| j� dS )z:Terminate any possible execution of the embedded function.N)r; �is_alive� terminater r5 r6 r r r r �cancel� s z_Timeout.cancelc C s2 | j r | jt�� k r | �� | j�� o0| j�� S )z9Read-only property indicating status of "value" property.)r3 r8 r7 rG r= �full�emptyr r r r rB � s z_Timeout.readyc C s( | j dkr$| j�� \}}|r |S |�dS )z:Read-only property containing data returned from function.TN)rB r= �get)r �flag�loadr r r r � s z_Timeout.valueN) r r r r r rD rG �propertyrB r r r r r r) p s r) )r � __future__r r r r/ r7 r9 r � functoolsr �AssertionErrorr r r r2 �objectr) r r r r �<module> s 0
💾 Save Changes
❌ Cancel