Home
last modified time | relevance | path

Searched refs:events (Results 1 – 25 of 25) sorted by relevance

/curl/lib/
H A Dselect.c377 if(ufds[i].events & POLLIN) in Curl_poll()
448 cpfds->pfds[i].events |= events; in cpfds_add_sock()
459 cpfds->pfds[cpfds->n].events = events; in cpfds_add_sock()
478 short events = 0; in Curl_pollfds_add_ps() local
480 events |= POLLIN; in Curl_pollfds_add_ps()
482 events |= POLLOUT; in Curl_pollfds_add_ps()
483 if(events) { in Curl_pollfds_add_ps()
510 cwfds->wfds[i].events |= events; in cwfds_add_sock()
519 cwfds->wfds[cwfds->n].events = events; in cwfds_add_sock()
532 short events = 0; in Curl_waitfds_add_ps() local
[all …]
H A Dselect.h53 short events; member
131 curl_socket_t sock, short events);
H A Deasy.c386 struct events { struct
405 struct events *ev = userp; in events_timer() argument
460 struct events *ev = userp; in events_socket()
488 m->socket.events = socketcb2poll(what); in events_socket()
512 m->socket.events = socketcb2poll(what); in events_socket()
533 static void events_setup(struct Curl_multi *multi, struct events *ev) in events_setup()
550 static CURLcode wait_or_timeout(struct Curl_multi *multi, struct events *ev) in wait_or_timeout()
569 f->events = m->socket.events; in wait_or_timeout()
677 static struct events evs = {-1, FALSE, 0, NULL, 0}; in easy_events()
743 static CURLcode easy_perform(struct Curl_easy *data, bool events) in easy_perform() argument
[all …]
H A Dsocketpair.c190 pfd[0].events = POLLIN; in Curl_socketpair()
213 pfd[0].events = POLLIN; in Curl_socketpair()
H A Dasyn-ares.c327 pfd[i].events = 0; in waitperform()
331 pfd[i].events |= POLLRDNORM|POLLIN; in waitperform()
335 pfd[i].events |= POLLWRNORM|POLLOUT; in waitperform()
337 if(pfd[i].events) in waitperform()
H A Dtelnet.c1264 pfd[0].events = POLLOUT; in send_telnet_data()
1305 WSANETWORKEVENTS events; in telnet_do() local
1454 events.lNetworkEvents = 0; in telnet_do()
1455 if(WSAEnumNetworkEvents(sockfd, event_handle, &events) == SOCKET_ERROR) { in telnet_do()
1464 if(events.lNetworkEvents & FD_READ) { in telnet_do()
1496 if(events.lNetworkEvents & FD_CLOSE) { in telnet_do()
1520 pfd[0].events = POLLIN; in telnet_do()
1529 pfd[1].events = POLLIN; in telnet_do()
H A Dcfilters.c584 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 Dmulti.c1301 unsigned short events = 0; local
1302 if(extra_fds[i].events & CURL_WAIT_POLLIN)
1303 events |= POLLIN;
1304 if(extra_fds[i].events & CURL_WAIT_POLLPRI)
1305 events |= POLLPRI;
1306 if(extra_fds[i].events & CURL_WAIT_POLLOUT)
1307 events |= POLLOUT;
1308 if(Curl_pollfds_add_sock(&cpfds, extra_fds[i].fd, events)) {
1318 if(cpfds.pfds[i].events & POLLIN)
1320 if(cpfds.pfds[i].events & POLLPRI)
[all …]
H A Dcf-socket.c1696 pfd[0].events = POLLRDNORM|POLLIN|POLLRDBAND|POLLPRI; in cf_socket_conn_is_alive()
/curl/docs/examples/
H A Dmulti-uv.c141 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 Dephiperfifo.c285 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 Dmulti-event.c143 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 Dcurl_multi_wait.md46 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 Dcurl_multi_poll.md47 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 Dcurl_multi_socket_action.md37 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 Dcurl_global_trace.md84 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 Dlib677.c73 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 Dtest129449 …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 Dtest50658 # don't run this with the threaded-resolver or c-ares since the events might
/curl/.github/workflows/
H A Dcodeql-analysis.yml47 security-events: write
/curl/include/curl/
H A Dmulti.h116 short events; member
/curl/src/
H A Dtool_operate.c2519 static void on_uv_socket(uv_poll_t *req, int status, int events) in on_uv_socket() argument
2524 if(events & UV_READABLE) in on_uv_socket()
2526 if(events & UV_WRITABLE) in on_uv_socket()
2600 int events = 0; in cb_socket() local
2613 events |= UV_WRITABLE; in cb_socket()
2615 events |= UV_READABLE; in cb_socket()
2617 uv_poll_start(&c->poll_handle, events, on_uv_socket); in cb_socket()
/curl/docs/
H A DTODO513 The multi_socket API should work with edge-triggered socket events. One of
H A DFAQ781 different set of events.
/curl/packages/OS400/
H A Dcurl.inc.in2327 d events 5i 0

Completed in 63 milliseconds