| Server IP : 178.128.116.179 / Your IP : 216.73.216.206 Web Server : nginx/1.30.3 System : Linux glamautowash 6.8.0-71-generic #71-Ubuntu SMP PREEMPT_DYNAMIC Tue Jul 22 16:52:38 UTC 2025 x86_64 User : root ( 0) PHP Version : 8.4.22 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : OFF Directory : /lib/python3/dist-packages/twisted/logger/__pycache__/ |
Upload File : |
�
oj� � �n � d Z ddlmZ ddlmZmZ ddlmZ ddlm Z m
Z
dZ ee � G d� d � � Z y
) z'
Log observer that maintains a buffer.
� )�deque)�Deque�Optional)� implementer� )� ILogObserver�LogEventi c �J � e Zd ZdZefdee ddfd�Zdeddfd�Z de
ddfd �Z y)
�LimitedHistoryLogObservera�
L{ILogObserver} that stores events in a buffer of a fixed size::
>>> from twisted.logger import LimitedHistoryLogObserver
>>> history = LimitedHistoryLogObserver(5)
>>> for n in range(10): history({'n': n})
...
>>> repeats = []
>>> history.replayTo(repeats.append)
>>> len(repeats)
5
>>> repeats
[{'n': 5}, {'n': 6}, {'n': 7}, {'n': 8}, {'n': 9}]
>>>
�size�returnNc �& � t |�� | _ y)zx
@param size: The maximum number of events to buffer. If L{None}, the
buffer is unbounded.
)�maxlenN)r �_buffer)�selfr s �8/usr/lib/python3/dist-packages/twisted/logger/_buffer.py�__init__z"LimitedHistoryLogObserver.__init__% s � �
).�T�(:�� � �eventc �: � | j j |� y )N)r �append)r r s r �__call__z"LimitedHistoryLogObserver.__call__, s � � � � ���E�"r �
otherObserverc �6 � | j D ]
} ||� � y)z�
Re-play the buffered events to another log observer.
@param otherObserver: An observer to replay events to.
N)r )r r r s r �replayToz"LimitedHistoryLogObserver.replayTo/ s � � �\�\� !�E� �%� � !r ) �__name__�
__module__� __qualname__�__doc__�_DEFAULT_BUFFER_MAXIMUMr �intr r r r r � r r r r sJ � �� .E� ;�X�c�]� ;�� ;�#�h� #�4� #�!�l� !�t� !r r N)
r � collectionsr �typingr r �zope.interfacer � _interfacesr r r r r" r r �<module>r' s< ��
� � "� &� /�#� �
�\��"!� "!� �"!r