Function task

qa/tasks/ceph_objectstore_tool.py:162–245

Run ceph_objectstore_tool test The config should be as follows:: ceph_objectstore_tool: objects: 20 # pgnum: 12 crimson_objectstore_tool: true # use crimson-objectstore-tool instead of ceph-objectstore-tool gc_before_rest

(ctx, config)

@contextlib.contextmanager
def task(ctx, config):
    """
    Run ceph_objectstore_tool test

    The config should be as follows::

        ceph_objectstore_tool:
          objects: 20 # <number of objects>
          pgnum: 12
          crimson_objectstore_tool: true # use crimson-objectstore-tool instead of ceph-objectstore-tool
          gc_before_restart: true # run crimson-objectstore-tool --op gc before restarting OSDs
    """

    if config is None:
        config = {}
    assert isinstance(config, dict), \
        'ceph_objectstore_tool task only accepts a dict for configuration'

    # Set global CRIMSON flags based on configuration
    global CRIMSON
    global CRIMSON_DEVICE_TYPE
    CRIMSON = config.get('crimson_objectstore_tool', False)
    log.info('crimson_objectstore_tool is {}...'.format(CRIMSON))

    log.debug(config)
    log.debug(ctx)
    clients = ctx.cluster.only(teuthology.is_type('client'))
    assert len(clients.remotes) > 0, 'Must specify at least 1 client'
    (cli_remote, _) = clients.remotes.popitem()
    log.debug(cli_remote)

    # clients = dict(teuthology.get_clients(ctx=ctx, roles=config.keys()))
    # client = clients.popitem()
    # log.info(client)
    osds = ctx.cluster.only(teuthology.is_type('osd'))
    log.info("OSDS")
    log.info(osds)
    log.info(osds.remotes)

    manager = ctx.managers['ceph']
    while (len(manager.get_osd_status()['up']) !=
           len(manager.get_osd_status()['raw'])):
        time.sleep(10)
    while (len(manager.get_osd_status()['in']) !=
           len(manager.get_osd_status()['up'])):
        time.sleep(10)
    manager.raw_cluster_cmd('osd', 'set', 'noout')
    manager.raw_cluster_cmd('osd', 'set', 'nodown')

    if CRIMSON:
        CRIMSON_DEVICE_TYPE = manager.get_config('osd', 0, 'seastore_main_device_type')
        log.info('seastore_main_device_type is {}...'.format(CRIMSON_DEVICE_TYPE))

    PGNUM = config.get('pgnum', 12)
    log.info("pgnum: {num}".format(num=PGNUM))

    ERRORS = 0