| Server IP : 209.38.156.173 / Your IP : 216.73.216.122 [ Web Server : Apache/2.4.52 (Ubuntu) System : Linux lakekumayuhotel 5.15.0-136-generic #147-Ubuntu SMP Sat Mar 15 15:53:30 UTC 2025 x86_64 User : root ( 0) PHP Version : 8.1.2-1ubuntu2.22 Disable Function : NONE Domains : 2 Domains MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /usr/lib/python3/dist-packages/twisted/logger/__pycache__/ |
Upload File : |
o
�b� � @ s� d Z ddlmZmZ ddlmZ ddlmZ ddlm Z m
Z
ddl m Z dZ
ee �G d d
� d
��Zee �d e
d d
fdd��Zd
S )z
Basic log observers.
� )�Callable�Optional)� implementer)�Failure� )� ILogObserver�LogEvent)�LoggerzITemporarily disabling observer {observer} due to exception: {log_failure}c @ sj e Zd ZdZdeddfdd�Zdeddfdd �Zdeddfd
d �Zd eddfd
d�Z dede
fdd�Z dS )� LogPublisherz�
I{ILogObserver} that fans out events to other observers.
Keeps track of a set of L{ILogObserver} objects and forwards
events to each.
� observers�returnNc G s t |�| _t| d�| _d S )N��observer)�list�
_observersr �log)�selfr � r �:/usr/lib/python3/dist-packages/twisted/logger/_observer.py�__init__ s
zLogPublisher.__init__r c C s4 t |�s td|����|| jvr| j�|� dS dS )zq
Registers an observer with this publisher.
@param observer: An L{ILogObserver} to add.
zObserver is not callable: N)�callable� TypeErrorr �append�r r r r r � addObserver# s
�zLogPublisher.addObserverc C s( z | j �|� W dS ty Y dS w )zv
Unregisters an observer with this publisher.
@param observer: An L{ILogObserver} to remove.
N)r �remove�
ValueErrorr r r r �removeObserver. s
�zLogPublisher.removeObserver�eventc s� d� vrd}n dt ddf� �fdd� }g }�jD ]!}|dur"||� z|� � W q ty9 |�|t� f� Y qw |D ]\}}��|�}|jt||d� q<dS )z8
Forward events to contained observers.
� log_traceNr r c s � d � �| f� dS )z�
Add tracing information for an observer.
@param observer: an observer being forwarded to
r N)r r
�r r r r �traceB s z$LogPublisher.__call__.<locals>.trace)�failurer )r r � Exceptionr r �_errorLoggerForObserverr" �OBSERVER_DISABLED)r r r! �brokenObserversr �brokenObserverr" � errorLoggerr r r �__call__9 s(
�
��zLogPublisher.__call__c s" t � fdd�| jD �� }t|d�S )z�
Create an error-logger based on this logger, which does not contain the
given bad observer.
@param observer: The observer which previously had an error.
@return: A L{Logger} without the given observer.
c 3 s � | ] }|� ur|V qd S )Nr )�.0�obsr
r r � <genexpr>g s � z7LogPublisher._errorLoggerForObserver.<locals>.<genexpr>r
)r
r r )r r �errorPublisherr r
r r$ ] s �
z$LogPublisher._errorLoggerForObserver) �__name__�
__module__� __qualname__�__doc__r r r r r r) r r$ r r r r r
s $r
r r Nc C s dS )zD
I{ILogObserver} that does nothing with the events it sees.
Nr )r r r r �bitbucketLogObserverl s r2 )r1 �typingr r �zope.interfacer �twisted.python.failurer � _interfacesr r �_loggerr r% r
r2 r r r r �<module> s �U