a
ťfE( @ sZ d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZmZm Z m
Z
m Z m Z m
Z
mZmZmZmZmZmZmZmZ d dlZejdd Zejdd Zdd Zd d
Zd d Z d
d Z dd Z dd Z dd Z dd 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,e j-d-krBe.Z/ne0Z/d.d/ Z1d0d1 Z2dS )2 N)bootedis_fifo_is_fifo is_socket
_is_socketis_socket_inet_is_socket_inetis_socket_unix_is_socket_unixis_socket_sockaddr_is_socket_sockaddris_mq_is_mq
listen_fdsnotifyc
c sJ z
d V W n: t yD } z"| jtjkr.t W Y d } ~ n
d } ~ 0 0 d S N)OSErrorerrnoZENOSYSpytestskip)e r >/usr/lib64/python3.9/site-packages/systemd/test/test_daemon.py skip_enosys s
r c c sL t | }z"|V W |d |d n|d |d 0 d S )Nr )socketZ
socketpairclose)Zfamilypairr r r closing_socketpair s
r c C s* t jdrt s&J nt dv s&J d S )Nz/run/systemd/system> FT)ospathexistsr r r r r test_booted& s r" c C sJ | dj}t| t|tjtjB }t|d s8J t||sFJ d S )N test.fifo) joinstrpathposixmkfifor openO_RDONLY
O_NONBLOCKr )tmpdirr fdr r r
test__is_fifo. s
r- c C sN | d}|d |j}t|tjtjB }t|d r r? r r r _is_mq_wrapperp s
rC c
C sR t tj0} | D ]}t|r$J t|r0J t|rJ t g ksLJ d S )N1r\ r] Fra rd r r r r test_listen_fds_default_unset s
rj c C s t jdd tddu s J t $ tdg ddu s:J W d n1 sN0 Y tdddgddu spJ tdt ddu sJ tdt d d
du sJ d S ) N
NOTIFY_SOCKETREADY=1F FDSTORE=1fdsr pidr rr ro )r re popr r rg r r r r test_notify_no_socket s 2rv )ra c C sP dt jd< tt td W d n1 s20 Y ttB t tdg d W d n1 sp0 Y W d n1 s0 Y tt tdddgd W d n1 s0 Y tt tdt d W d n1 s0 Y tt" tdt d d
W d n1 sB0 Y d S ) Nz /dev/nullrk rl rm rn r rp rq rs rt )r re r r5 connection_errorr r rg r r r r test_notify_bad_socket s
& H . 0 rx c
C s | dj}ttjtj}z|| W n4 tjy^ } ztd| W Y d }~n
d }~0 0 t tdd}|
tj |d |t j
d< tdsJ t tdg d sJ W d n1 s0 Y tddd
gd sJ tdt d sJ tdt d d
sJ d S )Nr zfailed to bind socket (%s) SO_PASSCRED r rk rl rm rn rp rq rs rt )r$ r% r rD rK rS rA r ZxfailgetattrZ
setsockoptZ
SOL_SOCKETr re r r rg )r+ r rG r ry r r r test_notify_with_socket! s $
.r| )3sysr r& r rQ r Zsystemd.daemonr r r r r r r r r
r r r
r r r r contextmanagerr r r" r- r2 r7 r: r; r< rB rC rH rM rW rX rZ r[ r_ rh rj rv version_infoConnectionRefusedErrorrw r rx r| r r r r sF D
&