o hu@s~dZddlmZmZmZddlmZddlmZm Z m Z ddl m Z ddl mZddlZddlZdZGd d d eeeeZdS) z/Module containing a database to deal with packs) FileDBBase ObjectDBR CachingDB) LazyMixin) BadObjectUnsupportedOperationAmbiguousObjectName) PackEntity)reduceN)PackedDBcseZdZdZdZfddZddZddZd d Zd d Z d dZ ddZ ddZ ddZ ddZdddZddZddZZS)r z-A database operating on a set of object packsicst|d|_d|_dSNr)super__init__ _hit_count _st_mtime)self root_path __class__A/var/www/vscode/kcb/lib/python3.10/site-packages/gitdb/db/pack.pyr)s  zPackedDB.__init__cCs$|dkrt|_|jdddSdS)N _entitiesT)force)listr update_cache)rattrrrr _set_cache_3szPackedDB._set_cache_cCs|jjdddddS)NcSs|dSr r)lrrr:z)PackedDB._sort_entities..T)keyreverse)rsortrrrr_sort_entities9szPackedDB._sort_entitiescCsn|j|jdkr ||jD]#}|d|}|dur2|dd7<|jd7_|d|fSqt|)a:return: tuple(entity, index) for an item at the given sha :param sha: 20 or 40 byte sha :raise BadObject: **Note:** This method is not thread-safe, but may be hit in multi-threaded operation. The worst thing that can happen though is a counter that was not incremented, or the list being in wrong order. So we safe the time for locking here, lets see how that goesrN)r_sort_intervalr$rr)rshaitemindexrrr _pack_info<s    zPackedDB._pack_infocCs&z||WdStyYdSw)NTF)r+r)rr(rrr has_objectYs   zPackedDB.has_objectcC||\}}||SN)r+ info_at_indexrr(entityr*rrrinfoa z PackedDB.infocCr-r.)r+stream_at_indexr0rrrstreamer3zPackedDB.streamccs>|D]}|}|j}t|D]}||VqqdSr.)entitiesr*r(rangesize)rr1r* sha_by_indexrrrsha_iteris  zPackedDB.sha_itercCs dd|jD}tdd|dS)NcSsg|] }|dqSr&)r*r8.0r)rrr sz!PackedDB.size..cSs||Sr.r)xyrrrrtrzPackedDB.size..r)rr )rsizesrrrr8rsz PackedDB.sizecCst)zStoring individual objects is not feasible as a pack is designed to hold multiple objects. Writing or rewriting packs for single objects is inefficient)r)ristreamrrrstorezszPackedDB.storeFc Cst|}|s|j|jkrdS|j|_tttj|d}dd|j D}||D]}t |}|j | ||jgq/||D]&}d}t|j D]\}} | d |kre|}nqS|dkslJ|j |=qJ|dS)a Update our cache with the actually existing packs on disk. Add new ones, and remove deleted ones. We keep the unchanged ones :param force: If True, the cache will be updated even though the directory does not appear to have changed according to its modification timestamp. :return: True if the packs have been updated so there is new information, False if there was no change to the pack databaseFz pack-*.packcSsh|] }|dqSr;)packpathr<rrr r?z(PackedDB.update_cache..r&T)osstatrst_mtimersetglobrFjoinrr appendrEr8r* sha_to_index enumerater$) rrrJ pack_filesour_pack_files pack_filer1 del_indexir)rrrrs(  "   zPackedDB.update_cachecCsdd|jDS)z=:return: list of pack entities operated upon by this databasecSsg|]}|dqSr;rr<rrrr>sz%PackedDB.entities..)rr#rrrr6szPackedDB.entitiescCsfd}|jD]%}|d||}|dur*|d|}|r(||kr(t||}q|r/|St|)a:return: 20 byte sha as inferred by the given partial binary sha :param partial_binsha: binary sha with less than 20 bytes :param canonical_length: length of the corresponding canonical representation. It is required as binary sha's cannot display whether the original hex sha had an odd or even number of characters :raise AmbiguousObjectName: :raise BadObject: Nr&)rr*partial_sha_to_indexr(rr)rpartial_binshacanonical_length candidater) item_indexr(rrrpartial_to_complete_shas  z PackedDB.partial_to_complete_sha)F)__name__ __module__ __qualname____doc__r'rrr$r+r,r2r5r:r8rDrr6r\ __classcell__rrrrr s     -r )r` gitdb.db.baserrr gitdb.utilr gitdb.excrrr gitdb.packr functoolsr rIrM__all__r rrrrs