nbNet_simple.py 文件源码

def run(self):
        '''????
          ??epoll????????
        '''
        while True:
            # epoll??????????????????????????????????????????
            # ?????????epoll???????
            epoll_list = self.epoll_sock.poll()
            for fd, events in epoll_list:
                sock_state = self.conn_state[fd]
                # ?? epoll?????io?? epoll hang??????
                if select.EPOLLHUP & events:
                    sock_state.state = "closing"
                # ??IO??epoll?????????
                elif select.EPOLLERR & events:
                    sock_state.state = "closing"
                self.state_machine(fd)

#}}}
#{{{fork_processes