{SrSSKJr SSKrSSKrSSKrSSKJrJr SSK J r SSK J r SSK JrJrJrJrJrJrJrJrJrJrJr SSKJrJrJrJrJrJrJ r J!r!J"r"J#r#J$r$J%r%J&r&J'r' SS K(J)r) S r*S r+"S S \,5r-"SS\-5r."SS\.5r/"SS\-5r0"SS\,5r1"SS\15r2Sr3Sr4S%Sjr5"SS\,5r6"SS\,5r7Sr8"S S!\-5r9S"r:"S#S$\.5r;g)&z/Git object store interfaces and implementation.BytesION) tree_changes walk_trees) NotTreeError)GitFile) CommitShaFileTagTreeZERO_SHA hex_to_sha sha_to_hexhex_to_filename S_ISGITLINK object_class valid_hexsha)PackPackData PackInflaterPackFileDisappearedload_pack_index_file iter_sha1pack_objects_to_datawrite_pack_headerwrite_pack_index_v2write_pack_datawrite_pack_objectcompute_file_sha PackIndexerPackStreamCopier)ANNOTATED_TAG_SUFFIXinfopackc\rSrSrSrSrSrSrSrSr \ S5r S r S r S rS rSSjrSSjrSSjrSSjrS S S SS 4SjrSrSSjrS SjrSr\"5\"5S4SjrSrSrg )!BaseObjectStoreIzObject store interface.cUR5VVs/sH6up#X0;dM UR[5(aM(U[:XaM4UPM8 snn$s snnfN)itemsendswithr"r )selfrefsrefshas 'lib/third_party/dulwich/object_store.pydetermine_wants_all#BaseObjectStore.determine_wants_allLsX#jjl *  LL!56 8O *   s AAA Ac[X5$)zsIterate over the objects for the specified shas. Args: shas: Iterable object with SHAs Returns: Object iterator )ObjectStoreIterator)r,shass r0 iter_shasBaseObjectStore.iter_shasUs#4..c,[UR5ez=Check if a particular object is present by SHA1 and is loose.)NotImplementedErrorcontains_looser,r/s r0r<BaseObjectStore.contains_loose^s!$"5"566r8c,[UR5e)>Check if a particular object is present by SHA1 and is packed.)r;contains_packedr=s r0rABaseObjectStore.contains_packedbs!$"6"677r8cTURU5=(d URU5$)uCheck if a particular object is present by SHA1. This method makes no distinction between loose and packed objects. )rAr<r=s r0 __contains__BaseObjectStore.__contains__fs% ##C(DD,?,?,DDr8c[e)zIterable of pack objects.r;r,s r0packsBaseObjectStore.packsms "!r8c,[UR5ez|Obtain the raw text for an object. Args: name: sha for the object. Returns: tuple with numeric type and object contents. )r;get_rawr,names r0rNBaseObjectStore.get_rawrs"$,,//r8cRURU5up#[R"X#US9$)zObtain an object by SHA1.r/)rNr from_raw_string)r,r/type_numuncomps r0 __getitem__BaseObjectStore.__getitem__{s&<<,&&xSAAr8c,[UR5e5Iterate over the SHAs that are present in this store.)r;__iter__rIs r0r\BaseObjectStore.__iter__s!$--00r8c,[UR5e))Add a single object to this object store.)r; add_objectr,objs r0r`BaseObjectStore.add_objects!$//22r8Nc,[UR5e)kAdd a set of objects to this object store. Args: objects: Iterable over a list of (object, path) tuples )r; add_objectsr,objectsprogresss r0rfBaseObjectStore.add_objectss "$"2"233r8cUS:XagUR5upEn[UUUUURS9 U"5$![a U"5 ef=f)z{Add pack data to this object store. Args: num_items: Number of items to add pack_data: Iterator over pack data tuples rNcompression_level)add_packrpack_compression_level BaseException)r,count pack_datarifcommitaborts r0 add_pack_dataBaseObjectStore.add_pack_datasb A: ==?5  "&"="=  8O   G  s :A c #B# [UUUUUUUS9HnURRURR4URRURR4URR URR 44v M g7f)aFind the differences between the contents of two trees Args: source: SHA1 of the source tree target: SHA1 of the target tree want_unchanged: Whether unchanged files should be reported include_trees: Whether to include trees change_type_same: Whether to report files changing type in the same entry. Returns: Iterator over tuples with (oldpath, newpath), (oldmode, newmode), (oldsha, newsha) )want_unchanged include_treeschange_type_samerename_detectorN)roldpathnewmoder/)r,sourcetargetryrzr{r|changes r0rBaseObjectStore.tree_changess*#   )'-+ F&**//2&**//20  sBBc## [XS5HDup4URb%[R"UR5(a U(dM@Uv MF g7f)aIterate the contents of a tree and all subtrees. Iteration is depth-first pre-order, as in e.g. os.walk. Args: tree_id: SHA1 of the tree. include_trees: If True, include tree objects in the iteration. Returns: Iterator over TreeEntry namedtuples for all the objects in a tree. N)rrstatS_ISDIR)r,tree_idrzentry_s r0iter_tree_contents"BaseObjectStore.iter_tree_contentss@#4$7HE &t||EJJ/G/G 8s A A AcUR$r)parentsrts r0BaseObjectStore.6>>r8c L[UUUUUUUS9n[URS5$)aFind the missing objects required for a set of revisions. Args: haves: Iterable over SHAs already in common. wants: Iterable over SHAs of objects to fetch. shallow: Set of shallow commit SHA1s to skip progress: Simple progress function that will be called with updated progress strings. get_tagged: Function that returns a dict of pointed-to sha -> tag sha for including tags. get_parents: Optional function for getting the parents of a commit. Returns: Iterator over (sha, path) pairs. ) get_parentsN)MissingObjectFinderiternext) r,haveswantsshallowri get_taggedrdepthfinders r0find_missing_objects$BaseObjectStore.find_missing_objectss60%      # FKK&&r8c/n[U5nU(a;X0;a"URU5 URU5 [U5nU(aM;U$)zFind which revisions this store has in common using graphwalker. Args: graphwalker: A graphwalker object. Returns: List of SHAs that are in common )rappendack)r, graphwalkerrr/s r0find_common_revisions%BaseObjectStore.find_common_revisionssK;{ S!${#C c  r8cHURXX45nURU5$)zIterate over the contents of a pack file. Args: have: List of SHA1s of objects that should not be sent want: List of SHA1s of objects that should be sent shallow: Set of shallow commit SHA1s to skip progress: Optional progress reporting method )rr6)r,havewantrrimissings r0generate_pack_contents&BaseObjectStore.generate_pack_contentss%++DJ~~g&&r8c8[URXX455$)a8Generate pack data objects for a set of wants/haves. Args: have: List of SHA1s of objects that should not be sent want: List of SHA1s of objects that should be sent shallow: Set of shallow commit SHA1s to skip ofs_delta: Whether OFS deltas can be included progress: Optional progress reporting method )rr)r,rrrri ofs_deltas r0generate_pack_data"BaseObjectStore.generate_pack_datas!$  ' 'G F  r8cXn[UR5nU[LaURup1XnU[LaMU$)zPeel all tags from a SHA. Args: sha: The object SHA to peel. Returns: The fully-peeled SHA1 of a tag object, after peeling all intermediate tags; if the original ref does not point to a tag, this will equal the original SHA1. )r type_namer object)r,r/rb obj_classs r0peel_shaBaseObjectStore.peel_sha.sDi / 3 ZZNI)C3 r8cUR$r)rrs r0rrCrr8c6[5n[5n/nURU5 U(aiURS5nX;aURU5 O8X;a3URU5 X;aMLXn URU"U 55 U(aMiXe4$)aCollect all ancestors of heads up to (excluding) those in common. Args: heads: commits to start from common: commits to end at, or empty set to walk repository completely get_parents: Optional function for getting the parents of a commit. Returns: a tuple (A, B) where A - all commits reachable from heads but not present in common, B - common (shared) elements that are directly reachable from heads r)setextendpopadd) r,headscommonrrbasescommitsqueueecmts r0_collect_ancestors"BaseObjectStore._collect_ancestors>s&% U ! A{ ! ! A<g [-.er8cg)z,Close any files opened by this object store.NrIs r0closeBaseObjectStore.closeasr8rr))FFFNF)NN)NNT)__name__ __module__ __qualname____firstlineno____doc__r1r6r<rArEpropertyrJrNrWr\r`rfrvrrrrrrrrrr__static_attributes__rr8r0r&r&Is! /78E""0B 134:"H*1!'F 'BF "&u1 ! F;r8r&c\rSrSrSSjr\S5rSrSrSr Sr Sr S r S r \S 5rS rS rSrSrSrSrSrSrSrSrSSjrSrg)PackBasedObjectStoreifc0UlXlgr) _pack_cachero)r,ros r0__init__PackBasedObjectStore.__init__gs&<#r8c/$r)rrIs r0 alternatesPackBasedObjectStore.alternatesks r8c\URH nX;a gM g![a Mf=f)z`Check if a particular object is present by SHA1 and is packed. This does not check alternates. TF)rJr)r,r/r$s r0rA$PackBasedObjectStore.contains_packedos= JJD ; '  s  ++cURU5(dURU5(agURH nX;dM g g)rDTF)rAr<r)r,r/ alternates r0rE!PackBasedObjectStore.__contains__|sD    $ $(;(;C(@(@I)r8cURRU5nX2La'X RU'U(aUR5 ggg)z/Add a newly appeared pack to the cache by path.N)rgetr)r, base_namer$ prev_packs r0_add_cached_pack%PackBasedObjectStore._add_cached_packsC$$((3  *.  Y '! !r8cURn0UlU(a,UR5up#UR5 U(aM+ggr))rpopitemr)r, pack_cacherPr$s r0_clear_cached_packs(PackBasedObjectStore._clear_cached_packss8%% %--/LT JJLjr8c6URR5$r))rvaluesrIs r0_iter_cached_packs'PackBasedObjectStore._iter_cached_packss&&((r8c,[UR5er))r;_update_pack_cacherIs r0r'PackBasedObjectStore._update_pack_caches!$"9"9::r8c$UR5 gr))rrIs r0rPackBasedObjectStore.closes   "r8ch[UR55[UR55-$zList with pack objects.)listrrrIs r0rJPackBasedObjectStore.packss+D++-.d6M6M6O1PPPr8c#L# URHnUHnUv M M g7f)z=Iterate over the SHAs of all the objects in alternate stores.N)r)r,ralternate_objects r0_iter_alternate_objects,PackBasedObjectStore._iter_alternate_objectss$I$- &&%.)s"$c,[UR5ez+Iterate over the SHAs of all loose objects.)r;_iter_loose_objectsrIs r0r(PackBasedObjectStore._iter_loose_objectss!$":":;;r8c,[UR5er))r;_get_loose_objectr=s r0r&PackBasedObjectStore._get_loose_objects!$"8"899r8c,[UR5er))r;_remove_loose_objectr=s r0r)PackBasedObjectStore._remove_loose_objects!$";";<.PackBasedObjectStore.repack..sE2D3;2Ds)rrrrrJrPr*update iterobjectsrfrrr r rr) r, loose_objectsr/rbrhp old_packsrPr$ consolidateds r0repackPackBasedObjectStore.repacks  ++-C   d44S9 :.*78-3;-8*.**5*QVVXq[* 5#//+JD NNE$2B2B2DE E,''0  l'')40 C  % %cff -!#//+JD   d #, !7|#95s  E#Ec## UR5 UR5HnUHnUv M M UR5HnUv M UR 5HnUv M g![a MYf=f7f)r[N)rrrrr)r,r$r/s r0r\PackBasedObjectStore.__iter__s} !++-D CI . ++-CI.//1CI2 '  s'$B A/;B/ A=9B<A==Bc(URU5SL$)z_Check if a particular object is present by SHA1 and is loose. This does not check alternates. N)rr=s r0r<#PackBasedObjectStore.contains_looses %%c*$66r8cU[:Xa [U5e[U5S:Xa[U5nUnO#[U5S:XaUnSnO[ SU<35eUR 5HnUR U5s $ Uc [U5nURU5nUbURUR54$UR5HnUR U5s $ URHnUR U5s $ [U5e![[4a Mf=f![a Mmf=f![a MYf=f)zObtain the raw fulltext for an object. Args: name: sha for the object. Returns: tuple with numeric type and object contents. (NzInvalid object name )r KeyErrorrrAssertionErrorrrNrrrrU as_raw_stringrr)r,rPr/hexshar$retrs r0rNPackBasedObjectStore.get_rawsT 8 4. t9?T"CF Y"_CF T!CD D++-D ||C((. >%F$$V, ?<<!2!2!44 4++-D ||C((. I  ((00) v'12       s6*DD-6D>D*)D*- D;:D;> E  E Nc8UR"[U5SU06$)zAdd a set of objects to this object store. Args: objects: Iterable over (object, path) tuples, should support __len__. Returns: Pack object of the objects written. ri)rvrrgs r0rf PackBasedObjectStore.add_objectss !!#7#@T8TTr8r)r))rrrrrrrrArErrrrrrJrrrrr rrr\r<rNrfrrr8r0rrfs=  ");#QQ' <:=5 8 7'RUr8rc^\rSrSrSrSU4SjjrSr\S5r\ S5r Sr Sr S r S rS rS rS rSrSrSrSrSrSrSr\S5rSrU=r$)DiskObjectStorei*z+Git-style object store that exists on disk.c>[[U] US9 Xl[RR UR[ 5UlSUlX l X0l g)zOpen an object store. Args: path: Path of the object store. loose_compression_level: zlib compression level for loose objects pack_compression_level: zlib compression level for pack objects )roN) superr/rr~osjoinPACKDIRpack_dir _alternatesloose_compression_levelro)r,r~r7ro __class__s r0rDiskObjectStore.__init__-sQ ot-#9 .   TYY8 '>$&<#r8cTSURR<SUR<S3$)N<(z)>)r8rr~rIs r0__repr__DiskObjectStore.__repr__>s!^^44dii@@r8c|[URSS5R55n[URSS5R55n[URSS5R55nU"XU5$![a SnNkf=f![a UnNSf=f![a UnN;f=f)N)scores compressionr-slooseCompressionpackCompression)intrdecoder%)clsr~configdefault_compression_levelr7ros r0 from_configDiskObjectStore.from_configAs +(+ :~6==?) %  @&) :':;BBD' #  ?%( :'89@@B& " 42HII +(* % +  @&? # @  ?%> " ?s4)B)B)B, BB B)(B), B;:B;cURb UR$/UlUR5H'nURR[U55 M) UR$r))r6_read_alternate_pathsrr/)r,r~s r0rDiskObjectStore.alternatesWsZ    '## #..0D    # #OD$9 :1r8c #|# [[RRUR[S5S5nU UR 5HnURS5nURS5(aM,[RRU5(a[R"U5v Mj[R"[RR[R"UR5U55v M SSS5 g![ a gf=f!,(df  g=f7f)Nrrb #) rr2r~r3INFODIRFileNotFoundError readlinesrstrip startswithisabsfsdecodefsencode)r,rslines r0rI%DiskObjectStore._read_alternate_paths`s  TYYFMA {{5)??4((77==&&++d++++bggll2;;tyy3I4&PQQ&Q!    Qs?D<9DD<CD+ D< D(%D<'D((D<+ D95D<c:[R"[RRUR[55 [RRUR[S5n[ US5n[US5nU URUR55 SSS5 UR[R"U5S-5 SSS5 [RRU5(d*[RRURU5nURR[U55 g![ a GN#f=f!,(df  N=f![a Nf=f!,(df  N=f)z+Add an alternate path to this object store.rwbrLNrM)r2mkdirr~r3rOFileExistsErrorropenwritereadrPrVrTrrr/)r,r~alternates_pathrsorig_fs r0add_alternate_path"DiskObjectStore.add_alternate_pathos  HHRWW\\$))W5 6'',,tyy'<H _d +q +ot4GGFKKM* GGBKK%- .,ww}}T""77<< 40D t45   V%  , +sZAE?F  E< F  E+/0F  E('E(+ E9 5F < F F F  F  Fc[R"UR5n[ 5nUHnUR S5(dMURS5(dM3[RRU5SS-nXA;dM_US[S5*nURU5 M /nUHfnXpR;dM[RURU55nURU5 XRU'Mh [ UR5U- H,nURR!U5R 5 M. U$![a UR 5 /s$f=f)z4Read and iterate over new pack files and cache them.pack-.packr.idxN)r2listdirr5rPrrrSr+r~splitextrrrrr3rr) r,pack_dir_contents pack_filesrPidx_name pack_name new_packsrsr$s r0r"DiskObjectStore._update_pack_cachesB  " 4== 9 U %Dw''DMM',B,B77++D1!4v=0 $_G } 5INN9-& A(((BGGLL:;  &&*  #  T%%&3A     # ) ) +4/!  JJLI s E))FFc.[URU5$r))rr~r=s r0_get_shafile_path!DiskObjectStore._get_shafile_pathstyy#..r8c#b# [R"UR5Hn[U5S:waM[R"[RR URU55H1n[R "X-5n[ U5(dM-Uv M3 M g7f)N)r2rhr~rr3rVr)r,baserestr/s r0r#DiskObjectStore._iter_loose_objectsstJJtyy)D4yA~ 277<< 4#@Akk$+.#C(( B*sB-B/crURU5n[R"U5$![a gf=fr))rqr from_pathrPr,r/r~s r0r!DiskObjectStore._get_loose_objects:%%c* $$T* *   s ) 66cN[R"URU55 gr))r2removerqr=s r0r$DiskObjectStore._remove_loose_objects $((-.r8cVUR[RRUR5 UR 5 [R"URR5 [R"URR5 g![ a Nqf=fr)) rr2r~basename _basenamer%rr}dataindex)r,r$s r0r DiskObjectStore._remove_packso   !1!1$..!AB  $))..! $**//"    s4B B('B(c[SU55nURS5n[RR UR SU-5$)Nc3*# UH oSv M g7frNrrrs r0r5DiskObjectStore._get_pack_basepath..s98asciire)rrBr2r~r3r5)r,entriessuffixs r0_get_pack_basepath"DiskObjectStore._get_pack_basepaths>999w'ww||DMM7V+;<        .) ,,. nj9!%      s'G>#H> H  H H c$SSKnURURSS9upE[R"US5n[ X`R S9n[XXgS9nUR5 URXeX5sSSS5 $!,(df  g=f)aAdd a new thin pack to this object store. Thin packs are packs that contain deltas with parents that exist outside the pack. They should never be placed in the object store directly, and always indexed and completed as they are copied. Args: read_all: Read function that blocks until the number of requested bytes are read. read_some: Read function that returns at least one byte, but may not return the number of bytes requested. Returns: A Pack object pointing at the now-completed thin pack in the objects/pack directory. rN tmp_pack_)dirprefixzw+bresolve_ext_ref delta_iter) tempfilemkstempr~r2fdopenr rNr!verifyr) r,read_all read_somerfdr~rsrrs r0 add_thin_packDiskObjectStore.add_thin_packsq ## +#F YYr5 !Q!!\\BG%h1QF MMO++AVE " ! !s ?B Bc[U5nUR5nURU5nUS-n[RR U5(d/[ US5n[XcUR55 SSS5 SSS5 URHnURW:XdMUs $ WS-n[RS:Xa[R"U5 [R"X5 [!U5n UR#XI5 U $!,(df  N=f!,(df  N=f![a Nbf=f)zMove a specific file containing a pack into the pack directory. Note: The file should be on the same file system as the packs directory. Args: path: Path to the pack file. rgrZNrfr)rsorted_entriesrr2r~existsrrget_stored_checksumrJrrrr}rPrrr) r,r~rrr index_namersr$rrs r0 move_in_packDiskObjectStore.move_in_pack's d^q&&(G..w7H!F*J77>>*--Z.!'A4I4I4KL/ JJD~~) ( <<7 "  +& $$(^  h3!/. ^ %  s6AD*#D>D*D; D' #D** D8; EEc^^^^SSKnURTRSS9umm[R"TS5mUUUU4SjnUU4SjnTX#4$)Add a new pack to this object store. Returns: Fileobject to write to, a commit function to call when the pack is finished and an abort function. rNrf)rrrZc>TR5 [R"T5 TR5 [RR T5S:aTR T5$[R"T5 gNr)rr2fsyncrr~getsizerr})rsrr~r,sr0rt(DiskObjectStore.add_pack..commitSsT GGI HHRL GGIwwt$q(((.. $r8cR>TR5 [R"T5 gr))rr2r})rsr~sr0ru'DiskObjectStore.add_pack..abort]s GGI IIdOr8)rrr5r2r)r,rrtrursrr~s` @@@r0rnDiskObjectStore.add_packGsQ ## g#FD IIb$    &r8cURUR5n[RR U5n[R "U5 [RRU5(ag[US5nURURURS95 SSS5 g![ a Nof=f!,(df  g=f)zFAdd a single object to this object store. Args: obj: Object to add NrZrl) rqr r2r~dirnamer[r\rrr^as_legacy_objectr7)r,rbr~rrss r0r`DiskObjectStore.add_objectcs %%cff-ggood#  HHSM 77>>$    T4 A GG$$t7S7S$T !    ! sB5)C5 CC Cc8[R"U5 [R"[RR US55 [R"[RR U[ 55 U"U5$![a Nf=f)Nr#)r2r[r\r~r3r4)rCr~s r0initDiskObjectStore.initvsh  HHTN dF+, dG,-4y    sB BB)r6r7ror5r~)r-r-)rrrrrrr= classmethodrFrrrIrbrrqrrrr rrrrrnr`rr __classcell__r8s@r0r/r/*s5="AJJ*   R6*://#= ENF0@ 8&r8r/c^\rSrSrSrU4SjrSrSrSrSr \ S5r S r S r S rS rSS jrSrSrSrSrU=r$)MemoryObjectStoreiz.Object store that keeps all objects in memory.cF>[[U] 5 0UlSUlg)Nr-)r1rr_dataro)r,r8s r0rMemoryObjectStore.__init__s  /1 &(#r8cv[U5S:XaU$[U5S:Xa [U5$[SU<35e)Nr#r$z Invalid sha )rr ValueErrorr=s r0 _to_hexshaMemoryObjectStore._to_hexshas5 s8r>J X^c? "67 7r8c>URU5UR;$r:)rrr=s r0r< MemoryObjectStore.contains_loosess#tzz11r8cg)r@Frr=s r0rA!MemoryObjectStore.contains_packedsr8cH[URR55$rZ)rrkeysrIs r0r\MemoryObjectStore.__iter__sDJJOO%&&r8c/$rrrIs r0rJMemoryObjectStore.packss  r8c`XRU5nURUR54$rM)rrUr')r,rPrbs r0rNMemoryObjectStore.get_raws-??4()||S..000r8cZURURU5R5$r))rrcopyrOs r0rWMemoryObjectStore.__getitem__s#zz$//$/05577r8c<URURU5 g)z3Delete an object from this store, for testing only.N)rrrOs r0 __delitem__MemoryObjectStore.__delitem__s JJtt, -r8cRUR5URUR'g)r_N)rrr ras r0r`MemoryObjectStore.add_objects XXZ 366r8c<UHup4URU5 M g)reN)r`)r,rhrirbr~s r0rfMemoryObjectStore.add_objectss !IC OOC !r8c6^^[5mUU4SjnSnTX4$)zAdd a new pack to this object store. Because this object store doesn't support packs, we extract and add the individual objects. Returns: Fileobject to write to and a commit function to call when the pack is finished. c>[R"[TR55TR 55nTR 5 [ R"UTR5HnTRU5 M gr)) r from_filergetvaluerrr for_pack_datarNr`)rrbrsr,s r0rt*MemoryObjectStore.add_pack..commitsW""71::<#8!&&(CA GGI#11!T\\B$Cr8cgr)rrr8r0ru)MemoryObjectStore.add_pack..aborts r8r)r,rtrurss` @r0rnMemoryObjectStore.add_packs# I %  &r8cz[U5nURS5 [U[U5[UR 55-5 [ USS9nUR 5H1n[U5S:XdeUR U5upg[XXtS9 M3 UR5nURU5 g)zComplete a thin pack by adding external references. Args: f: Open file object for the pack. indexer: A PackIndexer for indexing the pack. rrrr$rSN) rrrrrrrNrrr^) r,rsrrrrrUrrs r0r%MemoryObjectStore._complete_thin_packsw- q !S\C0@0@0B,CCD#1c2'')Gw<2% %%!\\'2NH a4 =*>># r8cUR5up4n[X0RS9n[XX6S9nUR 5 UR X65 U"5 g![ a U"5 ef=f)aAdd a new thin pack to this object store. Thin packs are packs that contain deltas with parents that exist outside the pack. Because this object store doesn't support packs, we extract and add the individual objects. Args: read_all: Read function that blocks until the number of requested bytes are read. read_some: Read function that returns at least one byte, but may not return the number of bytes requested. rrN)rnr rNr!rrrp)r,rrrsrtrurrs r0rMemoryObjectStore.add_thin_packsj ==?5 !!\\BG%h1QF MMO  $ $Q 0 H   G  s >AA.)rror))rrrrrrrr<rAr\rrJrNrWrr`rfrnrrrrrs@r0rrs`8) 82'18.(! ,0r8rc\rSrSrSrSrSrg)ObjectIteratoriz%Interface for iterating over objects.c,[UR5er))r;rrIs r0rObjectIterator.iterobjects s!$"2"233r8rN)rrrrrrrrr8r0rrs /4r8rcT\rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rg)r4iz3ObjectIterator that works on top of an ObjectStore.c*XlX l/Ulg)zxCreate a new ObjectIterator. Args: store: Object store to retrieve from sha_iter: Iterator over (sha, path) tuples N)storesha_iter_shas)r,r r s r0rObjectStoreIterator.__init__s   r8c#d# UR5HupURUU4v M g7f)z&Yield tuple with next object and path.N)itershasr rzs r0r\ObjectStoreIterator.__iter__s*IC**S/4' ')s.0c#*# UH upUv M g7f)zIterate over just the objects.Nr)r,or~s r0rObjectStoreIterator.iterobjects"sGAGrc## URHnUv M URH"nURRU5 Uv M$ g7f)zIterate over the SHAs.N)r r rr=s r0rObjectStoreIterator.itershas's=::CI==C JJ  c "I!sA A c4U[:XagXR;$)zCheck if an object is present. Note: This checks if the object is present in the underlying object store, not if it would be yielded by the iterator. Args: needle: SHA1 of the object to check for F)r r )r,needles r0rE ObjectStoreIterator.__contains__/s X ##r8c URU$)zFind an object by SHA1. Note: This retrieves the object from the underlying object store. It will also succeed if the object would not be returned by the iterator. )r )r,keys r0rWObjectStoreIterator.__getitem__=szz#r8cF[[UR555$)zReturn the number of objects.)rrrrIs r0__len__ObjectStoreIterator.__len__Fs4 ())r8cVSSKnURS[5 UR5$)NrzUse bool() instead.)warningswarnDeprecationWarning_empty)r,r s r0emptyObjectStoreIterator.emptyJs! +-?@{{}r8c\UR5n[U5 g![a gf=f)NFT)rr StopIteration)r,its r0r#ObjectStoreIterator._emptyPs2 ]]_  H  s  ++c,UR5(+$)z*Indicate whether this object has contents.)r#rIs r0__bool__ObjectStoreIterator.__bool__Ys;;=  r8)r r r N)rrrrrrr\rrrErWrr$r#r+rrr8r0r4r4s7= (   $* !r8r4ctU"U5n[U[5(d [U5eURX5$)zLook up an object in a Git tree. Args: lookup_obj: Callback for retrieving object by SHA1 root_sha: SHA1 of the root tree path: Path to lookup Returns: A tuple of (mode, SHA) of the resulting path. ) isinstancer r lookup_path) lookup_objroot_shar~trees r0tree_lookup_pathr3^s7 h D dD ! !8$$   J --r8cXnUR5HYupEn[U5(aMXb;dMURU5 [R"U5(dMM[ XU5 M[ g)zCollect SHA1s of files and directories for specified tree. Args: obj_store: Object store to get objects by SHA from tree_sha: tree reference to walk kset: set to fill with references to files and directories N) iteritemsrrrr_collect_filetree_revs) obj_storetree_shaksetfiletreerPrr/s r0r6r6msV"H#--/C4  S_ HHSM||D!!&yt< 0r8c[5n[5n[5nUHnXn[U[5(aURU5 M0[U[5(a<URU5 UR Sn[ X/US9upnX9-nXJ-nXW-nMURU5 M X4U4$![a U(deMf=f)aSplit object id list into three lists with commit, tag, and other SHAs. Commits referenced by tags are included into commits list as well. Only SHA1s known in this repository will get through, and unless ignore_unknown argument is True, KeyError is thrown for SHA1 missing in the repository Args: obj_store: Object store to get objects by SHA1 from lst: Collection of commit and tag SHAs ignore_unknown: True to skip SHA1 missing in the repository silently. Returns: A tuple of (commits, tags, others) SHA1s )ignore_unknown)rr.r rr r_split_commits_and_tagsr%) r7lstr=rtagsothersrrtaggedcts r0r>r>}seG 5D UF   A !V$$ AAs## !1xa    1 '( 6 ""# !" sB;;CCc<\rSrSrSrSSSS4SjrSrSr\rSr g) riaFind the objects missing from another object store. Args: object_store: Object store containing at least all objects to be sent haves: SHA1s of commits not to send (already present in target) wants: SHA1s of commits to send progress: Optional function to report progress to. get_tagged: Function that returns a dict of pointed-to sha -> tag sha for including tags. get_parents: Optional function for getting the parents of a commit. tagged: dict of pointed-to sha -> tag sha for including tags NcUR$r)rrs r0rMissingObjectFinder.rr8cXlUc [5nXpl[XS5upn [XS5upn UR XURS9SnUR U UUURS9unn[5UlUHDnUR R U5 UUn[UURUR 5 MF U HnUR R U5 M U RU 5nU RU 5nURU5nURU5n[UVs/sHnUSS4PM sn5Ul Uc SUl OXPl U=(a U"5=(d 0Ul gs snf)NTF)rrrcgr)r)xs r0r.MissingObjectFinder.__init__..sdr8) object_storer _get_parentsr>rsha_donerr6r2 differenceunionobjects_to_sendri_tagged)r,rLrrrrirr have_commits have_tags have_others want_commits want_tags want_others all_ancestorsmissing_commitscommon_commitshrrD missing_tagsmissing_othersws r0rMissingObjectFinder.__init__s) ?eG' 0G 0 , 0G 0 ,  %77 t7H7H8  +7*I*I  )) +J+ '   A MM  a q/C "<4== I A MM  a !++I6 $// < %%l3 N+"e#DeQe$4e#DE  *DM$M!2jl8b $Es>F cURRUVs/sHo"SUR;dMUPM sn5 gs snfr)rQrrN)r,rrs r0add_todoMissingObjectFinder.add_todos5 ##$U1tt}}?TQ$UV$Us AAc UR(dgURR5upnXR;aOMAU(dURUn[ U[ 5(a UR URSS4/5 O[ U[5(aeUR UR5VVVs/sH5upVn[U5(aMXu[R"U5(+4PM7 snnn5 O7[ U[5(a"UR URSSS4/5 XR;a"UR URUSS4/5 URR!U5 UR#S[%UR5-R'S55 X4$s snnnf)NTFr<zcounting objects: %d r)rQrrNrLr.r rbr2r r5rrrr rrRrrirencode)r,r/rPleafrnmss r0rMissingObjectFinder.nextsl'' $ 4 4 8 8 : S--'  !!#&A!V$$ E234At$$ (){{}'4GA!*1~44<<?23'4As##  T59:; ,,  MMDLL-tT:; < # /#dmm2DDLLWUV{s G !G )rMrRrLrQrirN) rrrrrrrbr__next__rrr8r0rrs. &1A9FW6Hr8rc2\rSrSrSrSSjrSrSr\rSr g) ObjectStoreGraphWalkerizGraph walker that finds what commits are missing from an object store. :ivar heads: Revisions without descendants in the local repo :ivar get_parents: Function to retrieve parents in the local repo Ncd[U5UlX l0UlUc [5nX0lg)zCreate a new instance. Args: local_heads: Heads to start search with get_parents: Function for finding the parents of a SHA1. N)rrrrr)r, local_headsrrs r0rObjectStoreGraphWalker.__init__ s.% & ?eG r8c[U5S:wa[SU-5e[U/5nUR(aUH/nX0R;dMURR U5 M1 [5nUHAnUR R U5nUbURU5 SUR U'MC U(dgUnUR(aMgg)z@Ack that a revision and its ancestors are present in the source.r#zunexpected sha %r receivedN)rrrrr}rrr)r,r/ ancestorsa new_ancestorspss r0rObjectStoreGraphWalker.ack.s s8r>9C?@ @J jj ?JJ%%a(  EM\\%%a(>!((,"& Q !%I#jjjr8c UR(axURR5nURU5nX RU'URR UVs/sHo3UR;dMUPM sn5 U$gs snf)z.Iterate over ancestors of heads in the target.N)rrrrr)r,r)rvrs r0rObjectStoreGraphWalker.nextHsm ::**.."C!!#&B "LL  JJ  "F"Q0Eq"F GJGs $B ;B )rrrrr)) rrrrrrrrrlrrr8r0rnrns &4Hr8rnc0nUH>upEnURSS5upxURU/5RXU45 M@ UR 5HMupXU Sn [X U 5n [U 5S:XaX M/[RU R4X'MO URU5 U$![a UcX MXV4X'Mf=f![ a [ 5n Nf=f)aCommit a specified set of changes to a tree structure. This will apply a set of changes on top of an existing tree, storing new objects in object_store. changes are a list of tuples with (path, mode, object_sha). Paths can be both blobs and trees. See the mode and object sha to None deletes the path. This method works especially well if there are only a small number of changes to a big tree. For a large number of changes to a large tree, use e.g. commit_tree. Args: object_store: Object store to store new objects in and retrieve old ones from. tree: Original tree root changes: changes to apply Returns: New tree root object /r<r) split setdefaultrrr*r%r commit_tree_changesrrS_IFDIRr r`) rLr2changesnested_changesr~new_moderrsubpathrP subchanges orig_subtreesubtrees r0r~r~Us.N%,! X!%D!!4 W  % %gr 2 9 97g:V W&-+002 "'T 1 6L&l*M w<1  ,, 3DJ3D! K% 1J&0  1 "6L "s)B; C;C CCC0/C0cZ\rSrSrSrS SjrSrS Sjr\S5r Sr S r S r S r S rg)OverlayObjectStoreiz5Object store that can overlay multiple object stores.NcXlX lgr))r add_store)r,rrs r0rOverlayObjectStore.__init__s  "r8c|URc[UR5eURRU5$r))rr;r`)r,rs r0r`OverlayObjectStore.add_objects0 >> !%doo6 6~~((00r8c|URc[UR5eURRX5$r))rr;r`rfrgs r0rfOverlayObjectStore.add_objectss0 >> !%doo6 6~~))'<TR5S:XaTR5 gTRS5 [TRT5nUR 5n[ SU55RS5nT R5nUR5n[X1U5 URS5 [US-U5nT RHInUR5UR5:XdM'UR5 UR5 Us $ TRS5 URS5 T RUTU5 [R"X5nT R!X'5 U$)Nrc3*# UH oSv M g7frrrs r0rBBucketBasedObjectStore.add_pack..commit..s ?weqwrrrg)rrrrrPrrrBSpooledTemporaryFilerrrrJrr from_objectsr) rrridxfchecksumidxr$rpfr,rs r0rt/BucketBasedObjectStore.add_pack..commits/wwyA~  GGAJ"%A&&(G ?w ??FFwOH002D,,.H x 8 IIaL&x&'8$?C ++-1F1F1HHGGIIIKK # GGAJ IIaL   hD 1**12J  ! !( 7 r8)rrr)r,rtrrs` @@r0rnBucketBasedObjectStore.add_packs.   * * , 46288##r8rN)rrrrrrrrr rrrrrnrrr8r0rrs4 592 "%$r8rr)rrnr~rrrrr8r0rs .6 !     .  Y;fY;zAU?AUHT*Tn DDN4V4L!.L!^ . = &#Rp&pf9V9x-`22j O$1O$r8