aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorrobot-piglet <robot-piglet@yandex-team.com>2024-02-25 02:23:01 +0300
committerrobot-piglet <robot-piglet@yandex-team.com>2024-02-25 02:32:17 +0300
commitf9e45d9dd1fc7c858cb65aac7b3bf357b443545c (patch)
tree46530e740c1864fd35692435837fd0d86ffca170
parent08c117d96c1fcb5f5e17328f4fe2899e6a384e74 (diff)
downloadydb-f9e45d9dd1fc7c858cb65aac7b3bf357b443545c.tar.gz
Intermediate changes
-rw-r--r--contrib/libs/clang14-rt/lib/sanitizer_common/sanitizer_procmaps_solaris.cpp2
-rw-r--r--contrib/libs/clang14-rt/lib/sanitizer_common/sanitizer_solaris.cpp2
-rw-r--r--contrib/libs/clang16-rt/lib/sanitizer_common/sanitizer_procmaps_solaris.cpp2
-rw-r--r--contrib/libs/clang16-rt/lib/sanitizer_common/sanitizer_solaris.cpp2
-rw-r--r--yt/yt/core/actions/invoker.h15
5 files changed, 15 insertions, 8 deletions
diff --git a/contrib/libs/clang14-rt/lib/sanitizer_common/sanitizer_procmaps_solaris.cpp b/contrib/libs/clang14-rt/lib/sanitizer_common/sanitizer_procmaps_solaris.cpp
index e16c4e938c..31818da628 100644
--- a/contrib/libs/clang14-rt/lib/sanitizer_common/sanitizer_procmaps_solaris.cpp
+++ b/contrib/libs/clang14-rt/lib/sanitizer_common/sanitizer_procmaps_solaris.cpp
@@ -16,7 +16,7 @@
#include "sanitizer_common.h"
#include "sanitizer_procmaps.h"
-#include <procfs.h>
+#error #include <procfs.h>
#include <limits.h>
namespace __sanitizer {
diff --git a/contrib/libs/clang14-rt/lib/sanitizer_common/sanitizer_solaris.cpp b/contrib/libs/clang14-rt/lib/sanitizer_common/sanitizer_solaris.cpp
index 62c40affc9..d95e5a9500 100644
--- a/contrib/libs/clang14-rt/lib/sanitizer_common/sanitizer_solaris.cpp
+++ b/contrib/libs/clang14-rt/lib/sanitizer_common/sanitizer_solaris.cpp
@@ -27,7 +27,7 @@
#include <pthread.h>
#include <sched.h>
#include <thread.h>
-#include <synch.h>
+#error #include <synch.h>
#include <signal.h>
#include <sys/mman.h>
#include <sys/resource.h>
diff --git a/contrib/libs/clang16-rt/lib/sanitizer_common/sanitizer_procmaps_solaris.cpp b/contrib/libs/clang16-rt/lib/sanitizer_common/sanitizer_procmaps_solaris.cpp
index eeb49e2afe..a2fe93566d 100644
--- a/contrib/libs/clang16-rt/lib/sanitizer_common/sanitizer_procmaps_solaris.cpp
+++ b/contrib/libs/clang16-rt/lib/sanitizer_common/sanitizer_procmaps_solaris.cpp
@@ -15,7 +15,7 @@
#if SANITIZER_SOLARIS
# include <fcntl.h>
# include <limits.h>
-# include <procfs.h>
+# error #include <procfs.h>
# include "sanitizer_common.h"
# include "sanitizer_procmaps.h"
diff --git a/contrib/libs/clang16-rt/lib/sanitizer_common/sanitizer_solaris.cpp b/contrib/libs/clang16-rt/lib/sanitizer_common/sanitizer_solaris.cpp
index 62c40affc9..d95e5a9500 100644
--- a/contrib/libs/clang16-rt/lib/sanitizer_common/sanitizer_solaris.cpp
+++ b/contrib/libs/clang16-rt/lib/sanitizer_common/sanitizer_solaris.cpp
@@ -27,7 +27,7 @@
#include <pthread.h>
#include <sched.h>
#include <thread.h>
-#include <synch.h>
+#error #include <synch.h>
#include <signal.h>
#include <sys/mman.h>
#include <sys/resource.h>
diff --git a/yt/yt/core/actions/invoker.h b/yt/yt/core/actions/invoker.h
index b70c177e3e..49c231879f 100644
--- a/yt/yt/core/actions/invoker.h
+++ b/yt/yt/core/actions/invoker.h
@@ -29,13 +29,20 @@ struct IInvoker
//! in some sense.
virtual bool CheckAffinity(const IInvokerPtr& invoker) const = 0;
- //! Returns true if invoker is serialized, i.e. never executes
- //! two callbacks concurrently.
+ //! Returns true if the invoker is serialized, i.e. no two callbacks can execute
+ //! concurrently.
+ /*!
+ * Note, however, that if a callback yields the execution context
+ * (e.g. by calling #WaitFor) another one can start running (or be resumed) within the
+ * same serialized invoker.
+ */
virtual bool IsSerialized() const = 0;
- using TWaitTimeObserver = std::function<void(TDuration)>;
+ using TWaitTimeObserver = std::function<void(TDuration waitTime)>;
+ //! Registers a callback that could be invoked to inform
+ //! of the current wait time for invocations via this invoker.
+ //! These invocations, however, are not guaranteed.
virtual void RegisterWaitTimeObserver(TWaitTimeObserver waitTimeObserver) = 0;
-
};
DEFINE_REFCOUNTED_TYPE(IInvoker)