← Back
Editing: reactor.cpython-38.pyc
U ���cl" � @ s� d Z ddlmZ ddlZddlZddlmZ ddlmZ G dd� de �Z G dd � d e �Z G d d � d e �Z G d d � d e �ZG dd� de �ZG dd� de�ZdS )zB Extend the regular Twisted reactor with event-handling features. � )�absolute_importN)� deferToThread)� format_objectc @ s e Zd ZdZdS )� InvalidIDz=Raised when an invalid ID is used with reactor.cancel_call().N��__name__� __module__� __qualname__�__doc__� r r �7/usr/lib/python3/dist-packages/landscape/lib/reactor.pyr s r c @ s e Zd ZdZdS )� CallHookErrorz-Raised when hooking on a reactor incorrectly.Nr r r r r r s r c @ s e Zd ZdZdd� ZdS )�EventIDz�Unique identifier for an event handler. @param event_type: Name of the event type handled by the handler. @param pair: Binary tuple C{(handler, priority)} holding the handler function and its priority. c C s || _ || _d S �N)� _event_type�_pair)�self� event_type�pairr r r �__init__ s zEventID.__init__N)r r r r r r r r r r s r c s: e Zd ZdZ� fdd�Zd dd�Zdd� Zd d � Z� ZS ) �EventHandlingReactorMixina� Fire events identified by strings and register handlers for them. Note that event handlers are executed synchronously when the C{fire} method is called, so unit-tests can generally exercise events without needing to run the real Twisted reactor (except of course if the event handlers themselves contain asynchronous calls that need the Twisted reactor running). c s t t| ��� i | _d S r )�superr r �_event_handlers�r �� __class__r r r - s z"EventHandlingReactorMixin.__init__r c C s: ||f}| j �|g �}|�|� |jdd� d� t||�S )a� Register an event handler. The handler will be invoked every time an event of the given type is fired (there's no need to re-register the handler after the event is fired). @param event_type: The name of the event type to handle. @param handler: The function handling the given event type. @param priority: The priority of the given handler function. @return: The L{EventID} of the registered handler. c S s | d S )N� r )r r r r �<lambda>B � z3EventHandlingReactorMixin.call_on.<locals>.<lambda>)�key)r � setdefault�append�sortr )r r �handler�priorityr �handlersr r r �call_on1 s z!EventHandlingReactorMixin.call_onc O s� t �d|� g }t| j�|d��}|D ]�\}}z(t �dt|�||� |�|||�� W q& tk r� t �dt|�|||� | � � � Y q& t k r� t �dt|�|||� Y q&X q&t �d|� |S )ac Fire an event of a given type. Call all handlers registered for the given C{event_type}, in order of priority. @param event_type: The name of the event type to fire. @param args: Positional arguments to pass to the registered handlers. @param kwargs: Keyword arguments to pass to the registered handlers. zStarted firing %s.r z#Calling %s for %s with priority %d.zTKeyboard interrupt while running event handler %s for event type %r with args %r %r.zAError running event handler %s for event type %r with args %r %r.zFinished firing %s.) �logging�debug�listr �getr r! �KeyboardInterruptZ exception�stop� Exception)r r �args�kwargsZresultsr% r# r$ r r r �fireF s: � � � z EventHandlingReactorMixin.firec C s2 t |�tkr"| j|j �|j� n td| ��dS )zfUnregister an event handler. @param id: the L{EventID} of the handler to unregister. z&EventID instance expected, received %rN)�typer r r �remover r �r �idr r r � cancel_callj s z%EventHandlingReactorMixin.cancel_call)r ) r r r r r r& r0 r5 � __classcell__r r r r r # s $r c @ s e Zd Zdd� ZdS )� ReactorIDc C s || _ d S r )Z_timeout)r Ztimeoutr r r r w s zReactorID.__init__N)r r r r r r r r r7 u s r7 c s� e Zd ZdZ� fdd�Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zdd� Z� ZS ) �EventHandlingReactora Wrap and add functionalities to the Twisted reactor. This is essentially a facade around the twisted.internet.reactor and will delegate to it for mostly everything except event handling features which are implemented using EventHandlingReactorMixin. c sF ddl m} ddlm} || _|| _| �� |j| _tt | �� � d S )Nr )�reactor)� LoopingCall) Ztwisted.internetr9 Ztwisted.internet.taskr: � _LoopingCall�_reactor�_cleanup�callFromThreadr r8 r )r r9 r: r r r r � s z EventHandlingReactor.__init__c C s t � � S )z5Get current time. @see L{time.time} )�timer r r r r? � s zEventHandlingReactor.timec O s | j j||�S )z�Call a function later. Simply call C{callLater(*args, **kwargs)} and return its result. @see: L{twisted.internet.interfaces.IReactorTime.callLater}. )r< Z callLater)r r. r/ r r r � call_later� s z EventHandlingReactor.call_laterc O s$ | j |f|�|�}|j|dd� |S )z�Call a function repeatedly. Create a new L{twisted.internet.task.LoopingCall} object and start it. @return: the created C{LoopingCall} object. F)Znow)r; �start)r Zseconds�fr. r/ Zlcr r r � call_every� s z EventHandlingReactor.call_everyc C s> t |t�rt�| |�S t || j�r*|�� S |�� r:|�� dS )a Cancel a scheduled function or event handler. @param id: The function call or handler to remove. It can be an L{EventID}, a L{LoopingCall} or a C{IDelayedCall}, as returned by L{call_on}, L{call_every} and L{call_later} respectively. N)� isinstancer r r5 r; r, �active�cancelr3 r r r r5 � s z EventHandlingReactor.cancel_callc C s | j �|� dS )zASchedule a function to be called when the reactor starts running.N)r< ZcallWhenRunning)r rB r r r �call_when_running� s z&EventHandlingReactor.call_when_runningc O s | j j|f|�|� dS )a1 Cause a function to be executed by the reactor thread. @param f: The callable object to execute. @param args: The arguments to call it with. @param kwargs: The keyword arguments to call it with. @see: L{twisted.internet.interfaces.IReactorThreads.callFromThread} N)r< r> )r rB r. r/ r r r � call_in_main� s z!EventHandlingReactor.call_in_mainc s@ � fdd�}�fdd�}t |f|�|�}|�|� |�|� dS )a Execute a callable object in a new separate thread. @param callback: A function to call in case C{f} was successful, it will be passed the return value of C{f}. @param errback: A function to call in case C{f} raised an exception, it will be pass a C{(type, value, traceback)} tuple giving information about the raised exception (see L{sys.exc_info}). @note: Both C{callback} and C{errback} will be executed in the the parent thread. c s � r � | �S d S r r )�result)�callbackr r � on_success� s z7EventHandlingReactor.call_in_thread.<locals>.on_successc s4 | j | j| jf}� r � |� ntj|d |d� d S )Nr )�exc_info)r1 �value�tbr' �error)ZfailurerL )�errbackr r � on_failure� s z7EventHandlingReactor.call_in_thread.<locals>.on_failureN)r Z addCallbackZ addErrback) r rJ rP rB r. r/ rK rQ Zdeferredr )rJ rP r �call_in_thread� s z#EventHandlingReactor.call_in_threadc C s | j j||dd�S )z!Start listening on a Unix socket.T)ZwantPID)r< Z listenUNIX�r Zsocket�factoryr r r � listen_unix� s z EventHandlingReactor.listen_unixc C s | j �||�S )zConnect to a Unix socket.)r< Z connectUNIXrS r r r � connect_unix� s z!EventHandlingReactor.connect_unixc C s" | � d� | j�� | � d� dS )z2Start the reactor, a C{"run"} event will be fired.�runr, N)r0 r< rW r r r r rW � s zEventHandlingReactor.runc C s | j �� | �� dS )z2Stop the reactor, a C{"stop"} event will be fired.N)r< r, r= r r r r r, � s zEventHandlingReactor.stopc C s$ | j �� D ]}|�� r |�� q d S r )r< ZgetDelayedCallsrE rF )r �callr r r r= � s z EventHandlingReactor._cleanup)r r r r r r? r@ rC r5 rG rH rR rU rV rW r, r= r6 r r r r r8 { s r8 )r Z __future__r r' r? Ztwisted.internet.threadsr Zlandscape.lib.formatr r- r r �objectr r r7 r8 r r r r �<module> s R
Save File
Cancel