|>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