| /lighttpd1.4/src/ |
| H A D | fdevent_fdnode.c | 22 free(fdn); in fdnode_free()
30 fdn->fd = fd; in fdevent_register()
31 fdn->ctx = ctx; in fdevent_register()
32 fdn->events = 0; in fdevent_register()
33 fdn->fde_ndx = -1; in fdevent_register()
34 return fdn; in fdevent_register()
43 fdnode_free(fdn); in fdevent_unregister()
138 if (NULL != fdn) fdevent_fdnode_event_unsetter(ev, fdn); in fdevent_fdnode_event_del()
144 if (NULL != fdn) fdevent_fdnode_event_setter(ev, fdn, events); in fdevent_fdnode_event_set()
150 if (NULL != fdn) fdevent_fdnode_event_setter(ev, fdn, (fdn->events|event)); in fdevent_fdnode_event_add()
[all …]
|
| H A D | fdevent_impl.c | 278 for (fdnode *fdn = ev->pendclose; fdn; ) { in fdevent_sched_run() local
290 fdn = (fdnode *)fdn->ctx; /* next */ in fdevent_sched_run()
325 int fd = fdn->fde_ndx = fdn->fd; in fdevent_linux_sysepoll_event_set()
344 (*fdn->handler)(fdn->ctx, revents); in fdevent_linux_sysepoll_poll()
425 int fd = fdn->fde_ndx = fdn->fd; in fdevent_freebsd_kqueue_event_set()
474 (*fdn->handler)(fdn->ctx, revents); in fdevent_freebsd_kqueue_poll()
535 int fd = fdn->fde_ndx = fdn->fd; in fdevent_solaris_port_event_set()
577 (*fdn->handler)(fdn->ctx, revents); in fdevent_solaris_port_poll()
643 pfd.fd = fdn->fde_ndx = fdn->fd; in fdevent_solaris_devpoll_event_set()
669 (*fdn->handler)(fdn->ctx, revents); in fdevent_solaris_devpoll_poll()
[all …]
|
| H A D | fdevent.h | 65 #define fdevent_fdnode_interest(fdn) (NULL != (fdn) ? (fdn)->events : 0) argument
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);
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);
|
| H A D | mod_cgi.c | 76 fdnode *fdn; member
428 fdevent_fdnode_event_del(ev, hctx->fdn); in cgi_connection_close()
430 fdevent_sched_close(ev, hctx->fdn); in cgi_connection_close()
431 hctx->fdn = NULL; in cgi_connection_close()
574 hctx->response, hctx->fdn)) { in cgi_recv_response()
976 fdevent_fdnode_event_set(ev, hctx->fdn, FDEVENT_IN | FDEVENT_RDHUP); in cgi_create_env()
1102 fdevent_fdnode_event_clr(hctx->ev, hctx->fdn, FDEVENT_IN); in SUBREQUEST_FUNC()
1103 } else if (!(fdevent_fdnode_interest(hctx->fdn) & FDEVENT_IN)) { in SUBREQUEST_FUNC()
1108 fdevent_fdnode_event_add(hctx->ev, hctx->fdn, FDEVENT_IN); in SUBREQUEST_FUNC()
1193 if (limits->read_timeout && hctx->fdn in cgi_trigger_cb()
[all …]
|
| H A D | base.h | 25 fdnode *fdn; /* fdevent (fdnode *) object */ member
132 fdnode *fdn; member
|
| H A D | network.c | 904 fdnode *fdn = srv_socket->fdn; in network_unregister_sock() local
905 if (NULL == fdn) return; in network_unregister_sock()
906 srv_socket->fdn = NULL; in network_unregister_sock()
907 fdevent_fdnode_event_del(srv->ev, fdn); in network_unregister_sock()
908 fdevent_unregister(srv->ev, fdn); in network_unregister_sock()
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 | connections.c | 92 fdevent_fdnode_event_del(srv->ev, con->fdn); in connection_close()
93 fdevent_unregister(srv->ev, con->fdn); in connection_close()
94 con->fdn = NULL; in connection_close()
625 con->fdn->handler = connection_handle_fdevent_h2; in connection_transition_h2()
917 con->fdn = fdevent_register(srv->ev, con->fd, connection_handle_fdevent, con); in connection_accepted()
1066 int events = fdevent_fdnode_interest(con->fdn); in connection_revents_err()
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()
1147 const int events = fdevent_fdnode_interest(con->fdn); in connection_set_fdevent_interest()
1166 fdevent_fdnode_event_set(con->srv->ev, con->fdn, n); in connection_set_fdevent_interest()
[all …]
|
| 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()
1805 hctx->fdn = NULL; in gw_backend_close()
1872 fdevent_fdnode_event_clr(hctx->ev, hctx->fdn, FDEVENT_OUT); in gw_conditional_tcp_fin()
1952 fdevent_fdnode_event_set(hctx->ev, hctx->fdn, FDEVENT_OUT); in gw_write_request()
1964 if (!(fdevent_fdnode_interest(hctx->fdn) & FDEVENT_OUT)) in gw_write_request()
2167 fdevent_fdnode_event_clr(hctx->ev, hctx->fdn, FDEVENT_IN); in gw_handle_subrequest()
2169 else if (!(fdevent_fdnode_interest(hctx->fdn) & FDEVENT_IN)) { in gw_handle_subrequest()
2175 fdevent_fdnode_event_add(hctx->ev, hctx->fdn, FDEVENT_IN); in gw_handle_subrequest()
2318 handler_t rc = http_response_read(r, &hctx->opts, b, hctx->fdn); in gw_recv_response()
[all …]
|
| H A D | http-header-glue.c | 1235 …read(request_st * const r, http_response_opts * const opts, buffer * const b, fdnode * const fdn) { in http_response_read() argument
1236 const int fd = fdn->fd; in http_response_read()
1275 return (fdevent_fdnode_interest(fdn) & FDEVENT_IN) in http_response_read()
1279 if (!(fdevent_fdnode_interest(fdn) & FDEVENT_IN)) { in http_response_read()
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()
|
| H A D | stat_cache.c | 239 fdnode *fdn; 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()
564 scf->fdn = NULL; in stat_cache_handle_fdevent()
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()
665 if (NULL == scf->fdn) return NULL; /* FAM connection closed; do nothing */ in fam_dir_monitor()
|
| H A D | response.h | 44 handler_t http_response_read(request_st *r, http_response_opts *opts, buffer *b, fdnode *fdn);
|
| H A D | server.c | 513 fdnode * const fdn = con->fdn; /* fdn->ctx == con */ in server_oneshot_handle_fdevent() local
514 handler_t rc = (fdn && (fdevent_handler)NULL != fdn->handler) in server_oneshot_handle_fdevent()
515 ? (*fdn->handler)(con, revents) in server_oneshot_handle_fdevent()
867 fdevent_fdnode_event_set(srv->ev, srv_socket->fdn, event); in server_sockets_set_event()
|
| H A D | gw_backend.h | 316 fdnode *fdn; /* fdevent (fdnode *) object */ member
|
| H A D | mod_fastcgi.c | 357 if (!(fdevent_fdnode_interest(hctx->fdn) & FDEVENT_IN) in fcgi_recv_0()
|
| H A D | mod_ajp13.c | 771 if (!(fdevent_fdnode_interest(hctx->fdn) & FDEVENT_IN) in ajp13_recv_0()
|
| /lighttpd1.4/ |
| H A D | NEWS | 35 * [core] pass fdn to fdevent_sched_close,_unregister
|