Operation   : Linux premium131.web-hosting.com 4.18.0-553.44.1.lve.el8.x86_64 #1 SMP Thu Mar 13 14:29:12 UTC 2025 x86_64
Software     : Apache
Server IP    : 162.0.232.56 | Your IP: 216.73.216.111
Domains      : 1034 Domain(s)
Permission   : [ 0755 ]

�
��fD-c@s}dZd
dl
Z
d
dlZd
dlmZ
Gdd�dej�ZGdd�d�ZGdd	�d	�Zd
d�Z	dS(u�A class supporting chat-style (command/response) protocols.

This class adds support for 'chat' style protocols - where one side
sends a 'command', and the other sends a response (examples would be
the common internet protocols - smtp, nntp, ftp, etc..).

The handle_read() method looks at the input stream for the current
'terminator' (usually '\r\n' for single-line responses, '\r\n.\r\n'
for multi-line output), calling self.found_terminator() on its
receipt.

for example:
Say you build an async nntp client using this class.  At the start
of the connection, you'll have self.terminator set to '\r\n', in
order to process the single-line greeting.  Just before issuing a
'LIST' command you'll set it to '\r\n.\r\n'.  The output of the LIST
command will be accumulated (using your own 'collect_incoming_data'
method) up to the terminator, and then control will be returned to
you - by calling your self.found_terminator() method.
iN(
udequec

Bs
|EeZ
dZd
ZdZdZdZdZd'd'dd�Z	dd�Z
d	d
�Zdd�Zd
d�Z
dd�Zdd�Zdd�Zdd�Zdd�Zdd�Zdd�Zdd�Zdd �Zd!d"�Zd#d$�Zd%d&�Zd'S((u
async_chatu�This is an abstract class.  You must derive from this class, and add
    the two methods collect_incoming_data() and found_terminator()iiulatin-1cCs8d
|_g|_
t�|_tjj||
|�
dS(Ns(uac_in_bufferuincomingudequeu
producer_fifouasyncoreu
dispatcheru__init__(uselfusockumap((u-/opt/alt/python33/lib64/python3.3/asynchat.pyu__init__Ds		
uasync_chat.__init__cCstd
�
�
dS(Numust be implemented in subclass(
uNotImplementedError(uselfudata((u-/opt/alt/python33/lib64/python3.3/asynchat.pyucollect_incoming_dataRs
u async_chat.collect_incoming_datacCs|jj
|
�

dS(
N(uincominguappend(uselfudata((u-/opt/alt/python33/lib64/python3.3/asynchat.pyu_collect_incoming_dataUs
u!async_chat._collect_incoming_datac
Cs&d
j|j
�
}
|j
dd�=|
S(Ns(ujoinuincoming(uselfu
d((u-/opt/alt/python33/lib64/python3.3/asynchat.pyu	_get_dataXs


uasync_chat._get_datac

Cstd
�
�
dS(Numust be implemented in subclass(
uNotImplementedError(
uself((u-/opt/alt/python33/lib64/python3.3/asynchat.pyufound_terminator]s
uasync_chat.found_terminatorcCs:t|
t
�r-|jr-t|
|j�}
n|
|_d
S(uRSet the input delimiter.  Can be a fixed string of any length, an integer, or NoneN(u
isinstanceustruuse_encodingubytesuencodingu
terminator(uselfuterm((u-/opt/alt/python33/lib64/python3.3/asynchat.pyuset_terminator`s

uasync_chat.set_terminatorc


Cs|jS(
N(
u
terminator(
uself((u-/opt/alt/python33/lib64/python3.3/asynchat.pyuget_terminatorfs
uasync_chat.get_terminatorc
Cs`y|j|j
�
}
Wn6tjk
rN
}
z|j�
dSWYdd}~Xn
Xt|
t�r||jr|tt|j	�}
n|j
|
|_
x�
|j
r[t|j
�
}|j�}|s�|j
|j
�

d
|_
q�t|t�rh
|}||kr"
|j
|j
�

d
|_
|j||_qX|j
|j
d|��

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

n|j
||d�|_
|j�
q�t|j
|�}|r?||kr;|j
|j
d|��

|j
|d�|_
nPq�|j
|j
�

d
|_
q�WdS(Nsii
i����(urecvuac_in_buffer_sizeusocketuerroruhandle_erroru
isinstanceustruuse_encodingubytesuencodinguac_in_bufferulenuget_terminatorucollect_incoming_datauintu
terminatorufound_terminatorufindufind_prefix_at_end(uselfudatauwhyulbu
terminatoru
nuterminator_lenuindex((u-/opt/alt/python33/lib64/python3.3/asynchat.pyuhandle_readnsN














	


	

	








uasync_chat.handle_readc


Cs|j�
dS(
N(
u
initiate_send(
uself((u-/opt/alt/python33/lib64/python3.3/asynchat.pyuhandle_write�s
uasync_chat.handle_writec


Cs|j�
dS(
N(
uclose(
uself((u-/opt/alt/python33/lib64/python3.3/asynchat.pyuhandle_close�s
uasync_chat.handle_closecCs}|j}t
|
�
|kr_xQtd
t
|
�
|�D]$}|jj|
|||��

q4Wn|jj|
�

|j�
dS(Ni(uac_out_buffer_sizeulenurangeu
producer_fifouappendu
initiate_send(uselfudatausabsu
i((u-/opt/alt/python33/lib64/python3.3/asynchat.pyupush�s
	


%
uasync_chat.pushcCs|jj
|
�

|j�
dS(
N(u
producer_fifouappendu
initiate_send(uselfuproducer((u-/opt/alt/python33/lib64/python3.3/asynchat.pyupush_with_producer�s

uasync_chat.push_with_producerc


Csd
S(u4predicate for inclusion in the readable for select()i
((
uself((u-/opt/alt/python33/lib64/python3.3/asynchat.pyureadable�suasync_chat.readablec

Cs|jp|j
S(
u4predicate for inclusion in the writable for select()(u
producer_fifou	connected(
uself((u-/opt/alt/python33/lib64/python3.3/asynchat.pyuwritable�suasync_chat.writablec

Cs|jj
d
�

d
S(uAautomatically close this channel once the outgoing queue is emptyN(u
producer_fifouappenduNone(
uself((u-/opt/alt/python33/lib64/python3.3/asynchat.pyuclose_when_done�suasync_chat.close_when_donec
Css
xl
|jrn
|j
rn
|jd
}
|
sO|jd
=|
dkrO|j�
dSn|j}y|
d|�}WnDtk
r�


|
j�}|r�|jj|�

n
|jd
=wYn
Xt|t	�r�|j
r�t||j�}ny|j
|�
}Wn#tjk
r



|j�
dSYn
X|rj
|t|�
ksC
|t|
�
kr]
|
|d�|jd
<qj
|jd
=ndSWdS(Ni(u
producer_fifou	connecteduNoneuhandle_closeuac_out_buffer_sizeu	TypeErrorumoreu
appendleftu
isinstanceustruuse_encodingubytesuencodingusendusocketuerroruhandle_errorulen(uselfufirstuobsudataunum_sent((u-/opt/alt/python33/lib64/python3.3/asynchat.pyu
initiate_send�s8







	














	
$

uasync_chat.initiate_sendc

Cs*d
|_|j
dd�=|jj�
dS(Ns(uac_in_bufferuincomingu
producer_fifouclear(
uself((u-/opt/alt/python33/lib64/python3.3/asynchat.pyudiscard_buffers�s	

uasync_chat.discard_buffersN(u__name__u
__module__u__qualname__u__doc__uac_in_buffer_sizeuac_out_buffer_sizeuuse_encodinguencodinguNoneu__init__ucollect_incoming_datau_collect_incoming_datau	_get_dataufound_terminatoruset_terminatoruget_terminatoruhandle_readuhandle_writeuhandle_closeupushupush_with_producerureadableuwritableuclose_when_doneu
initiate_sendudiscard_buffers(
u
__locals__((u-/opt/alt/python33/lib64/python3.3/asynchat.pyu
async_chat5s,

D	*u
async_chatc

Bs/|EeZ
dZd
dd�
Zdd�ZdS(usimple_producericCs|
|_||_
dS(
N(udataubuffer_size(uselfudataubuffer_size((u-/opt/alt/python33/lib64/python3.3/asynchat.pyu__init__
s
	
usimple_producer.__init__c
Cset|j
�
|jkrK|j
d|j�}
|j
|jd�|_
|
S|j
}
d
|_
|
SdS(Ns(ulenudataubuffer_size(uselfuresult((u-/opt/alt/python33/lib64/python3.3/asynchat.pyumore
s



	
	
usimple_producer.moreN(u__name__u
__module__u__qualname__u__init__umore(
u
__locals__((u-/opt/alt/python33/lib64/python3.3/asynchat.pyusimple_producer
susimple_producerc

Bs_|EeZ
dZd
d
d�
Zdd�Zdd�Zdd�Zd	d
�Zdd�Z	d
S(ufifocCs(|
st�|_
nt|
�
|_
dS(
N(udequeulist(uselfulist((u-/opt/alt/python33/lib64/python3.3/asynchat.pyu__init__
s

u
fifo.__init__c

Cs
t|j
�
S(
N(ulenulist(
uself((u-/opt/alt/python33/lib64/python3.3/asynchat.pyu__len__
s
ufifo.__len__c


Cs|jS(
N(
ulist(
uself((u-/opt/alt/python33/lib64/python3.3/asynchat.pyuis_empty
s
u
fifo.is_emptyc

Cs|jd
S(Ni(
ulist(
uself((u-/opt/alt/python33/lib64/python3.3/asynchat.pyufirst"
s
u
fifo.firstcCs|jj
|
�

dS(
N(ulistuappend(uselfudata((u-/opt/alt/python33/lib64/python3.3/asynchat.pyupush%
s
u	fifo.pushc

Cs$|jrd
|jj
�fSdSdS(Ni
i(iN(ulistupopleftuNone(
uself((u-/opt/alt/python33/lib64/python3.3/asynchat.pyupop(
s
	
ufifo.popN(
u__name__u
__module__u__qualname__uNoneu__init__u__len__uis_emptyufirstupushupop(
u
__locals__((u-/opt/alt/python33/lib64/python3.3/asynchat.pyufifo
s
ufifocCsEt|
�
d
}x.|r@|j
|
d|��
r@|d
8}qW|S(Ni
(ulenuendswith(uhaystackuneedleu
l((u-/opt/alt/python33/lib64/python3.3/asynchat.pyufind_prefix_at_end=
s

#

ufind_prefix_at_end(
u__doc__usocketuasyncoreucollectionsudequeu
dispatcheru
async_chatusimple_producerufifoufind_prefix_at_end(((u-/opt/alt/python33/lib64/python3.3/asynchat.pyu<module>/s


�(