cedric pushed a commit to branch master.
http://git.enlightenment.org/core/efl.git/commit/?id=e43d72710bb4c8f588b8a262f1a1a2040ec7ad78
commit e43d72710bb4c8f588b8a262f1a1a2040ec7ad78
Author: Cedric BAIL <ced...@osg.samsung.com>
Date: Mon Apr 30 15:13:40 2018 -0700
eo_cxx: remove tests related to old Efl_Future.
---
src/tests/eo_cxx/eo_cxx_test_promise.cc | 987 --------------------------------
1 file changed, 987 deletions(-)
diff --git a/src/tests/eo_cxx/eo_cxx_test_promise.cc
b/src/tests/eo_cxx/eo_cxx_test_promise.cc
index 642c9c00c4..86d1534331 100644
--- a/src/tests/eo_cxx/eo_cxx_test_promise.cc
+++ b/src/tests/eo_cxx/eo_cxx_test_promise.cc
@@ -8,994 +8,7 @@
#include "eo_cxx_suite.h"
-START_TEST(eo_cxx_future_construct_and_destroy)
-{
- Efl_Promise *p;
- Efl_Future *f;
-
- ecore_init();
-
- {
- p = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p);
-
- f = efl_promise_future_get(p);
- fail_if(!f);
-
- efl::shared_future<int> future(efl_ref(f));
- }
- ecore_shutdown();
-}
-END_TEST
-
-START_TEST(eo_cxx_future_wait)
-{
- Efl_Promise *p;
- Efl_Future *f;
-
- ecore_init();
-
- p = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p);
-
- f = efl_promise_future_get(p);
- fail_if(!f);
-
- {
- efl::shared_future<int> future(efl_ref(f));
-
- std::thread thread([&]
- {
- efl::ecore::main_loop_thread_safe_call_sync([]{});
// wait for ecore_main_loop_begin() call to start
- efl::ecore::main_loop_thread_safe_call_async
- ([&]
- {
- int* i =
static_cast<int*>(malloc(sizeof(int)));
- *i = 5;
- efl_promise_value_set(p, i, & ::free);
- });
-
- future.wait();
- efl::ecore::main_loop_thread_safe_call_sync([] {
ecore_main_loop_quit(); });
- });
-
- ecore_main_loop_begin();
-
- thread.join();
- }
- ecore_shutdown();
-}
-END_TEST
-
-START_TEST(eo_cxx_future_get)
-{
- Efl_Promise *p;
- Efl_Future *f;
-
- ecore_init();
-
- p = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p);
-
- f = efl_promise_future_get(p);
- fail_if(!f);
-
- {
- efl::shared_future<int> future(efl_ref(f));
-
- std::thread thread([&]
- {
- efl::ecore::main_loop_thread_safe_call_sync([]{});
// wait for ecore_main_loop_begin() call to start
- efl::ecore::main_loop_thread_safe_call_async
- ([&]
- {
- int* i =
static_cast<int*>(malloc(sizeof(int)));
- *i = 5;
- efl_promise_value_set(p, i, & ::free);
- });
-
- int i = future.get();
- ck_assert_int_eq(i, 5);
- efl::ecore::main_loop_thread_safe_call_sync([] {
ecore_main_loop_quit(); });
- });
-
- ecore_main_loop_begin();
-
- thread.join();
- }
- ecore_shutdown();
-}
-END_TEST
-
-START_TEST(eo_cxx_future_get_error)
-{
- Efl_Promise *p;
- Efl_Future *f;
-
- ecore_init();
-
- p = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p);
-
- f = efl_promise_future_get(p);
- fail_if(!f);
-
- {
- efl::shared_future<int> future(efl_ref(f));
-
- std::thread thread([&]
- {
- efl::ecore::main_loop_thread_safe_call_sync([]{});
// wait for ecore_main_loop_begin() call to start
- efl::ecore::main_loop_thread_safe_call_async
- ([&]
- {
- efl_promise_failed_set(p, ENOMEM);
- });
-
- try {
- future.get();
- ck_abort_msg("Execution should not have
continued, exception expected");
- }
- catch(std::system_error const& e)
- {
- }
- efl::ecore::main_loop_thread_safe_call_sync([] {
ecore_main_loop_quit(); });
- });
-
- ecore_main_loop_begin();
-
- thread.join();
- }
- ecore_shutdown();
-}
-END_TEST
-
-START_TEST(eo_cxx_future_then_value)
-{
- Efl_Promise *promise;
- Efl_Future *f;
-
- ecore_init();
-
- promise = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!promise);
-
- f = efl_promise_future_get(promise);
- fail_if(!f);
-
- {
- efl::shared_future<int> future(efl_ref(f)), rfuture;
-
-
- std::thread thread
- ([&]
- {
- efl::ecore::main_loop_thread_safe_call_sync
- ([&]
- {
- rfuture = then
- (future, [] (int i) -> int
- {
- ck_assert_int_eq(i, 5);
- return 42;
- }, [] (std::error_code)
- {
- throw std::bad_alloc();
- });
- });
- efl::ecore::main_loop_thread_safe_call_async
- ([&]
- {
- int* i = static_cast<int*>(malloc(sizeof(int)));
- *i = 5;
- efl_promise_value_set(promise, i, &::free);
- });
-
- int i = rfuture.get();
- ck_assert_int_eq(i, 42);
- efl::ecore::main_loop_thread_safe_call_sync([] {
ecore_main_loop_quit(); });
- });
-
- ecore_main_loop_begin();
- thread.join();
- }
- ecore_shutdown();
-}
-END_TEST
-
-START_TEST(eo_cxx_future_composite_construct_and_destroy)
-{
- ecore_init();
-
- {
- Efl_Promise *p1 = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p1);
-
- Efl_Future *f1 = efl_promise_future_get(p1);
- fail_if(!f1);
-
- Efl_Promise *p2 = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p1);
-
- Efl_Future *f2 = efl_promise_future_get(p2);
- fail_if(!f2);
-
- Efl_Future *f3 = efl_future_all(f1, f2);
- fail_if(!f3);
-
- efl::shared_future<int> future1(efl_ref(f1))
- , future2(efl_ref(f2));
- efl::shared_future<int, int> future3(efl_ref(f3));
- }
- ecore_shutdown();
-}
-END_TEST
-
-START_TEST(eo_cxx_future_composite_wait)
-{
- ecore_init();
-
- {
- Efl_Promise *p1 = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p1);
-
- Efl_Future* f1 = efl_promise_future_get(p1);
- fail_if(!f1);
-
- Efl_Promise *p2 = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p2);
-
- Efl_Future* f2 = efl_promise_future_get(p2);
- fail_if(!f2);
-
- Efl_Future *f3 = efl_future_all(f1, f2);
- fail_if(!f3);
-
- efl::shared_future<int> future1(efl_ref(f1))
- , future2(efl_ref(f2));
- efl::shared_future<int, int> future3(efl_ref(f3));
-
- std::thread thread([&]
- {
- efl::ecore::main_loop_thread_safe_call_sync([]{});
// wait for ecore_main_loop_begin() call to start
- efl::ecore::main_loop_thread_safe_call_async
- ([&]
- {
- int* i1 =
static_cast<int*>(malloc(sizeof(int)));
- *i1 = 5;
- efl_promise_value_set(p1, i1, & ::free);
- int* i2 =
static_cast<int*>(malloc(sizeof(int)));
- *i2 = 42;
- efl_promise_value_set(p2, i2, & ::free);
- });
-
- future3.wait();
- efl::ecore::main_loop_thread_safe_call_sync([] {
ecore_main_loop_quit(); });
- });
-
- ecore_main_loop_begin();
-
- thread.join();
- }
- ecore_shutdown();
-}
-END_TEST
-
-START_TEST(eo_cxx_future_composite_get)
-{
- ecore_init();
-
- {
- Efl_Promise *p1 = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p1);
-
- Efl_Future *f1 = efl_promise_future_get(p1);
- fail_if(!f1);
-
- Efl_Promise *p2 = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p2);
-
- Efl_Future *f2 = efl_promise_future_get(p2);
- fail_if(!f2);
-
- Efl_Future *f3 = efl_future_all(f1, f2);
- fail_if(!f3);
-
- efl::shared_future<int> future1(efl_ref(f1))
- , future2(efl_ref(f2));
- efl::shared_future<int, int> future3(efl_ref(f3));
-
- std::thread thread([&]
- {
- efl::ecore::main_loop_thread_safe_call_sync([]{});
// wait for ecore_main_loop_begin() call to start
- efl::ecore::main_loop_thread_safe_call_async
- ([&]
- {
- int* i1 =
static_cast<int*>(malloc(sizeof(int)));
- *i1 = 5;
- efl_promise_value_set(p1, i1, & ::free);
- int* i2 =
static_cast<int*>(malloc(sizeof(int)));
- *i2 = 42;
- efl_promise_value_set(p2, i2, & ::free);
- });
-
- std::tuple<int, int> tuple = future3.get();
- ck_assert_int_eq(std::get<0>(tuple), 5);
- ck_assert_int_eq(std::get<1>(tuple), 42);
- efl::ecore::main_loop_thread_safe_call_sync([] {
ecore_main_loop_quit(); });
- });
-
- ecore_main_loop_begin();
-
- thread.join();
- }
- ecore_shutdown();
-}
-END_TEST
-
-START_TEST(eo_cxx_future_composite_then_value)
-{
-
- ecore_init();
-
- {
- Efl_Promise *p1 = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p1);
-
- Efl_Future *f1 = efl_promise_future_get(p1);
- fail_if(!f1);
-
- Efl_Promise *p2 = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p2);
-
- Efl_Future *f2 = efl_promise_future_get(p2);
- fail_if(!f2);
-
- Efl_Future *f3 = efl_future_all(f1, f2);
- fail_if(!f3);
-
- efl::shared_future<int, int> future(efl_ref(f3));
- efl::shared_future<int> rfuture;
-
- std::thread thread
- ([&]
- {
- efl::ecore::main_loop_thread_safe_call_sync
- ([&]
- {
- rfuture = then
- (future, [] (int i1, int i2) -> int
- {
- ck_assert_int_eq(i1, 5);
- ck_assert_int_eq(i2, 42);
- return 42;
- }, [] (std::error_code)
- {
- throw std::bad_alloc();
- });
- });
- efl::ecore::main_loop_thread_safe_call_async
- ([&]
- {
- int* i1 = static_cast<int*>(malloc(sizeof(int)));
- *i1 = 5;
- efl_promise_value_set(p1, i1, &::free);
- int* i2 = static_cast<int*>(malloc(sizeof(int)));
- *i2 = 42;
- efl_promise_value_set(p2, i2, &::free);
- });
-
- int i;
- i = rfuture.get();
- ck_assert_int_eq(i, 42);
- efl::ecore::main_loop_thread_safe_call_sync([] {
ecore_main_loop_quit(); });
- });
-
- ecore_main_loop_begin();
- thread.join();
- }
- ecore_shutdown();
-}
-END_TEST
-
-START_TEST(eo_cxx_future_all_construct_and_destroy)
-{
- ecore_init();
-
- {
- Efl_Promise *p1 = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p1);
-
- Efl_Future *f1 = efl_promise_future_get(p1);
- fail_if(!f1);
-
- Efl_Promise *p2 = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p1);
-
- Efl_Future *f2 = efl_promise_future_get(p2);
- fail_if(!f2);
-
- Efl_Future *f3 = efl_future_all(f1, f2);
- fail_if(!f3);
-
- efl::shared_future<int> future1(efl_ref(f1))
- , future2(efl_ref(f2));
- efl::shared_future<int, int> future3 = all(future1, future2);
- }
- ecore_shutdown();
-}
-END_TEST
-
-START_TEST(eo_cxx_future_all_wait)
-{
- ecore_init();
-
- {
- Efl_Promise *p1 = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p1);
-
- Efl_Future* f1 = efl_promise_future_get(p1);
- fail_if(!f1);
-
- Efl_Promise *p2 = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p2);
-
- Efl_Future* f2 = efl_promise_future_get(p2);
- fail_if(!f2);
-
- efl::shared_future<int> future1(efl_ref(f1))
- , future2(efl_ref(f2));
- efl::shared_future<int, int> future3 = all(future1, future2);
-
- std::thread thread([&]
- {
- efl::ecore::main_loop_thread_safe_call_sync([]{});
// wait for ecore_main_loop_begin() call to start
- efl::ecore::main_loop_thread_safe_call_async
- ([&]
- {
- int* i1 =
static_cast<int*>(malloc(sizeof(int)));
- *i1 = 5;
- efl_promise_value_set(p1, i1, & ::free);
- int* i2 =
static_cast<int*>(malloc(sizeof(int)));
- *i2 = 42;
- efl_promise_value_set(p2, i2, & ::free);
- });
-
- future3.wait();
- efl::ecore::main_loop_thread_safe_call_sync([] {
ecore_main_loop_quit(); });
- });
-
- ecore_main_loop_begin();
-
- thread.join();
- }
- ecore_shutdown();
-}
-END_TEST
-
-START_TEST(eo_cxx_future_all_get)
-{
- ecore_init();
-
- {
- Efl_Promise *p1 = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p1);
-
- Efl_Future *f1 = efl_promise_future_get(p1);
- fail_if(!f1);
-
- Efl_Promise *p2 = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p2);
-
- Efl_Future *f2 = efl_promise_future_get(p2);
- fail_if(!f2);
-
- efl::shared_future<int> future1(efl_ref(f1))
- , future2(efl_ref(f2));
- efl::shared_future<int, int> future3 = all(future1, future2);
-
- std::thread thread([&]
- {
- efl::ecore::main_loop_thread_safe_call_sync([]{});
// wait for ecore_main_loop_begin() call to start
- efl::ecore::main_loop_thread_safe_call_async
- ([&]
- {
- int* i1 =
static_cast<int*>(malloc(sizeof(int)));
- *i1 = 5;
- efl_promise_value_set(p1, i1, & ::free);
- int* i2 =
static_cast<int*>(malloc(sizeof(int)));
- *i2 = 42;
- efl_promise_value_set(p2, i2, & ::free);
- });
-
- std::tuple<int, int> tuple = future3.get();
- ck_assert_int_eq(std::get<0>(tuple), 5);
- ck_assert_int_eq(std::get<1>(tuple), 42);
- efl::ecore::main_loop_thread_safe_call_sync([] {
ecore_main_loop_quit(); });
- });
-
- ecore_main_loop_begin();
-
- thread.join();
- }
- ecore_shutdown();
-}
-END_TEST
-
-START_TEST(eo_cxx_future_all_then_value)
-{
-
- ecore_init();
-
- {
- Efl_Promise *p1 = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p1);
-
- Efl_Future *f1 = efl_promise_future_get(p1);
- fail_if(!f1);
-
- Efl_Promise *p2 = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p2);
-
- Efl_Future *f2 = efl_promise_future_get(p2);
- fail_if(!f2);
-
- efl::shared_future<int> future1(efl_ref(f1)), future2(efl_ref(f2));
- efl::shared_future<int, int> future = all(future1, future2);
- efl::shared_future<int> rfuture;
-
- std::thread thread
- ([&]
- {
- efl::ecore::main_loop_thread_safe_call_sync
- ([&]
- {
- rfuture = then
- (future, [] (int i1, int i2) -> int
- {
- ck_assert_int_eq(i1, 5);
- ck_assert_int_eq(i2, 42);
- return 42;
- }, [] (std::error_code)
- {
- throw std::bad_alloc();
- });
- });
- efl::ecore::main_loop_thread_safe_call_async
- ([&]
- {
- int* i1 = static_cast<int*>(malloc(sizeof(int)));
- *i1 = 5;
- efl_promise_value_set(p1, i1, &::free);
- int* i2 = static_cast<int*>(malloc(sizeof(int)));
- *i2 = 42;
- efl_promise_value_set(p2, i2, &::free);
- });
-
- int i;
- i = rfuture.get();
- ck_assert_int_eq(i, 42);
- efl::ecore::main_loop_thread_safe_call_sync([] {
ecore_main_loop_quit(); });
- });
-
- ecore_main_loop_begin();
- thread.join();
- }
- ecore_shutdown();
-}
-END_TEST
-
-// race
-START_TEST(eo_cxx_future_race_construct_and_destroy)
-{
- ecore_init();
-
- {
- Efl_Promise *p1 = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p1);
-
- Efl_Future *f1 = efl_promise_future_get(p1);
- fail_if(!f1);
-
- Efl_Promise *p2 = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p1);
-
- Efl_Future *f2 = efl_promise_future_get(p2);
- fail_if(!f2);
-
- efl::shared_future<int> future1(efl_ref(f1)), future2(efl_ref(f2));
- efl::shared_future<double> future3(efl_ref(f2));
- efl::shared_race_future<int> race1 = race(future1, future2);
- efl::shared_race_future<efl::eina::variant<int, double>> race2 =
race(future1, future3);
- }
- ecore_shutdown();
-}
-END_TEST
-
-START_TEST(eo_cxx_future_race_wait)
-{
- ecore_init();
-
- {
- Efl_Promise *p1 = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p1);
-
- Efl_Future* f1 = efl_promise_future_get(p1);
- fail_if(!f1);
-
- Efl_Promise *p2 = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p2);
-
- Efl_Future* f2 = efl_promise_future_get(p2);
- fail_if(!f2);
-
- efl::shared_future<int> future1(efl_ref(f1))
- , future2(efl_ref(f2));
- efl::shared_race_future<int> future3 = race(future1, future2);
-
- std::thread thread([&]
- {
- efl::ecore::main_loop_thread_safe_call_sync([]{});
// wait for ecore_main_loop_begin() call to start
- efl::ecore::main_loop_thread_safe_call_async
- ([&]
- {
- int* i1 =
static_cast<int*>(malloc(sizeof(int)));
- *i1 = 5;
- efl_promise_value_set(p1, i1, & ::free);
- });
-
- future3.wait();
- efl::ecore::main_loop_thread_safe_call_sync([] {
ecore_main_loop_quit(); });
- });
-
- ecore_main_loop_begin();
-
- thread.join();
- }
- ecore_shutdown();
-}
-END_TEST
-
-START_TEST(eo_cxx_future_race_get)
-{
- ecore_init();
-
- {
- Efl_Promise *p1 = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p1);
-
- Efl_Future *f1 = efl_promise_future_get(p1);
- fail_if(!f1);
-
- Efl_Promise *p2 = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p2);
-
- Efl_Future *f2 = efl_promise_future_get(p2);
- fail_if(!f2);
-
- efl::shared_future<int> future1(efl_ref(f1))
- , future2(efl_ref(f2));
- efl::shared_race_future<int> future3 = race(future1, future2);
-
- std::thread thread([&]
- {
- efl::ecore::main_loop_thread_safe_call_sync([]{});
// wait for ecore_main_loop_begin() call to start
- efl::ecore::main_loop_thread_safe_call_async
- ([&]
- {
- int* i1 =
static_cast<int*>(malloc(sizeof(int)));
- *i1 = 5;
- efl_promise_value_set(p1, i1, & ::free);
- });
-
- int value = future3.get();
- ck_assert_int_eq(value, 5);
- efl::ecore::main_loop_thread_safe_call_sync([] {
ecore_main_loop_quit(); });
- });
-
- ecore_main_loop_begin();
-
- thread.join();
- }
- ecore_shutdown();
-}
-END_TEST
-
-START_TEST(eo_cxx_future_race_then_value)
-{
-
- ecore_init();
-
- {
- Efl_Promise *p1 = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p1);
-
- Efl_Future *f1 = efl_promise_future_get(p1);
- fail_if(!f1);
-
- Efl_Promise *p2 = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p2);
-
- Efl_Future *f2 = efl_promise_future_get(p2);
- fail_if(!f2);
-
- efl::shared_future<int> future1(efl_ref(f1)), future2(efl_ref(f2));
- efl::shared_race_future<int> future = race(future1, future2);
- efl::shared_future<int> rfuture;
-
- std::thread thread
- ([&]
- {
- efl::ecore::main_loop_thread_safe_call_sync
- ([&]
- {
- rfuture = then
- (future, [] (int i) -> int
- {
- ck_assert_int_eq(i, 5);
- return 42;
- }, [] (std::error_code)
- {
- throw std::bad_alloc();
- });
- });
- efl::ecore::main_loop_thread_safe_call_async
- ([&]
- {
- int* i1 = static_cast<int*>(malloc(sizeof(int)));
- *i1 = 5;
- efl_promise_value_set(p1, i1, &::free);
- });
-
- int i;
- i = rfuture.get();
- ck_assert_int_eq(i, 42);
- efl::ecore::main_loop_thread_safe_call_sync([] {
ecore_main_loop_quit(); });
- });
-
- ecore_main_loop_begin();
- thread.join();
- }
- ecore_shutdown();
-}
-END_TEST
-
-START_TEST(eo_cxx_future_race_variant_get)
-{
- ecore_init();
-
- {
- Efl_Promise *p1 = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p1);
-
- Efl_Future *f1 = efl_promise_future_get(p1);
- fail_if(!f1);
-
- Efl_Promise *p2 = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p2);
-
- Efl_Future *f2 = efl_promise_future_get(p2);
- fail_if(!f2);
-
- efl::shared_future<int> future1(efl_ref(f1));
- efl::shared_future<double> future2(efl_ref(f2));
- efl::shared_race_future<efl::eina::variant<int, double>> future3 =
race(future1, future2);
-
- std::thread thread([&]
- {
- efl::ecore::main_loop_thread_safe_call_sync([]{});
// wait for ecore_main_loop_begin() call to start
- efl::ecore::main_loop_thread_safe_call_async
- ([&]
- {
- int* i1 =
static_cast<int*>(malloc(sizeof(int)));
- *i1 = 5;
- efl_promise_value_set(p1, i1, & ::free);
- });
-
- efl::eina::variant<int, double> value =
future3.get();
- ck_assert(efl::eina::get<int>(&value) != nullptr);
- ck_assert_int_eq(efl::eina::get<int>(value), 5);
- efl::ecore::main_loop_thread_safe_call_sync([] {
ecore_main_loop_quit(); });
- });
-
- ecore_main_loop_begin();
-
- thread.join();
- }
- ecore_shutdown();
-}
-END_TEST
-
-START_TEST(eo_cxx_future_race_variant_then_value)
-{
-
- ecore_init();
-
- {
- Efl_Promise *p1 = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p1);
-
- Efl_Future *f1 = efl_promise_future_get(p1);
- fail_if(!f1);
-
- Efl_Promise *p2 = efl_add(EFL_PROMISE_CLASS, efl_main_loop_get());
- fail_if(!p2);
-
- Efl_Future *f2 = efl_promise_future_get(p2);
- fail_if(!f2);
-
- efl::shared_future<int> future1(efl_ref(f1));
- efl::shared_future<double> future2(efl_ref(f2));
- efl::shared_race_future<efl::eina::variant<int, double>> future =
race(future1, future2);
- efl::shared_future<int> rfuture;
-
- std::thread thread
- ([&]
- {
- efl::ecore::main_loop_thread_safe_call_sync
- ([&]
- {
- rfuture = then
- (future, [] (efl::eina::variant<int, double> v) -> int
- {
- ck_assert(efl::eina::get<int>(&v) != nullptr);
- ck_assert_int_eq(efl::eina::get<int>(v), 5);
- return 42;
- }, [] (std::error_code)
- {
- throw std::bad_alloc();
- });
- });
- efl::ecore::main_loop_thread_safe_call_async
- ([&]
- {
- int* i1 = static_cast<int*>(malloc(sizeof(int)));
- *i1 = 5;
- efl_promise_value_set(p1, i1, &::free);
- });
-
- int i;
- i = rfuture.get();
- ck_assert_int_eq(i, 42);
- efl::ecore::main_loop_thread_safe_call_sync([] {
ecore_main_loop_quit(); });
- });
-
- ecore_main_loop_begin();
- thread.join();
- }
- ecore_shutdown();
-}
-END_TEST
-
-template <typename...Args>
-void eo_cxx_promise_construct_and_destroy_impl()
-{
- ecore_init();
-
- {
- efl::promise<Args...> promise;
- efl::shared_future<Args...> f = promise.get_future();
- }
- ecore_shutdown();
-}
-
-START_TEST(eo_cxx_promise_construct_and_destroy)
-{
- eo_cxx_promise_construct_and_destroy_impl<int>();
-}
-END_TEST
-
-template <typename T>
-struct test_value_get;
-
-template <>
-struct test_value_get<int>
-{
- static int get() { return 5; }
-};
-
-template <typename T>
-void eo_cxx_promise_value_set_impl()
-{
- ecore_init();
-
- {
- efl::promise<T> promise;
- efl::shared_future<T> f = promise.get_future();
-
- std::thread thread
- ([&] {
- efl::ecore::main_loop_thread_safe_call_sync([]{}); // wait for
ecore_main_loop_begin() call to start
- efl::ecore::main_loop_thread_safe_call_async
- ([&]
- {
- promise.set_value(test_value_get<T>::get());
- });
-
- T value = f.get();
- ck_assert_int_eq(value, test_value_get<T>::get());
- efl::ecore::main_loop_thread_safe_call_sync([] {
ecore_main_loop_quit(); });
- });
-
- ecore_main_loop_begin();
-
- thread.join();
- }
- ecore_shutdown();
-}
-
-START_TEST(eo_cxx_promise_value_set)
-{
- eo_cxx_promise_value_set_impl<int>();
-}
-END_TEST
-
-template <typename T>
-void eo_cxx_promise_progress_set_impl()
-{
- ecore_init();
-
- {
- efl::promise<int, T> promise;
- efl::shared_future<int, efl::progress<T>> f = promise.get_future();
-
- on_progress
- (f, [&] (T const& value)
- {
- ck_assert_int_eq(value, test_value_get<T>::get());
- ecore_main_loop_quit();
- });
-
- std::thread thread
- ([&] {
- efl::ecore::main_loop_thread_safe_call_sync([]{}); // wait for
ecore_main_loop_begin() call to start
- efl::ecore::main_loop_thread_safe_call_async
- ([&]
- {
- promise.set_progress(test_value_get<T>::get());
- });
- });
-
- ecore_main_loop_begin();
-
- thread.join();
- }
- ecore_shutdown();
-}
-
-START_TEST(eo_cxx_promise_progress_set)
-{
- eo_cxx_promise_progress_set_impl<int>();
-}
-END_TEST
-
void
eo_cxx_test_promise(TCase* tc)
{
- tcase_add_test(tc, eo_cxx_future_construct_and_destroy);
- tcase_add_test(tc, eo_cxx_future_wait);
- tcase_add_test(tc, eo_cxx_future_get);
- tcase_add_test(tc, eo_cxx_future_get_error);
- tcase_add_test(tc, eo_cxx_future_then_value);
- tcase_add_test(tc, eo_cxx_future_composite_construct_and_destroy);
- tcase_add_test(tc, eo_cxx_future_composite_wait);
- tcase_add_test(tc, eo_cxx_future_composite_get);
- tcase_add_test(tc, eo_cxx_future_composite_then_value);
-
- tcase_add_test(tc, eo_cxx_future_all_construct_and_destroy);
- tcase_add_test(tc, eo_cxx_future_all_wait);
- tcase_add_test(tc, eo_cxx_future_all_get);
- tcase_add_test(tc, eo_cxx_future_all_then_value);
-
- tcase_add_test(tc, eo_cxx_future_race_construct_and_destroy);
- tcase_add_test(tc, eo_cxx_future_race_wait);
- tcase_add_test(tc, eo_cxx_future_race_get);
- tcase_add_test(tc, eo_cxx_future_race_then_value);
-
- tcase_add_test(tc, eo_cxx_future_race_variant_get);
- tcase_add_test(tc, eo_cxx_future_race_variant_then_value);
-
- tcase_add_test(tc, eo_cxx_promise_construct_and_destroy);
- tcase_add_test(tc, eo_cxx_promise_value_set);
- tcase_add_test(tc, eo_cxx_promise_progress_set);
}
--
