Home
last modified time | relevance | path

Searched refs:ev (Results 1 – 14 of 14) sorted by relevance

/PHP-5.5/sapi/fpm/fpm/
H A Dfpm_events.c36 #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 Dfpm_events.h13 #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 Dfpm_process_ctl.h24 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 Dfpm_systemd.h9 void fpm_systemd_heartbeat(struct fpm_event_s *ev, short which, void *arg);
H A Dfpm_process_ctl.c54 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 Dfpm_systemd.c48 void fpm_systemd_heartbeat(struct fpm_event_s *ev, short which, void *arg) /* {{{ */ in fpm_systemd_heartbeat() argument
H A Dfpm_stdio.c86 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.5/sapi/fpm/fpm/events/
H A Dpoll.c161 …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 Dselect.c40 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, &current_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 Depoll.c34 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 Dkqueue.c37 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 Ddevpoll.c38 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 Dport.c35 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.5/ext/com_dotnet/
H A Dcom_iterator.c34 IEnumVARIANT *ev; member
48 if (I->ev) { in com_iter_dtor()
49 IEnumVARIANT_Release(I->ev); in com_iter_dtor()
102 if (I->ev) { in com_iter_move_forwards()
104 if (SUCCEEDED(IEnumVARIANT_Next(I->ev, 1, &I->v, &n_fetched)) && n_fetched > 0) { in com_iter_move_forwards()
224 I->ev = iev; in php_com_iter_get()
227 if (SUCCEEDED(IEnumVARIANT_Next(I->ev, 1, &I->v, &n_fetched)) && n_fetched > 0) { in php_com_iter_get()

Completed in 20 milliseconds