Searched refs:fdset (Results 1 – 9 of 9) sorted by relevance
| /f-stack/dpdk/lib/librte_vhost/ |
| H A D | fd_man.h | 23 struct fdset { struct
42 void fdset_init(struct fdset *pfdset); argument
44 int fdset_add(struct fdset *pfdset, int fd,
47 void *fdset_del(struct fdset *pfdset, int fd);
48 int fdset_try_del(struct fdset *pfdset, int fd);
52 int fdset_pipe_init(struct fdset *fdset);
54 void fdset_pipe_uninit(struct fdset *fdset);
56 void fdset_pipe_notify(struct fdset *fdset);
|
| H A D | fd_man.c | 104 fdset_init(struct fdset *pfdset) in fdset_init()
232 struct fdset *pfdset = arg; in fdset_event_dispatch()
330 fdset_pipe_uninit(struct fdset *fdset) in fdset_pipe_uninit() argument
332 fdset_del(fdset, fdset->u.readfd); in fdset_pipe_uninit()
333 close(fdset->u.readfd); in fdset_pipe_uninit()
334 close(fdset->u.writefd); in fdset_pipe_uninit()
338 fdset_pipe_init(struct fdset *fdset) in fdset_pipe_init() argument
348 ret = fdset_add(fdset, fdset->u.readfd, in fdset_pipe_init()
354 fdset->u.readfd); in fdset_pipe_init()
356 fdset_pipe_uninit(fdset); in fdset_pipe_init()
[all …]
|
| H A D | socket.c | 74 struct fdset fdset; member
87 .fdset = {
259 ret = fdset_add(&vhost_user.fdset, fd, vhost_user_read_cb, in vhost_user_add_connection()
276 fdset_pipe_notify(&vhost_user.fdset); in vhost_user_add_connection()
394 ret = fdset_add(&vhost_user.fdset, fd, vhost_user_server_new_connection, in vhost_user_start_server()
1037 if (fdset_try_del(&vhost_user.fdset, in rte_vhost_driver_unregister()
1061 if (fdset_try_del(&vhost_user.fdset, in rte_vhost_driver_unregister()
1137 if (fdset_pipe_init(&vhost_user.fdset) < 0) { in rte_vhost_driver_start()
1145 &vhost_user.fdset); in rte_vhost_driver_start()
1150 fdset_pipe_uninit(&vhost_user.fdset); in rte_vhost_driver_start()
|
| /f-stack/app/redis-5.0.5/src/ |
| H A D | rio.c | 178 r->io.fdset.buf = sdscatlen(r->io.fdset.buf,buf,len); in rioFdsetWrite()
185 len = sdslen(r->io.fdset.buf); in rioFdsetWrite()
220 if (r->io.fdset.state[j] == 0) r->io.fdset.state[j] = EIO; in rioFdsetWrite()
226 r->io.fdset.pos += count; in rioFdsetWrite()
243 return r->io.fdset.pos; in rioFdsetTell()
274 r->io.fdset.numfds = numfds; in rioInitWithFdset()
275 r->io.fdset.pos = 0; in rioInitWithFdset()
276 r->io.fdset.buf = sdsempty(); in rioInitWithFdset()
281 zfree(r->io.fdset.fds); in rioFreeFdset()
282 zfree(r->io.fdset.state); in rioFreeFdset()
[all …]
|
| H A D | rio.h | 83 } fdset; member
|
| H A D | rdb.c | 2329 *ids++ = slave_sockets.io.fdset.state[j]; in rdbSaveToSlavesSockets()
|
| /f-stack/app/micro_thread/ |
| H A D | kqueue_proxy.h | 243 bool KqueueAdd(KqObjList& fdset);
244 bool KqueueDel(KqObjList& fdset);
|
| H A D | micro_thread.h | 220 void AddFdList(KqObjList* fdset) { in AddFdList() argument
221 TAILQ_CONCAT(&_fdset, fdset, _entry); in AddFdList()
|
| /f-stack/dpdk/drivers/event/dpaa/ |
| H A D | dpaa_eventdev.c | 120 static void drain_4_bytes(int fd, fd_set *fdset) in drain_4_bytes() argument
122 if (FD_ISSET(fd, fdset)) { in drain_4_bytes()
|