KP, j d Z ddlZddlmZ ddlmZ n# e$ r ddlmZ Y nw xY w G d d ZdS )z> > 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 r@ s B B $$$$$$$ 55 55 55 55 55 55 55 55 55 55s ##