wip

Author: Erixonich

modules/platforms/cpp/ignite/common/CMakeLists.txt

@@ -47,8 +47,12 @@ set(SOURCES
     big_integer.cpp
     detail/mpi.cpp
     detail/string_utils.cpp
+    detail/string_extensions.cpp
     detail/thread_timer.cpp
     uuid.cpp
+    detail/hash_calculator.cpp
+    detail/hash_utils.cpp
+    detail/Murmur3Hash.cpp
 )
 
 add_library(${TARGET} STATIC ${SOURCES})
@@ -71,3 +75,4 @@ ignite_test(thread_timer_test DISCOVER SOURCES detail/thread_timer_test.cpp LIBS
 ignite_test(uuid_test DISCOVER SOURCES uuid_test.cpp LIBS ${TARGET})
 ignite_test(bignum_test DISCOVER SOURCES bignum_test.cpp LIBS ${TARGET})
 ignite_test(primitive_test DISCOVER SOURCES primitive_test.cpp LIBS ${TARGET})
+ignite_test(hash_utils_test DISCOVER SOURCES detail/hash_utils_test.cpp LIBS ${TARGET})

modules/platforms/cpp/ignite/common/big_decimal.cpp

@@ -40,18 +40,34 @@ big_decimal::big_decimal(const std::byte *data, std::size_t size) {
     m_magnitude = big_integer(data + sizeof(m_scale), size - sizeof(m_scale));
 }
 
-void big_decimal::set_scale(std::int16_t new_scale, big_decimal &res) const {
-    if (m_scale == new_scale)
+void big_decimal::set_scale(std::int16_t new_scale, big_decimal &res, rounding_mode r_mode) const {
+    if (m_scale == new_scale) {
+        res = *this;
         return;
+    }
+
 
     auto diff = std::int16_t(m_scale - new_scale);
 
     big_integer adjustment;
 
     if (diff > 0) {
         big_integer::get_power_of_ten(diff, adjustment);
+        big_integer rem;
+
+        m_magnitude.divide(adjustment, res.m_magnitude, &rem);
 
-        m_magnitude.divide(adjustment, res.m_magnitude);
+        if (r_mode == rounding_mode::HALF_UP) {
+            rem.add(rem, rem);
+            if (rem.compare(adjustment, true) >= 0) {
+                static const big_integer plus_one{1};
+                static const big_integer minus_one{-1};
+
+                auto& fix = rem.get_sign() == 1 ? plus_one : minus_one;
+
+                res.m_magnitude.add(fix, res.m_magnitude);
+            }
+        }
     } else {
         big_integer::get_power_of_ten(-diff, adjustment);
 

modules/platforms/cpp/ignite/common/big_decimal.h

@@ -34,6 +34,13 @@ namespace ignite {
  */
 class big_decimal {
 public:
+
+    enum class rounding_mode {
+        // TODO support other rounding modes
+        DOWN,
+        HALF_UP
+    };
+
     // Default
     big_decimal() = default;
 
@@ -51,7 +58,7 @@ class big_decimal {
      */
     big_decimal(const std::int8_t *mag, std::int32_t len, std::int16_t scale, std::int8_t sign, bool big_endian = true)
         : m_scale(std::int16_t(scale & 0x7FFF))
-        , m_magnitude(mag, len, sign, big_endian) {}
+        , m_magnitude(mag, len, sign, big_endian) { }
 
     /**
      * Constructs a big decimal from the byte array.
@@ -67,7 +74,7 @@ class big_decimal {
      * @param val Integer value.
      */
     explicit big_decimal(int64_t val)
-        : m_magnitude(val) {}
+        : m_magnitude(val) { }
 
     /**
      * Integer constructor with scale.
@@ -77,7 +84,7 @@ class big_decimal {
      */
     big_decimal(int64_t val, int16_t scale)
         : m_scale(scale)
-        , m_magnitude(val) {}
+        , m_magnitude(val) { }
 
     /**
      * big_integer constructor with scale.
@@ -87,7 +94,7 @@ class big_decimal {
      */
     big_decimal(const big_integer &val, int16_t scale)
         : m_scale(scale)
-        , m_magnitude(val) {}
+        , m_magnitude(val) { }
 
     /**
      * big_integer constructor with scale.
@@ -97,7 +104,7 @@ class big_decimal {
      */
     big_decimal(big_integer &&val, int16_t scale)
         : m_scale(scale)
-        , m_magnitude(std::forward<big_integer>(val)) {}
+        , m_magnitude(std::forward<big_integer>(val)) { }
 
     /**
      * String constructor.
@@ -212,7 +219,7 @@ class big_decimal {
      * @param scale Scale to set.
      * @param res Result is placed here. Can be *this.
      */
-    void set_scale(std::int16_t new_scale, big_decimal &res) const;
+    void set_scale(std::int16_t new_scale, big_decimal &res, rounding_mode r_mode = rounding_mode::DOWN) const;
 
     /**
      * Get precision of the Decimal.

modules/platforms/cpp/ignite/common/bignum_test.cpp

@@ -1290,3 +1290,37 @@ TEST(bignum, TestDoubleCast) {
     CheckDoubleCast(-0.00000000000001);
     CheckDoubleCast(-0.000000000000001);
 }
+
+
+struct big_decimal_rounding_tc {
+    big_decimal initial;
+    int16_t new_scale;
+    big_decimal expected;
+};
+
+class big_decimal_rounding_test : public ::testing::TestWithParam<big_decimal_rounding_tc> {};
+
+TEST_P(big_decimal_rounding_test, TestScaleWithRoundHalfUp) {
+    auto [initial, new_scale, expected] = GetParam();;
+
+    big_decimal actual;
+    initial.set_scale(new_scale, actual, big_decimal::rounding_mode::HALF_UP);
+
+    ASSERT_EQ(expected, actual);
+}
+
+INSTANTIATE_TEST_SUITE_P(
+    ScaleWithRoundHalfUp,
+    big_decimal_rounding_test,
+    ::testing::Values(
+        big_decimal_rounding_tc{big_decimal{0}, 0, big_decimal{0}},
+        big_decimal_rounding_tc{big_decimal{1}, 0, big_decimal{1}},
+        big_decimal_rounding_tc{big_decimal{-1}, 0, big_decimal{-1}},
+        big_decimal_rounding_tc{big_decimal{"1.5"}, 0, big_decimal{2}},
+        big_decimal_rounding_tc{big_decimal{"-1.5"}, 0, big_decimal{-2}},
+        big_decimal_rounding_tc{big_decimal{"3.64586"}, 2, big_decimal{"3.65"}},
+        big_decimal_rounding_tc{big_decimal{"3.64586"}, 1, big_decimal{"3.6"}},
+        big_decimal_rounding_tc{big_decimal{"-3.64586"}, 2, big_decimal{"-3.65"}},
+        big_decimal_rounding_tc{big_decimal{"-3.64586"}, 1, big_decimal{"-3.6"}}
+    )
+);