dd6d829550
This big patch allows to have non-blocking writes. To achieve
this, it slightly changes the way transport is handled. The misc transport
layers are handled with OpenSSL BIOs. In the chain we insert a
bufferedBIO that will bufferize write calls that couldn't be honored.
For an access with Tls security the BIO chain would look like this:
FreeRdp Code ===> SSL bio ===> buffered BIO ===> socket BIO
The buffered BIO will store bytes that couldn't be send because of
blocking write calls.
This patch also rework TSG so that it would look like this in the
case of SSL security with TSG:
(TSG in)
> SSL BIO => buffered BIO ==> socket BIO
/
FreeRdp => SSL BIO => TSG BIO
\
> SSL BIO => buffered BIO ==> socket BIO
(TSG out)
So from the FreeRDP point of view sending something is only BIO_writing
on the frontBio (last BIO on the left).
78 lines
1.9 KiB
C
78 lines
1.9 KiB
C
/**
|
|
* FreeRDP: A Remote Desktop Protocol Implementation
|
|
* Transmission Control Protocol (TCP)
|
|
*
|
|
* Copyright 2011 Vic Lee
|
|
* Copyright 2011 Marc-Andre Moreau <marcandre.moreau@gmail.com>
|
|
*
|
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
* you may not use this file except in compliance with the License.
|
|
* You may obtain a copy of the License at
|
|
*
|
|
* http://www.apache.org/licenses/LICENSE-2.0
|
|
*
|
|
* Unless required by applicable law or agreed to in writing, software
|
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
* See the License for the specific language governing permissions and
|
|
* limitations under the License.
|
|
*/
|
|
|
|
#ifndef __TCP_H
|
|
#define __TCP_H
|
|
|
|
#include <winpr/windows.h>
|
|
|
|
#include <freerdp/types.h>
|
|
#include <freerdp/settings.h>
|
|
|
|
#include <winpr/crt.h>
|
|
#include <winpr/synch.h>
|
|
#include <winpr/stream.h>
|
|
#include <winpr/winsock.h>
|
|
|
|
#include <freerdp/utils/ringbuffer.h>
|
|
#include <openssl/bio.h>
|
|
|
|
#ifndef MSG_NOSIGNAL
|
|
#define MSG_NOSIGNAL 0
|
|
#endif
|
|
|
|
#define BIO_TYPE_BUFFERED 66
|
|
|
|
typedef struct rdp_tcp rdpTcp;
|
|
|
|
struct rdp_tcp
|
|
{
|
|
int sockfd;
|
|
char ip_address[32];
|
|
BYTE mac_address[6];
|
|
rdpSettings* settings;
|
|
#ifdef _WIN32
|
|
WSAEVENT wsa_event;
|
|
#endif
|
|
BIO *socketBio;
|
|
BIO *bufferedBio;
|
|
RingBuffer xmitBuffer;
|
|
BOOL writeBlocked;
|
|
BOOL readBlocked;
|
|
|
|
HANDLE event;
|
|
};
|
|
|
|
BOOL tcp_connect(rdpTcp* tcp, const char* hostname, int port);
|
|
BOOL tcp_disconnect(rdpTcp* tcp);
|
|
int tcp_read(rdpTcp* tcp, BYTE* data, int length);
|
|
int tcp_write(rdpTcp* tcp, BYTE* data, int length);
|
|
int tcp_wait_read(rdpTcp* tcp);
|
|
int tcp_wait_write(rdpTcp* tcp);
|
|
BOOL tcp_set_blocking_mode(rdpTcp* tcp, BOOL blocking);
|
|
BOOL tcp_set_keep_alive_mode(rdpTcp* tcp);
|
|
int tcp_attach(rdpTcp* tcp, int sockfd);
|
|
HANDLE tcp_get_event_handle(rdpTcp* tcp);
|
|
|
|
rdpTcp* tcp_new(rdpSettings* settings);
|
|
void tcp_free(rdpTcp* tcp);
|
|
|
|
#endif /* __TCP_H */
|