update cmake, update performance metrics

Author: basiliscos

CMakeLists.txt

@@ -78,7 +78,13 @@ else()
     set(LINK_DEPENDENCIES pthread ${Boost_LIBRARIES} catch_lib) #  asan ubsan
 endif()
 
-set(BOOST_VERSION_OK, (Boost_MAJOR_VERSION GREATER_EQUAL 1) AND (Boost_MINOR_VERSION GREATER_EQUAL 70))
+if ((Boost_MAJOR_VERSION GREATER_EQUAL 1) AND (Boost_MINOR_VERSION GREATER_EQUAL 70))
+    set(BOOST_VERSION_OK true)
+else()
+    set(BOOST_VERSION_OK false)
+endif()
+
+MESSAGE(STATUS "BOOST_VERSION_OK ${BOOST_VERSION_OK}")
 
 add_subdirectory(examples)
 

README.md

@@ -67,7 +67,7 @@ Results achieved with `examples/speed_test_async_multi.cpp` for 1 thread, Intel
 
  | bredis (commands/s) | bredis(*) (commands/s) | redox (commands/s)|
  |---------------------|------------------------|-------------------|
- |      1.59325e+06    |      2.50826e+06       |    0.999375+06    |
+ |      1.80845e+06    |      2.503e+06         |    0.999375+06    |
 
 These results are not completely fair, because of the usage of different semantics in the
 APIs; however they are still interesting, as they are using different

examples/CMakeLists.txt

@@ -2,6 +2,8 @@ find_package(Threads REQUIRED)
 
 set(LINK_DEPENDENCIES ${Boost_LIBRARIES} Threads::Threads)
 
+set(BOOST_VERSION_OK, (Boost_MAJOR_VERSION GREATER_EQUAL 1) AND (Boost_MINOR_VERSION GREATER_EQUAL 70))
+
 add_executable(stream-parse stream-parse.cpp)
 target_link_libraries(stream-parse ${LINK_DEPENDENCIES})
 

examples/speed_test_async_multi.cpp

@@ -11,7 +11,7 @@
 //
 //  bredis (commands/s) | bredis(*) (commands/s) | redox (commands/s)
 // ---------------------+------------------------+---------------------
-//       1.59325e+06    |      2.50826e+06       |    0.999375+06
+//       1.80845e+06    |      2.503e+06         |    0.999375+06
 //
 // Results are not completely fair, because of usage of different semantics in
 // APIs; however they are still interesting, as there are used different
@@ -60,8 +60,8 @@ int main(int argc, char **argv) {
         std::string::allocator_type
     >;
     using Iterator = typename r::to_iterator<Buffer>::iterator_t;
-    using policy_t = r::parsing_policy::drop_result;
-    //using policy_t = r::parsing_policy::keep_result;
+    //using policy_t = r::parsing_policy::drop_result;
+    using policy_t = r::parsing_policy::keep_result;
 
     if (argc < 2) {
         std::cout << "Usage : " << argv[0] << " ip:port \n";

include/bredis/impl/async_op.ipp

@@ -61,7 +61,6 @@ struct result_visitor_t<Iterator, parsing_policy::drop_result>
     size_t operator()(const positive_result_t &parse_result) {
         ++count;
         cumulative_consumption += parse_result.consumed;
-        // return parse_result.consumed;
         return count < replies_count ? parse_result.consumed : 0;
     }