Lines Matching refs:sa
107 static void *fpm_get_in_addr(struct sockaddr *sa) /* {{{ */ in fpm_get_in_addr() argument
109 if (sa->sa_family == AF_INET) { in fpm_get_in_addr()
110 return &(((struct sockaddr_in*)sa)->sin_addr); in fpm_get_in_addr()
113 return &(((struct sockaddr_in6*)sa)->sin6_addr); in fpm_get_in_addr()
117 static int fpm_get_in_port(struct sockaddr *sa) /* {{{ */ in fpm_get_in_port() argument
119 if (sa->sa_family == AF_INET) { in fpm_get_in_port()
120 return ntohs(((struct sockaddr_in*)sa)->sin_port); in fpm_get_in_port()
123 return ntohs(((struct sockaddr_in6*)sa)->sin6_port); in fpm_get_in_port()
127 static int fpm_sockets_hash_op(int sock, struct sockaddr *sa, char *key, int type, int op) /* {{{ */ in fpm_sockets_hash_op() argument
133 inet_ntop(sa->sa_family, fpm_get_in_addr(sa), key, INET6_ADDRSTRLEN); in fpm_sockets_hash_op()
134 sprintf(key+strlen(key), ":%d", fpm_get_in_port(sa)); in fpm_sockets_hash_op()
139 struct sockaddr_un *sa_un = (struct sockaddr_un *) sa; in fpm_sockets_hash_op()
192 static int fpm_sockets_new_listening_socket(struct fpm_worker_pool_s *wp, struct sockaddr *sa, int … in fpm_sockets_new_listening_socket() argument
198 sock = socket(sa->sa_family, SOCK_STREAM, 0); in fpm_sockets_new_listening_socket()
210 if (fpm_socket_unix_test_connect((struct sockaddr_un *)sa, socklen) == 0) { in fpm_sockets_new_listening_socket()
211 …RROR, "Another FPM instance seems to already listen on %s", ((struct sockaddr_un *) sa)->sun_path); in fpm_sockets_new_listening_socket()
215 unlink( ((struct sockaddr_un *) sa)->sun_path); in fpm_sockets_new_listening_socket()
219 if (0 > bind(sock, sa, socklen)) { in fpm_sockets_new_listening_socket()
229 char *path = ((struct sockaddr_un *) sa)->sun_path; in fpm_sockets_new_listening_socket()
249 static int fpm_sockets_get_listening_socket(struct fpm_worker_pool_s *wp, struct sockaddr *sa, int … in fpm_sockets_get_listening_socket() argument
253 sock = fpm_sockets_hash_op(0, sa, 0, wp->listen_address_domain, FPM_GET_USE_SOCKET); in fpm_sockets_get_listening_socket()
258 sock = fpm_sockets_new_listening_socket(wp, sa, socklen); in fpm_sockets_get_listening_socket()
259 fpm_sockets_hash_op(sock, sa, 0, wp->listen_address_domain, FPM_STORE_USE_SOCKET); in fpm_sockets_get_listening_socket()
