Lines Matching refs:wp
166 static int fpm_sockets_new_listening_socket(struct fpm_worker_pool_s *wp, struct sockaddr *sa, int … in fpm_sockets_new_listening_socket() argument
183 if (wp->listen_address_domain == FPM_AF_UNIX) { in fpm_sockets_new_listening_socket()
190 saved_umask = umask(0777 ^ wp->socket_mode); in fpm_sockets_new_listening_socket()
194 …zlog(ZLOG_SYSERROR, "unable to bind listening socket for address '%s'", wp->config->listen_address… in fpm_sockets_new_listening_socket()
195 if (wp->listen_address_domain == FPM_AF_UNIX) { in fpm_sockets_new_listening_socket()
202 if (wp->listen_address_domain == FPM_AF_UNIX) { in fpm_sockets_new_listening_socket()
207 if (wp->socket_uid != -1 || wp->socket_gid != -1) { in fpm_sockets_new_listening_socket()
208 if (0 > chown(path, wp->socket_uid, wp->socket_gid)) { in fpm_sockets_new_listening_socket()
209 zlog(ZLOG_SYSERROR, "failed to chown() the socket '%s'", wp->config->listen_address); in fpm_sockets_new_listening_socket()
216 if (0 > listen(sock, wp->config->listen_backlog)) { in fpm_sockets_new_listening_socket()
217 zlog(ZLOG_SYSERROR, "failed to listen to address '%s'", wp->config->listen_address); in fpm_sockets_new_listening_socket()
226 static int fpm_sockets_get_listening_socket(struct fpm_worker_pool_s *wp, struct sockaddr *sa, int … in fpm_sockets_get_listening_socket() argument
230 sock = fpm_sockets_hash_op(0, sa, 0, wp->listen_address_domain, FPM_GET_USE_SOCKET); in fpm_sockets_get_listening_socket()
235 sock = fpm_sockets_new_listening_socket(wp, sa, socklen); in fpm_sockets_get_listening_socket()
236 fpm_sockets_hash_op(sock, sa, 0, wp->listen_address_domain, FPM_STORE_USE_SOCKET); in fpm_sockets_get_listening_socket()
255 static int fpm_socket_af_inet_listening_socket(struct fpm_worker_pool_s *wp) /* {{{ */ in fpm_socket_af_inet_listening_socket() argument
258 char *dup_address = strdup(wp->config->listen_address); in fpm_socket_af_inet_listening_socket()
293 …return fpm_sockets_get_listening_socket(wp, (struct sockaddr *) &sa_in, sizeof(struct sockaddr_in)… in fpm_socket_af_inet_listening_socket()
297 static int fpm_socket_af_unix_listening_socket(struct fpm_worker_pool_s *wp) /* {{{ */ in fpm_socket_af_unix_listening_socket() argument
302 strlcpy(sa_un.sun_path, wp->config->listen_address, sizeof(sa_un.sun_path)); in fpm_socket_af_unix_listening_socket()
304 …return fpm_sockets_get_listening_socket(wp, (struct sockaddr *) &sa_un, sizeof(struct sockaddr_un)… in fpm_socket_af_unix_listening_socket()
311 struct fpm_worker_pool_s *wp; in fpm_sockets_init_main() local
346 for (wp = fpm_worker_all_pools; wp; wp = wp->next) { in fpm_sockets_init_main()
347 switch (wp->listen_address_domain) { in fpm_sockets_init_main()
349 wp->listening_socket = fpm_socket_af_inet_listening_socket(wp); in fpm_sockets_init_main()
353 if (0 > fpm_unix_resolve_socket_premissions(wp)) { in fpm_sockets_init_main()
356 wp->listening_socket = fpm_socket_af_unix_listening_socket(wp); in fpm_sockets_init_main()
360 if (wp->listening_socket == -1) { in fpm_sockets_init_main()
364 …if (wp->listen_address_domain == FPM_AF_INET && fpm_socket_get_listening_queue(wp->listening_socke… in fpm_sockets_init_main()
365 … fpm_scoreboard_update(-1, -1, -1, (int)lq_len, -1, -1, FPM_SCOREBOARD_ACTION_SET, wp->scoreboard); in fpm_sockets_init_main()
