ULTRA [ growontech.com ]

Linux premium216.web-hosting.com 4.18.0-513.18.1.lve.el8.x86_64 #1 SMP Thu Feb 22 12:55:50 UTC 2024 x86_64

LiteSpeed

66.29.141.148 | Your IP: 18.219.18.238

Cant read [ /etc/named.conf ]

[ drwxr-xr-x ]

/ opt / hc_python / lib / python3.8 / site-packages / dns /

Home Upload Mass Deface Mass Delete Back Connect Notify

_trio_backend.py

# Copyright (C) Dnspython Contributors, see LICENSE for text of ISC license

"""trio async I/O library query support"""

import socket

import trio
import trio.socket  # type: ignore

import dns._asyncbackend
import dns._features
import dns.exception
import dns.inet

if not dns._features.have("trio"):
    raise ImportError("trio not found or too old")

def _maybe_timeout(timeout):
    if timeout is not None:
        return trio.move_on_after(timeout)
    else:
        return dns._asyncbackend.NullContext()

# for brevity
_lltuple = dns.inet.low_level_address_tuple

# pylint: disable=redefined-outer-name

class DatagramSocket(dns._asyncbackend.DatagramSocket):
    def __init__(self, socket):
        super().__init__(socket.family)
        self.socket = socket

async def sendto(self, what, destination, timeout):
        with _maybe_timeout(timeout):
            return await self.socket.sendto(what, destination)
        raise dns.exception.Timeout(
            timeout=timeout
        )  # pragma: no cover  lgtm[py/unreachable-statement]

async def recvfrom(self, size, timeout):
        with _maybe_timeout(timeout):
            return await self.socket.recvfrom(size)
        raise dns.exception.Timeout(timeout=timeout)  # lgtm[py/unreachable-statement]

async def close(self):
        self.socket.close()

async def getpeername(self):
        return self.socket.getpeername()

async def getsockname(self):
        return self.socket.getsockname()

async def getpeercert(self, timeout):
        raise NotImplementedError

class StreamSocket(dns._asyncbackend.StreamSocket):
    def __init__(self, family, stream, tls=False):
        self.family = family
        self.stream = stream
        self.tls = tls

async def sendall(self, what, timeout):
        with _maybe_timeout(timeout):
            return await self.stream.send_all(what)
        raise dns.exception.Timeout(timeout=timeout)  # lgtm[py/unreachable-statement]

async def recv(self, size, timeout):
        with _maybe_timeout(timeout):
            return await self.stream.receive_some(size)
        raise dns.exception.Timeout(timeout=timeout)  # lgtm[py/unreachable-statement]

async def close(self):
        await self.stream.aclose()

async def getpeername(self):
        if self.tls:
            return self.stream.transport_stream.socket.getpeername()
        else:
            return self.stream.socket.getpeername()

async def getsockname(self):
        if self.tls:
            return self.stream.transport_stream.socket.getsockname()
        else:
            return self.stream.socket.getsockname()

async def getpeercert(self, timeout):
        if self.tls:
            with _maybe_timeout(timeout):
                await self.stream.do_handshake()
            return self.stream.getpeercert()
        else:
            raise NotImplementedError

if dns._features.have("doh"):
    import httpcore
    import httpcore._backends.trio
    import httpx

_CoreAsyncNetworkBackend = httpcore.AsyncNetworkBackend
    _CoreTrioStream = httpcore._backends.trio.TrioStream

from dns.query import _compute_times, _expiration_for_this_attempt, _remaining

class _NetworkBackend(_CoreAsyncNetworkBackend):
        def __init__(self, resolver, local_port, bootstrap_address, family):
            super().__init__()
            self._local_port = local_port
            self._resolver = resolver
            self._bootstrap_address = bootstrap_address
            self._family = family

async def connect_tcp(
            self, host, port, timeout, local_address, socket_options=None
        ):  # pylint: disable=signature-differs
            addresses = []
            _, expiration = _compute_times(timeout)
            if dns.inet.is_address(host):
                addresses.append(host)
            elif self._bootstrap_address is not None:
                addresses.append(self._bootstrap_address)
            else:
                timeout = _remaining(expiration)
                family = self._family
                if local_address:
                    family = dns.inet.af_for_address(local_address)
                answers = await self._resolver.resolve_name(
                    host, family=family, lifetime=timeout
                )
                addresses = answers.addresses()
            for address in addresses:
                try:
                    af = dns.inet.af_for_address(address)
                    if local_address is not None or self._local_port != 0:
                        source = (local_address, self._local_port)
                    else:
                        source = None
                    destination = (address, port)
                    attempt_expiration = _expiration_for_this_attempt(2.0, expiration)
                    timeout = _remaining(attempt_expiration)
                    sock = await Backend().make_socket(
                        af, socket.SOCK_STREAM, 0, source, destination, timeout
                    )
                    return _CoreTrioStream(sock.stream)
                except Exception:
                    continue
            raise httpcore.ConnectError

async def connect_unix_socket(
            self, path, timeout, socket_options=None
        ):  # pylint: disable=signature-differs
            raise NotImplementedError

async def sleep(self, seconds):  # pylint: disable=signature-differs
            await trio.sleep(seconds)

class _HTTPTransport(httpx.AsyncHTTPTransport):
        def __init__(
            self,
            *args,
            local_port=0,
            bootstrap_address=None,
            resolver=None,
            family=socket.AF_UNSPEC,
            **kwargs,
        ):
            if resolver is None:
                # pylint: disable=import-outside-toplevel,redefined-outer-name
                import dns.asyncresolver

resolver = dns.asyncresolver.Resolver()
            super().__init__(*args, **kwargs)
            self._pool._network_backend = _NetworkBackend(
                resolver, local_port, bootstrap_address, family
            )

else:
    _HTTPTransport = dns._asyncbackend.NullTransport  # type: ignore

class Backend(dns._asyncbackend.Backend):
    def name(self):
        return "trio"

async def make_socket(
        self,
        af,
        socktype,
        proto=0,
        source=None,
        destination=None,
        timeout=None,
        ssl_context=None,
        server_hostname=None,
    ):
        s = trio.socket.socket(af, socktype, proto)
        stream = None
        try:
            if source:
                await s.bind(_lltuple(source, af))
            if socktype == socket.SOCK_STREAM:
                connected = False
                with _maybe_timeout(timeout):
                    await s.connect(_lltuple(destination, af))
                    connected = True
                if not connected:
                    raise dns.exception.Timeout(
                        timeout=timeout
                    )  # lgtm[py/unreachable-statement]
        except Exception:  # pragma: no cover
            s.close()
            raise
        if socktype == socket.SOCK_DGRAM:
            return DatagramSocket(s)
        elif socktype == socket.SOCK_STREAM:
            stream = trio.SocketStream(s)
            tls = False
            if ssl_context:
                tls = True
                try:
                    stream = trio.SSLStream(
                        stream, ssl_context, server_hostname=server_hostname
                    )
                except Exception:  # pragma: no cover
                    await stream.aclose()
                    raise
            return StreamSocket(af, stream, tls)
        raise NotImplementedError(
            "unsupported socket " + f"type {socktype}"
        )  # pragma: no cover

async def sleep(self, interval):
        await trio.sleep(interval)

def get_transport_class(self):
        return _HTTPTransport

async def wait_for(self, awaitable, timeout):
        with _maybe_timeout(timeout):
            return await awaitable
        raise dns.exception.Timeout(
            timeout=timeout
        )  # pragma: no cover  lgtm[py/unreachable-statement]

Name	Type	Size	Owner/Group	Permission	Last Modified	Actions
.	dir	-	root/root	drwxr-xr-x	2024-08-19 05:31:25
..	dir	-	root/root	drwxr-xr-x	2024-10-22 05:00:48
__pycache__	dir	-	root/root	drwxr-xr-x	2024-08-19 05:31:26
dnssecalgs	dir	-	root/root	drwxr-xr-x	2024-08-19 05:31:25
quic	dir	-	root/root	drwxr-xr-x	2024-08-19 05:31:25
rdtypes	dir	-	root/root	drwxr-xr-x	2024-08-19 05:31:25
__init__.py	text/x-script.python	1.62 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
_asyncbackend.py	text/x-script.python	2.3 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
_asyncio_backend.py	text/x-script.python	8.76 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
_ddr.py	text/x-script.python	5.12 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
_features.py	text/x-script.python	2.33 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
_immutable_ctx.py	text/x-script.python	2.4 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
_trio_backend.py	text/x-script.python	8.08 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
asyncbackend.py	text/x-script.python	2.73 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
asyncquery.py	text/x-script.python	26.22 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
asyncresolver.py	text/x-script.python	17.43 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
dnssec.py	text/x-script.python	39.74 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
dnssectypes.py	text/x-script.python	1.76 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
e164.py	text/x-script.python	3.88 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
edns.py	text/x-script.python	14.91 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
entropy.py	text/x-script.python	4.14 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
enum.py	text/x-script.python	3.6 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
exception.py	text/x-script.python	5.82 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
flags.py	text/x-script.python	2.69 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
grange.py	text/x-script.python	2.1 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
immutable.py	text/x-script.python	1.97 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
inet.py	text/x-script.python	5.64 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
ipv4.py	text/x-script.python	2.49 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
ipv6.py	text/x-script.python	6.45 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
message.py	text/x-script.python	64.45 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
name.py	text/x-script.python	41.67 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
namedict.py	text/x-script.python	3.91 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
nameserver.py	text/x-script.python	9.68 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
node.py	text/x-script.python	12.37 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
opcode.py	text/x-script.python	2.67 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
py.typed	application/x-empty	0 B	root/root	-rw-r--r--	2024-08-19 05:31:25
query.py	text/x-script.python	53.55 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
rcode.py	text/x-script.python	4.06 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
rdata.py	text/x-script.python	28.77 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
rdataclass.py	text/x-script.python	2.91 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
rdataset.py	text/x-script.python	16.36 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
rdatatype.py	text/x-script.python	7.17 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
renderer.py	text/x-script.python	10.99 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
resolver.py	text/x-script.python	71.83 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
reversename.py	text/x-script.python	3.74 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
rrset.py	text/x-script.python	8.96 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
serial.py	text/x-script.python	3.52 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
set.py	text/x-script.python	8.88 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
tokenizer.py	text/x-script.python	23.03 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
transaction.py	text/x-script.python	22.11 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
tsig.py	text/x-script.python	11.15 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
tsigkeyring.py	text/x-script.python	2.57 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
ttl.py	text/x-script.python	2.91 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
update.py	text/x-script.python	11.96 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
version.py	text/plain	1.88 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
versioned.py	text/x-script.python	11.49 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
win32util.py	text/x-script.python	8.89 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
wire.py	text/x-script.python	2.76 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
xfr.py	text/x-script.python	12.96 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
zone.py	text/x-script.python	50.87 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
zonefile.py	text/x-script.python	27.27 KB	root/root	-rw-r--r--	2024-08-19 05:31:25
zonetypes.py	text/x-script.python	690 B	root/root	-rw-r--r--	2024-08-19 05:31:25