Home
last modified time | relevance | path

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

1234

/libevent-2.1.12/
H A Devmap.c82 evutil_socket_t fd; member
107 return e1->fd == e2->fd; in eqsocket()
284 if (fd < 0) in evmap_io_add_()
321 (int)fd); in evmap_io_add_()
362 if (fd < 0) in evmap_io_del_()
427 if (fd < 0 || fd >= io->nentries) in evmap_io_active_()
557 fd = (*mapent)->fd;
559 for (fd = 0; fd < iomap->nentries; ++fd) {
745 EVUTIL_ASSERT(c->fd == fd);
856 change->fd = fd;
[all …]
H A Dbufferevent_sock.c108 evutil_socket_t fd) in bufferevent_socket_set_conn_address_fd_() argument
116 getpeername(fd, addr, &len); in bufferevent_socket_set_conn_address_fd_()
385 evutil_socket_t fd; in bufferevent_socket_connect() local
392 fd = bufferevent_getfd(bev); in bufferevent_socket_connect()
393 if (fd < 0) { in bufferevent_socket_connect()
398 if (fd < 0) in bufferevent_socket_connect()
427 bufferevent_setfd(bev, fd); in bufferevent_socket_connect()
450 evutil_closesocket(fd); in bufferevent_socket_connect()
599 evutil_socket_t fd; in be_socket_destruct() local
605 EVUTIL_CLOSESOCKET(fd); in be_socket_destruct()
[all …]
H A Depoll.c193 int fd; in epoll_init() local
198 epev.data.fd = epollop->timerfd; in epoll_init()
202 close(fd); in epoll_init()
288 epev.data.fd = ch->fd; in epoll_apply_one_change()
304 (int)epev.events, ch->fd); in epoll_apply_one_change()
309 ch->fd)); in epoll_apply_one_change()
325 (int)epev.events, ch->fd); in epoll_apply_one_change()
330 ch->fd)); in epoll_apply_one_change()
342 ch->fd, in epoll_apply_one_change()
379 ch.fd = fd; in epoll_nochangelist_add()
[all …]
H A Dlistener.c96 evutil_socket_t fd; member
159 evutil_socket_t fd) in evconnlistener_new() argument
169 backlog, fd); in evconnlistener_new()
216 evutil_socket_t fd; in evconnlistener_new_bind() local
228 if (fd == -1) in evconnlistener_new_bind()
336 evutil_socket_t fd; in evconnlistener_get_fd() local
340 return fd; in evconnlistener_get_fd()
562 (char *)&as->lev->fd, sizeof(&as->lev->fd)); in start_accepting()
649 (char *)&as->lev->fd, sizeof(&as->lev->fd)); in accepted_socket_invoke_user_cb()
790 return lev_iocp->fd; in iocp_listener_getfd()
[all …]
H A Devport.c239 fd, sysevents, fdip) == -1) { in reassociate()
290 const int fd = epdp->ed_pending[i]; in evport_dispatch() local
291 if (fd != -1) { in evport_dispatch()
294 fdi = evmap_io_get_fdinfo_(&base->io, fd); in evport_dispatch()
298 reassociate(epdp, fdi, fd); in evport_dispatch()
327 int fd = (int) pevt->portev_object; in evport_dispatch() local
333 epdp->ed_pending[i] = fd; in evport_dispatch()
356 evmap_io_active_(base, fd, res); in evport_dispatch()
388 return reassociate(evpd, fdi, fd); in evport_add()
419 return (reassociate(evpd, fdi, fd)); in evport_del()
[all …]
H A Devutil.c112 int fd; in evutil_open_closeonexec_() local
117 return fd; in evutil_open_closeonexec_()
121 if (fd < 0) in evutil_open_closeonexec_()
126 close(fd); in evutil_open_closeonexec_()
131 return fd; in evutil_open_closeonexec_()
148 int fd, r; in evutil_read_file_() local
189 close(fd); in evutil_read_file_()
245 if (!fd) { in evutil_ersatz_socketpair_()
2695 fd[0] = fd[1] = -1; in evutil_make_internal_pipe_()
2716 fd[0] = fd[1] = -1; in evutil_make_internal_pipe_()
[all …]
H A Dbufferevent_async.c397 evutil_socket_t fd; in be_async_destruct() local
405 fd = evbuffer_overlapped_get_fd_(bev->input); in be_async_destruct()
406 if (fd != (evutil_socket_t)EVUTIL_INVALID_SOCKET && in be_async_destruct()
408 evutil_closesocket(fd); in be_async_destruct()
419 evutil_socket_t fd; in bev_async_set_wsa_error() local
421 fd = evbuffer_overlapped_get_fd_(bev->input); in bev_async_set_wsa_error()
544 evutil_socket_t fd, int options) in bufferevent_async_new_() argument
555 if (fd >= 0 && event_iocp_port_associate_(iocp, fd, 1)<0) { in bufferevent_async_new_()
587 bev_a->ok = fd >= 0; in bufferevent_async_new_()
686 bev_a->ok = data->fd >= 0; in be_async_ctrl()
[all …]
H A Ddevpoll.c65 static int devpoll_add(struct event_base *, int fd, short old, short events, void *);
66 static int devpoll_del(struct event_base *, int fd, short old, short events, void *);
100 devpoll_queue(struct devpollop *devpollop, int fd, int events) { in devpoll_queue() argument
113 pfd->fd = fd; in devpoll_queue()
220 evmap_io_active_(base, events[i].fd, which); in devpoll_dispatch()
228 devpoll_add(struct event_base *base, int fd, short old, short events, void *p) in devpoll_add() argument
247 if (devpoll_queue(devpollop, fd, res) != 0) in devpoll_add()
254 devpoll_del(struct event_base *base, int fd, short old, short events, void *p) in devpoll_del() argument
273 if (devpoll_queue(devpollop, fd, POLLREMOVE) != 0) in devpoll_del()
284 devpoll_queue(devpollop, fd, POLLOUT); in devpoll_del()
[all …]
H A Dbufferevent_openssl.c979 return fd; in be_openssl_auto_fd()
1092 if (fd < 0) in set_handshake_callbacks()
1113 if (fd >= 0) in set_handshake_callbacks()
1238 fd = BIO_get_fd(bio, NULL); in be_openssl_destruct()
1239 if (fd >= 0) in be_openssl_destruct()
1240 evutil_closesocket(fd); in be_openssl_destruct()
1345 evutil_socket_t fd, in bufferevent_openssl_new_impl() argument
1390 fd = be_openssl_auto_fd(bev_ssl, fd); in bufferevent_openssl_new_impl()
1442 evutil_socket_t fd, in bufferevent_openssl_socket_new() argument
1456 if (fd < 0) { in bufferevent_openssl_socket_new()
[all …]
H A Darc4random.c129 read_all(int fd, unsigned char *buf, size_t count) in read_all() argument
135 result = read(fd, buf+numread, count-numread); in read_all()
254 int fd; in arc4_seed_proc_sys_kernel_random_uuid() local
260 if (fd < 0) in arc4_seed_proc_sys_kernel_random_uuid()
262 n = read(fd, buf, sizeof(buf)); in arc4_seed_proc_sys_kernel_random_uuid()
263 close(fd); in arc4_seed_proc_sys_kernel_random_uuid()
296 int fd; in arc4_seed_urandom_helper_() local
299 fd = evutil_open_closeonexec_(fname, O_RDONLY, 0); in arc4_seed_urandom_helper_()
300 if (fd<0) in arc4_seed_urandom_helper_()
302 n = read_all(fd, buf, sizeof(buf)); in arc4_seed_urandom_helper_()
[all …]
H A Dselect.c252 select_add(struct event_base *base, int fd, short old, short events, void *p) in select_add() argument
263 if (sop->event_fds < fd) { in select_add()
272 while (fdsz < (int) SELECT_ALLOC_SIZE(fd + 1)) in select_add()
282 sop->event_fds = fd; in select_add()
286 FD_SET(fd, sop->event_readset_in); in select_add()
288 FD_SET(fd, sop->event_writeset_in); in select_add()
299 select_del(struct event_base *base, int fd, short old, short events, void *p) in select_del() argument
307 if (sop->event_fds < fd) { in select_del()
313 FD_CLR(fd, sop->event_readset_in); in select_del()
316 FD_CLR(fd, sop->event_writeset_in); in select_del()
H A Dbuffer_iocp.c57 evutil_socket_t fd; member
153 evbuffer_overlapped_new_(evutil_socket_t fd) in evbuffer_overlapped_new_() argument
166 evo->fd = fd; in evbuffer_overlapped_new_()
226 if (WSASend(buf_o->fd, buf_o->buffers, i, &bytesSent, 0, in evbuffer_launch_write_()
292 if (WSARecv(buf_o->fd, buf_o->buffers, nvecs, &bytesRead, &flags, in evbuffer_launch_read_()
315 return buf_o ? buf_o->fd : -1; in evbuffer_overlapped_get_fd_()
319 evbuffer_overlapped_set_fd_(struct evbuffer *buf, evutil_socket_t fd) in evbuffer_overlapped_set_fd_() argument
325 buf_o->fd = fd; in evbuffer_overlapped_set_fd_()
H A Devmap-internal.h62 int evmap_io_add_(struct event_base *base, evutil_socket_t fd, struct event *ev);
71 int evmap_io_del_(struct event_base *base, evutil_socket_t fd, struct event *ev);
78 void evmap_io_active_(struct event_base *base, evutil_socket_t fd, short events);
91 void *evmap_io_get_fdinfo_(struct event_io_map *ctx, evutil_socket_t fd);
H A Diocp-internal.h118 struct evbuffer *evbuffer_overlapped_new_(evutil_socket_t fd);
123 void evbuffer_overlapped_set_fd_(struct evbuffer *buf, evutil_socket_t fd);
172 int event_iocp_port_associate_(struct event_iocp_port *port, evutil_socket_t fd,
203 evutil_socket_t fd, int options);
208 int bufferevent_async_connect_(struct bufferevent *bev, evutil_socket_t fd,
H A Dpoll.c124 EVUTIL_ASSERT(pop->event_set[idx].fd == i); in poll_check_ok()
128 EVUTIL_ASSERT(pop->idxplus1_by_fd[pfd->fd] == i+1); in poll_check_ok()
223 evmap_io_active_(base, event_set[i].fd, res); in poll_dispatch()
230 poll_add(struct event_base *base, int fd, short old, short events, void *idx_) in poll_add() argument
272 pfd->fd = fd; in poll_add()
293 poll_del(struct event_base *base, int fd, short old, short events, void *idx_) in poll_del() argument
333 idx = evmap_io_get_fdinfo_(&base->io, pop->event_set[i].fd); in poll_del()
H A Dhttp.c1350 if (evcon->fd == -1) in evhttp_connection_reset_()
1360 evcon->fd = -1; in evhttp_connection_reset_()
1484 if (evcon->fd == -1) in evhttp_error_cb()
2300 evutil_socket_t fd = evcon->fd; in evhttp_read_header() local
2391 evcon->fd = -1; in evhttp_connection_base_bufferevent_new()
3561 evutil_socket_t fd; in evhttp_bind_socket_with_handle() local
3619 fd); in evhttp_accept_socket_with_handle()
4268 evcon->fd = fd; in evhttp_get_request_connection()
4402 if (fd == -1) { in create_bind_socket_nonblock()
4420 return (fd); in create_bind_socket_nonblock()
[all …]
H A Dchangelist-internal.h55 evutil_socket_t fd; member
96 int event_changelist_add_(struct event_base *base, evutil_socket_t fd, short old, short events,
99 int event_changelist_del_(struct event_base *base, evutil_socket_t fd, short old, short events,
/libevent-2.1.12/cmake/
H A DCheckWorkingKqueue.cmake17 int fd[2];
22 if (pipe(fd) == -1)
24 if (fcntl(fd[1], F_SETFL, O_NONBLOCK) == -1)
27 while ((n = write(fd[1], buf, sizeof(buf))) == sizeof(buf))
34 ev.ident = fd[1];
41 read(fd[0], buf, sizeof(buf));
/libevent-2.1.12/test/
H A Dregress_http.c187 evutil_socket_t fd; in http_connect() local
201 if (fd == -1) in http_connect()
219 return (fd); in http_connect()
763 if (fd >= 0) in http_bad_request_test()
846 if (fd >= 0) in http_delete_test()
927 if (fd >= 0) in http_on_complete_test()
2260 if (fd >= 0) in http_failure_test()
3156 if (fd >= 0) in http_incomplete_test_()
3956 if (fd >= 0) in http_multi_line_header_test()
4337 terminate_state.fd = fd; in http_terminate_chunked_test_impl()
[all …]
H A Dregress.c95 #define write(fd,buf,len) send((fd),(buf),(int)(len),0) argument
96 #define read(fd,buf,len) recv((fd),(buf),(int)(len),0) argument
273 len = write(fd, buf, len); in combined_write_cb()
1911 (void) fd; (void) what; in incr_arg_cb()
1917 (void) fd; (void) what; in remove_timers_cb()
1924 (void) fd; (void) what; in send_a_byte_cb()
1939 (void) fd; (void) what; in read_not_timeout_cb()
1940 n = read(fd, &c, 1); in read_not_timeout_cb()
2960 int fd, dfd=-1; in test_dup_fd() local
2965 fd = data->pair[1]; in test_dup_fd()
[all …]
H A Dregress_main.c136 int fd; in regress_make_tmpfile() local
142 fd = mkstemp(tmpfilename); in regress_make_tmpfile()
143 if (fd == -1) in regress_make_tmpfile()
145 if (write(fd, data, datalen) != (int)datalen) { in regress_make_tmpfile()
146 close(fd); in regress_make_tmpfile()
149 lseek(fd, 0, SEEK_SET); in regress_make_tmpfile()
152 return (fd); in regress_make_tmpfile()
H A Dbench_cascade.c67 read_cb(evutil_socket_t fd, short which, void *arg) in read_cb() argument
72 (void) recv(fd, &ch, sizeof(ch), 0); in read_cb()
110 evutil_socket_t fd = i < num_pipes - 1 ? cp[3] : -1; in run_once() local
112 (void *)(ev_intptr_t)fd); in run_once()
H A Dtest-fdleak.c126 evutil_socket_t fd; in start_loop() local
141 fd = evconnlistener_get_fd(listener); in start_loop()
142 if (fd < 0) { in start_loop()
146 if (getsockname(fd, (struct sockaddr *)&ss, &socklen) < 0) { in start_loop()
/libevent-2.1.12/sample/
H A Devent-read-fifo.c34 fifo_read(evutil_socket_t fd, short event, void *arg) in fifo_read() argument
44 (int)fd, event, arg); in fifo_read()
46 len = ReadFile((HANDLE)fd, buf, sizeof(buf) - 1, &dwBytesRead, NULL); in fifo_read()
57 len = read(fd, buf, sizeof(buf) - 1); in fifo_read()
77 signal_cb(evutil_socket_t fd, short event, void *arg) in signal_cb() argument
H A Dhttp-server.c192 int fd = -1; in send_document_cb() local
313 if ((fd = open(whole_path, O_RDONLY)) < 0) { in send_document_cb()
318 if (fstat(fd, &st)<0) { in send_document_cb()
326 evbuffer_add_file(evb, fd, 0, st.st_size); in send_document_cb()
333 if (fd>=0) in send_document_cb()
334 close(fd); in send_document_cb()
398 evutil_socket_t fd; in display_listen_sock() local
405 fd = evhttp_bound_socket_get_fd(handle); in display_listen_sock()
407 if (getsockname(fd, (struct sockaddr *)&ss, &socklen)) { in display_listen_sock()

1234