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