|
5 | 5 | #include <map>
|
6 | 6 | #include <uur/fixtures.h>
|
7 | 7 |
|
8 |
| -std::unordered_map<ur_queue_info_t, size_t> queue_info_size_map = { |
9 |
| - {UR_QUEUE_INFO_CONTEXT, sizeof(ur_context_handle_t)}, |
10 |
| - {UR_QUEUE_INFO_DEVICE, sizeof(ur_device_handle_t)}, |
11 |
| - {UR_QUEUE_INFO_DEVICE_DEFAULT, sizeof(ur_queue_handle_t)}, |
12 |
| - {UR_QUEUE_INFO_FLAGS, sizeof(ur_queue_flags_t)}, |
13 |
| - {UR_QUEUE_INFO_REFERENCE_COUNT, sizeof(uint32_t)}, |
14 |
| - {UR_QUEUE_INFO_SIZE, sizeof(uint32_t)}, |
15 |
| - {UR_QUEUE_INFO_EMPTY, sizeof(ur_bool_t)}, |
16 |
| -}; |
17 |
| - |
18 |
| -using urQueueGetInfoTestWithInfoParam = |
19 |
| - uur::urQueueTestWithParam<ur_queue_info_t>; |
20 |
| - |
21 |
| -UUR_TEST_SUITE_P(urQueueGetInfoTestWithInfoParam, |
22 |
| - ::testing::Values(UR_QUEUE_INFO_CONTEXT, UR_QUEUE_INFO_DEVICE, |
23 |
| - UR_QUEUE_INFO_FLAGS, |
24 |
| - UR_QUEUE_INFO_REFERENCE_COUNT, |
25 |
| - UR_QUEUE_INFO_EMPTY), |
26 |
| - uur::deviceTestWithParamPrinter<ur_queue_info_t>); |
27 |
| - |
28 |
| -TEST_P(urQueueGetInfoTestWithInfoParam, Success) { |
29 |
| - ur_queue_info_t info_type = getParam(); |
| 8 | +using urQueueGetInfoTest = uur::urQueueTest; |
| 9 | +UUR_INSTANTIATE_DEVICE_TEST_SUITE_P(urQueueGetInfoTest); |
| 10 | + |
| 11 | +TEST_P(urQueueGetInfoTest, Context) { |
30 | 12 | size_t size = 0;
|
31 |
| - auto result = urQueueGetInfo(queue, info_type, 0, nullptr, &size); |
32 |
| - |
33 |
| - if (result == UR_RESULT_SUCCESS) { |
34 |
| - ASSERT_NE(size, 0); |
35 |
| - |
36 |
| - if (const auto expected_size = queue_info_size_map.find(info_type); |
37 |
| - expected_size != queue_info_size_map.end()) { |
38 |
| - ASSERT_EQ(expected_size->second, size); |
39 |
| - } |
40 |
| - |
41 |
| - std::vector<uint8_t> data(size); |
42 |
| - ASSERT_SUCCESS( |
43 |
| - urQueueGetInfo(queue, info_type, size, data.data(), nullptr)); |
44 |
| - |
45 |
| - switch (info_type) { |
46 |
| - case UR_QUEUE_INFO_CONTEXT: { |
47 |
| - auto returned_context = |
48 |
| - reinterpret_cast<ur_context_handle_t *>(data.data()); |
49 |
| - ASSERT_EQ(context, *returned_context); |
50 |
| - break; |
51 |
| - } |
52 |
| - case UR_QUEUE_INFO_DEVICE: { |
53 |
| - auto returned_device = |
54 |
| - reinterpret_cast<ur_device_handle_t *>(data.data()); |
55 |
| - ASSERT_EQ(*returned_device, device); |
56 |
| - break; |
57 |
| - } |
58 |
| - case UR_QUEUE_INFO_DEVICE_DEFAULT: { |
59 |
| - auto returned_default_queue = |
60 |
| - reinterpret_cast<ur_queue_handle_t *>(data.data()); |
61 |
| - ASSERT_EQ(*returned_default_queue, queue); |
62 |
| - break; |
63 |
| - } |
64 |
| - case UR_QUEUE_INFO_FLAGS: { |
65 |
| - auto returned_flags = |
66 |
| - reinterpret_cast<ur_queue_flags_t *>(data.data()); |
67 |
| - EXPECT_EQ(*returned_flags, *returned_flags & UR_QUEUE_FLAGS_MASK); |
68 |
| - break; |
69 |
| - } |
70 |
| - case UR_QUEUE_INFO_REFERENCE_COUNT: { |
71 |
| - auto returned_reference_count = |
72 |
| - reinterpret_cast<uint32_t *>(data.data()); |
73 |
| - ASSERT_GT(*returned_reference_count, 0U); |
74 |
| - break; |
75 |
| - } |
76 |
| - case UR_QUEUE_INFO_EMPTY: { |
77 |
| - auto returned_empty_queue = |
78 |
| - reinterpret_cast<ur_bool_t *>(data.data()); |
79 |
| - ASSERT_TRUE(returned_empty_queue); |
80 |
| - break; |
81 |
| - } |
82 |
| - default: |
83 |
| - break; |
84 |
| - } |
85 |
| - } else { |
86 |
| - ASSERT_EQ_RESULT(result, UR_RESULT_ERROR_UNSUPPORTED_ENUMERATION); |
87 |
| - } |
| 13 | + auto infoType = UR_QUEUE_INFO_CONTEXT; |
| 14 | + ASSERT_SUCCESS(urQueueGetInfo(queue, infoType, 0, nullptr, &size)); |
| 15 | + ASSERT_NE(size, 0); |
| 16 | + ASSERT_EQ(sizeof(ur_context_handle_t), size); |
| 17 | + |
| 18 | + std::vector<uint8_t> data(size); |
| 19 | + ASSERT_SUCCESS(urQueueGetInfo(queue, infoType, size, data.data(), nullptr)); |
| 20 | + |
| 21 | + auto returned_context = |
| 22 | + reinterpret_cast<ur_context_handle_t *>(data.data()); |
| 23 | + ASSERT_EQ(context, *returned_context); |
88 | 24 | }
|
89 | 25 |
|
90 |
| -struct urQueueGetInfoDeviceQueueTestWithInfoParam |
91 |
| - : public uur::urContextTestWithParam<ur_queue_info_t> { |
92 |
| - void SetUp() { |
93 |
| - urContextTestWithParam<ur_queue_info_t>::SetUp(); |
94 |
| - ur_queue_flags_t deviceQueueCapabilities; |
95 |
| - ASSERT_SUCCESS( |
96 |
| - urDeviceGetInfo(device, UR_DEVICE_INFO_QUEUE_ON_DEVICE_PROPERTIES, |
97 |
| - sizeof(deviceQueueCapabilities), |
98 |
| - &deviceQueueCapabilities, nullptr)); |
99 |
| - if (!deviceQueueCapabilities) { |
100 |
| - GTEST_SKIP() << "Queue on device is not supported."; |
101 |
| - } |
102 |
| - ASSERT_SUCCESS( |
103 |
| - urQueueCreate(context, device, &queueProperties, &queue)); |
104 |
| - } |
105 |
| - |
106 |
| - void TearDown() { |
107 |
| - if (queue) { |
108 |
| - ASSERT_SUCCESS(urQueueRelease(queue)); |
109 |
| - } |
110 |
| - urContextTestWithParam<ur_queue_info_t>::TearDown(); |
111 |
| - } |
112 |
| - |
113 |
| - ur_queue_handle_t queue = nullptr; |
114 |
| - ur_queue_properties_t queueProperties = { |
115 |
| - UR_STRUCTURE_TYPE_QUEUE_PROPERTIES, nullptr, |
116 |
| - UR_QUEUE_FLAG_ON_DEVICE | UR_QUEUE_FLAG_ON_DEVICE_DEFAULT | |
117 |
| - UR_QUEUE_FLAG_OUT_OF_ORDER_EXEC_MODE_ENABLE}; |
118 |
| -}; |
| 26 | +TEST_P(urQueueGetInfoTest, Device) { |
| 27 | + size_t size = 0; |
| 28 | + auto infoType = UR_QUEUE_INFO_DEVICE; |
| 29 | + ASSERT_SUCCESS(urQueueGetInfo(queue, infoType, 0, nullptr, &size)); |
| 30 | + ASSERT_NE(size, 0); |
| 31 | + ASSERT_EQ(sizeof(ur_device_handle_t), size); |
119 | 32 |
|
120 |
| -using urQueueGetInfoTest = uur::urQueueTest; |
121 |
| -UUR_INSTANTIATE_DEVICE_TEST_SUITE_P(urQueueGetInfoTest); |
| 33 | + std::vector<uint8_t> data(size); |
| 34 | + ASSERT_SUCCESS(urQueueGetInfo(queue, infoType, size, data.data(), nullptr)); |
| 35 | + |
| 36 | + auto returned_device = reinterpret_cast<ur_device_handle_t *>(data.data()); |
| 37 | + ASSERT_EQ(device, *returned_device); |
| 38 | +} |
| 39 | + |
| 40 | +TEST_P(urQueueGetInfoTest, DeviceDefault) { |
| 41 | + size_t size = 0; |
| 42 | + auto infoType = UR_QUEUE_INFO_DEVICE_DEFAULT; |
| 43 | + ASSERT_SUCCESS(urQueueGetInfo(queue, infoType, 0, nullptr, &size)); |
| 44 | + ASSERT_NE(size, 0); |
| 45 | + ASSERT_EQ(sizeof(ur_queue_handle_t), size); |
| 46 | + |
| 47 | + std::vector<uint8_t> data(size); |
| 48 | + ASSERT_SUCCESS(urQueueGetInfo(queue, infoType, size, data.data(), nullptr)); |
| 49 | + |
| 50 | + auto returned_default_queue = |
| 51 | + reinterpret_cast<ur_queue_handle_t *>(data.data()); |
| 52 | + ASSERT_EQ(queue, *returned_default_queue); |
| 53 | +} |
| 54 | + |
| 55 | +TEST_P(urQueueGetInfoTest, Flags) { |
| 56 | + size_t size = 0; |
| 57 | + auto infoType = UR_QUEUE_INFO_FLAGS; |
| 58 | + ASSERT_SUCCESS(urQueueGetInfo(queue, infoType, 0, nullptr, &size)); |
| 59 | + ASSERT_NE(size, 0); |
| 60 | + ASSERT_EQ(sizeof(ur_queue_flags_t), size); |
| 61 | + |
| 62 | + std::vector<uint8_t> data(size); |
| 63 | + ASSERT_SUCCESS(urQueueGetInfo(queue, infoType, size, data.data(), nullptr)); |
| 64 | + |
| 65 | + auto returned_flags = reinterpret_cast<ur_queue_flags_t *>(data.data()); |
| 66 | + EXPECT_EQ(*returned_flags, queue_properties.flags); |
| 67 | +} |
| 68 | + |
| 69 | +TEST_P(urQueueGetInfoTest, ReferenceCount) { |
| 70 | + size_t size = 0; |
| 71 | + auto infoType = UR_QUEUE_INFO_REFERENCE_COUNT; |
| 72 | + ASSERT_SUCCESS(urQueueGetInfo(queue, infoType, 0, nullptr, &size)); |
| 73 | + ASSERT_NE(size, 0); |
| 74 | + ASSERT_EQ(sizeof(uint32_t), size); |
| 75 | + |
| 76 | + std::vector<uint8_t> data(size); |
| 77 | + ASSERT_SUCCESS(urQueueGetInfo(queue, infoType, size, data.data(), nullptr)); |
| 78 | + |
| 79 | + auto returned_reference_count = reinterpret_cast<uint32_t *>(data.data()); |
| 80 | + ASSERT_GT(*returned_reference_count, 0U); |
| 81 | +} |
| 82 | + |
| 83 | +TEST_P(urQueueGetInfoTest, EmptyQueue) { |
| 84 | + size_t size = 0; |
| 85 | + auto infoType = UR_QUEUE_INFO_EMPTY; |
| 86 | + UUR_ASSERT_SUCCESS_OR_UNSUPPORTED( |
| 87 | + urQueueGetInfo(queue, infoType, 0, nullptr, &size)); |
| 88 | + ASSERT_NE(size, 0); |
| 89 | + ASSERT_EQ(sizeof(ur_bool_t), size); |
| 90 | + |
| 91 | + std::vector<uint8_t> data(size); |
| 92 | + ASSERT_SUCCESS(urQueueGetInfo(queue, infoType, size, data.data(), nullptr)); |
| 93 | + |
| 94 | + auto returned_empty_queue = reinterpret_cast<ur_bool_t *>(data.data()); |
| 95 | + ASSERT_TRUE(returned_empty_queue); |
| 96 | +} |
122 | 97 |
|
123 | 98 | TEST_P(urQueueGetInfoTest, InvalidNullHandleQueue) {
|
124 | 99 | ur_context_handle_t context = nullptr;
|
|
0 commit comments