h1SrSSKrSSKrSSKrSSKrSSKrSSKrSSKJr SSK J r SSK J r J r Jr SSKJrJr SSKJr SSKJrJrJrJrJr SS KJrJr SS KJr SS KJ r SS K!J"r" SS K#J$r$J%r% /SQr&Sr'\RP"5S:XdJ\RP"5RSS5(d%\RP"5RSS5(aSr*Sr+OSr*Sr+Sr,"SS\5r-\"\R\5"SS\%\$55r/"SS\"SS55r0"SS \ 5r1"S!S"5r2\"\Rf5"S#S$\Rh55r5g)%zc Support for Linux ethernet and IP tunnel devices. @see: U{https://en.wikipedia.org/wiki/TUN/TAP} N) namedtuple)Tuple) Attribute Interface implementer) FlagConstantFlags)Version)abstractdefererror interfacestask)ethernetraw)log) deprecated)fullyQualifiedName) FancyEqMixin FancyStrMixin) TunnelFlags TunnelAddress TuntapPortpariscppcsparclTiT@iT@lTs /dev/net/tunc\rSrSrSr\"S5r\"S5r\"S5r\"S5r \"S5r \"S5r \"S 5r \"S 5r \"S 5r\"S 5r\"S 5r\"S5rSrg)r6aV L{TunnelFlags} defines more flags which are used to configure the behavior of a tunnel device. @cvar IFF_TUN: This indicates a I{tun}-type device. This type of tunnel carries IP datagrams. This flag is mutually exclusive with C{IFF_TAP}. @cvar IFF_TAP: This indicates a I{tap}-type device. This type of tunnel carries ethernet frames. This flag is mutually exclusive with C{IFF_TUN}. @cvar IFF_NO_PI: This indicates the I{protocol information} header will B{not} be included in data read from the tunnel. @see: U{https://www.kernel.org/doc/Documentation/networking/tuntap.txt} r @ii i@iN)__name__ __module__ __qualname____firstlineno____doc__rIFF_TUNIFF_TAP TUN_FASYNCTUN_NOCHECKSUM TUN_NO_PI TUN_ONE_QUEUE TUN_PERSIST TUN_VNET_HDR IFF_NO_PI IFF_ONE_QUEUE IFF_VNET_HDR IFF_TUN_EXCL__static_attributes__r'Z/root/1688_scrapy/alibaba-scraper/venv/lib/python3.13/site-packages/twisted/pair/tuntap.pyrr6s 6"G6"Gf%J!&)NV$I (Mv&K'LV$I (M'L'Lr:rcF\rSrSrSrSrSS4S4r\S5rSr S r S r g ) rWzM A L{TunnelAddress} represents the tunnel to which a L{TuntapPort} is bound. ) _typeValuenametypecUR$N)r?)flags r;TunnelAddress.^sDIIr:r?c.URR$)zu Return the integer value of the C{type} attribute. Used to produce correct results in the equality implementation. )r@valueselfs r;r>TunnelAddress._typeValue`syyr:cXlX lg)z @param type: Either L{TunnelFlags.IFF_TUN} or L{TunnelFlags.IFF_TAP}, representing the type of this tunnel. @param name: The system name of the tunnel. @type name: L{bytes} N)r@r?)rIr@r?s r;__init__TunnelAddress.__init__is  r:cX[R"S[SS9 SUR4U$)zC Deprecated accessor for the tunnel name. Use attributes instead. zUTunnelAddress.__getitem__ is deprecated since Twisted 14.0.0 Use attributes instead.r!)category stacklevelTUNTAP)warningswarnDeprecationWarningr?)rIindexs r; __getitem__TunnelAddress.__getitem__ts1   &'  $))$U++r:)r?r@N) r(r)r*r+r,compareAttributesshowAttributespropertyr>rLrVr9r'r:r;rrWs;/56?N   ,r:rc\rSrSrSrSrg)_TunnelDescriptionz Describe an existing tunnel. @ivar fileno: the file descriptor associated with the tunnel @type fileno: L{int} @ivar name: the name of the tunnel @type name: L{bytes} r'N)r(r)r*r+r,r9r'r:r;r\r\sr:r\z fileno namecz\rSrSrSr\"S5r\"S5r\"S5rSSjr SSjr S r S r S r S rS rSrg)_IInputOutputSystemz An interface for performing some basic kinds of I/O (particularly that I/O which might be useful for L{twisted.pair.tuntap}-using code). z@see: L{os.O_RDWR}z@see: L{os.O_NONBLOCK}z@see: L{os.O_CLOEXEC}cg)z @see: L{os.open} Nr')filenamerCmodes r;open_IInputOutputSystem.openr:Ncg)z @see: L{fcntl.ioctl} Nr')fdoptarg mutate_flags r;ioctl_IInputOutputSystem.ioctlrfr:cg)z @see: L{os.read} Nr')rhlimits r;read_IInputOutputSystem.readrfr:cg)z @see: L{os.write} Nr')rhdatas r;write_IInputOutputSystem.writerfr:cg)z @see: L{os.close} Nr')rhs r;close_IInputOutputSystem.closerfr:cg)aL Send a datagram to a certain address. @param datagram: The payload of a UDP datagram to send. @type datagram: L{bytes} @param address: The destination to which to send the datagram. @type address: L{tuple} of (L{bytes}, L{int}) @return: The local address from which the datagram was sent. @rtype: L{tuple} of (L{bytes}, L{int}) Nr')datagramaddresss r;sendUDP_IInputOutputSystem.sendUDPrfr:cg)a Return a socket which can be used to receive datagrams sent to the given address. @param fileno: A file descriptor representing a tunnel device which the datagram was either sent via or will be received via. @type fileno: L{int} @param host: The IPv4 address at which the datagram will be received. @type host: L{bytes} @param port: The UDP port number at which the datagram will be received. @type port: L{int} @return: A L{socket.socket} which can be used to receive the specified datagram. Nr')filenohostports r; receiveUDP_IInputOutputSystem.receiveUDPrfr:r')i)NN)r(r)r*r+r,rO_RDWR O_NONBLOCK O_CLOEXECrdrlrprtrwr|rr9r'r:r;r_r_sM + ,F34J12I       r:r_c\rSrSrSr\"\R5r\"\R5r\"\R5r \"\R5r \"\ R5r \Rr \Rr\"\SS5rSrg) _RealSystemz An interface to the parts of the operating system which L{TuntapPort} relies on. This is most of an implementation of L{_IInputOutputSystem}. rir'N)r(r)r*r+r, staticmethodosrdrprtrwfcntlrlrrgetattrrr9r'r:r;rrsq  D  D  "E  "E  %E YYFJK3Ir:rc\rSrSrSrSrSSjrS\4SjrSr S r S r S r S r S rSrSr\"\"SSSS5\5S5rSSjrSrSrSrg)rz@ A Port that reads and writes packets from/to a TUN/TAP-device. iNc [RRU5(aSUl[RUlOBSUl[R Ul[RRU5(deUc [5nXPl [RRX5 XlX lX0lUR#UR5nUSUR R$S3Ulg)Nr rz ())rIEthernetProtocol providedByrr._moder-rIRawPacketProtocolr_systemr FileDescriptorrL interfaceprotocol maxPacketSize _getLogPrefixr?logstr)rIrprotorreactorsystem logPrefixs r;rLTuntapPort.__init__s  % % 0 0 7 7DM$,,DJDM$,,DJ))44U;; ;; > ]F ((7" *&&t}}5 " 2djjoo%6a8 r:returnc[URR54nUR(aUS-nOUS-nXRR UR 4-nSU-$)N))znot z<%s %slistening on %s/%s>)rr __class__ connectedrr?r)rIargss r;__repr__TuntapPort.__repr__sW!3DMM4K4K!L N >>%s ||r:cPSnXR:alURRURUR5nU[U5- nURRUSS9 XR:aMkgg![ aHnUR [ R[ R[ R4;aSnAgeSnAf[a ef=f![a= [URR5n[ R""SSUS35 Nf=f)z- Called when my socket is ready for reading. rN)partialzUnhandled exception from z.datagramReceived) maxThroughputrrprrrerrno EWOULDBLOCKEAGAINEINTR BaseExceptionlenrdatagramReceivedrrrerr)rIrprsrclss r;doReadTuntapPort.doReadAs''' ||((t7I7IJ CI D R ..tQ.?''' 77u00%,, LL    ! R()@)@A 9#>OPQ Rs00A?C? C =C  C  CAD%$D%cURRURU5$![a:nUR[R :XaURU5sSnA$eSnAff=f)z Write the given data as a single datagram. @param datagram: The data that will make up the complete datagram to be written. @type datagram: L{bytes} N)rrtrrrr)rIrzrs r;rtTuntapPort.writeXsT <<%%dllH= = ww%++%zz(++  s %( A,.A' A,&A''A,cDURSRU55 g)z Write a datagram constructed from a L{list} of L{bytes}. @param seq: The data that will make up the complete datagram to be written. @type seq: L{list} of L{bytes} r:N)rtjoin)rIseqs r; writeSequenceTuntapPort.writeSequencegs 388C=!r:c2UR5 UR(a UR$UR(aD[R "UR SUR5UlSUlUR$[R"S5$)z Stop accepting connections on this port. This will shut down my socket and call self.connectionLost(). @return: A L{Deferred} that fires when this port has stopped. rTN) stopReading disconnecting_stoppedDeferredrr deferLaterrconnectionLostr succeedrHs r; stopListeningTuntapPort.stopListeningqss    (( ( ^^$(OO a!4!4%D !"&D (( (==& &r:Twistedrc^UR5R[R5 g)z> Close this tunnel. Use L{TuntapPort.stopListening} instead. N)r addErrbackrrrHs r;loseConnectionTuntapPort.loseConnections ''0r:c"[R"SUR-5 [RR X5 UR R5 SUlURRUR5 SUl g)zA Cleans up my socket. @param reason: Ignored. Do not use this. z(Tuntap %s Closed)rN) rrrr rrrdoStoprrrwr)rIreasons r;rTuntapPort.connectionLostsb $t~~56..t<  4<<( r:cUR$)z; Returns the name of my class, to prefix log entries with. )rrHs r;rTuntapPort.logPrefixs{{r:cB[URUR5$)z Get the local address of this L{TuntapPort}. @return: A L{TunnelAddress} which describes the tunnel device to which this object is bound. @rtype: L{TunnelAddress} )rrrrHs r;getHostTuntapPort.getHostsTZZ88r:) rrrrrrrrrrr)r&NNrB)r(r)r*r+r,rrLstrrrrrrrrtrrrr rrrrr9r'r:r;rrs~M9*2#2 M$*R. "'( 2q!,m<1=1  9r:r)6r,rrrplatformrrR collectionsrtypingrzope.interfacerrr constantlyrr incrementalr twisted.internetr r r rr twisted.pairrrtwisted.pythonrtwisted.python.deprecatertwisted.python.reflectrtwisted.python.utilrr__all__rmachine startswithr _TUNGETIFFrrIAddressrr\r_rIListeningPortrrr'r:r;rsE    "<<*EE&/5;    ("$$U++$$W--JJJJ (%(B Z !&,M<&,"&,R $8-H C )C L44& Z & &'@9((@9(@9r: