| /f-stack/app/micro_thread/ |
| H A D | micro_thread.cpp | 989 KqueuerObj epfd; in recvfrom() local
990 epfd.SetOsfd(fd); in recvfrom()
1055 KqueuerObj epfd; in sendto() local
1056 epfd.SetOsfd(fd); in sendto()
1106 KqueuerObj epfd; in connect() local
1152 KqueuerObj epfd; in accept() local
1198 KqueuerObj epfd; in read() local
1256 KqueuerObj epfd; in write() local
1296 KqueuerObj epfd; in recv() local
1374 KqueuerObj epfd; in send() local
[all …]
|
| /f-stack/app/redis-5.0.5/src/ |
| H A D | ae_epoll.c | 35 int epfd; member
48 state->epfd = epoll_create(1024); /* 1024 is just a hint for the kernel */ in aeApiCreate()
49 if (state->epfd == -1) { in aeApiCreate()
68 close(state->epfd); in aeApiFree()
86 if (epoll_ctl(state->epfd,op,fd,&ee) == -1) return -1; in aeApiAddEvent()
100 epoll_ctl(state->epfd,EPOLL_CTL_MOD,fd,&ee); in aeApiDelEvent()
104 epoll_ctl(state->epfd,EPOLL_CTL_DEL,fd,&ee); in aeApiDelEvent()
112 retval = epoll_wait(state->epfd,state->events,eventLoop->setsize, in aeApiPoll()
|
| /f-stack/example/ |
| H A D | main_epoll.c | 23 int epfd; variable
62 int nevents = ff_epoll_wait(epfd, events, MAX_EVENTS, 0); in loop()
77 if (ff_epoll_ctl(epfd, EPOLL_CTL_ADD, nclientfd, &ev) != 0) { in loop()
86 ff_epoll_ctl(epfd, EPOLL_CTL_DEL, events[i].data.fd, NULL); in loop()
94 ff_epoll_ctl(epfd, EPOLL_CTL_DEL, events[i].data.fd, NULL); in loop()
136 assert((epfd = ff_epoll_create(0)) > 0); in main()
139 ff_epoll_ctl(epfd, EPOLL_CTL_ADD, sockfd, &ev); in main()
|
| /f-stack/dpdk/lib/librte_eal/include/ |
| H A D | rte_eal_interrupts.h | 64 int epfd; /**< OUT: epoll instance the ev associated with */ member
114 rte_epoll_wait(int epfd, struct rte_epoll_event *events,
136 rte_epoll_wait_interruptible(int epfd, struct rte_epoll_event *events,
157 rte_epoll_ctl(int epfd, int op, int fd,
187 int epfd, int op, unsigned int vec, void *data);
|
| /f-stack/lib/ |
| H A D | ff_epoll.c | 31 ff_epoll_ctl(int epfd, int op, int fd, struct epoll_event *event) in ff_epoll_ctl() argument
57 return ff_kevent(epfd, kev, changes, NULL, 0, NULL); in ff_epoll_ctl()
103 return ff_kevent(epfd, kev, changes, NULL, 0, NULL); in ff_epoll_ctl()
148 ff_epoll_wait(int epfd, struct epoll_event *events, int maxevents, int timeout) in ff_epoll_wait() argument
156 return ff_kevent_do_each(epfd, NULL, 0, events, maxevents, NULL, ff_event_to_epoll); in ff_epoll_wait()
|
| H A D | ff_epoll.h | 11 int ff_epoll_ctl(int epfd, int op, int fd, struct epoll_event *event);
12 int ff_epoll_wait(int epfd, struct epoll_event *events, int maxevents, int timeout);
|
| /f-stack/dpdk/lib/librte_eal/linux/ |
| H A D | eal_interrupts.c | 1243 events[count].epfd = rev->epfd; in eal_epoll_process_event()
1295 if (epfd == RTE_EPOLL_PER_THREAD) in eal_epoll_wait()
1296 epfd = rte_intr_tls_epfd(); in eal_epoll_wait()
1353 ev->epfd = -1; in eal_epoll_data_safe_free()
1357 rte_epoll_ctl(int epfd, int op, int fd, in rte_epoll_ctl() argument
1368 if (epfd == RTE_EPOLL_PER_THREAD) in rte_epoll_ctl()
1369 epfd = rte_intr_tls_epfd(); in rte_epoll_ctl()
1375 event->epfd = epfd; in rte_epoll_ctl()
1380 if (epoll_ctl(epfd, op, fd, &ev) < 0) { in rte_epoll_ctl()
1432 rc = rte_epoll_ctl(epfd, epfd_op, in rte_intr_rx_ctl()
[all …]
|
| /f-stack/dpdk/drivers/vdpa/ifc/ |
| H A D | ifcvf_vdpa.c | 57 int epfd; member
447 if (epfd < 0) { in notify_relay()
451 internal->epfd = epfd; in notify_relay()
522 if (internal->epfd >= 0) in unset_notify_relay()
523 close(internal->epfd); in unset_notify_relay()
524 internal->epfd = -1; in unset_notify_relay()
728 if (epfd < 0) { in vring_relay()
732 internal->epfd = epfd; in vring_relay()
825 if (internal->epfd >= 0) in unset_vring_relay()
826 close(internal->epfd); in unset_vring_relay()
[all …]
|
| /f-stack/dpdk/lib/librte_eal/freebsd/ |
| H A D | eal_interrupts.c | 632 int epfd, int op, unsigned int vec, void *data) in rte_intr_rx_ctl() argument
635 RTE_SET_USED(epfd); in rte_intr_rx_ctl()
680 rte_epoll_wait(int epfd, struct rte_epoll_event *events, in rte_epoll_wait() argument
683 RTE_SET_USED(epfd); in rte_epoll_wait()
692 rte_epoll_wait_interruptible(int epfd, struct rte_epoll_event *events, in rte_epoll_wait_interruptible() argument
695 RTE_SET_USED(epfd); in rte_epoll_wait_interruptible()
704 rte_epoll_ctl(int epfd, int op, int fd, struct rte_epoll_event *event) in rte_epoll_ctl() argument
706 RTE_SET_USED(epfd); in rte_epoll_ctl()
|
| /f-stack/dpdk/drivers/net/failsafe/ |
| H A D | failsafe_intr.c | 269 int epfd; in failsafe_eth_rx_intr_ctl_subdevice() local
283 epfd = PRIV(fsdev)->rxp.efd; in failsafe_eth_rx_intr_ctl_subdevice()
286 if (epfd <= 0) { in failsafe_eth_rx_intr_ctl_subdevice()
301 rc = rte_eth_dev_rx_intr_ctl_q(pid, qid, epfd, in failsafe_eth_rx_intr_ctl_subdevice()
306 pid, qid, epfd, rc); in failsafe_eth_rx_intr_ctl_subdevice()
|
| /f-stack/dpdk/lib/librte_eal/windows/ |
| H A D | eal_interrupts.c | 84 __rte_unused int epfd, __rte_unused int op, in rte_intr_rx_ctl() argument
|
| /f-stack/app/nginx-1.16.1/src/event/modules/ |
| H A D | ngx_epoll_module.c | 59 int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event);
61 int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event) in epoll_ctl() argument
67 int epoll_wait(int epfd, struct epoll_event *events, int nevents, int timeout);
69 int epoll_wait(int epfd, struct epoll_event *events, int nevents, int timeout) in epoll_wait() argument
|
| /f-stack/dpdk/drivers/net/vhost/ |
| H A D | rte_eth_vhost.c | 533 int epfd, ret; in eth_vhost_update_intr() local
553 epfd = handle->elist[rxq_idx].epfd; in eth_vhost_update_intr()
555 ret = rte_epoll_ctl(epfd, EPOLL_CTL_DEL, rev.fd, in eth_vhost_update_intr()
564 ret = rte_epoll_ctl(epfd, EPOLL_CTL_ADD, rev.fd, in eth_vhost_update_intr()
|
| /f-stack/dpdk/lib/librte_bbdev/ |
| H A D | rte_bbdev.c | 1084 rte_bbdev_queue_intr_ctl(uint16_t dev_id, uint16_t queue_id, int epfd, int op, in rte_bbdev_queue_intr_ctl() argument
1108 ret = rte_intr_rx_ctl(intr_handle, epfd, op, vec, data); in rte_bbdev_queue_intr_ctl()
1112 dev_id, queue_id, op, epfd, vec); in rte_bbdev_queue_intr_ctl()
|
| H A D | rte_bbdev.h | 859 rte_bbdev_queue_intr_ctl(uint16_t dev_id, uint16_t queue_id, int epfd, int op,
|
| /f-stack/doc/ |
| H A D | F-Stack_API_Reference.md | 173 int ff_epoll_ctl(int epfd, int op, int fd, struct epoll_event *event);
175 …tem call performs control operations on the epoll(7) instance referred by the file descriptor epfd.
|
| /f-stack/dpdk/lib/librte_ethdev/ |
| H A D | rte_ethdev.h | 3580 int rte_eth_dev_rx_intr_ctl(uint16_t port_id, int epfd, int op, void *data);
3604 int epfd, int op, void *data);
|
| H A D | rte_ethdev.c | 4462 rte_eth_dev_rx_intr_ctl(uint16_t port_id, int epfd, int op, void *data) in rte_eth_dev_rx_intr_ctl() argument
4487 rc = rte_intr_rx_ctl(intr_handle, epfd, op, vec, data); in rte_eth_dev_rx_intr_ctl()
4491 port_id, qid, op, epfd, vec); in rte_eth_dev_rx_intr_ctl()
4687 int epfd, int op, void *data) in rte_eth_dev_rx_intr_ctl_q() argument
4714 rc = rte_intr_rx_ctl(intr_handle, epfd, op, vec, data); in rte_eth_dev_rx_intr_ctl_q()
4718 port_id, queue_id, op, epfd, vec); in rte_eth_dev_rx_intr_ctl_q()
|
| /f-stack/freebsd/arm/linux/ |
| H A D | linux_systrace_args.c | 1529 iarg[0] = p->epfd; /* l_int */ in systrace_args()
1539 iarg[0] = p->epfd; /* l_int */ in systrace_args()
2277 iarg[0] = p->epfd; /* l_int */ in systrace_args()
|
| H A D | linux_proto.h | 678 char epfd_l_[PADL_(l_int)]; l_int epfd; char epfd_r_[PADR_(l_int)]; member
684 char epfd_l_[PADL_(l_int)]; l_int epfd; char epfd_r_[PADR_(l_int)]; member
1108 char epfd_l_[PADL_(l_int)]; l_int epfd; char epfd_r_[PADR_(l_int)]; member
|
| /f-stack/freebsd/amd64/linux/ |
| H A D | linux_systrace_args.c | 1756 iarg[0] = p->epfd; /* l_int */ in systrace_args()
1766 iarg[0] = p->epfd; /* l_int */ in systrace_args()
2143 iarg[0] = p->epfd; /* l_int */ in systrace_args()
|
| H A D | linux_proto.h | 813 char epfd_l_[PADL_(l_int)]; l_int epfd; char epfd_r_[PADR_(l_int)]; member
819 char epfd_l_[PADL_(l_int)]; l_int epfd; char epfd_r_[PADR_(l_int)]; member
1042 char epfd_l_[PADL_(l_int)]; l_int epfd; char epfd_r_[PADR_(l_int)]; member
|
| /f-stack/freebsd/amd64/linux32/ |
| H A D | linux32_systrace_args.c | 1762 iarg[0] = p->epfd; /* l_int */ in systrace_args()
1772 iarg[0] = p->epfd; /* l_int */ in systrace_args()
2267 iarg[0] = p->epfd; /* l_int */ in systrace_args()
|
| /f-stack/freebsd/i386/linux/ |
| H A D | linux_systrace_args.c | 1807 iarg[0] = p->epfd; /* l_int */ in systrace_args()
1817 iarg[0] = p->epfd; /* l_int */ in systrace_args()
2308 iarg[0] = p->epfd; /* l_int */ in systrace_args()
|
| /f-stack/freebsd/arm64/linux/ |
| H A D | linux_systrace_args.c | 160 iarg[0] = p->epfd; /* l_int */ in systrace_args()
170 iarg[0] = p->epfd; /* l_int */ in systrace_args()
|