^cddlmZmZmZmZmZmZmZmZm Z ddl m Z dZ dZ e jddd d Zd Zd S) ) bundle2errorexchange extensionshg narrowspecwireprototypeswireprotov1peerwireprotov1server) narrowbundle2c2ttj_dS)N)peernarrowwidenr wirepeer narrow_widen=/usr/lib/python3/dist-packages/hgext/narrow/narrowwirepeer.pyuisetuprs,;O)))rcPfd}tj|dS)Nc>fd}tj|d|dS)Nc|dkr:j\}}d||d<d||d<||g|Ri|S)Nsunbundle, includepats excludepats) narrowpatsjoin)origcmdargskwargsincludeexcluderepos rwrappedz1reposetup..wirereposetup..wrappedshk!!$(? (, '(:(:}%(, '(:(:}%4-d---f-- -rs_calltwowaystream)r wrapfunction)uipeerr%r$s r wirereposetupz reposetup..wirereposetups: . . . . . &:GDDDDDr)rwirepeersetupfuncsappend)r$r)s` r reposetupr,s@ E E E E E  /////r narrow_widensToldincludes oldexcludes newincludes newexcludes commonheads cgversion known ellipsesspull) permissionc d} d} | |}| |}| |}| |}|jtjrtj|d|it jt|t jt|t jt|t jt|tj |} tj |}| dkrd} nt| } |}tj |j} t j |j||}t j |j||}| stj| |||| ||| nt!j| ||||| |n#t$j$r}}tj |j} d|jfg}g}|j|d|jf| tjd ||d } Yd}~nd}~wwxYw| }tj|| S) awireprotocol command to send data when a narrow clone is widen. We will be sending a changegroup here. The current set of arguments which are required: oldincludes: the old includes of the narrow copy oldexcludes: the old excludes of the narrow copy newincludes: the new includes of the narrow copy newexcludes: the new excludes of the narrow copy commonheads: list of heads which are common between the server and client cgversion(maybe): the changegroup version to produce known: list of nodes which are known on the client (used in ellipses cases) ellipses: whether to send ellipses data or not Fc4|r|dngS)Nr)split)datas r splitpathsz narrow_widen..splitpathsQs'+34::d### 3rr0)r"r#smessageNshints error:abortT)genprefer_uncompressed)r' has_sectionr_NARROWACL_SECTIONapplynarrowaclrvalidatepatternssetr decodelistboolrbundle20matchroot widen_bundler &generate_ellipses_bundle2_for_wideningrAbortmessagehintr+addpart bundlepart getchunks streamres)r$proto oldincludes oldexcludes newincludes newexcludes commonheads cgversionknownellipsespreferuncompressedr3commonbundlernewmatcholdmatchexcmanargsadvargschunkss rrr,sD@" 4 4 4!j--  j--  j--  j--  7  x: ; ; H  #D=+*F G G G #C $4$4555#C $4$4555#C $4$4555#C $4$4555*;77)%00 t  HHH~~H "47++# I{K   # I{K            @    ;""""47++ ,- 8  NNGSX. / / /*>7GLLMMM!"   F  # (:   sF9F>>I  A3II c dD]}tj||||< dD] }d||||<!dt|dz|d<|jdi|}t j|j|S)N)rOrQ)rKrMrLrNrs%irRr-)r-)r encodelistrr=_callcompressabler getunbundlerr')remoter!chfs rrrs&;;#.vbz::r J++YYvbz**r fZ&8!9!99F:  ;;F;;A   1 - --rN) mercurialrrrrrrr r r r rr,wireprotocommandrrrrrrfs                      <<< 0 0 0 $# ```F . . . . .r