+++ /dev/null
-/*
- * 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);
-}