export CEPH_MON="127.0.0.1:7121" # git grep '\<7121\>' : there must be only one
export CEPH_ARGS
CEPH_ARGS+="--fsid=$(uuidgen) --auth-supported=none "
- CEPH_ARGS+="--mon-host=$CEPH_MON "
+ CEPH_ARGS+="--mon-host=$CEPH_MON --osd-objectstore=filestore"
export -n CEPH_CLI_TEST_DUP_COMMAND
local funcs=${@:-$(set | sed -n -e 's/^\(TEST_[0-9a-z_]*\) .*/\1/p')}
# return a list of unique PGS given an osd subdirectory
def get_osd_pgs(SUBDIR, ID):
+ export CEPH_ARGS="--osd-objectstore=filestore"
PGS = []
if ID:
endhead = re.compile("{id}.*_head$".format(id=ID))
# return a sorted list of unique PGs given a directory
def get_pgs(DIR, ID):
+ export CEPH_ARGS="--osd-objectstore=filestore"
OSDS = [f for f in os.listdir(DIR) if os.path.isdir(os.path.join(DIR, f)) and f.find("osd") == 0]
PGS = []
for d in OSDS:
# return a sorted list of PGS a subset of ALLPGS that contain objects with prefix specified
def get_objs(ALLPGS, prefix, DIR, ID):
+ export CEPH_ARGS="--osd-objectstore=filestore"
OSDS = [f for f in os.listdir(DIR) if os.path.isdir(os.path.join(DIR, f)) and f.find("osd") == 0]
PGS = []
for d in OSDS:
# return a sorted list of OSDS which have data from a given PG
def get_osds(PG, DIR):
+ export CEPH_ARGS="--osd-objectstore=filestore"
ALLOSDS = [f for f in os.listdir(DIR) if os.path.isdir(os.path.join(DIR, f)) and f.find("osd") == 0]
OSDS = []
for d in ALLOSDS:
def check_data(DATADIR, TMPFILE, OSDDIR, SPLIT_NAME):
+ export CEPH_ARGS="--osd-objectstore=filestore"
repcount = 0
ERRORS = 0
for rawnsfile in [f for f in os.listdir(DATADIR) if f.split('-')[1].find(SPLIT_NAME) == 0]:
def test_removeall(CFSD_PREFIX, db, OBJREPPGS, REP_POOL, CEPH_BIN, OSDDIR, REP_NAME, NUM_CLONED_REP_OBJECTS):
+ export CEPH_ARGS="--osd-objectstore=filestore"
# Test removeall
TMPFILE = r"/tmp/tmp.{pid}".format(pid=os.getpid())
nullfd = open(os.devnull, "w")
def main(argv):
+ export CEPH_ARGS="--osd-objectstore=filestore"
if sys.version_info[0] < 3:
sys.stdout = stdout = os.fdopen(sys.stdout.fileno(), 'wb', 0)
else: