Lines Matching refs:poller
186 php_cli_server_poller poller; member
827 static int php_cli_server_poller_ctor(php_cli_server_poller *poller) /* {{{ */ in php_cli_server_poller_ctor() argument
829 FD_ZERO(&poller->rfds); in php_cli_server_poller_ctor()
830 FD_ZERO(&poller->wfds); in php_cli_server_poller_ctor()
831 poller->max_fd = -1; in php_cli_server_poller_ctor()
835 static void php_cli_server_poller_add(php_cli_server_poller *poller, int mode, php_socket_t fd) /* … in php_cli_server_poller_add() argument
838 PHP_SAFE_FD_SET(fd, &poller->rfds); in php_cli_server_poller_add()
841 PHP_SAFE_FD_SET(fd, &poller->wfds); in php_cli_server_poller_add()
843 if (fd > poller->max_fd) { in php_cli_server_poller_add()
844 poller->max_fd = fd; in php_cli_server_poller_add()
848 static void php_cli_server_poller_remove(php_cli_server_poller *poller, int mode, php_socket_t fd) … in php_cli_server_poller_remove() argument
851 PHP_SAFE_FD_CLR(fd, &poller->rfds); in php_cli_server_poller_remove()
854 PHP_SAFE_FD_CLR(fd, &poller->wfds); in php_cli_server_poller_remove()
857 if (fd == poller->max_fd) { in php_cli_server_poller_remove()
860 if (PHP_SAFE_FD_ISSET(fd, &poller->rfds) || PHP_SAFE_FD_ISSET(fd, &poller->wfds)) { in php_cli_server_poller_remove()
864 poller->max_fd = fd; in php_cli_server_poller_remove()
869 static int php_cli_server_poller_poll(php_cli_server_poller *poller, struct timeval *tv) /* {{{ */ in php_cli_server_poller_poll() argument
871 memmove(&poller->active.rfds, &poller->rfds, sizeof(poller->rfds)); in php_cli_server_poller_poll()
872 memmove(&poller->active.wfds, &poller->wfds, sizeof(poller->wfds)); in php_cli_server_poller_poll()
873 return php_select(poller->max_fd + 1, &poller->active.rfds, &poller->active.wfds, NULL, tv); in php_cli_server_poller_poll()
876 static int php_cli_server_poller_iter_on_active(php_cli_server_poller *poller, void *opaque, int(*c… in php_cli_server_poller_iter_on_active() argument
887 for (i = 0; i < poller->active.rfds.fd_count; i++) { in php_cli_server_poller_iter_on_active()
889 n->fd = poller->active.rfds.fd_array[i]; in php_cli_server_poller_iter_on_active()
894 for (i = 0; i < poller->active.wfds.fd_count; i++) { in php_cli_server_poller_iter_on_active()
896 SOCKET fd = poller->active.wfds.fd_array[i]; in php_cli_server_poller_iter_on_active()
921 const php_socket_t max_fd = poller->max_fd; in php_cli_server_poller_iter_on_active()
924 if (PHP_SAFE_FD_ISSET(fd, &poller->active.rfds)) { in php_cli_server_poller_iter_on_active()
929 if (PHP_SAFE_FD_ISSET(fd, &poller->active.wfds)) { in php_cli_server_poller_iter_on_active()
2078 php_cli_server_poller_add(&server->poller, POLLOUT, client->sock); in php_cli_server_send_error_page()
2178 php_cli_server_poller_add(&server->poller, POLLOUT, client->sock); in php_cli_server_begin_send_static()
2375 php_cli_server_poller_remove(&p->server->poller, POLLIN | POLLOUT, p->sock); in php_cli_server_client_dtor_wrapper()
2440 err = php_cli_server_poller_ctor(&server->poller); in php_cli_server_ctor()
2445 php_cli_server_poller_add(&server->poller, POLLIN, server_sock); in php_cli_server_ctor()
2520 php_cli_server_poller_remove(&server->poller, POLLIN, client->sock); in php_cli_server_recv_event_read_request()
2523 php_cli_server_poller_add(&server->poller, POLLIN, client->sock); in php_cli_server_recv_event_read_request()
2602 php_cli_server_poller_add(&server->poller, POLLIN, client->sock); in php_cli_server_do_event_for_each_fd_callback()
2625 …php_cli_server_poller_iter_on_active(&server->poller, ¶ms, php_cli_server_do_event_for_each_fd… in php_cli_server_do_event_for_each_fd()
2633 int n = php_cli_server_poller_poll(&server->poller, &tv); in php_cli_server_do_event_loop()
