ceph/src/boost/libs/compute/test/test_wait_list.cpp

   1 //---------------------------------------------------------------------------//
   2 // Copyright (c) 2013-2014 Kyle Lutz <kyle.r.lutz@gmail.com>
   3 //
   4 // Distributed under the Boost Software License, Version 1.0
   5 // See accompanying file LICENSE_1_0.txt or copy at
   6 // http://www.boost.org/LICENSE_1_0.txt
   7 //
   8 // See http://boostorg.github.com/compute for more information.
   9 //---------------------------------------------------------------------------//
  10
  11 #define BOOST_TEST_MODULE TestWaitList
  12 #include <boost/test/unit_test.hpp>
  13
  14 #include <algorithm>
  15 #include <vector>
  16
  17 #include <boost/compute/command_queue.hpp>
  18 #include <boost/compute/system.hpp>
  19 #include <boost/compute/async/future.hpp>
  20 #include <boost/compute/algorithm/copy.hpp>
  21 #include <boost/compute/container/vector.hpp>
  22 #include <boost/compute/utility/wait_list.hpp>
  23
  24 #include "check_macros.hpp"
  25 #include "context_setup.hpp"
  26
  27 namespace compute = boost::compute;
  28
  29 BOOST_AUTO_TEST_CASE(create_wait_list)
  30 {
  31     compute::wait_list events;
  32     BOOST_CHECK_EQUAL(events.size(), size_t(0));
  33     BOOST_CHECK_EQUAL(events.empty(), true);
  34     BOOST_CHECK(events.get_event_ptr() == 0);
  35 }
  36
  37 #ifndef BOOST_COMPUTE_NO_HDR_INITIALIZER_LIST
  38 BOOST_AUTO_TEST_CASE(create_wait_list_from_initializer_list)
  39 {
  40     compute::event event0;
  41     compute::event event1;
  42     compute::event event2;
  43     compute::wait_list events = { event0, event1, event2 };
  44     BOOST_CHECK_EQUAL(events.size(), size_t(3));
  45     CHECK_RANGE_EQUAL(compute::event, 3, events, (event0, event1, event2));
  46 }
  47 #endif // BOOST_COMPUTE_NO_HDR_INITIALIZER_LIST
  48
  49 BOOST_AUTO_TEST_CASE(insert_future)
  50 {
  51     // create vector on the host
  52     std::vector<int> host_vector(4);
  53     std::fill(host_vector.begin(), host_vector.end(), 7);
  54
  55     // create vector on the device
  56     compute::vector<int> device_vector(4, context);
  57
  58     // create wait list
  59     compute::wait_list events;
  60
  61     // copy values to device
  62     compute::future<void> future = compute::copy_async(
  63         host_vector.begin(), host_vector.end(), device_vector.begin(), queue
  64     );
  65
  66     // add future event to the wait list
  67     events.insert(future);
  68     BOOST_CHECK_EQUAL(events.size(), size_t(1));
  69     BOOST_CHECK(events.get_event_ptr() != 0);
  70
  71     // wait for copy to complete
  72     events.wait();
  73
  74     // check values
  75     CHECK_RANGE_EQUAL(int, 4, device_vector, (7, 7, 7, 7));
  76
  77     // clear the event list
  78     events.clear();
  79     BOOST_CHECK_EQUAL(events.size(), size_t(0));
  80 }
  81
  82 BOOST_AUTO_TEST_SUITE_END()