New Test

CMakeLists.txt

@@ -7,6 +7,7 @@ include(cmake/conan.cmake)
 
 conan(
     PACKAGES
+        zlib/1.2.11
         toml11/3.4.0
         libevent/2.1.11
         tbb/2020.1

src/CMakeLists.txt

@@ -1,30 +1,13 @@
+add_subdirectory(compresser)
 add_subdirectory(request)
-add_subdirectory(evclient)
+#add_subdirectory(evclient)
 add_subdirectory(types)
 add_subdirectory(storage)
 add_subdirectory(scheduler)
 add_subdirectory(graph)
 
-add_executable(client)
 add_executable(replica)
 
-target_sources(
-    client
-        PRIVATE
-            client.cpp
-)
-
-target_link_libraries(
-    client
-        PRIVATE
-            CONAN_PKG::tbb
-            CONAN_PKG::toml11
-            request
-            evclient
-            evpaxos
-            types
-)
-
 target_sources(
     replica
         PRIVATE
@@ -36,8 +19,6 @@ target_link_libraries(
         PRIVATE
             CONAN_PKG::toml11
             request
-            evclient
-            evpaxos
             types
             scheduler
 )

src/compresser/CMakeLists.txt

@@ -0,0 +1,15 @@
+add_library(compresser)
+
+target_sources(
+    compresser
+        PUBLIC
+            compresser.h
+        PRIVATE
+            compresser.cpp
+)
+
+target_link_libraries(
+    compresser
+        PUBLIC
+            CONAN_PKG::zlib
+)

src/compresser/compresser.cpp

@@ -0,0 +1,93 @@
+// Copyright 2007 Timo Bingmann <[email protected]>
+// Distributed under the Boost Software License, Version 1.0.
+// (See http://www.boost.org/LICENSE_1_0.txt)
+//
+// Original link http://panthema.net/2007/0328-ZLibString.html
+
+#include "compresser.h"
+
+
+/** Compress a STL string using zlib with given compression level and return
+  * the binary data. */
+std::string compress(const std::string& str,
+                            int compressionlevel/* = Z_BEST_COMPRESSION*/)
+{
+    z_stream zs;                        // z_stream is zlib's control structure
+    memset(&zs, 0, sizeof(zs));
+
+    if (deflateInit(&zs, compressionlevel) != Z_OK)
+        throw(std::runtime_error("deflateInit failed while compressing."));
+
+    zs.next_in = (Bytef*)str.data();
+    zs.avail_in = str.size();           // set the z_stream's input
+
+    int ret;
+    char outbuffer[4096];
+    std::string outstring;
+
+    // retrieve the compressed bytes blockwise
+    do {
+        zs.next_out = reinterpret_cast<Bytef*>(outbuffer);
+        zs.avail_out = sizeof(outbuffer);
+
+        ret = deflate(&zs, Z_FINISH);
+
+        if (outstring.size() < zs.total_out) {
+            // append the block to the output string
+            outstring.append(outbuffer,
+                             zs.total_out - outstring.size());
+        }
+    } while (ret == Z_OK);
+
+    deflateEnd(&zs);
+
+    if (ret != Z_STREAM_END) {          // an error occurred that was not EOF
+        std::ostringstream oss;
+        oss << "Exception during zlib compression: (" << ret << ") " << zs.msg;
+        throw(std::runtime_error(oss.str()));
+    }
+
+    return outstring;
+}
+
+/** Decompress an STL string using zlib and return the original data. */
+std::string decompress(const std::string& str)
+{
+    z_stream zs;                        // z_stream is zlib's control structure
+    memset(&zs, 0, sizeof(zs));
+
+    if (inflateInit(&zs) != Z_OK)
+        throw(std::runtime_error("inflateInit failed while decompressing."));
+
+    zs.next_in = (Bytef*)str.data();
+    zs.avail_in = str.size();
+
+    int ret;
+    char outbuffer[4096];
+    std::string outstring;
+
+    // get the decompressed bytes blockwise using repeated calls to inflate
+    do {
+        zs.next_out = reinterpret_cast<Bytef*>(outbuffer);
+        zs.avail_out = sizeof(outbuffer);
+
+        ret = inflate(&zs, 0);
+
+        if (outstring.size() < zs.total_out) {
+            outstring.append(outbuffer,
+                             zs.total_out - outstring.size());
+        }
+
+    } while (ret == Z_OK);
+
+    inflateEnd(&zs);
+
+    if (ret != Z_STREAM_END) {          // an error occurred that was not EOF
+        std::ostringstream oss;
+        oss << "Exception during zlib decompression: (" << ret << ") "
+            << zs.msg;
+        throw(std::runtime_error(oss.str()));
+    }
+
+    return outstring;
+}