o b @sdZddlmZmZddlmZddlmZddlm Z m Z ddl m Z dZ ee Gd d d Zee d e d d fddZd S)z Basic log observers. )CallableOptional) implementer)Failure) ILogObserverLogEvent)LoggerzITemporarily disabling observer {observer} due to exception: {log_failure}c@sjeZdZdZdeddfddZdeddfdd Zdeddfd d Zd eddfd dZ dede fddZ 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. observersreturnNcGst||_t|d|_dS)Nobserver)list _observersr log)selfr r:/usr/lib/python3/dist-packages/twisted/logger/_observer.py__init__s zLogPublisher.__init__rcCs4t|s td|||jvr|j|dSdS)zq Registers an observer with this publisher. @param observer: An L{ILogObserver} to add. zObserver is not callable: N)callable TypeErrorrappendrrrrr addObserver#s  zLogPublisher.addObservercCs(z |j|WdStyYdSw)zv Unregisters an observer with this publisher. @param observer: An L{ILogObserver} to remove. N)rremove ValueErrorrrrrremoveObserver.s  zLogPublisher.removeObservereventc sdvrd}n dtddffdd }g}jD]!}|dur"||z|Wqty9||tfYqw|D]\}}|}|jt||dq.trace)failurer)rr Exceptionrr_errorLoggerForObserverr"OBSERVER_DISABLED)rrr!brokenObserversrbrokenObserverr" errorLoggerrr r__call__9s(     zLogPublisher.__call__cs"tfdd|jD}t|dS)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. c3s|] }|ur|VqdS)Nr).0obsr rr gsz7LogPublisher._errorLoggerForObserver..r )r rr )rrerrorPublisherrr rr$]s  z$LogPublisher._errorLoggerForObserver) __name__ __module__ __qualname____doc__rrrrrr)r r$rrrrr s  $r rr NcCsdS)zD I{ILogObserver} that does nothing with the events it sees. Nr)rrrrbitbucketLogObserverlsr2)r1typingrrzope.interfacertwisted.python.failurer _interfacesrr_loggerr r%r r2rrrrs   U