$37 GRAYBYTE WORDPRESS FILE MANAGER $49



���]�.�@skdd
lZddl
mZ
Gdd�dej�ZGdd�d�ZGdd�d�Zd	d
�Zd
S)�N)
�dequec@s�eZ
dZd
Zd
ZdZdZdddd�Zdd�Zd	d
�Z	dd�Z
d
d�Zdd�Zdd�Z
dd�Zdd�Zdd�Zdd�Zdd�Zdd�Zdd �Zd!d"�Zd#d$�Zd%d&�ZdS)'�
async_chati
r
zlatin-1NcCs8d
|_g|_
t�|_tjj||
|�
dS)N�)�ac_in_buffer�incomingr�
producer_fifo�asyncore�
dispatcher�__init__)�self�sock�map�r�-/opt/alt/python35/lib64/python3.5/asynchat.pyr
Cs		
zasync_chat.__init__cCstd
�
�
dS)Nzmust be implemented in subclass)
�NotImplementedError)r�datarrr�collect_incoming_dataQs
z async_chat.collect_incoming_datacCs|jj
|
�

dS)
N)r�append)rrrrr�_collect_incoming_dataTs
z!async_chat._collect_incoming_datac
Cs&d
j|j
�
}
|j
dd�=|
S)Nr)�joinr)r�
drrr�	_get_dataWs


zasync_chat._get_datac

Cstd
�
�
dS)Nzmust be implemented in subclass)
r)
rrrr�found_terminator\s
zasync_chat.found_terminatorcCsat|
t
�r-|jr-t|
|j�}
n't|
t�rT|
d
krTtd�
�
|
|_dS)Nr
z-the number of received bytes must be positive)�
isinstance�str�use_encoding�bytes�encoding�int�
ValueError�
terminator)rZtermrrr�set_terminator_s




zasync_chat.set_terminatorc


Cs|jS)
N)
r )
rrrr�get_terminatorjs
zasync_chat.get_terminatorc
Csiy|j|j
�
}
WnHtk
r.


dSYn3tk
r`
}
z|j�
dSWYdd}~Xn
Xt|
t�r�|jr�tt|j	�}
|j
|
|_
x�
|j
rdt|j
�
}|j�}|s�|j
|j
�

d
|_
q�t|t�rw
|}||kr1
|j
|j
�

d
|_
|j||_qa|j
|j
d|��

|j
|d�|_
d|_|j�
q�t|�
}|j
j|�
}|dkr�
|dkr�
|j
|j
d|��

|j
||d�|_
|j�
q�t|j
|�}|rH||krD|j
|j
d|��

|j
|d�|_
Pq�|j
|j
�

d
|_
q�WdS)Nrr
�
���)�recv�ac_in_buffer_size�BlockingIOError�OSError�handle_errorrrrrrr�lenr"rrr r�find�find_prefix_at_end)rr�whyZlbr �
nZterminator_len�indexrrr�handle_readrsR

















	


	

	








zasync_chat.handle_readc


Cs|j�
dS)
N)
�
initiate_send)
rrrr�handle_write�s
zasync_chat.handle_writec


Cs|j�
dS)
N)
�close)
rrrr�handle_close�s
zasync_chat.handle_closecCs�t|
t
ttf�s-td
t|
�
��
|j}t|
�
|kr�xQtdt|
�
|�D]$}|j	j
|
|||��

qaWn|j	j
|
�

|j�
dS)Nz#data argument must be byte-ish (%r)r
)rr�	bytearray�
memoryview�	TypeError�type�ac_out_buffer_sizer*�rangerrr1)rrZsabs�
irrr�push�s



	


%
zasync_chat.pushcCs|jj
|
�

|j�
dS)
N)rrr1)rZproducerrrr�push_with_producer�s

zasync_chat.push_with_producerc


Csd
S)Nr#r)
rrrr�readable�szasync_chat.readablec


Cs|jp|j
S)
N)r�	connected)
rrrr�writable�szasync_chat.writablec

Cs|jj
d�

dS)
N)rr)
rrrr�close_when_done�szasync_chat.close_when_donec
Csg
x`
|jrb
|j
rb
|jd
}
|
sL|jd
=|
dkrL|j�
dS|j}y|
d|�}WnDtk
r�


|
j�}|r�|jj|�

n
|jd
=wYn
Xt|t�r�|j	r�t
||j�}y|j|�
}Wn t
k
r



|j�
dSYn
X|r^
|t|�
ks:
|t|
�
krT
|
|d�|jd
<n
|jd
=dSWdS)Nr
)rr?r4r9r7�more�
appendleftrrrrr�sendr(r)r*)r�firstZobsrZnum_sentrrrr1�s8








	















	
$

zasync_chat.initiate_sendc

Cs*d
|_|j
dd�=|jj�
dS)Nr)rrr�clear)
rrrr�discard_buffers
s	

zasync_chat.discard_buffers)�__name__�
__module__�__qualname__r&r9rrr
rrrrr!r"r0r2r4r<r=r>r@rAr1rGrrrrr4s*

H(rc@s+eZ
dZd
dd�
Zdd�ZdS)�simple_producericCs|
|_||_
dS)
N)r�buffer_size)rrrLrrrr

s
	
zsimple_producer.__init__c
Cset|j
�
|jkrK|j
d|j�}
|j
|jd�|_
|
S|j
}
d
|_
|
SdS)Nr)r*rrL)r�resultrrrrB
s



	
	
zsimple_producer.moreN)rHrIrJr
rBrrrrrK
srKc@s[eZ
dZd
dd�
Zdd�Zdd�Zdd	�Zd
d�Zdd
�Zd
S)�fifoNcCsJd
dl}|j
dtdd�

|
s7t�|_nt|
�
|_dS)Nr
z(fifo class will be removed in Python 3.6�
stacklevel�)�warnings�warn�DeprecationWarningr�list)rrTrQrrrr
!
s

	



z
fifo.__init__c

Cs
t|j
�
S)
N)r*rT)
rrrr�__len__*
s
zfifo.__len__c


Cs|jS)
N)
rT)
rrrr�is_empty-
s
z
fifo.is_emptyc

Cs|jd
S)Nr
)
rT)
rrrrrE0
s
z
fifo.firstcCs|jj
|
�

dS)
N)rTr)rrrrrr<3
s
z	fifo.pushc

Cs$|jrd
|jj
�fSdSdS)Nr#r
)r
N)rT�popleft)
rrrr�pop6
s
	
zfifo.pop)	rHrIrJr
rUrVrEr<rXrrrrrN 
s
	rNcCsEt|
�
d
}x.|r@|j
|
d|��
r@|d
8}qW|S)Nr#)r*�endswith)ZhaystackZneedle�
lrrrr,L
s

#

r,)r�collectionsrr	rrKrNr,rrrr�<module>0s

�,