SSKrSSKrSSKrSSKrSSKrSSKJr Sr Sr "SS\ 5r SrSSjrS rS rS rS rS rSSjrSrg!\a \ "S5rN>f=f)N) NpipeSocketc\rSrSrSrg) SocketErrorN)__name__ __module__ __qualname____firstlineno____static_attributes__r &lib/third_party/docker/utils/socket.pyrrsrrmc[R[R[R4n[ U[ 5(d[ [S5(d[R"U///5 OV[R"5nURU[R[R-5 UR5 [ US5(aURU5$[ U[[S55(aURU5$[ R"UR#5U5$![$anURU;aeSnAgSnAf[&a^n[ U[ 5=(a5 [)UR*5S:=(a UR*S[,:HnU(aSnAgeSnAff=f)z# Reads at most n bytes from socket pollrecvSocketIONr)errnoEINTREDEADLK EWOULDBLOCK isinstancerhasattrselectrregisterPOLLINPOLLPRIrgetattrpysocketreadosfilenoOSError Exceptionlenargs NPIPE_ENDED)socketnrecoverable_errorsre is_pipe_endeds rr#r#sF  ++u}}e6G6GH fk * *vv&& MM6(B +;;=D MM&&--&.."@ A IIK 66 " ";;q> ! fgh ; < <;;q> !wwv}}**  77, ,  - #FK82QVVq2k1   s7 !E-/E$E G  E"" G /AGGG c[5n[U5U:a>[X[U5- 5nU(d [S5eX#- n[U5U:aM>U$)zQ Reads exactly n bytes from socket Raises SocketError if there isn't enough data zUnexpected EOF)bytesr(r#r)r+r,data next_datas r read_exactlyr4>sS 7D d)a-SY/ ./ /  d)a- Krct[US5n[R"SU5up#X#4$![a gf=f)z Returns the stream and size of the next frame of data waiting to be read from socket, according to the protocol defined here: https://docs.docker.com/engine/api/v1.24/#attach-to-a-container )r7z>BxxxL)r4rstructunpack)r+r2streamactuals rnext_frame_headerr<LsDFA&]]8T2NF   s * 77cJU(aS[U55$[U5$)z Return a generator of frames read from socket. A frame is a tuple where the first item is the stream number and the second item is a chunk of data. If the tty setting is enabled, the streams are multiplexed into the stdout stream. c32# UH n[U4v M g7f)N)STDOUT).0frames r frames_iter..esE-DE-Ds)frames_iter_ttyframes_iter_no_tty)r+ttys r frames_iterrG\s" E_V-DEE!&))rc## [U5upUS:agUS:a3[X5nUcM[U5nUS:XagX$-nX4v US:aM3MO7f)zW Returns a generator of data read from the socket when the tty setting is not enabled. rN)r<r#r()r+r:r,result data_lengths rrErEjsk '/  q5 !e&_F~f+Ka A" "!e s A AAc#N# [U5n[U5S:XagUv M!7f)zR Return a generator of data read from the socket when the tty setting is enabled. rN)r#r()r+rIs rrDrDs, f v;!   s#%cUSLa[5RU5$SS/nUHSnUS:wdeUSb"USc USUS'M!US==US- ss'M3USc USUS'MCUS==US- ss'MU [U5$)as Iterate through frames read from the socket and return the result. Args: demux (bool): If False, stdout and stderr are multiplexed, and the result is the concatenation of all the frames. If True, the streams are demultiplexed, and the result is a 2-tuple where each item is the concatenation of frames belonging to the same stream. FN)NNrr)r1jointuple)framesdemuxoutrAs rconsume_socket_outputrRs ~w||F## ,C $$$ 8 1v~qAA%("1v~qAA%(" :rcVU[:XaUS4$U[:XaSU4$[US35e)zO Utility to demultiplex stdout and stderr when reading frames from the socket. Nz is not a valid stream)r?STDERR ValueError) stream_idr2s r demux_adaptorrWs; Fd| f d|I;&<=>>r)i)F)rr$rr+r"r8 transportr ImportErrortyper?rTr'rr*r#r4r<rGrErDrRrWr rrr[s  '   )  !H   *#* "J ?Qt*KsA AA