Gemfury

odigos / odigos-demo-inventory deb

Repository URL to install this package:
Details
odigos-demo-inventory / opt / odigos-demo-inventory / site-packages / dulwich / __pycache__ / server.cpython-311.pyc
§

iµµh¿ãóddZddlZddlZddlZddlZddlZddlmZddlm	Z	m
Z
mZmZm
Z
mZ	ddlmZn#e$r	ddlmZYnwxYwddlZddlZddlmZddlmZdd	lmZmZmZmZmZmZm Z dd
l!m"Z"ddl#m$Z$m%Z%m&Z&ddl'm(Z(m)Z)m*Z*dd
l+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;m<Z<m=Z=m>Z>m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEmFZFmGZGmHZHmIZImZmJZJmKZKmLZLmMZMmNZNmOZOmPZPmQZQmRZRmSZSddlTmUZUmVZVmWZWddlXmYZYmZZZej[e\¦«Z]Gdd¦«Z^Gdde¦«Z_Gdde^¦«Z`Gdde^¦«ZaGdd¦«ZbGddeb¦«ZcGddec¦«ZddZede(fd Zfde(fd!Zgde(fd"ZhGd#d$¦«Zie<e;dfZjGd%d&¦«ZkGd'd(¦«ZlGd)d*¦«ZmGd+d,ec¦«ZnGd-d.eb¦«Zoedeneod/ZpGd0d1ejq¦«ZrGd2d3ejs¦«Ztejufd4Zvejudejwejxfd5Zyd6Zzd7Z{d8Z|e\d9krev¦«dSdS):aêGit smart network protocol server implementation.

For more detailed implementation on the network protocol, see the
Documentation/technical directory in the cgit distribution, and in particular:

* Documentation/technical/protocol-capabilities.txt
* Documentation/technical/pack-protocol.txt

Currently supported capabilities:

 * include-tag
 * thin-pack
 * multi_ack_detailed
 * multi_ack
 * side-band-64k
 * ofs-delta
 * no-progress
 * report-status
 * delete-refs
 * shallow
 * symref
éN)Úpartial)ÚDictÚIterableÚListÚOptionalÚSetÚTuple)ÚProtocol)Ú	log_utilsé)Ú
tar_stream)ÚApplyDeltaErrorÚChecksumMismatchÚGitProtocolErrorÚ	HookErrorÚNotGitRepositoryÚObjectFormatExceptionÚUnexpectedCommandError)Úpeel_sha)ÚCommitÚObjectIDÚvalid_hexsha)ÚObjectContainerÚPackedObjectContainerÚwrite_pack_from_container))ÚCAPABILITIES_REFÚCAPABILITY_AGENTÚCAPABILITY_DELETE_REFSÚCAPABILITY_INCLUDE_TAGÚCAPABILITY_MULTI_ACKÚCAPABILITY_MULTI_ACK_DETAILEDÚCAPABILITY_NO_DONEÚCAPABILITY_NO_PROGRESSÚCAPABILITY_OFS_DELTAÚCAPABILITY_QUIETÚCAPABILITY_REPORT_STATUSÚCAPABILITY_SHALLOWÚCAPABILITY_SIDE_BAND_64KÚCAPABILITY_THIN_PACKÚCOMMAND_DEEPENÚCOMMAND_DONEÚCOMMAND_HAVEÚCOMMAND_SHALLOWÚCOMMAND_UNSHALLOWÚCOMMAND_WANTÚ	MULTI_ACKÚMULTI_ACK_DETAILEDÚNAK_LINEÚSIDE_BAND_CHANNEL_DATAÚSIDE_BAND_CHANNEL_FATALÚSIDE_BAND_CHANNEL_PROGRESSÚ
SINGLE_ACKÚTCP_GIT_PORTÚZERO_SHAÚBufferedPktLineWriterr
ÚReceivableProtocolÚack_typeÚcapability_agentÚextract_capabilitiesÚextract_want_line_capabilitiesÚformat_ack_lineÚformat_ref_lineÚformat_shallow_lineÚformat_unshallow_lineÚsymref_capabilities)ÚPEELED_TAG_SUFFIXÚ
RefsContainerÚwrite_info_refs)ÚBaseRepoÚRepocóeZdZdZdZdS)ÚBackendz2A backend for the Git smart server implementation.có*t|j¦«)zÖOpen the repository at a path.

        Args:
          path: Path to the repository
        Raises:
          NotGitRepository: no git repository was found at path
        Returns: Instance of BackendRepo
        )ÚNotImplementedErrorÚopen_repository)ÚselfÚpaths  ú9/usr/local/lib/python3.11/site-packages/dulwich/server.pyrMzBackend.open_repositorysõ" $Ô"6Ñ7Ô7Ð7óN)Ú__name__Ú
__module__Ú__qualname__Ú__doc__rM©rQrPrJrJ}s)Ø<Ð<ð	8ð	8ð	8ð	8ð	8rQrJcójeZdZUdZeed<eed<deeeffdZ	dede
efdZ	d
d	ZdS)ÚBackendRepozRepository abstraction used by the Git server.

    The methods required here are a subset of those provided by
    dulwich.repo.Repo.
    Úobject_storeÚrefsÚreturncót)zRGet all the refs in the repository.

        Returns: dict of name -> sha
        ©rL©rNs rPÚget_refszBackendRepo.get_refss
õ
"Ð!rQÚnamecódS)aReturn the cached peeled value of a ref, if available.

        Args:
          name: Name of the ref to peel
        Returns: The peeled value of the ref. If the ref is known not point to
            a tag, this will be the SHA the ref refers to. If no cached
            information about a tag is available, this method may return None,
            but it should attempt to peel the tag if possible.
        NrV)rNr`s  rPÚ
get_peeledzBackendRepo.get_peeleds	ðtrQNcót)aYield the objects required for a list of commits.

        Args:
          progress: is a callback to send progress messages to the client
          get_tagged: Function that returns a dict of pointed-to sha ->
            tag sha for including tags.
        r])rNÚdetermine_wantsÚgraph_walkerÚprogressÚ
get_taggeds     rPÚfind_missing_objectsz BackendRepo.find_missing_objects©s
õ"Ð!rQ©N)
rRrSrTrUrÚ__annotations__rErÚbytesr_rrbrhrVrQrPrXrXsððð(Ð'Ð'Ñ'Ø
ÐÐÑð"$u e|Ô,ð"ð"ð"ð"ð
uð
¨°%¬ð
ð
ð
ð
ðCGð
"ð
"ð
"ð
"ð
"ð
"rQrXcó*eZdZdZddZdedefdZdS)ÚDictBackendz?Trivial backend that looks up Git repositories in a dictionary.r[Ncó||_dSri)Úrepos)rNros  rPÚ__init__zDictBackend.__init__¹s
Ø


rQrOc
óÊt d|¦«	|j|S#t$r.}t	djdit
|¬¦«¤¦«|d}~wwxYw)NzOpening repository at %sz%No git repository was found at {path})rOrV)ÚloggerÚdebugroÚKeyErrorrÚformatÚdict)rNrOÚexcs   rPrMzDictBackend.open_repository¼s|ÝÐ/°Ñ6Ô6Ð6ð	Ø:dÔ#Ð#øÝð	ð	ð	Ý"Ø>Ð7Ô>ÐQÐQÅÈ4ÀÁÄÐQÐQñôàð
øøøøð	øøøs*ª
A"´)AÁA"©r[N)rRrSrTrUrpÚstrrGrMrVrQrPrmrm¶sPØIÐIððððð Cð¨HððððððrQrmcó8eZdZdZejfdfd
ZdZxZS)ÚFileSystemBackendzDSimple backend looking up Git repositories in the local file system.r[Ncót¦« ¦«tj |¦«tjz tjdztj¦«|_dS)Né)ÚsuperrpÚosrOÚabspathÚsepÚreplaceÚroot)rNrÚ	__class__s  rPrpzFileSystemBackend.__init__ÉsQøÝ
×ÒÑÔÐÝW__ TÑ*Ô*R¬VÑ3×<Ò<½R¼VÀa¹ZÍÌÑPÔP			rQcóØt d|¦«tj tj |j|¦«¦«tjz}tj |¦«}tj |j¦«}| 	|¦«std|d|j¦«t|¦«S)Nzopening repository at %szPath z not inside root )rrrsrrOrÚjoinrrÚnormcaseÚ
startswithrrH)rNrOrÚnormcase_abspathÚ
normcase_roots     rPrMz!FileSystemBackend.open_repositoryÍs´ÝÐ/°Ñ6Ô6Ð6Ý'//¥"¤'§,¢,¨t¬y¸$Ñ"?Ô"?Ñ@Ô@Å2Ä6ÑIÝ7×+Ò+¨GÑ4Ô4ÐÝ×(Ò(¨¬Ñ3Ô3
Ø×*Ò*¨=Ñ9Ô9ð	SÝ"Ð#Q¨4Ð#QÐ#QÀDÄIÐ#QÐ#QÑRÔRÐRÝG}}ÐrQrx)	rRrSrTrUrrrprMÚ
__classcell__©rs@rPr{r{ÆscøØNÐNàFðQðQðQðQðQðQðQðððððððrQr{có"eZdZdZdddZdZdS)	ÚHandlerz*Smart protocol command handler base class.Fr[Ncó0||_||_||_dSri)ÚbackendÚprotoÚ
stateless_rpc)rNrrrs    rPrpzHandler.__init__ÚsØØ
Ø*ÔÐÐrQcó*t|j¦«ri)rLÚhandler^s rPrzHandler.handleßsÝ! $¤+Ñ.Ô.Ð.rQ©Frx)rRrSrTrUrprrVrQrPrr×sBØ4Ð4ð+ð+ð+ð+ð+ð
/ð/ð/ð/ð/rQrcóÒeZdZdZddfd
Zedeefd¦«Zedeefd¦«Z	edeefd¦«Z
d	eeddfd
ZdedefdZ
dd
ZxZS)ÚPackHandlerzProtocol handler for packs.Fr[Ncójt¦« |||¦«d|_d|_dS©NF)r~rpÚ_client_capabilitiesÚ_done_received)rNrrrrs    rPrpzPackHandler.__init__æs5øÝ
×Ò %¨Ñ7Ô7Ð7Ø:>Ô!à#ÔÐÐrQcó*t|j¦«ri)rLÚcapabilities©Úclss rPrzPackHandler.capabilitiesìså! #Ô"2Ñ3Ô3Ð3rQcóPttttt	¦«gSri)rr)r#r$r<rs rPÚinnocuous_capabilitiesz"PackHandler.innocuous_capabilitiesðs#õ
#Ý Ý"Ý ÝÑÔð
ð	
rQcógS)zAReturn a list of capabilities that we require the client to have.rVrs rPÚrequired_capabilitiesz!PackHandler.required_capabilitiesús	ð	rQÚcapscóÀt| ¦«¦«}| | ¦«¦«|D]6}| t
dz¦«r ||vrt
d|z¦«7| ¦«D]}||vrt
d|z¦«t|¦«|_t 
d|¦«dS)Nó=z7Client asked for capability %r that was not advertised.z/Client does not support required capability %r.zClient capabilities: %s)Úsetr¡Úupdaterrrrr£rrrÚinfo)rNr¤Úallowable_capsÚcaps    rPÚset_client_capabilitiesz#PackHandler.set_client_capabilitiesÿsÝT×8Ò8Ñ:Ô:Ñ;Ô;Ø×Òd×/Ò/Ñ1Ô1Ñ2Ô2Ð2Øð	ð	CØ~~Õ.°Ñ5Ñ6Ô6ð
ØØ.Ð(Ð(Ý&ØPÐSVÑVñôðð)ð×-Ò-Ñ/Ô/ð	ð	CØ$Ý&ØHÈ3ÑNñôððõ%(¨¡I¤IÔ!ÝÐ-¨tÑ4Ô4Ð4Ð4Ð4rQr«cóF|jtd|z¦«||jvS)Nz=Server attempted to access capability %r before asking client)rr)rNr«s  rPÚhas_capabilityzPackHandler.has_capabilitys6ØÔ$Ð,Ý"ØRÐUXÑXñôð
ðdÔ/Ð/Ð/rQcód|_dS)NT)rr^s rPÚnotify_donezPackHandler.notify_donesØ"ÔÐÐrQrrx)rRrSrTrUrpÚclassmethodrrkrr¡r£r¬Úboolr®r°rrs@rPrrãs%øØ%Ð%ð$ð$ð$ð$ð$ð$ð$ðð4X e_ð4ð4ð4ñ[ð4ðð
 x°¤ð
ð
ð
ñ[ð
ðð h¨u¤oðððñ[ðð5¨H°U¬Oð5Àð5ð5ð5ð5ð$0 %ð0¨Dð0ð0ð0ð0ð#ð#ð#ð#ð#ð#ð#ð#rQrcóeZdZdZ	d
	dfd
Zed¦«Zed¦«Zdefd	Z	d
Z
ddeeeffdZ
dZxZS)ÚUploadPackHandlerz4Protocol handler for uploading a pack to the client.Fr[Ncóºt¦« |||¬¦«| |d¦«|_d|_||_d|_dS)N©rrF)r~rprMÚrepoÚ
_graph_walkerÚadvertise_refsÚ_processing_have_lines©rNrÚargsrrr¹rs      rPrpzUploadPackHandler.__init__s]øõ	×Ò %°}ÐÑEÔEÐEØ×+Ò+¨D°¬GÑ4Ô4	Ø!ÔØ,Ôð',Ô#Ð#Ð#rQc	órtttttt
tttg	Sri)	r!r r(r)r$r#rr'r"rs rPrzUploadPackHandler.capabilities+s)õ
*Ý Ý$Ý Ý Ý"Ý"ÝÝð

ð
	
rQcó*tttfSri)r(r)r$rs rPr£z'UploadPackHandler.required_capabilities9sõ
%Ý Ý ð
ð	
rQÚmessagecódSrirV)rNr¿s  rPrfzUploadPackHandler.progressAóØrQcó$| t¦«rd| t¦«s$t|jjt¦«|_t|jjt¦«|_	dS|jj
|_	dSri)r®r(r#rrÚwrite_sidebandr5rfr3Úwrite_pack_dataÚwriter^s rPÚ_start_pack_send_phasez(UploadPackHandler._start_pack_send_phaseDsØ×ÒÕ7Ñ8Ô8ð	4ð×&Ò&Õ'=Ñ>Ô>ð
Ý 'ØJÔ-Õ/Iñ!ô!
õ$+Ø
Ô)Õ+Añ$ô$DÔ Ð Ð ð$(¤:Ô#3DÔ Ð Ð rQcó$| t¦«siS||j ¦«}|t	|jdd¦«}|iSi}| ¦«D]%\}}| |¦«}||kr|||<&|S)a¼Get a dict of peeled values of tags to their original tag shas.

        Args:
          refs: dict of refname -> sha of possible tags; defaults to all
            of the backend's refs.
          repo: optional Repo instance for getting peeled refs; defaults
            to the backend's repo, if available
        Returns: dict of peeled_sha -> tag_sha, where tag_sha is the sha of a
            tag whose peeled value is peeled_sha.
        Nr·)r®rr·r_ÚgetattrÚitemsrb)rNrZr·Útaggedr`ÚshaÚ
peeled_shas       rPrgzUploadPackHandler.get_taggedSsªð×"Ò"Õ#9Ñ:Ô:ð	ØIØ<Ø9×%Ò%Ñ'Ô'DØ<Ý49 f¨dÑ3Ô3DØ|ð
	ðØð	)ð	)ID#Ø¨Ñ.Ô.JØSÒ Ð Ø%(zÑ"øØ
rQcó¢d|_t||jj|jj|jjj¦«gfd}|j ||j|j	¬¦«}t|¦«}t¦«dkrdS | 
t¦«|j¦«sdS| ¦«| dt|¦«z d¦«¦«t%|j|jj|¦«|j d¦«dS)NTcóJ j|fi|¤¦«Sri)Úextendrd)rZÚkwargsreÚwantss  rPÚ
wants_wrapperz/UploadPackHandler.handle.<locals>.wants_wrappers0øØLLÐ5Ô5°dÐEÐE¸fÐEÐEÑFÔFÐFØLrQ)rgrzcounting objects: %d, done.
Úascii)rºÚ_ProtocolGraphWalkerr·rYrbrZÚget_symrefsrhrfrgÚlistÚlenÚhandle_doner®r"rrÆÚencoderrÄrÚwrite_pkt_line)rNrÒÚmissing_objectsÚ
object_idsrerÑs    @@rPrzUploadPackHandler.handlesspøøð'+Ô#å+ØØIÔ"ØIÔ ØINÔ&ñ	
ô
ðð	ð	ð	ð	ð	ð	ð)×8Ò8ØØØMØð	9ñ
ô
õ/Ñ*Ô*
õu::??ØFà×'Ò'Ø×#Ò#Õ$6Ñ7Ô7Ð7¸Ô9Lñ
ô
ð	ð
Fà×#Ò#Ñ%Ô%Ð%Ø

Ø
,s°:©¬Ñ
>×FÒFÀwÑOÔOñ	
ô	
ð	
õ	"ØÔ  $¤)Ô"8¸*ñ	
ô	
ð	
ð	

×!Ò! $Ñ'Ô'Ð'Ð'Ð'rQ©FFrx)NN)rRrSrTrUrpr±rr£rkrfrÆrrrgrrrs@rPr´r´sìøØ>Ð>ðINð
,à	
ð
,ð
,ð
,ð
,ð
,ð
,ðð
ð
ñ[ð
ðð
ð
ñ[ð
ð
 ð
ð
ð
ð
ð
4ð
4ð
4ðð°$°xÀÐ7IÔ2Jððððð@2(ð2(ð2(ð2(ð2(ð2(ð2(rQr´có
|sdg}n)| d¦« dd¦«}|d}|||vrt|¦«t|¦«dkr|tdfvr|dfSt|¦«dkrq|t
tttfvr3t|d¦«std¦«t|¦«S|tkr|t|d¦«fStd|z¦«)	acSplit a line read from the wire.

    Args:
      line: The line read from the wire.
      allowed: An iterable of command names that should be allowed.
        Command names not listed below as possible return values will be
        ignored.  If None, any commands from the possible return values are
        allowed.
    Returns: a tuple having one of the following forms:
        ('want', obj_id)
        ('have', obj_id)
        ('done', None)
        (None, None)  (for a flush-pkt)

    Raises:
      UnexpectedCommandError: if the line cannot be parsed into one of the
        allowed return values.
    Nó
ó rrr}zInvalid shaz%Received invalid line from client: %r)ÚrstripÚsplitrr×r+r/r,r-r.rrÚtupler*Úint)ÚlineÚallowedÚfieldsÚcommands    rPÚ_split_proto_lineré¨sð&ð3ØàUÑ#Ô#×)Ò)¨$°Ñ2Ô2ØQiGØÐw¨gÐ5Ð5Ý$ WÑ-Ô-Ð-Ý
6{{aÒÐG°dÐ';Ð;Ð;ØÐÝ	VÒ	Ð	ØÝÝÝÝð	
ð
ð
õ   q¤	Ñ*Ô*ð
6Ý& }Ñ5Ô5Ð5Ý==Ð Ø
Ò
&Ð
&ØC  q¤	NNÐ*Ð*Ý
ÐBÀTÑIÑ
JÔ
JÐJrQÚstorecóä
i

fd}g}|D]F}t|¦«\}}t|t¦«r| |jdf¦«Gt¦«}t¦«}	|ry| ¦«\}
}||krE| |
¦«|dz| fd||
¦«D¦«¦«n|	 |
¦«|°y|	|fS)aFind shallow commits according to a given depth.

    Args:
      store: An ObjectStore for looking up objects.
      heads: Iterable of head SHAs to start walking from.
      depth: The depth of ancestors to include. A depth of one includes
        only the heads themselves.
    Returns: A tuple of (shallow, not_shallow), sets of SHAs that should be
        considered shallow and unshallow according to the arguments. Note that
        these sets may overlap if a commit is reachable along multiple paths.
    có\ |d¦«}|s|j}||<|Sri)ÚgetÚparents)rËÚresultrîrês  rPÚget_parentsz"_find_shallow.<locals>.get_parentsás8øØS $Ñ'Ô'Øð	"Ø3ZÔ'FØ!GCLØ
rQrc3ó K|]}|fV	dSrirV)Ú.0ÚpÚ	new_depths  rPú	<genexpr>z _find_shallow.<locals>.<genexpr>õs'øèèÐAÐA¨1IÐAÐAÐAÐAÐAÐArQ)	rÚ
isinstancerÚappendÚidr§ÚpopÚaddrÏ)rêÚheadsÚdepthrðÚtodoÚhead_shaÚ	_unpeeledÚpeeledÚnot_shallowÚshallowrËÚ	cur_depthrôrîs`           @@rPÚ
_find_shallowrÓs-øøøð)+GðððððððDØð(ð(Ý$ U¨HÑ5Ô5Ñ	6ÝffÑ%Ô%ð	(ØKK AÑ'Ô'Ð'øå%%KÝeeGØ
ðØYØuÒÐØOOCÑ Ô Ð Ø! A
IØKKÐAÐAÐAÐA°°¸CÑ0@Ô0@ÐAÑAÔAÑAÔAÐAÐAàKKÑÔÐðððKÐÐrQcó~||}tj|g¦«}|h}|r| ¦«}|j|vrdSt	|t
¦«s7|jD][}||vr| |¦«||}	t	|	t
¦«sJ|	j|kr| 	|	¦«\|°dS)NTF)
ÚcollectionsÚdequeÚpopleftrørörrîrúÚcommit_timer÷)
rêÚhavesÚwantÚearliestÚoÚpendingÚknownÚcommitÚparentÚ
parent_objs
          rPÚ_want_satisfiedrüsâØ
dAÝÔ  Ñ$Ô$GØ
FEØ
ð+ØÑ"Ô"Ø9ÐÐØ4Ý&¥&Ñ)Ô)ð	àØnð	+ð	+FØØØIIfÑÔÐØvJÝj&Ñ1Ô1Ð1Ð1Ð1àÔ%¨Ò1Ð1ØzÑ*Ô*Ð*øðð+ð 5rQcó²t|¦«}|r(fd|D¦«}td|D¦«¦«}nd}|D]}t|||¦«sdSdS)a~Check whether all the current wants are satisfied by a set of haves.

    Args:
      store: Object store to retrieve objects from
      haves: A set of commits we know the client has.
      wants: A set of commits the client wants
    Note: Wants are specified with set_wants rather than passed in since
        in the current interface they are determined outside this class.
    có g|]
}|SrVrV)ròÚhrês  rPú
<listcomp>z(_all_wants_satisfied.<locals>.<listcomp>søÐ-Ð-Ð- !U1XÐ-Ð-Ð-rQcóFg|]}t|t¦«¯|jSrV)rörr	)ròrs  rPrz(_all_wants_satisfied.<locals>.<listcomp> s)ÐRÐRÐR¨!½JÀqÍ&Ñ<QÔ<QÐR
ÐRÐRÐRrQrFT)r§Úminr)rêr
rÑÚ	have_objsrrs`     rPÚ_all_wants_satisfiedrsøõ
JJEØðØ-Ð-Ð-Ð- uÐ-Ñ-Ô-	ÝÐRÐR¨yÐRÑRÔRÑSÔSàØððÝu e¨T°8Ñ<Ô<ð	Ø55ð	ð4rQcóeZdZdZdeddfdZddZdZdZd	Z	d
Z
dZeZdZ
d
ZdZddZdZdZdZdZdZdS)rÔa7A graph walker that knows the git protocol.

    As a graph walker, this class implements ack(), next(), and reset(). It
    also contains some base methods for interacting with the wire and walking
    the commit tree.

    The work of determining which acks to send is passed on to the
    implementation instance stored in _impl. The reason for this is that we do
    not know at object creation time what ack level the protocol requires. A
    call to set_ack_type() is required to set up the implementation, before
    any calls to next() or ack() are made.
    rYr[Ncó>||_||_||_||_|j|_|j|_|j|_g|_t¦«|_	t¦«|_
t¦«|_d|_g|_
d|_d|_dS)NFr)ÚhandlerrêrbrÕrrr¹Ú_wantsr§rÚclient_shallowÚ	unshallowÚ_cachedÚ_cacheÚ_cache_indexÚ_impl)rNrrYrbrÕs     rPrpz_ProtocolGraphWalker.__init__8sðØ&2
Ø$Ø&ÔØ]
Ø$Ô2ÔØ%Ô4ÔØ#%Ý#&¡5¤5Ý*-©%¬%ÔÝ%(¡U¤UØØ#%ØÔØ


rQc
ó| ¦«}t| ¦«¦«}|js|jsftt
| ¦«¦«¦«D]\}\}}	| |¦«}n#t$rY,wxYw|dkr}t d|j 
¦«¦«t|||j 
¦«t| ¦«¦«z¦«}	nt||¦«}	|j |	¦«||kr0|j t|t$z|¦«¦«|j d¦«|jrgS|j ¦«}
|
sgSt)|
¦«\}	}|j |¦«| t/|¦«¦«t0t2t4df}t7|	|¦«\}
}g}|
t0krN||vrt9d|z¦«| |¦«| |¦«\}
}|
t0k°N| |¦«|
t2t4fvr+|  |
|¦«| !|¦«|jr|j "¦«rgS|S)a-Determine the wants for a set of heads.

        The given heads are advertised to the client, who then specifies which
        refs they want using 'want' lines. This portion of the protocol is the
        same regardless of ack type, and in fact is used to set the ack type of
        the ProtocolGraphWalker.

        If the client has the 'shallow' capability, this method also reads and
        responds to the 'shallow' and 'deepen' lines from the client. These are
        not part of the wants per se, but they set up necessary state for
        walking the graph. Additionally, later code depends on this method
        consuming everything up to the first 'have' line.

        Args:
          heads: a dict of refname->SHA1 to advertise
        Returns: a list of SHA1s requested by the client
        rúSending capabilities: %sNzClient wants invalid object %s)#rÕr§Úvaluesr¹rÚ	enumerateÚsortedrÉrbrtrrr©rrr@rCrrÚrDÚ
read_pkt_liner>r¬Úset_ack_typer;r/r-r*rérr÷Úread_proto_lineÚ	set_wantsÚunread_proto_lineÚ_handle_shallow_requestÚeof)rNrûrüÚsymrefsr(ÚiÚrefrËrÌrårr¤rærèÚ	want_revss               rPrdz$_ProtocolGraphWalker.determine_wantsKsð$×"Ò"Ñ$Ô$ÝU\\^^Ñ$Ô$ØÔð	 dÔ&8ñ	Ý!*6°%·+²+±-´-Ñ+@Ô+@Ñ!AÔ!Að
ñ

:CðØ!%§¢°Ñ!5Ô!5JJøÝððððHð	øøøð
66ÝKKÐ :¸D¼L×<UÒ<UÑ<WÔ<WÑXÔXÐXÝ*ØØØ×1Ò1Ñ3Ô3Ý-¨g¯mªm©o¬oÑ>Ô>ñ?ñôDDõ+¨3°Ñ4Ô4DØ
×)Ò)¨$Ñ/Ô/Ð/Ø Ò$Ð$ØJ×-Ò-Ý'¨Õ.?Ñ(?ÀÑLÔLñôðùð

J×%Ò% dÑ+Ô+Ð+àÔ"ð
Ø	ðz×'Ò'Ñ)Ô)Øð	ØIÝ3°DÑ9Ô9
dØ×,Ò,¨TÑ2Ô2Ð2Ø×Ò( 4..Ñ)Ô)Ð)Ý¥µ.À$ÐGÝ(¨¨wÑ7Ô7à	ØÒ%Ð%Ø&Ð Ð Ý&Ð'GÈ#Ñ'MÑNÔNÐNØ×ÒSÑ!Ô!Ð!Ø×/Ò/°Ñ8Ô8LGSð	Ò%Ð%ð	
yÑ!Ô!Ð!ØÐ7Ð7Ð7Ø×"Ò" 7¨CÑ0Ô0Ð0Ø×(Ò(¨Ñ3Ô3Ð3àÔð	 $¤*§.¢.Ñ"2Ô"2ð	ð
IàÐsÁ=BÂ
B ÂB có´t|t¦«r"t|¦« d¦«}|j |dz|z¦«dS)NrÓrà)röräryrÙrÚunread_pkt_line)rNrèÚvalues   rPr/z&_ProtocolGraphWalker.unread_proto_linesRÝeSÑ!Ô!ð	/ÝJJ×%Ò% gÑ.Ô.EØ
×"Ò" 7¨T¡>°EÑ#9Ñ:Ô:Ð:Ð:Ð:rQcódSrirVr^s rPÚnakz_ProtocolGraphWalker.nak¢rÁrQcót|¦«dkrtd|z¦«|j |¦«S)Né(zinvalid sha %r)r×Ú
ValueErrorr%Úack©rNÚhave_refs  rPr>z_ProtocolGraphWalker.ack¥s;Ýx==BÒÐÝÐ-°Ñ8Ñ9Ô9Ð9Øz~~hÑ'Ô'Ð'rQcó"d|_d|_dS)NTr)r"r$r^s rPÚresetz_ProtocolGraphWalker.resetªsØØÔÐÐrQcóÚ|js$|js	|jrdSt|j¦«S|xjdz
c_|jt|j¦«krdS|j|jS)Nr)r"r%rÚnextr$r×r#r^s rPrDz_ProtocolGraphWalker.next®svØ|ð	$Ø:ð
 $Ô"4ð
ØtÝ
Ñ#Ô#Ð#ØÐÔQÑÐÔØÔs 4¤;Ñ/Ô/Ò/Ð/Ø4Ø{4Ô,Ô-Ð-rQcóPt|j ¦«|¦«S)aRead a line from the wire.

        Args:
          allowed: An iterable of command names that should be allowed.
        Returns: A tuple of (command, value); see _split_proto_line.

        Raises:
          UnexpectedCommandError: If an error occurred reading the line.
        )rérr+)rNræs  rPr-z$_ProtocolGraphWalker.read_proto_lineºs"õ! ¤×!9Ò!9Ñ!;Ô!;¸WÑEÔEÐErQcó	| ttf¦«\}}|tkr|}n|j |¦«M| d¦«t|j||¦«\}}|j ||z
¦«|j|jz
}||jzx}|_	t|¦«D])}	|j t|	¦«¦«*t|¦«D])}	|j t|	¦«¦«*|j d¦«dS)NTri)r-r*r-r rúrrêrr¨r!r*rrÚrArB)
rNrÑrèÚvalrürrÚnew_shallowr!rËs
          rPr0z,_ProtocolGraphWalker._handle_shallow_requestÆsRð	)Ø×/Ò/µÅÐ0QÑRÔRLGSØ.Ò(Ð(ØØØÔ×#Ò# CÑ(Ô(Ð(ð	)ð	
×ÒWÑ%Ô%Ð%å,¨T¬Z¸ÀÑFÔFÑð	
×ÒG kÑ1Ñ2Ô2Ð2Øl TÔ%8Ñ8Ø%0°4Ô3FÑ%FÐF	DNå+Ñ&Ô&ð	@ð	@CØJ×%Ò%Õ&9¸#Ñ&>Ô&>Ñ?Ô?Ð?Ð?Ý)Ñ$Ô$ð	Bð	BCØJ×%Ò%Õ&;¸CÑ&@Ô&@ÑAÔAÐAÐAà
×!Ò! $Ñ'Ô'Ð'Ð'Ð'rQcó8|j ¦«dSri)rr°r^s rPr°z _ProtocolGraphWalker.notify_doneÞsà× Ò Ñ"Ô"Ð"Ð"Ð"rQrQcóV|j t||¦«¦«dSri)rrÚr?)rNrËr;s   rPÚsend_ackz_ProtocolGraphWalker.send_ackâs(Ø
×!Ò!¥/°#°xÑ"@Ô"@ÑAÔAÐAÐAÐArQcóD|j t¦«dSri)rrÚr2r^s rPÚsend_nakz_ProtocolGraphWalker.send_nakåsØ
×!Ò!¥(Ñ+Ô+Ð+Ð+Ð+rQcó8|j ||¦«Sri)r%rØ©rNÚ
done_requiredÚ
done_receiveds   rPrØz _ProtocolGraphWalker.handle_doneèsàz×%Ò% m°]ÑCÔCÐCrQcó||_dSri)r)rNrÑs  rPr.z_ProtocolGraphWalker.set_wantsìs
ØrQcó8t|j||j¦«S)a0Check whether all the current wants are satisfied by a set of haves.

        Args:
          haves: A set of commits we know the client has.
        Note: Wants are specified with set_wants rather than passed in since
            in the current interface they are determined outside this class.
        )rrêr)rNr
s  rPÚall_wants_satisfiedz(_ProtocolGraphWalker.all_wants_satisfiedïsõ$ D¤J°°t´{ÑCÔCÐCrQcó~tttttt
i}|||¦«|_dSri)r0ÚMultiAckGraphWalkerImplr1ÚMultiAckDetailedGraphWalkerImplr6ÚSingleAckGraphWalkerImplr%)rNr;Úimpl_classess   rPr,z!_ProtocolGraphWalker.set_ack_typeùs7åÕ.ÝÕ ?ÝÕ0ð
ð
,\ (Ô+¨DÑ1Ô1


rQri)rQ)rRrSrTrUrrprdr/r:r>rBrDÚ__next__r-r0r°rKrMrØr.rTr,rVrQrPrÔrÔ*sFðððØ%4ðà	
ððððð&PðPðPðPðd;ð;ð;ð

ð
ð
ð(ð(ð(ð
ððð.ð.ð.ðHð
Fð
Fð
Fð(ð(ð(ð0#ð#ð#ðBðBðBðBð,ð,ð,ðDðDðDððððDðDðDð2ð2ð2ð2ð2rQrÔcó0eZdZdZddZdZdZeZdZdS)	rXz@Graph walker implementation that speaks the single-ack protocol.r[Ncó"||_g|_dSri©ÚwalkerÚ_common©rNr^s  rPrpz!SingleAckGraphWalkerImpl.__init__óØØ$&rQcó|js6|j |¦«|j |¦«dSdSri)r_r^rKr÷r?s  rPr>zSingleAckGraphWalkerImpl.acksHØ|ð	*ØK× Ò  Ñ*Ô*Ð*ØL×Ò Ñ)Ô)Ð)Ð)Ð)ð	*ð	*rQcó°|j t¦«\}}|dtfvr|j ¦«dS|t
kr|SdSri)r^r-Ú_GRAPH_WALKER_COMMANDSr+r°r,©rNrèrËs   rPrDzSingleAckGraphWalkerImpl.nexts]Ø{×2Ò2Õ3IÑJÔJØt\Ð*Ð*Ð*àK×#Ò#Ñ%Ô%Ð%Ø4Ø
Ò
$Ð
$ØJð%Ð
$rQcóh|js|j ¦«|r|sdS|s	|jsdSdS)NFT)r_r^rMrOs   rPrØz$SingleAckGraphWalkerImpl.handle_donesSØ|ð	#ØK× Ò Ñ"Ô"Ð"àð	 ð	ð5àð	 T¤\ð	ð5àtrQrx©	rRrSrTrUrpr>rDrZrØrVrQrPrXrXsbØJÐJð'ð'ð'ð'ð*ð*ð*ð
ðððHðððððrQrXcó0eZdZdZddZdZdZeZdZdS)	rVz?Graph walker implementation that speaks the multi-ack protocol.r[Ncó0||_d|_g|_dSr)r^Ú_found_baser_r`s  rPrpz MultiAckGraphWalkerImpl.__init__4sØØ ÔØ$&rQcóÒ|j |¦«|jsC|j |d¦«|j |j¦«rd|_dSdSdS)NócontinueT)r_r÷rjr^rKrTr?s  rPr>zMultiAckGraphWalkerImpl.ack9swØ×ÒHÑ%Ô%Ð%ØÔð	(ØK× Ò  ¨;Ñ7Ô7Ð7Ø{×.Ò.¨t¬|Ñ<Ô<ð
(Ø#'Ô Ð Ð ð	(ð	(ð
(ð
(rQcó,	|j t¦«\}}||j ¦«?|tkr|j ¦«dS|tkr$|jr|j |d¦«|S)NTrl)	r^r-rdrMr+r°r,rjrKres   rPrDzMultiAckGraphWalkerImpl.nextAsð	Ø;×6Ò6Õ7MÑNÔNLGSØØ×$Ò$Ñ&Ô&Ð&ðØLÒ(Ð(Ø×'Ò'Ñ)Ô)Ð)ØtØLÒ(Ð(ØÔ#ð;àK×(Ò(¨¨kÑ:Ô:Ð:Ø
ð	rQcó´|r|sdS|s	|jsdS|jr&|j |jd¦«n|j ¦«dS©NFéÿÿÿÿT©r_r^rKrMrOs   rPrØz#MultiAckGraphWalkerImpl.handle_doneTóuØð	 ð	ð5àð	 T¤\ð	ð5ð<ð	#ØK× Ò  ¤¨bÔ!1Ñ2Ô2Ð2Ð2àK× Ò Ñ"Ô"Ð"ØtrQrxrgrVrQrPrVrV1sbØIÐIð'ð'ð'ð'ð
(ð(ð(ðððð"HðððððrQrVcó0eZdZdZddZdZdZeZdZdS)	rWzEGraph walker implementation speaking the multi-ack-detailed protocol.r[Ncó"||_g|_dSrir]r`s  rPrpz(MultiAckDetailedGraphWalkerImpl.__init__orarQcóp|j |¦«|j |d¦«dS)Nscommon)r_r÷r^rKr?s  rPr>z#MultiAckDetailedGraphWalkerImpl.ackss6à×ÒHÑ%Ô%Ð%Ø×ÒX yÑ1Ô1Ð1Ð1Ð1rQcó	|j t¦«\}}|m|j |j¦«r&|j |jdd¦«|j ¦«|jjrdSn3|tkr|j 	¦«dS|tkr|SÅ)NTrpsready)r^r-rdrTr_rKrMrr+r°r,res   rPrDz$MultiAckDetailedGraphWalkerImpl.nextxsÊð	Ø;×6Ò6Õ7MÑNÔNLGSØØ;×2Ò2°4´<Ñ@Ô@ðEØK×(Ò(¨¬°bÔ)9¸8ÑDÔDÐDØ×$Ò$Ñ&Ô&Ð&Ø;Ô,ð ð 4ð ðLÒ(Ð(à×'Ò'Ñ)Ô)Ð)ØØLÒ(Ð(ð
ð-	rQcó´|r|sdS|s	|jsdS|jr&|j |jd¦«n|j ¦«dSrorqrOs   rPrØz+MultiAckDetailedGraphWalkerImpl.handle_donerrrQrxrgrVrQrPrWrWlsbØOÐOð'ð'ð'ð'ð2ð2ð2ð
ððð6HðððððrQrWcóÖeZdZdZ	d
	dfd
Zedeefd¦«Zde	e
eeefde	e
eeffdZd	e	e
eefddfd
ZdZ
ddZxZS)ÚReceivePackHandlerz8Protocol handler for downloading a pack from the client.Fr[Ncót¦« |||¬¦«| |d¦«|_||_dS)Nr¶r)r~rprMr·r¹r»s      rPrpzReceivePackHandler.__init__°sKøõ	×Ò %°}ÐÑEÔEÐEØ×+Ò+¨D°¬GÑ4Ô4	Ø,ÔÐÐrQcóNtttttt
gSri)r&rr%r$r(r"rs rPrzReceivePackHandler.capabilities·s õ
%Ý"ÝÝ Ý$Ýð

ð	
rQrZcóàtttttt
jtjtf}g}d}|D]}|dtkrd}|r´	t|jdd¦«}|jj
 |jj|¦«| d¦«nr#|$rU}| dt#|¦« dd¦« d	¦«f¦«Yd}~nd}~wwxYw| d¦«|D]Ç\}}	}
d
}	|	tkrYt(| ¦«vrt-d¦«	|jj |
|¦«n=#|$rd}Yn4wxYw	|jj |
||	¦«n
#|$rd
}YnwxYwn#t4$rd}YnwxYw| |
|f¦«È|S)NFrTÚrecv)óunpackóokr~ú
Úúutf-8rz8Attempted to delete refs without delete-refs capability.sfailed to deletesfailed to writesbad ref)ÚIOErrorÚOSErrorrrÚAssertionErrorÚsocketÚerrorÚzlibrr8rÈrr·rYÚ
add_thin_packÚreadr÷ryrrÙrrrrZÚremove_if_equalsÚ
set_if_equalsrt)rNrZÚall_exceptionsÚstatusÚwill_send_packrèr}ÚeÚoldsharËr4Ú
ref_statuss            rPÚ_apply_packzReceivePackHandler._apply_packÂsVõ
ÝÝÝÝÝLÝJÝ!ð	
ðØàð	&ð	&GØqzXÒ%Ð%Ø!%øàð	.ð
UÝtz¨6°4Ñ8Ô8Ø	Ô&×4Ò4°T´Z´_ÀdÑKÔKÐKØ

Ð0Ñ1Ô1Ð1Ð1øØ!ð
Uð
Uð
UØ

y#¨a©&¬&¯.ª.¸¸rÑ*BÔ*B×*IÒ*IÈ'Ñ*RÔ*RÐSÑTÔTÐTÐTÐTÐTÐTÐTøøøøð
Uøøøð
MMÐ,Ñ-Ô-Ð-à $ð	-ð	-ÑFCØJð
(Ø(??Ý-°T×5FÒ5FÑ5HÔ5HÐHÐHÝ.ð*ñôðð9Ø	×7Ò7¸¸VÑDÔDÐDÐDøØ)ð9ð9ð9Ø%8


ð9øøøð8Ø	×4Ò4°S¸&À#ÑFÔFÐFÐFøØ)ð8ð8ð8Ø%7


ð8øøøøøåð
(ð
(ð
(Ø'


ð
(øøøàMM3 
Ð+Ñ,Ô,Ð,Ð,à
stÁAB2Â2DÂ7ADÄDÄ/5GÅ% FÆGÆFÆ
GÆFÆGÆ!F6Æ5GÆ6GÆ=GÆ?GÇGÇGÇGrcód t¦«r tfd¦«j}fd}njj}d}|D]L\}}|dkr|d|zdz¦«|dkr|d|zdz¦«5|d	|zd
z|zdz¦«M|d¦«|¦«dS)NcóDj t|¦«Sri©rrÃr3)ÚdrNs rPú<lambda>z3ReceivePackHandler._report_status.<locals>.<lambda>sø$*×3Ò3Õ4JÈAÑNÔNrQcód ¦«j d¦«dSri)ÚflushrrÚ)rNÚwritersrPrz0ReceivePackHandler._report_status.<locals>.flushs,øØØ
×)Ò)¨$Ñ/Ô/Ð/Ð/Ð/rQcódSrirVrVrQrPrz0ReceivePackHandler._report_status.<locals>.flushsØrQr~sunpack rßrsok sng rà)r®r(r9rÅrrÚ)rNrrÅrr`Úmsgrs`     @rPÚ_report_statusz!ReceivePackHandler._report_statusþs!øøØ×ÒÕ7Ñ8Ô8ð	Ý*ØNÐNÐNÐNñôFðLEð
0ð
0ð
0ð
0ð
0ð
0ð
0ð
JÔ-Eð
ð
ð
ð ð	:ð	:ID#ØyÒ Ð Øj 3Ñ&¨Ñ.Ñ/Ô/Ð/Ð/ØØftm eÑ+Ñ,Ô,Ð,Ð,àftm dÑ*¨SÑ0°5Ñ8Ñ9Ô9Ð9Ð9Ø
dØ
rQcór|jj dd¦«}|sdS	| |¦«}|r"|j t|¦«dSdS#t$rK}|j tt|¦« 
d¦«¦«Yd}~dSd}~wwxYw)Nzpost-receiver)r·ÚhooksríÚexecuterrÃr5rr4ryrÙ)rNÚclient_refsÚhookÚoutputÚerrs     rPÚ_on_post_receivez#ReceivePackHandler._on_post_receivesÓØy×"Ò" >°4Ñ8Ô8Øð	ØFð	YØ\\ +Ñ.Ô.FØð
NØ
×)Ò)Õ*DÀfÑMÔMÐMÐMÐMð
Nð
Nøåð	Yð	Yð	YØJ×%Ò%Õ&=½sÀ3¹x¼x¿ºÈwÑ?WÔ?WÑXÔXÐXÐXÐXÐXÐXÐXÐXøøøøð	Yøøøs¦7A!Á!
B6Á+AB1Â1B6c
ó|js|jst|j ¦« ¦«¦«}t|jj ¦« ¦«¦«}|sttfg}t d| ¦«¦«|j
 t|dd|dd| ¦«t!|¦«z¦«¦«t#dt%|¦«¦«D]>}||}|j
 t|d|d¦«¦«?|j
 d¦«|jrdSg}|j
 ¦«}|dSt)|¦«\}}| |¦«|rB| | ¦«¦«|j
 ¦«}|°B| |¦«}| |¦«| t6¦«r| |¦«dSdS)Nr'rr)r¹rr*r·r_rÉrZrÕrr8rrr©rrrÚr@rCÚranger×r+r=r¬r÷rârr¦r®r&r)rNrZr2r3r4r¢r¤rs        rPrzReceivePackHandler.handle$sfØÔð	 dÔ&8ñ	Ý$)×,Ò,Ñ.Ô.×4Ò4Ñ6Ô6Ñ7Ô7DÝTY^×7Ò7Ñ9Ô9×?Ò?ÑAÔAÑBÔBGàð
6Ý)8Ð4Ð5ÝKKÐ2°D×4EÒ4EÑ4GÔ4GÑHÔHÐHØJ×%Ò%ÝØGAJØGAJØ×%Ò%Ñ'Ô'Õ*=¸gÑ*FÔ*FÑFñôñ
ô
ð
õ1c $iiÑ(Ô(ð
Kð
KØ1gØ
×)Ò)/¸#¸a¼&À#ÀaÄ&Ñ*IÔ*IÑJÔJÐJÐJàJ×%Ò% dÑ+Ô+Ð+ØÔ"ð
ØàØj×&Ò&Ñ(Ô(ð;ØFå(¨Ñ-Ô-	TØ×$Ò$ TÑ*Ô*Ð*ðð	-Ø×Òsyy{{Ñ+Ô+Ð+Ø*×*Ò*Ñ,Ô,Cðð	-ð
×!Ò! +Ñ.Ô.à×ÒkÑ*Ô*Ð*ð×ÒÕ7Ñ8Ô8ð	(Ø×Ò Ñ'Ô'Ð'Ð'Ð'ð	(ð	(rQrÝrx)rRrSrTrUrpr±rrkrrr	rrr¦rrrs@rPryrysøØBÐBðINð-à	
ð-ð-ð-ð-ð-ð-ðð
X e_ð
ð
ð
ñ[ð
ð:Øu e¨UÐ2Ô3Ô4ð:à	
eE5LÔ!Ô	"ð:ð:ð:ð:ðx T¨%°°u°Ô*=Ô%>ðÀ4ððððð6	Yð	Yð	Yð.(ð.(ð.(ð.(ð.(ð.(ð.(ð.(rQrycó(eZdZddfd
ZdZxZS)ÚUploadArchiveHandlerFr[Ncót¦« |||¦«| |d¦«|_dS)Nr)r~rprMr·)rNrr¼rrrs     rPrpzUploadArchiveHandler.__init__Vs<øÝ
×Ò %¨Ñ7Ô7Ð7Ø×+Ò+¨D°¬GÑ4Ô4			rQcóLfd}g}j ¦«D][}| dd¦«\}}|dkrtd|z¦«| | d¦«¦«\d}d}d	}jj}	|t|¦«kr||}
|
d
kr|dz
}||}nL|
dkr!|dz
}|| 	d¦«}n%jj
|
}|	|	|j}|dz
}|t|¦«k°j d
¦«j d¦«t|	|tj¦«||¬¦«D]
}
||
¦«j d¦«dS)NcóDj t|¦«Srir)ÚxrNs rPrÅz*UploadArchiveHandler.handle.<locals>.write[søØ:×,Ò,Õ-CÀQÑGÔGÐGrQràrsargumentzunknown command %srßrQÚtarrs--prefixs--formatrÓsACK)ÚmtimeÚprefixru)rÚread_pkt_seqrârr÷rár·rYr×ÚdecoderZÚtreerÚr
Útime)rNrÅÚ	argumentsÚpktÚkeyr8r±rur3rêÚargumentÚ
commit_shar´Úchunks`             rPrzUploadArchiveHandler.handleZsãøð	Hð	Hð	Hð	Hð	Hð	Ø:×*Ò*Ñ,Ô,ð	2ð	2CØ99 T¨1Ñ-Ô-LS%ØkÒ!Ð!Ý&Ð';¸cÑ'AÑBÔBÐBØ×ÒU\\¨%Ñ0Ô0Ñ1Ô1Ð1Ð1ØØØ
Ø!%¤Ô!7Ø#i..Ò Ð Ø  |HØ;Ò&Ð&ØQØ" 1Ø[Ò(Ð(ØQØ" 1×,Ò,¨WÑ5Ô5à!Y^¨HÔ5
ØU :Ô.Ô3Ô4Ø
FAð#i..Ò Ð ð	

×!Ò! &Ñ)Ô)Ð)Ø
×!Ò! $Ñ'Ô'Ð'ÝØ4ty{{°6À&ð
ñ
ô
ð	ð	Eð
E%LLLLØ
×!Ò! $Ñ'Ô'Ð'Ð'Ð'rQrrx)rRrSrTrprrrs@rPrªrªUsQøð5ð5ð5ð5ð5ð5ð5ð (ð (ð (ð (ð (ð (ð (rQrª)sgit-upload-packsgit-receive-packsgit-upload-archivecóeZdZddZdZdS)ÚTCPGitRequestHandlerr[NcóH||_tjj|g|¢Ri|¤dSri)ÚhandlersÚsocketserverÚStreamRequestHandlerrp)rNr¿r¼rÐs    rPrpzTCPGitRequestHandler.__init__s3Ø 
ÝÔ)Ô2°4ÐI¸$ÐIÐIÐIÀ&ÐIÐIÐIÐIÐIrQcót|jj|jj¦«}| ¦«\}}t d||¦«|j 	|d¦«}t|¦«std|z¦«||jj
||¦«}| ¦«dS)NzHandling %s request, args=%szInvalid service %s)r:Ú
connectionr}ÚwfilerÅÚread_cmdrrr©r¿ríÚcallablerÚserverrr)rNrrèr¼rrs      rPrzTCPGitRequestHandler.handles¨Ý" 4¤?Ô#7¸¼Ô9IÑJÔJØÑ(Ô(
ÝÐ2°G¸TÑBÔBÐBàm×Ò ¨Ñ.Ô.Ý}}ð	CÝ"Ð#7¸'Ñ#AÑBÔBÐBØCÔ# T¨5Ñ1Ô1Ø	




rQrx)rRrSrTrprrVrQrPr½r½s;ðJðJðJðJð	ð	ð	ð	ð	rQr½cóJeZdZdZejjZdZe	dfddZ
dZdZdS)	ÚTCPGitServerTcó,t|jg|¢Ri|¤Sri)r½r¿)rNr¼rÐs   rPÚ
_make_handlerzTCPGitServer._make_handlers"Ý# D¤MÐC°DÐCÐCÐC¸FÐCÐCÐCrQNr[cótt¦«|_||j |¦«||_t
 d||¦«tj 	|||f|j
¦«dS)Nz&Listening for TCP connections on %s:%d)rvÚDEFAULT_HANDLERSr¿r¨rrrr©rÀÚ	TCPServerrprË)rNrÚlisten_addrÚportr¿s     rPrpzTCPGitServer.__init__suÝÕ-Ñ.Ô.
ØÐØM× Ò  Ñ*Ô*Ð*ØÝÐ<¸kÈ4ÑPÔPÐPÝÔ×'Ò'¨¨{¸DÐ.AÀ4ÔCUÑVÔVÐVÐVÐVrQcó<t d|¦«dS)NzHandling request from %sT)rrr©©rNÚrequestÚclient_addresss   rPÚverify_requestzTCPGitServer.verify_request¥sÝÐ.°Ñ?Ô?Ð?ØtrQcó<t d|¦«dS)Nz7Exception happened during processing of request from %s)rrÚ	exceptionrÒs   rPÚhandle_errorzTCPGitServer.handle_error©s*Ý×ÒØHØñ	
ô	
ð	
ð	
ð	
rQrx)
rRrSrTÚallow_reuse_addressrÀrÎÚ
serve_foreverÚserverËr7rprÕrØrVrQrPrÉrÉszØÐØÔ"Ô0EðDðDðDð3?ÈðWðWðWðWðWðððð
ð
ð
ð
ð
rQrÉcóÂddl}| ¦«}| ddddd¬¦«| d	d
dttd¬
¦«| |¦«\}}t
j¦«t|¦«dkr	|d}nd}t|¦«}t||j|j¦«}| 
¦«dS)z*Entry point for starting a TCP git server.rNz-lz--listen_addressÚlisten_addressÚ	localhostzBinding IP address.)ÚdestÚdefaultÚhelpz-pz--portrÐzBinding TCP port.)rßÚtyperàrárú.)ÚoptparseÚOptionParserÚ
add_optionrär7Ú
parse_argsrÚdefault_logging_configr×r{rÉrÝrÐrÚ)ÚargvräÚparserÚoptionsr¼ÚgitdirrrÇs        rPÚmainrí°sûàOOOà
×
"Ò
"Ñ
$Ô
$FØ
×ÒØØØ
ØØ
"ðñôðð×ÒØØØ
Ý
ÝØ
 ð
ñôðð×%Ò% dÑ+Ô+MGTå
Ô$Ñ&Ô&Ð&Ý
4yy1}}Øaàå Ñ'Ô'GÝ
' 7Ô#9¸7¼<Ñ
HÔ
HFØ
×ÒÑÔÐÐÐrQcó®|t¦«}fd}t|j|¦«}|||dd|¦«}| ¦«dS)aöServe a single command.

    This is mostly useful for the implementation of commands used by e.g.
    git+ssh.

    Args:
      handler_cls: `Handler` class to use for the request
      argv: execv-style command-line arguments. Defaults to sys.argv.
      backend: `Backend` to use
      inf: File-like object to read from, defaults to standard input.
      outf: File-like object to write to, defaults to standard output.
    Returns: Exit code for use with sys.exit. 0 on success, 1 on failure.
    NcóZ |¦« ¦«dSri)rÅr)ÚdataÚoutfs rPÚsend_fnzserve_command.<locals>.send_fnäs&øØ

4ÑÔÐØ

rQrr)r{r
rr)Úhandler_clsrérÚinfrñròrrs    `   rPÚ
serve_commandrõÑsqøð Ý#Ñ%Ô%ðððððõ
SXwÑ'Ô'EØk' 4¨¨¨¤8¨UÑ3Ô3GàNNÑÔÐØ1rQcóT| ¦«}t||j¦«S)zGenerate an info refs file.)r_rFrY)r·rZs  rPÚgenerate_info_refsr÷ïs"à==??DÝ4 Ô!2Ñ3Ô3Ð3rQc#ótK|jjD](}dtj|jj¦«zdzV)dS)z Generate an index for for packs.sP rßN)rYÚpacksrÚfsencoderðÚfilename)r·Úpacks  rPÚgenerate_objects_info_packsrýõsQèèàÔ!Ô'ð@ð@Ør{ 4¤9Ô#5Ñ6Ô6Ñ6¸Ñ>Ð?Ð?Ð?Ð?ð@ð@rQcóX| tj dd¦«d t	|¦«¦«¦«| tj ddd¦«d t|¦«¦«¦«dS)zGenerate server info for dumb file access.

    This generates info/refs and objects/info/packs,
    similar to "git update-server-info".
    r©rZrQÚobjectsrùN)Ú_put_named_filerrOrr÷rý)r·s rPÚupdate_server_inforûsð	×ÒÝ
VVÑ$Ô$ c§h¢hÕ/AÀ$Ñ/GÔ/GÑ&HÔ&Hñôðð	×ÒÝ
Y ¨Ñ0Ô0ØÕ,¨TÑ2Ô2Ñ3Ô3ñôðððrQÚ__main__)}rUrrrÚsysrµÚ	functoolsrÚtypingrrrrrr	r
ÚTypingProtocolÚImportErrorÚtyping_extensionsrÀrÚdulwichrÚarchiver
ÚerrorsrrrrrrrrYrrÿrrrrürrrÚprotocolrrrrr r!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1r2r3r4r5r6r7r8r9r:r;r<r=r>r?r@rArBrCrZrDrErFr·rGrHÚ	getLoggerrRrrrJrXrmr{rrr´rérrrrÔrdrXrVrWryrªrÍrÁr½rÎrÉréríÚstdinÚstdoutrõr÷rýrrVrQrPú<module>rsaðð,ðð.ÐÐÐØ				Ø



Ø



ØØÐÐÐÐÐØ=Ð=Ð=Ð=Ð=Ð=Ð=Ð=Ð=Ð=Ð=Ð=Ð=Ð=Ð=Ð=ð=Ø1Ð1Ð1Ð1Ð1Ð1Ð1øØð=ð=ð=Ø<Ð<Ð<Ð<Ð<Ð<Ð<Ð<ð=øøøðÐÐÐØàÐÐÐÐÐàÐÐÐÐÐððððððððððððððððððð#Ð"Ð"Ð"Ð"Ð"Ø3Ð3Ð3Ð3Ð3Ð3Ð3Ð3Ð3Ð3ØSÐSÐSÐSÐSÐSÐSÐSÐSÐSð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ð*ðVDÐCÐCÐCÐCÐCÐCÐCÐCÐCØ Ð Ð Ð Ð Ð Ð Ð à	Ô	XÑ	&Ô	&ð8ð8ð8ð8ð8ñ8ô8ð8ð'"ð'"ð'"ð'"ð'".ñ'"ô'"ð'"ðT
ð
ð
ð
ð
'ñ
ô
ð
ð ððððñôðð"	/ð	/ð	/ð	/ð	/ñ	/ô	/ð	/ð6#ð6#ð6#ð6#ð6#'ñ6#ô6#ð6#ðrI(ðI(ðI(ðI(ðI(ñI(ôI(ðI(ðX(Kð(Kð(KðV& ð& ð& ð& ð& ðR?ððððð. ððððð.U2ðU2ðU2ðU2ðU2ñU2ôU2ðU2ðp'¨°dÐ;Ðð)ð)ð)ð)ð)ñ)ô)ð)ðX8ð8ð8ð8ð8ñ8ô8ð8ðv>ð>ð>ð>ð>ñ>ô>ð>ðBe(ðe(ðe(ðe(ðe(ñe(ôe(ðe(ðP%(ð%(ð%(ð%(ð%(7ñ%(ô%(ð%(ðT*Ø+Ø/ððÐððððð<Ô<ñôðð"
ð
ð
ð
ð
<Ô)ñ
ô
ð
ð4hðððððDh¨°#´)À#Ä*ð
ð
ð
ð
ð<4ð4ð4ð@ð@ð@ð
ð
ð
ð zÒÐØDFFFFFðÐs®5µAÁA
odigos / odigos-demo-inventory deb

Products

About

Resources

Contact Gemfury
