change leveldb to rocksdb

.gitmodules

@@ -1,6 +1,6 @@
-[submodule "third/leveldb"]
-	path = third/leveldb
-	url = https://github.com/google/leveldb.git
 [submodule "third/glog"]
 	path = third/glog
 	url = https://github.com/google/glog.git
+[submodule "third/nemo"]
+	path = third/nemo
+	url = [email protected]:baotiao/nemo.git

Makefile

@@ -1,5 +1,5 @@
 CXX = g++
-CXXFLAGS = -Wall -W -DDEBUG -g -O0 -D__XDEBUG__ -fPIC -Wno-unused-function
+CXXFLAGS = -Wall -W -DDEBUG -g -O0 -D__XDEBUG__ -fPIC -Wno-unused-function -std=c++11
 OBJECT = pika
 SRC_DIR = ./src
 THIRD_PATH = ./third
@@ -9,15 +9,21 @@ OUTPUT = ./output
 INCLUDE_PATH = -I./include/ \
 			   -I./src/ \
 			   -I$(THIRD_PATH)/glog/src/ \
-			   -I$(THIRD_PATH)/leveldb/include/ 
+			   -I$(THIRD_PATH)/nemo/output/include/ 
 
 LIB_PATH = -L./ \
-		   -L$(THIRD_PATH)/leveldb/
+		   -L$(THIRD_PATH)/nemo/output/lib/ \
+		   -L$(THIRD_PATH)/nemo/3rdparty/rocksdb/
 
 
 LIBS = -lpthread \
 	   -lglog \
-	   -lleveldb
+	   -lnemo \
+	   -lrocksdb \
+	   -lz \
+	   -lbz2 \
+	   -lsnappy \
+	   -lrt
 
 GLOG = /usr/local/lib/libglog.a
 
@@ -42,7 +48,7 @@ all: $(OBJECT)
 
 
 $(OBJECT): $(GLOG) $(OBJS)
-	make -C $(THIRD_PATH)/leveldb/
+	make -C $(THIRD_PATH)/nemo/
 	$(CXX) $(CXXFLAGS) -o $@ $(OBJS) $(INCLUDE_PATH) $(LIB_PATH) -Wl,-Bdynamic $(LIBS)
 
 $(GLOG):

include/pika_server.h

@@ -16,8 +16,9 @@
 #include "csapp.h"
 #include "xdebug.h"
 #include "pika_define.h"
-#include "leveldb/db.h"
-#include "leveldb/write_batch.h"
+#include "nemo.h"
+//#include "leveldb/db.h"
+//#include "leveldb/write_batch.h"
 
 class PikaThread;
 class PikaEpoll;
@@ -32,7 +33,7 @@ class PikaServer
     void RunProcess();
 
     static void* StartThread(void* arg);
-    leveldb::DB* GetHandle() {return db_;};
+    nemo::Nemo* GetHandle() {return db_;};
 
 private:
     friend class PikaConn;
@@ -54,9 +55,10 @@ class PikaServer
     /*
      * The leveldb handler
      */
-    leveldb::DB *db_;
+    nemo::Nemo *db_;
+ //   leveldb::DB *db_;
 
-    leveldb::Options options_;
+ //   leveldb::Options options_;
 
     /*
      * Here we used auto poll to find the next work thread,

src/pika_cmdget.cc

@@ -1,6 +1,5 @@
 #include "pika_command.h"
 #include "pika_server.h"
-#include "leveldb/db.h"
 #include <algorithm>
 #include <map>
 
@@ -18,7 +17,7 @@ void GetCmd::Do(std::list<std::string> &argv, std::string &ret) {
     std::string key = argv.front();
     argv.pop_front();
     std::string value;
-    leveldb::Status s = g_pikaServer->GetHandle()->Get(leveldb::ReadOptions(), key, &value);
+    nemo::Status s = g_pikaServer->GetHandle()->Get(key, &value);
     if (s.ok()) {
         char buf[32];
         snprintf(buf, sizeof(buf), "$%d\r\n", (int)value.size());

src/pika_cmdset.cc

@@ -1,6 +1,5 @@
 #include "pika_command.h"
 #include "pika_server.h"
-#include "leveldb/db.h"
 #include <algorithm>
 #include <map>
 
@@ -45,7 +44,7 @@ void SetCmd::Do(std::list<std::string> &argv, std::string &ret) {
             return;
         }
     }
-    leveldb::Status s = g_pikaServer->GetHandle()->Put(leveldb::WriteOptions(), key, value);
+    nemo::Status s = g_pikaServer->GetHandle()->Set(key, value);
     if (s.ok()) {
         ret = "+OK\r\n";
     } else {

src/pika_conn.cc

@@ -1,7 +1,6 @@
 #include "pika_conn.h"
 #include "pika_util.h"
 #include "pika_command.h"
-#include "leveldb/db.h"
 #include "pika_define.h"
 #include "zmalloc.h"
 #include "util.h"

src/pika_server.cc

@@ -57,13 +57,14 @@ PikaServer::PikaServer()
         pikaThread_[i] = new PikaThread();
     }
 
-    options_.create_if_missing = true;
-    options_.write_buffer_size = 1500000000;
+//    options_.create_if_missing = true;
+//    options_.write_buffer_size = 1500000000;
 //    leveldb::Status s = leveldb::DB::Open(options_, "/tmp/testdb", &db_);
-    leveldb::Status s = leveldb::DB::Open(options_, "/tmp/testdb", &db_);
-    if (!s.ok()) {
-        log_err("Open db failed");
-    }
+//    leveldb::Status s = leveldb::DB::Open(options_, "/tmp/testdb", &db_);
+    db_ = new nemo::Nemo("/tmp/testdb");
+//    if (!s.ok()) {
+//        log_err("Open db failed");
+//    }
 
     // start the pikaThread_ thread
     for (int i = 0; i < g_pikaConf->thread_num(); i++) {