src/ceph_osd, osd: Implement running benchmark during OSD creation

The changeset implements the following:

1. Adds an option called "--run-benchmark" to the ceph-osd process to enable
   running the existing osd benchmark during the creation of the OSD but before
   it's added to the cluster. If the option is specified, the benchmark is run
   just after 'mkfs' is performed on the OSD.
2. A separate OSDBenchTest class is created that can be instantiated when the
   benchmark is needed to be run. The class has interfaces to perform precheck,
   prefill, run the actual randwrite test and do the cleanup. It also has
   interfaces to extract the metrics. The new class in used where applicable
   and maintains the existing behavior of the "bench" command.
3. The vstart.sh script is modified to run the benchmark and store the results
   for each OSD in ceph.conf. This currently prevents the execution of the
   existing benchmark during the OSD boot-up.

Signed-off-by: Sridhar Seshasayee <[email protected]>
Fixes: https://tracker.ceph.com/issues/71941

Author: sseshasa

src/ceph_osd.cc

@@ -113,6 +113,7 @@ static void usage()
        << "  --debug_osd <N>   set debug level (e.g. 10)\n"
        << "  --get-device-fsid PATH\n"
        << "                    get OSD fsid for the given block device\n"
+       << "  --run-benchmark   run a throughput benchmark test against the OSD and dump the result\n"
        << std::endl;
   generic_server_usage();
 }
@@ -151,6 +152,7 @@ int main(int argc, const char **argv)
   bool get_cluster_fsid = false;
   bool get_journal_fsid = false;
   bool get_device_fsid = false;
+  bool run_benchmark = false;
   string device_path;
   std::string dump_pg_log;
   std::string osdspec_affinity;
@@ -190,6 +192,8 @@ int main(int argc, const char **argv)
     } else if (ceph_argparse_witharg(args, i, &device_path,
 				     "--get-device-fsid", (char*)NULL)) {
       get_device_fsid = true;
+    } else if (ceph_argparse_flag(args, i, "--run-benchmark", (char*)NULL)) {
+      run_benchmark = true;
     } else {
       ++i;
     }
@@ -380,6 +384,23 @@ int main(int argc, const char **argv)
   if (mkkey) {
     forker.exit(0);
   }
+  // Run a benchmark if specified
+  if (run_benchmark) {
+    store->mount();
+    tl::expected<std::string, int> res =
+      OSD::run_osd_bench(g_ceph_context, store.get());
+    if (!res.has_value()) {
+      int ret = res.error();
+      derr << TEXT_RED << " ** ERROR: error running benchmark: "
+           << cpp_strerror(ret) << TEXT_NORMAL << dendl;
+      cerr << " ** ERROR: error running benchmark: "
+           << cpp_strerror(ret) << std::endl;
+      forker.exit(ret);
+    }
+    cout << res.value() << std::endl;
+    store->umount();
+    forker.exit(0);
+  }
   if (mkjournal) {
     common_init_finish(g_ceph_context);
     int err = store->mkjournal();