doc: add Meson coding style to contributors guide
[dpdk.git] / lib / librte_eal / freebsd / eal_interrupts.c
1 /* SPDX-License-Identifier: BSD-3-Clause
2  * Copyright(c) 2010-2018 Intel Corporation
3  */
4
5 #include <string.h>
6 #include <sys/types.h>
7 #include <sys/event.h>
8 #include <sys/queue.h>
9 #include <unistd.h>
10
11 #include <rte_errno.h>
12 #include <rte_lcore.h>
13 #include <rte_spinlock.h>
14 #include <rte_common.h>
15 #include <rte_interrupts.h>
16 #include <rte_eal_trace.h>
17
18 #include "eal_private.h"
19 #include "eal_alarm_private.h"
20
21 #define MAX_INTR_EVENTS 16
22
23 /**
24  * union buffer for reading on different devices
25  */
26 union rte_intr_read_buffer {
27         char charbuf[16];                /* for others */
28 };
29
30 TAILQ_HEAD(rte_intr_cb_list, rte_intr_callback);
31 TAILQ_HEAD(rte_intr_source_list, rte_intr_source);
32
33 struct rte_intr_callback {
34         TAILQ_ENTRY(rte_intr_callback) next;
35         rte_intr_callback_fn cb_fn;  /**< callback address */
36         void *cb_arg;                /**< parameter for callback */
37         uint8_t pending_delete;      /**< delete after callback is called */
38         rte_intr_unregister_callback_fn ucb_fn; /**< fn to call before cb is deleted */
39 };
40
41 struct rte_intr_source {
42         TAILQ_ENTRY(rte_intr_source) next;
43         struct rte_intr_handle intr_handle; /**< interrupt handle */
44         struct rte_intr_cb_list callbacks;  /**< user callbacks */
45         uint32_t active;
46 };
47
48 /* global spinlock for interrupt data operation */
49 static rte_spinlock_t intr_lock = RTE_SPINLOCK_INITIALIZER;
50
51 /* interrupt sources list */
52 static struct rte_intr_source_list intr_sources;
53
54 /* interrupt handling thread */
55 static pthread_t intr_thread;
56
57 static volatile int kq = -1;
58
59 static int
60 intr_source_to_kevent(const struct rte_intr_handle *ih, struct kevent *ke)
61 {
62         /* alarm callbacks are special case */
63         if (ih->type == RTE_INTR_HANDLE_ALARM) {
64                 uint64_t timeout_ns;
65
66                 /* get soonest alarm timeout */
67                 if (eal_alarm_get_timeout_ns(&timeout_ns) < 0)
68                         return -1;
69
70                 ke->filter = EVFILT_TIMER;
71                 /* timers are one shot */
72                 ke->flags |= EV_ONESHOT;
73                 ke->fflags = NOTE_NSECONDS;
74                 ke->data = timeout_ns;
75         } else {
76                 ke->filter = EVFILT_READ;
77         }
78         ke->ident = ih->fd;
79
80         return 0;
81 }
82
83 int
84 rte_intr_callback_register(const struct rte_intr_handle *intr_handle,
85                 rte_intr_callback_fn cb, void *cb_arg)
86 {
87         struct rte_intr_callback *callback;
88         struct rte_intr_source *src;
89         int ret = 0, add_event = 0;
90
91         /* first do parameter checking */
92         if (intr_handle == NULL || intr_handle->fd < 0 || cb == NULL) {
93                 RTE_LOG(ERR, EAL,
94                         "Registering with invalid input parameter\n");
95                 return -EINVAL;
96         }
97         if (kq < 0) {
98                 RTE_LOG(ERR, EAL, "Kqueue is not active: %d\n", kq);
99                 return -ENODEV;
100         }
101
102         rte_spinlock_lock(&intr_lock);
103
104         /* find the source for this intr_handle */
105         TAILQ_FOREACH(src, &intr_sources, next) {
106                 if (src->intr_handle.fd == intr_handle->fd)
107                         break;
108         }
109
110         /* if this is an alarm interrupt and it already has a callback,
111          * then we don't want to create a new callback because the only
112          * thing on the list should be eal_alarm_callback() and we may
113          * be called just to reset the timer.
114          */
115         if (src != NULL && src->intr_handle.type == RTE_INTR_HANDLE_ALARM &&
116                  !TAILQ_EMPTY(&src->callbacks)) {
117                 callback = NULL;
118         } else {
119                 /* allocate a new interrupt callback entity */
120                 callback = calloc(1, sizeof(*callback));
121                 if (callback == NULL) {
122                         RTE_LOG(ERR, EAL, "Can not allocate memory\n");
123                         ret = -ENOMEM;
124                         goto fail;
125                 }
126                 callback->cb_fn = cb;
127                 callback->cb_arg = cb_arg;
128                 callback->pending_delete = 0;
129                 callback->ucb_fn = NULL;
130
131                 if (src == NULL) {
132                         src = calloc(1, sizeof(*src));
133                         if (src == NULL) {
134                                 RTE_LOG(ERR, EAL, "Can not allocate memory\n");
135                                 ret = -ENOMEM;
136                                 goto fail;
137                         } else {
138                                 src->intr_handle = *intr_handle;
139                                 TAILQ_INIT(&src->callbacks);
140                                 TAILQ_INSERT_TAIL(&intr_sources, src, next);
141                         }
142                 }
143
144                 /* we had no interrupts for this */
145                 if (TAILQ_EMPTY(&src->callbacks))
146                         add_event = 1;
147
148                 TAILQ_INSERT_TAIL(&(src->callbacks), callback, next);
149         }
150
151         /* add events to the queue. timer events are special as we need to
152          * re-set the timer.
153          */
154         if (add_event || src->intr_handle.type == RTE_INTR_HANDLE_ALARM) {
155                 struct kevent ke;
156
157                 memset(&ke, 0, sizeof(ke));
158                 ke.flags = EV_ADD; /* mark for addition to the queue */
159
160                 if (intr_source_to_kevent(intr_handle, &ke) < 0) {
161                         RTE_LOG(ERR, EAL, "Cannot convert interrupt handle to kevent\n");
162                         ret = -ENODEV;
163                         goto fail;
164                 }
165
166                 /**
167                  * add the intr file descriptor into wait list.
168                  */
169                 if (kevent(kq, &ke, 1, NULL, 0, NULL) < 0) {
170                         /* currently, nic_uio does not support interrupts, so
171                          * this error will always be triggered and output to the
172                          * user. so, don't output it unless debug log level set.
173                          */
174                         if (errno == ENODEV)
175                                 RTE_LOG(DEBUG, EAL, "Interrupt handle %d not supported\n",
176                                         src->intr_handle.fd);
177                         else
178                                 RTE_LOG(ERR, EAL, "Error adding fd %d "
179                                                 "kevent, %s\n",
180                                                 src->intr_handle.fd,
181                                                 strerror(errno));
182                         ret = -errno;
183                         goto fail;
184                 }
185         }
186         rte_eal_trace_intr_callback_register(intr_handle, cb, cb_arg, ret);
187         rte_spinlock_unlock(&intr_lock);
188
189         return 0;
190 fail:
191         /* clean up */
192         if (src != NULL) {
193                 if (callback != NULL)
194                         TAILQ_REMOVE(&(src->callbacks), callback, next);
195                 if (TAILQ_EMPTY(&(src->callbacks))) {
196                         TAILQ_REMOVE(&intr_sources, src, next);
197                         free(src);
198                 }
199         }
200         free(callback);
201         rte_eal_trace_intr_callback_register(intr_handle, cb, cb_arg, ret);
202         rte_spinlock_unlock(&intr_lock);
203         return ret;
204 }
205
206 int
207 rte_intr_callback_unregister_pending(const struct rte_intr_handle *intr_handle,
208                                 rte_intr_callback_fn cb_fn, void *cb_arg,
209                                 rte_intr_unregister_callback_fn ucb_fn)
210 {
211         int ret;
212         struct rte_intr_source *src;
213         struct rte_intr_callback *cb, *next;
214
215         /* do parameter checking first */
216         if (intr_handle == NULL || intr_handle->fd < 0) {
217                 RTE_LOG(ERR, EAL,
218                 "Unregistering with invalid input parameter\n");
219                 return -EINVAL;
220         }
221
222         if (kq < 0) {
223                 RTE_LOG(ERR, EAL, "Kqueue is not active\n");
224                 return -ENODEV;
225         }
226
227         rte_spinlock_lock(&intr_lock);
228
229         /* check if the insterrupt source for the fd is existent */
230         TAILQ_FOREACH(src, &intr_sources, next)
231                 if (src->intr_handle.fd == intr_handle->fd)
232                         break;
233
234         /* No interrupt source registered for the fd */
235         if (src == NULL) {
236                 ret = -ENOENT;
237
238         /* only usable if the source is active */
239         } else if (src->active == 0) {
240                 ret = -EAGAIN;
241
242         } else {
243                 ret = 0;
244
245                 /* walk through the callbacks and mark all that match. */
246                 for (cb = TAILQ_FIRST(&src->callbacks); cb != NULL; cb = next) {
247                         next = TAILQ_NEXT(cb, next);
248                         if (cb->cb_fn == cb_fn && (cb_arg == (void *)-1 ||
249                                         cb->cb_arg == cb_arg)) {
250                                 cb->pending_delete = 1;
251                                 cb->ucb_fn = ucb_fn;
252                                 ret++;
253                         }
254                 }
255         }
256
257         rte_spinlock_unlock(&intr_lock);
258
259         return ret;
260 }
261
262 int
263 rte_intr_callback_unregister(const struct rte_intr_handle *intr_handle,
264                 rte_intr_callback_fn cb_fn, void *cb_arg)
265 {
266         int ret;
267         struct rte_intr_source *src;
268         struct rte_intr_callback *cb, *next;
269
270         /* do parameter checking first */
271         if (intr_handle == NULL || intr_handle->fd < 0) {
272                 RTE_LOG(ERR, EAL,
273                 "Unregistering with invalid input parameter\n");
274                 return -EINVAL;
275         }
276         if (kq < 0) {
277                 RTE_LOG(ERR, EAL, "Kqueue is not active\n");
278                 return -ENODEV;
279         }
280
281         rte_spinlock_lock(&intr_lock);
282
283         /* check if the insterrupt source for the fd is existent */
284         TAILQ_FOREACH(src, &intr_sources, next)
285                 if (src->intr_handle.fd == intr_handle->fd)
286                         break;
287
288         /* No interrupt source registered for the fd */
289         if (src == NULL) {
290                 ret = -ENOENT;
291
292         /* interrupt source has some active callbacks right now. */
293         } else if (src->active != 0) {
294                 ret = -EAGAIN;
295
296         /* ok to remove. */
297         } else {
298                 struct kevent ke;
299
300                 ret = 0;
301
302                 /* remove it from the kqueue */
303                 memset(&ke, 0, sizeof(ke));
304                 ke.flags = EV_DELETE; /* mark for deletion from the queue */
305
306                 if (intr_source_to_kevent(intr_handle, &ke) < 0) {
307                         RTE_LOG(ERR, EAL, "Cannot convert to kevent\n");
308                         ret = -ENODEV;
309                         goto out;
310                 }
311
312                 /**
313                  * remove intr file descriptor from wait list.
314                  */
315                 if (kevent(kq, &ke, 1, NULL, 0, NULL) < 0) {
316                         RTE_LOG(ERR, EAL, "Error removing fd %d kevent, %s\n",
317                                 src->intr_handle.fd, strerror(errno));
318                         /* removing non-existent even is an expected condition
319                          * in some circumstances (e.g. oneshot events).
320                          */
321                 }
322
323                 /*walk through the callbacks and remove all that match. */
324                 for (cb = TAILQ_FIRST(&src->callbacks); cb != NULL; cb = next) {
325                         next = TAILQ_NEXT(cb, next);
326                         if (cb->cb_fn == cb_fn && (cb_arg == (void *)-1 ||
327                                         cb->cb_arg == cb_arg)) {
328                                 TAILQ_REMOVE(&src->callbacks, cb, next);
329                                 free(cb);
330                                 ret++;
331                         }
332                 }
333
334                 /* all callbacks for that source are removed. */
335                 if (TAILQ_EMPTY(&src->callbacks)) {
336                         TAILQ_REMOVE(&intr_sources, src, next);
337                         free(src);
338                 }
339         }
340 out:
341         rte_eal_trace_intr_callback_unregister(intr_handle, cb_fn, cb_arg,
342                 ret);
343         rte_spinlock_unlock(&intr_lock);
344
345         return ret;
346 }
347
348 int
349 rte_intr_callback_unregister_sync(const struct rte_intr_handle *intr_handle,
350                 rte_intr_callback_fn cb_fn, void *cb_arg)
351 {
352         int ret = 0;
353
354         while ((ret = rte_intr_callback_unregister(intr_handle, cb_fn, cb_arg)) == -EAGAIN)
355                 rte_pause();
356
357         return ret;
358 }
359
360 int
361 rte_intr_enable(const struct rte_intr_handle *intr_handle)
362 {
363         int rc = 0;
364
365         if (intr_handle == NULL)
366                 return -1;
367
368         if (intr_handle->type == RTE_INTR_HANDLE_VDEV) {
369                 rc = 0;
370                 goto out;
371         }
372
373         if (intr_handle->fd < 0 || intr_handle->uio_cfg_fd < 0) {
374                 rc = -1;
375                 goto out;
376         }
377
378         switch (intr_handle->type) {
379         /* not used at this moment */
380         case RTE_INTR_HANDLE_ALARM:
381                 rc = -1;
382                 break;
383         /* not used at this moment */
384         case RTE_INTR_HANDLE_DEV_EVENT:
385                 rc = -1;
386                 break;
387         /* unknown handle type */
388         default:
389                 RTE_LOG(ERR, EAL,
390                         "Unknown handle type of fd %d\n",
391                                         intr_handle->fd);
392                 rc = -1;
393                 break;
394         }
395
396 out:
397         rte_eal_trace_intr_enable(intr_handle, rc);
398         return rc;
399 }
400
401 int
402 rte_intr_disable(const struct rte_intr_handle *intr_handle)
403 {
404         int rc = 0;
405
406         if (intr_handle == NULL)
407                 return -1;
408
409         if (intr_handle->type == RTE_INTR_HANDLE_VDEV) {
410                 rc = 0;
411                 goto out;
412         }
413
414         if (intr_handle->fd < 0 || intr_handle->uio_cfg_fd < 0) {
415                 rc = -1;
416                 goto out;
417         }
418
419         switch (intr_handle->type) {
420         /* not used at this moment */
421         case RTE_INTR_HANDLE_ALARM:
422                 rc = -1;
423                 break;
424         /* not used at this moment */
425         case RTE_INTR_HANDLE_DEV_EVENT:
426                 rc = -1;
427                 break;
428         /* unknown handle type */
429         default:
430                 RTE_LOG(ERR, EAL,
431                         "Unknown handle type of fd %d\n",
432                                         intr_handle->fd);
433                 rc = -1;
434                 break;
435         }
436 out:
437         rte_eal_trace_intr_disable(intr_handle, rc);
438         return rc;
439 }
440
441 int
442 rte_intr_ack(const struct rte_intr_handle *intr_handle)
443 {
444         if (intr_handle && intr_handle->type == RTE_INTR_HANDLE_VDEV)
445                 return 0;
446
447         return -1;
448 }
449
450 static void
451 eal_intr_process_interrupts(struct kevent *events, int nfds)
452 {
453         struct rte_intr_callback active_cb;
454         union rte_intr_read_buffer buf;
455         struct rte_intr_callback *cb, *next;
456         struct rte_intr_source *src;
457         bool call = false;
458         int n, bytes_read;
459         struct kevent ke;
460
461         for (n = 0; n < nfds; n++) {
462                 int event_fd = events[n].ident;
463
464                 rte_spinlock_lock(&intr_lock);
465                 TAILQ_FOREACH(src, &intr_sources, next)
466                         if (src->intr_handle.fd == event_fd)
467                                 break;
468                 if (src == NULL) {
469                         rte_spinlock_unlock(&intr_lock);
470                         continue;
471                 }
472
473                 /* mark this interrupt source as active and release the lock. */
474                 src->active = 1;
475                 rte_spinlock_unlock(&intr_lock);
476
477                 /* set the length to be read dor different handle type */
478                 switch (src->intr_handle.type) {
479                 case RTE_INTR_HANDLE_ALARM:
480                         bytes_read = 0;
481                         call = true;
482                         break;
483                 case RTE_INTR_HANDLE_VDEV:
484                 case RTE_INTR_HANDLE_EXT:
485                         bytes_read = 0;
486                         call = true;
487                         break;
488                 case RTE_INTR_HANDLE_DEV_EVENT:
489                         bytes_read = 0;
490                         call = true;
491                         break;
492                 default:
493                         bytes_read = 1;
494                         break;
495                 }
496
497                 if (bytes_read > 0) {
498                         /**
499                          * read out to clear the ready-to-be-read flag
500                          * for epoll_wait.
501                          */
502                         bytes_read = read(event_fd, &buf, bytes_read);
503                         if (bytes_read < 0) {
504                                 if (errno == EINTR || errno == EWOULDBLOCK)
505                                         continue;
506
507                                 RTE_LOG(ERR, EAL, "Error reading from file "
508                                         "descriptor %d: %s\n",
509                                         event_fd,
510                                         strerror(errno));
511                         } else if (bytes_read == 0)
512                                 RTE_LOG(ERR, EAL, "Read nothing from file "
513                                         "descriptor %d\n", event_fd);
514                         else
515                                 call = true;
516                 }
517
518                 /* grab a lock, again to call callbacks and update status. */
519                 rte_spinlock_lock(&intr_lock);
520
521                 if (call) {
522                         /* Finally, call all callbacks. */
523                         TAILQ_FOREACH(cb, &src->callbacks, next) {
524
525                                 /* make a copy and unlock. */
526                                 active_cb = *cb;
527                                 rte_spinlock_unlock(&intr_lock);
528
529                                 /* call the actual callback */
530                                 active_cb.cb_fn(active_cb.cb_arg);
531
532                                 /*get the lock back. */
533                                 rte_spinlock_lock(&intr_lock);
534                         }
535                 }
536
537                 /* we done with that interrupt source, release it. */
538                 src->active = 0;
539
540                 /* check if any callback are supposed to be removed */
541                 for (cb = TAILQ_FIRST(&src->callbacks); cb != NULL; cb = next) {
542                         next = TAILQ_NEXT(cb, next);
543                         if (cb->pending_delete) {
544                                 /* remove it from the kqueue */
545                                 memset(&ke, 0, sizeof(ke));
546                                 /* mark for deletion from the queue */
547                                 ke.flags = EV_DELETE;
548
549                                 if (intr_source_to_kevent(&src->intr_handle, &ke) < 0) {
550                                         RTE_LOG(ERR, EAL, "Cannot convert to kevent\n");
551                                         rte_spinlock_unlock(&intr_lock);
552                                         return;
553                                 }
554
555                                 /**
556                                  * remove intr file descriptor from wait list.
557                                  */
558                                 if (kevent(kq, &ke, 1, NULL, 0, NULL) < 0) {
559                                         RTE_LOG(ERR, EAL, "Error removing fd %d kevent, "
560                                                 "%s\n", src->intr_handle.fd,
561                                                 strerror(errno));
562                                         /* removing non-existent even is an expected
563                                          * condition in some circumstances
564                                          * (e.g. oneshot events).
565                                          */
566                                 }
567
568                                 TAILQ_REMOVE(&src->callbacks, cb, next);
569                                 if (cb->ucb_fn)
570                                         cb->ucb_fn(&src->intr_handle, cb->cb_arg);
571                                 free(cb);
572                         }
573                 }
574
575                 /* all callbacks for that source are removed. */
576                 if (TAILQ_EMPTY(&src->callbacks)) {
577                         TAILQ_REMOVE(&intr_sources, src, next);
578                         free(src);
579                 }
580
581                 rte_spinlock_unlock(&intr_lock);
582         }
583 }
584
585 static void *
586 eal_intr_thread_main(void *arg __rte_unused)
587 {
588         struct kevent events[MAX_INTR_EVENTS];
589         int nfds;
590
591         /* host thread, never break out */
592         for (;;) {
593                 /* do not change anything, just wait */
594                 nfds = kevent(kq, NULL, 0, events, MAX_INTR_EVENTS, NULL);
595
596                 /* kevent fail */
597                 if (nfds < 0) {
598                         if (errno == EINTR)
599                                 continue;
600                         RTE_LOG(ERR, EAL,
601                                 "kevent returns with fail\n");
602                         break;
603                 }
604                 /* kevent timeout, will never happen here */
605                 else if (nfds == 0)
606                         continue;
607
608                 /* kevent has at least one fd ready to read */
609                 eal_intr_process_interrupts(events, nfds);
610         }
611         close(kq);
612         kq = -1;
613         return NULL;
614 }
615
616 int
617 rte_eal_intr_init(void)
618 {
619         int ret = 0;
620
621         /* init the global interrupt source head */
622         TAILQ_INIT(&intr_sources);
623
624         kq = kqueue();
625         if (kq < 0) {
626                 RTE_LOG(ERR, EAL, "Cannot create kqueue instance\n");
627                 return -1;
628         }
629
630         /* create the host thread to wait/handle the interrupt */
631         ret = rte_ctrl_thread_create(&intr_thread, "eal-intr-thread", NULL,
632                         eal_intr_thread_main, NULL);
633         if (ret != 0) {
634                 rte_errno = -ret;
635                 RTE_LOG(ERR, EAL,
636                         "Failed to create thread for interrupt handling\n");
637         }
638
639         return ret;
640 }
641
642 int
643 rte_intr_rx_ctl(struct rte_intr_handle *intr_handle,
644                 int epfd, int op, unsigned int vec, void *data)
645 {
646         RTE_SET_USED(intr_handle);
647         RTE_SET_USED(epfd);
648         RTE_SET_USED(op);
649         RTE_SET_USED(vec);
650         RTE_SET_USED(data);
651
652         return -ENOTSUP;
653 }
654
655 int
656 rte_intr_efd_enable(struct rte_intr_handle *intr_handle, uint32_t nb_efd)
657 {
658         RTE_SET_USED(intr_handle);
659         RTE_SET_USED(nb_efd);
660
661         return 0;
662 }
663
664 void
665 rte_intr_efd_disable(struct rte_intr_handle *intr_handle)
666 {
667         RTE_SET_USED(intr_handle);
668 }
669
670 int
671 rte_intr_dp_is_en(struct rte_intr_handle *intr_handle)
672 {
673         RTE_SET_USED(intr_handle);
674         return 0;
675 }
676
677 int
678 rte_intr_allow_others(struct rte_intr_handle *intr_handle)
679 {
680         RTE_SET_USED(intr_handle);
681         return 1;
682 }
683
684 int
685 rte_intr_cap_multiple(struct rte_intr_handle *intr_handle)
686 {
687         RTE_SET_USED(intr_handle);
688         return 0;
689 }
690
691 int
692 rte_epoll_wait(int epfd, struct rte_epoll_event *events,
693                 int maxevents, int timeout)
694 {
695         RTE_SET_USED(epfd);
696         RTE_SET_USED(events);
697         RTE_SET_USED(maxevents);
698         RTE_SET_USED(timeout);
699
700         return -ENOTSUP;
701 }
702
703 int
704 rte_epoll_wait_interruptible(int epfd, struct rte_epoll_event *events,
705                              int maxevents, int timeout)
706 {
707         RTE_SET_USED(epfd);
708         RTE_SET_USED(events);
709         RTE_SET_USED(maxevents);
710         RTE_SET_USED(timeout);
711
712         return -ENOTSUP;
713 }
714
715 int
716 rte_epoll_ctl(int epfd, int op, int fd, struct rte_epoll_event *event)
717 {
718         RTE_SET_USED(epfd);
719         RTE_SET_USED(op);
720         RTE_SET_USED(fd);
721         RTE_SET_USED(event);
722
723         return -ENOTSUP;
724 }
725
726 int
727 rte_intr_tls_epfd(void)
728 {
729         return -ENOTSUP;
730 }
731
732 void
733 rte_intr_free_epoll_fd(struct rte_intr_handle *intr_handle)
734 {
735         RTE_SET_USED(intr_handle);
736 }
737
738 int rte_thread_is_intr(void)
739 {
740         return pthread_equal(intr_thread, pthread_self());
741 }