am 790d25b7: am 5403d155: am e36b10a8: Merge "Switch libcutils from gethostbyname to getaddrinfo."

#include <cutils/sockets.h>

/* Connect to port on the IP interface. type is

 * SOCK_STREAM or SOCK_DGRAM. 

 * return is a file descriptor or -1 on error

 */

int socket_network_client(const char *host, int port, int type)

{

    return socket_network_client_timeout(host, port, type, 0);

}

/* Connect to port on the IP interface. type is SOCK_STREAM or SOCK_DGRAM.

 * timeout in seconds return is a file descriptor or -1 on error

 */

int socket_network_client_timeout(const char *host, int port, int type, int timeout)

{

    struct hostent *hp;

    struct sockaddr_in addr;

    int s;

    int flags = 0, error = 0, ret = 0;

    fd_set rset, wset;

    socklen_t len = sizeof(error);

    struct timeval ts;

static int fix_O_NONBLOCK(int s, int type) {

    // If the caller actually wanted a non-blocking socket, fine.

    if ((type & SOCK_NONBLOCK)) return s;

    ts.tv_sec = timeout;

    ts.tv_usec = 0;

    // Otherwise clear the O_NONBLOCK flag.

    int flags = fcntl(s, F_GETFL);

    if (flags == -1 || fcntl(s, F_SETFL, flags & ~O_NONBLOCK) == -1) {

        close(s);

        return -1;

    }

    hp = gethostbyname(host);

    if (hp == 0) return -1;

    return s;

}

    memset(&addr, 0, sizeof(addr));

    addr.sin_family = hp->h_addrtype;

    addr.sin_port = htons(port);

    memcpy(&addr.sin_addr, hp->h_addr, hp->h_length);

// Connect to the given host and port.

// 'timeout' is in seconds (0 for no timeout).

// Returns a file descriptor or -1 on error.

int socket_network_client_timeout(const char* host, int port, int type, int timeout) {

    struct addrinfo hints;

    memset(&hints, 0, sizeof(hints));

    hints.ai_family = AF_UNSPEC;

    hints.ai_socktype = type;

    s = socket(hp->h_addrtype, type, 0);

    if (s < 0) return -1;

    char port_str[16];

    snprintf(port_str, sizeof(port_str), "%d", port);

    if ((flags = fcntl(s, F_GETFL, 0)) < 0) {

        close(s);

    struct addrinfo* addrs;

    if (getaddrinfo(host, port_str, &hints, &addrs) != 0) {

        return -1;

    }

    if (fcntl(s, F_SETFL, flags | O_NONBLOCK) < 0) {

        close(s);

        return -1;

    }

    // TODO: try all the addresses if there's more than one?

    int family = addrs[0].ai_family;

    int protocol = addrs[0].ai_protocol;

    socklen_t addr_len = addrs[0].ai_addrlen;

    struct sockaddr_storage addr;

    memcpy(&addr, addrs[0].ai_addr, addr_len);

    freeaddrinfo(addrs);

    if ((ret = connect(s, (struct sockaddr *) &addr, sizeof(addr))) < 0) {

        if (errno != EINPROGRESS) {

    int s = socket(family, type | SOCK_NONBLOCK, protocol);

    if (s == -1) return -1;

    int rc = connect(s, (const struct sockaddr*) &addr, addr_len);

    if (rc == 0) {

        return fix_O_NONBLOCK(s, type);

    } else if (rc == -1 && errno != EINPROGRESS) {

        close(s);

        return -1;

    }

    }

    if (ret == 0)

        goto done;

    fd_set r_set;

    FD_ZERO(&r_set);

    FD_SET(s, &r_set);

    fd_set w_set = r_set;

    FD_ZERO(&rset);

    FD_SET(s, &rset);

    wset = rset;

    if ((ret = select(s + 1, &rset, &wset, NULL, (timeout) ? &ts : NULL)) < 0) {

    struct timeval ts;

    ts.tv_sec = timeout;

    ts.tv_usec = 0;

    if ((rc = select(s + 1, &r_set, &w_set, NULL, (timeout != 0) ? &ts : NULL)) == -1) {

        close(s);

        return -1;

    }

    if (ret == 0) {   // we had a timeout

    if (rc == 0) {   // we had a timeout

        errno = ETIMEDOUT;

        close(s);

        return -1;

    }

    if (FD_ISSET(s, &rset) || FD_ISSET(s, &wset)) {

    int error = 0;

    socklen_t len = sizeof(error);

    if (FD_ISSET(s, &r_set) || FD_ISSET(s, &w_set)) {

        if (getsockopt(s, SOL_SOCKET, SO_ERROR, &error, &len) < 0) {

            close(s);

            return -1;

        return -1;

    }

done:

    if (fcntl(s, F_SETFL, flags) < 0) {

        close(s);

        return -1;

    return fix_O_NONBLOCK(s, type);

}

    return s;

int socket_network_client(const char* host, int port, int type) {

    return socket_network_client_timeout(host, port, type, 0);

}