--- mqtt/src/utils.c 2012/04/11 15:08:27 1.2.2.1 +++ mqtt/src/utils.c 2012/04/15 21:44:33 1.2.2.2 @@ -8,9 +8,7 @@ srv_Socket(cfg_root_t * __restrict cfg) struct hostent *host; ait_val_t v; u_short port; - struct sockaddr_storage ss; - struct sockaddr_in *sin = (struct sockaddr_in*) &ss; - struct sockaddr_in6 *sin6 = (struct sockaddr_in6*) &ss; + io_sockaddr_t sa; ioTRACE(2); @@ -22,39 +20,39 @@ srv_Socket(cfg_root_t * __restrict cfg) host = gethostbyname(AIT_GET_STR(&v)); AIT_FREE_VAL(&v); if (!host) { - printf("Error:: resolver #%d - %s\n", h_errno, hstrerror(h_errno)); + ioERROR(h_errno, "%s", hstrerror(h_errno)); return -1; } switch (host->h_addrtype) { case AF_INET: - sin->sin_len = sizeof(struct sockaddr_in); - sin->sin_family = AF_INET; - sin->sin_port = htons(port); - memcpy(&sin->sin_addr, host->h_addr, sizeof sin->sin_addr); + sa.sin.sin_len = sizeof(struct sockaddr_in); + sa.sin.sin_family = AF_INET; + sa.sin.sin_port = htons(port); + memcpy(&sa.sin.sin_addr, host->h_addr, sizeof sa.sin.sin_addr); break; case AF_INET6: - sin6->sin6_len = sizeof(struct sockaddr_in6); - sin6->sin6_family = AF_INET6; - sin6->sin6_port = htons(port); - memcpy(&sin6->sin6_addr, host->h_addr, sizeof sin6->sin6_addr); + sa.sin6.sin6_len = sizeof(struct sockaddr_in6); + sa.sin6.sin6_family = AF_INET6; + sa.sin6.sin6_port = htons(port); + memcpy(&sa.sin6.sin6_addr, host->h_addr, sizeof sa.sin6.sin6_addr); break; default: - printf("Error:: unsupported socket type %d\n", host->h_addrtype); + ioERROR(host->h_addrtype, "unsupported socket type"); return -1; } - s = socket(ss.ss_family, SOCK_STREAM, 0); + s = socket(sa.ss.ss_family, SOCK_STREAM, 0); if (s == -1) { - printf("Error:: socket() #%d - %s\n", errno, strerror(errno)); + ioSYSERR(0); return -1; } if (setsockopt(s, SOL_SOCKET, SO_REUSEADDR, &n, sizeof n) == -1) { - printf("Error:: setsockopt(SO_REUSEADDR) #%d - %s\n", errno, strerror(errno)); + ioSYSERR(0); close(s); return -1; } - if (bind(s, (struct sockaddr*) &ss, ss.ss_len) == -1) { - printf("Error:: bind() #%d - %s\n", errno, strerror(errno)); + if (bind(s, (struct sockaddr*) &sa.ss, sa.ss.ss_len) == -1) { + ioSYSERR(0); close(s); return -1; }