Lines Matching refs:sa
78 static void *fpm_get_in_addr(struct sockaddr *sa) /* {{{ */ in fpm_get_in_addr() argument
80 if (sa->sa_family == AF_INET) { in fpm_get_in_addr()
81 return &(((struct sockaddr_in*)sa)->sin_addr); in fpm_get_in_addr()
84 return &(((struct sockaddr_in6*)sa)->sin6_addr); in fpm_get_in_addr()
88 static int fpm_get_in_port(struct sockaddr *sa) /* {{{ */ in fpm_get_in_port() argument
90 if (sa->sa_family == AF_INET) { in fpm_get_in_port()
91 return ntohs(((struct sockaddr_in*)sa)->sin_port); in fpm_get_in_port()
94 return ntohs(((struct sockaddr_in6*)sa)->sin6_port); in fpm_get_in_port()
98 static int fpm_sockets_hash_op(int sock, struct sockaddr *sa, char *key, int type, int op) /* {{{ */ in fpm_sockets_hash_op() argument
104 inet_ntop(sa->sa_family, fpm_get_in_addr(sa), key, INET6_ADDRSTRLEN); in fpm_sockets_hash_op()
105 sprintf(key+strlen(key), ":%d", fpm_get_in_port(sa)); in fpm_sockets_hash_op()
110 struct sockaddr_un *sa_un = (struct sockaddr_un *) sa; in fpm_sockets_hash_op()
163 static int fpm_sockets_new_listening_socket(struct fpm_worker_pool_s *wp, struct sockaddr *sa, int … in fpm_sockets_new_listening_socket() argument
169 sock = socket(sa->sa_family, SOCK_STREAM, 0); in fpm_sockets_new_listening_socket()
181 if (fpm_socket_unix_test_connect((struct sockaddr_un *)sa, socklen) == 0) { in fpm_sockets_new_listening_socket()
182 …R, "An another FPM instance seems to already listen on %s", ((struct sockaddr_un *) sa)->sun_path); in fpm_sockets_new_listening_socket()
186 unlink( ((struct sockaddr_un *) sa)->sun_path); in fpm_sockets_new_listening_socket()
190 if (0 > bind(sock, sa, socklen)) { in fpm_sockets_new_listening_socket()
200 char *path = ((struct sockaddr_un *) sa)->sun_path; in fpm_sockets_new_listening_socket()
223 static int fpm_sockets_get_listening_socket(struct fpm_worker_pool_s *wp, struct sockaddr *sa, int … in fpm_sockets_get_listening_socket() argument
227 sock = fpm_sockets_hash_op(0, sa, 0, wp->listen_address_domain, FPM_GET_USE_SOCKET); in fpm_sockets_get_listening_socket()
232 sock = fpm_sockets_new_listening_socket(wp, sa, socklen); in fpm_sockets_get_listening_socket()
233 fpm_sockets_hash_op(sock, sa, 0, wp->listen_address_domain, FPM_STORE_USE_SOCKET); in fpm_sockets_get_listening_socket()
