tcp.c File Reference

#include "precomp.h"

Include dependency graph for tcp.c:

Go to the source code of this file.

Macros
#define	TCP_CLOSE(_sck)   close(_sck)
#define	TCP_STRERROR   strerror(errno)
#define	TCP_SLEEP(_n)   sleep(_n)
#define	TCP_BLOCKS   (errno == EWOULDBLOCK)
#define	INADDR_NONE   ((unsigned long) -1)
#define	STREAM_COUNT   1

Functions
STREAM	tcp_init (uint32 maxlen)
void	tcp_send (STREAM s)
STREAM	tcp_recv (STREAM s, uint32 length)
RD_BOOL	tcp_connect (char *server)
void	tcp_disconnect (void)
char *	tcp_get_address ()
RD_BOOL	tcp_is_connected ()
void	tcp_reset_state (void)

Variables
static int	g_sock
static struct stream	g_in
static struct stream	g_out [STREAM_COUNT]
int	g_tcp_port_rdp = TCP_PORT_RDP
RD_BOOL	g_user_quit
RD_BOOL	g_network_error
RD_BOOL	g_reconnect_loop

Macro Definition Documentation

INADDR_NONE

#define INADDR_NONE   ((unsigned long) -1)

Definition at line 42 of file tcp.c.

STREAM_COUNT

#define STREAM_COUNT   1

Definition at line 48 of file tcp.c.

TCP_BLOCKS

#define TCP_BLOCKS   (errno == EWOULDBLOCK)

Definition at line 38 of file tcp.c.

TCP_CLOSE

#define TCP_CLOSE

(

_sck

)

close(_sck)

Definition at line 35 of file tcp.c.

TCP_SLEEP

#define TCP_SLEEP

(

_n

)

sleep(_n)

Definition at line 37 of file tcp.c.

TCP_STRERROR

#define TCP_STRERROR   strerror(errno)

Definition at line 36 of file tcp.c.

Function Documentation

tcp_connect()

RD_BOOL tcp_connect

(

char *

server

)

Definition at line 717 of file tcp.c.

{
    socklen_t option_len;
    uint32 option_value;
    int i;
 
#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;
    g_sock = -1;
    while (res)
    {
        g_sock = socket(res->ai_family, res->ai_socktype, res->ai_protocol);
        if (!(g_sock < 0))
        {
            if (connect(g_sock, res->ai_addr, res->ai_addrlen) == 0)
                break;
            TCP_CLOSE(g_sock);
            g_sock = -1;
        }
        res = res->ai_next;
    }
    freeaddrinfo(ressave);
 
    if (g_sock == -1)
    {
        error("%s: unable to connect\n", server);
        return False;
    }
 
#else /* no IPv6 support */
 
    struct hostent *nslookup;
    struct sockaddr_in servaddr;
 
    if ((nslookup = gethostbyname(server)) != NULL)
    {
        memcpy(&servaddr.sin_addr, nslookup->h_addr, sizeof(servaddr.sin_addr));
    }
    else if ((servaddr.sin_addr.s_addr = inet_addr(server)) == INADDR_NONE)
    {
        error("%s: unable to resolve host\n", server);
        return False;
    }
 
    if ((g_sock = socket(AF_INET, SOCK_STREAM, 0)) < 0)
    {
        error("socket: %s\n", TCP_STRERROR);
        return False;
    }
 
    servaddr.sin_family = AF_INET;
    servaddr.sin_port = htons((uint16) g_tcp_port_rdp);
 
    if (connect(g_sock, (struct sockaddr *) &servaddr, sizeof(struct sockaddr)) < 0)
    {
        if (!g_reconnect_loop)
            error("connect: %s\n", TCP_STRERROR);
 
        TCP_CLOSE(g_sock);
        g_sock = -1;
        return False;
    }
 
#endif /* IPv6 */
 
    option_value = 1;
    option_len = sizeof(option_value);
    setsockopt(g_sock, IPPROTO_TCP, TCP_NODELAY, (void *) &option_value, option_len);
    /* receive buffer must be a least 16 K */
    if (getsockopt(g_sock, SOL_SOCKET, SO_RCVBUF, (void *) &option_value, &option_len) == 0)
    {
        if (option_value < (1024 * 16))
        {
            option_value = 1024 * 16;
            option_len = sizeof(option_value);
            setsockopt(g_sock, SOL_SOCKET, SO_RCVBUF, (void *) &option_value,
                   option_len);
        }
    }
 
    g_in.size = 4096;
    g_in.data = (uint8 *) xmalloc(g_in.size);
 
    for (i = 0; i < STREAM_COUNT; i++)
    {
        g_out[i].size = 4096;
        g_out[i].data = (uint8 *) xmalloc(g_out[i].size);
    }
 
#ifdef WITH_SSL
    g_ssl_server = xmalloc(strlen(server)+1);
#endif /* WITH_SSL */
 
    return True;
}

Referenced by iso_connect(), iso_reconnect(), and LibTCPConnectCallback().

tcp_disconnect()

void tcp_disconnect

(

void

)

Definition at line 832 of file tcp.c.

{
#ifdef WITH_SSL
    if (g_ssl)
    {
        xfree(g_ssl->peek_msg_mem);
        g_ssl->peek_msg_mem = NULL;
        g_ssl->peek_msg = NULL;
        g_ssl->peek_len = 0;
        xfree(g_ssl->ssl_buf);
        g_ssl->ssl_buf = NULL;
        xfree(g_ssl->extra_buf);
        g_ssl->extra_buf = NULL;
        g_ssl->extra_len = 0;
        if (SecIsValidHandle(&g_ssl->ssl_ctx))
            DeleteSecurityContext(&g_ssl->ssl_ctx);
        if (cred_handle_initialized)
            FreeCredentialsHandle(&cred_handle);
        if (have_compat_cred_handle)
            FreeCredentialsHandle(&compat_cred_handle);
        if (g_ssl_server)
        {
            xfree(g_ssl_server);
            g_ssl_server = NULL;
        }
        g_ssl = NULL;
        g_ssl_initialized = False;
    }
#endif /* WITH_SSL */
    TCP_CLOSE(g_sock);
    g_sock = -1;
}

Referenced by iso_connect(), iso_disconnect(), and iso_reconnect().

tcp_get_address()

char * tcp_get_address

(

void

)

Definition at line 866 of file tcp.c.

{
    static char ipaddr[32];
    struct sockaddr_in sockaddr;
    socklen_t len = sizeof(sockaddr);
    if (getsockname(g_sock, (struct sockaddr *) &sockaddr, &len) == 0)
    {
        uint8 *ip = (uint8 *) & 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;
}

Referenced by rdp_send_logon_info(), and wWinMain().

tcp_init()

STREAM tcp_init

(

uint32

maxlen

)

Definition at line 82 of file tcp.c.

{
    static int cur_stream_id = 0;
    STREAM result = NULL;
 
#ifdef WITH_SCARD
    scard_lock(SCARD_LOCK_TCP);
#endif
    result = &g_out[cur_stream_id];
    cur_stream_id = (cur_stream_id + 1) % STREAM_COUNT;
 
    if (maxlen > result->size)
    {
        result->data = (uint8 *) xrealloc(result->data, maxlen);
        result->size = maxlen;
    }
 
    result->p = result->data;
    result->end = result->data + result->size;
#ifdef WITH_SCARD
    scard_unlock(SCARD_LOCK_TCP);
#endif
    return result;
}

Referenced by iso_init(), iso_send_connection_request(), iso_send_msg(), and lwip_init().

tcp_is_connected()

RD_BOOL tcp_is_connected

(

void

)

Definition at line 882 of file tcp.c.

{
    struct sockaddr_in sockaddr;
    socklen_t len = sizeof(sockaddr);
    if (getpeername(g_sock, (struct sockaddr *) &sockaddr, &len))
        return True;
    return False;
}

tcp_recv()

STREAM tcp_recv	(	STREAM	s,
		uint32	length
	)

Definition at line 344 of file tcp.c.

{
    uint32 new_length, end_offset, p_offset;
    int rcvd = 0;
 
    if (g_network_error == True)
        return NULL;
 
    if (s == NULL)
    {
        /* read into "new" stream */
        if (length > g_in.size)
        {
            g_in.data = (uint8 *) xrealloc(g_in.data, length);
            g_in.size = length;
        }
        g_in.end = g_in.p = g_in.data;
        s = &g_in;
    }
    else
    {
        /* append to existing stream */
        new_length = (s->end - s->data) + length;
        if (new_length > s->size)
        {
            p_offset = s->p - s->data;
            end_offset = s->end - s->data;
            s->data = (uint8 *) xrealloc(s->data, new_length);
            s->size = new_length;
            s->p = s->data + p_offset;
            s->end = s->data + end_offset;
        }
    }
 
    while (length > 0)
    {
#ifdef WITH_SSL
        if (!g_ssl)
#endif /* WITH_SSL */
        {
            if (!ui_select(g_sock))
            {
                /* User quit */
                g_user_quit = True;
                return NULL;
            }
        }
 
#ifdef WITH_SSL
        if (g_ssl)
        {
            SIZE_T size = 0;
            BOOL eof;
            DWORD res;
 
            if (g_ssl->peek_msg)
            {
                size = min(length, g_ssl->peek_len);
                memcpy(s->end, g_ssl->peek_msg, size);
                g_ssl->peek_len -= size;
                g_ssl->peek_msg += size;
                s->end += size;
 
                if (!g_ssl->peek_len)
                {
                    xfree(g_ssl->peek_msg_mem);
                    g_ssl->peek_msg_mem = g_ssl->peek_msg = NULL;
                }
 
                return s;
            }
 
            do
            {
                res = read_ssl_chunk((BYTE*)s->end, length, TRUE, &size, &eof);
                if (res != ERROR_SUCCESS)
                {
                    if (res == WSAEWOULDBLOCK)
                    {
                        if (size)
                        {
                            res = ERROR_SUCCESS;
                        }
                    }
                    else
                    {
                        error("read_ssl_chunk: %d (%s)\n", res, TCP_STRERROR);
                        g_network_error = True;
                        return NULL;
                    }
                    break;
                }
            }
            while (!size && !eof);
            rcvd = size;
        }
        else
        {
#endif /* WITH_SSL */
            rcvd = recv(g_sock, (char *)s->end, length, 0);
            if (rcvd < 0)
            {
                if (rcvd == -1 && TCP_BLOCKS)
                {
                    rcvd = 0;
                }
                else
                {
                    error("recv: %d (%s)\n", rcvd, TCP_STRERROR);
                    g_network_error = True;
                    return NULL;
                }
            }
            else if (rcvd == 0)
            {
                error("Connection closed\n");
                return NULL;
            }
#ifdef WITH_SSL
        }
#endif /* WITH_SSL */
 
        s->end += rcvd;
        length -= rcvd;
    }
 
    return s;
}

Referenced by iso_recv_msg(), LibTCPAccept(), LibTCPConnectCallback(), and test_tcp_new_counters_pcb().

tcp_reset_state()

void tcp_reset_state

(

void

)

Definition at line 894 of file tcp.c.

{
    int i;
 
    /* Clear the incoming stream */
    if (g_in.data != NULL)
        xfree(g_in.data);
    g_in.p = NULL;
    g_in.end = NULL;
    g_in.data = NULL;
    g_in.size = 0;
    g_in.iso_hdr = NULL;
    g_in.mcs_hdr = NULL;
    g_in.sec_hdr = NULL;
    g_in.rdp_hdr = NULL;
    g_in.channel_hdr = NULL;
 
    /* Clear the outgoing stream(s) */
    for (i = 0; i < STREAM_COUNT; i++)
    {
        if (g_out[i].data != NULL)
            xfree(g_out[i].data);
        g_out[i].p = NULL;
        g_out[i].end = NULL;
        g_out[i].data = NULL;
        g_out[i].size = 0;
        g_out[i].iso_hdr = NULL;
        g_out[i].mcs_hdr = NULL;
        g_out[i].sec_hdr = NULL;
        g_out[i].rdp_hdr = NULL;
        g_out[i].channel_hdr = NULL;
    }
}

Referenced by iso_reset_state().

tcp_send()

void tcp_send

(

STREAM

s

)

Definition at line 270 of file tcp.c.

{
    int length = s->end - s->data;
    int sent, total = 0;
 
    if (g_network_error == True)
        return;
 
#ifdef WITH_SCARD
    scard_lock(SCARD_LOCK_TCP);
#endif
    while (total < length)
    {
#ifdef WITH_SSL
        if (g_ssl)
        {
            const BYTE *ptr = s->data + total;
            size_t chunk_size;
 
            sent = 0;
 
            while (length - total)
            {
                chunk_size = min(length - total, g_ssl->ssl_sizes.cbMaximumMessage);
                if (!send_ssl_chunk(ptr, chunk_size))
                {
#ifdef WITH_SCARD
                    scard_unlock(SCARD_LOCK_TCP);
#endif
 
                    //error("send_ssl_chunk: %d (%s)\n", sent, TCP_STRERROR);
                    g_network_error = True;
                    return;
                }
 
                sent += chunk_size;
                ptr += chunk_size;
                length -= chunk_size;
            }
        }
        else
        {
#endif /* WITH_SSL */
            sent = send(g_sock, (const char *)s->data + total, length - total, 0);
            if (sent <= 0)
            {
                if (sent == -1 && TCP_BLOCKS)
                {
                    TCP_SLEEP(0);
                    sent = 0;
                }
                else
                {
#ifdef WITH_SCARD
                    scard_unlock(SCARD_LOCK_TCP);
#endif
 
                    error("send: %d (%s)\n", sent, TCP_STRERROR);
                    g_network_error = True;
                    return;
                }
            }
#ifdef WITH_SSL
        }
#endif /* WITH_SSL */
        total += sent;
    }
#ifdef WITH_SCARD
    scard_unlock(SCARD_LOCK_TCP);
#endif
}

Referenced by iso_send(), iso_send_connection_request(), and iso_send_msg().

Variable Documentation

g_in

struct stream g_in

static

Definition at line 73 of file tcp.c.

Referenced by convert_r5g5_snorm_l6_unorm(), convert_r5g5_snorm_l6_unorm_ext(), convert_r5g5_snorm_l6_unorm_nv(), tcp_connect(), tcp_recv(), and tcp_reset_state().

g_network_error

RD_BOOL g_network_error

extern

Definition at line 77 of file uimain.c.

Referenced by tcp_recv(), and tcp_send().

g_out

struct stream g_out[STREAM_COUNT]

static

Definition at line 74 of file tcp.c.

Referenced by convert_r5g5_snorm_l6_unorm_ext(), tcp_connect(), tcp_init(), and tcp_reset_state().

g_reconnect_loop

RD_BOOL g_reconnect_loop

extern

Definition at line 86 of file uimain.c.

Referenced by tcp_connect().

g_sock

int g_sock

static

Definition at line 72 of file tcp.c.

Referenced by tcp_connect(), tcp_disconnect(), tcp_get_address(), tcp_is_connected(), tcp_recv(), and tcp_send().

g_tcp_port_rdp

int g_tcp_port_rdp = TCP_PORT_RDP

Definition at line 75 of file tcp.c.

Referenced by parse_parameters(), tcp_connect(), and wWinMain().

g_user_quit

RD_BOOL g_user_quit

extern

Definition at line 76 of file uimain.c.

Referenced by tcp_recv().