|
Server IP : 82.180.170.48 / Your IP : 216.73.216.217 Web Server : LiteSpeed System : Linux us-phx-web1609.main-hosting.eu 5.14.0-503.40.1.el9_5.x86_64 #1 SMP PREEMPT_DYNAMIC Mon May 5 06:06:04 EDT 2025 x86_64 User : u636808025 ( 636808025) PHP Version : 8.2.28 Disable Function : system, exec, shell_exec, passthru, mysql_list_dbs, ini_alter, dl, symlink, link, chgrp, leak, popen, apache_child_terminate, virtual, mb_send_mail MySQL : OFF | cURL : ON | WGET : ON | Perl : OFF | Python : OFF Directory (0755) : /home/../dev/../lib64/nss/../python3.9/html/../__pycache__/ |
| [ Home ] | [ C0mmand ] | [ Upload File ] | [ Lock Shell ] | [ Logout ] |
|---|
a
�DOg9,�@sDdZddlZddlmZGdd�dej�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�eZdZdZdZdZdZdZd(dd�Zdd �Z d
d �Z
d d
�Z dd�Z dd�Z
dd�Zdd�Zdd�Zdd�Zdd�Zd d �Zd d �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()irzlatin-1NcCs(d|_g|_t�|_tj�|||�dS�N�)� ac_in_buffer�incomingr�
producer_fifo�asyncore�
dispatcher�__init__)�self�sock�map�r� /usr/lib64/python3.9/asynchat.pyr Cszasync_chat.__init__cCs td��dS�Nz must be implemented in subclass��NotImplementedError�r �datarrr�collect_incoming_dataQsz async_chat.collect_incoming_datacCs|j�|�dS�N)r�appendrrrr�_collect_incoming_dataTsz!async_chat._collect_incoming_datacCs d�|j�}|jdd�=|Sr)�joinr)r �drrr� _get_dataWs zasync_chat._get_datacCs td��dSrr�r rrr�found_terminator\szasync_chat.found_terminatorcCsBt|t�r |jr t||j�}nt|t�r8|dkr8td��||_dS)zdSet the input delimiter.
Can be a fixed string of any length, an integer, or None.
rz-the number of received bytes must be positiveN)�
isinstance�str� use_encoding�bytes�encoding�int�
ValueError�
terminator)r Ztermrrr�set_terminator_s
zasync_chat.set_terminatorcCs|jSr)r&r rrr�get_terminatorjszasync_chat.get_terminatorcCs�z|�|j�}Wn.ty$YdSty>|��YdS0t|t�r\|jr\tt|j �}|j
||_
|j
�r�t |j
�}|� �}|s�|�
|j
�d|_
qht|t��r|}||kr�|�
|j
�d|_
|j||_n2|�
|j
d|��|j
|d�|_
d|_|��qht |�}|j
�|�}|dk�r`|dk�rB|�
|j
d|��|j
||d�|_
|��qht|j
|�}|�r�||k�r�|�
|j
d| ��|j
| d�|_
�q�qh|�
|j
�d|_
qhdS)Nrr���)�recv�ac_in_buffer_size�BlockingIOError�OSError� handle_errorr r r!r"r#r�lenr(rr$r&r �find�find_prefix_at_end)r rZlbr&�nZterminator_len�indexrrr� handle_readrsR
zasync_chat.handle_readcCs |��dSr)�
initiate_sendr rrr� handle_write�szasync_chat.handle_writecCs |��dSr)�closer rrr� handle_close�szasync_chat.handle_closecCsxt|tttf�s tdt|���|j}t|�|kr`tdt|�|�D] }|j �
||||��q@n |j �
|�|� �dS)Nz#data argument must be byte-ish (%r)r) r r"� bytearray�
memoryview� TypeError�type�ac_out_buffer_sizer/�rangerrr5)r rZsabs�irrr�push�s� zasync_chat.pushcCs|j�|�|��dSr)rrr5)r Zproducerrrr�push_with_producer�s z async_chat.push_with_producercCsdS)z4predicate for inclusion in the readable for select()�rr rrr�readable�szasync_chat.readablecCs|jp |j S)z4predicate for inclusion in the writable for select())r� connectedr rrr�writable�szasync_chat.writablecCs|j�d�dS)zAautomatically close this channel once the outgoing queue is emptyN)rrr rrr�close_when_done�szasync_chat.close_when_donecCs|j�r|j�r|jd}|s:|jd=|dur:|��dS|j}z|d|�}Wn8ty�|��}|rx|j�|�n|jd=YqYn0t|t�r�|j r�t
||j �}z|� |�}Wn t
y�|��YdS0|�r|t|�ks�|t|�k�r||d�|jd<n|jd=dSdS)Nr)rrDr8r=r;�more�
appendleftr r r!r"r#�sendr-r.r/)r �firstZobsrZnum_sentrrrr5�s8
zasync_chat.initiate_sendcCs d|_|jdd�=|j��dSr)rrr�clearr rrr�discard_bufferss zasync_chat.discard_buffers)NN)�__name__�
__module__� __qualname__�__doc__r+r=r!r#r rrr r r'r(r4r6r8r@rArCrErFr5rLrrrrr4s,
H (rc@s eZdZddd�Zdd�ZdS)�simple_producer�cCs||_||_dSr)r� buffer_size)r rrSrrrr szsimple_producer.__init__cCsJt|j�|jkr6|jd|j�}|j|jd�|_|S|j}d|_|SdSr)r/rrS)r �resultrrrrGszsimple_producer.moreN)rR)rMrNrOr rGrrrrrQs
rQcCs0t|�d}|r,|�|d|��s,|d8}q |S)NrB)r/�endswith)ZhaystackZneedle�lrrrr1/s
r1)rPr � collectionsrr
rrQr1rrrr�<module> s \