| /lighttpd1.4/src/ |
| H A D | fdevent_impl.c | 189 ev = ck_calloc(1, sizeof(*ev)); in fdevent_init()
247 if (ev->free) ev->free(ev); in fdevent_free()
264 int rc = (NULL != ev->reset) ? ev->reset(ev) : 0; in fdevent_reset()
302 const int n = ev->poll(ev, ev->pendclose ? 0 : timeout_ms); in fdevent_poll()
383 ev->epoll_events = ck_calloc(ev->maxfds, sizeof(*ev->epoll_events)); in fdevent_linux_sysepoll_init()
514 ev->kq_results = ck_calloc(ev->maxfds, sizeof(*ev->kq_results)); in fdevent_freebsd_kqueue_init()
613 ev->port_events = ck_calloc(ev->maxfds, sizeof(*ev->port_events)); in fdevent_solaris_port_init()
713 ev->devpollfds = ck_calloc(ev->maxfds, sizeof(*ev->devpollfds)); in fdevent_solaris_devpoll_init()
746 ev->unused.ptr[ev->unused.used++] = k; in fdevent_poll_event_del()
772 if (ev->size == ev->used) { in fdevent_poll_event_set()
[all …]
|
| H A D | fdevent_fdnode.c | 28 fdnode *fdn = ev->fdarray[fd] = fdnode_init(); in fdevent_register()
38 fdevent_unregister (fdevents *ev, fdnode *fdn) in fdevent_unregister() argument
40 fdnode **fdn_slot = &ev->fdarray[fdn->fd]; in fdevent_unregister()
47 fdevent_sched_close (fdevents *ev, fdnode *fdn) in fdevent_sched_close() argument
49 fdnode **fdn_slot = &ev->fdarray[fdn->fd]; in fdevent_sched_close()
53 fdn->ctx = ev->pendclose; in fdevent_sched_close()
54 ev->pendclose = fdn; in fdevent_sched_close()
80 } while (0 != ev->event_del(ev, fdn)); in fdevent_fdnode_event_unsetter_retry()
88 if (0 != ev->event_del(ev, fdn)) in fdevent_fdnode_event_unsetter()
117 } while (0 != ev->event_set(ev, fdn, events)); in fdevent_fdnode_event_setter_retry()
[all …]
|
| H A D | fdevent.h | 57 int fdevent_reset(fdevents *ev); /* "init" after fork() */
60 void fdevent_free(fdevents *ev);
66 void fdevent_fdnode_event_del(fdevents *ev, fdnode *fdn);
67 void fdevent_fdnode_event_set(fdevents *ev, fdnode *fdn, int events);
68 void fdevent_fdnode_event_add(fdevents *ev, fdnode *fdn, int event);
69 void fdevent_fdnode_event_clr(fdevents *ev, fdnode *fdn, int event);
71 int fdevent_poll(fdevents *ev, int timeout_ms);
74 fdnode * fdevent_register(fdevents *ev, int fd, fdevent_handler handler, void *ctx);
76 void fdevent_unregister(fdevents *ev, fdnode *fdn);
77 void fdevent_sched_close(fdevents *ev, fdnode *fdn);
|
| H A D | fdevent_impl.h | 79 int (*event_set)(struct fdevents *ev, fdnode *fdn, int events);
80 int (*event_del)(struct fdevents *ev, fdnode *fdn);
81 int (*poll)(struct fdevents *ev, int timeout_ms);
122 int (*reset)(struct fdevents *ev);
123 void (*free)(struct fdevents *ev);
|
| H A D | mod_cgi.c | 81 struct fdevents *ev; /* dumb pointer */ member
410 struct fdevents * const ev = hctx->ev; in cgi_connection_close_fdtocgi() local
411 fdevent_fdnode_event_del(ev, hctx->fdntocgi); in cgi_connection_close_fdtocgi()
413 fdevent_sched_close(ev, hctx->fdntocgi); in cgi_connection_close_fdtocgi()
426 struct fdevents * const ev = hctx->ev; in cgi_connection_close() local
428 fdevent_fdnode_event_del(ev, hctx->fdn); in cgi_connection_close()
430 fdevent_sched_close(ev, hctx->fdn); in cgi_connection_close()
734 struct fdevents * const ev = hctx->ev; in cgi_write_request() local
741 fdevent_fdnode_event_set(ev, hctx->fdntocgi, 0); in cgi_write_request()
968 struct fdevents * const ev = hctx->ev; in cgi_create_env() local
[all …]
|
| H A D | server.c | 395 fdevent_fdnode_event_del(srv->ev, oneshot_fdn); in server_free()
396 fdevent_unregister(srv->ev, oneshot_fdn); in server_free()
410 fdevent_free(srv->ev); in server_free()
489 fdevent_fdnode_event_set(con->srv->ev, oneshot_fdn, n); in server_oneshot_read_cq()
511 fdevent_fdnode_event_set(con->srv->ev, oneshot_fdn, n); in server_oneshot_handle_fdevent()
606 fdevent_register(srv->ev, fdin, server_oneshot_handle_fdevent, con); in server_oneshot_init_pipe()
607 fdevent_fdnode_event_set(srv->ev, oneshot_fdn, FDEVENT_RDHUP); in server_oneshot_init_pipe()
867 fdevent_fdnode_event_set(srv->ev, srv_socket->fdn, event); in server_sockets_set_event()
1750 if (NULL == srv->ev) { in server_main_setup()
1785 if (!stat_cache_init(srv->ev, srv->errh)) { in server_main_setup()
[all …]
|
| H A D | stat_cache.c | 238 fdevents *ev; member
562 fdevent_fdnode_event_del(scf->ev, scf->fdn); in stat_cache_handle_fdevent()
563 fdevent_unregister(scf->ev, scf->fdn); in stat_cache_handle_fdevent()
573 static stat_cache_fam * stat_cache_init_fam(fdevents *ev, log_error_st *errh) { in stat_cache_init_fam() argument
576 scf->ev = ev; in stat_cache_init_fam()
628 scf->fdn = fdevent_register(scf->ev, scf->fd, stat_cache_handle_fdevent, scf); in stat_cache_init_fam()
629 fdevent_fdnode_event_set(scf->ev, scf->fdn, FDEVENT_IN | FDEVENT_RDHUP); in stat_cache_init_fam()
871 int stat_cache_init(fdevents *ev, log_error_st *errh) { in stat_cache_init() argument
874 sc.scf = stat_cache_init_fam(ev, errh); in stat_cache_init()
878 UNUSED(ev); in stat_cache_init()
|
| H A D | gw_backend.c | 1802 fdevent_fdnode_event_del(hctx->ev, hctx->fdn); in gw_backend_close()
1804 fdevent_sched_close(hctx->ev, hctx->fdn); in gw_backend_close()
1872 fdevent_fdnode_event_clr(hctx->ev, hctx->fdn, FDEVENT_OUT); in gw_conditional_tcp_fin()
1941 hctx->fdn = fdevent_register(hctx->ev,hctx->fd,gw_handle_fdevent,hctx); in gw_write_request()
1952 fdevent_fdnode_event_set(hctx->ev, hctx->fdn, FDEVENT_OUT); in gw_write_request()
2046 fdevent_fdnode_event_clr(hctx->ev, hctx->fdn, FDEVENT_OUT); in gw_write_request()
2061 fdevent_fdnode_event_clr(hctx->ev, hctx->fdn, FDEVENT_OUT); in gw_write_request()
2065 fdevent_fdnode_event_add(hctx->ev, hctx->fdn, FDEVENT_OUT); in gw_write_request()
2167 fdevent_fdnode_event_clr(hctx->ev, hctx->fdn, FDEVENT_IN); in gw_handle_subrequest()
2175 fdevent_fdnode_event_add(hctx->ev, hctx->fdn, FDEVENT_IN); in gw_handle_subrequest()
[all …]
|
| H A D | network.c | 907 fdevent_fdnode_event_del(srv->ev, fdn); in network_unregister_sock()
908 fdevent_unregister(srv->ev, fdn); in network_unregister_sock()
912 if (-1 == fdevent_reset(srv->ev)) { in network_register_fdevents()
922 …srv_socket->fdn = fdevent_register(srv->ev, srv_socket->fd, network_server_handle_fdevent, srv_soc… in network_register_fdevents()
923 fdevent_fdnode_event_set(srv->ev, srv_socket->fdn, FDEVENT_IN); in network_register_fdevents()
|
| H A D | stat_cache.h | 33 int stat_cache_init(struct fdevents *ev, log_error_st *errh);
|
| H A D | base.h | 147 struct fdevents *ev; member
|
| H A D | connections.c | 92 fdevent_fdnode_event_del(srv->ev, con->fdn); in connection_close()
93 fdevent_unregister(srv->ev, con->fdn); in connection_close()
917 con->fdn = fdevent_register(srv->ev, con->fd, connection_handle_fdevent, con); in connection_accepted()
1077 fdevent_fdnode_event_set(con->srv->ev, con->fdn, events); in connection_revents_err()
1090 fdevent_fdnode_event_set(con->srv->ev, con->fdn, events); in connection_revents_err()
1166 fdevent_fdnode_event_set(con->srv->ev, con->fdn, n); in connection_set_fdevent_interest()
|
| H A D | gw_backend.h | 315 struct fdevents *ev; member
|
| H A D | http-header-glue.c | 1302 fdevent_fdnode_event_clr(r->con->srv->ev, fdn, FDEVENT_IN); in http_response_read()
1425 fdevent_fdnode_event_clr(r->con->srv->ev, fdn, FDEVENT_IN); in http_response_read()
|