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 ]

B

� f@,�@sDdZd
dl
Z
d
dlmZ
Gdd�de
j�ZGdd�d�Zdd	�ZdS)
a�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.
�N)
�dequec@s�eZ
dZd
ZdZdZdZdZd(dd�
Zdd	�Z	d
d�Z
dd
�Zdd�Zdd�Z
dd�Zdd�Zdd�Zdd�Zdd�Zdd�Zdd�Zd d!�Zd"d#�Zd$d%�Zd&d'�ZdS))�
async_chatz�This is an abstract class.  You must derive from this class, and add
    the two methods collect_incoming_data() and found_terminator()i
r
zlatin-1NcCs(d
|_g|_
t�|_tj�||
|�
dS)N�)�ac_in_buffer�incomingr�
producer_fifo�asyncore�
dispatcher�__init__)�selfZsock�map�r
�-/opt/alt/python37/lib64/python3.7/asynchat.pyr
Cs
zasync_chat.__init__cCstd
�
�
dS)Nzmust be implemented in subclass)
�NotImplementedError)r�datar
r
r�collect_incoming_dataQs
z async_chat.collect_incoming_datacCs|j�
|
�

dS)
N)r�append)rrr
r
r�_collect_incoming_dataTs
z!async_chat._collect_incoming_datac
Csd
�|j
�
}
|j
dd�=|
S)Nr)�joinr)r�
dr
r
r�	_get_dataWs


zasync_chat._get_datac

Cstd
�
�
dS)Nzmust be implemented in subclass)
r)
rr
r
r�found_terminator\s
zasync_chat.found_terminatorcCsBt|
t
�r|jrt|
|j�}
nt|
t�r8|
d
kr8td�
�
|
|_dS)zdSet the input delimiter.

        Can be a fixed string of any length, an integer, or None.
        r
z-the number of received bytes must be positiveN)�
isinstance�str�use_encoding�bytes�encoding�int�
ValueError�
terminator)rZtermr
r
r�set_terminator_s




zasync_chat.set_terminatorc


Cs|jS)
N)
r)
rr
r
r�get_terminatorjs
zasync_chat.get_terminatorc

Cs�
y|�|j
�
}
Wn<tk
r$


dStk
rL
}
z|��
dSd}~XYnXt|
t�rj|jrjtt|j	�}
|j
|
|_
�
xV|j
�
r�t|j
�
}|��}|s�|�
|j
�

d
|_
qzt|t��
r|}||kr�|�
|j
�

d
|_
|j||_n2|�
|j
d|��

|j
|d�|_
d|_|��
qzt|�
}|j
�|�
}|dk�
rr|dk�
rT|�
|j
d|��

|j
||d�|_
|��
qzt|j
|�}|�
r�||k�
r�|�
|j
d|��

|j
|d�|_
Pqz|�
|j
�

d
|_
qzWdS)Nrr
���)Zrecv�ac_in_buffer_size�BlockingIOError�OSError�handle_errorrrrrrr�lenr!rrrr�find�find_prefix_at_end)rrZwhyZlbr�
nZterminator_len�indexr
r
r�handle_readrsR





















	











zasync_chat.handle_readc

Cs|��
dS)
N)
�
initiate_send)
rr
r
r�handle_write�s
zasync_chat.handle_writec

Cs|��
dS)
N)
�close)
rr
r
r�handle_close�s
zasync_chat.handle_closecCs|t|
t
ttf�std
t|
�
��
|j}t|
�
|krdx>tdt|
�
|�D]}|j	�
|
|||��

qBWn|j	�
|
�

|��
dS)Nz#data argument must be byte-ish (%r)r
)rr�	bytearray�
memoryview�	TypeError�type�ac_out_buffer_sizer'�rangerrr-)rrZsabs�
ir
r
r�push�s








zasync_chat.pushcCs|j�
|
�

|��
dS)
N)rrr-)rZproducerr
r
r�push_with_producer�s

zasync_chat.push_with_producerc


Csd
S)z4predicate for inclusion in the readable for select()�
r
)
rr
r
r�readable�szasync_chat.readablec


Cs|jp|j
S)
z4predicate for inclusion in the writable for select())r�	connected)
rr
r
r�writable�szasync_chat.writablec

Cs|j�
d
�

d
S)zAautomatically close this channel once the outgoing queue is emptyN)rr)
rr
r
r�close_when_done�szasync_chat.close_when_donec
Cs
�
x|j�
r|j
�
r|jd
}
|
s>|jd
=|
dkr>|��
dS|j}y|
d|�}Wn8tk
r�


|
��}|r~|j�|�

n|jd
=wYnXt|t�r�|j	r�t
||j�}y|�|�
}Wnt
k
r�


|��
dSX|�
r|t|�
ks�|t|
�
k�
r
|
|d�|jd
<n|jd
=dSWdS)Nr
)rr<r0r5r3�more�
appendleftrrrrr�sendr%r&r')r�firstZobsrZnum_sentr
r
rr-�s8




















zasync_chat.initiate_sendc

Cs d
|_|j
dd�=|j��
dS)Nr)rrr�clear)
rr
r
r�discard_buffers
s

zasync_chat.discard_buffers)NN)�__name__�
__module__�__qualname__�__doc__r#r5rrr
rrrrr r!r,r.r0r8r9r;r=r>r-rDr
r
r
rr4s,


H(rc@seZ
dZddd�
Zdd�ZdS)�simple_producer�cCs|
|_||_
dS)
N)r�buffer_size)rrrKr
r
rr

s

zsimple_producer.__init__c
CsJt|j
�
|jkr6|j
d|j�}
|j
|jd�|_
|
S|j
}
d
|_
|
SdS)Nr)r'rrK)r�resultr
r
rr?
s





zsimple_producer.moreN)
rJ)rErFrGr
r?r
r
r
rrI
s
rIcCs4t|
�
d
}x"|r.|�
|
d|��
s.|d
8}qW|S)Nr:)r'�endswith)ZhaystackZneedle�
lr
r
rr)/
s



r))rHr�collectionsrr	rrIr)r
r
r
r�<module>/s

\