← Back
Editing: test_journal.cpython-36.opt-1.pyc
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 � <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 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 �<lambda> s z(test_reader_converters.<locals>.<lambda>)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.<locals>.<lambda>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 �<module> sV
Save File
Cancel