aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/threading/future
diff options
context:
space:
mode:
authortobo <tobo@yandex-team.ru>2022-02-10 16:47:27 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:47:27 +0300
commit7fe839092527589b38f014d854c51565b3c1adfa (patch)
tree309e97022d3530044b712b8f71318c78faf7856e /library/cpp/threading/future
parentd0d68c395c10da4cb56a1c845504570a04d7893e (diff)
downloadydb-7fe839092527589b38f014d854c51565b3c1adfa.tar.gz
Restoring authorship annotation for <tobo@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/threading/future')
-rw-r--r--library/cpp/threading/future/subscription/wait_all_or_exception_ut.cpp10
-rw-r--r--library/cpp/threading/future/subscription/wait_all_ut.cpp8
-rw-r--r--library/cpp/threading/future/subscription/wait_any_ut.cpp8
3 files changed, 13 insertions, 13 deletions
diff --git a/library/cpp/threading/future/subscription/wait_all_or_exception_ut.cpp b/library/cpp/threading/future/subscription/wait_all_or_exception_ut.cpp
index 34ae9edb4e..0a9f84ab69 100644
--- a/library/cpp/threading/future/subscription/wait_all_or_exception_ut.cpp
+++ b/library/cpp/threading/future/subscription/wait_all_or_exception_ut.cpp
@@ -29,7 +29,7 @@ Y_UNIT_TEST_SUITE(TWaitAllOrExceptionTest) {
auto w = NWait::WaitAllOrException(p1.GetFuture(), p2.GetFuture());
UNIT_ASSERT(!w.HasValue() && !w.HasException());
- constexpr TStringBuf message = "Test exception";
+ constexpr TStringBuf message = "Test exception";
p1.SetException(std::make_exception_ptr(yexception() << message));
UNIT_ASSERT_EXCEPTION_SATISFIES(w.TryRethrow(), yexception, [message](auto const& e) {
return message == e.what();
@@ -54,7 +54,7 @@ Y_UNIT_TEST_SUITE(TWaitAllOrExceptionTest) {
auto w = NWait::WaitAllOrException(f, p.GetFuture());
UNIT_ASSERT(!w.HasValue() && !w.HasException());
- constexpr TStringBuf message = "Test exception 2";
+ constexpr TStringBuf message = "Test exception 2";
p.SetException(std::make_exception_ptr(yexception() << message));
UNIT_ASSERT_EXCEPTION_SATISFIES(w.TryRethrow(), yexception, [message](auto const& e) {
return message == e.what();
@@ -85,7 +85,7 @@ Y_UNIT_TEST_SUITE(TWaitAllOrExceptionTest) {
auto w = NWait::WaitAllOrException(TVector<TFuture<void>>{ p.GetFuture() });
UNIT_ASSERT(!w.HasValue() && !w.HasException());
- constexpr TStringBuf message = "Test exception 3";
+ constexpr TStringBuf message = "Test exception 3";
p.SetException(std::make_exception_ptr(yexception() << message));
UNIT_ASSERT_EXCEPTION_SATISFIES(w.TryRethrow(), yexception, [message](auto const& e) {
return message == e.what();
@@ -112,7 +112,7 @@ Y_UNIT_TEST_SUITE(TWaitAllOrExceptionTest) {
auto w = NWait::WaitAllOrException(TVector<TFuture<int>>{ p1.GetFuture(), f, p2.GetFuture() });
UNIT_ASSERT(!w.HasValue() && !w.HasException());
- constexpr TStringBuf message = "Test exception 4";
+ constexpr TStringBuf message = "Test exception 4";
p1.SetException(std::make_exception_ptr(yexception() << message));
UNIT_ASSERT_EXCEPTION_SATISFIES(w.TryRethrow(), yexception, [message](auto const& e) {
return message == e.what();
@@ -124,7 +124,7 @@ Y_UNIT_TEST_SUITE(TWaitAllOrExceptionTest) {
Y_UNIT_TEST(TestManyWithVectorAndIntialError) {
auto p1 = NewPromise();
auto p2 = NewPromise();
- constexpr TStringBuf message = "Test exception 5";
+ constexpr TStringBuf message = "Test exception 5";
auto f = MakeErrorFuture<void>(std::make_exception_ptr(yexception() << message));
auto w = NWait::WaitAllOrException(TVector<TFuture<void>>{ p1.GetFuture(), p2.GetFuture(), f });
UNIT_ASSERT_EXCEPTION_SATISFIES(w.TryRethrow(), yexception, [message](auto const& e) {
diff --git a/library/cpp/threading/future/subscription/wait_all_ut.cpp b/library/cpp/threading/future/subscription/wait_all_ut.cpp
index 3bc9762671..73e2d4d6e4 100644
--- a/library/cpp/threading/future/subscription/wait_all_ut.cpp
+++ b/library/cpp/threading/future/subscription/wait_all_ut.cpp
@@ -29,7 +29,7 @@ Y_UNIT_TEST_SUITE(TWaitAllTest) {
auto w = NWait::WaitAll(p1.GetFuture(), p2.GetFuture());
UNIT_ASSERT(!w.HasValue() && !w.HasException());
- constexpr TStringBuf message = "Test exception";
+ constexpr TStringBuf message = "Test exception";
p1.SetException(std::make_exception_ptr(yexception() << message));
UNIT_ASSERT(!w.HasValue() && !w.HasException());
@@ -55,7 +55,7 @@ Y_UNIT_TEST_SUITE(TWaitAllTest) {
auto w = NWait::WaitAll(f, p.GetFuture());
UNIT_ASSERT(!w.HasValue() && !w.HasException());
- constexpr TStringBuf message = "Test exception 2";
+ constexpr TStringBuf message = "Test exception 2";
p.SetException(std::make_exception_ptr(yexception() << message));
UNIT_ASSERT_EXCEPTION_SATISFIES(w.TryRethrow(), yexception, [message](auto const& e) {
return message == e.what();
@@ -86,7 +86,7 @@ Y_UNIT_TEST_SUITE(TWaitAllTest) {
auto w = NWait::WaitAll(TVector<TFuture<void>>{ p.GetFuture() });
UNIT_ASSERT(!w.HasValue() && !w.HasException());
- constexpr TStringBuf message = "Test exception 3";
+ constexpr TStringBuf message = "Test exception 3";
p.SetException(std::make_exception_ptr(yexception() << message));
UNIT_ASSERT_EXCEPTION_SATISFIES(w.TryRethrow(), yexception, [message](auto const& e) {
return message == e.what();
@@ -113,7 +113,7 @@ Y_UNIT_TEST_SUITE(TWaitAllTest) {
auto w = NWait::WaitAll(TVector<TFuture<int>>{ p1.GetFuture(), f, p2.GetFuture() });
UNIT_ASSERT(!w.HasValue() && !w.HasException());
- constexpr TStringBuf message = "Test exception 4";
+ constexpr TStringBuf message = "Test exception 4";
p1.SetException(std::make_exception_ptr(yexception() << message));
UNIT_ASSERT(!w.HasValue() && !w.HasException());
diff --git a/library/cpp/threading/future/subscription/wait_any_ut.cpp b/library/cpp/threading/future/subscription/wait_any_ut.cpp
index 262080e8d1..745072b892 100644
--- a/library/cpp/threading/future/subscription/wait_any_ut.cpp
+++ b/library/cpp/threading/future/subscription/wait_any_ut.cpp
@@ -27,7 +27,7 @@ Y_UNIT_TEST_SUITE(TWaitAnyTest) {
auto w = NWait::WaitAny(p1.GetFuture(), p2.GetFuture());
UNIT_ASSERT(!w.HasValue() && !w.HasException());
- constexpr TStringBuf message = "Test exception";
+ constexpr TStringBuf message = "Test exception";
p2.SetException(std::make_exception_ptr(yexception() << message));
UNIT_ASSERT_EXCEPTION_SATISFIES(w.TryRethrow(), yexception, [message](auto const& e) {
return message == e.what();
@@ -47,7 +47,7 @@ Y_UNIT_TEST_SUITE(TWaitAnyTest) {
Y_UNIT_TEST(TestOneUnsignaledOneSignaledWithException) {
auto p = NewPromise();
- constexpr TStringBuf message = "Test exception 2";
+ constexpr TStringBuf message = "Test exception 2";
auto f = MakeErrorFuture<void>(std::make_exception_ptr(yexception() << message));
auto w = NWait::WaitAny(f, p.GetFuture());
UNIT_ASSERT_EXCEPTION_SATISFIES(w.TryRethrow(), yexception, [message](auto const& e) {
@@ -81,7 +81,7 @@ Y_UNIT_TEST_SUITE(TWaitAnyTest) {
auto w = NWait::WaitAny(TVector<TFuture<void>>{ p.GetFuture() });
UNIT_ASSERT(!w.HasValue() && !w.HasException());
- constexpr TStringBuf message = "Test exception 3";
+ constexpr TStringBuf message = "Test exception 3";
p.SetException(std::make_exception_ptr(yexception() << message));
UNIT_ASSERT_EXCEPTION_SATISFIES(w.TryRethrow(), yexception, [message](auto const& e) {
return message == e.what();
@@ -121,7 +121,7 @@ Y_UNIT_TEST_SUITE(TWaitAnyTest) {
auto w = NWait::WaitAny(TVector<TFuture<void>>{ p1.GetFuture(), p2.GetFuture(), p3.GetFuture() });
UNIT_ASSERT(!w.HasValue() && !w.HasException());
- constexpr TStringBuf message = "Test exception 4";
+ constexpr TStringBuf message = "Test exception 4";
p2.SetException(std::make_exception_ptr(yexception() << message));
UNIT_ASSERT_EXCEPTION_SATISFIES(w.TryRethrow(), yexception, [message](auto const& e) {
return message == e.what();