/I_fSSKrSSKrSSKrSSKrSSKJr "SS\5r "SS\ 5r g!\\4a SSKJr N'f=f)N) BaseObjectc8\rSrSrSrSrSrSrSrSr Sr g ) IO$c0[R"U5 g)N)r__init__)selfs /usr/share/ifupdown2/lib/io.pyr IO.__init__%sD!c @URRSU<SU<35 [US5nURU5 SSS5 g!,(df  g=f![a6nURR SU<S[ U5<35 SnAgSnAff=f)N writing " " to file wTzerror while writing to file z: F)loggerinfoopenwriteIOErrorwarningstr)r pathstringfes r write_to_fileIO.write_to_file(su  KK  FDI JdCA!!  KK  cRSf U V s4/AA A AAA B',BBc6URSU<SU<35 g)NrrTlog_info_dry_run)r rrs r write_to_file_dry_runIO.write_to_file_dry_run2s VTJKr cURRSU-5 [US5nUR5R S5sSSS5 $!,(df  g=f![ a gf=f)N reading '%s'r )rrrreadlinestrip Exceptionr rrs r read_file_onelineIO.read_file_oneline6sX  KK  ^d2 3dCAzz|))$/!  s.*A&A A& A#A&#A&& A32A3c,URSU-5 g)Nz reading "%s"r)r rs r read_file_oneline_dry_runIO.read_file_oneline_dry_run>s .56r cURRSU-5 [US5nUR5sSSS5 $!,(df  g=f![a gf=f)z)read file and return lines from the file r$r%N)rrr readlinesr)r*s r read_file IO.read_fileBsM  KK  ^d2 3dCA{{}!  s-*AA A AAA A$#A$N) __name__ __module__ __qualname____firstlineno__rrr!r+r.r2__static_attributes__r4r r rr$s "r rc>\rSrSrSr\S5r\S5rSrSr g)SocketIOLzb Helper class to provide common TX/RX methods for socket communication to both client and daemon. c$[R"/U//5nU(apUS(aeUSSU:XaXS[U5-n[R"X15n[R"S[U55nUR XT-5 gggg)z We don't send raw data over the socket, we pack it with the length (first 4 bytes) then with the data. That way the the transfer is more reliable rz=%ds=IN)selectlenstructpacksendall)_socketdatareadyfrmt packed_msg packed_hdrs r tx_dataSocketIO.tx_dataRsx b7)R0 U1X%(1+"8CI%DT0JT3z?;J OOJ3 4 #9X5r c[R"U///5nU(aUS(aUSSU:XaURS5nU(d [S5e[U5S:a [S5e[R "SU5SnURU5n[U5U:a0X@RU[U5- 5-n[U5U:aM0[ R"U5$g)z Reading data from socket. Unpacking the packets sent by "tx_data" first 4 bytes are the length of the following data. The data should be in json format rzrx_json_packet: socket closedz%rx_json_packet: invalid data receivedr?N)r@recvr)rArBunpackjsonloads)rErG header_datadata_lenrFs r rx_json_packetSocketIO.rx_json_packet`s wiR0 U1X%(1+"8!,,q/K ?@@;!# GHH}}T;7:H<<)Dd)h&ll8c$i+?@@d)h&::d# #r c [R"SUR[RUR [R "S555$)z^ Returns tuple of (pid, uid, gid) of connected AF_UNIX stream socket :param _socket: :return: 3i)rBrP getsockoptsocket SOL_SOCKET SO_PEERCREDcalcsize)r rEs r get_socket_peer_credSocketIO.get_socket_peer_cred|s= }}T7#5#5f6G6GIYIY[a[j[jko[p#qrrr r4N) r5r6r7r8__doc__ staticmethodrKrUr^r9r4r r r;r;Ls5  5 56sr r;) rQrBrZr@ifupdown2.lib.base_objectsr ImportErrorModuleNotFoundErrorlib.base_objectsrobjectr;r4r r rgsQ2 ,5 %%P6sv6sY (),+,s/AA