golden hour
/opt/saltstack/salt/lib/python3.10/site-packages/salt/_logging/__pycache__
⬆️ Go Up
Upload
File/Folder
Size
Actions
__init__.cpython-310.pyc
1.77 KB
Del
OK
handlers.cpython-310.pyc
8.52 KB
Del
OK
impl.cpython-310.pyc
20.33 KB
Del
OK
mixins.cpython-310.pyc
4.11 KB
Del
OK
Edit: handlers.cpython-310.pyc
o �xe+ � @ s$ d Z ddlZddlZddlZddlZddlZddlmZ ddl m Z ddl m Z e� e�ZG dd� dej�ZG dd � d e ej�ZG d d � d e�ZG d d � d e ej�ZG dd� de ejj�ZG dd� de ejj�ZG dd� de ejj�Zejdk r�G dd� de ejj�ZdS G dd� de ejj�ZdS )zT salt._logging.handlers ~~~~~~~~~~~~~~~~~~~~~~ Salt's logging handlers � N)�deque)� ExcInfoOnLogLevelFormatMixin)�warn_until_datec s: e Zd ZdZejdf� fdd� Zdd� Zd dd �Z� Z S ) �TemporaryLoggingHandlera This logging handler will store all the log records up to its maximum queue size at which stage the first messages stored will be dropped. Should only be used as a temporary logging handler, while the logging system is not fully configured. Once configured, pass any logging handlers that should have received the initial log messages to the function :func:`TemporaryLoggingHandler.sync_with_handlers` and all stored log records will be dispatched to the provided handlers. .. versionadded:: 0.17.0 �' c s0 t ddjtd�� t� j|d� t|d�| _d S )N�20240101zqPlease stop using '{name}.TemporaryLoggingHandler'. '{name}.TemporaryLoggingHandler' will go away after {{date}}.��name)�level��maxlen)r �format�__name__�super�__init__r �"_TemporaryLoggingHandler__messages)�selfr �max_queue_size�� __class__� �J/opt/saltstack/salt/lib/python3.10/site-packages/salt/_logging/handlers.pyr % s ��z TemporaryLoggingHandler.__init__c C � | � � | j�|� | �� d S �N)�acquirer �append�release�r �recordr r r �handle/ � z TemporaryLoggingHandler.handler c C sH |sdS | j r"| j �� }|D ]}|j|jkrq|�|� q| j sdS dS �zK Sync the stored log records to the provided log handlers. N)r �popleftr Zlevelnor �r �handlersr �handlerr r r �sync_with_handlers4 s �z*TemporaryLoggingHandler.sync_with_handlers�r ) r � __module__� __qualname__�__doc__�loggingZNOTSETr r r& � __classcell__r r r r r s r c @ � e Zd ZdZdS )� StreamHandlerzO Stream handler which properly handles exc_info on a per handler basis N�r r( r) r* r r r r r. E � r. c s@ e Zd ZdZd � fdd� Zdd� Z� fdd�Zd d d �Z� ZS )�DeferredStreamHandlera� This logging handler will store all the log records up to its maximum queue size at which stage the first messages stored will be dropped. Should only be used as a temporary logging handler, while the logging system is not fully configured. Once configured, pass any logging handlers that should have received the initial log messages to the function :func:`DeferredStreamHandler.sync_with_handlers` and all stored log records will be dispatched to the provided handlers. If anything goes wrong before logging is properly setup, all stored messages will be flushed to the handler's stream, ie, written to console. .. versionadded:: 3005 r c s" t � �|� t|d�| _d| _d S )Nr F)r r r � _DeferredStreamHandler__messages� _DeferredStreamHandler__emitting)r �streamr r r r r ^ s z DeferredStreamHandler.__init__c C r r )r r2 r r r r r r r c r z DeferredStreamHandler.handlec sT | j rd S | jr#zd| _ | j�� }t� �|� W d| _ nd| _ w | jst� �� d S )NTF)r3 r2 r" r r �flushr r r r r5 h s � zDeferredStreamHandler.flushr c C s< | j r | j �� }|D ] }|| u rq |�|� q | j sdS dS r! )r2 r" r r# r r r r& y s �z(DeferredStreamHandler.sync_with_handlers)r r' ) r r( r) r* r r r5 r& r, r r r r r1 K s r1 c @ r- )� FileHandlerzM File handler which properly handles exc_info on a per handler basis Nr/ r r r r r6 � r0 r6 c � e Zd ZdZ� fdd�Z� ZS )� SysLogHandlerzO Syslog handler which properly handles exc_info on a per handler basis c sh d}t jr(t jdkr(t �� \}}}z|jdv r t j�d� d}W ~~~n~~~w |s2t� �|� dS dS )z� Override the default error handling mechanism for py3 Deal with syslog os errors when the log file does not exist F)� � � �FileNotFoundErrorzc[WARNING ] The log_file does not exist. Logging not setup correctly or syslog service not started. TN)�sys�stderr� version_info�exc_infor �writer � handleError�r r Zhandled�exc_type�exc� exc_tracebackr r r rB � s ���zSysLogHandler.handleError�r r( r) r* rB r, r r r r r8 � s r8 c r7 )�RotatingFileHandlerzV Rotating file handler which properly handles exc_info on a per handler basis c s� d}t j�d�r;tjr;t jr;t �� \}}}z!|jdv r2|jdkr2| j tj kr0t j� d� | j �� d}W ~~~n~~~w |sEt� �|� dS dS )z� Override the default error handling mechanism Deal with log file rotation errors due to log file in use more softly. F�win)�PermissionError�OSError� zC[WARNING ] Unable to rotate the log file "{}" because it is in use TN)r= �platform� startswithr+ ZraiseExceptionsr> r@ r �winerrorr ZWARNINGrA r Z baseFilenamer rB rC r r r rB � s, ��� ���z RotatingFileHandler.handleErrorrG r r r r rH � s rH c @ r- )�WatchedFileHandlerzU Watched file handler which properly handles exc_info on a per handler basis Nr/ r r r r rP � s rP )r9 � c s, e Zd Z� fdd�Zdd� Zdd� Z� ZS )� QueueHandlerc �" t � �|� tddjtd�� d S �Nr z�Please stop using '{name}.QueueHandler' and instead use 'logging.handlers.QueueHandler'. '{name}.QueueHandler' will go away after {{date}}.r �r r r r r �r �queuer r r r � � ���QueueHandler.__init__c C �< z | j �|� W dS tjy tj�d�|�� Y dS w �z� Enqueue a record. The base implementation uses put_nowait. You may want to override this method if you want to use blocking, timeouts or custom queue implementations. z?[WARNING ] Message queue is full, unable to write "{}" to log. N�rW Z put_nowait�_queueZFullr= r> rA r r r r r �enqueue� � ���QueueHandler.enqueuec C s6 | � |�}t�|�}||_||_d|_d|_d|_|S )a� Prepares a record for queuing. The object returned by this method is enqueued. The base implementation formats the record to merge the message and arguments, and removes unpickleable items from the record in-place. You might want to override this method if you want to convert the record to a dict or JSON string, or send a modified copy of the record while leaving the original intact. N)r �copy�message�msg�argsr@ Zexc_text)r r rc r r r �prepare� s zQueueHandler.prepare)r r( r) r r^ re r, r r r r rR � s rR c s$ e Zd Z� fdd�Zdd� Z� ZS )rR c rS rT rU rV r r r r rX rY c C rZ r[ r\ r r r r r^ % r_ r` )r r( r) r r^ r, r r r r rR s )r* ra r+ Zlogging.handlersrW r] r= � collectionsr Zsalt._logging.mixinsr Zsalt.utils.versionsr Z getLoggerr �logZ NullHandlerr r. r1 r6 r$ r8 rH rP r? rR r r r r �<module> s8 0: � +� � :�
Save