swiftly/cli/ping.py
def cli_ping(context, prefix):
    """
    Performs a ping test.

    See :py:mod:`swiftly.cli.ping` for context usage information.

    See :py:class:`CLIPing` for more information.

    :param context: The :py:class:`swiftly.cli.context.CLIContext` to
        use.
    :param prefix: The container name prefix to use. Default:
        swiftly-ping
    """
    if not prefix:
        prefix = 'swiftly-ping'
    ping_ring_object_puts = collections.defaultdict(lambda: [])
    ping_ring_object_gets = collections.defaultdict(lambda: [])
    ping_ring_object_deletes = collections.defaultdict(lambda: [])
    context.ping_begin = context.ping_begin_last = time.time()
    container = prefix + '-' + uuid.uuid4().hex
    objects = [uuid.uuid4().hex for x in moves.range(context.ping_count)]
    conc = Concurrency(context.concurrency)
    with context.client_manager.with_client() as client:
        client.auth()
        _cli_ping_status(context, 'auth', '-', None, None, None, None)
        _cli_ping_status(context, 'account head', '-', *client.head_account())
        _cli_ping_status(
            context, 'container put', '-', *client.put_container(container))
    if _cli_ping_objects(
            context, 'put', conc, container, objects, _cli_ping_object_put,
            ping_ring_object_puts):
        with context.io_manager.with_stderr() as fp:
            fp.write(
                'ERROR put objects did not complete successfully due to '
                'previous error; but continuing\n')
            fp.flush()
    if _cli_ping_objects(
            context, 'get', conc, container, objects, _cli_ping_object_get,
            ping_ring_object_gets):
        with context.io_manager.with_stderr() as fp:
            fp.write(
                'ERROR get objects did not complete successfully due to '
                'previous error; but continuing\n')
            fp.flush()
    if _cli_ping_objects(
            context, 'delete', conc, container, objects,
            _cli_ping_object_delete, ping_ring_object_deletes):
        with context.io_manager.with_stderr() as fp:
            fp.write(
                'ERROR delete objects did not complete successfully due to '
                'previous error; but continuing\n')
            fp.flush()
    for attempt in moves.range(5):
        if attempt:
            sleep(2**attempt)
        with context.client_manager.with_client() as client:
            try:
                _cli_ping_status(
                    context, 'container delete', '-',
                    *client.delete_container(container))
                break
            except ReturnCode as err:
                with context.io_manager.with_stderr() as fp:
                    fp.write(str(err))
                    fp.write('\n')
                    fp.flush()
    else:
        with context.io_manager.with_stderr() as fp:
            fp.write(
                'ERROR could not confirm deletion of container due to '
                'previous error; but continuing\n')
            fp.flush()
    end = time.time()
    with context.io_manager.with_stdout() as fp:
        if context.graphite:
            fp.write(
                '%s.ping_overall %.02f %d\n' % (
                    context.graphite, end - context.ping_begin, time.time()))
        if context.ping_verbose:
            fp.write('% 6.02fs total\n' % (end - context.ping_begin))
        elif not context.graphite:
            fp.write('%.02fs\n' % (end - context.ping_begin))
        fp.flush()
    ping_ring_overall = collections.defaultdict(lambda: [])
    _cli_ping_ring_report(context, ping_ring_object_puts, 'PUT')
    for ip, timings in six.iteritems(ping_ring_object_puts):
        ping_ring_overall[ip].extend(timings)
    _cli_ping_ring_report(context, ping_ring_object_gets, 'GET')
    for ip, timings in six.iteritems(ping_ring_object_gets):
        ping_ring_overall[ip].extend(timings)
    _cli_ping_ring_report(context, ping_ring_object_deletes, 'DELETE')
    for ip, timings in six.iteritems(ping_ring_object_deletes):
        ping_ring_overall[ip].extend(timings)
    _cli_ping_ring_report(context, ping_ring_overall, 'overall')
def cli_ping(context, prefix):
    """
    Performs a ping test.

    See :py:mod:`swiftly.cli.ping` for context usage information.

    See :py:class:`CLIPing` for more information.

    :param context: The :py:class:`swiftly.cli.context.CLIContext` to
        use.
    :param prefix: The container name prefix to use. Default:
        swiftly-ping
    """
    if not prefix:
        prefix = 'swiftly-ping'
    ping_ring_object_puts = collections.defaultdict(lambda: [])
    ping_ring_object_gets = collections.defaultdict(lambda: [])
    ping_ring_object_deletes = collections.defaultdict(lambda: [])
    context.ping_begin = context.ping_begin_last = time.time()
    container = prefix + '-' + uuid.uuid4().hex
    objects = [uuid.uuid4().hex for x in moves.range(context.ping_count)]
    conc = Concurrency(context.concurrency)
    with context.client_manager.with_client() as client:
        client.auth()
        _cli_ping_status(context, 'auth', '-', None, None, None, None)
        _cli_ping_status(context, 'account head', '-', *client.head_account())
        _cli_ping_status(
            context, 'container put', '-', *client.put_container(container))
    if _cli_ping_objects(
            context, 'put', conc, container, objects, _cli_ping_object_put,
            ping_ring_object_puts):
        with context.io_manager.with_stderr() as fp:
            fp.write(
                'ERROR put objects did not complete successfully due to '
                'previous error; but continuing\n')
            fp.flush()
    if _cli_ping_objects(
            context, 'get', conc, container, objects, _cli_ping_object_get,
            ping_ring_object_gets):
        with context.io_manager.with_stderr() as fp:
            fp.write(
                'ERROR get objects did not complete successfully due to '
                'previous error; but continuing\n')
            fp.flush()
    if _cli_ping_objects(
            context, 'delete', conc, container, objects,
            _cli_ping_object_delete, ping_ring_object_deletes):
        with context.io_manager.with_stderr() as fp:
            fp.write(
                'ERROR delete objects did not complete successfully due to '
                'previous error; but continuing\n')
            fp.flush()
    for attempt in moves.range(5):
        if attempt:
            sleep(2**attempt)
        with context.client_manager.with_client() as client:
            try:
                _cli_ping_status(
                    context, 'container delete', '-',
                    *client.delete_container(container))
                break
            except ReturnCode as err:
                with context.io_manager.with_stderr() as fp:
                    fp.write(str(err))
                    fp.write('\n')
                    fp.flush()
    else:
        with context.io_manager.with_stderr() as fp:
            fp.write(
                'ERROR could not confirm deletion of container due to '
                'previous error; but continuing\n')
            fp.flush()
    end = time.time()
    with context.io_manager.with_stdout() as fp:
        if context.graphite:
            fp.write(
                '%s.ping_overall %.02f %d\n' % (
                    context.graphite, end - context.ping_begin, time.time()))
        if context.ping_verbose:
            fp.write('% 6.02fs total\n' % (end - context.ping_begin))
        elif not context.graphite:
            fp.write('%.02fs\n' % (end - context.ping_begin))
        fp.flush()
    ping_ring_overall = collections.defaultdict(lambda: [])
    _cli_ping_ring_report(context, ping_ring_object_puts, 'PUT')
    for ip, timings in six.iteritems(ping_ring_object_puts):
        ping_ring_overall[ip].extend(timings)
    _cli_ping_ring_report(context, ping_ring_object_gets, 'GET')
    for ip, timings in six.iteritems(ping_ring_object_gets):
        ping_ring_overall[ip].extend(timings)
    _cli_ping_ring_report(context, ping_ring_object_deletes, 'DELETE')
    for ip, timings in six.iteritems(ping_ring_object_deletes):
        ping_ring_overall[ip].extend(timings)
    _cli_ping_ring_report(context, ping_ring_overall, 'overall')
def cli_ping ( context , prefix ) : if not prefix : prefix = 'swiftly-ping' ping_ring_object_puts = collections . defaultdict ( lambda : [ ] ) ping_ring_object_gets = collections . defaultdict ( lambda : [ ] ) ping_ring_object_deletes = collections . defaultdict ( lambda : [ ] ) context . ping_begin = context . ping_begin_last = time . time ( ) container = prefix + '-' + uuid . uuid4 ( ) . hex objects = [ uuid . uuid4 ( ) . hex for x in moves . range ( context . ping_count ) ] conc = Concurrency ( context . concurrency ) with context . client_manager . with_client ( ) as client : client . auth ( ) _cli_ping_status ( context , 'auth' , '-' , None , None , None , None ) _cli_ping_status ( context , 'account head' , '-' , * client . head_account ( ) ) _cli_ping_status ( context , 'container put' , '-' , * client . put_container ( container ) ) if _cli_ping_objects ( context , 'put' , conc , container , objects , _cli_ping_object_put , ping_ring_object_puts ) : with context . io_manager . with_stderr ( ) as fp : fp . write ( 'ERROR put objects did not complete successfully due to ' 'previous error; but continuing\n' ) fp . flush ( ) if _cli_ping_objects ( context , 'get' , conc , container , objects , _cli_ping_object_get , ping_ring_object_gets ) : with context . io_manager . with_stderr ( ) as fp : fp . write ( 'ERROR get objects did not complete successfully due to ' 'previous error; but continuing\n' ) fp . flush ( ) if _cli_ping_objects ( context , 'delete' , conc , container , objects , _cli_ping_object_delete , ping_ring_object_deletes ) : with context . io_manager . with_stderr ( ) as fp : fp . write ( 'ERROR delete objects did not complete successfully due to ' 'previous error; but continuing\n' ) fp . flush ( ) for attempt in moves . range ( 5 ) : if attempt : sleep ( 2 ** attempt ) with context . client_manager . with_client ( ) as client : try : _cli_ping_status ( context , 'container delete' , '-' , * client . delete_container ( container ) ) break except ReturnCode as err : with context . io_manager . with_stderr ( ) as fp : fp . write ( str ( err ) ) fp . write ( '\n' ) fp . flush ( ) else : with context . io_manager . with_stderr ( ) as fp : fp . write ( 'ERROR could not confirm deletion of container due to ' 'previous error; but continuing\n' ) fp . flush ( ) end = time . time ( ) with context . io_manager . with_stdout ( ) as fp : if context . graphite : fp . write ( '%s.ping_overall %.02f %d\n' % ( context . graphite , end - context . ping_begin , time . time ( ) ) ) if context . ping_verbose : fp . write ( '% 6.02fs total\n' % ( end - context . ping_begin ) ) elif not context . graphite : fp . write ( '%.02fs\n' % ( end - context . ping_begin ) ) fp . flush ( ) ping_ring_overall = collections . defaultdict ( lambda : [ ] ) _cli_ping_ring_report ( context , ping_ring_object_puts , 'PUT' ) for ip , timings in six . iteritems ( ping_ring_object_puts ) : ping_ring_overall [ ip ] . extend ( timings ) _cli_ping_ring_report ( context , ping_ring_object_gets , 'GET' ) for ip , timings in six . iteritems ( ping_ring_object_gets ) : ping_ring_overall [ ip ] . extend ( timings ) _cli_ping_ring_report ( context , ping_ring_object_deletes , 'DELETE' ) for ip , timings in six . iteritems ( ping_ring_object_deletes ) : ping_ring_overall [ ip ] . extend ( timings ) _cli_ping_ring_report ( context , ping_ring_overall , 'overall' )
Performs a ping test.

    See :py:mod:`swiftly.cli.ping` for context usage information.

    See :py:class:`CLIPing` for more information.

    :param context: The :py:class:`swiftly.cli.context.CLIContext` to
        use.
    :param prefix: The container name prefix to use. Default:
        swiftly-ping
Performs a ping test .