mirror of https://github.com/facebook/rocksdb.git
244 lines
7.2 KiB
C++
244 lines
7.2 KiB
C++
// Copyright (c) 2011-present, Facebook, Inc. All rights reserved.
|
|
// This source code is licensed under both the GPLv2 (found in the
|
|
// COPYING file in the root directory) and Apache 2.0 License
|
|
// (found in the LICENSE.Apache file in the root directory).
|
|
//
|
|
// Copyright (c) 2011 The LevelDB Authors. All rights reserved.
|
|
// Use of this source code is governed by a BSD-style license that can be
|
|
// found in the LICENSE file. See the AUTHORS file for names of contributors.
|
|
|
|
#include "file/filename.h"
|
|
|
|
#include "db/dbformat.h"
|
|
#include "port/port.h"
|
|
#include "test_util/testharness.h"
|
|
|
|
namespace ROCKSDB_NAMESPACE {
|
|
|
|
class FileNameTest : public testing::Test {};
|
|
|
|
TEST_F(FileNameTest, Parse) {
|
|
Slice db;
|
|
FileType type;
|
|
uint64_t number;
|
|
|
|
char kDefautInfoLogDir = 1;
|
|
char kDifferentInfoLogDir = 2;
|
|
char kNoCheckLogDir = 4;
|
|
char kAllMode = kDefautInfoLogDir | kDifferentInfoLogDir | kNoCheckLogDir;
|
|
|
|
// Successful parses
|
|
static struct {
|
|
const char* fname;
|
|
uint64_t number;
|
|
FileType type;
|
|
char mode;
|
|
} cases[] = {
|
|
{"100.log", 100, kWalFile, kAllMode},
|
|
{"0.log", 0, kWalFile, kAllMode},
|
|
{"0.sst", 0, kTableFile, kAllMode},
|
|
{"CURRENT", 0, kCurrentFile, kAllMode},
|
|
{"LOCK", 0, kDBLockFile, kAllMode},
|
|
{"MANIFEST-2", 2, kDescriptorFile, kAllMode},
|
|
{"MANIFEST-7", 7, kDescriptorFile, kAllMode},
|
|
{"METADB-2", 2, kMetaDatabase, kAllMode},
|
|
{"METADB-7", 7, kMetaDatabase, kAllMode},
|
|
{"LOG", 0, kInfoLogFile, kDefautInfoLogDir},
|
|
{"LOG.old", 0, kInfoLogFile, kDefautInfoLogDir},
|
|
{"LOG.old.6688", 6688, kInfoLogFile, kDefautInfoLogDir},
|
|
{"rocksdb_dir_LOG", 0, kInfoLogFile, kDifferentInfoLogDir},
|
|
{"rocksdb_dir_LOG.old", 0, kInfoLogFile, kDifferentInfoLogDir},
|
|
{"rocksdb_dir_LOG.old.6688", 6688, kInfoLogFile, kDifferentInfoLogDir},
|
|
{"18446744073709551615.log", 18446744073709551615ull, kWalFile, kAllMode},
|
|
};
|
|
for (char mode : {kDifferentInfoLogDir, kDefautInfoLogDir, kNoCheckLogDir}) {
|
|
for (unsigned int i = 0; i < sizeof(cases) / sizeof(cases[0]); i++) {
|
|
InfoLogPrefix info_log_prefix(mode != kDefautInfoLogDir, "/rocksdb/dir");
|
|
if (cases[i].mode & mode) {
|
|
std::string f = cases[i].fname;
|
|
if (mode == kNoCheckLogDir) {
|
|
ASSERT_TRUE(ParseFileName(f, &number, &type)) << f;
|
|
} else {
|
|
ASSERT_TRUE(ParseFileName(f, &number, info_log_prefix.prefix, &type))
|
|
<< f;
|
|
}
|
|
ASSERT_EQ(cases[i].type, type) << f;
|
|
ASSERT_EQ(cases[i].number, number) << f;
|
|
}
|
|
}
|
|
}
|
|
|
|
// Errors
|
|
static const char* errors[] = {
|
|
"",
|
|
"foo",
|
|
"foo-dx-100.log",
|
|
".log",
|
|
"",
|
|
"manifest",
|
|
"CURREN",
|
|
"CURRENTX",
|
|
"MANIFES",
|
|
"MANIFEST",
|
|
"MANIFEST-",
|
|
"XMANIFEST-3",
|
|
"MANIFEST-3x",
|
|
"META",
|
|
"METADB",
|
|
"METADB-",
|
|
"XMETADB-3",
|
|
"METADB-3x",
|
|
"LOC",
|
|
"LOCKx",
|
|
"LO",
|
|
"LOGx",
|
|
"18446744073709551616.log",
|
|
"184467440737095516150.log",
|
|
"100",
|
|
"100.",
|
|
"100.lop"
|
|
};
|
|
for (unsigned int i = 0; i < sizeof(errors) / sizeof(errors[0]); i++) {
|
|
std::string f = errors[i];
|
|
ASSERT_TRUE(!ParseFileName(f, &number, &type)) << f;
|
|
};
|
|
}
|
|
|
|
TEST_F(FileNameTest, InfoLogFileName) {
|
|
std::string dbname = ("/data/rocksdb");
|
|
std::string db_absolute_path;
|
|
ASSERT_OK(Env::Default()->GetAbsolutePath(dbname, &db_absolute_path));
|
|
|
|
ASSERT_EQ("/data/rocksdb/LOG", InfoLogFileName(dbname, db_absolute_path, ""));
|
|
ASSERT_EQ("/data/rocksdb/LOG.old.666",
|
|
OldInfoLogFileName(dbname, 666u, db_absolute_path, ""));
|
|
|
|
ASSERT_EQ("/data/rocksdb_log/data_rocksdb_LOG",
|
|
InfoLogFileName(dbname, db_absolute_path, "/data/rocksdb_log"));
|
|
ASSERT_EQ(
|
|
"/data/rocksdb_log/data_rocksdb_LOG.old.666",
|
|
OldInfoLogFileName(dbname, 666u, db_absolute_path, "/data/rocksdb_log"));
|
|
}
|
|
|
|
TEST_F(FileNameTest, Construction) {
|
|
uint64_t number;
|
|
FileType type;
|
|
std::string fname;
|
|
|
|
fname = CurrentFileName("foo");
|
|
ASSERT_EQ("foo/", std::string(fname.data(), 4));
|
|
ASSERT_TRUE(ParseFileName(fname.c_str() + 4, &number, &type));
|
|
ASSERT_EQ(0U, number);
|
|
ASSERT_EQ(kCurrentFile, type);
|
|
|
|
fname = LockFileName("foo");
|
|
ASSERT_EQ("foo/", std::string(fname.data(), 4));
|
|
ASSERT_TRUE(ParseFileName(fname.c_str() + 4, &number, &type));
|
|
ASSERT_EQ(0U, number);
|
|
ASSERT_EQ(kDBLockFile, type);
|
|
|
|
fname = LogFileName("foo", 192);
|
|
ASSERT_EQ("foo/", std::string(fname.data(), 4));
|
|
ASSERT_TRUE(ParseFileName(fname.c_str() + 4, &number, &type));
|
|
ASSERT_EQ(192U, number);
|
|
ASSERT_EQ(kWalFile, type);
|
|
|
|
fname = TableFileName({DbPath("bar", 0)}, 200, 0);
|
|
std::string fname1 =
|
|
TableFileName({DbPath("foo", 0), DbPath("bar", 0)}, 200, 1);
|
|
ASSERT_EQ(fname, fname1);
|
|
ASSERT_EQ("bar/", std::string(fname.data(), 4));
|
|
ASSERT_TRUE(ParseFileName(fname.c_str() + 4, &number, &type));
|
|
ASSERT_EQ(200U, number);
|
|
ASSERT_EQ(kTableFile, type);
|
|
|
|
fname = DescriptorFileName("bar", 100);
|
|
ASSERT_EQ("bar/", std::string(fname.data(), 4));
|
|
ASSERT_TRUE(ParseFileName(fname.c_str() + 4, &number, &type));
|
|
ASSERT_EQ(100U, number);
|
|
ASSERT_EQ(kDescriptorFile, type);
|
|
|
|
fname = TempFileName("tmp", 999);
|
|
ASSERT_EQ("tmp/", std::string(fname.data(), 4));
|
|
ASSERT_TRUE(ParseFileName(fname.c_str() + 4, &number, &type));
|
|
ASSERT_EQ(999U, number);
|
|
ASSERT_EQ(kTempFile, type);
|
|
|
|
fname = MetaDatabaseName("met", 100);
|
|
ASSERT_EQ("met/", std::string(fname.data(), 4));
|
|
ASSERT_TRUE(ParseFileName(fname.c_str() + 4, &number, &type));
|
|
ASSERT_EQ(100U, number);
|
|
ASSERT_EQ(kMetaDatabase, type);
|
|
}
|
|
|
|
TEST_F(FileNameTest, NormalizePath) {
|
|
// No leading slash
|
|
const std::string sep = std::string(1, kFilePathSeparator);
|
|
|
|
std::string expected = "FOLDER" + sep + "filename.ext";
|
|
std::string given = "FOLDER" + sep + "filename.ext";
|
|
|
|
ASSERT_EQ(expected, NormalizePath(given));
|
|
|
|
// Two chars /a
|
|
|
|
expected = sep + "a";
|
|
given = expected;
|
|
ASSERT_EQ(expected, NormalizePath(given));
|
|
|
|
// Two chars a/
|
|
expected = "a" + sep;
|
|
given = expected;
|
|
ASSERT_EQ(expected, NormalizePath(given));
|
|
|
|
// Server only
|
|
expected = sep + sep + "a";
|
|
given = expected;
|
|
ASSERT_EQ(expected, NormalizePath(given));
|
|
|
|
// Two slashes after character
|
|
expected = "a" + sep;
|
|
given = "a" + sep + sep;
|
|
|
|
ASSERT_EQ(expected, NormalizePath(given));
|
|
|
|
// slash only /
|
|
expected = sep;
|
|
given = expected;
|
|
ASSERT_EQ(expected, NormalizePath(given));
|
|
|
|
// UNC only //
|
|
expected = sep;
|
|
given = sep + sep;
|
|
|
|
ASSERT_EQ(expected, NormalizePath(given));
|
|
|
|
// 3 slashesy //
|
|
expected = sep + sep;
|
|
given = sep + sep + sep;
|
|
ASSERT_EQ(expected, NormalizePath(given));
|
|
|
|
// 3 slashes //
|
|
expected = sep + sep + "a" + sep;
|
|
given = sep + sep + sep + "a" + sep;
|
|
ASSERT_EQ(expected, NormalizePath(given));
|
|
|
|
// 2 separators in the middle
|
|
expected = "a" + sep + "b";
|
|
given = "a" + sep + sep + "b";
|
|
ASSERT_EQ(expected, NormalizePath(given));
|
|
|
|
// UNC with duplicate slashes
|
|
expected = sep + sep + "SERVER" + sep + "a" + sep + "b" + sep + "c";
|
|
given = sep + sep + "SERVER" + sep + "a" + sep + sep + "b" + sep + "c";
|
|
ASSERT_EQ(expected, NormalizePath(given));
|
|
}
|
|
|
|
} // namespace ROCKSDB_NAMESPACE
|
|
|
|
int main(int argc, char** argv) {
|
|
ROCKSDB_NAMESPACE::port::InstallStackTraceHandler();
|
|
::testing::InitGoogleTest(&argc, argv);
|
|
return RUN_ALL_TESTS();
|
|
}
|