Lines Matching refs:worker_pool

1362   if (NULL != daemon->worker_pool)  in internal_add_connection()
1369 worker = &daemon->worker_pool[(i + client_socket) % daemon->worker_pool_size]; in internal_add_connection()
3077 if (NULL != daemon->worker_pool) in MHD_quiesce_daemon()
3080 daemon->worker_pool[i].socket_fd = MHD_INVALID_SOCKET; in MHD_quiesce_daemon()
3083 (-1 != daemon->worker_pool[i].epoll_fd) && in MHD_quiesce_daemon()
3084 (MHD_YES == daemon->worker_pool[i].listen_socket_in_epoll) ) in MHD_quiesce_daemon()
3086 if (0 != epoll_ctl (daemon->worker_pool[i].epoll_fd, in MHD_quiesce_daemon()
3091 daemon->worker_pool[i].listen_socket_in_epoll = MHD_NO; in MHD_quiesce_daemon()
4182 daemon->worker_pool = malloc (sizeof (struct MHD_Daemon) in MHD_start_daemon_va()
4184 if (NULL == daemon->worker_pool) in MHD_start_daemon_va()
4191 struct MHD_Daemon *d = &daemon->worker_pool[i]; in MHD_start_daemon_va()
4199 d->worker_pool = NULL; in MHD_start_daemon_va()
4285 if (NULL != daemon->worker_pool) in MHD_start_daemon_va()
4286 free (daemon->worker_pool); in MHD_start_daemon_va()
4442 if (NULL != daemon->worker_pool) in MHD_stop_daemon()
4447 daemon->worker_pool[i].shutdown = MHD_YES; in MHD_stop_daemon()
4448 daemon->worker_pool[i].socket_fd = MHD_INVALID_SOCKET; in MHD_stop_daemon()
4451 (-1 != daemon->worker_pool[i].epoll_fd) && in MHD_stop_daemon()
4453 epoll_shutdown (&daemon->worker_pool[i]); in MHD_stop_daemon()
4486 if (NULL != daemon->worker_pool) in MHD_stop_daemon()
4491 if (MHD_INVALID_PIPE_ != daemon->worker_pool[i].wpipe[1]) in MHD_stop_daemon()
4493 if (1 != MHD_pipe_write_ (daemon->worker_pool[i].wpipe[1], "e", 1)) in MHD_stop_daemon()
4496 if (0 != MHD_join_thread_ (daemon->worker_pool[i].pid)) in MHD_stop_daemon()
4498 close_all_connections (&daemon->worker_pool[i]); in MHD_stop_daemon()
4499 (void) MHD_mutex_destroy_ (&daemon->worker_pool[i].cleanup_connection_mutex); in MHD_stop_daemon()
4501 if ( (-1 != daemon->worker_pool[i].epoll_fd) && in MHD_stop_daemon()
4502 (0 != MHD_socket_close_ (daemon->worker_pool[i].epoll_fd)) ) in MHD_stop_daemon()
4507 if (MHD_INVALID_PIPE_ != daemon->worker_pool[i].wpipe[1]) in MHD_stop_daemon()
4509 if (0 != MHD_pipe_close_ (daemon->worker_pool[i].wpipe[0])) in MHD_stop_daemon()
4511 if (0 != MHD_pipe_close_ (daemon->worker_pool[i].wpipe[1])) in MHD_stop_daemon()
4516 free (daemon->worker_pool); in MHD_stop_daemon()
4598 if (daemon->worker_pool) in MHD_get_daemon_info()
4606 MHD_cleanup_connections (&daemon->worker_pool[i]); in MHD_get_daemon_info()
4607 daemon->connections += daemon->worker_pool[i].connections; in MHD_get_daemon_info()