cj?4 d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Zd dl
Z
d dl Z d dl m
Z
d dlZg dZe j" j% d Z G d d Z G d de Z G d d
e Z G d d e Z G d
de Z G d de Z G d de Z G d de Z G d dej6 j8 Z G d de Z G d de Z G d d e Z G d d e Z G d d e Z! G d! d"e Z" G d# d$ Z# G d% d&e# Z$d7d'Z%d( Z&d) Z'd* Z(d+ Z)d, Z* G d- d.e+ Z, G d/ d0e, Z- G d1 d2e, Z. G d3 d4e, Z/ G d5 d6e, Z0y# e$ r dZY Aw xY w)8 N) GenericAlias)MailboxMaildirmboxMHBabylMMDFMessageMaildirMessage mboxMessage MHMessage BabylMessage MMDFMessageErrorNoSuchMailboxError
NotEmptyErrorExternalClashError FormatErrorasciic e Zd Z d"dZd Zd Zd Zd Zd Zd#dZ d Z
d
Z d Z d Z
d
Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd#dZd Zd#dZd Z d Z d Z d Z d Z d Z!d$d!Z" e#e$ Z%y)%r Nc t j j t j j | | _ || _ y N)ospathabspath
expanduser_path_factoryselfr factorycreates /usr/lib64/python3.12/mailbox.py__init__zMailbox.__init__% s/ ,WW__RWW%7%7%=>
c t d Nz&Method must be implemented by subclassNotImplementedErrorr messages r# addz Mailbox.add* s 2!"JKKr% c t d r' r( r keys r# removezMailbox.remove. s K!"JKKr% c & | j | y r )r0 r. s r# __delitem__zMailbox.__delitem__2 s Cr% c H | j | y # t $ r Y y w xY wr )r0 KeyErrorr. s r# discardzMailbox.discard5 s( 5 KK s !!c t d r' r( r r/ r+ s r# __setitem__zMailbox.__setitem__< s L!"JKKr% c J | j | S # t $ r |cY S w xY wr ) __getitem__r4 )r r/ defaults r# getz Mailbox.get@ s/ G ##C( ( N s ""c | j s| j | S t j | j | 5 }| j | cd d d S # 1 sw Y y xY wr )r get_message
contextlibclosingget_file)r r/ files r# r: zMailbox.__getitem__G sN K}}##C( (##DMM#$674}}T* 877s A A'c t d r' r( r. s r# r> zMailbox.get_messageO s B!"JKKr% c h t j | j | j S r emailmessage_from_bytes get_bytes as_stringr. s r#
get_stringzMailbox.get_stringS s, * ''s(;<FFHHr% c t d r' r( r. s r# rH zMailbox.get_bytesZ s F!"JKKr% c t d r' r( r. s r# rA zMailbox.get_file^ s D!"JKKr% c t d r' r( r s r# iterkeyszMailbox.iterkeysb s +!"JKKr% c 6 t | j S r )listrO rN s r# keysz Mailbox.keysf s $DMMO$$r% c # j K | j D ] } | | }| y # t $ r Y w xY wwr rO r4 r r/ values r#
itervalueszMailbox.itervaluesj sA 3==?C
S K #
s 3$3 0303c " | j S r )rW rN s r# __iter__zMailbox.__iter__s s r% c 6 t | j S r )rQ rW rN s r# valueszMailbox.valuesv s :DOO%&&r% c # n K | j D ] } | | }||f y # t $ r Y w xY wwr rT rU s r# iteritemszMailbox.iteritemsz sF <==?C
S , #
s 5& 5 2525c 6 t | j S r )rQ r] rN s r# itemsz
Mailbox.items s GDNN$%%r% c t d r' r( r. s r# __contains__zMailbox.__contains__ s G!"JKKr% c t d r' r( rN s r# __len__zMailbox.__len__ s 8!"JKKr% c R | j D ] }| j | y r )rR r5 r. s r# clearz
Mailbox.clear s! "99;C LL r% c X | | }| j | |S # t $ r |cY S w xY wr )r4 r5 )r r/ r; results r# popz Mailbox.pop s< A #YF
S
N s ))c l | j D ] }|| j | fc S t d )NzNo messages in mailbox)rO rh r4 r. s r# popitemzMailbox.popitem s6 D==?C# ' ' # 34 4r% c t |d r|j }n t |d r|j }n|}d}|D ] \ }} || |<
|r t d y # t $ r d}Y )w xY w)Nr] r_ FTzNo message with key(s))hasattrr] r_ r4 )r argsourcebad_keyr/ r+ s r# updatezMailbox.update s B 3 $]]_F
S'
"YY[FF "LC
#S #
34 4
s A A,+A,c t d r' r( rN s r# flushz
Mailbox.flush s 4!"JKKr% c t d r' r( rN s r# lockz Mailbox.lock s !"JKKr% c t d r' r( rN s r# unlockzMailbox.unlock s 1!"JKKr% c t d r' r( rN s r# closez
Mailbox.close s *!"JKKr% c V |j d S # t $ r t d w xY w)Nr z?String input must be ASCII-only; use bytes or a Message instead)encode UnicodeError
ValueErrorr* s r# _string_to_byteszMailbox._string_to_bytes s7 2>>'* * 2 1 2
2 2s (Fc t |t j j rt j
}t j j ||d }|j | |j d |j }|j dt }|j | | j r,|j t s|j t y y y t |t t" t j$ f rt |t j$ r+t' j( dt* d |j- }t |t r| j/ | }|r|j dd }|j dt }|j | | j r,|j t s|j t y y y t1 |d rt1 |d r't' j( d t* d |j2 }d } |j5 }|j d
r |d d dz }n|j d r|d d
dz }|snE|r|j7 d rd|dd z }|j dt }|j | |}| j r/|r,|j t s|j t y y y y t9 dt; | z )Nr
8Use of StringIO input is deprecated, use BytesIO instead s
From s
>From readbufferDUse of text mode files is deprecated, use a binary mode file instead
From s >From Invalid message type: %s)
isinstancerF r+ r
ioBytesIO generatorBytesGeneratorflattenseekr replacelinesepwrite_append_newlineendswithstrbytesStringIOwarningswarnDeprecationWarninggetvaluer} rl r readline
startswith TypeErrortype) r r+ target mangle_from_r gendatalastlinelines r#
_dump_messagezMailbox._dump_message sw 3 gu}} 4 4 5ZZ\F//00 qIC KK KKN;;=D<<w/D LL ##DMM',B W% -C# #ubkk!:
;'2;;/
*+=qB!**,'3' //8!//*kB ooeW5G LL !##G,<, rJ rH rA rO rR rW rY r[ r] r_ ra rc re rh rj rp rr rt rv rx r} r r classmethodr __class_getitem__ r% r# r r " s 4
LLL+LILLL%!' &LL
55"LLLL2 O4Hl $L1r% r c e Zd Z dZd dZd Zd Zd Zd Zd Z d Z
d
Z d Z d Z
d
Zd Zd Zd Zd Zd Zd Zd Zd Zd ZdZd Zd Zd Zd Z y) r :Nc t j | ||| t j j | j
d t j j | j
d t j j | j
d d| _ t j j | j
sm|rVt j | j
d | j j D ] }t j |d nt | j
i | _ ddd| _ d| _
d| _ y ) Ntmpnewcur)r r r r )r r g?)r r$ r r joinr _pathsexistsmkdirr[ r _toc _toc_mtimes
_last_read _skewfactor)r dirnamer! r" r s r# r$ zMaildir.__init__ s ,w877<<
E277<<
E277<<
E2
ww~~djj)U+ KK . . 0DHHT5) 1 )44 #$Q/ r% c | j } | j || t | t |t r?|j }| j |j z }|| j k( rd}nd}d}t j j |j j | j d }t j j! | j" |||z }t |t rWt j$ |j t j j' |j |j) f t j* |j | t j
|j |S # t $ r1 |j t j
|j w xY w# t, t. f$ r$ t j0 |j | Y |S w xY w# t2 $ rP}t j
|j |j4 t4 j6 k( rt9 d|z d }~ww xY w)N r r z$Name clash with existing message: %s) _create_tmpr
BaseExceptionrx r r0 name _sync_closer r
get_subdircolonget_infor basenamesplitr r utimegetatimeget_datelinkAttributeErrorPermissionErrorrenameOSErrorerrnoEEXISTr )r r+ tmp_filesubdirsuffixuniqdestes r# r, z Maildir.add$ s 2##% w 1
H g~ . '')FZZ'"2"2"44F#FFww
.44TZZ@Cww||DJJv
> g~ . HHX]]gg&&x}}5w7G7G7IJ
L
)
t, (--( G NN IIhmm $ 0 #O4
/ (--.
/ IIhmm $ww%,,&()O+/*0 1 1
sB F G ? H :G /H H HH I, A I''I,c t j t j j | j | j | y r )r r0 r r r _lookupr. s r# r0 zMaildir.removeN s- K
"'',,tzz4<<+<=>r% c T | j | y # t t f$ r Y y w xY wr )r0 r4 FileNotFoundErrorr. s r# r5 zMaildir.discardR s. 5 KK +, s ''c | j | }| j | }| j | }t |t r|}n|}t j
j
| }| j |v r,| j |j | j d z }nd}| j | t j
j | j | } t j
j | j |||z }
t |t rCt j | t j
j | |j f t j | |
y )Nr r )r r, r r r r r r r r5 r r r r r r ) r r/ r+ old_subpathtemp_key temp_subpathdominant_subpathr r tmp_pathnew_paths r# r8 zMaildir.__setitem__Z s Lll3' 88G$||H- g~ . + + !12 ::) )ZZ"2"8"8"DR"HHFF S77<<
L977<<
FC&LA g~ . HHXgg&&x0'2B2B2DE
G
(H%r% c | j | }t t j j | j
| d 5 }| j r| j
| }n t | }d d d t j j | \ }}j | | j |v r-|j |j | j d |j t j j t j j | j
| |S # 1 sw Y xY w)Nrbr )r openr r r r r r r
set_subdirr set_infoset_dategetmtime)r r/ subpathfmsgr r s r# r> zMaildir.get_messageu s B,,s#
"'',,tzz73T
:a}}mmA&$Q' ;
ww}}W- v :: LLDJJ/3 4 RWW%%bggll4::w&GHI
;
:s *D??Ec t t j j | j | j | d 5 }|j
j t d cd d d S # 1 sw Y y xY w)Nr r ) r r r r r r r r r r r/ r s r# rH zMaildir.get_bytes sP @
"'',,tzz4<<+<=t
D668##GU3 E
D
Ds $A33A<c t t j j | j | j | d }t
| S )Nr )r r r r r r
_ProxyFiler s r# rA zMaildir.get_file s7 D djj$,,s*;
r% c ~ t j }t j t j j | j
d D ]h }t j j | j
d| }|t j j
| z
dkD sTt j | j y )Nr i@ )timer r r r r r r0 )r nowr r s r# cleanz
Maildir.clean sx (iikZZ TZZ ?@E77<<
E59DRWW%%d++f4 $ Ar% r c d t j }t j }d|v r|j dd }d|v r|j dd }t | dt |dz dz dt j d t j d
| }t
j j | j d | } t j | t! d |z # t $ r9 t xj dz
c_ t | cY S # t $ r Y nw xY wY Ow xY w)
N/z\057r z\072z.Mr g .APQr r z&Name clash prevented file creation: %s)r socket gethostnamer intr getpidr _countr r r statr _create_carefullyFileExistsErrorr )r r hostnamer r s r# r zMaildir._create_tmp s Kiik%%' (? ''W5H (? ''W5H$'Hc#'C-.@"))+$+NNH>ww||DJJt4 GGDM !!I!%"& ' ' ! NNa N
(.."
s6
C- -"D/
D D/ D)&D/(D))D/.D/c t j | j z
d| j z kD red}| j D ]Q }t j
j
| j | }|| j | kD rd}|| j |< S |sy i | _ | j D ] }| j | }t j | D ] }t j
j || }t j
j | rC|j | j d }t j
j || | j |< t j | _ y )N FTr )r r r r r r r r r r r r r r )r refreshr mtimer r pr s r# r zMaildir._refresh s, / 99; (1t/?/?+? ?G **((V)<=4++F33 "G+0 ( +
&&F;;v&DD)GGLLu-77==# {{4::.q1"$'',,vu"= $ * ' ))+r% c d t j j t j j | j | j
| r| j
| S | j | j
| S # t $ r Y +w xY w# t $ r t
d|z d w xY wNNo message with key: %s)r r r r r r r4 r r. s r# r zMaildir._lookup& s K ww~~bggll4::tyy~ FGyy~% H
F99S> !
F4s:; E Fs A"B 8B BBB/c t | d s| j | _ | t | j S # t $ r Y y t
$ r Y /w xY w)N
_onetime_keys)rl rO r7 next
StopIterationr4 rN s r# r8 z Maildir.next4 sX >t_-!% D
D!3!3 455
s = AAAr ) r r r r r$ r, r0 r5 r8 r> rH rA rO ra rc rr rt rv rx r r r r r r) r r r r8 r r% r# r r s ( E ((T?&6
4
% & F'0"&H F
r% r c r e Zd Z ddZd Zd Zd Zd Zd Zd Z d Z
d
Z d Z d Z
d
Zd Zd ZddZd Zy)_singlefileMailboxNc t j | ||| t | j d }|| _
d | _ d| _ d| _
d| _ d| _ d | _ y # t $ r}|j
t
j k( r.|rt | j d }nYt | j |j
t
j t
j fv rt | j d }n Y d }~d }~ww xY w)Nrb+zwb+r r F)r r$ r r r r ENOENTr EACCESEROFS_filer _next_key_pending
_pending_sync_locked _file_length)r r r! r" r r s r# r$ z_singlefileMailbox.__init__D s /tWf5 TZZ'A
" ! ww%,,& TZZ/A,TZZ88U\\5;; 77T* s A# # D,BD Dc | j | j | | j | j < | xj dz
c_ d| _ | j dz
S )Nr T)r _append_messager rB rD r* s r# r, z_singlefileMailbox.add[ sR 2 $($8$8$A $..! ! "~~!!r% c P | j | | j |= d| _ y r )r r rC r. s r# r0 z_singlefileMailbox.removee s# K S IIcN
r% c r | j | | j | | j |< d| _ y r )r rH r rC r7 s r# r8 z _singlefileMailbox.__setitem__k s0 L S --g6 #
r% c # v K | j | j j E d { y 7 wr )r r rR rN s r# rO z_singlefileMailbox.iterkeysq s& + 99>>###s /979c @ | j || j v S r )r r r. s r# ra z _singlefileMailbox.__contains__v s G dii r% c N | j t | j S r )r r r rN s r# rc z_singlefileMailbox.__len__{ s 8 499~ r% c X | j s t | j d| _ y y r )rE
_lock_filerA rN s r# rt z_singlefileMailbox.lock s$ || tzz " DL r% c X | j r t | j d| _ y y NF)rE _unlock_filerA rN s r# rv z_singlefileMailbox.unlock s$ 1 << $ DL r% c | j s)| j r t | j d| _ y | j j dd | j j }|| j k7 rt d| j |fz t | j } i }| j | t | j j D ] }| j | \ }}| j j | | j | |j } | j j t! d|| j j z
}|sn|j# | U||j f||< | j% | |j | _ t/ | | j j' t) j0 | j } t) j2 |j, | j4 t) j6 |j, | j8 | j: t) j@ |j, | j tE | j d | _ || _ d| _ d| _ | jF rtI | j d y y # |j' t) j* |j, xY w# t< t> f$ r Y w xY w# tB $ rL t) j* | j t) j@ |j, | j Y w xY w)NFr r/ z4Size of mailbox file changed (expected %i, found %i) r= )dotlock)%rC rD _sync_flushrA r tellrF r _create_temporaryr _pre_mailbox_hooksortedr rR _pre_message_hookr minr _post_message_hookrx r r0 r r r* chmodst_modechownst_uidst_gidr r r r, r rE rO )
r cur_lennew_filenew_tocr/ startstop new_startr infos
r# rr z_singlefileMailbox.flush s 0}}!! DJJ'%*"
1 **//# d'' '$ &?&*&7&7%A&B C
C %TZZ0 G " "8 , diinn ./ "iin t
&&&x0 $MMO !ZZ__S15
8I1I.K LF! NN6* !*8==? ; ''1 0 !)
D
H
wwtzz"
- HHX]]DKK = 1 IIhmmTZZ 0 $**e,
" << tzz5 1 / NN IIhmm $ ( 1 IIdjj ! IIhmmTZZ 0 1s2 ,DK* 55L +*L4 *2L L10L14AN N c y r r r r s r# rY z$_singlefileMailbox._pre_mailbox_hook :r% c y r r rk s r# r[ z$_singlefileMailbox._pre_message_hook s ;r% c y r r rk s r# r] z%_singlefileMailbox._post_message_hook rl r% c | j | j r| j | j j y # | j j w xY w# | j r| j | j j w # | j j w xY wxY wr )rr rE rv rA rx rN s r# rx z_singlefileMailbox.close s * # JJL
#<<KKM
"
"
#<<KKM
"
"s. A* A A'*C, B#C# B??Cc | j | j | | j | S y # t $ r t d|z d w xY wr4 )r
_generate_tocr4 r. s r# r z_singlefileMailbox._lookup s_ 5 99 ?
Jyy~%
J 83 >?TI
Js 1 A
c F | j j dd | j j }t | j dk( r'| j
s| j
| j | j | j | j | }| j | j | j j | j j | _
|S # t $ r | j j | w xY w)Nr r/ )rA r rW r r rC rY r[ _install_messager] r truncaterr rF )r r+ beforeoffsetss r# rH z"_singlefileMailbox._append_message s I
1 " tyy>Q t}}
" "4:: . " "4:: .++G4G # #DJJ /
JJOO - JJ ' s
8AC: :&D r r )r r r r$ r, r0 r8 rO ra rc rt rv rr rY r[ r] rx r rH r r% r# r; r; A sX !." $
! B2H #Jr% r; c 6 e Zd Z dZd ZddZddZddZd Zy) _mboxMMDFTc | j | \ }}| j j | | j j j t
d j
d }| j j || j j z
}| j |j t
d }|j | |j |dd |S )Nr% r r r ) r rA r r r r decoder rW _message_factory set_unixfromset_from)r r/ rf rg from_linestringr s r# r> z_mboxMMDF.get_message
s Bll3' t
JJ'')11'3?FFwO
(9!9:##FNN7E$BC # Yqr]#
r% c n t j | j || j | S )N)unixfromrE )r r/ from_s r# rJ z_mboxMMDF.get_string s3 A'' NN3 &((1 5 (A Br% c 2 | j | \ }}| j j | |s| j j | j j || j j z
}|j
t d S Nr )r rA r r r rW r r )r r/ r rf rg r s r# rH z_mboxMMDF.get_bytes sm All3' t
JJ !
(9!9:~~gu--r% c | j | \ }}| j j | |s| j j t | j | j j | S r )r rA r r _PartialFilerW )r r/ r rf rg s r# rA z_mboxMMDF.get_file& sX Dll3' t
JJ !DJJ
(94@@r% c L d }t |t r| j | }t |t r:|j d r)|j d }|dk7 r|d | }||dz d }n|}d}n|t |t r%|j j d }d|z }nGt |t j j r#|j }||j d }|8dt j t j j z }| j j# }| j j% |t& z | j) || j | j* | j j# }||fS )Nr r r r r% r s From MAILER-DAEMON )r r r} r r find_mboxMMDFMessageget_fromrz rF r+ r
get_unixfromr asctimegmtimerA rW r r r
_mangle_from_)r r+ r~ newlineauthorrf rg s r# rs z_mboxMMDF._install_message. sa ? gs #++G4G gu %'*<* rJ rH rA rs r r% r# rx rx s% "M B
.A r% rx c * e Zd Z dZdZddZd Zd Zy)r TNc L t | _ t j | ||| y r )r r{ rx r$ r s r# r$ z
mbox.__init__T ! ) + 4w7r% c 0 |j t y r r r rk s r# r] zmbox._post_message_hookY s : r% c g g }}d}| j j d | j j }| j j }|j d r`t | t | k r5|r"|j
|t t z
n|j
| |j
| d}nF|s6|r"|j
|t t z
n|j
| n|t k( rd}nd}t t t || | _ t | j | _ | j j | _
y )NFr Tr )rA r rW r r r r r dict enumeratezipr rB rF )r startsstopslast_was_emptyline_posr s r# rq zmbox._generate_toc] s >B
zz(H::&&(Dx(u:F +% XG %<=
X.
h'!&!LLCL!89LL* !%!&/ 0 3vu#567 TYY JJOO -r% r )r r r r r r$ r] rq r r% r# r r K s !M O8
.r% r c ( e Zd Z ddZd Zd Zd Zy)r Nc L t | _ t j | ||| y r )r r{ rx r$ r s r# r$ z
MMDF.__init__ r r% c 6 |j dt z y N r rk s r# r[ zMMDF._pre_message_hook s ; #g-.r% c D |j t dz t z y r r rk s r# r] zMMDF._post_message_hook s : --78r% c g g }}| j j d d} |}| j j }| j j }|j dt
z r|j
| |}| j j }| j j }|dt
z k( r"|j
|t t
z
n|s|j
| ny|snt t t || | _ t | j | _ | j j dd | j j | _
y )Nr r r/ )rA r r rW r r r r r r r r rB rF )r r r next_posr r s r# rq zMMDF._generate_toc s- >B
H::&&(Dzz(H 2W <=
h' 'H ::..0D #zz 0H 2W << XG %<= ! X. # $ 3vu#567 TYY
1 JJOO -r% r )r r r r$ r[ r] rq r r% r# r r s 8
/9.r% r c e Zd Z ddZd Zd Zd Zd Zd Zd Z d Z
d
Z d Z d Z
d
Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zy)r Nc t j | ||| t j j | j
s|rt j | j
d t j t j t j j | j
d t j t j z t j z d d| _ y t | j
d| _ y )Nr
.mh_sequencesi F)r r$ r r r r r rx r r r O_EXCLr r rE r s r# r$ z MH.__init__ s (tWf5ww~~djj)U+ djj/!J!#bii!7"++!EuN O )44 r% c | j }t | dk( rd}nt | dz }t j j | j t | }t | }d} | j r t | | j || t! |t" r| j% || | j r t | |s t | |S # t $ r; | j r t | t | d}t j | w xY w# | j r t | w w xY w# |s t | w w xY w)Nr r FT)rR r maxr r r r r r+ rE rO r r rR r r0 r r
_dump_sequences)r r+ rR new_keyr r closeds r# r, zMH.add s 2yy{ t9>G$i!mG77<<
CL9 h ' ||1
$ &&w2 gy1((':<< OA! % ||$Q N !FIIh' << O A s7 2E
C& "D- ?E
&AD**D- -EE
Ec J t j j | j t | } t |d }|j
t j | y # t $ r1}|j t j k( rt d|z d }~ww xY wNr= r5 ) r r r r r r rx r0 r r r> r4 )r r/ r r r s r# r0 z MH.remove s~ Kww||DJJC1 T5!A
GGI IIdO ww%,,& 83 >?? s A( ( B"1,B B"c t j j | j t | } t |d } | j r t | t j t j
|t j t j z | j || t! |t" r| j% || | j r t' | t) | y # t $ r1}|j t j k( rt d|z d }~ww xY w# | j r t' | w w xY w# t) | w xY wr )r r r r r r r r r> r4 rE rO rx r O_TRUNCr r r
r rR r )r r/ r+ r r r s r# r8 zMH.__setitem__ s Lww||DJJC1 T5!A ||1
$r{{RZZ'?@A""7A. gy1((#6<< O N# ww%,,& 83 >?? << O
Ns< C; E At t j j | j
t
| d }n=t t j j | j
t
| d }|5 | j r t | t | }| j r t | d d d | j j D ] \ }}||v s j! | S # t $ r1}|j t j k( rt d|z d }~ww xY w# | j r t | w w xY w# 1 sw Y xY w)Nr= r r5 )rE r r r r r r r r r> r4 rO r
rR
get_sequencesr_ add_sequence)r r/ r r r r key_lists r# r> zMH.get_message s B || djj#c(;UC djj#c(;TB ||1
$ l<< O # 0 0 2 8 8 :ND(h & ;
! ww%,,& 83 >?? << O
Qs< BD E(% E 0E( E,EE E%%E((E1c | j r>t t j j | j
t
| d }n=t t j j | j
t
| d }|5 | j r t | |j j t d | j r t | cd d d S # t $ r1}|j t j k( rt d|z d }~ww xY w# | j r t | w w xY w# 1 sw Y y xY w)Nr= r r5 r )rE r r r r r r r r r> r4 rO r r r rR r r/ r r s r# rH z MH.get_bytes s @ || djj#c(;UC djj#c(;TB ||1
$vvx''7<< O Q ww%,,& 83 >?? << O
Qs< BC) E%#D&E) D#2,D D#&E EE c t t j j | j t | d }t | S # t $ r1}|j t j k( rt d|z d }~ww xY w)Nr r5 ) r r r r r r r r r> r4 r r s r# rA z MH.get_file1 so D RWW\\$**c#h7>A !} ww%,,& 83 >?? s =A B,B Bc t t t d t j | j D S )Nc 3 R K | ] }|j r
t | ! y wr )isdigitr' ).0r s r# z MH.iterkeys..> s% :3I%). u:3Is %')iterrZ r r r rN s r# rO z MH.iterkeys< s2 +F :2::djj3I : : ; ;r% c t j j t j j | j t | S r )r r r r r r r. s r# ra zMH.__contains__A s/ Gww~~bggll4::s3x @AAr% c H t t | j S r )r rQ rO rN s r# rc z
MH.__len__E s 84
())r% c | j sVt t j j | j
d d | _ t | j d| _ y y )Nr r= T)rE r r r r r rA rO rN s r# rt zMH.lockI sE || bggll4:: GODJ tzz " DL r% c | j r4t | j t | j | `d| _ y y rQ )rE rR rA r rN s r# rv z MH.unlockP s5 1 << $
#
DL r% c y r r rN s r# rr zMH.flushX s 4r% c @ | j r| j y y r )rE rv rN s r# rx zMH.close\ s * << KKM r% c g }t j | j D ][ }t j j t j j | j | sK|j
| ] |S r )r r r r r r r r s r# r zMH.list_foldersa sW ,ZZ
+Eww}}RWW\\$**e <=
e$ ,
r% c t t j j | j | | j
d S )NFr r r r r r r r
s r# r z
MH.get_folderi s0 9"'',,tzz62 --7 7r% c t t j j | j | | j
S )Nr r r
s r# r z
MH.add_foldern s. H"'',,tzz62 --) )r% c ^ t j j | j | }t j | }|dgk( r4t j
t j j |d n |g k( rnt
d| j z t j | y )Nr zFolder not empty: %s)r r r r r r0 r r )r r r entriess r# r zMH.remove_folders s{ ;ww||DJJ/**T" ' ' IIbggll4 9 :
] 6 CD D
r% c
i }t t j j | j d dd 5 }t | j
}|D ] } |j d \ }}t }|j D ]f }|j r|j t | .d |j d D \ } }
|j t | |
dz h t | D cg c] } | |v r|
c} ||< t || d k( r||= d d d |S c c} w # t $ r t! d
|j# z w xY w# 1 sw Y |S xY w) Nr rASCIIencodingr c 3 2 K | ] }t | y wr )r' )r xs r# r z#MH.get_sequences.. s *K?a3q6?s -r r z"Invalid sequence specification: %s)r r r r r setrR r r r, r' rp rangerZ r r| r rstrip) r resultsr all_keysr r contentsrR specrf rg r/ s r# r zMH.get_sequences sN K
"'',,tzz?;S7
SWX499;'H5%)ZZ_ND( 5D ( 0 <<> HHSY /*K4::c?*KKE4 KKeTAX(> ? !1 5;4L %=LS,/8O &)L %=GDM74=)Q. #DM T& %= " 5%&J&*kkm'4 5 55! T& s6 E B$D7>
D2 D7%E 2D77&E E E*c t t j j | j d dd } t j
t j |j t j t j z |j D ] \ }}t | dk( r|j |dz d }d}t t | D ]Q }|dz
|k( r|sCd }|j d
n/|rd}|j |d | n|j d |z |}S |r |j t | d
z |j d
t | y # t | w xY w)Nr zr+r r r r Fr Tr z %s
)r r r r r rx r r r r_ r r rZ r r r )r sequencesr r rR prev
completingr/ s r#
set_sequenceszMH.set_sequences s% H djj/:D7 S HHRWWQVVR[[2::%=> ? 'oo /
dt9> s
# "
!#d),CQw$ ))-J GGCL#%*
4 56 , D - GGCI ,-GGDM) 0,
NKNs D*E0 0
E=c | j }d}g }| j D ] }|dz
|k7 r|j ||dz f t j t j
j
| j t | t j
j
| j t |dz t j t j
j
| j t | |dz
} |dz | _
t | dk( ry |j D ]( \ }}|D ] \ }}||v s |||j! | < * | j# | y # t t f$ r~ t j t j
j
| j t | t j
j
| j t |dz Y w xY w)Nr r )r rO r r r r r r r unlinkr r r rB r r_ indexr ) r r r changesr/ r r oldr s r# packzMH.pack s M&&( ==?CQw$TAX/BGGBGGLLSX > GGLLS] CE IIbggll4::s3x @A AID # w<1 'oo /ND( #S(?47HX^^C 01 $ 0
9% '8 GIIbggll4::s3x @ ggll4::s4!8} EGGs A;E66B
HHc |j }| j }|j D ]2 \ }}||v r|j | ||v s!||j | = 4 |D ]
}||vs|g||< | j | y r )r r_ r r r )r r+ r/ pending_sequences
all_sequencesr r sequences r# r zMH._dump_sequences s I # 1 1 3 **,
+ 1 1 3ND((($ X^^C 01 4
*H},+.%
h' *
=)r% r )r r r r$ r, r0 r8 r> rH rA rO ra rc rt rv rr rx r r r r r r r r r r% r# r r su
D 02$* ;
B* !
7
)
0:&4 *r% r c r e Zd Z eh d ZddZd Zd Zd Zd Z d Z
d Z d
Z d Z
d Zd
Zd Zd Zy)r > filededitedresentunseendeletedanswered forwardedNc D t j | ||| i | _ y r )r; r$ _labelsr s r# r$ zBabyl.__init__ s )##D$@ r% c t j | | }t |t r |j | j
|< |S r )r; r, r r
get_labelsr )r r+ r/ s r# r, z Babyl.add s= 2 $$T73 g| , ' 2 2 4DLL
r% c j t j | | || j v r| j |= y y r )r; r0 r r. s r# r0 z Babyl.remove s2 K!!$, $,, S! r% c t j | || t |t r |j | j
|< y y r )r; r8 r r r r r7 s r# r8 zBabyl.__setitem__ s= L&&tS': g| , ' 2 2 4DLL -r% c | j | \ }}| j j | | j j t j
} | j j }|dt z k( s|sn&|j |j t d Ot j
} | j j }|t k( s|sn&|j |j t d L|| j j z
}| j j | }|j t d }t |j |z } | j |j || j v r | j | j | | S N *** EOOH ***r )r rA r r r r r r r rW r r r set_visibler
set_labels)
r r/ rf rg original_headersr visible_headersnbodyr s
r# r> zBabyl.get_message sa Bll3' t
::<::&&(D00 " "4<<#? @
**,::&&(Dwd ! !$,,w"> ?
4::??$ $zzq!||GU++446=> 0023 $,, NN4<<, -
r% c t | j | \ }}| j j | | j j t j
} | j j }|dt z k( s|sn&|j |j t d O | j j }|t k( s|sn'|j }|| j j z
}| j j | }|j t d }||z S r ) r rA r r r r r r r r rW r ) r r/ rf rg r r headersr r s r# rH zBabyl.get_bytes s All3' t
::<::&&(D00 " "4<<#? @
::&&(Dwd #++- 4::??$ $zzq!||GU+~ r% c t t j | j | j dt S r )r r rH r r r. s r# rA zBabyl.get_file- s* Dzz$..-55eWEFFr% c | j t }| j j D ] }|j | |j | j t | S r )r r r r[ rp difference_update_special_labelsrQ )r labels
label_lists r# r zBabyl.get_labels1 sV B ,,--/J MM* % 0 !5!56F|r% c B g g }}| j j d d}g } |}| j j }| j j }|dt z k( rt | t | k r!|j
|t t z
|j
| | j j dd j d D cg c]" }|j r|j $ }}|j
| nn|dk( s |dt z k( r9t | t | k rF|j
|t t z
n$|s"|j
|t t z
ndt t t || | _ t t | | _
t | j | _ | j j dd | j j | _ y c c}w )Nr s r , r/ )rA r r rW r r r r stripr r r r r rB rF ) r r r r label_listsr r labelr s r# rq zBabyl._generate_toc: s >B
H::&&(Dzz(H{W,,u:F +LLCL!89
h'+/::+>+>+@+D+J+J4+P:+P -2+0;;= ++-+P : ""6* DGg,=$=u:F +LLCL!89 XG 45# $ 3vu#567 Ik 23 TYY
1 JJOO - :s 'H c dt z }|dt z z
}| j }d |D }|ddj | z t z z
}|dz
}|j | y )Ns BABYL OPTIONS:s
Version: 5c 3 < K | ] }|j y wr )rz )r r s r# r z*Babyl._pre_mailbox_hook..] s 5fU%,,.fs s Labels:r r
)r r r r )r r babylr s r# rY zBabyl._pre_mailbox_hookX sf :!G+
(( "5f5
dii //'99
r% c 6 |j dt z y )N r rk s r# r[ zBabyl._pre_message_hookb s ; '!"r% c 6 |j t dz y )Nr
r rk s r# r] zBabyl._post_message_hookf s : '!"r% c | j j }t |t r g }g }|j D ]3 }|| j
v r|j
| #|j
| 5 | j j d |D ]. }| j j d|j z 0 | j j d |D ]1 }| j j d|j z dz 3 | j j t n"| j j dt z t |t j j rt j }t j j! |dd }|j# | |j% d |j' }| j j |j) d
t |d
k( s|snH| j j d t z t |t rt j } t j j! | dd }
|
j# |j+ | j' }| j j |j) d
t |d
k( s|sn[H|j% d |j' }| j j |j) d
t |d
k( s|snH |j- d } | sn| j j | j) d
t Et |t. t0 t j2 f rt |t j2 r+t5 j6 d
t8 d |j; }t |t0 r| j= | }|j? d dz } | dz
dk7 r| j j |d | j) d
t | j j d t z | j j |d | j) d
t | j j || d j) d
t n | j j d t z t z | j j |j) d
t ntA |d rtA |d r't5 j6 dt8 d |jB }|j }
d } |j' }|jE d r |d d d
z }n|jE d r|d d d
z }| j j |j) d
t |d
k( s|s9|r6d}| j j d t z |j% |
nn |j' }|sn|jE d r
|d d t z }n;|jE d r
|d d t z }n |jE d
r |d d t z }| j j | tG dtI | z | j j }||fS )N 1s , s ,, r s 1,,Fr Tr r rT r r s
r/ r r r r r r r r )%rA rW r r r r r r rz r rF r+ r
r r r r r r r r get_visibler r r r r r r r r} r rl r r r r )r r+ rf special_labelsr r orig_bufferorig_generatorr
vis_buffer
vis_generatorr
body_start original_pos
first_passrg s r# rs zBabyl._install_messagej s >
! g| , NF ++-D 0 00"))%0MM%( .
JJ T "'
!78 ( JJ U #
!6!=> JJ W % JJ Vg - . gu}} 4 4 5 **,K "__ ; ;KPQ RN " "7 + Q "++-
eW!=>5=
JJ _w 6 7'<0 ZZ\
% > >z5RS T
%%g&9&9&;<%..0DJJ$$T\\%%ABu}D #&//1DJJ$$T\\%%ABu}D
$))$/
w!?@
%bkk!:
;'2;;/
*+=qB!**,'3' //8 g.2JA~#
*!5!=!=eW!MN
7!:;
*!5!=!=eW!MN
!5!=!=eW!MN
7!:W!DE
!@A
Wj
)w)
56H!M!.."<<>L J '')==) 9u,D]]5) 9u,D
eW!=>5=!%*
(( 7)BC \2 '')==) 9w.D]]5) 9w.D]]5) 9w.D
& 6g FG Gzz t} r% r )r r r frozensetr r$ r, r0 r8 r> rH rA r rq rY r[ r] rs r r% r# r r sY ' !B CO
" 5 8 ,G .<##i r% r c " e Zd Z ddZd Zd Zy)r
Nc t |t j j rG| j t j | t |t r|j | y y t |t r%| j t j | y t |t r%| j t j | y t |t j r%| j t j | y t |d r%| j t j | y |*t j j j# | y t% dt' | z )Nr r )r rF r+ r
_become_messagecopydeepcopy _explain_tor rG r message_from_stringr
TextIOWrappermessage_from_filerl message_from_binary_filer$ r r r* s r# r$ zMessage.__init__ s , gu}} 4 4 5 w!7 8'7+##D) ,
' !9!9'!B C
% !:!:7!C D
!1!1
2 !8!8!A B
Wf
% !?!?!H I
_ MM ! ! * *4 0 6g FG Gr% c t |dg }|j D ]# }||vs|j | | j |< % y )N_type_specific_attributes)getattr__dict__)r r+
type_specificr s r# r& zMessage._become_message sE > )DbI
$$D=(&-&6&6t&<
d# %r% c < t |t ry t d )Nz Cannot convert to specified type)r r
r r* s r# r) zMessage._explain_to s H gw ' >? ?r% r )r r r r$ r& r) r r% r# r
r
s :H&=@r% r
c ` e Zd Z g dZddZd Zd Zd Zd Zd Z d Z
d
Z d Z d Z
d
Zd Zy)r )_subdir_info_dateNc d| _ d| _ t j | _ t j | | y )Nr r )r5 r6 r r7 r
r$ r* s r# r$ zMaildirMessage.__init__ s0 3
YY[
w'r% c | j S r )r5 rN s r# r zMaildirMessage.get_subdir s $||r% c D |dk( s|dk( r|| _ y t d|z )Nr r z!subdir must be 'new' or 'cur': %s)r5 r| )r r s r# r zMaildirMessage.set_subdir s* + U?fo!DL @6 IJ Jr% c Z | j j d r| j dd S y)N2,r/ r )r6 r rN s r# get_flagszMaildirMessage.get_flags s* 8 :: &::ab> !r% c J ddj t | z | _ y )Nr< r )r rZ r6 )r flagss r# set_flagszMaildirMessage.set_flags s 7BGGF5M 22
r% c | j dj t | j t | z y Nr r@ r r r= r flags r# add_flagzMaildirMessage.add_flag / < rwws4>>#3 4s4y @ABr% c | j rD| j dj t | j t | z
y y rB )r= r@ r r rD s r# remove_flagzMaildirMessage.remove_flag! s> E >> NN2773t~~'7#83t9#DE F r% c | j S r )r7 rN s r# r zMaildirMessage.get_date& s Jzzr% c ` t | | _ y # t $ r t d|z d w xY w)Nzcan't convert to float: %s)floatr7 r| r )r dates r# r zMaildirMessage.set_date* s: G K tDJ K 84 ?@d J Ks -c | j S r )r6 rN s r# r zMaildirMessage.get_info1 s 3zzr% c b t |t r|| _ y t dt | z )Nzinfo must be a string: %s)r r r6 r r )r ri s r# r zMaildirMessage.set_info5 s+ . dC DJ 7$t* DE Er% c t |t r^|j | j |j | j |j
| j y t |t rt | j }d|v r|j d | j dk( r|j d d|v r|j d d|v r|j d d|v r|j d |j d t j | j y t |t rZt | j }d|vr|j d
d|v r|j d d|v r|j d y y t |t rot | j }d|vr|j# d
d|v r|j# d
d|v r|j# d d|v r|j# d y y t |t$ ry t' dt) | z )NSRr OTDFA
MAILER-DAEMONr repliedflaggedr r r# r $Cannot convert to specified type: %s)r r r@ r= r r r r r r rF r} r r r
r r add_labelr
r r )r r+ r? s r# r) zMaildirMessage._explain_to< s I g~ . dnn . / t 0 1 T]]_ -
!1
2()Ee| % E) %e| %e| %e| % _dkk$--/.J K
+()E% $$X.e|$$Y/e|$$Y/
.()E% !!(+e|!!),e|!!*-e|!!+.
) B M * +
+r% r )r r r r/ r$ r r r= r@ rF rI r r r r r) r r% r# r r sL 3 = ( K3CG
KF)+r% r c H e Zd Z dgZd dZd Zd dZd Zd Zd Z d Z
d
Z y) r _fromNc | j dd t |t j j r7|j }|%|j
d r| j |dd t j | | y )NrX TzFrom r )r} r rF r+ r
r r r$ )r r+ r s r# r$ z_mboxMMDFMessage.__init__m sj 5
ot, gu}} 4 4 5 ++-H#(;(;G(D
hqrl+w'r% c | j S r )r^ rN s r# r z_mboxMMDFMessage.get_fromv s .zzr% c ~ |3|du rt j }|dt j | z z
}|| _ y )NTr )r r r r^ )r r time_s r# r} z_mboxMMDFMessage.set_fromz s< L }
S4<<.. .E
r% c N | j dd | j dd z S )NStatusr X-Status)r< rN s r# r= z_mboxMMDFMessage.get_flags s& 8xx"%R(@@@r% c t | }d\ }}dD ] }||v s||z
}|j | dD ] }||v s||z
}|j | |dj t | z
} | j d| | j d| y # t
$ r | j
d| Y 1w xY w# t
$ r | j
d| Y y w xY w)N)r r )rR rS )rU rV rW r rd re )r r0 r rZ replace_headerr4
add_header)r r? status_flags
xstatus_flagsrE s r# r@ z_mboxMMDFMessage.set_flags s 7E
&,# m Du} $ T" $Du} %
T" $ //
4 , 7 7
M : 4 OOHl 3 4 7 OOJ
6 7s$ 4B B; B87B8;CCc | j dj t | j t | z y rB rC rD s r# rF z_mboxMMDFMessage.add_flag rG r% c d| v sd| v rD| j dj t | j t | z
y y )Nrd re r rC rD s r# rI z _mboxMMDFMessage.remove_flag sC E t zT 1 NN2773t~~'7#83t9#DE F 2r% c t |t rt | j }d|v r|j d d|v r|j d d|v r|j d d|v r|j d d|v r|j d |d = |d
= d j
| j j d d } |j t j t j |d
y t |t r?|j# | j |j% | j y t |t& r_t | j }d|vr|j) d d|v r|j) d d|v r|j) d |d = |d
= y t |t* r_t | j }d|vr|j- d d|v r|j- d d|v r|j- d |d = |d
= y t |t. ry t1 dt3 | z # t t f$ r Y y w xY w)NrS r rV rW rR rQ rU rT statuszx-statusr z%a %b %d %H:%M:%S %Yr rY rZ r r r[ )r r r r= r rF r r r r calendartimegmr strptimer|
OverflowErrorr r@ r} r
r r r\ r
r r )r r+ r?
maybe_dates r# r) z _mboxMMDFMessage._explain_to s< O g~ .()Ee|""5)e| %e| %e| %e| %!
# $--/"7"7"9"#">?J
z6L2N "O P !1
2 dnn . / T]]_ -
+()E% $$X.e|$$Y/e|$$Y/!
#
.()E% !!(+e|!!),e|!!*-!
#
) B M * +
+9
.
s 8I I+*I+r ) r r r r/ r$ r r} r= r@ rF rI r) r r% r# r r h s8 9!( (A7,CG
1+r% r c e Zd Zy)r Nr r r r r% r# r r 0r% r c : e Zd Z dgZd dZd Zd Zd Zd Zd Z y)
r
_sequencesNc @ g | _ t j | | y r )ry r
r$ r* s r# r$ zMHMessage.__init__ s / w'r% c " | j d d S r )ry rN s r# r zMHMessage.get_sequences s Bq!!r% c & t | | _ y r )rQ ry )r r s r# r zMHMessage.set_sequences s A y/r% c t |t r+|| j vr | j j | y y t dt | z )Nz sequence type must be str: %s)r r ry r r r r r s r# r zMHMessage.add_sequence sI F h $t.&&x0 / ;d8n LM Mr% c \ | j j | y # t $ r Y y w xY wr )ry r0 r| r~ s r# remove_sequencezMHMessage.remove_sequence s. O OO " "8 , ++c ~ t |t r}t | j }d|v r|j d n"|j d |j d d|v r|j d d|v r|j d y y t |t rlt | j }d|vr|j d n|j d d|v r|j d d|v r|j d
y y t |t r'| j D ] }|j | y t |t rEt | j }d|v r|j d d|v r|j d y y t |t ry t d t | z )
Nr r rQ rZ rV rY rR ROrS rW r r[ )r r r r r rF r r
r r r\ r
r r )r r+ r r s r# r) zMHMessage._explain_to s D g~ .D . . 01I9$""5)""5) %I% %I% % &
!1
2D . . 01Iy( & %I% %I% % &
+ . . 0$$X. 1
.D . . 01I9$!!(+I%!!*- &
) B M * +
+r% r )
r r r r/ r$ r r r r r) r r% r# r
r
s, .!- (
"*N$+r% r
c N e Zd Z ddgZd
dZd Zd Zd Zd Zd Z d
Z
d Z d Z y)r r _visibleNc ^ g | _ t | _ t j | | y r )r r
r r$ r* s r# r$ zBabylMessage.__init__* s% 1
w'r% c " | j d d S r )r rN s r# r zBabylMessage.get_labels0 s 5||A r% c & t | | _ y r )rQ r )r r s r# r zBabylMessage.set_labels4 s 4F| r% c t |t r+|| j vr | j j | y y t dt | z )Nzlabel must be a string: %s)r r r r r r r r s r# r\ zBabylMessage.add_label8 sI 9 eS !DLL( ##E* ) 84; FG Gr% c \ | j j | y # t $ r Y y w xY wr )r r0 r| r s r# remove_labelzBabylMessage.remove_label@ s. B LL & r c . t | j S r r
r rN s r# r zBabylMessage.get_visibleG s At}}%%r% c & t | | _ y r r )r visibles r# r zBabylMessage.set_visibleK s @ (
r% c | j j D ]3 }|| v r | j j || | '| j |= 5 dD ]( }|| v s|| j vs| | | j |< * y )N)DateFromzReply-ToToCCSubject)r rR rg )r headers r# update_visiblezBabylMessage.update_visibleO sy Gmm((*F~
,,VT&\BMM&) +
JF~&
"=(,V
f% Jr% c t |t rt | j }d|v r|j d n"|j d |j d d|v sd|v r|j d d|v r|j d d |v r|j d
y y t |t rlt | j }d|vr|j d n|j d d |v r|j d
d|v r|j d y y t |t rEt | j }d|v r|j d d|v r|j d y y t |t rF|j | j | j D ] }|j | y t |t ry t dt | z )Nr r rQ r r r# r rR r rT r rS rU rW rY r[ )r r r r r rF r r
r r r r r\ r
r r )r r+ r r s r# r) zBabylMessage._explain_toZ s G g~ . *+F6!""5)""5) %f$F(: %V# %F" % #
!1
2 *+Fv% & %F" %V# % $
+ *+F6!$$X.V#$$Y/ $
. 0 0 2 3 *!!%( +
) B M * +
+r% r )
r r r r/ r$ r r r\ r r r r r) r r% r# r r % s> 1!*J 7 ( $H&) 5'+r% r c e Zd Zy)r Nrv r r% r# r r rw r% r c e Zd Z ddZddZddZddZddZd Zd Z dd Z
d
Z d Z d Z
d
Zd Zd Zd Zd Zed Z ee Zy)r Nc R || _ ||j | _ y || _ y r )rA rW _pos)r r poss r# r$ z_ProxyFile.__init__ s% &
;DIDIr% c P | j || j j S r )_readrA r r sizes r# r z_ProxyFile.read s zz$
00r% c P | j || j j S r )r rA read1r s r# r z_ProxyFile.read1 s zz$
0 011r% c P | j || j j S r )r rA r r s r# r z_ProxyFile.readline s zz$
3 344r% c n g }| D ], }|j | ||t | z }|dk s+ |S |S )Nr )r r )r sizehintrg r s r# readlinesz_ProxyFile.readlines sJ "D MM$ #CI%q=
r% c # b K | j x}r| | j x}ry y wr )r )r r s r# rY z_ProxyFile.__iter__ s2 !mmo%d%J mmo%d%s *//c | j S r )r rN s r# rW z_ProxyFile.tell s "yyr% c |dk( r%| j j | j | j j || | j j | _ y )Nr rA r r rW r offsetwhences r# r z_ProxyFile.seek sD Q; JJOODII &
'JJOO% r% c t | d r4 t | j d r| j j | `y y # | `w xY w)NrA rx )rl rA rx rN s r# rx z_ProxyFile.close sE 4 !
4::w/JJ$$&J "
Js 0A Ac |d}| j j | j || }| j j | _ |S )Nr r )r r read_methodrg s r# r z_ProxyFile._read sD 0 <D
" T"JJOO%
r% c | S r r rN s r# __enter__z_ProxyFile.__enter__ s
2 r% c $ | j y r )rx )r excs r# __exit__z_ProxyFile.__exit__ s
r% c 6 | j j S r )rA readablerN s r# r z_ProxyFile.readable zz""$$r% c 6 | j j S r )rA writablerN s r# r z_ProxyFile.writable r r% c 6 | j j S r )rA seekablerN s r# r z_ProxyFile.seekable r r% c 6 | j j S r )rA rr rN s r# rr z_ProxyFile.flush s zz !!r% c v t | d syt | j d sy| j j S )NrA Tr F)rl rA r rN s r# r z_ProxyFile.closed s0 tW%tzz8,zz r% r r )r r r r$ r r r r rY rW r rx r r r r r r rr propertyr r r r r r% r# r r sv ( 125
& %%%" ! ! $L1r% r c 0 e Zd Z ddZd ZddZd Zd Zy) r Nc P t j | || || _ || _ y r )r r$ _start_stop)r r rf rg s r# r$ z_PartialFile.__init__ s% (D!U+
r% c H t j | | j z
S r )r rW r rN s r# rW z_PartialFile.tell s 8t$t{{22r% c |dk( r| j | _ d}n|dk( r| j | _ d}t j | || y )Nr r r/ )r r r r r r s r# r z_PartialFile.seek sC F Q; DIF
q[
DIFff-r% c | j | j z
}|dk ry|
|dk s||kD r|}t j | || S )Nr r% )r r r r )r r r remainings r# r z_PartialFile._read sM IJJ* > <4!8ti'7 D dK88r% c " t | d r| `y y )NrA )rl rA rN s r# rx z_PartialFile.close
s 4 !
"r% )NNr )r r r r$ rW r r rx r r% r# r r s 0 3.9r% r c d} t r6 t j | t j t j z |r{ t | j dz }|j t j |j | j dz d}t j |j y y y # t $ rY}|j
t
j t
j t
j fv rt d| j z d }~ww xY w# t $ r7}|j
t
j t
j fv rY d }~y d }~ww xY w# t t" f$ r2 t j$ |j | j dz d}Y w xY w# t& $ r8 t j( |j t d| j z w xY w# t r$t j | t j* |r"t j( | j dz xY w)NFzlockf: lock unavailable: %s.lockTzdot lock unavailable: %s)fcntllockfLOCK_EXLOCK_NBr r EAGAINr? r@ r r rX rx r r r r r r r, r0 LOCK_UN)r rU dotlock_doner pre_locks r# rO rO s 2L%
Au}}u}} <=
,QVVg-=>
1-GGHMM166G+;<#'L
IIhmm, !
77u||U\\5;; GG,-J-.VV.4 5 5
77u||U[[ 99
'8 (IIhmmQVVg-=>#'L(
#
1 (--(()C)**0 1 1
1 KK5== ) IIaffw& '
s G/ 5B? G/ (D$ ./E' F+ ? D!AD D!!G/ $ E$-,E G/ E E$$G/ '>F(%F+ 'F((F+ +AG,,G/ /AI c t r$t j | t j t j j | j dz r#t j | j dz y y )Nr )r r r r r r r r0 r s r# rR rR ; sM 4
Au}}% ww~~affw&'
!&&7"# (r% c
t j | t j t j z t j z d } t | d t j
| S # t j
| w xY w)Nr r= )r r r r O_RDWRrx )r fds r# r+ r+ B sS M rzzBII- 95 ABD%
s
A+ +Bc
t | dt t j dt j dt j S )Nr )r+ r' r r% r& r r( )r s r# rX rX J s; L dC 4D.4.@.@.B.0iik ; < r s J
A
**
G
$f2 f2Rsg sl C CN@ " @ F1.9 1.h*.9 *.Zn* n*b v v r"@emm## "@Jj+W j+Zn+w n+b1" 1E+ E+P\+7 \+~1" 1_2 _2D$: $N(T$< -I -E EIE I4 44% 4aB Es E4 4E?>E?