3
��X]' � @ s� d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z
d dl m Z m
Z
d dlmZ d dlZejd�Zejd�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.6/test_journal.py�__init__ s zMockSender.__init__Nc K s� d| g}|d k r,t |d|�}|jd| � || koH| koHd kn rltjdd�d d d� \}}}|d k r�|jd| � |d k r�|jd j|�� |d k r�|jd
| � |jd d � |j� D �� | jj|� d S )
NzMESSAGE=�hexz MESSAGE_ID=� )�limitr � z
CODE_FILE=zCODE_LINE={:d}z
CODE_FUNC=c s s | ]\}}t ||�V qd S )N)r )�.0�key�valr r r
� ) s z"MockSender.send..)�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 y
d V W n: t tfk
rD } z|j| kr2tj� � W Y d d }~X nX d S )N)�OSError�IOError�errno�pytest�skip)�code�er r r
� skip_oserror, s
r* c c s, y
d V W n t k
r& tj� Y nX d S )N)�
ValueErrorr& r' r r r r
�skip_valueerror5 s
r, c C s t jj} d S )N)r �JournalHandlerZ map_priority)�pr r r
�test_priorities< s r/ c
C s. ddi} t jt�� tjf | � W d Q R X d S )Nz X r )r& �raisesr+ r r- )�kwr r r
�"test_journalhandler_init_exceptionQ s r2 c C s ddd�} t jtjf| � d S )Nr � )�X�X3)r r- �logging�INFO)r1 r r r
�test_journalhandler_initV s
r8 c C sJ t jdt jdddd d �} t� }dd|jd�}tjt jf|�}|j| � d S )Nz test-logger�testpath� �testr r3 )r4 r5 �sender_function)r6 � LogRecordr7 r r r r- �emit)�record�senderr1 �handlerr r r
�test_journalhandler_infoZ s
rB c C s> t jdt jdddd d �} t� }tjt j|jd�}|j| � d S )Nz test-loggerr9 r: r; )r< )r6 r= r7 r r r- r r> )r? r@ rA r r r
�!test_journalhandler_no_message_ide s
rC c C s@ t jdt jdddd d �} t� }tjt j|jtd�}|j| � d S )Nz test-loggerr9 r: r; )r< r ) r6 r= r7 r r r- r �TEST_MIDr> )r? r@ rA r r r
�)test_journalhandler_message_id_on_handlerm s
rE c C sB t jdt jdddd d �} t� }tjt j|jtjd�}|j | � d S )Nz test-loggerr9 r: r; )r< r )
r6 r= r7 r r r- r rD r r> )r? r@ rA r r r
�-test_journalhandler_message_id_on_handler_hexv s
rF c C sJ t jdt jdddd d �} t| jd< t� }tjt j|jt d�}|j
| � d S )Nz test-loggerr9 r: r; r )r< r ) r6 r= r7 � TEST_MID2�__dict__r r r- r rD r> )r? r@ rA r r r
�)test_journalhandler_message_id_on_message s
rI c C sL t jdt jdddd d �} tj| jd< t� }tjt j|j t
d�}|j | � d S )Nz test-loggerr9 r: r; r )r< r ) r6 r= r7 rG r rH r r r- r rD r> )r? r@ rA r r r
�-test_journalhandler_message_id_on_message_hex� s
rJ c C sR t j� } t jt j�}t jt j�}t jt j�}t jt jt jB t jB �}t jd�}d S )Nr )r �ReaderZ
LOCAL_ONLYZ RUNTIME_ONLY� SYSTEM_ONLY)�j1�j2�j3Zj4Zj5Zj6r r r
�test_reader_init_flags� s rP c C s� t jt�� tjtj� W d Q R X t� � tj| jtjd�}W d Q R X t� � tj| jtjtjB d�}W d Q R X tj| jtjtj B d�}d S )N)�path�flags)
r& r0 r+ r rK ZOS_ROOTr, �strpath� CURRENT_USERrL )�tmpdirrM rN rO r r r
�test_reader_os_root� s rV c C s> t j| jd�}t jd| jd� t j| jd�}t j| jd� d S )N)rQ r )r rK rS )rU rM rN r r r
�test_reader_init_path� s rW c C s( t jt�� tjddd� W d Q R X d S )Nr r: )rQ �����)r& r0 r# r rK r r r r
� test_reader_init_path_invalid_fd� s rY c C s( t jt�� tjddd� W d Q R X d S )Nr )rQ )r& r0 r# r rK r r r r
�%test_reader_init_path_nondirectory_fd� s rZ c C sh t j| jt j�}ttj�� tj|d�}W d Q R X t � � tjtj
|d�}W d Q R X tjtj |d�}d S )N)rQ ) �os�openrS �O_RDONLYr* r% �ENOSYSr rK r, ZSYSTEMrT )rU �fdrM rN rO r r r
�test_reader_init_path_fd� s r` c C s@ t j| jd�}|� W d Q R X tjt�� t|� W d Q R X d S )N)rQ )r rK rS r& r0 r# �next)rU �jr r r
�test_reader_as_cm� s
rc c C s< t j| jd�}|� |jtj� |jtjj� W d Q R X d S )N)rQ )r rK rS Zmessageid_matchr ZSD_MESSAGE_JOURNAL_STARTZSD_MESSAGE_JOURNAL_STOPr )rU rb r r r
�test_reader_messageid_match� s rd c C s@ t j| jd�}|�$ |j� |jt� |jtj� W d Q R X d S )N)rQ )r rK rS Z this_bootrD r )rU rb r r r
�test_reader_this_boot� s
re c C s@ t j| jd�}|�$ |j� |jt� |jtj� W d Q R X d S )N)rQ )r rK rS Z this_machinerD r )rU rb r r r
�test_reader_this_machine� s
rf c C sB t j| jd�}|�& ttj�� |jd�}W d Q R X W d Q R X d S )N)rQ ZFOOBAR)r rK rS r* r% r^ Z query_unique)rU rb �ansr r r
�test_reader_query_unique� s
rh c C s@ t j| jd�}|�$ ttj�� |j� }W d Q R X W d Q R X d S )N)rQ )r rK rS r* r% r^ Zenumerate_fields)rU rb rg r r r
� test_reader_enumerate_fields� s
ri c C s@ t j| jd�}|�$ ttj�� |j� }W d Q R X W d Q R X d S )N)rQ )r rK rS r* r% r^ �has_runtime_files)rU rb rg r r r
� test_reader_has_runtime_files� s
rk c C s@ t j| jd�}|�$ ttj�� |j� }W d Q R X W d Q R X d S )N)rQ )r rK rS r* r% r^ rj )rU rb rg r r r
� test_reader_has_persistent_files� s
rl c C s8 ddd� i}t j| j|d�}|jdd�}|jdd�}d S )NZxxxc S s dS )N�yyyr )�argr r r
� s z(test_reader_converters..)rQ �
converterss abcZzzzs ��)r rK rS Z_convert_field)rU rp rb r r r r
�test_reader_converters� s
rq c C sB dd� dd� d�}t j| j|d�}|jddddgdd gd
��}d S ) Nc S s dS )Nrm r )rn r r r
ro
s z+test_reader_convert_entry..c S s dS )NZYYYr )rn r r r
ro s )�x1�x2)rQ rp s abcs ��s defs ��)rr Zy1rs Zy2)r rK rS Z_convert_entry)rU rp rb r r r r
�test_reader_convert_entry s rt c C sF t j| jd�}tj� }|j|� |jd� tjddd�}|j|� d S )N)rQ i90 i� � r3 )r rK rS �timeZ
seek_realtime�datetime)rU rb ZnowZlong_agor r r
�test_seek_realtime s
rx c C s: t tj�� tjd�} W d Q R X | jd�}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 �
contextlibrw r% r6 r[ rv Zuuid� tracebackr Zsystemdr r Zsystemd.journalr r& ZUUIDrD rG r �contextmanagerr* r, r/ r2 r8 rB rC rE rF rI rJ rP rV rW rY rZ r` rc rd re rf rh ri rk rl rq rt rx r r r r r
� sV