File: //lib/python3/dist-packages/systemd/test/__pycache__/test_journal.cpython-38.pyc
U
��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/lib/python3/dist-packages/systemd/test/test_journal.py�__init__ s zMockSender.__init__Nc K s� d| g}|d k r,t |d|�}|�d| � || krJ| krJd krln n tjdd�d d d� \}}}|d k r�|�d| � |d k r�|�d �|�� |d k r�|�d
| � |�d d � |�� D �� | j�|� d S )
NzMESSAGE=�hex� 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>) s 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 sJ z
d V W n: t tfk
rD } z|j| kr2t�� � W 5 d }~X Y nX 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 k
r& t�� Y nX d S r )�
ValueErrorr) r* r r r r �skip_valueerror5 s
r/ c C s| t jj} | tj�t jks t�| tj�t jks0t�| tjd �t jksHt�| tjd �t jks`t�| tj d �t jksxt�| tj �t jks�t�| tj d �t j
ks�t�| tj d �t j
ks�t�| tj �t j
ks�t�| tj d �t j ks�t�| tj
d �t j k�st�| tj
�t j k�st�| tj
d �t jk�s2t�| tj�t jk�sHt�| tj�t jk�s^t�| tjd �t jk�sxt�d S )N� )r �JournalHandlerZ map_priority�loggingZNOTSETZ LOG_DEBUG�AssertionError�DEBUGZLOG_INFO�INFOZ LOG_WARNINGZWARNZLOG_ERRZERRORZLOG_CRITZFATALZCRITICALZ LOG_ALERT)�pr r r �test_priorities< s" r7 c C s. ddi} t �t�� tjf | � W 5 Q R X d S )Nz X r )r) �raisesr. r r1 ��kwr r r �"test_journalhandler_init_exceptionQ s r; c C s ddd�} t jtjf| � d S )Nr � )�X�X3)r r1 r2 r5 r9 r r r �test_journalhandler_initV s
r? c C s� t �dt jdddd d �} t� }dd|jd�}tjt jf|�}|�| � t|j �dksXt
�d|j d ksjt
�d
|j d ks|t
�d S ) N� test-logger�testpathr0 �testr r< )r= r> �sender_functionzX=3r zX3=4) r2 � LogRecordr5 r r" r r1 �emit�lenr r3 )�record�senderr: �handlerr r r �test_journalhandler_infoZ s
rJ c C sl t �dt jdddd d �} t� }tjt j|jd�}|�| � t|j �dksLt
�t dd� |j d D ��sht
�d S ) Nr@ rA r0 rB )rC c s s | ]}|� d � V qdS )r N)�
startswith)r �mr r r r k s z4test_journalhandler_no_message_id.<locals>.<genexpr>r ) r2 rD r5 r r r1 r" rE rF r r3 �all�rG rH rI r r r �!test_journalhandler_no_message_ide s
rO c C sj t �dt jdddd d �} t� }tjt j|jtd�}|�| � t |j
�dksNt �dtj |j
d ksft �d S �Nr@ rA r0 rB �rC r r r )
r2 rD r5 r r r1 r" �TEST_MIDrE rF r r3 r rN r r r �)test_journalhandler_message_id_on_handlerm s �
rS c C sl t �dt jdddd d �} t� }tjt j|jtjd�}|� | � t
|j �dksPt �dtj |j d ksht �d S rP )
r2 rD r5 r r r1 r" rR r rE rF r r3 rN r r r �-test_journalhandler_message_id_on_handler_hexv s �
rT c C st t �dt jdddd d �} t| jd< t� }tjt j|jt d�}|�
| � t |j �dksXt
�dtj |j d kspt
�d S � Nr@ rA r0 rB r rQ r r )r2 rD r5 � TEST_MID2�__dict__r r r1 r" rR rE rF r r3 r rN r r r �)test_journalhandler_message_id_on_message s
�
rX c C sv t �dt jdddd d �} tj| jd< t� }tjt j|j t
d�}|� | � t |j
�dksZt�dtj |j
d ksrt�d S rU )r2 rD r5 rV r rW r r r1 r" rR rE rF r r3 rN r r r �-test_journalhandler_message_id_on_message_hex� s �
rY 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 r_ c C s� t �t�� t�tj� W 5 Q R X t� � tj| jtjd�}W 5 Q R X t� � tj| jtjtjB d�}W 5 Q R X tj| jtjtj B d�}d S )N)�path�flags)
r) r8 r. r rZ ZOS_ROOTr/ �strpath� CURRENT_USERr[ )�tmpdirr\ r] r^ r r r �test_reader_os_root� s �
�
�re c C s> t j| jd�}t jd| jd� t j| jd�}t j| jd� d S )N�r` r )r rZ rb )rd r\ r] r r r �test_reader_init_path� s rg c C s( t �t�� tjddd� W 5 Q R X d S )Nr ���rf �r) r8 r& r rZ r r r r � test_reader_init_path_invalid_fd� s rj c C s( t �t�� tjddd� W 5 Q R X d S )Nr rf ri r r r r �%test_reader_init_path_nondirectory_fd� s rk c C s� t �| jt j�}ttj�� tj|d�}W 5 Q R X t |�g ksBt
�t � � tjtj |d�}W 5 Q R X t |�g kstt
�tjtj
|d�}t |�g ks�t
�d S �Nrf )�os�openrb �O_RDONLYr- r( �ENOSYSr rZ �listr3 r/ ZSYSTEMrc )rd �fdr\ r] r^ r r r �test_reader_init_path_fd� s rs c C sT t j| jd�}|� |jr t�W 5 Q R X |js2t�t�t�� t|� W 5 Q R X d S rl ) r rZ rb �closedr3 r) r8 r& �next�rd �jr r r �test_reader_as_cm� s
rx c C s< t j| jd�}|� |�tj� |�tjj� W 5 Q R X d S rl )r rZ rb Zmessageid_matchr ZSD_MESSAGE_JOURNAL_STARTZSD_MESSAGE_JOURNAL_STOPr rv r r r �test_reader_messageid_match� s ry c C s@ t j| jd�}|�$ |�� |�t� |�tj� W 5 Q R X d S rl )r rZ rb Z this_bootrR r rv r r r �test_reader_this_boot� s
rz c C s@ t j| jd�}|�$ |�� |�t� |�tj� W 5 Q R X d S rl )r rZ rb Z this_machinerR r rv r r r �test_reader_this_machine� s
r{ c
C s^ t j| jd�}|�& ttj�� |�d�}W 5 Q R X W 5 Q R X t|t�sLt �|t� ksZt �d S )Nrf ZFOOBAR)
r rZ rb r- r( rp Z query_unique�
isinstance�setr3 �rd rw Zansr r r �test_reader_query_unique� s r c
C s\ t j| jd�}|�$ ttj�� |�� }W 5 Q R X W 5 Q R X t|t�sJt �|t� ksXt �d S rl )
r rZ rb r- r( rp Zenumerate_fieldsr| r} r3 r~ r r r � test_reader_enumerate_fields� s r� c
C sL t j| jd�}|�$ ttj�� |�� }W 5 Q R X W 5 Q R X |dksHt�d S �Nrf F�r rZ rb r- r( rp Zhas_runtime_filesr3 r~ r r r � test_reader_has_runtime_files� s
r� c
C sL t j| jd�}|�$ ttj�� |�� }W 5 Q R X W 5 Q R X |dksHt�d S r� r� r~ r r r � test_reader_has_persistent_files� s
r� c C sP ddd� i}t j| j|d�}|�dd�}|dks4t�|�dd�}|dksLt�d S ) NZxxxc S s dS �N�yyyr ��argr r r �<lambda> � z(test_reader_converters.<locals>.<lambda>�r` �
converters� abcr� Zzzz� ��)r rZ rb Z_convert_fieldr3 �rd r� rw r r r r �test_reader_converters� s r� c C s` dd� dd� d�}t j| j|d�}|�ddddgdd gd
��}|d dd d gdd gd
�ks\t�d S )
Nc S s dS r� r r� r r r r�
r� z+test_reader_convert_entry.<locals>.<lambda>c S s dS )N�YYYr r� r r r r� r� )�x1�x2r� r� r� s defs ��)r� Zy1r� Zy2r� r� )r rZ rb Z_convert_entryr3 r� r r r �test_reader_convert_entry s ���r� c C sF t j| jd�}t�� }|�|� |�d� t�ddd�}|�|� d S )Nrf i90 i� � r< )r rZ rb �timeZ
seek_realtime�datetime)rd rw ZnowZlong_agor r r �test_seek_realtime s
r� c C sF t tj�� t�d�} W 5 Q R X | �d�}|dks6t�td| d� d S )Nztest_journal.pyz message...
)� Nzprinted message...)�file)r- r( ZENOENTr �stream�writer3 �print)r� �resr r r �test_journal_stream" s
r� )3Z
__future__r �
contextlibr� r( r2 rm r� Zuuid� tracebackr Zsystemdr r Zsystemd.journalr r) ZUUIDrR rV r �contextmanagerr- r/ r7 r; r? rJ rO rS rT rX rY r_ re rg rj rk rs rx ry rz r{ r r� r� r� r� r� r� r� r r r r �<module> sZ