JezK
Edit File: test_journal.cpython-39.opt-1.pyc
a ��X]' � @ s� d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl m Z m Z d dlmZ d dlZe�d�Ze�d�ZG dd� d�Zejd d � �Zejd d � �Zd d� Zdd� Zdd� Zdd� Zdd� Z dd� Z dd� Z dd � Z d d � Z d d � Z!d!d"� Z"d#d$� Z#d%d&� Z$d'd(� Z%d)d*� Z&d+d,� Z'd-d.� Z(d/d0� Z)d1d2� Z*d3d4� Z+d5d6� Z,d7d8� Z-d9d:� Z.d;d<� Z/d=d>� Z0d?d@� Z1dAdB� Z2dS )C� )�print_functionN)�journal�id128�� _make_lineZ 8441372f8dca4ca98694a6091fd8519fZ 8441370000000000000000001fd85000c @ s e Zd Zdd� Zddd�ZdS )� MockSenderc C s g | _ d S �N)�buf)�self� r �?/usr/lib64/python3.9/site-packages/systemd/test/test_journal.py�__init__ s zMockSender.__init__Nc K s� d| g}|d ur,t |d|�}|�d| � || u rJ| u rJd u rln n tjdd�d d d� \}}}|d ur�|�d| � |d ur�|�d �|�� |d ur�|�d | � |�d d � |�� D �� | j�|� d S ) NzMESSAGE=�hexz MESSAGE_ID=� )�limitr � z CODE_FILE=zCODE_LINE={:d}z CODE_FUNC=c s s | ]\}}t ||�V qd S r r )�.0�key�valr r r � <genexpr>) � z"MockSender.send.<locals>.<genexpr>)�getattr�append� _traceback� extract_stack�format�extend�itemsr ) r ZMESSAGE� MESSAGE_IDZ CODE_FILEZ CODE_LINEZ CODE_FUNC�kwargs�args�idr r r �send s " zMockSender.send)NNNN)�__name__� __module__� __qualname__r r" r r r r r s �r c c sL z d V W n< t tfyF } z |j| kr0t�� � W Y d }~n d }~0 0 d S r )�OSError�IOError�errno�pytest�skip)�code�er r r � skip_oserror, s r- c c s* z d V W n t y$ t�� Y n0 d S r )� ValueErrorr) r* r r r r �skip_valueerror5 s r/ c C s t jj} d S r )r �JournalHandlerZ map_priority)�pr r r �test_priorities< s r2 c C sF ddi} t �t�� tjf i | �� W d � n1 s80 Y d S )Nz X r )r) �raisesr. r r0 ��kwr r r �"test_journalhandler_init_exceptionQ s r6 c C s" ddd�} t jtjfi | �� d S )Nr � )�X�X3)r r0 �logging�INFOr4 r r r �test_journalhandler_initV s r< c C sN t �dt jdddd d �} t� }dd|jd�}tjt jfi |��}|�| � d S )N� test-logger�testpath� �testr r7 )r8 r9 �sender_function)r: � LogRecordr; r r" r r0 �emit)�record�senderr5 �handlerr r r �test_journalhandler_infoZ s rG c C s> t �dt jdddd d �} t� }tjt j|jd�}|�| � d S )Nr= r> r? r@ )rA )r: rB r; r r r0 r" rC �rD rE rF r r r �!test_journalhandler_no_message_ide s rI c C s@ t �dt jdddd d �} t� }tjt j|jtd�}|�| � d S �Nr= r> r? r@ �rA r ) r: rB r; r r r0 r" �TEST_MIDrC rH r r r �)test_journalhandler_message_id_on_handlerm s � rM c C sB t �dt jdddd d �} t� }tjt j|jtjd�}|� | � d S rJ ) r: rB r; r r r0 r" rL r rC rH r r r �-test_journalhandler_message_id_on_handler_hexv s � rN c C sJ t �dt jdddd d �} t| jd< t� }tjt j|jt d�}|� | � d S �Nr= r> r? r@ r rK ) r: rB r; � TEST_MID2�__dict__r r r0 r" rL rC rH r r r �)test_journalhandler_message_id_on_message s � rR c C sL t �dt jdddd d �} tj| jd< t� }tjt j|j t d�}|� | � d S rO ) r: rB r; rP r rQ r r r0 r" rL rC rH r r r �-test_journalhandler_message_id_on_message_hex� s � rS c C sR t �� } t �t j�}t �t j�}t �t j�}t �t jt jB t jB �}t �d�}d S )Nr )r �ReaderZ LOCAL_ONLYZ RUNTIME_ONLY� SYSTEM_ONLY)�j1�j2�j3Zj4Zj5Zj6r r r �test_reader_init_flags� s rY c C s� t �t�� t�tj� W d � n1 s,0 Y t� �" tj| jtjd�}W d � n1 sd0 Y t� �( tj| jtjtjB d�}W d � n1 s�0 Y tj| jtjtj B d�}d S )N)�path�flags) r) r3 r. r rT ZOS_ROOTr/ �strpath� CURRENT_USERrU )�tmpdirrV rW rX r r r �test_reader_os_root� s *�$ �$ �r_ c C s> t j| jd�}t jd| jd� t j| jd�}t j| jd� d S )N�rZ r )r rT r\ )r^ rV rW r r r �test_reader_init_path� s ra c C s< t �t�� tjddd� W d � n1 s.0 Y d S )Nr ���r` �r) r3 r& r rT r r r r � test_reader_init_path_invalid_fd� s rd c C s< t �t�� tjddd� W d � n1 s.0 Y d S )Nr r` rc r r r r �%test_reader_init_path_nondirectory_fd� s re c C s� t �| jt j�}ttj�� tj|d�}W d � n1 s<0 Y t � � tjtj |d�}W d � n1 sr0 Y tjtj |d�}d S �Nr` ) �os�openr\ �O_RDONLYr- r( �ENOSYSr rT r/ ZSYSTEMr] )r^ �fdrV rW rX r r r �test_reader_init_path_fd� s *.rl c C sh t j| jd�}|� W d � n1 s(0 Y t�t�� t|� W d � n1 sZ0 Y d S rf )r rT r\ r) r3 r& �next�r^ �jr r r �test_reader_as_cm� s rp c C sP t j| jd�}|�* |�tj� |�tjj� W d � n1 sB0 Y d S rf )r rT r\ Zmessageid_matchr ZSD_MESSAGE_JOURNAL_STARTZSD_MESSAGE_JOURNAL_STOPr rn r r r �test_reader_messageid_match� s rq c C sT t j| jd�}|�. |�� |�t� |�tj� W d � n1 sF0 Y d S rf )r rT r\ Z this_bootrL r rn r r r �test_reader_this_boot� s rr c C sT t j| jd�}|�. |�� |�t� |�tj� W d � n1 sF0 Y d S rf )r rT r\ Z this_machinerL r rn r r r �test_reader_this_machine� s rs c C sj t j| jd�}|�D ttj�� |�d�}W d � n1 s>0 Y W d � n1 s\0 Y d S )Nr` ZFOOBAR)r rT r\ r- r( rj Z query_unique�r^ ro Zansr r r �test_reader_query_unique� s Fru c C sh t j| jd�}|�B ttj�� |�� }W d � n1 s<0 Y W d � n1 sZ0 Y d S rf )r rT r\ r- r( rj Zenumerate_fieldsrt r r r � test_reader_enumerate_fields� s Drv c C sh t j| jd�}|�B ttj�� |�� }W d � n1 s<0 Y W d � n1 sZ0 Y d S rf �r rT r\ r- r( rj Zhas_runtime_filesrt r r r � test_reader_has_runtime_files� s Drx c C sh t j| jd�}|�B ttj�� |�� }W d � n1 s<0 Y W d � n1 sZ0 Y d S rf rw rt r r r � test_reader_has_persistent_files� s Dry c C s8 ddd� i}t j| j|d�}|�dd�}|�dd�}d S )NZxxxc S s dS �NZyyyr ��argr r r �<lambda> r z(test_reader_converters.<locals>.<lambda>�rZ � converters� abcZzzz� ��)r rT r\ Z_convert_field�r^ r ro r r r r �test_reader_converters� s r� c C sB dd� dd� d�}t j| j|d�}|�ddddgdd gd ��}d S ) Nc S s dS rz r r{ r r r r} r z+test_reader_convert_entry.<locals>.<lambda>c S s dS )NZYYYr r{ r r r r} r )�x1�x2r~ r� r� s defs ��)r� Zy1r� Zy2)r rT r\ Z_convert_entryr� r r r �test_reader_convert_entry s ��r� c C sF t j| jd�}t�� }|�|� |�d� t�ddd�}|�|� d S )Nr` i90 i� � r7 )r rT r\ �timeZ seek_realtime�datetime)r^ ro ZnowZlong_agor r r �test_seek_realtime s r� c C sN t tj�� t�d�} W d � n1 s*0 Y | �d�}td| d� d S )Nztest_journal.pyz message... zprinted message...)�file)r- r( �ENOENTr �stream�write�print)r� �resr r r �test_journal_stream" s ( r� )3Z __future__r � contextlibr� r( r: rg r� Zuuid� tracebackr Zsystemdr r Zsystemd.journalr r) ZUUIDrL rP r �contextmanagerr- r/ r2 r6 r< rG rI rM rN rR rS rY r_ ra rd re rl rp rq rr rs ru rv rx ry r� r� r� r� r r r r �<module> sZ