Merge pull request #14977 from ydb-platform/merge-libs-250225-0058

Author: alexv-smirnov

build/plugins/_dart_fields.py

@@ -670,7 +670,7 @@ def cpp_configs(cls, unit, flat_args, spec_args):
 class LintExtraParams:
     KEY = 'LINT-EXTRA-PARAMS'
 
-    _CUSTOM_CLANG_FORMAT_BIN_ALLOWED_PATHS = consts.CUSTOM_CLANG_FORMAT_YT_ALLOWED_PATHS
+    _CUSTOM_CLANG_FORMAT_BIN_ALLOWED_PATHS = ('ads', 'bigrt', 'grut')
 
     @classmethod
     def from_macro_args(cls, unit, flat_args, spec_args):

build/plugins/lib/test_const/__init__.py

@@ -476,8 +476,6 @@ class DefaultLinterConfig(Enum):
     'build/internal/conf/autoincludes.json',
 )
 
-CUSTOM_CLANG_FORMAT_YT_ALLOWED_PATHS = ('ads', 'bigrt', 'grut')
-
 
 class Status(object):
     GOOD, XFAIL, FAIL, XPASS, MISSING, CRASHED, TIMEOUT = range(1, 8)

build/sysincl/darwin.yml

@@ -176,6 +176,7 @@
   - util.h
   - uuid/uuid.h
   - vis.h
+  - xpc/connection.h
   - xpc/xpc.h
 
   # OSX frameworks

contrib/libs/cxxsupp/libcxxmsvc/include/initializer_list

@@ -47,12 +47,14 @@ template<class E> const E* end(initializer_list<E> il) noexcept; // constexpr in
 
 #if defined(_LIBCPP_COMPILER_MSVC) && !defined(__clang__)
 
-// save __cpp_lib_concepts because it can be redefined inside MSVC standard headers
+// save __cpp_lib_concepts and __cpp_lib_ranges because they can be redefined inside MSVC standard headers
 #pragma push_macro("__cpp_lib_concepts")
+#pragma push_macro("__cpp_lib_ranges")
 
 #include Y_MSVC_INCLUDE_NEXT(yvals.h)
 
 #pragma pop_macro("__cpp_lib_concepts")
+#pragma pop_macro("__cpp_lib_ranges")
 
 #include Y_MSVC_INCLUDE_NEXT(initializer_list)
 

contrib/libs/cxxsupp/libcxxrt/cxxabi.h

@@ -22,6 +22,7 @@
 
 #ifndef __CXXABI_H_
 #define __CXXABI_H_
+#include <stddef.h>
 #include <stdint.h>
 #include "unwind.h"
 namespace std 

contrib/libs/cxxsupp/libcxxrt/exception.cc

@@ -287,31 +287,6 @@ namespace std
 
 using namespace ABI_NAMESPACE;
 
-/**
- * Callback function used with _Unwind_Backtrace().
- *
- * Prints a stack trace.  Used only for debugging help.
- *
- * Note: As of FreeBSD 8.1, dladd() still doesn't work properly, so this only
- * correctly prints function names from public, relocatable, symbols.
- */
-static _Unwind_Reason_Code trace(struct _Unwind_Context *context, void *c)
-{
-	Dl_info myinfo;
-	int mylookup =
-		dladdr(reinterpret_cast<void *>(__cxa_current_exception_type), &myinfo);
-	void *ip = reinterpret_cast<void*>(_Unwind_GetIP(context));
-	Dl_info info;
-	if (dladdr(ip, &info) != 0)
-	{
-		if (mylookup == 0 || strcmp(info.dli_fname, myinfo.dli_fname) != 0)
-		{
-			printf("%p:%s() in %s\n", ip, info.dli_sname, info.dli_fname);
-		}
-	}
-	return _URC_CONTINUE_UNWIND;
-}
-
 static void bt_terminate_handler() {
     __cxa_eh_globals* globals = __cxa_get_globals();
     __cxa_exception* thrown_exception = globals->caughtExceptions;
@@ -784,6 +759,31 @@ void __cxa_free_dependent_exception(void *thrown_exception)
 	free_exception(reinterpret_cast<char*>(thrown_exception) - dependent_exception_size - backtrace_buffer_size);
 }
 
+/**
+ * Callback function used with _Unwind_Backtrace().
+ *
+ * Prints a stack trace.  Used only for debugging help.
+ *
+ * Note: As of FreeBSD 8.1, dladd() still doesn't work properly, so this only
+ * correctly prints function names from public, relocatable, symbols.
+ */
+static _Unwind_Reason_Code trace(struct _Unwind_Context *context, void *c)
+{
+	Dl_info myinfo;
+	int mylookup =
+		dladdr(reinterpret_cast<void *>(__cxa_current_exception_type), &myinfo);
+	void *ip = reinterpret_cast<void*>(_Unwind_GetIP(context));
+	Dl_info info;
+	if (dladdr(ip, &info) != 0)
+	{
+		if (mylookup == 0 || strcmp(info.dli_fname, myinfo.dli_fname) != 0)
+		{
+			printf("%p:%s() in %s\n", ip, info.dli_sname, info.dli_fname);
+		}
+	}
+	return _URC_CONTINUE_UNWIND;
+}
+
 /**
  * Report a failure that occurred when attempting to throw an exception.
  *

contrib/libs/cxxsupp/libcxxrt/ya.make

@@ -1,4 +1,4 @@
-# Generated by devtools/yamaker from nixpkgs 22.11.
+# Generated by devtools/yamaker from nixpkgs 24.05.
 
 LIBRARY()
 

library/python/monlib/metric.pxd

@@ -48,9 +48,9 @@ cdef extern from "library/cpp/monlib/metrics/metric.h" namespace "NMonitoring" n
     cdef cppclass TCounter:
         TCounter(ui64 value) except +
 
-        void Set(ui64)
         ui64 Get() const
-        void Inc()
+        ui64 Add(ui64)
+        ui64 Inc()
         void Reset()
 
     cdef cppclass TRate:

library/python/monlib/metric.pyx

@@ -103,6 +103,12 @@ cdef class Counter:
         """
         return self.__wrapped.Inc()
 
+    def add(self, i64 value):
+        """
+        Add value to metric
+        """
+        return self.__wrapped.Add(value)
+
     def reset(self):
         """
         Reset metric value to zero

library/python/monlib/ut/py2/test.py

@@ -252,6 +252,16 @@ def test_gauge_sensors():
     assert ig.get() == 5
 
 
+def test_counter():
+    registry = MetricRegistry()
+    c = registry.counter({'a': 'b'})
+
+    assert c.inc() == 1
+    assert c.add(2) == 3
+    c.reset()
+    assert c.get() == 0
+
+
 UNISTAT_DATA = """[
     ["signal1_max", 10],
     ["signal2_hgram", [[0, 100], [50, 200], [200, 300]]],

library/python/monlib/ut/py3/test.py

@@ -250,6 +250,16 @@ def test_gauge_sensors():
     assert ig.get() == 5
 
 
+def test_counter():
+    registry = MetricRegistry()
+    c = registry.counter({'a': 'b'})
+
+    assert c.inc() == 1
+    assert c.add(2) == 3
+    c.reset()
+    assert c.get() == 0
+
+
 UNISTAT_DATA = """[
     ["signal1_max", 10],
     ["signal2_hgram", [[0, 100], [50, 200], [200, 300]]],

util/datetime/benchmark/gmtime_r/main.cpp

@@ -3,63 +3,84 @@
 #include <util/datetime/base.h>
 #include <util/random/fast.h>
 
-void BM_GmTimeR(benchmark::State& state) {
-    time_t now = TInstant::Now().TimeT();
-    struct tm buf {};
+using TRandomEngine = TFastRng<ui64>;
 
-    for (auto _ : state) {
-        Y_DO_NOT_OPTIMIZE_AWAY(GmTimeR(&now, &buf));
-    }
-}
+namespace {
 
-void BM_gmtime_r(benchmark::State& state) {
-    time_t now = TInstant::Now().TimeT();
-    struct tm buf {};
+    class TTimeRange {
+    public:
+        TTimeRange(TInstant base, TDuration spread)
+            : TTimeRange(base.Seconds(), spread.Seconds())
+        {
+        }
 
-    for (auto _ : state) {
-        Y_DO_NOT_OPTIMIZE_AWAY(gmtime_r(&now, &buf));
-    }
-}
+        TTimeRange(time_t base, time_t spread)
+            : Base_(base)
+            , Spread_(spread)
+        {
+            Y_ASSERT(Spread_ >= 0);
+        }
 
-void BM_GmTimeRRandom(benchmark::State& state, TDuration window) {
-    time_t now = TInstant::Now().TimeT();
-    struct tm buf {};
+        time_t Next(TRandomEngine& gen) const {
+            if (Spread_ <= 1) {
+                return Base_;
+            }
+            time_t offset = gen.GenRand() % Spread_;
+            return Base_ + offset;
+        }
 
-    TFastRng<ui32> rng(2);
-    const size_t range = window.Seconds();
-    for (auto _ : state) {
-        size_t offset = rng.GenRand() % range;
-        time_t v = now - offset;
-        Y_DO_NOT_OPTIMIZE_AWAY(GmTimeR(&v, &buf));
+    private:
+        time_t Base_;
+        time_t Spread_;
+    };
+
+    // change base date after `BATCH_SIZE` iterations to reduce the effect of changing the benchmark's speed depending on the day it was launched
+    const TDuration FOUR_YEARS = TDuration::Days(1461); // the interval length should be at least four years so that the probability of choosing a leap day/year is not greatly skewed
+    const TTimeRange BASE_TIME{TInstant::Now(), FOUR_YEARS};
+    const size_t BATCH_SIZE = 5'000;
+
+} // namespace
+
+void BM_GmTimeR(benchmark::State& state, TDuration window) {
+    struct tm buf {};
+    TRandomEngine rng(2);
+    const time_t range = window.Seconds();
+    while (state.KeepRunningBatch(BATCH_SIZE)) {
+        const TTimeRange time{BASE_TIME.Next(rng) - range, range};
+        for (size_t i = 0; i < BATCH_SIZE; ++i) {
+            time_t v = time.Next(rng);
+            Y_DO_NOT_OPTIMIZE_AWAY(GmTimeR(&v, &buf));
+        }
     }
 }
 
-void BM_gmtime_r_Random(benchmark::State& state, TDuration window) {
-    time_t now = TInstant::Now().TimeT();
+void BM_gmtime_r(benchmark::State& state, TDuration window) {
     struct tm buf {};
-
-    TFastRng<ui32> rng(2);
-    const size_t range = window.Seconds();
-    for (auto _ : state) {
-        size_t offset = rng.GenRand() % range;
-        time_t v = now - offset;
-        Y_DO_NOT_OPTIMIZE_AWAY(gmtime_r(&v, &buf));
+    TRandomEngine rng(2);
+    const time_t range = window.Seconds();
+    while (state.KeepRunningBatch(BATCH_SIZE)) {
+        const TTimeRange time{BASE_TIME.Next(rng) - range, range};
+        for (size_t i = 0; i < BATCH_SIZE; ++i) {
+            time_t v = time.Next(rng);
+            Y_DO_NOT_OPTIMIZE_AWAY(gmtime_r(&v, &buf));
+        }
     }
 }
 
-BENCHMARK(BM_GmTimeR);
-BENCHMARK(BM_gmtime_r);
-BENCHMARK_CAPTURE(BM_GmTimeRRandom, last_hour, TDuration::Hours(1));
-BENCHMARK_CAPTURE(BM_gmtime_r_Random, last_hour, TDuration::Hours(1));
-BENCHMARK_CAPTURE(BM_GmTimeRRandom, last_day, TDuration::Days(1));
-BENCHMARK_CAPTURE(BM_gmtime_r_Random, last_day, TDuration::Days(1));
-BENCHMARK_CAPTURE(BM_GmTimeRRandom, last_month, TDuration::Days(31));
-BENCHMARK_CAPTURE(BM_gmtime_r_Random, last_month, TDuration::Days(31));
-BENCHMARK_CAPTURE(BM_GmTimeRRandom, last_year, TDuration::Days(365));
-BENCHMARK_CAPTURE(BM_gmtime_r_Random, last_year, TDuration::Days(365));
-BENCHMARK_CAPTURE(BM_GmTimeRRandom, last_decade, TDuration::Days(3653));
-BENCHMARK_CAPTURE(BM_gmtime_r_Random, last_decade, TDuration::Days(3653));
-BENCHMARK_CAPTURE(BM_GmTimeRRandom, last_half_century, TDuration::Days(18262));
-BENCHMARK_CAPTURE(BM_gmtime_r_Random, last_half_century, TDuration::Days(18262));
-BENCHMARK_CAPTURE(BM_GmTimeRRandom, last_century, TDuration::Days(36525));
-BENCHMARK_CAPTURE(BM_gmtime_r_Random, last_century, TDuration::Days(36525));
+BENCHMARK_CAPTURE(BM_GmTimeR, now, TDuration::Seconds(0));
+BENCHMARK_CAPTURE(BM_GmTimeR, last_hour, TDuration::Hours(1));
+BENCHMARK_CAPTURE(BM_GmTimeR, last_day, TDuration::Days(1));
+BENCHMARK_CAPTURE(BM_GmTimeR, last_month, TDuration::Days(31));
+BENCHMARK_CAPTURE(BM_GmTimeR, last_year, TDuration::Days(365));
+BENCHMARK_CAPTURE(BM_GmTimeR, last_decade, TDuration::Days(3653));
+BENCHMARK_CAPTURE(BM_GmTimeR, last_half_century, TDuration::Days(18262));
+BENCHMARK_CAPTURE(BM_GmTimeR, last_century, TDuration::Days(36525));
+
+BENCHMARK_CAPTURE(BM_gmtime_r, now, TDuration::Seconds(0));
+BENCHMARK_CAPTURE(BM_gmtime_r, last_hour, TDuration::Hours(1));
+BENCHMARK_CAPTURE(BM_gmtime_r, last_day, TDuration::Days(1));
+BENCHMARK_CAPTURE(BM_gmtime_r, last_month, TDuration::Days(31));
+BENCHMARK_CAPTURE(BM_gmtime_r, last_year, TDuration::Days(365));
+BENCHMARK_CAPTURE(BM_gmtime_r, last_decade, TDuration::Days(3653));
+BENCHMARK_CAPTURE(BM_gmtime_r, last_half_century, TDuration::Days(18262));
+BENCHMARK_CAPTURE(BM_gmtime_r, last_century, TDuration::Days(36525));