>GSrSSKJr SSKJr SSKrSSKrSSKJrJ r Sr Sr Sr Sr S rSrS rS rS rS rS rSrSrSrSrSrSrSrSrSrSrSrSr Sr!Sr"Sr#Sr$Sr%Sr&S r'\\ \!\#\/r(\)"\(\"\\\\\$\\\\%\&/ -5r*\)"\(\\\\/-5r+S!r,S"r-S#r.S$r/S%r0S&r1S'r2Sr3S(r4S)r5S*r6S+r7"S,S-\85r9S.r:S/r;S0r<"S1S2\85r=S3r>"S4S5\=5r?S6r@S7rAS8rB"S9S:\85rC"S;S<\85rDg)=z>rc&[SU55$)Nc3># UHn[U5Sv M g7f)rN)parse_capability).0cs r +extract_capability_names..|s<|!"1%|s)set capabilitiess rextract_capability_namesr){s <|< <UVs/sH n[U6PM sn$s snfN)r)symrefsks rsymref_capabilitiesr4s +2 37a q !7 33 3ssdeepens unshallowsdoneswantshavec*\rSrSrSrSrSrSrSrg) ProtocolFilez;A dummy file for network ops that expect file-like objects.cXlX lgr1readwrite)selfr:r;s r__init__ProtocolFile.__init__s   rcgr1rr<s rtellProtocolFile.tell rcgr1rr@s rcloseProtocolFile.closerCrr9N) __name__ __module__ __qualname____firstlineno____doc__r=rArE__static_attributes__rrrr6r6sE  rr6c`US-SRUVs/sHo"S-PM sn5-$s snf)N r)join)cmdargsas rformat_cmd_pktrTs. :t!L< 1$,&O<(1,d34 || &"1% % &sAC&.C&&D : DD chUR5nURU5 g![a gf=f)zTest whether the protocol stream has reached EOF. Note that this refers to the actual stream EOF and not just a flush-pkt. Returns: True if the stream is at EOF, False otherwise. TF)r{runread_pkt_line)r< next_lines reof Protocol.eofs< **,I Y'  s $ 11cfURb [S5e[[U55Ulg)aUnread a single line of data into the readahead buffer. This method can be used to unread a single pkt-line into a fixed readahead buffer. Args: data: The data to unread, without the length prefix. Raises: ValueError: If more than one pkt-line is unread. Nz'Attempted to unread multiple pkt-lines.)re ValueErrorrr^r<r]s rr~Protocol.unread_pkt_lines* ?? &FG G!(4.1rc#v# UR5nU(aUv UR5nU(aMgg7f)zRead a sequence of pkt-lines from the remote git process. Returns: Yields each line of data up to but not including the next flush-pkt. N)r{)r<pkts r read_pkt_seqProtocol.read_pkt_seqs2   "I$$&Ccs399c[U5nURU5 UR(aUR[U5S5 gg![R an[ U5eSnAff=f)zSends a pkt-line to the remote git process. Args: line: A string containing the data to send, without the length prefix. r;N)r^r;rdr,rurvr)r<rXrzs rwrite_pkt_lineProtocol.write_pkt_line"s] &D>D JJt ##$$SY8$|| &"1% % &sAA A0 A++A0c0"SS[5nU"U5$)z5Return a writable file-like object for this protocol.c,\rSrSrSrSrSrSrSrg))Protocol.write_file..ProtocolFilei4cXlSUlgNr)_proto_offset)r<protos rr=2Protocol.write_file..ProtocolFile.__init__5s#   rcvURRU5 U=R[U5- slgr1)rr;rr,rs rr;/Protocol.write_file..ProtocolFile.write9s& !!$' D ) rcUR$r1)rr@s rrA.Protocol.write_file..ProtocolFile.tell=s ||#rcgr1rr@s rrE/Protocol.write_file..ProtocolFile.close@sr)rrN) rGrHrIrJr=r;rArErLrrrr6r4s ! * $ rr6)object)r<r6s r write_fileProtocol.write_file1s 6 D!!rcU(a9UR[[U/55USS-5 USSnU(aM8gg)zWrite multiplexed data to the sideband. Args: channel: An int specifying the channel to write to. blob: A blob of data (as a string) to send on this channel. N)rbytes bytearray)r<channelblobs rwrite_sidebandProtocol.write_sidebandEs>   i &: ;d6El J K[[U] URX#US9 Xl[ 5UlXPlg)N)rErd)superrr=r:_recvr_rbuf _rbufsize)r<recvr;rErdrbufsize __class__s rr=ReceivableProtocol.__init__xs:  $0 IIu? 1  Y !rcUS:deURnUR5nURS[5 UR5U- nXA:awURU5 UR U5n[ 5UlURR UR 55 URRS5 U$[ 5UlX- nURU5nU(dOY[U5nX:Xa U(dU$X:XaUR U5 AO(X::d SXh4-5eUR U5 XH- nAMvURU5 UR 5$)Nrz_recv(%d) returned %d bytes) rrAseekrr:rr;rr,) r<rxbufstartbuf_lenrvleftr]ns rr:ReceivableProtocol.reads6axx jj  H((*u$ ? HHUO$B DJ JJ  SXXZ ( JJOOA IY >D ::d#DD Ay  y $9 G;tiG G9 IIdO LG36 xxzrcUS:deURnUR5nURS[5 UR5nURU5 XC- nU(d_UR UR 5n[ U5U:XaU$[5nURU5 URS5 AX lURU5$r) rrArrrrr,rr;r:)r<rxrrrrr]s rrReceivableProtocol.recvsaxxjj  H((* ::dnn-D4yD  )C IIdO HHQKJxx~r)rrr) rGrHrIrJrK _RBUFSIZEr=r:rrL __classcell__)rs@rrrls& "&ti";zrrcSU;aU/4$UR5RS5upXR5RS54$)zExtract a capabilities list from a string, if present. Args: text: String to extract from Returns: Tuple with text with capabilities removed and list of capabilities rOrN)rstripr+strip)textr(s rextract_capabilitiesrsK DRx,,U3D $$&,,T2 33rcUR5RS5n[U5S:aU/4$SRUSS5USS4$)a\Extract a capabilities list from a want line, if present. Note that want lines have capabilities separated from the rest of the line by a space instead of a null byte. Thus want lines have the form: want obj-id cap1 cap2 ... Args: text: Want line to extract from Returns: Tuple with text with capabilities removed and list of capabilities rNr Nr)rr+r,rP)r split_texts rextract_want_line_capabilitiesrsO$$T*J :Rx IIj!n %z!"~ 66rc>SU;a[$SU;a[$[$)z.Extract the ack type from a capabilities list.r r )MULTI_ACK_DETAILED MULTI_ACK SINGLE_ACKr's rack_typers$ ,!!  % rc.\rSrSrSrSSjrSrSrSrg) BufferedPktLineWriteriaWriter that wraps its data in pkt-lines and has an independent buffer. Consecutive calls to write() wrap the data in a pkt-line and then buffers it until enough lines have been written such that their total length (including length prefix) reach the buffer size. cHXlX l[5UlSUlg)zInitialize the BufferedPktLineWriter. Args: write: A write callback for the underlying writer. bufsize: The internal buffer size, including length prefixes. rN)_write_bufsizer_wbuf_buflen)r<r;bufsizes rr=BufferedPktLineWriter.__init__s  Y  rcX[U5n[U5nURU-UR- nUS:a3X4- nURR USU5 UR 5 OSnX%SnURR U5 U=R[U5- slg)z&Write data, wrapping it in a pkt-line.rN)r^r,rrrr;flush)r<r]rXline_lenoverrsaveds rr;BufferedPktLineWriter.writes~t9||h&6 19OE JJ  T&5\ * JJLEV   E " rcURR5nU(aURU5 SUl[ 5Ulg)zFlush all data from the buffer.rN)rgetvaluer_lenrrs rrBufferedPktLineWriter.flush"s3zz""$  KK  Y r)rrrrrN)r) rGrHrIrJrKr=r;rrLrrrrrs  #rrc*\rSrSrSrSrSrSrSrg) PktLineParseri+zBPacket line parser that hands completed packets off to a callback.c.Xl[5Ulgr1) handle_pktrre)r<rs rr=PktLineParser.__init__.s$!)rcURRU5 URR5n[U5S:ag[U5S:af[ USSS5nUS:XaUR S5 USSnO)U[U5::aUR USU5 X#SnOO[U5S:aMf[ 5UlURRU5 g)zAParse a fragment of data and call back for any completed packets.r\Nrsr)rer;rr,rtrr)r<r]rrxs rparsePktLineParser.parse2s d#oo&&( s8a< #h!ms2Aw#Dqy%!"gS!Ad ,%j#h!m") c"rc6URR5$)zRead back any unused data.)rerr@s rget_tailPktLineParser.get_tailEs''))r)rerN) rGrHrIrJrKr=rrrLrrrrr+sL$#&*rr)ErKiorosrrurdulwich.errorsrr TCP_GIT_PORTZERO_SHArrrSIDE_BAND_CHANNEL_DATASIDE_BAND_CHANNEL_PROGRESSSIDE_BAND_CHANNEL_FATALCAPABILITY_ATOMICCAPABILITY_DEEPEN_SINCECAPABILITY_DEEPEN_NOTCAPABILITY_DEEPEN_RELATIVECAPABILITY_DELETE_REFSCAPABILITY_INCLUDE_TAGCAPABILITY_MULTI_ACKCAPABILITY_MULTI_ACK_DETAILEDCAPABILITY_NO_DONECAPABILITY_NO_PROGRESSCAPABILITY_OFS_DELTACAPABILITY_QUIETCAPABILITY_REPORT_STATUSCAPABILITY_SHALLOWCAPABILITY_SIDE_BANDCAPABILITY_SIDE_BAND_64KCAPABILITY_THIN_PACKrr!CAPABILITY_ALLOW_TIP_SHA1_IN_WANT'CAPABILITY_ALLOW_REACHABLE_SHA1_IN_WANTCAPABILITIES_REFCOMMON_CAPABILITIESr&KNOWN_UPLOAD_CAPABILITIESKNOWN_RECEIVE_CAPABILITIESrrrr)r!r4COMMAND_DEEPENCOMMAND_SHALLOWCOMMAND_UNSHALLOW COMMAND_DONE COMMAND_WANT COMMAND_HAVErr6rTrZr^r`rrrrrrrrrrrs,C    )%/''# 5'#+#+#$=!*I'&  %")/   !  F4?=4      6  >' =n#vn#b  hhV 47$)F)X*F*r