上传文件至 'test'

test/ttl_test.cc

@@ -1,121 +1,121 @@
-
-
-#include "gtest/gtest.h"
-
-#include "leveldb/env.h"
-#include "leveldb/db.h"
-
-
-using namespace leveldb;
-// 定义了数据的大小，用于插入大数据集，燕
-constexpr int value_size = 2048;
-constexpr int data_size = 128 << 20;
-
-Status OpenDB(std::string dbName, DB **db) {
-  Options options;
-  options.create_if_missing = true;
-  return DB::Open(options, dbName, db);
-}
-
-void InsertData(DB *db, uint64_t ttl/* second */) {
-  WriteOptions writeOptions;
-  int key_num = data_size / value_size;
-  srand(0);
-
-  for (int i = 0; i < key_num; i++) {
-    int key_ = rand() % key_num+1;
-    // int key_ = i % key_num+1;
-    std::string key = std::to_string(key_);
-    std::string value(value_size, 'a');
-    db->Put(writeOptions, key, value, ttl);
-  }
-}
-
-void GetData(DB *db, int size = (1 << 30)) {
-  ReadOptions readOptions;
-  int key_num = data_size / value_size;
-  
-  // 使用随机种子生成随机键进行点查（单次查询），燕
-  // 点查
-  srand(0);
-  for (int i = 0; i < 100; i++) {
-    int key_ = rand() % key_num+1;
-    //int key_ = i % key_num+1;
-    std::string key = std::to_string(key_);
-    std::string value;   
-    db->Get(readOptions, key, &value);
-  }
-}
-
-TEST(TestTTL, ReadTTL) {
-    DB *db;
-    if(OpenDB("testdb", &db).ok() == false) {
-        std::cerr << "open db failed" << std::endl;
-        abort();
-    }
-
-    uint64_t ttl = 50;
-
-    InsertData(db, ttl);
-
-    ReadOptions readOptions;
-    Status status;
-    int key_num = data_size / value_size;
-    srand(0);
-    for (int i = 0; i < 100; i++) {
-        int key_ = rand() % key_num+1;
-        // int key_ = i % key_num+1;
-        std::string key = std::to_string(key_);
-        std::string value;
-        status = db->Get(readOptions, key, &value);
-        ASSERT_TRUE(status.ok());
-    }
-    // 等待TTL过期，使插入的数据变为“过期”状态，燕
-    Env::Default()->SleepForMicroseconds(ttl * 1000000);
-
-    for (int i = 0; i < 100; i++) {
-        int key_ = rand() % key_num+1;
-        // int key_ = i % key_num+1;
-        std::string key = std::to_string(key_);
-        std::string value;
-        status = db->Get(readOptions, key, &value);
-        ASSERT_FALSE(status.ok());
-    }
-    delete db;
-}
-
-TEST(TestTTL, CompactionTTL) {
-    DB *db;
-
-    if(OpenDB("testdb", &db).ok() == false) {
-        std::cerr << "open db failed" << std::endl;
-        abort();
-    }
-
-    uint64_t ttl = 20;
-    InsertData(db, ttl);
-
-    leveldb::Range ranges[1];
-    ranges[0] = leveldb::Range("-", "A");
-    uint64_t sizes[1];
-    db->GetApproximateSizes(ranges, 1, sizes);
-    ASSERT_GT(sizes[0], 0);
-
-    Env::Default()->SleepForMicroseconds(ttl * 1000000);
-
-    db->CompactRange(nullptr, nullptr);
-
-    // leveldb::Range ranges[1]; // 这里为什么要重复定义？心
-    ranges[0] = leveldb::Range("-", "A");
-    // uint64_t sizes[1]; // 心
-
-    db->GetApproximateSizes(ranges, 1, sizes);
-    ASSERT_EQ(sizes[0], 0);
-}
-
-
-int main(int argc, char** argv) {
-  // All tests currently run with the same read-only file limits.
-  testing::InitGoogleTest(&argc, argv);
-  return RUN_ALL_TESTS();
-}
+
+
+#include "gtest/gtest.h"
+
+#include "leveldb/env.h"
+#include "leveldb/db.h"
+
+
+using namespace leveldb;
+// 定义了数据的大小，用于插入大数据集，燕
+constexpr int value_size = 2048;
+constexpr int data_size = 128 << 20;
+
+Status OpenDB(std::string dbName, DB **db) {
+  Options options;
+  options.create_if_missing = true;
+  return DB::Open(options, dbName, db);
+}
+
+void InsertData(DB *db, uint64_t ttl/* second */) {
+  WriteOptions writeOptions;
+  int key_num = data_size / value_size;
+  srand(0);
+
+  for (int i = 0; i < key_num; i++) {
+    int key_ = rand() % key_num+1;
+    // int key_ = i % key_num+1;
+    std::string key = std::to_string(key_);
+    std::string value(value_size, 'a');
+    db->Put(writeOptions, key, value, ttl);
+  }
+}
+
+void GetData(DB *db, int size = (1 << 30)) {
+  ReadOptions readOptions;
+  int key_num = data_size / value_size;
+  
+  // 使用随机种子生成随机键进行点查（单次查询），燕
+  // 点查
+  srand(0);
+  for (int i = 0; i < 100; i++) {
+    int key_ = rand() % key_num+1;
+    //int key_ = i % key_num+1;
+    std::string key = std::to_string(key_);
+    std::string value;   
+    db->Get(readOptions, key, &value);
+  }
+}
+
+TEST(TestTTL, ReadTTL) {
+    DB *db;
+    if(OpenDB("testdb", &db).ok() == false) {
+        std::cerr << "open db failed" << std::endl;
+        abort();
+    }
+
+    uint64_t ttl = 50;
+
+    InsertData(db, ttl);
+
+    ReadOptions readOptions;
+    Status status;
+    int key_num = data_size / value_size;
+    srand(0);
+    for (int i = 0; i < 100; i++) {
+        int key_ = rand() % key_num+1;
+        // int key_ = i % key_num+1;
+        std::string key = std::to_string(key_);
+        std::string value;
+        status = db->Get(readOptions, key, &value);
+        ASSERT_TRUE(status.ok());
+    }
+    // 等待TTL过期，使插入的数据变为“过期”状态，燕
+    Env::Default()->SleepForMicroseconds(ttl * 1000000);
+
+    for (int i = 0; i < 100; i++) {
+        int key_ = rand() % key_num+1;
+        // int key_ = i % key_num+1;
+        std::string key = std::to_string(key_);
+        std::string value;
+        status = db->Get(readOptions, key, &value);
+        ASSERT_FALSE(status.ok());
+    }
+    delete db;
+}
+
+TEST(TestTTL, CompactionTTL) {
+    DB *db;
+
+    if(OpenDB("testdb", &db).ok() == false) {
+        std::cerr << "open db failed" << std::endl;
+        abort();
+    }
+
+    uint64_t ttl = 50;
+    InsertData(db, ttl);
+
+    leveldb::Range ranges[1];
+    ranges[0] = leveldb::Range("-", "A");
+    uint64_t sizes[1];
+    db->GetApproximateSizes(ranges, 1, sizes);
+    ASSERT_GT(sizes[0], 0);
+
+    Env::Default()->SleepForMicroseconds(ttl * 1000000);
+
+    db->CompactRange(nullptr, nullptr);
+
+    // leveldb::Range ranges[1]; // 这里为什么要重复定义？心
+    ranges[0] = leveldb::Range("-", "A");
+    // uint64_t sizes[1]; // 心
+
+    db->GetApproximateSizes(ranges, 1, sizes);
+    ASSERT_EQ(sizes[0], 0);
+}
+
+
+int main(int argc, char** argv) {
+  // All tests currently run with the same read-only file limits.
+  testing::InitGoogleTest(&argc, argv);
+  return RUN_ALL_TESTS();
+}