֛hkOSrSSKJr SSKrSSKrSSKrSSKJrJrJ r SSK J r J r SSK JrJrJrJrJr SSKJrJr SSKJrJr SS KJr SS KJrJr SS KJ r J!r!J"r"J#r#J$r$ SS K%J&r& SS K'J(r( SSK)J*r+J,r,J-r-J.r.J/r/J0r0J1r1 SSK2J3r3J4r4J5r5 SSK6J7r8 \8r9\(aSSK;J>r9c[U5n[R"UR5USURR 5U5$)zv 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) memoryviewrHsendr1 SEND_LIMITtobytes)r3buffrK writeViews r7 writeToHandleConnection.writeToHandleasC t$ zz    )A"@"H"H"JC  r9cfURRS5 [R"UR S5nU(aUR 5 gg![a NGf=f![a> [R"5n[R"5 URU5 gf=f)N) r/shutdownOSErrorr IHalfCloseableProtocolr2writeConnectionLost BaseExceptionr#Failurer$errconnectionLost)r3pfs r7_closeWriteConnection Connection._closeWriteConnectionks  KK  #  - -dmmT B  '%%'     ! 'OO% ##A& 's$AA( A%$A%(AB0/B0c,[R"URS5nU(aUR5 gURU5 g![a< [ R "5 UR[R"55 gf=fr,) r r[r2readConnectionLostr]r$r_r`r#r^)r3reasonras r7rfConnection.readConnectionLostysk  - -dmmT B  7$$&    ' ! 7 ##GOO$56 7sA ABBc,UR(ag[RRX5 USL=(d$ UR [ R 5(+nURU5 URnU?U? U? URU5 gr,) disconnectedrr-r`checkr ConnectionAborted _closeSocketr2r/r1)r3rgisCleanr2s r7r`Connection.connectionLostsw    **48D.M U5L5L(M$M '"== M K  'r9cUR$)z> Return the prefix to log with when I own the logging thread. )logstrr;s r7 logPrefixConnection.logPrefix{{r9c[URR[R[R55$r,)boolr/ getsockopt IPPROTO_TCP TCP_NODELAYr;s r7 getTcpNoDelayConnection.getTcpNoDelays*DKK**6+=+=v?Q?QRSSr9cvURR[R[RU5 gr,)r/ setsockoptrxryr3enableds r7 setTcpNoDelayConnection.setTcpNoDelays$ v1163E3EwOr9c[URR[R[R55$r,)rvr/rw SOL_SOCKET SO_KEEPALIVEr;s r7getTcpKeepAliveConnection.getTcpKeepAlives*DKK**6+<+Q>QRSSr9cvURR[R[RU5 gr,)r/r}rrr~s r7setTcpKeepAliveConnection.setTcpKeepAlives$ v00&2E2EwOr9c:[XU[R5 g)z! @see: L{ITLSTransport.startTLS} N) _startTLSrr-)r3contextFactorynormals r7r&Connection.startTLSs dFH4G4G Hr9cUR(agUR(aURRU5 g[R RX5 g)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)rjTLSr2writerr-)r3datas r7rConnection.writes=     88 MM   %    % %d 1r9cUR(agUR(aURRU5 g[R RX5 g)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)rjrr2 writeSequencerr-)r3iovecs r7rConnection.writeSequences=     88 MM ' ' .    - -d :r9cUR(a?UR(a-UR(dURR 5 ggg[ R R X5 g)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 disconnectingr2loseConnectionrr-)r3rgs r7rConnection.loseConnectionsG 88~~d&8&8 ,,.'9~    . .t +>r?+S&TU  KK " "!!) C!3!3!56  !NN88HDM!DN**4==9I#i/DK}}$!)  ##% ,,T2!!#r9c[US5(dg[R(deURR U5 [R "UR U5n[R"URR5URU5nU(aU[:waUR USU5 ggg)Nrr) hasattrrHhave_connectexr6addActiveHandleEventrconnectr/r0 realAddressr)r3rKrs r7 doConnectClient.doConnectGst[)) #### $$T*kk$..$/ ]]4;;--/1A1A3 G "(( NN2q# &)2r9)rrqr2r6N)rrrrrr/AF_INETr SOCK_STREAMr_tlsClientDefaultr)_commonConnectionr.rrrrrrrr9r7rrsI NNM##J"SN,.$< 'r9rcT\rSrSrSrSrS SjrS SjrSrSr Sr g ) ServeriUa: 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. Fc[RXX&5 X@lX0lXPlUR UR 5nUSUSURR3UlSRUR RRURURR5Ul SUlUR5 g)z 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. serverAddr clientAddr sessionnorr2rrqformat __class__rrrepstrrr)r3r4r2rrrr6rrs r7r.Server.__init__cs D:$$"&&t}}5 " 1YKq1E1E0FG +22 MM # # , , NN OO    r9cUR$)z- A string representation of this connection. )rr;s r7__repr__Server.__repr__rtr9cUR$)z? Returns an IPv4Address. This indicates the server's address. )rr;s r7rServer.getHost r9cUR$)z? Returns an IPv4Address. This indicates the client's address. )rr;s r7rServer.getPeerrr9)rrrqrrrN) r4z socket.socketr2rrUnion[IPv4Address, IPv6Address]rrrintr6r'returnstr) rrrrrrr.rrrrrr9r7rrUs] 4  4   < r9rc\rSrSrSrSrg)ricn[URURURXR5$r,)rrrrr6r;s r7_makeTransportConnector._makeTransports%diiD,<,z<{} of {} (not listening)>)rrrr r;s r7r Port.__repr__sg    +%,, &&$$  066 && r9cURRURUR5nUR[R :Xa![ URUR5nOURUR4nURU5 [R"UR55UlUR#5SUl[&R("UR+UR,5<SUR$<35 UR,R/5 UR1UR25 SUlSUlURR9U5 XlURRUlUR=5 g![a1n[R"URURU5eSnAff=f)NrXz starting on TF)r6rrrr/r r!r rbindrZr CannotListenErrorrH maxAddrLenr0addrLen getsocknamerr$msgrr doStartlistenr rrjrr1doAccept)r3sktaddrles r7startListeningPort.startListenings[ I,,++D,>,>PC!!V__4#DNNDII> 2 HHTN'' 5  #03 !!$,,/1E1E G  4<< ! $$T* ![[// + I))$..$))RH H IsBF++ G&5,G!!G&cSUlUR(aM[R"5UlUR R SURU5 UR$g)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 Deferreddeferredr6 callLaterr`)r3connDones r7rPort.loseConnectionsL" >>!NN,DM LL " "1d&9&98 D==  r9cf[R"SURSURS35 g)z Log message for closing port (z Port z Closed)N)r$r_typerr;s r7_logConnectionLostMsgPort._logConnectionLostMsgs* !DJJ[R"S[R R US5<SU<S35 gURR[R[[R"SURR555 [R "URR5UR"5up4nX0R$:XdeSUS;a,['USR)S5S 5nUSUS SU4nSUS;a,['USR)S5S 5nUSUS SU4nUR*R-UR."S /UQ765nUcURR15 g UR2nUS -Ul[5URUUR."S /UQ76UR."S /UQ76UUR65n UR9U 5 g ) NFz#Could not accept new connection -- z unknown errorz ()r%rrXrT)rrjr$rrrrnewsktr}r/rrrrr0rHget_accept_addrsrSrrsplitr rr closerrr6r) r3rrKfamilylAddrrAddrscoper2s transports r7r7Port.handleAccept0s   !2!2  GG??&&r?;RA  JJ ! !!!( C!3!3!56  $)#9#9#**:K:K:Msxx#X F5/// //eAhE!HNN3/23q58Q6eAhE!HNN3/23q58Q6||11$2C2CE2RE2RSH   "NN!"Q"JJ%%e4e4%%e4e4LL  '' 2r9c[R"URU5n[SURS--5=UlnUR RURUR5=Ul n[R"URR5UR5X!5nU(aU[:waURXA5 ggg)N)rHrr8rArrSr6rrrr=acceptr/r0rr7)r3rKrSr=rs r7r Port.doAcceptcskk$--.$A):$;<<4"ll77      V\\$++,,.  K "((   b &)2r9)r rrrr rr"rjrr r1r rr6rr/)2rNr)$rrrrrrjrr/rrrrr rr rr__annotations__r(r.rrr#r^r CONNECTION_DONEr stopListeningr)r`rrrr8r7rrrr9r7rrsILMNNM##J&&LI&*O]) E4 @'.ood6J6J&K !#MF !>4 D 1f 'r9r)Ir __future__rrr/rtypingrrrzope.interfacerrtwisted.internetr r r r r twisted.internet.abstractrrtwisted.internet.addressrrtwisted.internet.interfacesrtwisted.internet.iocpreactorrrrH"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) ITLSTransportrrIListeningPortrrr9r7ris[# 117DD>=1GE.10?I@e33u33  z779Q9QRx $$m^x Sx v J 8 89V'_njV'r@Z@FR R  Z & &'Q'=)Q'(Q'e Is E EE