redis lua

Author: danielshaving

bench/hiredis/hiredissync.cc

@@ -425,14 +425,14 @@ void testThroughPut()
 
 int main(int argc, char* argv[])
 {
-	#ifdef _WIN64
-		WSADATA wsaData;
-		int32_t iRet = WSAStartup(MAKEWORD(2, 2), &wsaData);
-		assert(iRet == 0);
-	#else
-		signal(SIGPIPE, SIG_IGN);
-		signal(SIGHUP, SIG_IGN);
-	#endif
+#ifdef _WIN64
+	WSADATA wsaData;
+	int32_t iRet = WSAStartup(MAKEWORD(2, 2), &wsaData);
+	assert(iRet == 0);
+#else
+	signal(SIGPIPE, SIG_IGN);
+	signal(SIGHUP, SIG_IGN);
+#endif
 
 	struct timeval timeout = { 1, 500000 }; // 1.5 seconds
 

example/hiredis/hiredistest.cc

@@ -390,14 +390,14 @@ void HiredisTest::list()
 
 int main(int argc, char *argv[])
 {
-	#ifdef _WIN64
-		WSADATA wsaData;
-		int32_t iRet = WSAStartup(MAKEWORD(2, 2), &wsaData);
-		assert(iRet == 0);
-	#else
-		signal(SIGPIPE, SIG_IGN);
-		signal(SIGHUP, SIG_IGN);
-	#endif
+#ifdef _WIN64
+	WSADATA wsaData;
+	int32_t iRet = WSAStartup(MAKEWORD(2, 2), &wsaData);
+	assert(iRet == 0);
+#else
+	signal(SIGPIPE, SIG_IGN);
+	signal(SIGHUP, SIG_IGN);
+#endif
 
 	const char *ip = "127.0.0.1";
 	uint16_t port = 6379;

example/http/httptest.cc

@@ -24,7 +24,7 @@ void onMessage(const HttpRequest &req, HttpResponse *resp)
 		if (req.getPath() == "/")
 		{
 			printf("");
-			resp->setStatusCode(HttpResponse::k2000k);
+			resp->setStatusCode(HttpResponse::k200k);
 			resp->setStatusMessage("OK");
 			resp->setContentType("text/html");
 			resp->addHeader("Server", "xHttp");
@@ -35,14 +35,14 @@ void onMessage(const HttpRequest &req, HttpResponse *resp)
 		}
 		else if (req.getPath() == "/favicon.ico")
 		{
-			resp->setStatusCode(HttpResponse::k2000k);
+			resp->setStatusCode(HttpResponse::k200k);
 			resp->setStatusMessage("OK");
 			resp->setContentType("image/png");
 			resp->setBody(std::string(favicon, sizeof favicon));
 		}
 		else if (req.getPath() == "/hello")
 		{
-			resp->setStatusCode(HttpResponse::k2000k);
+			resp->setStatusCode(HttpResponse::k200k);
 			resp->setStatusMessage("OK");
 			resp->setContentType("text/plain");
 			resp->addHeader("Server", "xHttp");
@@ -52,7 +52,7 @@ void onMessage(const HttpRequest &req, HttpResponse *resp)
 		{
 			std::string filename = "attachment;filename=";
 			filename += "test.txt";
-			resp->setStatusCode(HttpResponse::k2000k);
+			resp->setStatusCode(HttpResponse::k200k);
 			resp->setStatusMessage("OK");
 			resp->setContentType("text/plain");
 			resp->addHeader("Content-Disposition", filename);
@@ -67,7 +67,7 @@ void onMessage(const HttpRequest &req, HttpResponse *resp)
 	}
 	else if (req.getMethod() == HttpRequest::kPost)
 	{
-		resp->setStatusCode(HttpResponse::k2000k);
+		resp->setStatusCode(HttpResponse::k200k);
 		resp->setStatusMessage("OK");
 	}
 }

example/leveldb/src/block.cc

@@ -60,7 +60,7 @@ class BlockIterator : public Iterator
 
 	inline int compare(const std::string_view &a, const std::string_view &b) const 
 	{
-		//return comparator->compare(a, b);
+		return comparator->compare(a, b);
 
 		int r = comparator->compare(extractUserKey(a), extractUserKey(b));
 		if (r == 0)
@@ -80,7 +80,6 @@ class BlockIterator : public Iterator
 		return r;
 	}
 
-
 	// Return the offset in data_ just past the end of the current entry.
 	inline uint32_t nextEntryOffset() const 
 	{
@@ -129,7 +128,7 @@ class BlockIterator : public Iterator
 	{
 		clearnups.push_back(arg);
 	}
-	
+
 	virtual bool valid() const { return current < restarts; }
 	virtual Status status() const { return s; }
 	virtual std::string_view key() const

example/leveldb/src/dbformat.cc

@@ -130,7 +130,6 @@ int InternalKeyComparator::compare(const std::string_view &akey, const std::stri
 	//    increasing user key (according to user-supplied comparator)
 	//    decreasing sequence number
 	//    decreasing type (though sequence# should be enough to disambiguate)
-	return comparator->compare(extractUserKey(akey), extractUserKey(bkey));
 	int r = comparator->compare(extractUserKey(akey), extractUserKey(bkey));
 	if (r == 0)
 	{

example/leveldb/src/dbformat.h

@@ -125,8 +125,15 @@ class Comparator
 class BytewiseComparatorImpl : public Comparator
 {
 public:
-	explicit BytewiseComparatorImpl() { }
-	virtual ~BytewiseComparatorImpl() { }
+	explicit BytewiseComparatorImpl()
+	{
+		
+	}
+	
+	virtual ~BytewiseComparatorImpl()
+	{
+	
+	}
 	virtual const char *name() const { return "leveldb.BytewiseComparator"; }
 	virtual int compare(const std::string_view &a, const std::string_view &b) const
 	{
@@ -141,14 +148,22 @@ class BytewiseComparatorImpl : public Comparator
 class InternalKeyComparator : public Comparator
 {
 public:
-	explicit InternalKeyComparator(const Comparator *c) : comparator(c) { }
-	virtual ~InternalKeyComparator() { }
+	explicit InternalKeyComparator(const Comparator *c)
+		: comparator(c)
+	{
+		
+	}
+		
+	virtual ~InternalKeyComparator() 
+	{
+		
+	}
 
 	virtual const char *name() const;
 	virtual void findShortestSeparator(std::string *start, const std::string_view &limit) const;
 	virtual void findShortSuccessor(std::string *key) const;
 	virtual int compare(const std::string_view &a, const std::string_view &b) const;
-	virtual int compare(const InternalKey &a, const InternalKey &b) const;
+	virtual int compare1(const InternalKey &a, const InternalKey &b) const;
 	const Comparator *getComparator() const { return comparator; }
 
 private:
@@ -189,7 +204,7 @@ class InternalKey
 	void clear() { rep.clear(); }
 };
 
-inline int InternalKeyComparator::compare(const InternalKey &a, const InternalKey &b) const
+inline int InternalKeyComparator::compare1(const InternalKey &a, const InternalKey &b) const
 {
 	return compare(a.encode(), b.encode());
 }