Source code for

# -*- coding: utf-8 -*-
    ⚡⚡⚡ Fast, Lightweight, Pluggable, TLS interception capable proxy server focused on
    Network monitoring, controls & Application development, testing, debugging.

    :copyright: (c) 2013-present by Abhinav Singh and contributors.
    :license: BSD, see LICENSE for more details.
import asyncio
from typing import Any, Optional
from multiprocessing import connection
from multiprocessing.reduction import recv_handle

from .fd import ThreadlessFdExecutor

[docs]class RemoteFdExecutor(ThreadlessFdExecutor[connection.Connection]): """A threadless executor implementation which receives work over a connection. NOTE: RemoteExecutor uses ``recv_handle`` to accept file descriptors. TODO: Refactor and abstract ``recv_handle`` part so that a threaded remote executor can also accept work over a connection. Currently, remote executors must be running in a process. """ def __init__(self, *args: Any, **kwargs: Any) -> None: super().__init__(*args, **kwargs) self._loop: Optional[asyncio.AbstractEventLoop] = None @property def loop(self) -> Optional[asyncio.AbstractEventLoop]: if self._loop is None: self._loop = asyncio.get_event_loop_policy().get_event_loop() return self._loop
[docs] def receive_from_work_queue(self) -> bool: # Acceptor will not send address for # unix socket domain environments. addr = None if not self.flags.unix_socket_path: addr = self.work_queue.recv() fileno = recv_handle(self.work_queue), addr, None) return False
[docs] def work_queue_fileno(self) -> Optional[int]: return self.work_queue.fileno()
[docs] def close_work_queue(self) -> None: self.work_queue.close()