&p % d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ d dlm Z m
Z
m Z e
Z d dl
Z
d dlmZ n!# e$ r d dlmZmZ e ZddZY nw xY we j Ze j Zej Zej j Zej Z ej Z ej j Z ej j Z ej Z ej j! Z!ej j" Z"ej j# Z#ej$ Z$ej% Z%ej& Z&ej' Z'd Z(d Z)d d l*m+Z+m,Z, G d
d Z-d Z.d dZ/d Z0d dZ1d dZ2ddZ3d Z4d Z5 G d d Z6 G d d Z7dS ) N)BytesIO)StaticWindowMapManagerSlidingWindowMapManagerSlidingWindowMapBuffer) unpack_from)unpackcalcsizec t | }n)# t $ r t | }|t | < Y nw xY wt | ||||z S N)__calcsize_cacheKeyErrorr r )fmtdataoffsetsizes \/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib/python3.11/site-packages/gitdb/util.pyr r ! sj )#C(DD ) ) )C==D$( S ! ! ! ) c4
56777s
#66c t j dk rHt d D ]0} | |i |c S # t $ r t j d Y -w xY w | |i |S | |i |S )Nwin32
g?)sysplatformrange Exceptiontimesleep)funcargskwargs_s r _retryr D s |w r A
tT,V,,,,,
3
tT$V$$$tT$V$$$s - A
Ac 6 t t j g| R i |S r )r osremove)r r s r r# r# R s" ") -d - - -f - -- ) NULL_BIN_SHA NULL_HEX_SHAc 6 e Zd ZdZdZd
dZd Zd Zd Zd Z d S ) _RandomAccessBytesIOzWrapper to provide required functionality in case memory maps cannot or may
not be used. This is only really required in python 2.4_sio c . t | | _ d S r )r r) )selfbufs r __init__z _RandomAccessBytesIO.__init__g s CLL r$ c , t | j | S r )getattrr) r, attrs r __getattr__z _RandomAccessBytesIO.__getattr__j s ty$'''r$ c D t | S r )lengetvaluer, s r __len__z _RandomAccessBytesIO.__len__m s 4==??###r$ c 6 | | S r r6 )r, is r __getitem__z _RandomAccessBytesIO.__getitem__p s }}q!!r$ c : | || S r r: )r, startends r __getslice__z!_RandomAccessBytesIO.__getslice__s s }}uSy))r$ N)r* )
__name__
__module__ __qualname____doc__ __slots__r. r3 r8 r< r@ r$ r r( r( a ss ? ?I! ! ! !( ( ($ $ $" " "* * * * *r$ r( c F t | S # t $ r | cY S w xY w)z
Return the integer representation of the byte string. This supports Python
3 byte arrays as well as standard strings.
)ord TypeError)bs r byte_ordrK w s6
1vv
s r$ c t j | S # t $ r ddl}| | }|cY S w xY w)z`A python2.4 workaround for the sha/hashlib module fiasco
**Note** From the dulwich project r N)hashlibsha1 NameErrorsha)sourcerP rN s r make_sharR sS |F###
wwv s %>>c | dk rt d S t j d| S # t $ r t d| z cY S w xY w)zB:return: a file-protocol accessible memory block of the given sizer r$ )r( mmapOSError)r s r allocate_memoryrX se qyy#C(((2yT""" 2 2 2
$EDL11111 2s , A
A FTc | |rj t j | dt j S # t $ r; t j | t j | j t j cY S w xY wn# t $ r Y nw xY wt j | t j | j }|rt | S |S )a :return: read-only contents of the file represented by the file descriptor fd
:param fd: file descriptor opened for reading
:param stream: if False, random access is provided, otherwise the stream interface
is provided.
:param allow_mmap: if True, its allowed to map the contents into memory, which
allows large files to be handled and accessed efficiently. The file-descriptor
will change its position if this is Falser )access)rV ACCESS_READrW r" fstatst_sizereadr( )fdstream
allow_mmapcontentss r file_contents_rorc s
T
TyQt/?@@@@
T
T
TyRXb\\%9$BRSSSSSS
T T
wr28B<</00H
.#H--- Os- A/ & AA+(A/ *A++A/ /
A<;A<c t j | t j t t dd z |z } t ||| t | S # t | w xY w)a< Get the file contents at filepath as fast as possible
:return: random access compatible memory of the given filepath
:param stream: see ``file_contents_ro``
:param allow_mmap: see ``file_contents_ro``
:param flags: additional flags to pass to os.open
:raise OSError: If the file could not be opened
**Note** for now we don't try to use O_NOATIME directly as the right value needs to be
shared per database in fact. It only makes a real difference for loose object
databases anyway, and they use it with the help of the ``flags`` parameterO_BINARYr )r" openO_RDONLYr0 rc close)filepathr` ra flagsr_ s r file_contents_ro_filepathrk s^
2;Z)C)CCeK L LB FJ77
b b s A A,c T t t | | S )z
:return: a buffer compatible object which uses our mapped memory manager internally
ready to read the whole given filepath)rj )r mman make_cursor)ri rj s r sliding_ro_bufferro s% "$"2"28"<"))r$ Fc | j t d| j z || _ t t dd }t j t j z t j z |z } t j | |t dd }|st j
| n|| _ n7# t $ r*}t d| z |d}~ww xY w| j U t j | j
t j |z | _ n'# t | xY w|rddlm} || j S | j S ) a
Open the file descriptor for reading or writing, both in binary mode.
:param write: if True, the file descriptor will be opened for writing. Other
wise it will be opened read-only.
:param stream: if True, the file descriptor will be wrapped into a simple stream
object which supports only reading or writing
:return: fd to read from or write to. It is still maintained by this instance
and must not be closed directly
:raise IOError: if the lock could not be retrieved
:raise OSError: If the actual file could not be opened for reading
**note** must only be called onceNzCalled %s multiple timesre r 600 z Lock at %r could not be obtained)FDStream)r AssertionErrorrf r0 r" O_WRONLYO_CREATO_EXCLr intrh r rW r rg r# gitdb.streamr )r, writer` binarylockmoder_ er s r rf z
LockedFD.open, sp ; " !;di!GHH H Z++;+bi7&@ \++--xUA GGB
\ \ \2;3GHH
t))++,,, - - - - - -8DH%% %8Os% &AB; ;
C/%C**C/:,D' '$E c 2 | d dS )zWhen done writing, call this function to commit your changes into the
actual file.
The file descriptor will be closed, and the lockfile handled.
**Note** can be called multiple timesT
successfulN _end_writingr7 s r commitzLockedFD.commita s!
T*****r$ c 2 | d dS )zAbort your operation without any changes. The file descriptor will be
closed, and the lock released.
**Note** can be called multiple timesFr Nr r7 s r r zLockedFD.rollbacki s!
U+++++r$ Tc | j t d | j dS t j | j d| _ | }| j ry|rwt j dk r(t | j rt | j t j || j t | j t dd dS t | dS )z,Handle the lock according to the write mode Nz-Cannot end operation if it wasn't started yetr 644r )r r r r" rh r r r isfiler r# renamechmodr )r, r lockfiles r r zLockedFD._end_writingp s ; !PQQ Q 8 F
%%'' ; : |w&&$.)) +4>***
Ih / / /
$.#eQ-- 0 0 0 0 0
8 r$ N)FF)T) rA rB rC rD rE r. r r rf r r r rF r$ r r r
s B B /I
* * *2 2 2 2 j+ + +, , , r$ r )r )r$ )FT)FTr )8binasciir" rV r r errnoior smmapr r r rm rM structr ImportErrorr r dictr a2b_hexrw b2a_hexrr ENOENTpathexistsmkdirr isdirr r dirnamebasenamejoinr^ r rh fsyncr r# gitdb.constr% r& r( rK rR rX rc rk ro rt rx rz r rF r$ r r s
8""""""" 8 8 8''''''''tvv8 8 8 8 8 8 8"
'/
7 w| w
% % % . . .
* * * * * * * *,
2
2
2" : (K K K K
@~ ~ ~ ~ ~ ~ ~ ~ ~ ~ s ? A A