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
|
/*
* Copyright (c) 2016 Intel Corporation.
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at:
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#include <rte_errno.h>
#include <rte_malloc.h>
#include <rte_log.h>
#include <tle_event.h>
#include "osdep.h"
struct tle_evq *
tle_evq_create(const struct tle_evq_param *prm)
{
struct tle_evq *evq;
size_t sz;
uint32_t i;
if (prm == NULL) {
rte_errno = EINVAL;
return NULL;
}
sz = sizeof(*evq) + sizeof(evq->events[0]) * prm->max_events;
evq = rte_zmalloc_socket(NULL, sz, RTE_CACHE_LINE_SIZE,
prm->socket_id);
if (evq == NULL) {
UDP_LOG(ERR, "allocation of %zu bytes for "
"new tle_evq(%u) on socket %d failed\n",
sz, prm->max_events, prm->socket_id);
return NULL;
}
TAILQ_INIT(&evq->armed);
TAILQ_INIT(&evq->free);
for (i = 0; i != prm->max_events; i++) {
evq->events[i].head = evq;
TAILQ_INSERT_TAIL(&evq->free, evq->events + i, ql);
}
evq->nb_events = i;
evq->nb_free = i;
return evq;
}
void
tle_evq_destroy(struct tle_evq *evq)
{
rte_free(evq);
}
struct tle_event *
tle_event_alloc(struct tle_evq *evq, const void *data)
{
struct tle_event *h;
if (evq == NULL) {
rte_errno = EINVAL;
return NULL;
}
rte_spinlock_lock(&evq->lock);
h = TAILQ_FIRST(&evq->free);
if (h != NULL) {
TAILQ_REMOVE(&evq->free, h, ql);
evq->nb_free--;
h->data = data;
} else
rte_errno = ENOMEM;
rte_spinlock_unlock(&evq->lock);
return h;
}
void
tle_event_free(struct tle_event *ev)
{
struct tle_evq *q;
if (ev == NULL) {
rte_errno = EINVAL;
return;
}
q = ev->head;
rte_spinlock_lock(&q->lock);
ev->data = NULL;
ev->state = TLE_SEV_IDLE;
TAILQ_INSERT_HEAD(&q->free, ev, ql);
q->nb_free++;
rte_spinlock_unlock(&q->lock);
}
|
