Lines Matching refs:wp
204 static int fpm_sockets_new_listening_socket(struct fpm_worker_pool_s *wp, struct sockaddr *sa, int … in fpm_sockets_new_listening_socket() argument
221 if (wp->listen_address_domain == FPM_AF_UNIX) { in fpm_sockets_new_listening_socket()
228 saved_umask = umask(0777 ^ wp->socket_mode); in fpm_sockets_new_listening_socket()
232 …zlog(ZLOG_SYSERROR, "unable to bind listening socket for address '%s'", wp->config->listen_address… in fpm_sockets_new_listening_socket()
233 if (wp->listen_address_domain == FPM_AF_UNIX) { in fpm_sockets_new_listening_socket()
240 if (wp->listen_address_domain == FPM_AF_UNIX) { in fpm_sockets_new_listening_socket()
245 if (0 > fpm_unix_set_socket_permissions(wp, path)) { in fpm_sockets_new_listening_socket()
251 if (0 > listen(sock, wp->config->listen_backlog)) { in fpm_sockets_new_listening_socket()
252 zlog(ZLOG_SYSERROR, "failed to listen to address '%s'", wp->config->listen_address); in fpm_sockets_new_listening_socket()
258 if (-1 < wp->config->listen_setfib) { in fpm_sockets_new_listening_socket()
259 if (routemax < wp->config->listen_setfib) { in fpm_sockets_new_listening_socket()
260 zlog(ZLOG_ERROR, "Invalid routing table id %d, max is %d", wp->config->listen_setfib, routemax); in fpm_sockets_new_listening_socket()
265 …if (0 > setsockopt(sock, SOL_SOCKET, SO_SETFIB, &wp->config->listen_setfib, sizeof(wp->config->lis… in fpm_sockets_new_listening_socket()
275 static int fpm_sockets_get_listening_socket(struct fpm_worker_pool_s *wp, struct sockaddr *sa, int … in fpm_sockets_get_listening_socket() argument
279 sock = fpm_sockets_hash_op(0, sa, 0, wp->listen_address_domain, FPM_GET_USE_SOCKET); in fpm_sockets_get_listening_socket()
284 sock = fpm_sockets_new_listening_socket(wp, sa, socklen); in fpm_sockets_get_listening_socket()
285 fpm_sockets_hash_op(sock, sa, 0, wp->listen_address_domain, FPM_STORE_USE_SOCKET); in fpm_sockets_get_listening_socket()
304 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
323 if ((sock = fpm_sockets_get_listening_socket(wp, p->ai_addr, p->ai_addrlen)) != -1) { in fpm_socket_af_inet_socket_by_addr()
337 static int fpm_socket_af_inet_listening_socket(struct fpm_worker_pool_s *wp) /* {{{ */ in fpm_socket_af_inet_listening_socket() argument
339 char *dup_address = strdup(wp->config->listen_address); in fpm_socket_af_inet_listening_socket()
371 sock = fpm_socket_af_inet_socket_by_addr(wp, addr, port_str); in fpm_socket_af_inet_listening_socket()
381 sock = fpm_socket_af_inet_socket_by_addr(wp, "::", port_str); in fpm_socket_af_inet_listening_socket()
386 sock = fpm_socket_af_inet_socket_by_addr(wp, "0.0.0.0", port_str); in fpm_socket_af_inet_listening_socket()
396 static int fpm_socket_af_unix_listening_socket(struct fpm_worker_pool_s *wp) /* {{{ */ in fpm_socket_af_unix_listening_socket() argument
400 size_t address_length = strlen(wp->config->listen_address); in fpm_socket_af_unix_listening_socket()
403 strlcpy(sa_un.sun_path, wp->config->listen_address, socket_length); in fpm_socket_af_unix_listening_socket()
410 wp->config->name, in fpm_socket_af_unix_listening_socket()
411 wp->config->listen_address, in fpm_socket_af_unix_listening_socket()
419 …return fpm_sockets_get_listening_socket(wp, (struct sockaddr *) &sa_un, sizeof(struct sockaddr_un)… in fpm_socket_af_unix_listening_socket()
440 struct fpm_worker_pool_s *wp; in fpm_sockets_init_main() local
497 for (wp = fpm_worker_all_pools; wp; wp = wp->next) { in fpm_sockets_init_main()
498 switch (wp->listen_address_domain) { in fpm_sockets_init_main()
500 wp->listening_socket = fpm_socket_af_inet_listening_socket(wp); in fpm_sockets_init_main()
504 if (0 > fpm_unix_resolve_socket_permissions(wp)) { in fpm_sockets_init_main()
507 wp->listening_socket = fpm_socket_af_unix_listening_socket(wp); in fpm_sockets_init_main()
511 if (wp->listening_socket == -1) { in fpm_sockets_init_main()
515 …if (wp->listen_address_domain == FPM_AF_INET && fpm_socket_get_listening_queue(wp->listening_socke… in fpm_sockets_init_main()
516 …fpm_scoreboard_update(-1, -1, -1, (int)lq_len, -1, -1, 0, FPM_SCOREBOARD_ACTION_SET, wp->scoreboar… in fpm_sockets_init_main()
