// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
+// vim: ts=8 sw=2 smarttab
/*
* Ceph - scalable distributed file system
*
int operation, int secondsToRun,
int maxObjectsToCreate,
int concurrentios, int op_size, bool cleanup, const char* run_name) {
+
+ if (concurrentios <= 0)
+ return -EINVAL;
+
int object_size = op_size;
int num_objects = 0;
int r = 0;
int ObjBencher::write_bench(int secondsToRun, int maxObjectsToCreate,
int concurrentios, const string& run_name_meta) {
+ if (concurrentios <= 0)
+ return -EINVAL;
+
if (maxObjectsToCreate > 0 && concurrentios > maxObjectsToCreate)
concurrentios = maxObjectsToCreate;
out(cout) << "Maintaining " << concurrentios << " concurrent writes of "
int ObjBencher::seq_read_bench(int seconds_to_run, int num_objects, int concurrentios, int pid) {
lock_cond lc(&lock);
+
+ if (concurrentios <= 0)
+ return -EINVAL;
+
std::vector<string> name(concurrentios);
std::string newName;
bufferlist* contents[concurrentios];
int ObjBencher::rand_read_bench(int seconds_to_run, int num_objects, int concurrentios, int pid)
{
lock_cond lc(&lock);
+
+ if (concurrentios <= 0)
+ return -EINVAL;
+
std::vector<string> name(concurrentios);
std::string newName;
bufferlist* contents[concurrentios];
int ObjBencher::clean_up(int num_objects, int prevPid, int concurrentios) {
lock_cond lc(&lock);
+
+ if (concurrentios <= 0)
+ return -EINVAL;
+
std::vector<string> name(concurrentios);
std::string newName;
int r = 0;
int ObjBencher::clean_up_slow(const std::string& prefix, int concurrentios) {
lock_cond lc(&lock);
+
+ if (concurrentios <= 0)
+ return -EINVAL;
+
std::vector<string> name(concurrentios);
std::string newName;
int r = 0;