Lines Matching refs:rfds
2929 static __thread struct pollfd *rfds; in rs_fds_alloc() local
2933 if (rfds) in rs_fds_alloc()
2934 free(rfds); in rs_fds_alloc()
2936 rfds = malloc(sizeof(*rfds) * nfds); in rs_fds_alloc()
2937 rnfds = rfds ? nfds : 0; in rs_fds_alloc()
2940 return rfds; in rs_fds_alloc()
3028 static int rs_poll_arm(struct pollfd *rfds, struct pollfd *fds, nfds_t nfds) in rs_poll_arm() argument
3042 rfds[i].fd = rs->cm_id->recv_cq_channel->fd; in rs_poll_arm()
3044 rfds[i].fd = rs->cm_id->channel->fd; in rs_poll_arm()
3046 rfds[i].fd = rs->epfd; in rs_poll_arm()
3048 rfds[i].events = POLLIN; in rs_poll_arm()
3050 rfds[i].fd = fds[i].fd; in rs_poll_arm()
3051 rfds[i].events = fds[i].events; in rs_poll_arm()
3053 rfds[i].revents = 0; in rs_poll_arm()
3058 static int rs_poll_events(struct pollfd *rfds, struct pollfd *fds, nfds_t nfds) in rs_poll_events() argument
3064 if (!rfds[i].revents) in rs_poll_events()
3077 fds[i].revents = rfds[i].revents; in rs_poll_events()
3094 struct pollfd *rfds; in rpoll() local
3111 rfds = rs_fds_alloc(nfds); in rpoll()
3112 if (!rfds) in rpoll()
3116 ret = rs_poll_arm(rfds, fds, nfds); in rpoll()
3120 ret = poll(rfds, nfds, timeout); in rpoll()
3124 ret = rs_poll_events(rfds, fds, nfds); in rpoll()