|
Server : LiteSpeed System : Linux premium217.web-hosting.com 4.18.0-553.54.1.lve.el8.x86_64 #1 SMP Wed Jun 4 13:01:13 UTC 2025 x86_64 User : alloknri ( 880) PHP Version : 8.1.34 Disable Function : NONE Directory : /lib64/python3.6/asyncio/__pycache__/ |
3
\� � @ sR d Z ddddgZG dd� d�ZG dd� de�ZG dd� de�ZG dd� de�Zd S )
zAbstract Protocol class.� BaseProtocol�Protocol�DatagramProtocol�SubprocessProtocolc @ s0 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
S ) r a Common base class for protocol interfaces.
Usually user implements protocols that derived from BaseProtocol
like Protocol or ProcessProtocol.
The only case when BaseProtocol should be implemented directly is
write-only transport like write pipe
c C s dS )z�Called when a connection is made.
The argument is the transport representing the pipe connection.
To receive data, wait for data_received() calls.
When the connection is closed, connection_lost() is called.
N� )�selfZ transportr r �)/usr/lib64/python3.6/asyncio/protocols.py�connection_made s z BaseProtocol.connection_madec C s dS )z�Called when the connection is lost or closed.
The argument is an exception object or None (the latter
meaning a regular EOF is received or the connection was
aborted or closed).
Nr )r �excr r r �connection_lost s z BaseProtocol.connection_lostc C s dS )a Called when the transport's buffer goes over the high-water mark.
Pause and resume calls are paired -- pause_writing() is called
once when the buffer goes strictly over the high-water mark
(even if subsequent writes increases the buffer size even
more), and eventually resume_writing() is called once when the
buffer size reaches the low-water mark.
Note that if the buffer size equals the high-water mark,
pause_writing() is not called -- it must go strictly over.
Conversely, resume_writing() is called when the buffer size is
equal or lower than the low-water mark. These end conditions
are important to ensure that things go as expected when either
mark is zero.
NOTE: This is the only Protocol callback that is not called
through EventLoop.call_soon() -- if it were, it would have no
effect when it's most needed (when the app keeps writing
without yielding until pause_writing() is called).
Nr )r r r r �
pause_writing! s zBaseProtocol.pause_writingc C s dS )zvCalled when the transport's buffer drains below the low-water mark.
See pause_writing() for details.
Nr )r r r r �resume_writing7 s zBaseProtocol.resume_writingN)�__name__�
__module__� __qualname__�__doc__r r
r r r r r r r s
c @ s e Zd ZdZdd� Zdd� ZdS )r an Interface for stream protocol.
The user should implement this interface. They can inherit from
this class but don't need to. The implementations here do
nothing (they don't raise exceptions).
When the user wants to requests a transport, they pass a protocol
factory to a utility function (e.g., EventLoop.create_connection()).
When the connection is made successfully, connection_made() is
called with a suitable transport object. Then data_received()
will be called 0 or more times with data (bytes) received from the
transport; finally, connection_lost() will be called exactly once
with either an exception object or None as an argument.
State machine of calls:
start -> CM [-> DR*] [-> ER?] -> CL -> end
* CM: connection_made()
* DR: data_received()
* ER: eof_received()
* CL: connection_lost()
c C s dS )zTCalled when some data is received.
The argument is a bytes object.
Nr )r �datar r r �
data_receivedX s zProtocol.data_receivedc C s dS )z�Called when the other end calls write_eof() or equivalent.
If this returns a false value (including None), the transport
will close itself. If it returns a true value, closing the
transport is up to the protocol.
Nr )r r r r � eof_received^ s zProtocol.eof_receivedN)r
r r r r r r r r r r > s c @ s e Zd ZdZdd� Zdd� ZdS )r z Interface for datagram protocol.c C s dS )z&Called when some datagram is received.Nr )r r Zaddrr r r �datagram_receivedj s z"DatagramProtocol.datagram_receivedc C s dS )z~Called when a send or receive operation raises an OSError.
(Other than BlockingIOError or InterruptedError.)
Nr )r r r r r �error_receivedm s z DatagramProtocol.error_receivedN)r
r r r r r r r r r r g s c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) r z,Interface for protocol for subprocess calls.c C s dS )z�Called when the subprocess writes data into stdout/stderr pipe.
fd is int file descriptor.
data is bytes object.
Nr )r �fdr r r r �pipe_data_receivedw s z%SubprocessProtocol.pipe_data_receivedc C s dS )z�Called when a file descriptor associated with the child process is
closed.
fd is the int file descriptor that was closed.
Nr )r r r r r r �pipe_connection_lost~ s z'SubprocessProtocol.pipe_connection_lostc C s dS )z"Called when subprocess has exited.Nr )r r r r �process_exited� s z!SubprocessProtocol.process_exitedN)r
r r r r r r r r r r r t s N)r �__all__r r r r r r r r �<module> s 7)