dout(10) << "prepare_pool_crush_rule returns " << r << dendl;
return r;
}
+ unsigned size, min_size;
+ r = prepare_pool_size(pool_type, erasure_code_profile, repl_size,
+ &size, &min_size, ss);
+ if (r) {
+ dout(10) << "prepare_pool_size returns " << r << dendl;
+ return r;
+ }
if (g_conf()->mon_osd_crush_smoke_test) {
CrushWrapper newcrush = _get_pending_crush();
ostringstream err;
tester.set_min_x(0);
tester.set_max_x(50);
tester.set_rule(crush_rule);
+ tester.set_num_rep(size);
auto start = ceph::coarse_mono_clock::now();
r = tester.test_with_fork(g_conf()->mon_lease);
auto duration = ceph::coarse_mono_clock::now() - start;
dout(10) << __func__ << " crush smoke test duration: "
<< duration << dendl;
}
- unsigned size, min_size;
- r = prepare_pool_size(pool_type, erasure_code_profile, repl_size,
- &size, &min_size, ss);
- if (r) {
- dout(10) << "prepare_pool_size returns " << r << dendl;
- return r;
- }
r = check_pg_num(-1, pg_num, size, ss);
if (r) {
dout(10) << "check_pg_num returns " << r << dendl;
CrushTester tester(crush, ess);
tester.set_min_x(0);
tester.set_max_x(50);
+ tester.set_num_rep(3); // arbitrary
auto start = ceph::coarse_mono_clock::now();
int r = tester.test_with_fork(g_conf()->mon_lease);
auto duration = ceph::coarse_mono_clock::now() - start;