1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
|
/* Copyright (c) 2015-2018, Linaro Limited
* Copyright (c) 2021, Nokia
* All rights reserved.
*
* SPDX-License-Identifier: BSD-3-Clause
*/
#include <odp_api.h>
#include "odp_cunit_common.h"
#include "mask_common.h"
/* default worker parameter to get all that may be available */
#define ALL_AVAILABLE 0
static void cpumask_test_odp_cpumask_def_control(void)
{
unsigned int num, max_num;
unsigned int mask_count;
unsigned int max_cpus = mask_capacity();
odp_cpumask_t mask;
num = odp_cpumask_default_control(&mask, ALL_AVAILABLE);
mask_count = odp_cpumask_count(&mask);
CU_ASSERT(mask_count == num);
CU_ASSERT(num > 0);
CU_ASSERT(num <= max_cpus);
max_num = odp_cpumask_default_control(&mask, max_cpus);
mask_count = odp_cpumask_count(&mask);
CU_ASSERT(max_num > 0);
CU_ASSERT(max_num == mask_count);
CU_ASSERT(max_num <= max_cpus);
CU_ASSERT(max_num <= num);
}
static void cpumask_test_odp_cpumask_def_worker(void)
{
unsigned int num, max_num;
unsigned int mask_count;
unsigned int max_cpus = mask_capacity();
odp_cpumask_t mask;
num = odp_cpumask_default_worker(&mask, ALL_AVAILABLE);
mask_count = odp_cpumask_count(&mask);
CU_ASSERT(mask_count == num);
CU_ASSERT(num > 0);
CU_ASSERT(num <= max_cpus);
max_num = odp_cpumask_default_worker(&mask, max_cpus);
mask_count = odp_cpumask_count(&mask);
CU_ASSERT(max_num > 0);
CU_ASSERT(max_num == mask_count);
CU_ASSERT(max_num <= max_cpus);
CU_ASSERT(max_num <= num);
}
static void cpumask_test_odp_cpumask_def(void)
{
unsigned mask_count;
unsigned num_worker;
unsigned num_control;
unsigned max_cpus = mask_capacity();
unsigned available_cpus = odp_cpu_count();
unsigned requested_cpus;
odp_cpumask_t mask;
CU_ASSERT(available_cpus <= max_cpus);
if (available_cpus > 1)
requested_cpus = available_cpus - 1;
else
requested_cpus = available_cpus;
num_worker = odp_cpumask_default_worker(&mask, requested_cpus);
mask_count = odp_cpumask_count(&mask);
CU_ASSERT(mask_count == num_worker);
num_control = odp_cpumask_default_control(&mask, 1);
mask_count = odp_cpumask_count(&mask);
CU_ASSERT(mask_count == num_control);
CU_ASSERT(num_control >= 1);
CU_ASSERT(num_worker <= available_cpus);
CU_ASSERT(num_worker > 0);
}
odp_testinfo_t cpumask_suite[] = {
ODP_TEST_INFO(cpumask_test_odp_cpumask_to_from_str),
ODP_TEST_INFO(cpumask_test_odp_cpumask_equal),
ODP_TEST_INFO(cpumask_test_odp_cpumask_zero),
ODP_TEST_INFO(cpumask_test_odp_cpumask_set),
ODP_TEST_INFO(cpumask_test_odp_cpumask_clr),
ODP_TEST_INFO(cpumask_test_odp_cpumask_isset),
ODP_TEST_INFO(cpumask_test_odp_cpumask_count),
ODP_TEST_INFO(cpumask_test_odp_cpumask_and),
ODP_TEST_INFO(cpumask_test_odp_cpumask_or),
ODP_TEST_INFO(cpumask_test_odp_cpumask_xor),
ODP_TEST_INFO(cpumask_test_odp_cpumask_copy),
ODP_TEST_INFO(cpumask_test_odp_cpumask_first),
ODP_TEST_INFO(cpumask_test_odp_cpumask_last),
ODP_TEST_INFO(cpumask_test_odp_cpumask_next),
ODP_TEST_INFO(cpumask_test_odp_cpumask_setall),
ODP_TEST_INFO(cpumask_test_odp_cpumask_def_control),
ODP_TEST_INFO(cpumask_test_odp_cpumask_def_worker),
ODP_TEST_INFO(cpumask_test_odp_cpumask_def),
ODP_TEST_INFO_NULL,
};
odp_suiteinfo_t cpumask_suites[] = {
{"Cpumask", NULL, NULL, cpumask_suite},
ODP_SUITE_INFO_NULL,
};
int main(int argc, char *argv[])
{
int ret;
/* parse common options: */
if (odp_cunit_parse_options(argc, argv))
return -1;
ret = odp_cunit_register(cpumask_suites);
if (ret == 0)
ret = odp_cunit_run();
return ret;
}
|
