§
Z¶<½d’oã ó„ — d Z ddlmZ ddlmZmZ ddlmZmZ ddl m
Z
m Z ddl m
Z
mZ ddlmZ dZ G d „ d
ee¦ « Zd S ) z*Contains the MemoryDatabase implementationé )Ú
LooseObjectDB)Ú ObjectDBRÚ ObjectDBW)ÚOStreamÚIStream)Ú BadObjectÚUnsupportedOperation)ÚZippedStoreShaWriterÚDecompressMemMapReader)ÚBytesIO)ÚMemoryDBc óR ‡ — e Zd ZdZˆ fd„Zd„ Zd„ Zd„ Zd„ Zd„ Z d„ Z
d „ Z d
„ Z ˆ xZ
S ) r
a/ A memory database stores everything to memory, providing fast IO and object
retrieval. It should be used to buffer results and obtain SHAs before writing
it to the actual physical storage, as it allows to query whether object already
exists in the target storage before introducing actual IOc ó– •— t ¦ « ¦ « t d¦ « | _ t ¦ « | _ d S )Nzpath/doesnt/matter)ÚsuperÚ__init__r Ú_dbÚdictÚ_cache)ÚselfÚ __class__s €ú^/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib/python3.11/site-packages/gitdb/db/mem.pyr zMemoryDB.__init__' s: ø€ Ý
‰Œ×ÒÑÔÐÝ Ð!5Ñ6Ô6ˆŒõ ‘f”fˆŒ ˆ ˆ ó c ó — t d¦ « ‚)Nz$MemoryDB's always stream into memory)r )r Ústreams r Ú set_ostreamzMemoryDB.set_ostream. s € Ý"Ð#IÑJÔJÐJr c ó~ — t ¦ « }| j |¦ « | j |¦ « }| ¦ « | d¦ « t
| ¦ « d¬¦ « }t |j |j
|j |¦ « | j |j < |S )Nr F)Úclose_on_deletion)
r
r r ÚstoreÚcloseÚseekr Úgetvaluer ÚbinshaÚtypeÚsizer )r ÚistreamÚzstreamÚ
decomp_streams r r zMemoryDB.store1 s› € Ý&Ñ(Ô(ˆØ Œ× Ò ˜WÑ%Ô%Ð%à”(—.’. Ñ)Ô)ˆØ
Š
‰ŒˆØ Š Q‰Œˆõ /¨w×/?Ò/?Ñ/AÔ/AÐUZÐ[Ñ[Ô[ˆ
Ý&-¨g¬n¸g¼lÈGÌLÐZgÑ&hÔ&hˆŒ G”NÑ#àˆr c ó — || j v S ©N)r ©r Úshas r Ú
has_objectzMemoryDB.has_object@ s € Ød”kÐ!Ð!r c ó, — | |¦ « S r) )r r* s r Úinfoz
MemoryDB.infoC s € à{Š{˜3Ñ Ô Ð r c óš — | j | }|j d¦ « |S # t $ r}t |¦ « |‚d }~ww xY w)Nr )r r r ÚKeyErrorr )r r+ ÚostreamÚes r r zMemoryDB.streamG s[ € ð (Ø”k #Ô&ˆGà ŒN× Ò Ñ "Ô "Ð "؈NøÝð (ð (ð (ݘC‘.”. aÐ 'øøøøð (øøøs ‚(+ «
A
µAÁA
c ó* — t | j ¦ « S r) )Úlenr ©r s r r$ z
MemoryDB.sizeQ s € Ý4”;Ñ Ô Ð r c ó4 — | j ¦ « S r) )r Úkeysr5 s r Úsha_iterzMemoryDB.sha_iterT s € ØŒ{× Ò Ñ!Ô!Ð!r c ó" — d}|D ]‰}| |¦ « rŒ| |¦ « }t |j ¦ « ¦ « }t |j |j ||¦ « }| |¦ « |dz
}ŒŠ|S )ar Copy the streams as identified by sha's yielded by sha_iter into the given odb
The streams will be copied directly
**Note:** the object will only be written if it did not exist in the target db
:return: amount of streams actually copied into odb. If smaller than the amount
of input shas, one or more objects did already exist in odbr é )r, r r Údatar r# r$ r )r r8 ÚodbÚcountr+ r1 Úsior% s r Ú stream_copyzMemoryDB.stream_copyX s– € ð ˆØð ð ˆCØ~Š~˜cÑ"Ô"ð
Øð —k’k #Ñ&Ô&ˆGå˜'œ.×-Ò-Ñ/Ô/Ñ0Ô0ˆCÝ ˜gœl¨G¬L¸#¸sÑCÔCˆGà IŠIgÑ Ô Ð Ø Q‰JˆEˆEàˆ r )Ú__name__Ú
__module__Ú __qualname__Ú__doc__r r r r, r. r r$ r8 r? Ú
__classcell__)r s @r r
r
s¿ ø€ € € € € ðAð Að
ð ð ð ð ðKð Kð Kð
ð
ð
ð "ð "ð "ð ð ð ð(ð (ð (ð ð ð ð"ð "ð "ðð ð ð ð ð ð r r
N)rC Úgitdb.db.looser Ú
gitdb.db.baser r Ú
gitdb.baser r Ú gitdb.excr r Ú gitdb.streamr
r Úior Ú__all__r
© r r úrM s ðð
1Ð 0Ø (Ð (Ð (Ð (Ð (Ð (ðð ð ð ð ð ð ð ð
ð ð ð ð ð ð ð ð
ð ð ð ð ð ð ð ð
ð ð ð ð ð ð ð ð
Ð Ð Ð Ð Ð à
€ðMð Mð Mð Mð Mˆy˜)ñ Mô Mð Mð Mð Mr