preforkunix.py 文件源码

def process_command(conn):
        query = conn.recv(HEADER_SIZE)
        if not query:
            return None
        #print(len(query))
        assert(len(query) == HEADER_SIZE)
        if sys.hexversion > 0x3000000:
            query = query.decode('iso8859-1')

        #print "%r" % query
        if not re_valid_query.match(query):
            send_response(conn, -1, '', '', 'Invalid query %r' % query)
            raise ValueError('Invalid query %r' % query)

        query = query.strip().split(',')

        if query[0] == REQ:
            run_command(conn, query[1:])
        elif query[0] == BYE:
            raise ValueError('Exit')
        else:
            raise ValueError('Invalid query %r' % query)
        return 'ok'