The requested URL was not found on this server.
Additionally, a 404 Not Found error was encountered while trying to use an ErrorDocument to handle the request.
; /li~ jn-jqA AqTţ a=JJj"Tfbѿ ? /# # Copyright (C) 2022 Red Hat, Inc. # SPDX-License-Identifier: GPL-3.0-or-later """Bi-directional asyncio.Transport implementations based on file descriptors.""" import asyncio import collections import ctypes import errno import fcntl import logging import os import select import signal import struct import subprocess import termios from typing import Any, ClassVar, Sequence from .jsonutil import JsonObject, get_int sys_prctl = ctypes.CDLL(None).prctl def prctl(*args: int) -> None: if sys_prctl(*args) != 0: raise OSError('prctl() failed') SET_PDEATHSIG = 1 logger = logging.getLogger(__name__) IOV_MAX = 1024 # man 2 writev class _Transport(asyncio.Transport): BLOCK_SIZE: ClassVar[int] = 1024 * 1024 # A transport always has a loop and a protocol _loop: asyncio.AbstractEventLoop _protocol: asyncio.Protocol _queue: 'collections.deque[bytes] | None' _in_fd: int _out_fd: int _closing: bool _is_reading: bool _eof: bool _eio_is_eof: bool = False def __init__(self, loop: asyncio.AbstractEventLoop, protocol: asyncio.Protocol, in_fd: int = -1, out_fd: int = -1, extra: 'dict[str, object] | None' = None): super().__init__(extra) self._loop = loop self._protocol = protocol logger.debug('Created transport %s for protocol %s, fds %d %d', self, protocol, in_fd, out_fd) self._queue = None self._is_reading = False self._eof = False self._closing = False self._in_fd = in_fd self._out_fd = out_fd os.set_blocking(in_fd, False) if out_fd != in_fd: os.set_blocking(out_fd, False) self._protocol.connection_made(self) self.resume_reading() def _read_ready(self) -> None: logger.debug('Read ready on %s %s %d', self, self._protocol, self._in_fd) try: data = os.read(self._in_fd, _Transport.BLOCK_SIZE) except BlockingIOError: # pragma: no cover return except OSError as exc: if self._eio_is_eof and exc.errno == errno.EIO: # PTY devices return EIO to mean "EOF" data = b'' else: # Other errors: terminate the connection self.abort(exc) return if data != b'': logger.debug(' read %d bytes', len(data)) self._protocol.data_received(data) else: logger.debug(' got EOF') self._close_reader() keep_open = self._protocol.eof_received() if not keep_open: self.close() def is_reading(self) -> bool: return self._is_reading def _close_reader(self) -> None: self.pause_reading() self._in_fd = -1 def pause_reading(self) -> None: if self._is_reading: self._loop.remove_reader(self._in_fd) self._is_reading = False def resume_reading(self) -> None: # It's possible that the Protocol could decide to attempt to unpause # reading after _close_reader() got called. Check that the fd is != -1 # before actually resuming. if not self._is_reading and self._in_fd != -1: self._loop.add_reader(self._in_fd, self._read_ready) self._is_reading = True def _close(self) -> None: pass def abort(self, exc: 'Exception | None' = None) -> None: self._closing = True self._close_reader() self._remove_write_queue() self._loop.cal