1 files changed, 108 insertions, 0 deletions
diff --git a/platform/linux-generic/include/odp_queue_internal.h b/platform/linux-generic/include/odp_queue_internal.h
new file mode 100644
index 000000000..6d6700a60
--- /dev/null
+++ b/platform/linux-generic/include/odp_queue_internal.h
@@ -0,0 +1,108 @@
+/* Copyright (c) 2013, Linaro Limited
+ * All rights reserved.
+ *
+ * SPDX-License-Identifier:     BSD-3-Clause
+ */
+
+
+/**
+ * @file
+ *
+ * ODP queue - implementation internal
+ */
+
+#ifndef ODP_QUEUE_INTERNAL_H_
+#define ODP_QUEUE_INTERNAL_H_
+
+#ifdef __cplusplus
+extern "C" {
+#endif
+
+#include <odp_queue.h>
+#include <odp_buffer_internal.h>
+#include <odp_packet_io.h>
+#include <odp_align.h>
+
+
+#define USE_TICKETLOCK
+
+#ifdef USE_TICKETLOCK
+#include <odp_ticketlock.h>
+#else
+#include <odp_spinlock.h>
+#endif
+
+#define QUEUE_STATUS_FREE     0
+#define QUEUE_STATUS_READY    1
+#define QUEUE_STATUS_NOTSCHED 2
+#define QUEUE_STATUS_SCHED    3
+
+/* forward declaration */
+union queue_entry_u;
+
+typedef int (*enqueue_func_t)(union queue_entry_u *, odp_buffer_hdr_t *);
+typedef	odp_buffer_hdr_t *(*dequeue_func_t)(union queue_entry_u *);
+
+struct queue_entry_s {
+#ifdef USE_TICKETLOCK
+	odp_ticketlock_t  lock ODP_ALIGNED_CACHE;
+#else
+	odp_spinlock_t    lock ODP_ALIGNED_CACHE;
+#endif
+
+	odp_buffer_hdr_t *head;
+	odp_buffer_hdr_t *tail;
+	int               status;
+
+	enqueue_func_t    enqueue ODP_ALIGNED_CACHE;
+	dequeue_func_t    dequeue;
+	odp_queue_t       handle;
+	odp_buffer_t      sched_buf;
+	odp_queue_type_t  type;
+	odp_queue_param_t param;
+	odp_pktio_t       pktin;
+	odp_pktio_t       pktout;
+	char              name[ODP_QUEUE_NAME_LEN];
+};
+
+typedef union queue_entry_u {
+	struct queue_entry_s s;
+	uint8_t pad[ODP_CACHE_LINE_SIZE_ROUNDUP(sizeof(struct queue_entry_s))];
+} queue_entry_t;
+
+
+queue_entry_t *get_qentry(uint32_t queue_id);
+
+int queue_enq(queue_entry_t *queue, odp_buffer_hdr_t *buf_hdr);
+odp_buffer_hdr_t *queue_deq(queue_entry_t *queue);
+
+void queue_lock(queue_entry_t *queue);
+void queue_unlock(queue_entry_t *queue);
+
+odp_buffer_t queue_sched_buf(odp_queue_t queue);
+int queue_sched_atomic(odp_queue_t handle);
+
+static inline uint32_t queue_to_id(odp_queue_t handle)
+{
+	return handle - 1;
+}
+
+static inline odp_queue_t queue_from_id(uint32_t queue_id)
+{
+	return queue_id + 1;
+}
+
+static inline queue_entry_t *queue_to_qentry(odp_queue_t handle)
+{
+	uint32_t queue_id;
+
+	queue_id = queue_to_id(handle);
+	return get_qentry(queue_id);
+}
+
+#ifdef __cplusplus
+}
+#endif
+
+#endif
+