Patch Detail
get:
Show a patch.
patch:
Update a patch.
put:
Update a patch.
GET /api/patches/41559/?format=api
{ "id": 41559, "url": "http://patches.dpdk.org/api/patches/41559/?format=api", "web_url": "http://patches.dpdk.org/project/dpdk/patch/efc55c28d1d7698fcc838f032af45d68c9289384.1530009564.git.anatoly.burakov@intel.com/", "project": { "id": 1, "url": "http://patches.dpdk.org/api/projects/1/?format=api", "name": "DPDK", "link_name": "dpdk", "list_id": "dev.dpdk.org", "list_email": "dev@dpdk.org", "web_url": "http://core.dpdk.org", "scm_url": "git://dpdk.org/dpdk", "webscm_url": "http://git.dpdk.org/dpdk", "list_archive_url": "https://inbox.dpdk.org/dev", "list_archive_url_format": "https://inbox.dpdk.org/dev/{}", "commit_url_format": "" }, "msgid": "<efc55c28d1d7698fcc838f032af45d68c9289384.1530009564.git.anatoly.burakov@intel.com>", "list_archive_url": "https://inbox.dpdk.org/dev/efc55c28d1d7698fcc838f032af45d68c9289384.1530009564.git.anatoly.burakov@intel.com", "date": "2018-06-26T10:53:14", "name": "[v2,3/7] eal/bsdapp: add interrupt thread", "commit_ref": null, "pull_url": null, "state": "accepted", "archived": true, "hash": "831c09080d6db88da0f75507b7c00cba37a45651", "submitter": { "id": 4, "url": "http://patches.dpdk.org/api/people/4/?format=api", "name": "Anatoly Burakov", "email": "anatoly.burakov@intel.com" }, "delegate": { "id": 1, "url": "http://patches.dpdk.org/api/users/1/?format=api", "username": "tmonjalo", "first_name": "Thomas", "last_name": "Monjalon", "email": "thomas@monjalon.net" }, "mbox": "http://patches.dpdk.org/project/dpdk/patch/efc55c28d1d7698fcc838f032af45d68c9289384.1530009564.git.anatoly.burakov@intel.com/mbox/", "series": [ { "id": 238, "url": "http://patches.dpdk.org/api/series/238/?format=api", "web_url": "http://patches.dpdk.org/project/dpdk/list/?series=238", "date": "2018-06-26T10:53:12", "name": "Remove asynchronous IPC thread", "version": 2, "mbox": "http://patches.dpdk.org/series/238/mbox/" } ], "comments": "http://patches.dpdk.org/api/patches/41559/comments/", "check": "success", "checks": "http://patches.dpdk.org/api/patches/41559/checks/", "tags": {}, "related": [], "headers": { "Return-Path": "<dev-bounces@dpdk.org>", "X-Original-To": "patchwork@dpdk.org", "Delivered-To": "patchwork@dpdk.org", "Received": [ "from [92.243.14.124] (localhost [127.0.0.1])\n\tby dpdk.org (Postfix) with ESMTP id 4FB401B573;\n\tTue, 26 Jun 2018 12:53:38 +0200 (CEST)", "from mga17.intel.com (mga17.intel.com [192.55.52.151])\n\tby dpdk.org (Postfix) with ESMTP id 93A131B4BA\n\tfor <dev@dpdk.org>; Tue, 26 Jun 2018 12:53:24 +0200 (CEST)", "from fmsmga001.fm.intel.com ([10.253.24.23])\n\tby fmsmga107.fm.intel.com with ESMTP/TLS/DHE-RSA-AES256-GCM-SHA384;\n\t26 Jun 2018 03:53:23 -0700", "from irvmail001.ir.intel.com ([163.33.26.43])\n\tby fmsmga001.fm.intel.com with ESMTP; 26 Jun 2018 03:53:20 -0700", "from sivswdev01.ir.intel.com (sivswdev01.ir.intel.com\n\t[10.237.217.45])\n\tby irvmail001.ir.intel.com (8.14.3/8.13.6/MailSET/Hub) with ESMTP id\n\tw5QArJnL026441; Tue, 26 Jun 2018 11:53:19 +0100", "from sivswdev01.ir.intel.com (localhost [127.0.0.1])\n\tby sivswdev01.ir.intel.com with ESMTP id w5QArJY7021199;\n\tTue, 26 Jun 2018 11:53:19 +0100", "(from aburakov@localhost)\n\tby sivswdev01.ir.intel.com with LOCAL id w5QArJYw021195;\n\tTue, 26 Jun 2018 11:53:19 +0100" ], "X-Amp-Result": "SKIPPED(no attachment in message)", "X-Amp-File-Uploaded": "False", "X-ExtLoop1": "1", "X-IronPort-AV": "E=Sophos;i=\"5.51,274,1526367600\"; d=\"scan'208\";a=\"67358859\"", "From": "Anatoly Burakov <anatoly.burakov@intel.com>", "To": "dev@dpdk.org", "Cc": "Bruce Richardson <bruce.richardson@intel.com>,\n\tkonstantin.ananyev@intel.com, thomas@monjalon.net, qi.z.zhang@intel.com", "Date": "Tue, 26 Jun 2018 11:53:14 +0100", "Message-Id": "<efc55c28d1d7698fcc838f032af45d68c9289384.1530009564.git.anatoly.burakov@intel.com>", "X-Mailer": "git-send-email 1.7.0.7", "In-Reply-To": [ "<cover.1530009564.git.anatoly.burakov@intel.com>", "<cover.1530009564.git.anatoly.burakov@intel.com>" ], "References": [ "<cover.1530009564.git.anatoly.burakov@intel.com>", "<cover.1529071026.git.anatoly.burakov@intel.com>\n\t<cover.1530009564.git.anatoly.burakov@intel.com>" ], "Subject": "[dpdk-dev] [PATCH v2 3/7] eal/bsdapp: add interrupt thread", "X-BeenThere": "dev@dpdk.org", "X-Mailman-Version": "2.1.15", "Precedence": "list", "List-Id": "DPDK patches and discussions <dev.dpdk.org>", "List-Unsubscribe": "<https://mails.dpdk.org/options/dev>,\n\t<mailto:dev-request@dpdk.org?subject=unsubscribe>", "List-Archive": "<http://mails.dpdk.org/archives/dev/>", "List-Post": "<mailto:dev@dpdk.org>", "List-Help": "<mailto:dev-request@dpdk.org?subject=help>", "List-Subscribe": "<https://mails.dpdk.org/listinfo/dev>,\n\t<mailto:dev-request@dpdk.org?subject=subscribe>", "Errors-To": "dev-bounces@dpdk.org", "Sender": "\"dev\" <dev-bounces@dpdk.org>" }, "content": "Add interrupt thread to FreeBSD. It is largely a copy-paste from\nLinuxapp interrupt thread, except for a few key differences:\n\n* Use kevent instead of epoll\n* Do not recreate the event queue on adding/removing interrupt\n sources, add/remove them to/from the queue on the fly instead\n* No support for UIO/VFIO handles\n\nSigned-off-by: Anatoly Burakov <anatoly.burakov@intel.com>\n---\n lib/librte_eal/bsdapp/eal/eal_interrupts.c | 436 ++++++++++++++++++++-\n 1 file changed, 418 insertions(+), 18 deletions(-)", "diff": "diff --git a/lib/librte_eal/bsdapp/eal/eal_interrupts.c b/lib/librte_eal/bsdapp/eal/eal_interrupts.c\nindex 290d53ab9..d0db6c6ff 100644\n--- a/lib/librte_eal/bsdapp/eal/eal_interrupts.c\n+++ b/lib/librte_eal/bsdapp/eal/eal_interrupts.c\n@@ -1,51 +1,451 @@\n /* SPDX-License-Identifier: BSD-3-Clause\n- * Copyright(c) 2010-2014 Intel Corporation\n+ * Copyright(c) 2010-2018 Intel Corporation\n */\n \n+#include <string.h>\n+#include <sys/types.h>\n+#include <sys/event.h>\n+#include <sys/queue.h>\n+#include <unistd.h>\n+\n+#include <rte_errno.h>\n+#include <rte_interrupts.h>\n+#include <rte_lcore.h>\n+#include <rte_spinlock.h>\n #include <rte_common.h>\n #include <rte_interrupts.h>\n+\n #include \"eal_private.h\"\n \n+#define MAX_INTR_EVENTS 16\n+\n+/**\n+ * union buffer for reading on different devices\n+ */\n+union rte_intr_read_buffer {\n+\tchar charbuf[16]; /* for others */\n+};\n+\n+TAILQ_HEAD(rte_intr_cb_list, rte_intr_callback);\n+TAILQ_HEAD(rte_intr_source_list, rte_intr_source);\n+\n+struct rte_intr_callback {\n+\tTAILQ_ENTRY(rte_intr_callback) next;\n+\trte_intr_callback_fn cb_fn; /**< callback address */\n+\tvoid *cb_arg; /**< parameter for callback */\n+};\n+\n+struct rte_intr_source {\n+\tTAILQ_ENTRY(rte_intr_source) next;\n+\tstruct rte_intr_handle intr_handle; /**< interrupt handle */\n+\tstruct rte_intr_cb_list callbacks; /**< user callbacks */\n+\tuint32_t active;\n+};\n+\n+/* global spinlock for interrupt data operation */\n+static rte_spinlock_t intr_lock = RTE_SPINLOCK_INITIALIZER;\n+\n+/* interrupt sources list */\n+static struct rte_intr_source_list intr_sources;\n+\n+/* interrupt handling thread */\n+static pthread_t intr_thread;\n+\n+static volatile int kq = -1;\n+\n+static int\n+intr_source_to_kevent(const struct rte_intr_handle *ih, struct kevent *ke)\n+{\n+\tke->filter = EVFILT_READ;\n+\tke->ident = ih->fd;\n+\n+\treturn 0;\n+}\n+\n int\n rte_intr_callback_register(const struct rte_intr_handle *intr_handle,\n-\t\t\trte_intr_callback_fn cb,\n-\t\t\tvoid *cb_arg)\n+\t\trte_intr_callback_fn cb, void *cb_arg)\n {\n-\tRTE_SET_USED(intr_handle);\n-\tRTE_SET_USED(cb);\n-\tRTE_SET_USED(cb_arg);\n+\tstruct rte_intr_callback *callback = NULL;\n+\tstruct rte_intr_source *src = NULL;\n+\tint ret, add_event;\n \n-\treturn -ENOTSUP;\n+\t/* first do parameter checking */\n+\tif (intr_handle == NULL || intr_handle->fd < 0 || cb == NULL) {\n+\t\tRTE_LOG(ERR, EAL,\n+\t\t\t\"Registering with invalid input parameter\\n\");\n+\t\treturn -EINVAL;\n+\t}\n+\tif (kq < 0) {\n+\t\tRTE_LOG(ERR, EAL, \"Kqueue is not active: %d\\n\", kq);\n+\t\treturn -ENODEV;\n+\t}\n+\n+\t/* allocate a new interrupt callback entity */\n+\tcallback = calloc(1, sizeof(*callback));\n+\tif (callback == NULL) {\n+\t\tRTE_LOG(ERR, EAL, \"Can not allocate memory\\n\");\n+\t\treturn -ENOMEM;\n+\t}\n+\tcallback->cb_fn = cb;\n+\tcallback->cb_arg = cb_arg;\n+\n+\trte_spinlock_lock(&intr_lock);\n+\n+\t/* check if there is at least one callback registered for the fd */\n+\tTAILQ_FOREACH(src, &intr_sources, next) {\n+\t\tif (src->intr_handle.fd == intr_handle->fd) {\n+\t\t\t/* we had no interrupts for this */\n+\t\t\tif (TAILQ_EMPTY(&src->callbacks))\n+\t\t\t\tadd_event = 1;\n+\n+\t\t\tTAILQ_INSERT_TAIL(&(src->callbacks), callback, next);\n+\t\t\tret = 0;\n+\t\t\tbreak;\n+\t\t}\n+\t}\n+\n+\t/* no existing callbacks for this - add new source */\n+\tif (src == NULL) {\n+\t\tsrc = calloc(1, sizeof(*src));\n+\t\tif (src == NULL) {\n+\t\t\tRTE_LOG(ERR, EAL, \"Can not allocate memory\\n\");\n+\t\t\tret = -ENOMEM;\n+\t\t\tgoto fail;\n+\t\t} else {\n+\t\t\tsrc->intr_handle = *intr_handle;\n+\t\t\tTAILQ_INIT(&src->callbacks);\n+\t\t\tTAILQ_INSERT_TAIL(&(src->callbacks), callback, next);\n+\t\t\tTAILQ_INSERT_TAIL(&intr_sources, src, next);\n+\t\t\tadd_event = 1;\n+\t\t\tret = 0;\n+\t\t}\n+\t}\n+\n+\t/* add events to the queue */\n+\tif (add_event) {\n+\t\tstruct kevent ke;\n+\n+\t\tmemset(&ke, 0, sizeof(ke));\n+\t\tke.flags = EV_ADD; /* mark for addition to the queue */\n+\n+\t\tif (intr_source_to_kevent(intr_handle, &ke) < 0) {\n+\t\t\tRTE_LOG(ERR, EAL, \"Cannot convert interrupt handle to kevent\\n\");\n+\t\t\tret = -ENODEV;\n+\t\t\tgoto fail;\n+\t\t}\n+\n+\t\t/**\n+\t\t * add the intr file descriptor into wait list.\n+\t\t */\n+\t\tif (kevent(kq, &ke, 1, NULL, 0, NULL) < 0) {\n+\t\t\tRTE_LOG(ERR, EAL, \"Error adding fd %d kevent, %s\\n\",\n+\t\t\t\tsrc->intr_handle.fd, strerror(errno));\n+\t\t\tret = -errno;\n+\t\t\tgoto fail;\n+\t\t}\n+\t}\n+\trte_spinlock_unlock(&intr_lock);\n+\n+\treturn ret;\n+fail:\n+\t/* clean up */\n+\tif (src != NULL) {\n+\t\tTAILQ_REMOVE(&(src->callbacks), callback, next);\n+\t\tif (TAILQ_EMPTY(&(src->callbacks))) {\n+\t\t\tTAILQ_REMOVE(&intr_sources, src, next);\n+\t\t\tfree(src);\n+\t\t}\n+\t}\n+\tfree(callback);\n+\trte_spinlock_unlock(&intr_lock);\n+\treturn ret;\n }\n \n int\n rte_intr_callback_unregister(const struct rte_intr_handle *intr_handle,\n-\t\t\trte_intr_callback_fn cb,\n-\t\t\tvoid *cb_arg)\n+\t\trte_intr_callback_fn cb_fn, void *cb_arg)\n {\n-\tRTE_SET_USED(intr_handle);\n-\tRTE_SET_USED(cb);\n-\tRTE_SET_USED(cb_arg);\n+\tint ret;\n+\tstruct rte_intr_source *src;\n+\tstruct rte_intr_callback *cb, *next;\n \n-\treturn -ENOTSUP;\n+\t/* do parameter checking first */\n+\tif (intr_handle == NULL || intr_handle->fd < 0) {\n+\t\tRTE_LOG(ERR, EAL,\n+\t\t\"Unregistering with invalid input parameter\\n\");\n+\t\treturn -EINVAL;\n+\t}\n+\tif (kq < 0) {\n+\t\tRTE_LOG(ERR, EAL, \"Kqueue is not active\\n\");\n+\t\treturn -ENODEV;\n+\t}\n+\n+\trte_spinlock_lock(&intr_lock);\n+\n+\t/* check if the insterrupt source for the fd is existent */\n+\tTAILQ_FOREACH(src, &intr_sources, next)\n+\t\tif (src->intr_handle.fd == intr_handle->fd)\n+\t\t\tbreak;\n+\n+\t/* No interrupt source registered for the fd */\n+\tif (src == NULL) {\n+\t\tret = -ENOENT;\n+\n+\t/* interrupt source has some active callbacks right now. */\n+\t} else if (src->active != 0) {\n+\t\tret = -EAGAIN;\n+\n+\t/* ok to remove. */\n+\t} else {\n+\t\tstruct kevent ke;\n+\n+\t\tret = 0;\n+\n+\t\t/* remove it from the kqueue */\n+\t\tmemset(&ke, 0, sizeof(ke));\n+\t\tke.flags = EV_DELETE; /* mark for deletion from the queue */\n+\n+\t\tif (intr_source_to_kevent(intr_handle, &ke) < 0) {\n+\t\t\tRTE_LOG(ERR, EAL, \"Cannot convert to kevent\\n\");\n+\t\t\tret = -ENODEV;\n+\t\t\tgoto out;\n+\t\t}\n+\n+\t\t/**\n+\t\t * remove intr file descriptor from wait list.\n+\t\t */\n+\t\tif (kevent(kq, &ke, 1, NULL, 0, NULL) < 0) {\n+\t\t\tRTE_LOG(ERR, EAL, \"Error removing fd %d kevent, %s\\n\",\n+\t\t\t\tsrc->intr_handle.fd, strerror(errno));\n+\t\t\tret = -errno;\n+\t\t\tgoto out;\n+\t\t}\n+\n+\t\t/*walk through the callbacks and remove all that match. */\n+\t\tfor (cb = TAILQ_FIRST(&src->callbacks); cb != NULL; cb = next) {\n+\t\t\tnext = TAILQ_NEXT(cb, next);\n+\t\t\tif (cb->cb_fn == cb_fn && (cb_arg == (void *)-1 ||\n+\t\t\t\t\tcb->cb_arg == cb_arg)) {\n+\t\t\t\tTAILQ_REMOVE(&src->callbacks, cb, next);\n+\t\t\t\tfree(cb);\n+\t\t\t\tret++;\n+\t\t\t}\n+\t\t}\n+\n+\t\t/* all callbacks for that source are removed. */\n+\t\tif (TAILQ_EMPTY(&src->callbacks)) {\n+\t\t\tTAILQ_REMOVE(&intr_sources, src, next);\n+\t\t\tfree(src);\n+\t\t}\n+\t}\n+out:\n+\trte_spinlock_unlock(&intr_lock);\n+\n+\treturn ret;\n }\n \n int\n-rte_intr_enable(const struct rte_intr_handle *intr_handle __rte_unused)\n+rte_intr_enable(const struct rte_intr_handle *intr_handle)\n {\n-\treturn -ENOTSUP;\n+\tif (intr_handle && intr_handle->type == RTE_INTR_HANDLE_VDEV)\n+\t\treturn 0;\n+\n+\tif (!intr_handle || intr_handle->fd < 0 || intr_handle->uio_cfg_fd < 0)\n+\t\treturn -1;\n+\n+\tswitch (intr_handle->type) {\n+\t/* not used at this moment */\n+\tcase RTE_INTR_HANDLE_ALARM:\n+\t\treturn -1;\n+\t/* not used at this moment */\n+\tcase RTE_INTR_HANDLE_DEV_EVENT:\n+\t\treturn -1;\n+\t/* unknown handle type */\n+\tdefault:\n+\t\tRTE_LOG(ERR, EAL,\n+\t\t\t\"Unknown handle type of fd %d\\n\",\n+\t\t\t\t\tintr_handle->fd);\n+\t\treturn -1;\n+\t}\n+\n+\treturn 0;\n }\n \n int\n-rte_intr_disable(const struct rte_intr_handle *intr_handle __rte_unused)\n+rte_intr_disable(const struct rte_intr_handle *intr_handle)\n {\n-\treturn -ENOTSUP;\n+\tif (intr_handle && intr_handle->type == RTE_INTR_HANDLE_VDEV)\n+\t\treturn 0;\n+\n+\tif (!intr_handle || intr_handle->fd < 0 || intr_handle->uio_cfg_fd < 0)\n+\t\treturn -1;\n+\n+\tswitch (intr_handle->type) {\n+\t/* not used at this moment */\n+\tcase RTE_INTR_HANDLE_ALARM:\n+\t\treturn -1;\n+\t/* not used at this moment */\n+\tcase RTE_INTR_HANDLE_DEV_EVENT:\n+\t\treturn -1;\n+\t/* unknown handle type */\n+\tdefault:\n+\t\tRTE_LOG(ERR, EAL,\n+\t\t\t\"Unknown handle type of fd %d\\n\",\n+\t\t\t\t\tintr_handle->fd);\n+\t\treturn -1;\n+\t}\n+\n+\treturn 0;\n+}\n+\n+static void\n+eal_intr_process_interrupts(struct kevent *events, int nfds)\n+{\n+\tstruct rte_intr_callback active_cb;\n+\tunion rte_intr_read_buffer buf;\n+\tstruct rte_intr_callback *cb;\n+\tstruct rte_intr_source *src;\n+\tbool call = false;\n+\tint n, bytes_read;\n+\n+\tfor (n = 0; n < nfds; n++) {\n+\t\tint event_fd = events[n].ident;\n+\n+\t\trte_spinlock_lock(&intr_lock);\n+\t\tTAILQ_FOREACH(src, &intr_sources, next)\n+\t\t\tif (src->intr_handle.fd == event_fd)\n+\t\t\t\tbreak;\n+\t\tif (src == NULL) {\n+\t\t\trte_spinlock_unlock(&intr_lock);\n+\t\t\tcontinue;\n+\t\t}\n+\n+\t\t/* mark this interrupt source as active and release the lock. */\n+\t\tsrc->active = 1;\n+\t\trte_spinlock_unlock(&intr_lock);\n+\n+\t\t/* set the length to be read dor different handle type */\n+\t\tswitch (src->intr_handle.type) {\n+\t\tcase RTE_INTR_HANDLE_ALARM:\n+\t\t\tbytes_read = 0;\n+\t\t\tcall = true;\n+\t\t\tbreak;\n+\t\tcase RTE_INTR_HANDLE_VDEV:\n+\t\tcase RTE_INTR_HANDLE_EXT:\n+\t\t\tbytes_read = 0;\n+\t\t\tcall = true;\n+\t\t\tbreak;\n+\t\tcase RTE_INTR_HANDLE_DEV_EVENT:\n+\t\t\tbytes_read = 0;\n+\t\t\tcall = true;\n+\t\t\tbreak;\n+\t\tdefault:\n+\t\t\tbytes_read = 1;\n+\t\t\tbreak;\n+\t\t}\n+\n+\t\tif (bytes_read > 0) {\n+\t\t\t/**\n+\t\t\t * read out to clear the ready-to-be-read flag\n+\t\t\t * for epoll_wait.\n+\t\t\t */\n+\t\t\tbytes_read = read(event_fd, &buf, bytes_read);\n+\t\t\tif (bytes_read < 0) {\n+\t\t\t\tif (errno == EINTR || errno == EWOULDBLOCK)\n+\t\t\t\t\tcontinue;\n+\n+\t\t\t\tRTE_LOG(ERR, EAL, \"Error reading from file \"\n+\t\t\t\t\t\"descriptor %d: %s\\n\",\n+\t\t\t\t\tevent_fd,\n+\t\t\t\t\tstrerror(errno));\n+\t\t\t} else if (bytes_read == 0)\n+\t\t\t\tRTE_LOG(ERR, EAL, \"Read nothing from file \"\n+\t\t\t\t\t\"descriptor %d\\n\", event_fd);\n+\t\t\telse\n+\t\t\t\tcall = true;\n+\t\t}\n+\n+\t\t/* grab a lock, again to call callbacks and update status. */\n+\t\trte_spinlock_lock(&intr_lock);\n+\n+\t\tif (call) {\n+\t\t\t/* Finally, call all callbacks. */\n+\t\t\tTAILQ_FOREACH(cb, &src->callbacks, next) {\n+\n+\t\t\t\t/* make a copy and unlock. */\n+\t\t\t\tactive_cb = *cb;\n+\t\t\t\trte_spinlock_unlock(&intr_lock);\n+\n+\t\t\t\t/* call the actual callback */\n+\t\t\t\tactive_cb.cb_fn(active_cb.cb_arg);\n+\n+\t\t\t\t/*get the lock back. */\n+\t\t\t\trte_spinlock_lock(&intr_lock);\n+\t\t\t}\n+\t\t}\n+\n+\t\t/* we done with that interrupt source, release it. */\n+\t\tsrc->active = 0;\n+\t\trte_spinlock_unlock(&intr_lock);\n+\t}\n+}\n+\n+static void *\n+eal_intr_thread_main(void *arg __rte_unused)\n+{\n+\tstruct kevent events[MAX_INTR_EVENTS];\n+\tint nfds;\n+\n+\t/* host thread, never break out */\n+\tfor (;;) {\n+\t\t/* do not change anything, just wait */\n+\t\tnfds = kevent(kq, NULL, 0, events, MAX_INTR_EVENTS, NULL);\n+\n+\t\t/* kevent fail */\n+\t\tif (nfds < 0) {\n+\t\t\tif (errno == EINTR)\n+\t\t\t\tcontinue;\n+\t\t\tRTE_LOG(ERR, EAL,\n+\t\t\t\t\"kevent returns with fail\\n\");\n+\t\t\tbreak;\n+\t\t}\n+\t\t/* kevent timeout, will never happen here */\n+\t\telse if (nfds == 0)\n+\t\t\tcontinue;\n+\n+\t\t/* kevent has at least one fd ready to read */\n+\t\teal_intr_process_interrupts(events, nfds);\n+\t}\n+\tclose(kq);\n+\tkq = -1;\n+\treturn NULL;\n }\n \n int\n rte_eal_intr_init(void)\n {\n-\treturn 0;\n+\tint ret = 0;\n+\n+\t/* init the global interrupt source head */\n+\tTAILQ_INIT(&intr_sources);\n+\n+\tkq = kqueue();\n+\tif (kq < 0) {\n+\t\tRTE_LOG(ERR, EAL, \"Cannot create kqueue instance\\n\");\n+\t\treturn -1;\n+\t}\n+\n+\t/* create the host thread to wait/handle the interrupt */\n+\tret = rte_ctrl_thread_create(&intr_thread, \"eal-intr-thread\", NULL,\n+\t\t\teal_intr_thread_main, NULL);\n+\tif (ret != 0) {\n+\t\trte_errno = -ret;\n+\t\tRTE_LOG(ERR, EAL,\n+\t\t\t\"Failed to create thread for interrupt handling\\n\");\n+\t}\n+\n+\treturn ret;\n }\n \n int\n", "prefixes": [ "v2", "3/7" ] }