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
133
134
135
136
137
138
139
140
141
142
143
144
145
|
/* Copyright (c) 2017, ARM Limited
* All rights reserved.
*
* SPDX-License-Identifier: BSD-3-Clause
*/
#include "config.h"
#include <odp_queue_if.h>
#include <odp_init_internal.h>
#include <odp_debug_internal.h>
#include <stdlib.h>
#include <string.h>
#include <odp/api/align.h>
#include <odp/api/plat/queue_inline_types.h>
#include <odp/visibility_begin.h>
_odp_queue_inline_offset_t ODP_ALIGNED_CACHE _odp_queue_inline_offset;
#include <odp/visibility_end.h>
extern const queue_api_t queue_scalable_api;
extern const queue_fn_t queue_scalable_fn;
extern const queue_api_t queue_basic_api;
extern const queue_fn_t queue_basic_fn;
const queue_api_t *queue_api;
const queue_fn_t *queue_fn;
odp_queue_t odp_queue_create(const char *name, const odp_queue_param_t *param)
{
return queue_api->queue_create(name, param);
}
int odp_queue_destroy(odp_queue_t queue)
{
return queue_api->queue_destroy(queue);
}
odp_queue_t odp_queue_lookup(const char *name)
{
return queue_api->queue_lookup(name);
}
int odp_queue_capability(odp_queue_capability_t *capa)
{
return queue_api->queue_capability(capa);
}
int odp_queue_context_set(odp_queue_t queue, void *context, uint32_t len)
{
return queue_api->queue_context_set(queue, context, len);
}
int odp_queue_enq(odp_queue_t queue, odp_event_t ev)
{
return queue_api->queue_enq(queue, ev);
}
int odp_queue_enq_multi(odp_queue_t queue, const odp_event_t events[], int num)
{
return queue_api->queue_enq_multi(queue, events, num);
}
odp_event_t odp_queue_deq(odp_queue_t queue)
{
return queue_api->queue_deq(queue);
}
int odp_queue_deq_multi(odp_queue_t queue, odp_event_t events[], int num)
{
return queue_api->queue_deq_multi(queue, events, num);
}
odp_queue_type_t odp_queue_type(odp_queue_t queue)
{
return queue_api->queue_type(queue);
}
odp_schedule_sync_t odp_queue_sched_type(odp_queue_t queue)
{
return queue_api->queue_sched_type(queue);
}
odp_schedule_prio_t odp_queue_sched_prio(odp_queue_t queue)
{
return queue_api->queue_sched_prio(queue);
}
odp_schedule_group_t odp_queue_sched_group(odp_queue_t queue)
{
return queue_api->queue_sched_group(queue);
}
uint32_t odp_queue_lock_count(odp_queue_t queue)
{
return queue_api->queue_lock_count(queue);
}
uint64_t odp_queue_to_u64(odp_queue_t hdl)
{
return queue_api->queue_to_u64(hdl);
}
void odp_queue_param_init(odp_queue_param_t *param)
{
return queue_api->queue_param_init(param);
}
int odp_queue_info(odp_queue_t queue, odp_queue_info_t *info)
{
return queue_api->queue_info(queue, info);
}
int _odp_queue_init_global(void)
{
const char *sched = getenv("ODP_SCHEDULER");
if (sched == NULL || !strcmp(sched, "default"))
sched = ODP_SCHEDULE_DEFAULT;
if (!strcmp(sched, "basic") ||
!strcmp(sched, "sp") ||
!strcmp(sched, "iquery")) {
queue_fn = &queue_basic_fn;
queue_api = &queue_basic_api;
} else if (!strcmp(sched, "scalable")) {
queue_fn = &queue_scalable_fn;
queue_api = &queue_scalable_api;
} else {
ODP_ABORT("Unknown scheduler specified via ODP_SCHEDULER\n");
return -1;
}
return queue_fn->init_global();
}
int _odp_queue_term_global(void)
{
return queue_fn->term_global();
}
|
