+ jkORt^RIHt^RIt^RIt^RIt^RIHtHtH t ^RI H t H t ^RI HtHtHtHtHt^RIHtHt^RIHtHt^RIHt^R IHtHt^R IH t H!t!H"t"H#t#H$t$^R I%H&t&^R I'H(t(^R I)H*t+H,t,H-t-H.t.H/t/H0t0H1t1^RI2H3t3H4t4H5t5^RI6H7t8]8t9]'d^RI;H>r7c \V4p\P!VP4V^VPP 4V4#)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}. ) memoryviewrFsendr/ SEND_LIMITtobytes)r1buffrI writeViews&&& r5 writeToHandleConnection.writeToHandleasC t$ zz    )A"@"H"H"JC  r7c rVPP^4\P!VP R4pV'dVP 4R#R# \dLKi;i \d@\P!4p\P!4TPT4R#i;i)N) r-shutdownOSErrorr IHalfCloseableProtocolr0writeConnectionLost BaseExceptionr"Failurer#errconnectionLost)r1pfs& r5_closeWriteConnection Connection._closeWriteConnectionks  KK  #  - -dmmT B  '%%'     ! 'OO% ##A& 's$AA, A)(A),AB65B6c 6\P!VPR4pV'dVP4R#VPV4R# \d>\ P !4TP\P!44R#i;ir*) r rYr0readConnectionLostr[r#r]r^r"r\)r1reasonr_s&& r5rdConnection.readConnectionLostysk  - -dmmT B  7$$&    ' ! 7 ##GOO$56 7sAABBc 4VP'dR#\PPW4VRJ;'g%VP \ P 4'*pVPV4VPpV=V= V= VPV4R#r*) disconnectedrr+r^checkr ConnectionAborted _closeSocketr0r-r/)r1reisCleanr0s&& r5r^Connection.connectionLosts}     **48D.MM U5L5L(M$M '"== M K  'r7c VP#)z> Return the prefix to log with when I own the logging thread. )logstrr9s&r5 logPrefixConnection.logPrefix{{r7c \VPP\P\P44#r*)boolr- getsockopt IPPROTO_TCP TCP_NODELAYr9s&r5 getTcpNoDelayConnection.getTcpNoDelays*DKK**6+=+=v?Q?QRSSr7c xVPP\P\PV4R#r*)r- setsockoptrvrwr1enableds&&r5 setTcpNoDelayConnection.setTcpNoDelays$ v1163E3EwOr7c \VPP\P\P44#r*)rtr-ru SOL_SOCKET SO_KEEPALIVEr9s&r5getTcpKeepAliveConnection.getTcpKeepAlives*DKK**6+<+Q>QRSSr7c xVPP\P\PV4R#r*)r-r{rrr|s&&r5setTcpKeepAliveConnection.setTcpKeepAlives$ v00&2E2EwOr7c <\WV\P4R#)z! @see: L{ITLSTransport.startTLS} N) _startTLSrr+)r1contextFactorynormals&&&r5r%Connection.startTLSs dFH4G4G Hr7c VP'dR#VP'dVPPV4R#\P PW4R#)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)rhTLSr0writerr+)r1datas&&r5rConnection.writesB      888 MM   %    % %d 1r7c VP'dR#VP'dVPPV4R#\P PW4R#)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)rhrr0 writeSequencerr+)r1iovecs&&r5rConnection.writeSequencesB      888 MM ' ' .    - -d :r7c VP'dEVP'd1VP'gVPP 4R#R#R#\ P P W4R#)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 disconnectingr0loseConnectionrr+)r1res&&r5rConnection.loseConnectionsN 888~~~d&8&8&8 ,,.'9~    . .t +>r?+S&TU  KK " "!!) C!3!3!56  !NN88HDM!DN**4==9I#i/DK}}$!)  ##% ,,T2!!#r7c \VR4'gR#\P'gQhVPP V4\P !VP V4p\P!VPP4VPV4pV'd#V\8wdVP V^V4R#R#R#)rN) hasattrrFhave_connectexr4addActiveHandleEventrconnectr-r. realAddressr)r1rIrs& r5 doConnectClient.doConnectGst[)) ##### $$T*kk$..$/ ]]4;;--/1A1A3 G "(( NN2q# &)2r7)rror0r4N)rrrrrr-AF_INETr SOCK_STREAMr_tlsClientDefaultr(_commonConnectionr,rrrrrrrr7r5rrsI NNM##J"SN,.$< 'r7rcB]tRtRtRtRtRRltRRltRtR t R t R #) 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 0V^8dQhRRRRRRRRRR R R /#) r2z socket.socketr0r clientAddrzUnion[IPv4Address, IPv6Address] serverAddr sessionnointr4r&r)formats"r5 __annotate__Server.__annotate__csF4  4   r7c \PWW&4W@nW0nWPnVP VP 4pV RV RVPP 2VnRPVP PPVPVPP4Vn RVnVP4R#)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,rrrrr0rror __class__rrrepstrrr)r1r2r0rrrr4rps&&&&&&& r5r,Server.__init__cs D:$$"&&t}}5 " 1YKq1E1E0FG +22 MM # # , , NN OO    r7cV^8dQhRR/#rreturnstrr)rs"r5rrs#r7c VP#)z- A string representation of this connection. )rr9s&r5__repr__Server.__repr__rrr7c VP#)z? Returns an IPv4Address. This indicates the server's address. )rr9s&r5rServer.getHost r7c VP#)z? Returns an IPv4Address. This indicates the client's address. )rr9s&r5rServer.getPeerrr7)rrrorrrN) rrrrrrr,rrrrrr7r5rrUs# < r7rc]tRtRtRtRtR#)ric n\VPVPVPWP4#r*)rrrrr4r9s&r5_makeTransportConnector._makeTransports%diiD,<,z<{} of {} (not listening)>)rrrr r9s&r5r Port.__repr__sg    +%,, &&$$  066 && r7c VPPVPVP4pVP\P 8Xd"\ VPVP4pMVPVP3pVPV4\P!TP44TnTP#4^,Tn\&P(!TP+TP,4: RTP$: 24TP,P/4TP1TP24RTnRTnTPP9T4YnTPPTnTP=4R# \d2p\P!TPTPT4hRp?ii;i)Nz starting on TF)r4rrrr-rr r rbindrXr CannotListenErrorrF maxAddrLenr.addrLen getsocknamerr#msgrr doStartlistenr rrhrr/doAccept)r1sktaddrles& r5startListeningPort.startListenings[ I,,++D,>,>PC!!V__4#DNNDII> 2 HHTN'' 5  #03 !!$,,/1E1E G  4<< ! $$T* ![[// + I))$..$))RH H IsBF11 G-<,G((G-c RVnVP'dN\P!4VnVP P ^VPV4VP#R#)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. TN)rrr Deferreddeferredr4 callLaterr^)r1connDones&&r5rPort.loseConnectionsN" >>>!NN,DM LL " "1d&9&98 D==  r7c h\P!RVP RVP R24R#)z Log message for closing port (z Port z Closed)N)r#r_typerr9s&r5_logConnectionLostMsgPort._logConnectionLostMsgs* !DJJ4 D 1f 'r7r)Ir __future__rrr-rtypingrrrzope.interfacerrtwisted.internetrr r r r twisted.internet.abstractr rtwisted.internet.addressrrtwisted.internet.interfacesrtwisted.internet.iocpreactorrrrF"twisted.internet.iocpreactor.constrrrrr'twisted.internet.iocpreactor.interfacesrtwisted.internet.protocolrtwisted.internet.tcpr TCPConnectorrrrrr r!twisted.pythonr"r#r$twisted.internet._newtlsr% __startTLSr ImportError$twisted.internet.iocpreactor.reactorr&WSAECONNREFUSEDWSAENETUNREACHr ITCPTransport ISystemHandler+r( ITLSTransportrrIListeningPortrrr7r5rks[# 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