#include "memtable/stl_wrappers.h"
#include "rocksdb/db.h"
#include "rocksdb/env.h"
+#include "test_util/testharness.h"
+#include "test_util/testutil.h"
#include "util/hash.h"
#include "util/kv_map.h"
#include "util/string_util.h"
-#include "util/testharness.h"
-#include "util/testutil.h"
#include "utilities/merge_operators.h"
using std::unique_ptr;
-namespace rocksdb {
+namespace ROCKSDB_NAMESPACE {
namespace {
-static const Comparator* comparator;
+static const Comparator* kTestComparator = nullptr;
class KVIter : public Iterator {
public:
void DoRandomIteraratorTest(DB* db, std::vector<std::string> source_strings,
Random* rnd, int num_writes, int num_iter_ops,
int num_trigger_flush) {
- stl_wrappers::KVMap map((stl_wrappers::LessOfComparator(comparator)));
+ stl_wrappers::KVMap map((stl_wrappers::LessOfComparator(kTestComparator)));
for (int i = 0; i < num_writes; i++) {
if (num_trigger_flush > 0 && i != 0 && i % num_trigger_flush == 0) {
public:
ComparatorDBTest() : env_(Env::Default()), db_(nullptr) {
- comparator = BytewiseComparator();
+ kTestComparator = BytewiseComparator();
dbname_ = test::PerThreadDBPath("comparator_db_test");
BlockBasedTableOptions toptions;
toptions.format_version = GetParam();
last_options_.table_factory.reset(
- rocksdb::NewBlockBasedTableFactory(toptions));
+ ROCKSDB_NAMESPACE::NewBlockBasedTableFactory(toptions));
EXPECT_OK(DestroyDB(dbname_, last_options_));
}
~ComparatorDBTest() override {
delete db_;
EXPECT_OK(DestroyDB(dbname_, last_options_));
- comparator = BytewiseComparator();
+ kTestComparator = BytewiseComparator();
}
DB* GetDB() { return db_; }
} else {
comparator_guard.reset();
}
- comparator = cmp;
+ kTestComparator = cmp;
last_options_.comparator = cmp;
}
for (int rnd_seed = 301; rnd_seed < 316; rnd_seed++) {
Options* opt = GetOptions();
- opt->comparator = comparator;
+ opt->comparator = kTestComparator;
DestroyAndReopen();
Random rnd(rnd_seed);
for (int rnd_seed = 301; rnd_seed < 316; rnd_seed++) {
Options* opt = GetOptions();
- opt->comparator = comparator;
+ opt->comparator = kTestComparator;
DestroyAndReopen();
Random rnd(rnd_seed);
Random64 rnd64(rnd_seed);
for (int rnd_seed = 301; rnd_seed < 316; rnd_seed++) {
Options* opt = GetOptions();
- opt->comparator = comparator;
+ opt->comparator = kTestComparator;
DestroyAndReopen();
Random rnd(rnd_seed);
for (int rnd_seed = 301; rnd_seed < 316; rnd_seed++) {
Options* opt = GetOptions();
- opt->comparator = comparator;
+ opt->comparator = kTestComparator;
DestroyAndReopen();
Random rnd(rnd_seed);
for (int rnd_seed = 301; rnd_seed < 316; rnd_seed++) {
Options* opt = GetOptions();
- opt->comparator = comparator;
+ opt->comparator = kTestComparator;
DestroyAndReopen();
Random rnd(rnd_seed);
}
}
-} // namespace rocksdb
+} // namespace ROCKSDB_NAMESPACE
int main(int argc, char** argv) {
::testing::InitGoogleTest(&argc, argv);