control.py 文件源码

def step_accepting(self, connection, event, fd):
        #print('%s(%s, %s)' %
        #   (inspect.currentframe().f_code.co_name,connection,event_str(event)))

        if event & ERRMASK:
            #print('%s %d close accepting %d %d %s' % (
            #   self.proc_name,os.getpid(),fd,connection.port,event_str(event)))
            self.accepting.remove(connection)
            connection.close()
            self.unpollable(fd)

        elif event & OUTMASK:
            self.accepting.remove(connection)
            salt = make_salt()
            try:
                connection.put(CHALLENGE + salt)
                self.authenticating[connection] = salt
                self.pollable(fd, connection, INMASK)
            except ConnectionClosed:
                #print('%s %d peer closed accepting %d %d OUT' % (
                #    self.proc_name, os.getpid(), fd, connection.port))
                connection.close()
                self.unpollable(fd)