]ji j d Z ddlZddlmZ ddlmZ n# e$ r ddlmZ Y nw xY w G d d ZdS )z<For internal use only. It provides a slice-like file reader. N)Union)Lockc e Zd ZdZdeddfdZdeeef fdZ de
d edefd
Z defd Z dd Z
eed
r dedede
fdZdS dedede
fdZdS )
FileBufferzA slice-able file readerdatabasereturnNc t |d | _ t j | j j | _ t t d st | _ d S d S )Nrbpread)
open_handleosfstatfilenost_size_sizehasattrr _lock)selfr s n/builddir/build/BUILD/imunify360-venv-2.6.3/opt/imunify360/venv/lib/python3.11/site-packages/maxminddb/file.py__init__zFileBuffer.__init__ s` Hd++ Xdl 1 1 3 344<
r7## DJJJ keyc t |t r(| |j |j z
|j S t |t
r | d| d S t
d )N r zInvalid argument type.)
isinstanceslice_readstopstartint TypeError)r r s r __getitem__zFileBuffer.__getitem__ sm c5 ! ! ?::ch 2CI>> > c3 )::a%%a( (0111r needler c | | j |z
dz
| | }|dk r|S ||z S )z Reverse find needle from startr )r r rfind)r r$ r poss r r' zFileBuffer.rfind sG jje+a/77==fEE "99Js{r c | j S )z Size of file)r r s r sizezFileBuffer.size% s
zr c 8 | j dS )z
Close fileN)r
closer* s r r- zFileBuffer.close) s r r
buffersizeoffsetc \ t j | j || S )zread that uses pread)r r r
r r r. r/ s r r zFileBuffer._read/ s& 8DL / / 1 1:vFF Fr c | j 5 | j | | j | cddd S # 1 swxY w Y dS )a read with a lock
This lock is necessary as after a fork, the different processes
will share the same file table entry, even if we dup the fd, and
as such the same offsets. There does not appear to be a way to
duplicate the file table entry and we cannot re-open based on the
original path as that file may have replaced with another or
unlinked.
N)r r
seekreadr1 s r r zFileBuffer._read6 s
5
5 !!&)))|((44
5
5
5
5
5
5
5
5
5
5
5
5
5
5
5
5
5
5s 4A A
A
)r N)__name__
__module__ __qualname____doc__strr r r r! r# bytesr' r+ r- r r r r r r r
s3 "" 2uUCZ 0 2 2 2 2E # # c wr7 5 GC G G G G G G G G 5C 5 5 5 5 5 5 5 5r r ) r8 r typingr multiprocessingr ImportError threadingr r; r r <module>r@ s B B $$$$$$$ 55 55 55 55 55 55 55 55 55 55s ##