lib/librte_eal/windows/eal_interrupts.c

   1 /* SPDX-License-Identifier: BSD-3-Clause
   2  * Copyright 2020 Mellanox Technologies, Ltd
   3  */
   4
   5 #include <rte_interrupts.h>
   6
   7 #include "eal_private.h"
   8 #include "eal_windows.h"
   9
  10 static pthread_t intr_thread;
  11
  12 static HANDLE intr_iocp;
  13
  14 static void
  15 eal_intr_process(const OVERLAPPED_ENTRY *event)
  16 {
  17         RTE_SET_USED(event);
  18 }
  19
  20 static void *
  21 eal_intr_thread_main(LPVOID arg __rte_unused)
  22 {
  23         while (1) {
  24                 OVERLAPPED_ENTRY events[16];
  25                 ULONG event_count, i;
  26                 BOOL result;
  27
  28                 result = GetQueuedCompletionStatusEx(
  29                         intr_iocp, events, RTE_DIM(events), &event_count,
  30                         INFINITE, /* no timeout */
  31                         TRUE);    /* alertable wait for alarm APCs */
  32
  33                 if (!result) {
  34                         DWORD error = GetLastError();
  35                         if (error != WAIT_IO_COMPLETION) {
  36                                 RTE_LOG_WIN32_ERR("GetQueuedCompletionStatusEx()");
  37                                 RTE_LOG(ERR, EAL, "Failed waiting for interrupts\n");
  38                                 break;
  39                         }
  40
  41                         /* No I/O events, all work is done in completed APCs. */
  42                         continue;
  43                 }
  44
  45                 for (i = 0; i < event_count; i++)
  46                         eal_intr_process(&events[i]);
  47         }
  48
  49         CloseHandle(intr_iocp);
  50         intr_iocp = NULL;
  51         return NULL;
  52 }
  53
  54 int
  55 rte_eal_intr_init(void)
  56 {
  57         int ret = 0;
  58
  59         intr_iocp = CreateIoCompletionPort(INVALID_HANDLE_VALUE, NULL, 0, 1);
  60         if (intr_iocp == NULL) {
  61                 RTE_LOG_WIN32_ERR("CreateIoCompletionPort()");
  62                 RTE_LOG(ERR, EAL, "Cannot create interrupt IOCP\n");
  63                 return -1;
  64         }
  65
  66         ret = rte_ctrl_thread_create(&intr_thread, "eal-intr-thread", NULL,
  67                         eal_intr_thread_main, NULL);
  68         if (ret != 0) {
  69                 rte_errno = -ret;
  70                 RTE_LOG(ERR, EAL, "Cannot create interrupt thread\n");
  71         }
  72
  73         return ret;
  74 }
  75
  76 int
  77 rte_thread_is_intr(void)
  78 {
  79         return pthread_equal(intr_thread, pthread_self());
  80 }
  81
  82 int
  83 rte_intr_rx_ctl(__rte_unused struct rte_intr_handle *intr_handle,
  84                 __rte_unused int epfd, __rte_unused int op,
  85                 __rte_unused unsigned int vec, __rte_unused void *data)
  86 {
  87         return -ENOTSUP;
  88 }
  89
  90 int
  91 eal_intr_thread_schedule(void (*func)(void *arg), void *arg)
  92 {
  93         HANDLE handle;
  94
  95         handle = OpenThread(THREAD_ALL_ACCESS, FALSE, intr_thread);
  96         if (handle == NULL) {
  97                 RTE_LOG_WIN32_ERR("OpenThread(%llu)", intr_thread);
  98                 return -ENOENT;
  99         }
 100
 101         if (!QueueUserAPC((PAPCFUNC)(ULONG_PTR)func, handle, (ULONG_PTR)arg)) {
 102                 RTE_LOG_WIN32_ERR("QueueUserAPC()");
 103                 return -EINVAL;
 104         }
 105
 106         return 0;
 107 }