/curl/lib/ |
H A D | select.c | 385 if(ufds[i].events & POLLIN) in Curl_poll() 456 cpfds->pfds[i].events |= events; in cpfds_add_sock() 467 cpfds->pfds[cpfds->n].events = events; in cpfds_add_sock() 486 short events = 0; in Curl_pollfds_add_ps() local 488 events |= POLLIN; in Curl_pollfds_add_ps() 490 events |= POLLOUT; in Curl_pollfds_add_ps() 491 if(events) { in Curl_pollfds_add_ps() 518 cwfds->wfds[i].events |= events; in cwfds_add_sock() 527 cwfds->wfds[cwfds->n].events = events; in cwfds_add_sock() 540 short events = 0; in Curl_waitfds_add_ps() local [all …]
|
H A D | select.h | 53 short events; member 131 curl_socket_t sock, short events);
|
H A D | easy.c | 386 struct events { struct 405 struct events *ev = userp; in events_timer() argument 460 struct events *ev = userp; in events_socket() 487 m->socket.events = socketcb2poll(what); in events_socket() 511 m->socket.events = socketcb2poll(what); in events_socket() 532 static void events_setup(struct Curl_multi *multi, struct events *ev) in events_setup() 549 static CURLcode wait_or_timeout(struct Curl_multi *multi, struct events *ev) in wait_or_timeout() 568 f->events = m->socket.events; in wait_or_timeout() 676 static struct events evs = {-1, FALSE, 0, NULL, 0}; in easy_events() 742 static CURLcode easy_perform(struct Curl_easy *data, bool events) in easy_perform() argument [all …]
|
H A D | socketpair.c | 190 pfd[0].events = POLLIN; in Curl_socketpair() 213 pfd[0].events = POLLIN; in Curl_socketpair()
|
H A D | asyn-ares.c | 336 pfd[i].events = 0; in waitperform() 340 pfd[i].events |= POLLRDNORM|POLLIN; in waitperform() 344 pfd[i].events |= POLLWRNORM|POLLOUT; in waitperform() 346 if(pfd[i].events) in waitperform()
|
H A D | telnet.c | 1270 pfd[0].events = POLLOUT; in send_telnet_data() 1311 WSANETWORKEVENTS events; in telnet_do() local 1460 events.lNetworkEvents = 0; in telnet_do() 1461 if(WSAEnumNetworkEvents(sockfd, event_handle, &events) == SOCKET_ERROR) { in telnet_do() 1470 if(events.lNetworkEvents & FD_READ) { in telnet_do() 1502 if(events.lNetworkEvents & FD_CLOSE) { in telnet_do() 1526 pfd[0].events = POLLIN; in telnet_do() 1535 pfd[1].events = POLLIN; in telnet_do()
|
H A D | cfilters.c | 584 short events = 0; in Curl_conn_cf_poll() local 586 events |= POLLIN; in Curl_conn_cf_poll() 589 events |= POLLOUT; in Curl_conn_cf_poll() 591 if(events) { in Curl_conn_cf_poll() 593 pfds[npfds].events = events; in Curl_conn_cf_poll()
|
H A D | multi.c | 1290 unsigned short events = 0; local 1291 if(extra_fds[i].events & CURL_WAIT_POLLIN) 1292 events |= POLLIN; 1293 if(extra_fds[i].events & CURL_WAIT_POLLPRI) 1294 events |= POLLPRI; 1295 if(extra_fds[i].events & CURL_WAIT_POLLOUT) 1296 events |= POLLOUT; 1297 if(Curl_pollfds_add_sock(&cpfds, extra_fds[i].fd, events)) { 1307 if(cpfds.pfds[i].events & POLLIN) 1309 if(cpfds.pfds[i].events & POLLPRI) [all …]
|
H A D | cf-socket.c | 1693 pfd[0].events = POLLRDNORM|POLLIN|POLLRDBAND|POLLPRI; in cf_socket_conn_is_alive()
|
/curl/docs/examples/ |
H A D | multi-uv.c | 141 static void on_uv_socket(uv_poll_t *req, int status, int events) in on_uv_socket() argument 147 if(events & UV_READABLE) in on_uv_socket() 149 if(events & UV_WRITABLE) in on_uv_socket() 192 int events = 0; in cb_socket() local 205 events |= UV_WRITABLE; in cb_socket() 207 events |= UV_READABLE; in cb_socket() 209 uv_poll_start(&curl_context->poll_handle, events, on_uv_socket); in cb_socket()
|
H A D | ephiperfifo.c | 285 ev.events = kind; in setsock() 442 epev.events = EPOLLIN; in init_fifo() 470 struct epoll_event events[10]; in main() local 495 ev.events = EPOLLIN; in main() 515 int err = epoll_wait(g.epfd, events, in main() 516 sizeof(events)/sizeof(struct epoll_event), 10000); in main() 529 if(events[idx].data.fd == g.fifofd) { in main() 530 fifo_cb(&g, events[idx].events); in main() 532 else if(events[idx].data.fd == g.tfd) { in main() 533 timer_cb(&g, events[idx].events); in main() [all …]
|
H A D | multi-event.c | 143 static void on_timeout(evutil_socket_t fd, short events, void *arg) in on_timeout() argument 172 int events = 0; in handle_socket() local 184 events |= EV_WRITE; in handle_socket() 186 events |= EV_READ; in handle_socket() 188 events |= EV_PERSIST; in handle_socket() 191 event_assign(curl_context->event, base, curl_context->sockfd, events, in handle_socket()
|
/curl/docs/libcurl/ |
H A D | curl_multi_wait.md | 46 number of file descriptors on which interesting events occurred. This number 63 short events; 70 Bit flag to *curl_waitfd.events* indicating the socket should poll on read 71 events such as new data received. 75 Bit flag to *curl_waitfd.events* indicating the socket should poll on high 76 priority read events such as out of band data. 80 Bit flag to *curl_waitfd.events* indicating the socket should poll on 81 write events such as the socket being clear to write without blocking.
|
H A D | curl_multi_poll.md | 47 number of file descriptors on which interesting events occurred. This number 70 short events; 77 Bit flag to curl_waitfd.events indicating the socket should poll on read 78 events such as new data received. 82 Bit flag to curl_waitfd.events indicating the socket should poll on high 83 priority read events such as out of band data. 87 Bit flag to curl_waitfd.events indicating the socket should poll on write 88 events such as the socket being clear to write without blocking. 116 myown.events = CURL_WAIT_POLLIN; /* wait for input */
|
H A D | curl_multi_socket_action.md | 37 set to the socket with the action. When the events on a socket are known, they 38 can be passed as an events bitmask **ev_bitmask** by first setting 40 events to be chosen from CURL_CSELECT_IN, CURL_CSELECT_OUT or 41 CURL_CSELECT_ERR. When the events on a socket are unknown, pass 0 instead, and
|
H A D | curl_global_trace.md | 84 Details about HTTP/2 handling: frames, events, I/O, etc. 88 Details about HTTP/3 handling: connect, frames, events, I/O etc.
|
/curl/tests/libtest/ |
H A D | lib677.c | 73 waitfd.events = state ? CURL_WAIT_POLLIN : CURL_WAIT_POLLOUT; in test() 80 if((sock != CURL_SOCKET_BAD) && (waitfd.revents & waitfd.events)) { in test()
|
/curl/tests/data/ |
H A D | test1294 | 49 …possible consequence to the reader, in this stage of the business at all events; the item of morta… 61 …possible consequence to the reader, in this stage of the business at all events; the item of morta…
|
H A D | test506 | 58 # don't run this with the threaded-resolver or c-ares since the events might
|
/curl/.github/workflows/ |
H A D | codeql-analysis.yml | 47 security-events: write
|
/curl/include/curl/ |
H A D | multi.h | 120 short events; member
|
/curl/src/ |
H A D | tool_operate.c | 2585 static void on_uv_socket(uv_poll_t *req, int status, int events) in on_uv_socket() argument 2590 if(events & UV_READABLE) in on_uv_socket() 2592 if(events & UV_WRITABLE) in on_uv_socket() 2666 int events = 0; in cb_socket() local 2679 events |= UV_WRITABLE; in cb_socket() 2681 events |= UV_READABLE; in cb_socket() 2683 uv_poll_start(&c->poll_handle, events, on_uv_socket); in cb_socket()
|
/curl/docs/ |
H A D | TODO | 513 The multi_socket API should work with edge-triggered socket events. One of
|
H A D | FAQ | 781 different set of events.
|
/curl/packages/OS400/ |
H A D | curl.inc.in | 2327 d events 5i 0
|