Gecko [ theprintave.ca ]

Name	Size	Permission	Date
__pycache__	[ DIR ]	drwxr-xr-x	2024-11-28 06:59
iocpreactor	[ DIR ]	drwxr-xr-x	2024-11-28 06:59
test	[ DIR ]	drwxr-xr-x	2024-11-28 06:59
__init__.py	521 B	-rw-r--r--	2022-02-07 13:12
_baseprocess.py	1.96 KB	-rw-r--r--	2022-02-07 13:12
_dumbwin32proc.py	12.48 KB	-rw-r--r--	2022-02-07 13:12
_glibbase.py	12.41 KB	-rw-r--r--	2022-02-07 13:12
_idna.py	1.39 KB	-rw-r--r--	2022-02-07 13:12
_newtls.py	8.94 KB	-rw-r--r--	2022-02-07 13:12
_pollingfile.py	8.58 KB	-rw-r--r--	2022-02-07 13:12
_posixserialport.py	2.03 KB	-rw-r--r--	2022-02-07 13:12
_posixstdio.py	4.88 KB	-rw-r--r--	2022-02-07 13:12
_producer_helpers.py	3.82 KB	-rw-r--r--	2022-02-07 13:12
_resolver.py	8.27 KB	-rw-r--r--	2022-02-07 13:12
_signals.py	2.61 KB	-rw-r--r--	2022-02-07 13:12
_sslverify.py	71.09 KB	-rw-r--r--	2022-02-07 13:12
_threadedselect.py	11.31 KB	-rw-r--r--	2022-02-07 13:12
_win32serialport.py	4.8 KB	-rw-r--r--	2022-02-07 13:12
_win32stdio.py	3.07 KB	-rw-r--r--	2022-02-07 13:12
abstract.py	18.84 KB	-rw-r--r--	2022-02-07 13:12
address.py	5.12 KB	-rw-r--r--	2024-11-22 17:49
asyncioreactor.py	10.87 KB	-rw-r--r--	2022-02-07 13:12
base.py	46.28 KB	-rw-r--r--	2022-02-07 13:12
cfreactor.py	17.09 KB	-rw-r--r--	2022-02-07 13:12
default.py	1.85 KB	-rw-r--r--	2022-02-07 13:12
defer.py	83.65 KB	-rw-r--r--	2024-11-22 17:49
endpoints.py	75.63 KB	-rw-r--r--	2022-02-07 13:12
epollreactor.py	8.73 KB	-rw-r--r--	2022-02-07 13:12
error.py	13.17 KB	-rw-r--r--	2022-02-07 13:12
fdesc.py	3.16 KB	-rw-r--r--	2022-02-07 13:12
gireactor.py	4.51 KB	-rw-r--r--	2022-02-07 13:12
glib2reactor.py	1.09 KB	-rw-r--r--	2022-02-07 13:12
gtk2reactor.py	3.55 KB	-rw-r--r--	2022-02-07 13:12
gtk3reactor.py	1.49 KB	-rw-r--r--	2022-02-07 13:12
inotify.py	14.06 KB	-rw-r--r--	2022-02-07 13:12
interfaces.py	95.75 KB	-rw-r--r--	2022-02-07 13:12
kqreactor.py	10.56 KB	-rw-r--r--	2022-02-07 13:12
main.py	1006 B	-rw-r--r--	2022-02-07 13:12
pollreactor.py	5.83 KB	-rw-r--r--	2022-02-07 13:12
posixbase.py	26.96 KB	-rw-r--r--	2022-02-07 13:12
process.py	37.61 KB	-rw-r--r--	2022-02-07 13:12
protocol.py	26.75 KB	-rw-r--r--	2022-02-07 13:12
pyuisupport.py	843 B	-rw-r--r--	2022-02-07 13:12
reactor.py	1.77 KB	-rw-r--r--	2022-02-07 13:12
selectreactor.py	5.96 KB	-rw-r--r--	2022-02-07 13:12
serialport.py	2.22 KB	-rw-r--r--	2022-02-07 13:12
ssl.py	8.44 KB	-rw-r--r--	2022-02-07 13:12
stdio.py	1000 B	-rw-r--r--	2022-02-07 13:12
task.py	32.82 KB	-rw-r--r--	2022-02-07 13:12
tcp.py	53.69 KB	-rw-r--r--	2024-11-22 17:49
testing.py	28.55 KB	-rw-r--r--	2022-02-07 13:12
threads.py	3.72 KB	-rw-r--r--	2022-02-07 13:12
tksupport.py	1.92 KB	-rw-r--r--	2022-02-07 13:12
udp.py	18.18 KB	-rw-r--r--	2022-02-07 13:12
unix.py	21.98 KB	-rw-r--r--	2022-02-07 13:12
utils.py	8.48 KB	-rw-r--r--	2022-02-07 13:12
win32eventreactor.py	14.91 KB	-rw-r--r--	2022-02-07 13:12
wxreactor.py	5.19 KB	-rw-r--r--	2022-02-07 13:12
wxsupport.py	1.27 KB	-rw-r--r--	2022-02-07 13:12

Rename

# -*- test-case-name: twisted.internet.test.test_resolver -*-
# Copyright (c) Twisted Matrix Laboratories.
# See LICENSE for details.

"""
IPv6-aware hostname resolution.

@see: L{IHostnameResolver}
"""

from socket import (
    AF_INET,
    AF_INET6,
    AF_UNSPEC,
    SOCK_DGRAM,
    SOCK_STREAM,
    gaierror,
    getaddrinfo,
)

from zope.interface import implementer

from twisted.internet._idna import _idnaBytes
from twisted.internet.address import IPv4Address, IPv6Address
from twisted.internet.defer import Deferred
from twisted.internet.error import DNSLookupError
from twisted.internet.interfaces import (
    IHostnameResolver,
    IHostResolution,
    IResolutionReceiver,
    IResolverSimple,
)
from twisted.internet.threads import deferToThreadPool
from twisted.logger import Logger
from twisted.python.compat import nativeString

@implementer(IHostResolution)
class HostResolution:
    """
    The in-progress resolution of a given hostname.
    """

def __init__(self, name):
        """
        Create a L{HostResolution} with the given name.
        """
        self.name = name

def cancel(self):
        # IHostResolution.cancel
        raise NotImplementedError()

_any = frozenset([IPv4Address, IPv6Address])

_typesToAF = {
    frozenset([IPv4Address]): AF_INET,
    frozenset([IPv6Address]): AF_INET6,
    _any: AF_UNSPEC,
}

_afToType = {
    AF_INET: IPv4Address,
    AF_INET6: IPv6Address,
}

_transportToSocket = {
    "TCP": SOCK_STREAM,
    "UDP": SOCK_DGRAM,
}

_socktypeToType = {
    SOCK_STREAM: "TCP",
    SOCK_DGRAM: "UDP",
}

@implementer(IHostnameResolver)
class GAIResolver:
    """
    L{IHostnameResolver} implementation that resolves hostnames by calling
    L{getaddrinfo} in a thread.
    """

def __init__(self, reactor, getThreadPool=None, getaddrinfo=getaddrinfo):
        """
        Create a L{GAIResolver}.

@param reactor: the reactor to schedule result-delivery on
        @type reactor: L{IReactorThreads}

@param getThreadPool: a function to retrieve the thread pool to use for
            scheduling name resolutions.  If not supplied, the use the given
            C{reactor}'s thread pool.
        @type getThreadPool: 0-argument callable returning a
            L{twisted.python.threadpool.ThreadPool}

@param getaddrinfo: a reference to the L{getaddrinfo} to use - mainly
            parameterized for testing.
        @type getaddrinfo: callable with the same signature as L{getaddrinfo}
        """
        self._reactor = reactor
        self._getThreadPool = (
            reactor.getThreadPool if getThreadPool is None else getThreadPool
        )
        self._getaddrinfo = getaddrinfo

def resolveHostName(
        self,
        resolutionReceiver,
        hostName,
        portNumber=0,
        addressTypes=None,
        transportSemantics="TCP",
    ):
        """
        See L{IHostnameResolver.resolveHostName}

@param resolutionReceiver: see interface

@param hostName: see interface

@param portNumber: see interface

@param addressTypes: see interface

@param transportSemantics: see interface

@return: see interface
        """
        pool = self._getThreadPool()
        addressFamily = _typesToAF[
            _any if addressTypes is None else frozenset(addressTypes)
        ]
        socketType = _transportToSocket[transportSemantics]

def get():
            try:
                return self._getaddrinfo(
                    hostName, portNumber, addressFamily, socketType
                )
            except gaierror:
                return []

d = deferToThreadPool(self._reactor, pool, get)
        resolution = HostResolution(hostName)
        resolutionReceiver.resolutionBegan(resolution)

@d.addCallback
        def deliverResults(result):
            for family, socktype, proto, cannoname, sockaddr in result:
                addrType = _afToType[family]
                resolutionReceiver.addressResolved(
                    addrType(_socktypeToType.get(socktype, "TCP"), *sockaddr)
                )
            resolutionReceiver.resolutionComplete()

return resolution

@implementer(IHostnameResolver)
class SimpleResolverComplexifier:
    """
    A converter from L{IResolverSimple} to L{IHostnameResolver}.
    """

_log = Logger()

def __init__(self, simpleResolver):
        """
        Construct a L{SimpleResolverComplexifier} with an L{IResolverSimple}.
        """
        self._simpleResolver = simpleResolver

@param resolutionReceiver: see interface

@param hostName: see interface

@param portNumber: see interface

@param addressTypes: see interface

@param transportSemantics: see interface

@return: see interface
        """
        # If it's str, we need to make sure that it's just ASCII.
        try:
            hostName = hostName.encode("ascii")
        except UnicodeEncodeError:
            # If it's not just ASCII, IDNA it. We don't want to give a Unicode
            # string with non-ASCII in it to Python 3, as if anyone passes that
            # to a Python 3 stdlib function, it will probably use the wrong
            # IDNA version and break absolutely everything
            hostName = _idnaBytes(hostName)

# Make sure it's passed down as a native str, to maintain the interface
        hostName = nativeString(hostName)

resolution = HostResolution(hostName)
        resolutionReceiver.resolutionBegan(resolution)
        onAddress = self._simpleResolver.getHostByName(hostName)

def addressReceived(address):
            resolutionReceiver.addressResolved(IPv4Address("TCP", address, portNumber))

def errorReceived(error):
            if not error.check(DNSLookupError):
                self._log.failure(
                    "while looking up {name} with {resolver}",
                    error,
                    name=hostName,
                    resolver=self._simpleResolver,
                )

onAddress.addCallbacks(addressReceived, errorReceived)

def finish(result):
            resolutionReceiver.resolutionComplete()

onAddress.addCallback(finish)
        return resolution

@implementer(IResolutionReceiver)
class FirstOneWins:
    """
    An L{IResolutionReceiver} which fires a L{Deferred} with its first result.
    """

def __init__(self, deferred):
        """
        @param deferred: The L{Deferred} to fire when the first resolution
            result arrives.
        """
        self._deferred = deferred
        self._resolved = False

def resolutionBegan(self, resolution):
        """
        See L{IResolutionReceiver.resolutionBegan}

@param resolution: See L{IResolutionReceiver.resolutionBegan}
        """
        self._resolution = resolution

def addressResolved(self, address):
        """
        See L{IResolutionReceiver.addressResolved}

@param address: See L{IResolutionReceiver.addressResolved}
        """
        if self._resolved:
            return
        self._resolved = True
        self._deferred.callback(address.host)

def resolutionComplete(self):
        """
        See L{IResolutionReceiver.resolutionComplete}
        """
        if self._resolved:
            return
        self._deferred.errback(DNSLookupError(self._resolution.name))

@implementer(IResolverSimple)
class ComplexResolverSimplifier:
    """
    A converter from L{IHostnameResolver} to L{IResolverSimple}
    """

def __init__(self, nameResolver):
        """
        Create a L{ComplexResolverSimplifier} with an L{IHostnameResolver}.

@param nameResolver: The L{IHostnameResolver} to use.
        """
        self._nameResolver = nameResolver

def getHostByName(self, name, timeouts=()):
        """
        See L{IResolverSimple.getHostByName}

@param name: see L{IResolverSimple.getHostByName}

@param timeouts: see L{IResolverSimple.getHostByName}

@return: see L{IResolverSimple.getHostByName}
        """
        result = Deferred()
        self._nameResolver.resolveHostName(FirstOneWins(result), name, 0, [IPv4Address])
        return result