/PHP-5.4/sapi/fpm/fpm/ |
H A D | fpm_events.c | 36 #define fpm_event_set_timeout(ev, now) timeradd(&(now), &(ev)->frequency, &(ev)->timeout); argument 60 int fd = ev->fd; in fpm_got_signal() 128 if (!ev) { in fpm_event_queue_isset() 133 if (queue->ev == ev) { in fpm_event_queue_isset() 134 return ev; in fpm_event_queue_isset() 161 elt->ev = ev; in fpm_event_queue_add() 186 if (q->ev == ev) { in fpm_event_queue_del() 463 if (!ev || !ev->callback) { in fpm_event_fire() 467 (*ev->callback)( (struct fpm_event_s *) ev, ev->which, ev->arg); in fpm_event_fire() 477 ev->fd = fd; in fpm_event_set() [all …]
|
H A D | fpm_events.h | 13 #define fpm_event_set_timer(ev, flags, cb, arg) fpm_event_set((ev), -1, (flags), (cb), (arg)) argument 29 struct fpm_event_s *ev; member 38 int (*add)(struct fpm_event_s *ev); 39 int (*remove)(struct fpm_event_s *ev); 43 void fpm_event_fire(struct fpm_event_s *ev); 45 int fpm_event_set(struct fpm_event_s *ev, int fd, int flags, void (*callback)(struct fpm_event_s *,… 46 int fpm_event_add(struct fpm_event_s *ev, unsigned long int timeout); 47 int fpm_event_del(struct fpm_event_s *ev);
|
H A D | fpm_process_ctl.h | 24 void fpm_pctl_heartbeat(struct fpm_event_s *ev, short which, void *arg); 25 void fpm_pctl_perform_idle_server_maintenance_heartbeat(struct fpm_event_s *ev, short which, void *… 26 void fpm_pctl_on_socket_accept(struct fpm_event_s *ev, short which, void *arg);
|
H A D | fpm_systemd.h | 9 void fpm_systemd_heartbeat(struct fpm_event_s *ev, short which, void *arg);
|
H A D | fpm_process_ctl.c | 54 static void fpm_pctl_action(struct fpm_event_s *ev, short which, void *arg) /* {{{ */ in fpm_pctl_action() argument 441 void fpm_pctl_heartbeat(struct fpm_event_s *ev, short which, void *arg) /* {{{ */ in fpm_pctl_heartbeat() argument 466 void fpm_pctl_perform_idle_server_maintenance_heartbeat(struct fpm_event_s *ev, short which, void *… in fpm_pctl_perform_idle_server_maintenance_heartbeat() argument 496 void fpm_pctl_on_socket_accept(struct fpm_event_s *ev, short which, void *arg) /* {{{ */ in fpm_pctl_on_socket_accept() argument
|
H A D | fpm_systemd.c | 48 void fpm_systemd_heartbeat(struct fpm_event_s *ev, short which, void *arg) /* {{{ */ in fpm_systemd_heartbeat() argument
|
H A D | fpm_stdio.c | 86 static void fpm_stdio_child_said(struct fpm_event_s *ev, short which, void *arg) /* {{{ */ in fpm_stdio_child_said() argument 89 int fd = ev->fd; in fpm_stdio_child_said()
|
/PHP-5.4/sapi/fpm/fpm/events/ |
H A D | poll.c | 161 …if (q->ev && q->ev->index >= 0 && q->ev->index < npollfds && q->ev->fd == active_pollfds[q->ev->in… in fpm_event_poll_wait() 167 fpm_event_fire(q->ev); in fpm_event_poll_wait() 197 ev->index = next_free_slot++; in fpm_event_poll_add() 212 pollfds[i].fd = ev->fd; in fpm_event_poll_add() 216 ev->index = next_free_slot++; in fpm_event_poll_add() 236 if (ev->index >= 0 && ev->index < npollfds && pollfds[ev->index].fd == ev->fd) { in fpm_event_poll_remove() 238 next_free_slot = ev->index; in fpm_event_poll_remove() 241 pollfds[ev->index].fd = -1; in fpm_event_poll_remove() 242 pollfds[ev->index].events = 0; in fpm_event_poll_remove() 245 ev->index = -1; in fpm_event_poll_remove() [all …]
|
H A D | select.c | 40 static int fpm_event_select_add(struct fpm_event_s *ev); 117 if (q->ev) { /* sanity check */ in fpm_event_select_wait() 120 if (FD_ISSET(q->ev->fd, ¤t_fds)) { in fpm_event_select_wait() 123 fpm_event_fire(q->ev); in fpm_event_select_wait() 145 if (ev->fd >= FD_SETSIZE) { in fpm_event_select_add() 151 if (!FD_ISSET(ev->fd, &fds)) { in fpm_event_select_add() 152 FD_SET(ev->fd, &fds); in fpm_event_select_add() 153 ev->index = ev->fd; in fpm_event_select_add() 166 if (FD_ISSET(ev->fd, &fds)) { in fpm_event_select_remove() 167 FD_CLR(ev->fd, &fds); in fpm_event_select_remove() [all …]
|
H A D | epoll.c | 34 static int fpm_event_epoll_add(struct fpm_event_s *ev); 35 static int fpm_event_epoll_remove(struct fpm_event_s *ev); 168 e.data.fd = ev->fd; in fpm_event_epoll_add() 169 e.data.ptr = (void *)ev; in fpm_event_epoll_add() 171 if (ev->flags & FPM_EV_EDGE) { in fpm_event_epoll_add() 177 zlog(ZLOG_ERROR, "epoll: unable to add fd %d", ev->fd); in fpm_event_epoll_add() 182 ev->index = ev->fd; in fpm_event_epoll_add() 196 e.data.fd = ev->fd; in fpm_event_epoll_remove() 197 e.data.ptr = (void *)ev; in fpm_event_epoll_remove() 199 if (ev->flags & FPM_EV_EDGE) { in fpm_event_epoll_remove() [all …]
|
H A D | kqueue.c | 37 static int fpm_event_kqueue_add(struct fpm_event_s *ev); 38 static int fpm_event_kqueue_remove(struct fpm_event_s *ev); 145 struct fpm_event_s *ev = (struct fpm_event_s *)kevents[i].udata; in fpm_event_kqueue_wait() local 146 fpm_event_fire(ev); in fpm_event_kqueue_wait() 161 static int fpm_event_kqueue_add(struct fpm_event_s *ev) /* {{{ */ in fpm_event_kqueue_add() argument 166 if (ev->flags & FPM_EV_EDGE) { in fpm_event_kqueue_add() 170 EV_SET(&k, ev->fd, EVFILT_READ, flags, 0, 0, (void *)ev); in fpm_event_kqueue_add() 178 ev->index = ev->fd; in fpm_event_kqueue_add() 191 if (ev->flags & FPM_EV_EDGE) { in fpm_event_kqueue_remove() 195 EV_SET(&k, ev->fd, EVFILT_READ, flags, 0, 0, (void *)ev); in fpm_event_kqueue_remove() [all …]
|
H A D | devpoll.c | 38 static int fpm_event_devpoll_add(struct fpm_event_s *ev); 39 static int fpm_event_devpoll_remove(struct fpm_event_s *ev); 179 if (q->ev && q->ev->fd == active_pollfds[i].fd) { in fpm_event_devpoll_wait() 182 fpm_event_fire(q->ev); in fpm_event_devpoll_wait() 201 static int fpm_event_devpoll_add(struct fpm_event_s *ev) /* {{{ */ in fpm_event_devpoll_add() argument 206 pollfd.fd = ev->fd; in fpm_event_devpoll_add() 217 ev->index = ev->fd; in fpm_event_devpoll_add() 226 static int fpm_event_devpoll_remove(struct fpm_event_s *ev) /* {{{ */ in fpm_event_devpoll_remove() argument 231 pollfd.fd = ev->fd; in fpm_event_devpoll_remove() 242 ev->index = -1; in fpm_event_devpoll_remove()
|
H A D | port.c | 35 static int fpm_event_port_add(struct fpm_event_s *ev); 36 static int fpm_event_port_remove(struct fpm_event_s *ev); 160 static int fpm_event_port_add(struct fpm_event_s *ev) /* {{{ */ in fpm_event_port_add() argument 163 if (port_associate(pfd, PORT_SOURCE_FD, ev->fd, POLLIN, (void *)ev) < 0) { in fpm_event_port_add() 174 static int fpm_event_port_remove(struct fpm_event_s *ev) /* {{{ */ in fpm_event_port_remove() argument 177 if (port_dissociate(pfd, PORT_SOURCE_FD, ev->fd) < 0) { in fpm_event_port_remove()
|
/PHP-5.4/ext/com_dotnet/ |
H A D | com_iterator.c | 34 IEnumVARIANT *ev; member 48 if (I->ev) { in com_iter_dtor() 49 IEnumVARIANT_Release(I->ev); in com_iter_dtor() 103 if (I->ev) { in com_iter_move_forwards() 105 if (SUCCEEDED(IEnumVARIANT_Next(I->ev, 1, &I->v, &n_fetched)) && n_fetched > 0) { in com_iter_move_forwards() 225 I->ev = iev; in php_com_iter_get() 228 if (SUCCEEDED(IEnumVARIANT_Next(I->ev, 1, &I->v, &n_fetched)) && n_fetched > 0) { in php_com_iter_get()
|