1 files changed, 104 insertions, 0 deletions

diff --git a/lib/libtle_l4p/event.c b/lib/libtle_l4p/event.c
new file mode 100644
index 0000000..66c5a3b
--- /dev/null
+++ b/lib/libtle_l4p/event.c
@@ -0,0 +1,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);
+}