| Server IP : 209.38.156.173 / Your IP : 216.73.216.122 [ Web Server : Apache/2.4.52 (Ubuntu) System : Linux lakekumayuhotel 5.15.0-136-generic #147-Ubuntu SMP Sat Mar 15 15:53:30 UTC 2025 x86_64 User : root ( 0) PHP Version : 8.1.2-1ubuntu2.22 Disable Function : NONE Domains : 2 Domains MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /lib/python3/dist-packages/systemd/test/__pycache__/ |
Upload File : |
o
��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_line� 8441372f8dca4ca98694a6091fd8519f� 8441370000000000000000001fd85000c @ s" e Zd Zdd� Z ddd�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 urt |d|�}|�d| � || u r%| u r%d u r6n ntjdd�d d d� \}}}|d urA|�d| � |d urM|�d �|�� |d urX|�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 �MESSAGE�
MESSAGE_ID� CODE_FILE� CODE_LINE� 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 s@ � zd V W d S t tfy } z
|j| krt�� � d }~ww r
)�OSError�IOError�errno�pytest�skip)�code�er
r
r � skip_oserror, s �
��r3 c c s, � zd V W d S t y t�� Y d S w r
)�
ValueErrorr/ r0 r
r
r
r �skip_valueerror5 s � �r5 c C sp t jj} | tj�t jksJ �| tj�t jksJ �| tjd �t jks$J �| tjd �t jks0J �| tjd �t jks<J �| tj�t jksFJ �| tjd �t j ksRJ �| tj
d �t j ks^J �| tj
�t j kshJ �| tj
d �t j kstJ �| tj d �t j ks�J �| tj �t j ks�J �| tj d �t j
ks�J �| tj�t j
ks�J �| tj�t j
ks�J �| tjd �t jks�J �d S )N� )r �JournalHandler� map_priority�logging�NOTSET� LOG_DEBUG�DEBUG�LOG_INFO�INFO� LOG_WARNING�WARN�LOG_ERR�ERROR�LOG_CRIT�FATAL�CRITICAL� LOG_ALERT)�pr
r
r �test_priorities< s" rH c C sH ddi} t �t�� tjdi | �� W d � d S 1 s w Y d S )Nz X r r
)r/ �raisesr4 r r7 ��kwr
r
r �"test_journalhandler_init_exceptionQ s "�rL c C s" ddd�} t jtjfi | �� d S )Nr � )�X�X3)r r7 r9 r> rJ r
r
r �test_journalhandler_initV s
rP c C s� t �dt jdddd d �} t� }dd|jd�}tjt jfi |��}|�| � t|j �dks.J �d|j d v s7J �d
|j d v s@J �d S ) N� test-logger�testpathr6 �testr rM )rN rO �sender_functionzX=3r zX3=4)
r9 � LogRecordr> r r( r r7 �emit�lenr )�record�senderrK �handlerr
r
r �test_journalhandler_infoZ s
r[ c C sl t �dt jdddd d �} t� }tjt j|jd�}|�| � t|j �dks&J �t
dd� |j d D ��s4J �d S ) NrQ rR r6 rS )rT c s s � | ] }|� d � V qdS )r N)�
startswith)r �mr
r
r r k s � z4test_journalhandler_no_message_id.<locals>.<genexpr>r ) r9 rU r> r r r7 r( rV rW r �all�rX rY rZ r
r
r �!test_journalhandler_no_message_ide s
r` c C sj t �dt jdddd d �} t� }tjt j|jtd�}|�| � t |j
�dks'J �dtj |j
d v s3J �d S �NrQ rR r6 rS �rT r! r r ) r9 rU r> r r r7 r( �TEST_MIDrV rW r r r_ r
r
r �)test_journalhandler_message_id_on_handlerm s �
rd c C sl t �dt jdddd d �} t� }tjt j|jtjd�}|� | � t
|j �dks(J �dtj |j d v s4J �d S ra ) r9 rU r> r r r7 r( rc r rV rW r r_ r
r
r �-test_journalhandler_message_id_on_handler_hexv s �
re c C st t �dt jdddd d �} t| jd< t� }tjt j|jt d�}|�
| � t |j �dks,J �dtj
|j d v s8J �d S � NrQ rR r6 rS r! rb r r )r9 rU r> � TEST_MID2�__dict__r r r7 r( rc rV rW r r r_ r
r
r �)test_journalhandler_message_id_on_message s
�
ri c C sv t �dt jdddd d �} tj| jd< t� }tjt j|j t
d�}|� | � t |j
�dks-J �dtj |j
d v s9J �d S rf )r9 rU r> rg r rh r r r7 r( rc rV rW r r_ r
r
r �-test_journalhandler_message_id_on_message_hex� s �
rj 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 �Reader�
LOCAL_ONLY� RUNTIME_ONLY� SYSTEM_ONLY)�j1�j2�j3�j4�j5�j6r
r
r �test_reader_init_flags� s ru c C s� t �t�� t�tj� W d � n1 sw Y t� � tj| jtjd�}W d � n1 s2w Y t� � tj| jtjtjB d�}W d � n1 sQw Y tj| jtjtj B d�}d S )N)�path�flags)
r/ rI r4 r rk �OS_ROOTr5 �strpath� CURRENT_USERrn )�tmpdirro rp rq 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�rv r )r rk ry )r{ ro rp r
r
r �test_reader_init_path� s r~ c C s> t �t�� tjddd� W d � d S 1 sw Y d S )Nr ���r} �r/ rI r, r rk r
r
r
r � test_reader_init_path_invalid_fd� � "�r� c C s> t �t�� tjddd� W d � d S 1 sw Y d S )Nr r} r� r
r
r
r �%test_reader_init_path_nondirectory_fd� r� r� c C s� t �| jt j�}ttj�� tj|d�}W d � n1 s w Y t |�g ks+J �t
� � tjtj |d�}W d � n1 sAw Y t |�g ksNJ �tjtj |d�}t |�g ks^J �d S �Nr} )
�os�openry �O_RDONLYr3 r. �ENOSYSr rk �listr5 �SYSTEMrz )r{ �fdro rp rq r
r
r �test_reader_init_path_fd� s � �r� c C s~ t j| jd�}|�
|jrJ �W d � n1 sw Y |js#J �t�t��
t|� W d � d S 1 s8w Y d S r� )r rk ry �closedr/ rI r, �next�r{ �jr
r
r �test_reader_as_cm� s �
"�r� c C sR t j| jd�}|� |�tj� |�tjj� W d � d S 1 s"w Y d S r� )r rk ry �messageid_matchr �SD_MESSAGE_JOURNAL_START�SD_MESSAGE_JOURNAL_STOPr r� r
r
r �test_reader_messageid_match� s
"�r� c C �V t j| jd�}|� |�� |�t� |�tj� W d � d S 1 s$w Y d S r� )r rk ry � this_bootrc r r� r
r
r �test_reader_this_boot� �
"�r� c C r� r� )r rk ry � this_machinerc r r� r
r
r �test_reader_this_machine� r� r� c C s� t j| jd�}|�" ttj��
|�d�}W d � n1 s w Y W d � n1 s.w Y t|t�s:J �|t� ksAJ �d S )Nr} �FOOBAR) r rk ry r3 r. r� � query_unique�
isinstance�set�r{ r� �ansr
r
r �test_reader_query_unique� s �� �r� c C s� t j| jd�}|�! ttj�� |�� }W d � n1 s w Y W d � n1 s-w Y t|t�s9J �|t� ks@J �d S r� ) r rk ry r3 r. r� �enumerate_fieldsr� r� r� r
r
r � test_reader_enumerate_fields� s
�� �r� c C �t t j| jd�}|�! ttj�� |�� }W d � n1 s w Y W d � n1 s-w Y |du s8J �d S �Nr} F�r rk ry r3 r. r� �has_runtime_filesr� r
r
r � test_reader_has_runtime_files� �
�� �r� c C r� r� r� r� r
r
r � test_reader_has_persistent_files� r� r� c C sP ddd� i}t j| j|d�}|�dd�}|dksJ �|�dd�}|dks&J �d S ) N�xxxc S � dS �N�yyyr
��argr
r
r �<lambda> � z(test_reader_converters.<locals>.<lambda>�rv �
converters� abcr� �zzz� ��)r rk ry �_convert_field�r{ r� r� 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.J �d S )
Nc S r� r� r
r� r
r
r r�
r� z+test_reader_convert_entry.<locals>.<lambda>c S r� )N�YYYr
r� r
r
r r� r� )�x1�x2r� r� r� s defs ��)r� �y1r� �y2r� r� )r rk ry �_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� � rM )r rk ry �time�
seek_realtime�datetime)r{ r� �now�long_agor
r
r �test_seek_realtime s
r� c C sZ t tj��
t�d�} W d � n1 sw Y | �d�}|dv s%J �td| d� d S )Nztest_journal.pyz message...
)� Nzprinted message...)�file)r3 r. �ENOENTr �stream�write�print)r� �resr
r
r �test_journal_stream" s �
r� )3�
__future__r �
contextlibr� r. r9 r� r� �uuid� tracebackr �systemdr r �systemd.journalr r/ �UUIDrc rg r �contextmanagerr3 r5 rH rL rP r[ r` rd re ri rj ru r| r~ r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r
r
r
r �<module> s\