| Server IP : 138.197.176.125 / Your IP : 216.73.217.55 Web Server : Apache/2.4.41 (Ubuntu) System : Linux SuiteCRM-8 5.4.0-216-generic #236-Ubuntu SMP Fri Apr 11 19:53:21 UTC 2025 x86_64 User : root ( 0) PHP Version : 8.3.19 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON Directory : /lib/python3/dist-packages/twisted/internet/__pycache__/ |
Upload File : |
U
W[e1 � ( @ s� d Z ddlmZmZ ddlZddlmZ ddlmZ G dd� de �Z
G dd � d e
�Z G d
d � d e �Z G d d
� d
e �Z
G dd� de�ZG dd� de �ZG dd� de �ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de�ZG d d � d e�ZG d d � d e�ZG d d!� d!e�ZG d"d#� d#e�ZG d$d%� d%e�ZG d&d'� d'e�ZG d(d)� d)e �Z G d*d+� d+e �Z G d,d-� d-e �Z zBddl Z e j ee j!ee j"eiZ#e$e d.��r�ee#e j%< ee#e j&< W n e'k
�r� i Z#Y nX d/d0� Z(G d1d2� d2e �Z)G d3d4� d4e)�Z*G d5d6� d6e*�Z+G d7d8� d8e)�Z,G d9d:� d:e*�Z-G d;d<� d<e*�Z.G d=d>� d>e/�Z0G d?d@� d@e/�Z1G dAdB� dBe2�Z3e�4edCdDdd�dEe5dB� G dFdG� dGe,�Z6G dHdI� dIe*�Z7G dJdK� dKe �Z8G dLdM� dMe9�Z:G dNdO� dOe9�Z;G dPdQ� dQe9�Z<G dRdS� dSe9�Z=G dTdU� dUe9�Z>G dVdW� dWe?�Z@G dXdY� dYe �ZAG dZd[� d[e �ZBG d\d]� d]e �ZCG d^d_� d_e �ZDG d`da� dae �ZEG dbdc� dce/�ZFdd d d
dddddddd d d!d#d%d'd)d+d-d0d2d4d8d<d>d@dBdGdIdKdMdOdQdUdWdYd]d_dcg(ZGdS )dz<
Exceptions and errors for use in twisted.internet modules.
� )�division�absolute_importN)� deprecate)�Versionc @ s e Zd ZdZdd� ZdS )� BindErrorz)An error occurred binding to an interfacec C s, | j }| jr d|d�| j�f }d| }|S �N�%s: %s� �%s.��__doc__�args�join��self�s� r �8/usr/lib/python3/dist-packages/twisted/internet/error.py�__str__ s
zBindError.__str__N��__name__�
__module__� __qualname__r r r r r r r s r c @ s e Zd ZdZdd� Zdd� ZdS )�CannotListenErrora2
This gets raised by a call to startListening, when the object cannotstart
listening.
@ivar interface: the interface I tried to listen on
@ivar port: the port I tried to listen on
@ivar socketError: the exception I got when I tried to listen
@type socketError: L{socket.error}
c C s& t �| |||� || _|| _|| _d S �N)r �__init__� interface�port� socketError)r r r r r r r r ' s zCannotListenError.__init__c C s | j pd}d|| j| jf S )N�anyz Couldn't listen on %s:%s: %s.)r r r )r Zifacer r r r - s
�zCannotListenError.__str__N�r r r r r r r r r r r s r c @ s e Zd ZdZdS )�MulticastJoinErrorz6
An attempt to join a multicast group failed.
N�r r r r r r r r r! 4 s r! c @ s e Zd ZdZdd� ZdS )�MessageLengthErrorzMessage is too long to sendc C s, | j }| jr d|d�| j�f }d| }|S r r r r r r r > s
zMessageLengthError.__str__Nr r r r r r# ; s r# c @ s e Zd ZdZdd� ZdS )�DNSLookupErrorzDNS lookup failedc C s, | j }| jr d|d�| j�f }d| }|S r r r r r r r J s
zDNSLookupError.__str__Nr r r r r r$ G s r$ c @ s e Zd ZdZdS )�ConnectInProgressErrorz3A connect operation was started and isn't done yet.Nr" r r r r r% S s r% c @ s" e Zd ZdZddd�Zdd� ZdS ) � ConnectErrorz"An error occurred while connectingN� c C s || _ t�| |� d S r )�osError� Exceptionr )r r( �stringr r r r \ s zConnectError.__init__c C sJ | j p | jj}| jr"d|| jf }| jd r>d|| jd f }d| }|S )Nr r r
)r � __class__r r( r
r r r r r ` s
zConnectError.__str__)Nr' r r r r r r& Y s
r& c @ s e Zd ZdZdS )�ConnectBindErrorz
Couldn't bindNr" r r r r r, k s r, c @ s e Zd ZdZdS )�UnknownHostErrorz Hostname couldn't be looked upNr" r r r r r- p s r- c @ s e Zd ZdZdS )� NoRouteErrorzNo route to hostNr" r r r r r. u s r. c @ s e Zd ZdZdS )�ConnectionRefusedErrorz$Connection was refused by other sideNr" r r r r r/ z s r/ c @ s e Zd ZdZdS )�TCPTimedOutErrorzTCP connection timed outNr" r r r r r0 s r0 c @ s e Zd ZdZdS )� BadFileErrorz$File used for UNIX socket is no goodNr" r r r r r1 � s r1 c @ s e Zd ZdZdS )�ServiceNameUnknownErrorz%Service name given as port is unknownNr" r r r r r2 � s r2 c @ s e Zd ZdZdS )� UserErrorzUser aborted connectionNr" r r r r r3 � s r3 c @ s e Zd ZdZdS )� TimeoutErrorz&User timeout caused connection failureNr" r r r r r4 � s r4 c @ s e Zd ZdZdS )�SSLErrorzAn SSL error occurredNr" r r r r r5 � s r5 c @ s e Zd ZdZdS )� VerifyErrorz?Could not verify something that was supposed to be signed.
Nr" r r r r r6 � s r6 c @ s e Zd ZdZdS )�PeerVerifyErrorz(The peer rejected our verify error.
Nr" r r r r r7 � s r7 c @ s e Zd ZdZdS )�CertificateErrorzF
We did not find a certificate where we expected to find one.
Nr" r r r r r8 � s r8 �WSAECONNREFUSEDc C st t | t�r| j}n| }z |\}}W n tk
r@ t| d� Y S X ttd�r^t | tj�r^t}n t �
|t�}|||�S )z2Given a socket exception, return connection error.)r* �gaierror) �
isinstancer) r
�
ValueErrorr& �hasattr�socketr: r- � errnoMapping�get)�er
Znumberr* �klassr r r �getConnectError� s
rC c @ s e Zd ZdZdS )�ConnectionClosedz@
Connection was closed, whether cleanly or non-cleanly.
Nr" r r r r rD � s rD c @ s e Zd ZdZdd� ZdS )�ConnectionLostz<Connection to the other side was lost in a non-clean fashionc C s8 | j �� �� d }| jr,d|d�| j�f }d| }|S )Nr r r r
)r �strip�
splitlinesr
r r r r r r � s
zConnectionLost.__str__Nr r r r r rE � s rE c @ s e Zd ZdZdS )�ConnectionAbortedz�
Connection was aborted locally, using
L{twisted.internet.interfaces.ITCPTransport.abortConnection}.
@since: 11.1
Nr" r r r r rH � s rH c @ s e Zd ZdZdd� ZdS )�ConnectionDonez Connection was closed cleanlyc C s, | j }| jr d|d�| j�f }d| }|S r r r r r r r � s
zConnectionDone.__str__Nr r r r r rI � s rI c @ s e Zd ZdZdS )�FileDescriptorOverrunaw
A mis-use of L{IUNIXTransport.sendFileDescriptor} caused the connection to
be closed.
Each file descriptor sent using C{sendFileDescriptor} must be associated
with at least one byte sent using L{ITransport.write}. If at any point
fewer bytes have been written than file descriptors have been sent, the
connection is closed with this exception.
Nr" r r r r rJ � s rJ c @ s e Zd ZdZdS )�ConnectionFdescWentAwayZUhNr" r r r r rK
s rK c @ s e Zd ZdZdd� ZdS )�
AlreadyCalledz'Tried to cancel an already-called eventc C s, | j }| jr d|d�| j�f }d| }|S r r r r r r r s
zAlreadyCalled.__str__Nr r r r r rL s rL c @ s e Zd ZdZdd� ZdS )�AlreadyCancelledz*Tried to cancel an already-cancelled eventc C s, | j }| jr d|d�| j�f }d| }|S r r r r r r r s
zAlreadyCancelled.__str__Nr r r r r rM s rM c @ s e Zd ZdZdZdS )�PotentialZombieWarningz�
Emitted when L{IReactorProcess.spawnProcess} is called in a way which may
result in termination of the created child process not being reported.
Deprecated in Twisted 10.0.
z�spawnProcess called, but the SIGCHLD handler is not installed. This probably means you have not yet called reactor.run, or called reactor.run(installSignalHandler=0). You will probably never see this process finish, and it may become a zombie process.N)r r r r ZMESSAGEr r r r rN ' s �rN ZTwisted�
z4There is no longer any potential for zombie process.c @ s e Zd ZdZdd� ZdS )� ProcessDonez+A process has ended without apparent errorsc C s" t �| d� d| _d | _|| _d S )Nz!process finished with exit code 0r )r) r �exitCode�signal�status)r rS r r r r A s zProcessDone.__init__N�r r r r r r r r r rP > s rP c @ s e Zd ZdZddd�ZdS )�ProcessTerminatedz�
A process has ended with a probable error condition
@ivar exitCode: See L{__init__}
@ivar signal: See L{__init__}
@ivar status: See L{__init__}
Nc C sN || _ || _|| _d}|dk r*|d| }|dk r>|d| }t�| |� dS )a�
@param exitCode: The exit status of the process. This is roughly like
the value you might pass to L{os.exit}. This is L{None} if the
process exited due to a signal.
@type exitCode: L{int} or L{None}
@param signal: The exit signal of the process. This is L{None} if the
process did not exit due to a signal.
@type signal: L{int} or L{None}
@param status: The exit code of the process. This is a platform
specific combination of the exit code and the exit signal. See
L{os.WIFEXITED} and related functions.
@type status: L{int}
z
process endedNz with exit code %sz
by signal %s)rQ rR rS r) r )r rQ rR rS r r r r r Q s zProcessTerminated.__init__)NNNrT r r r r rU I s rU c @ s e Zd ZdZdS )�ProcessExitedAlreadyzd
The process has already exited and the operation requested can no longer
be performed.
Nr" r r r r rV k s rV c @ s e Zd ZdZdd� ZdS )�NotConnectingErrorzEThe Connector was not connecting when it was asked to stop connectingc C s, | j }| jr d|d�| j�f }d| }|S r r r r r r r v s
zNotConnectingError.__str__Nr r r r r rW s s rW c @ s e Zd ZdZdd� ZdS )�NotListeningErrorz>The Port was not listening when it was asked to stop listeningc C s, | j }| jr d|d�| j�f }d| }|S r r r r r r r � s
zNotListeningError.__str__Nr r r r r rX s rX c @ s e Zd ZdZdS )�ReactorNotRunningzJ
Error raised when trying to stop a reactor which is not running.
Nr" r r r r rY � s rY c @ s e Zd ZdZdS )�ReactorNotRestartablezF
Error raised when trying to run a reactor which was stopped.
Nr" r r r r rZ � s rZ c @ s e Zd ZdZdS )�ReactorAlreadyRunningzG
Error raised when trying to start the reactor multiple times.
Nr" r r r r r[ � s r[ c @ s e Zd ZdZdS )� ReactorAlreadyInstalledErrorzE
Could not install reactor because one is already installed.
Nr" r r r r r\ � s r\ c @ s e Zd ZdZdd� ZdS )�ConnectingCancelledErrorz�
An C{Exception} that will be raised when an L{IStreamClientEndpoint} is
cancelled before it connects.
@ivar address: The L{IAddress} that is the destination of the
cancelled L{IStreamClientEndpoint}.
c C s t �| |� || _dS )z�
@param address: The L{IAddress} that is the destination of the
L{IStreamClientEndpoint} that was cancelled.
N)r) r �address)r r^ r r r r � s z!ConnectingCancelledError.__init__NrT r r r r r] � s r] c @ s e Zd ZdZdS )�
NoProtocolz�
An C{Exception} that will be raised when the factory given to a
L{IStreamClientEndpoint} returns L{None} from C{buildProtocol}.
Nr" r r r r r_ � s r_ c @ s e Zd ZdZdS )�UnsupportedAddressFamilyz�
An attempt was made to use a socket with an address family (eg I{AF_INET},
I{AF_INET6}, etc) which is not supported by the reactor.
Nr" r r r r r` � s r` c @ s e Zd ZdZdS )�UnsupportedSocketTypez�
An attempt was made to use a socket of a type (eg I{SOCK_STREAM},
I{SOCK_DGRAM}, etc) which is not supported by the reactor.
Nr" r r r r ra � s ra c @ s e Zd ZdZdS )�AlreadyListenedzd
An attempt was made to listen on a file descriptor which can only be
listened on once.
Nr" r r r r rb � s rb c @ s e Zd ZdZdd� ZdS )�InvalidAddressErrorz�
An invalid address was specified (i.e. neither IPv4 or IPv6, or expected
one and got the other).
@ivar address: See L{__init__}
@ivar message: See L{__init__}
c C s || _ || _dS )z�
@param address: The address that was provided.
@type address: L{bytes}
@param message: A native string of additional information provided by
the calling context.
@type address: L{str}
N)r^ �message)r r^ rd r r r r � s z InvalidAddressError.__init__NrT r r r r rc � s rc )Hr Z
__future__r r r> Ztwisted.pythonr Z incrementalr r) r r r! r# �IOErrorr$ r% r& r, r- r. r/ r0 r1 r2 r3 r4 r5 r6 r7 r8 �errnoZ ENETUNREACHZ ECONNREFUSEDZ ETIMEDOUTr? r= r9 ZWSAENETUNREACH� ImportErrorrC rD rE rH rI rJ rK r< rL rM �WarningrN ZdeprecatedModuleAttributer rP rU rV � RuntimeErrorrW rX rY rZ r[ �AssertionErrorr\ r] r_ r` ra rb rc �__all__r r r r �<module> s� �
� " �