--- sourceforge.net/trunk/rdesktop/tcp.c 2003/06/17 08:44:32 423 +++ sourceforge.net/trunk/rdesktop/tcp.c 2004/06/27 19:17:24 728 @@ -35,7 +35,7 @@ static int sock; static struct stream in; static struct stream out; -extern int tcp_port_rdp; +int g_tcp_port_rdp = TCP_PORT_RDP; /* Initialise TCP transport data packet */ STREAM @@ -112,11 +112,16 @@ return NULL; rcvd = recv(sock, s->end, length, 0); - if (rcvd <= 0) + if (rcvd < 0) { error("recv: %s\n", strerror(errno)); return NULL; } + else if (rcvd == 0) + { + error("Connection closed\n"); + return NULL; + } s->end += rcvd; length -= rcvd; @@ -129,9 +134,52 @@ BOOL tcp_connect(char *server) { + int true_value = 1; + +#ifdef IPv6 + + int n; + struct addrinfo hints, *res, *ressave; + char tcp_port_rdp_s[10]; + + snprintf(tcp_port_rdp_s, 10, "%d", g_tcp_port_rdp); + + memset(&hints, 0, sizeof(struct addrinfo)); + hints.ai_family = AF_UNSPEC; + hints.ai_socktype = SOCK_STREAM; + + if ((n = getaddrinfo(server, tcp_port_rdp_s, &hints, &res))) + { + error("getaddrinfo: %s\n", gai_strerror(n)); + return False; + } + + ressave = res; + sock = -1; + while (res) + { + sock = socket(res->ai_family, res->ai_socktype, res->ai_protocol); + if (!(sock < 0)) + { + if (connect(sock, res->ai_addr, res->ai_addrlen) == 0) + break; + close(sock); + sock = -1; + } + res = res->ai_next; + } + freeaddrinfo(ressave); + + if (sock == -1) + { + error("%s: unable to connect\n", server); + return False; + } + +#else /* no IPv6 support */ + struct hostent *nslookup; struct sockaddr_in servaddr; - int true_value = 1; if ((nslookup = gethostbyname(server)) != NULL) { @@ -150,7 +198,7 @@ } servaddr.sin_family = AF_INET; - servaddr.sin_port = htons(tcp_port_rdp); + servaddr.sin_port = htons(g_tcp_port_rdp); if (connect(sock, (struct sockaddr *) &servaddr, sizeof(struct sockaddr)) < 0) { @@ -159,6 +207,8 @@ return False; } +#endif /* IPv6 */ + setsockopt(sock, IPPROTO_TCP, TCP_NODELAY, (void *) &true_value, sizeof(true_value)); in.size = 4096; @@ -176,3 +226,19 @@ { close(sock); } + +char * +tcp_get_address() +{ + static char ipaddr[32]; + struct sockaddr_in sockaddr; + size_t len = sizeof(sockaddr); + if (getsockname(sock, (struct sockaddr *) &sockaddr, &len) == 0) + { + unsigned char *ip = (unsigned char *) &sockaddr.sin_addr; + sprintf(ipaddr, "%d.%d.%d.%d", ip[0], ip[1], ip[2], ip[3]); + } + else + strcpy(ipaddr, "127.0.0.1"); + return ipaddr; +}