HEX
Server: Apache/2.4.52 (Ubuntu)
System: Linux WebLive 5.15.0-79-generic #86-Ubuntu SMP Mon Jul 10 16:07:21 UTC 2023 x86_64
User: ubuntu (1000)
PHP: 7.4.33
Disabled: pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wifcontinued,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_get_handler,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority,pcntl_async_signals,pcntl_unshare,
Upload Files
File: //usr/local/qcloud/monitor/barad/comm/epoll/acceptor.py
from epoll_reactor import EpollReactor
from event_handler import EventHandler
import select

class Acceptor(EventHandler):
    def __init__(self, reactor, sock, client_class, logger, router):
        super(Acceptor, self).__init__(reactor, sock, select.EPOLLIN)
        self.__sock = sock
        self.__client_class = client_class
        self.__logger = logger
        self.__router = router
        
    def handle_input(self):
        conn, addr = self.__sock.accept()
        conn.setblocking(0)
        self.__client_class(self.reactor(), conn, addr, select.EPOLLIN, self.__logger, self.__router)
        return 0
        
    def handle_output(self):
        return 0