tfkOdZddlmZddlZddlZddlZddlmZmZm Z ddl m Z m Z ddl mZmZmZmZmZddlmZmZddlmZmZdd lmZdd lmZmZdd lm Z m!Z!m"Z"m#Z#m$Z$dd l%m&Z&dd l'm(Z(ddl)m*Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1ddl2m3Z3m4Z4m5Z5 ddl6m7Z8e8Z9n #e:$rdZ9YnwxYwerddl;miZ?e e&ej@ejAGddejBe1e,ZCe9e eCejDGdde-e.eCZEGddeCZFGdde+Z*e ejGGdde1eZHdS)z TCP support for IOCP reactor ) annotationsN) TYPE_CHECKINGOptionalUnion)classImplements implementer)addressdefererror interfacesmain) _LogOwner isIPv6Address) IPv4Address IPv6Address) IProtocol)abstract iocpsupport)ERROR_CONNECTION_REFUSEDERROR_IO_PENDINGERROR_NETWORK_UNREACHABLESO_UPDATE_ACCEPT_CONTEXTSO_UPDATE_CONNECT_CONTEXT)IReadWriteHandle)Protocol) Connector_AbortingMixin_BaseBaseClient_BaseTCPClient _getsockname _resolveIPv6 _SocketCloser)failurelogreflect)startTLS) IOCPReactorceZdZdZdZddZdZdZdZdZ d Z d Z d Z d Z d ZdZdZdZeddZdZdZddZdZdZdZdZdS) Connectionz @ivar TLS: C{False} to indicate the connection is in normal TCP mode, C{True} to indicate that TLS has been started and that operations must be routed through the L{TLSMemoryBIOProtocol} instance. FNcztj||||_|j|_||_dSN)r FileHandle__init__socketfileno getFileHandleprotocol)selfsockprotoreactors _/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/twisted/internet/iocpreactor/tcp.pyr-zConnection.__init__Fs7$$T7333 ![ c|jSr+)r.r2s r6 getHandlezConnection.getHandleLs {r7ct|trnDt|trt|}ntdt |z|j|dS)z` @param rbuffer: Data received. @type rbuffer: L{bytes} or L{bytearray} z%data must be bytes or bytearray, not N) isinstancebytes bytearray TypeErrortyper1 dataReceived)r2rbuffers r6rAzConnection.dataReceivedOsp gu % % U   + + UGnnGGCd7mmSTT T ""7+++++r7cRtj|||Sr+)_iocprecvr0)r2bufflistevts r6readFromHandlezConnection.readFromHandle^s"z$,,..#>>>r7ct|}tj||d|j|S)z Send C{buff} to current file handle using C{_iocp.send}. The buffer sent is limited to a size of C{self.SEND_LIMIT}. r) memoryviewrDsendr0 SEND_LIMITtobytes)r2buffrG writeViews r6 writeToHandlezConnection.writeToHandleasP t$$ z    )A,?"@"H"H"J"JC   r7c\ |jdn#t$rYnwxYwtj|jd}|rc |dS#t$r?tj }tj | |YdSwxYwdS)N) r.shutdownOSErrorr IHalfCloseableProtocolr1writeConnectionLost BaseExceptionr#Failurer$errconnectionLost)r2pfs r6_closeWriteConnectionz Connection._closeWriteConnectionks  K  # # # #    D   -dmT B B  ' '%%'''''  ' ' 'O%% ##A&&&&&& ' ' 's ** A AB)(B)c*tj|jd}|ra |dS#t$r=t j|tj YdSwxYw||dSr+) r rUr1readConnectionLostrWr$rYrZr#rX)r2reasonr[s r6r_zConnection.readConnectionLostys  -dmT B B  ( 7$$&&&&&  7 7 7 ##GO$5$5666666 7    ' ' ' ' 's4AA;:A;c|jrdStj|||dup|t j }|||j}|`|` |` ||dSr+) disconnectedrr,rZcheckr ConnectionAborted _closeSocketr1r.r0)r2r`isCleanr1s r6rZzConnection.connectionLosts    F**4888D.M U5L(M(M$M '"""= M K  '''''r7c|jS)zN Return the prefix to log with when I own the logging thread. )logstrr9s r6 logPrefixzConnection.logPrefix {r7czt|jtjtjSr+)boolr. getsockopt IPPROTO_TCP TCP_NODELAYr9s r6 getTcpNoDelayzConnection.getTcpNoDelays(DK**6+=v?QRRSSSr7cf|jtjtj|dSr+)r. setsockoptrnror2enableds r6 setTcpNoDelayzConnection.setTcpNoDelays( v163EwOOOOOr7czt|jtjtjSr+)rlr.rm SOL_SOCKET SO_KEEPALIVEr9s r6getTcpKeepAlivezConnection.getTcpKeepAlives(DK**6+QRRSSSr7cf|jtjtj|dSr+)r.rrrwrxrss r6setTcpKeepAlivezConnection.setTcpKeepAlives( v0&2EwOOOOOr7Tc>t|||tjdS)z9 @see: L{ITLSTransport.startTLS} N) _startTLSrr,)r2contextFactorynormals r6r&zConnection.startTLSs! dNFH4G H H H H Hr7c|jrdS|jr|j|dStj||dS)z Write some data, either directly to the underlying handle or, if TLS has been started, to the L{TLSMemoryBIOProtocol} for it to encrypt and send. @see: L{twisted.internet.interfaces.ITransport.write} N)rbTLSr1writerr,)r2datas r6rzConnection.writesY    F 8 2 M   % % % % %   % %dD 1 1 1 1 1r7c|jrdS|jr|j|dStj||dS)z Write some data, either directly to the underlying handle or, if TLS has been started, to the L{TLSMemoryBIOProtocol} for it to encrypt and send. @see: L{twisted.internet.interfaces.ITransport.writeSequence} N)rbrr1 writeSequencerr,)r2iovecs r6rzConnection.writeSequencesY    F 8 ; M ' ' . . . . .   - -dE : : : : :r7c|jr-|jr"|js|jdSdSdSt j||dS)z Close the underlying handle or, if TLS has been started, first shut it down. @see: L{twisted.internet.interfaces.ITransport.loseConnection} N)r connected disconnectingr1loseConnectionrr,)r2r`s r6rzConnection.loseConnectionsq 8 =~ /d&8 / ,,..... / / / /   . .tV < < < < +>r?+S+S&TUU      K " "!) C!3!3!5!566    !N88HHDM!DN**4=99I#i/DK}$!)  ##%%%%% ,,T222!!#####r7cbt|dsdStjsJ|j|tj|j|}tj|j |j |}|r$|tkr||d|dSdSdS)Nrr) hasattrrDhave_connectexr5addActiveHandleEventrconnectr.r/ realAddressr)r2rGrs r6 doConnectzClient.doConnectGst[))  F#### $$T***k$.$// ]4;--//1A3 G G  '"((( NN2q# & & & & & ' '((r7N)rrrrr.AF_INETr SOCK_STREAMr_tlsClientDefaultr)_commonConnectionr-rrrrrrr7r6rrs NM#J"SSSNNN,,,...$$$< ' ' ' ' 'r7rc2eZdZdZdZddZddZdZdZdS)ServeraV Serverside socket-stream connection class. I am a serverside network connection transport; a socket which came from an accept() on a server. @ivar _tlsClientDefault: Always C{False}, indicating that this is a server connection, and by default when TLS is negotiated this class will act as a TLS server. Fr3 socket.socketr1r clientAddrUnion[IPv4Address, IPv6Address] serverAddr sessionnointr5r'czt||||||_||_||_||j}|d|d|jj|_d |jj j |j|jj |_ d|_|dS)a  Server(sock, protocol, client, server, sessionno) Initialize me with a socket, a protocol, a descriptor for my peer (a tuple of host, port describing the other end of the connection), an instance of Port, and a session number. ,z<{} #{} on {}>TN)r)r-rrrrr1rrhformat __class__rrrepstrrr)r2r3r1rrrr5ris r6r-zServer.__init__cs D$':::$$"&&t}55 "GGYGG1EGG +22 M # , N O     r7returnstrc|jS)z= A string representation of this connection. )rr9s r6__repr__zServer.__repr__rjr7c|jS)zW Returns an IPv4Address. This indicates the server's address. )rr9s r6rzServer.getHost r7c|jS)zW Returns an IPv4Address. This indicates the client's address. )rr9s r6rzServer.getPeerrr7N) r3rr1rrrrrrrr5r'rr) rrrrrr-rrrrr7r6rrUsl  < r7rceZdZdZdS)rcPt|j|j|j||jSr+)rrrrr5r9s r6_makeTransportzConnector._makeTransports!diD,z<{} of {} (not listening)>)rrrrr9s r6rz Port.__repr__s]   +%,, &$  066 & r7cl |j|j|j}|jtjkrt |j|j}n|j|jf}| |n2#t$r%}tj |j|j|d}~wwxYwtj||_|d|_t'j||jd|j|j||jd|_d|_|j|||_|jj|_|dS)NrRz starting on TF)r5rrrr.rr!rrbindrTr CannotListenErrorrD maxAddrLenr/addrLen getsocknamerr$msgrrdoStartlistenrrrbrr0doAccept)r2sktaddrles r6startListeningzPort.startListenings I,++D,>PPC!V_44#DNDI>> 2 HHTNNNN I I I)$.$)RHH H I' 55  #003 !!$,////1E1E G    4<   ! $$T*** ![/ sA8A;; B* B%%B*cd|_|jr@tj|_|jd|j||jSdS)z Stop accepting connections on this port. This will shut down my socket and call self.connectionLost(). It returns a deferred which will fire successfully when the port is actually closed. TrN)rrr Deferreddeferredr5 callLaterrZ)r2connDones r6rzPort.loseConnectionsT" > !!N,,DM L " "1d&98 D D D=  ! !r7cPtjd|jd|jddS)z. Log message for closing port (z Port z Closed)N)r$r_typerr9s r6_logConnectionLostMsgzPort._logConnectionLostMsgs3 DDJDDd&:DDDEEEEEr7c|d|_d}t|dr |j}|`d|_|j|d|_|d|` |` |j d|_ ||ddSdS#t$r4d|_ |)|t#jYdSwxYw)z' Cleans up the socket. NrTF)rrrrrbr5rrrer.r0rdoStoprcallbackrWerrbackr#rX)r2r`ds r6rZzPort.connectionLosts ""$$$#  4 $ $  A   ''--- $ K   ! L   ! ! !"'D } 4     }   !&D } '/++,,,,,,  s9B449C20C2c>tj|jjS)zK Returns the name of my class, to prefix log entries with. )r%qualrrr9s r6rizPort.logPrefixs|DL2333r7cB|jdgt|jRS)zf Returns an IPv4Address or IPv6Address. This indicates the server's address. r)rr r.r9s r6rz Port.getHost#s) !t Cdk)B)BCCCCr7c~||||js|js|dSdSdSr+) handleAcceptrrbr)r2rrrGs r6cbAcceptz Port.cbAccept+sR "c"""" d&7  MMOOOOO    r7c 2|js|jrdS|r;tjdtj|dd|ddS|jtj ttj d|j tj|j|j\}}}||jksJd|dvr@t'|ddd }|d|d d|f}d|dvr@t'|ddd }|d|d d|f}|j|jd g|R}||jn\|j}|d z|_t5|j||jd g|R|jd g|R||j} || d S) NFz#Could not accept new connection -- z unknown errorz ()r%rrRrT)rrbr$rrrrnewsktrrr.rwrrrr/rDget_accept_addrsrNrrsplitrrrcloserrr5r) r2rrGfamilylAddrrAddrscoper1s transports r6r zPort.handleAccept0s;   !2 5 +  GG?&&r?;;;;RRRA   5 J ! !!( C!3!3!5!566    $)#9#*:K:K:M:Msx#X#X FE5T/////eAhE!HNN3//233q58Q6eAhE!HNN3//233q58Q6|112C$2CE2RE2R2R2RSSH   """"N!"Q"J%D%e4e444%D%e4e444L  '' 2224r7ctj|j|}td|jdzzx|_}|j|j|j x|_ }tj |j | ||}|r#|tkr|||dSdSdS)N)rDrrr>rrNr5rrrracceptr.r/rr )r2rGrNrrs r6rz Port.doAcceptcsk$-..$A):$;<<<4"l77      V\$+,,.. s K K  '"(((   b# & & & & & ' '((r7)rrNr)"rrrrrbrr.rrrrr rrrr__annotations__rr-rrr#rXr CONNECTION_DONEr stopListeningrrZrirrr rrr7r6rrs2ILMNM#J&LI&*O)))) E4444    @'6god6J&K&K ! ! ! !#MFFF !!!>444 DDD 111f ' ' ' ' 'r7r)Ir __future__rrr.rtypingrrrzope.interfacerrtwisted.internetr r r r r twisted.internet.abstractrrtwisted.internet.addressrrtwisted.internet.interfacesrtwisted.internet.iocpreactorrrrD"twisted.internet.iocpreactor.constrrrrr'twisted.internet.iocpreactor.interfacesrtwisted.internet.protocolrtwisted.internet.tcpr TCPConnectorrrrr r!r"twisted.pythonr#r$r%twisted.internet._newtlsr& __startTLSr} ImportError$twisted.internet.iocpreactor.reactorr'WSAECONNREFUSEDWSAENETUNREACHr ITCPTransport ISystemHandler,r) ITLSTransportrrIListeningPortrrr7r6r;s#""""" 111111111177777777DDDDDDDDDDDDDD>>>>>>>>========111111GGGGGGGGEDDDDD......1000000000??????IIIII A@@@@@@e3u3   z79QRRx x x x x $m^x x SRx v OJ 8999V'V'V'V'V'_njV'V'V'r@@@@@Z@@@FRRRRR RRR  Z &''Q'Q'Q'Q'Q'=)Q'Q'('Q'Q'Q's BBB