--- mqtt/src/utils.c 2012/04/15 21:44:33 1.2.2.2 +++ mqtt/src/utils.c 2012/04/24 08:06:09 1.2.2.3 @@ -5,7 +5,6 @@ int srv_Socket(cfg_root_t * __restrict cfg) { int s = -1, n = 1; - struct hostent *host; ait_val_t v; u_short port; io_sockaddr_t sa; @@ -16,30 +15,12 @@ srv_Socket(cfg_root_t * __restrict cfg) 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) { - ioERROR(h_errno, "%s", 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: - 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: - 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: - ioERROR(host->h_addrtype, "unsupported socket type"); - return -1; - } + } else + AIT_FREE_VAL(&v); s = socket(sa.ss.ss_family, SOCK_STREAM, 0); if (s == -1) { @@ -51,7 +32,7 @@ srv_Socket(cfg_root_t * __restrict cfg) close(s); return -1; } - if (bind(s, (struct sockaddr*) &sa.ss, sa.ss.ss_len) == -1) { + if (bind(s, &sa.sa, sa.sa.sa_len) == -1) { ioSYSERR(0); close(s); return -1;