mirrors/FreeRDP
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge pull request #2236 from marioli/master

Browse Source 
Rename tcp-functions as they are conflicting with qemu functions
This commit is contained in:
Marc-André Moreau 2014-11-29 21:08:36 -05:00
commit 8033022d6c
3 changed files with 47 additions and 47 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
libfreerdp/core/tcp.c
View File

@ -441,7 +441,7 @@ BOOL transport_bio_buffered_drain(BIO *bio)
return status >= 0; return status >= 0;
} }
void tcp_get_ip_address(rdpTcp* tcp) void freerdp_tcp_get_ip_address(rdpTcp* tcp)
{ {
BYTE* ip; BYTE* ip;
socklen_t length; socklen_t length;
@ -467,7 +467,7 @@ void tcp_get_ip_address(rdpTcp* tcp)
tcp->settings->ClientAddress = _strdup(tcp->ip_address); tcp->settings->ClientAddress = _strdup(tcp->ip_address);
} }
void tcp_get_mac_address(rdpTcp* tcp) void freerdp_tcp_get_mac_address(rdpTcp* tcp)
{ {
#ifdef LINUX #ifdef LINUX
BYTE* mac; BYTE* mac;
@ -531,7 +531,7 @@ int uds_connect(const char* path)
#endif #endif
} }
BOOL tcp_connect(rdpTcp* tcp, const char* hostname, int port, int timeout) BOOL freerdp_tcp_connect(rdpTcp* tcp, const char* hostname, int port, int timeout)
{ {
int status; int status;
UINT32 option_value; UINT32 option_value;
@ -678,8 +678,8 @@ BOOL tcp_connect(rdpTcp* tcp, const char* hostname, int port, int timeout)
SetEventFileDescriptor(tcp->event, tcp->sockfd); SetEventFileDescriptor(tcp->event, tcp->sockfd);
tcp_get_ip_address(tcp); freerdp_tcp_get_ip_address(tcp);
tcp_get_mac_address(tcp); freerdp_tcp_get_mac_address(tcp);
option_value = 1; option_value = 1;
option_len = sizeof(option_value); option_len = sizeof(option_value);
@ -708,7 +708,7 @@ BOOL tcp_connect(rdpTcp* tcp, const char* hostname, int port, int timeout)
if (!tcp->ipcSocket) if (!tcp->ipcSocket)
{ {
if (!tcp_set_keep_alive_mode(tcp)) if (!freerdp_tcp_set_keep_alive_mode(tcp))
return FALSE; return FALSE;
} }
@ -724,7 +724,7 @@ BOOL tcp_connect(rdpTcp* tcp, const char* hostname, int port, int timeout)
return TRUE; return TRUE;
} }
BOOL tcp_disconnect(rdpTcp* tcp) BOOL freerdp_tcp_disconnect(rdpTcp* tcp)
{ {
if (tcp->sockfd != -1) if (tcp->sockfd != -1)
{ {
@ -737,7 +737,7 @@ BOOL tcp_disconnect(rdpTcp* tcp)
return TRUE; return TRUE;
} }
BOOL tcp_set_blocking_mode(rdpTcp* tcp, BOOL blocking) BOOL freerdp_tcp_set_blocking_mode(rdpTcp* tcp, BOOL blocking)
{ {
#ifndef _WIN32 #ifndef _WIN32
int flags; int flags;
@ -784,7 +784,7 @@ BOOL tcp_set_blocking_mode(rdpTcp* tcp, BOOL blocking)
return TRUE; return TRUE;
} }
BOOL tcp_set_keep_alive_mode(rdpTcp* tcp) BOOL freerdp_tcp_set_keep_alive_mode(rdpTcp* tcp)
{ {
#ifndef _WIN32 #ifndef _WIN32
UINT32 option_value; UINT32 option_value;
@ -844,7 +844,7 @@ BOOL tcp_set_keep_alive_mode(rdpTcp* tcp)
return TRUE; return TRUE;
} }
int tcp_attach(rdpTcp* tcp, int sockfd) int freerdp_tcp_attach(rdpTcp* tcp, int sockfd)
{ {
tcp->sockfd = sockfd; tcp->sockfd = sockfd;
SetEventFileDescriptor(tcp->event, tcp->sockfd); SetEventFileDescriptor(tcp->event, tcp->sockfd);
@ -881,7 +881,7 @@ int tcp_attach(rdpTcp* tcp, int sockfd)
return 0; return 0;
} }
HANDLE tcp_get_event_handle(rdpTcp* tcp) HANDLE freerdp_tcp_get_event_handle(rdpTcp* tcp)
{ {
if (!tcp) if (!tcp)
return NULL; return NULL;
@ -889,7 +889,7 @@ HANDLE tcp_get_event_handle(rdpTcp* tcp)
return tcp->event; return tcp->event;
} }
int tcp_wait_read(rdpTcp* tcp, DWORD dwMilliSeconds) int freerdp_tcp_wait_read(rdpTcp* tcp, DWORD dwMilliSeconds)
{ {
int status; int status;
@ -927,7 +927,7 @@ int tcp_wait_read(rdpTcp* tcp, DWORD dwMilliSeconds)
return status; return status;
} }
int tcp_wait_write(rdpTcp* tcp, DWORD dwMilliSeconds) int freerdp_tcp_wait_write(rdpTcp* tcp, DWORD dwMilliSeconds)
{ {
int status; int status;
@ -965,7 +965,7 @@ int tcp_wait_write(rdpTcp* tcp, DWORD dwMilliSeconds)
return status; return status;
} }
rdpTcp* tcp_new(rdpSettings* settings) rdpTcp* freerdp_tcp_new(rdpSettings* settings)
{ {
rdpTcp* tcp; rdpTcp* tcp;
@ -998,7 +998,7 @@ out_free:
return NULL; return NULL;
} }
void tcp_free(rdpTcp* tcp) void freerdp_tcp_free(rdpTcp* tcp)
{ {
if (!tcp) if (!tcp)
return; return;

24
libfreerdp/core/tcp.h
View File

@ -58,18 +58,18 @@ struct rdp_tcp
HANDLE event; HANDLE event;
}; };
BOOL tcp_connect(rdpTcp* tcp, const char* hostname, int port, int timeout); BOOL freerdp_tcp_connect(rdpTcp* tcp, const char* hostname, int port, int timeout);
BOOL tcp_disconnect(rdpTcp* tcp); BOOL freerdp_tcp_disconnect(rdpTcp* tcp);
int tcp_read(rdpTcp* tcp, BYTE* data, int length); int freerdp_tcp_read(rdpTcp* tcp, BYTE* data, int length);
int tcp_write(rdpTcp* tcp, BYTE* data, int length); int freerdp_tcp_write(rdpTcp* tcp, BYTE* data, int length);
int tcp_wait_read(rdpTcp* tcp, DWORD dwMilliSeconds); int freerdp_tcp_wait_read(rdpTcp* tcp, DWORD dwMilliSeconds);
int tcp_wait_write(rdpTcp* tcp, DWORD dwMilliSeconds); int freerdp_tcp_wait_write(rdpTcp* tcp, DWORD dwMilliSeconds);
BOOL tcp_set_blocking_mode(rdpTcp* tcp, BOOL blocking); BOOL freerdp_tcp_set_blocking_mode(rdpTcp* tcp, BOOL blocking);
BOOL tcp_set_keep_alive_mode(rdpTcp* tcp); BOOL freerdp_tcp_set_keep_alive_mode(rdpTcp* tcp);
int tcp_attach(rdpTcp* tcp, int sockfd); int freerdp_tcp_attach(rdpTcp* tcp, int sockfd);
HANDLE tcp_get_event_handle(rdpTcp* tcp); HANDLE freerdp_tcp_get_event_handle(rdpTcp* tcp);
rdpTcp* tcp_new(rdpSettings* settings); rdpTcp* freerdp_tcp_new(rdpSettings* settings);
void tcp_free(rdpTcp* tcp); void freerdp_tcp_free(rdpTcp* tcp);
#endif /* __TCP_H */ #endif /* __TCP_H */

40
libfreerdp/core/transport.c
View File

@ -71,7 +71,7 @@ wStream* transport_send_stream_init(rdpTransport* transport, int size)
void transport_attach(rdpTransport* transport, int sockfd) void transport_attach(rdpTransport* transport, int sockfd)
{ {
tcp_attach(transport->TcpIn, sockfd); freerdp_tcp_attach(transport->TcpIn, sockfd);
transport->SplitInputOutput = FALSE; transport->SplitInputOutput = FALSE;
transport->TcpOut = transport->TcpIn; transport->TcpOut = transport->TcpIn;
transport->frontBio = transport->TcpIn->bufferedBio; transport->frontBio = transport->TcpIn->bufferedBio;
@ -443,14 +443,14 @@ BOOL transport_connect(rdpTransport* transport, const char* hostname, UINT16 por
{ {
transport->layer = TRANSPORT_LAYER_TSG; transport->layer = TRANSPORT_LAYER_TSG;
transport->SplitInputOutput = TRUE; transport->SplitInputOutput = TRUE;
transport->TcpOut = tcp_new(settings); transport->TcpOut = freerdp_tcp_new(settings);
if (!tcp_connect(transport->TcpIn, settings->GatewayHostname, settings->GatewayPort, timeout) || if (!freerdp_tcp_connect(transport->TcpIn, settings->GatewayHostname, settings->GatewayPort, timeout) ||
!tcp_set_blocking_mode(transport->TcpIn, FALSE)) !freerdp_tcp_set_blocking_mode(transport->TcpIn, FALSE))
return FALSE; return FALSE;
if (!tcp_connect(transport->TcpOut, settings->GatewayHostname, settings->GatewayPort, timeout) || if (!freerdp_tcp_connect(transport->TcpOut, settings->GatewayHostname, settings->GatewayPort, timeout) ||
!tcp_set_blocking_mode(transport->TcpOut, FALSE)) !freerdp_tcp_set_blocking_mode(transport->TcpOut, FALSE))
return FALSE; return FALSE;
if (!transport_tsg_connect(transport, hostname, port)) if (!transport_tsg_connect(transport, hostname, port))
@ -460,7 +460,7 @@ BOOL transport_connect(rdpTransport* transport, const char* hostname, UINT16 por
} }
else else
{ {
status = tcp_connect(transport->TcpIn, hostname, port, timeout); status = freerdp_tcp_connect(transport->TcpIn, hostname, port, timeout);
transport->SplitInputOutput = FALSE; transport->SplitInputOutput = FALSE;
transport->TcpOut = transport->TcpIn; transport->TcpOut = transport->TcpIn;
transport->frontBio = transport->TcpIn->bufferedBio; transport->frontBio = transport->TcpIn->bufferedBio;
@ -554,11 +554,11 @@ static int transport_wait_for_read(rdpTransport* transport)
if (tcpIn->readBlocked) if (tcpIn->readBlocked)
{ {
return tcp_wait_read(tcpIn, 10); return freerdp_tcp_wait_read(tcpIn, 10);
} }
else if (tcpIn->writeBlocked) else if (tcpIn->writeBlocked)
{ {
return tcp_wait_write(tcpIn, 10); return freerdp_tcp_wait_write(tcpIn, 10);
} }
USleep(1000); USleep(1000);
@ -572,11 +572,11 @@ static int transport_wait_for_write(rdpTransport* transport)
if (tcpOut->writeBlocked) if (tcpOut->writeBlocked)
{ {
return tcp_wait_write(tcpOut, 10); return freerdp_tcp_wait_write(tcpOut, 10);
} }
else if (tcpOut->readBlocked) else if (tcpOut->readBlocked)
{ {
return tcp_wait_read(tcpOut, 10); return freerdp_tcp_wait_read(tcpOut, 10);
} }
USleep(1000); USleep(1000);
@ -942,12 +942,12 @@ void transport_get_fds(rdpTransport* transport, void** rfds, int* rcount)
void transport_get_read_handles(rdpTransport* transport, HANDLE* events, DWORD* count) void transport_get_read_handles(rdpTransport* transport, HANDLE* events, DWORD* count)
{ {
events[*count] = tcp_get_event_handle(transport->TcpIn); events[*count] = freerdp_tcp_get_event_handle(transport->TcpIn);
(*count)++; (*count)++;
if (transport->SplitInputOutput) if (transport->SplitInputOutput)
{ {
events[*count] = tcp_get_event_handle(transport->TcpOut); events[*count] = freerdp_tcp_get_event_handle(transport->TcpOut);
(*count)++; (*count)++;
} }
@ -1067,12 +1067,12 @@ BOOL transport_set_blocking_mode(rdpTransport* transport, BOOL blocking)
if (transport->SplitInputOutput) if (transport->SplitInputOutput)
{ {
status &= tcp_set_blocking_mode(transport->TcpIn, blocking); status &= freerdp_tcp_set_blocking_mode(transport->TcpIn, blocking);
status &= tcp_set_blocking_mode(transport->TcpOut, blocking); status &= freerdp_tcp_set_blocking_mode(transport->TcpOut, blocking);
} }
else else
{ {
status &= tcp_set_blocking_mode(transport->TcpIn, blocking); status &= freerdp_tcp_set_blocking_mode(transport->TcpIn, blocking);
} }
if (transport->layer == TRANSPORT_LAYER_TSG || transport->layer == TRANSPORT_LAYER_TSG_TLS) if (transport->layer == TRANSPORT_LAYER_TSG || transport->layer == TRANSPORT_LAYER_TSG_TLS)
@ -1166,7 +1166,7 @@ rdpTransport* transport_new(rdpSettings* settings)
if (!transport->log) if (!transport->log)
goto out_free; goto out_free;
transport->TcpIn = tcp_new(settings); transport->TcpIn = freerdp_tcp_new(settings);
if (!transport->TcpIn) if (!transport->TcpIn)
goto out_free; goto out_free;
@ -1217,7 +1217,7 @@ out_free_receivebuffer:
out_free_receivepool: out_free_receivepool:
StreamPool_Free(transport->ReceivePool); StreamPool_Free(transport->ReceivePool);
out_free_tcpin: out_free_tcpin:
tcp_free(transport->TcpIn); freerdp_tcp_free(transport->TcpIn);
out_free: out_free:
free(transport); free(transport);
return NULL; return NULL;
@ -1247,10 +1247,10 @@ void transport_free(rdpTransport* transport)
transport->TlsOut = NULL; transport->TlsOut = NULL;
if (transport->TcpIn) if (transport->TcpIn)
tcp_free(transport->TcpIn); freerdp_tcp_free(transport->TcpIn);
if (transport->TcpOut != transport->TcpIn) if (transport->TcpOut != transport->TcpIn)
tcp_free(transport->TcpOut); freerdp_tcp_free(transport->TcpOut);
transport->TcpIn = NULL; transport->TcpIn = NULL;
transport->TcpOut = NULL; transport->TcpOut = NULL;