Lines Matching refs:wp
200 static int fpm_sockets_new_listening_socket(struct fpm_worker_pool_s *wp, struct sockaddr *sa, int … in fpm_sockets_new_listening_socket() argument
217 if (wp->listen_address_domain == FPM_AF_UNIX) { in fpm_sockets_new_listening_socket()
224 saved_umask = umask(0777 ^ wp->socket_mode); in fpm_sockets_new_listening_socket()
228 …zlog(ZLOG_SYSERROR, "unable to bind listening socket for address '%s'", wp->config->listen_address… in fpm_sockets_new_listening_socket()
229 if (wp->listen_address_domain == FPM_AF_UNIX) { in fpm_sockets_new_listening_socket()
236 if (wp->listen_address_domain == FPM_AF_UNIX) { in fpm_sockets_new_listening_socket()
241 if (0 > fpm_unix_set_socket_premissions(wp, path)) { in fpm_sockets_new_listening_socket()
247 if (0 > listen(sock, wp->config->listen_backlog)) { in fpm_sockets_new_listening_socket()
248 zlog(ZLOG_SYSERROR, "failed to listen to address '%s'", wp->config->listen_address); in fpm_sockets_new_listening_socket()
257 static int fpm_sockets_get_listening_socket(struct fpm_worker_pool_s *wp, struct sockaddr *sa, int … in fpm_sockets_get_listening_socket() argument
261 sock = fpm_sockets_hash_op(0, sa, 0, wp->listen_address_domain, FPM_GET_USE_SOCKET); in fpm_sockets_get_listening_socket()
266 sock = fpm_sockets_new_listening_socket(wp, sa, socklen); in fpm_sockets_get_listening_socket()
267 fpm_sockets_hash_op(sock, sa, 0, wp->listen_address_domain, FPM_STORE_USE_SOCKET); in fpm_sockets_get_listening_socket()
286 static int fpm_socket_af_inet_socket_by_addr(struct fpm_worker_pool_s *wp, const char *addr, const … in fpm_socket_af_inet_socket_by_addr() argument
305 if ((sock = fpm_sockets_get_listening_socket(wp, p->ai_addr, p->ai_addrlen)) != -1) { in fpm_socket_af_inet_socket_by_addr()
319 static int fpm_socket_af_inet_listening_socket(struct fpm_worker_pool_s *wp) /* {{{ */ in fpm_socket_af_inet_listening_socket() argument
321 char *dup_address = strdup(wp->config->listen_address); in fpm_socket_af_inet_listening_socket()
353 sock = fpm_socket_af_inet_socket_by_addr(wp, addr, port_str); in fpm_socket_af_inet_listening_socket()
363 sock = fpm_socket_af_inet_socket_by_addr(wp, "::", port_str); in fpm_socket_af_inet_listening_socket()
368 sock = fpm_socket_af_inet_socket_by_addr(wp, "0.0.0.0", port_str); in fpm_socket_af_inet_listening_socket()
378 static int fpm_socket_af_unix_listening_socket(struct fpm_worker_pool_s *wp) /* {{{ */ in fpm_socket_af_unix_listening_socket() argument
383 strlcpy(sa_un.sun_path, wp->config->listen_address, sizeof(sa_un.sun_path)); in fpm_socket_af_unix_listening_socket()
385 …return fpm_sockets_get_listening_socket(wp, (struct sockaddr *) &sa_un, sizeof(struct sockaddr_un)… in fpm_socket_af_unix_listening_socket()
392 struct fpm_worker_pool_s *wp; in fpm_sockets_init_main() local
443 for (wp = fpm_worker_all_pools; wp; wp = wp->next) { in fpm_sockets_init_main()
444 switch (wp->listen_address_domain) { in fpm_sockets_init_main()
446 wp->listening_socket = fpm_socket_af_inet_listening_socket(wp); in fpm_sockets_init_main()
450 if (0 > fpm_unix_resolve_socket_premissions(wp)) { in fpm_sockets_init_main()
453 wp->listening_socket = fpm_socket_af_unix_listening_socket(wp); in fpm_sockets_init_main()
457 if (wp->listening_socket == -1) { in fpm_sockets_init_main()
461 …if (wp->listen_address_domain == FPM_AF_INET && fpm_socket_get_listening_queue(wp->listening_socke… in fpm_sockets_init_main()
462 …fpm_scoreboard_update(-1, -1, -1, (int)lq_len, -1, -1, 0, FPM_SCOREBOARD_ACTION_SET, wp->scoreboar… in fpm_sockets_init_main()
