--- mqtt/src/utils.c 2012/04/11 15:08:27 1.2.2.1 +++ mqtt/src/utils.c 2012/04/25 16:55:33 1.2.2.4 @@ -5,56 +5,37 @@ int srv_Socket(cfg_root_t * __restrict cfg) { int s = -1, n = 1; - 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 = {{ 0 }}; ioTRACE(2); + assert(cfg); + cfg_loadAttribute(cfg, "mqttd", "port", &v, MQTT_PORT); port = strtol(AIT_GET_STR(&v), NULL, 0); AIT_FREE_VAL(&v); cfg_loadAttribute(cfg, "mqttd", "listen", &v, MQTT_HOST); - - host = gethostbyname(AIT_GET_STR(&v)); - AIT_FREE_VAL(&v); - if (!host) { - printf("Error:: resolver #%d - %s\n", h_errno, hstrerror(h_errno)); + if (!io_gethostbyname(AIT_GET_STR(&v), port, &sa)) { + ioLIBERR(io); + AIT_FREE_VAL(&v); 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); - 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); - break; - default: - printf("Error:: unsupported socket type %d\n", host->h_addrtype); - return -1; - } + } else + AIT_FREE_VAL(&v); - 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, &sa.sa, sa.sa.sa_len) == -1) { + ioSYSERR(0); close(s); return -1; }