Lines Matching refs:cpfds
1258 struct curl_pollfds cpfds; local
1280 Curl_pollfds_init(&cpfds, a_few_on_stack, NUM_POLLS_ON_STACK);
1287 if(Curl_pollfds_add_ps(&cpfds, &data->last_poll)) {
1293 if(Curl_cpool_add_pollfds(&multi->cpool, &cpfds)) {
1298 curl_nfds = cpfds.n; /* what curl internally uses in cpfds */
1308 if(Curl_pollfds_add_sock(&cpfds, extra_fds[i].fd, events)) {
1316 for(i = 0; i < cpfds.n; i++) {
1318 if(cpfds.pfds[i].events & POLLIN)
1320 if(cpfds.pfds[i].events & POLLPRI)
1322 if(cpfds.pfds[i].events & POLLOUT) {
1324 reset_socket_fdwrite(cpfds.pfds[i].fd);
1327 if(WSAEventSelect(cpfds.pfds[i].fd, multi->wsa_event, mask) != 0) {
1338 if(Curl_pollfds_add_sock(&cpfds, multi->wakeup_pair[0], POLLIN)) {
1355 if(cpfds.n || use_wakeup) {
1357 if(cpfds.n) {
1361 if(cpfds.n) /* just pre-check with Winsock */
1362 pollrc = Curl_poll(cpfds.pfds, cpfds.n, 0);
1366 pollrc = Curl_poll(cpfds.pfds, cpfds.n, timeout_ms); /* wait... */
1389 unsigned r = (unsigned)cpfds.pfds[curl_nfds + i].revents;
1443 if(cpfds.pfds[curl_nfds + extra_nfds].revents & POLLIN) {
1470 if(extrawait && !cpfds.n && !use_wakeup) {
1472 if(extrawait && !cpfds.n) {
1489 Curl_pollfds_cleanup(&cpfds);
