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 dlZejdZejdZG dd dZejd 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)journalid128)
_make_lineZ 8441372f8dca4ca98694a6091fd8519fZ 8441370000000000000000001fd85000c @ s e Zd Zdd ZdddZdS )
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 rltjddd 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 ).0keyvalr r r
) s z"MockSender.send..)getattrappend
_traceback
extract_stackformatextenditemsr ) r ZMESSAGE
MESSAGE_IDZ CODE_FILEZ CODE_LINEZ CODE_FUNCkwargsargsidr 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)OSErrorIOErrorerrnopytestskip)codeer 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 )XX3)r r- loggingINFO)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-loggertestpath testr r3 )r4 r5 sender_function)r6 LogRecordr7 r r r r- emit)recordsenderr1 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)j1j2j3Zj4Zj5Zj6r 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)pathflags)
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 ) osopenrS 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 )Nyyyr )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 )x1x2)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_realtimedatetime)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 streamwriteprint)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