21#include <freerdp/config.h>
26#include <winpr/string.h>
27#include <winpr/synch.h>
28#include <winpr/assert.h>
29#include <winpr/cast.h>
30#include <winpr/json.h>
38#include "redirection.h"
40#include <freerdp/codec/bulk.h>
41#include <freerdp/crypto/per.h>
42#include <freerdp/log.h>
43#include <freerdp/buildflags.h>
45#define RDP_TAG FREERDP_TAG("core.rdp")
55static const char* DATA_PDU_TYPE_STRINGS[80] = {
97 "Set Keyboard Indicators",
99 "Bitmap Cache Persistent List",
100 "Bitmap Cache Error",
101 "Set Keyboard IME Status",
102 "Offscreen Cache Error",
104 "Draw Nine Grid Error",
123#define rdp_check_monitor_layout_pdu_state(rdp, expected) \
124 rdp_check_monitor_layout_pdu_state_(rdp, expected, __FILE__, __func__, __LINE__)
126static BOOL rdp_check_monitor_layout_pdu_state_(
const rdpRdp* rdp, BOOL expected,
const char* file,
127 const char* fkt,
size_t line)
130 if (expected != rdp->monitor_layout_pdu)
132 const DWORD log_level = WLOG_ERROR;
133 if (WLog_IsLevelActive(rdp->log, log_level))
135 WLog_PrintMessage(rdp->log, WLOG_MESSAGE_TEXT, log_level, line, file, fkt,
136 "Expected rdp->monitor_layout_pdu == %s",
137 expected ?
"TRUE" :
"FALSE");
144#define rdp_set_monitor_layout_pdu_state(rdp, expected) \
145 rdp_set_monitor_layout_pdu_state_(rdp, expected, __FILE__, __func__, __LINE__)
146static BOOL rdp_set_monitor_layout_pdu_state_(rdpRdp* rdp, BOOL value,
const char* file,
147 const char* fkt,
size_t line)
151 if (value && (value == rdp->monitor_layout_pdu))
153 const DWORD log_level = WLOG_WARN;
154 if (WLog_IsLevelActive(rdp->log, log_level))
156 WLog_PrintMessage(rdp->log, WLOG_MESSAGE_TEXT, log_level, line, file, fkt,
157 "rdp->monitor_layout_pdu == TRUE, expected FALSE");
161 rdp->monitor_layout_pdu = value;
165const char* data_pdu_type_to_string(UINT8 type)
167 if (type >= ARRAYSIZE(DATA_PDU_TYPE_STRINGS))
169 return DATA_PDU_TYPE_STRINGS[type];
172static BOOL rdp_read_flow_control_pdu(rdpRdp* rdp,
wStream* s, UINT16* type, UINT16* channel_id);
173static BOOL rdp_write_share_control_header(rdpRdp* rdp,
wStream* s,
size_t length, UINT16 type,
175static BOOL rdp_write_share_data_header(rdpRdp* rdp,
wStream* s,
size_t length, BYTE type,
188BOOL rdp_read_security_header(rdpRdp* rdp,
wStream* s, UINT16* flags, UINT16* length)
190 char buffer[256] = { 0 };
196 if ((length && (*length < 4)))
198 WLog_Print(rdp->log, WLOG_WARN,
199 "invalid security header length, have %" PRIu16
", must be >= 4", *length);
202 if (!Stream_CheckAndLogRequiredLengthWLog(rdp->log, s, 4))
205 *flags = Stream_Get_UINT16(s);
206 const uint16_t flagsHi = Stream_Get_UINT16(s);
207 if ((*flags & SEC_FLAGSHI_VALID) != 0)
209 WLog_Print(rdp->log, WLOG_WARN,
210 "[MS-RDPBCGR] 2.2.8.1.1.2.1 Basic (TS_SECURITY_HEADER) SEC_FLAGSHI_VALID field "
211 "set: flagsHi=0x%04" PRIx16,
214 WLog_Print(rdp->log, WLOG_TRACE,
"%s",
215 rdp_security_flag_string(*flags, buffer,
sizeof(buffer)));
231BOOL rdp_write_security_header(rdpRdp* rdp,
wStream* s, UINT16 flags)
233 char buffer[256] = { 0 };
237 if (!Stream_CheckAndLogRequiredCapacityWLog(rdp->log, (s), 4))
240 WLog_Print(rdp->log, WLOG_TRACE,
"%s", rdp_security_flag_string(flags, buffer,
sizeof(buffer)));
242 WINPR_ASSERT((flags & SEC_FLAGSHI_VALID) == 0);
243 Stream_Write_UINT16(s, flags);
244 Stream_Write_UINT16(s, 0);
248BOOL rdp_read_share_control_header(rdpRdp* rdp,
wStream* s, UINT16* tpktLength,
249 UINT16* remainingLength, UINT16* type, UINT16* channel_id)
257 WINPR_ASSERT(channel_id);
259 if (!Stream_CheckAndLogRequiredLengthWLog(rdp->log, s, 2))
263 Stream_Read_UINT16(s, len);
269 if (!rdp_read_flow_control_pdu(rdp, s, type, channel_id))
275 *remainingLength = 0;
277 char buffer[128] = { 0 };
278 WLog_Print(rdp->log, WLOG_DEBUG,
279 "[Flow control PDU] type=%s, tpktLength=%" PRIuz
", remainingLength=%" PRIuz,
280 pdu_type_to_str(*type, buffer,
sizeof(buffer)), tpktLength ? *tpktLength : 0,
281 remainingLength ? *remainingLength : 0);
287 WLog_Print(rdp->log, WLOG_ERROR,
288 "Invalid share control header, length is %" PRIu16
", must be >4", len);
295 if (!Stream_CheckAndLogRequiredLengthWLog(rdp->log, s, 2))
298 Stream_Read_UINT16(s, tmp);
301 size_t remLen = len - 4;
304 if (!Stream_CheckAndLogRequiredLengthWLog(rdp->log, s, 2))
307 Stream_Read_UINT16(s, *channel_id);
313 char buffer[128] = { 0 };
314 WLog_Print(rdp->log, WLOG_DEBUG,
"type=%s, tpktLength=%" PRIuz
", remainingLength=%" PRIuz,
315 pdu_type_to_str(*type, buffer,
sizeof(buffer)), len, remLen);
318 WINPR_ASSERT(remLen <= UINT16_MAX);
319 *remainingLength = (UINT16)remLen;
321 return Stream_CheckAndLogRequiredLengthWLog(rdp->log, s, remLen);
324BOOL rdp_write_share_control_header(rdpRdp* rdp,
wStream* s,
size_t length, UINT16 type,
329 if (length > UINT16_MAX)
332 if (length < RDP_PACKET_HEADER_MAX_LENGTH)
334 if (!Stream_CheckAndLogRequiredCapacityWLog(rdp->log, (s), 6))
336 length -= RDP_PACKET_HEADER_MAX_LENGTH;
338 Stream_Write_UINT16(s, WINPR_ASSERTING_INT_CAST(uint16_t, length));
339 Stream_Write_UINT16(s, WINPR_ASSERTING_INT_CAST(uint16_t, type | 0x10));
340 Stream_Write_UINT16(s, WINPR_ASSERTING_INT_CAST(uint16_t, channel_id));
344BOOL rdp_read_share_data_header(rdpRdp* rdp,
wStream* s, UINT16* length, BYTE* type,
345 UINT32* shareId, BYTE* compressedType, UINT16* compressedLength)
350 if (!Stream_CheckAndLogRequiredLengthWLog(rdp->log, s, 12))
354 Stream_Read_UINT32(s, *shareId);
355 Stream_Seek_UINT8(s);
356 Stream_Seek_UINT8(s);
357 Stream_Read_UINT16(s, *length);
358 Stream_Read_UINT8(s, *type);
359 Stream_Read_UINT8(s, *compressedType);
360 Stream_Read_UINT16(s, *compressedLength);
364BOOL rdp_write_share_data_header(rdpRdp* rdp,
wStream* s,
size_t length, BYTE type, UINT32 share_id)
366 const size_t headerLen = RDP_PACKET_HEADER_MAX_LENGTH + RDP_SHARE_CONTROL_HEADER_LENGTH +
367 RDP_SHARE_DATA_HEADER_LENGTH;
371 if (length > UINT16_MAX)
374 if (length < headerLen)
377 if (!Stream_CheckAndLogRequiredCapacityWLog(rdp->log, (s), 12))
381 Stream_Write_UINT32(s, share_id);
382 Stream_Write_UINT8(s, 0);
383 Stream_Write_UINT8(s, STREAM_LOW);
385 s, WINPR_ASSERTING_INT_CAST(uint16_t, length));
386 Stream_Write_UINT8(s, type);
387 Stream_Write_UINT8(s, 0);
388 Stream_Write_UINT16(s, 0);
392static BOOL rdp_security_stream_init(rdpRdp* rdp,
wStream* s, BOOL sec_header, UINT16* sec_flags)
396 WINPR_ASSERT(sec_flags);
400 if (!Stream_SafeSeek(s, 12))
403 if (rdp->settings->EncryptionMethods == ENCRYPTION_METHOD_FIPS)
405 if (!Stream_SafeSeek(s, 4))
409 *sec_flags |= SEC_ENCRYPT;
411 if (rdp->do_secure_checksum)
412 *sec_flags |= SEC_SECURE_CHECKSUM;
414 else if (*sec_flags != 0 || sec_header)
416 if (!Stream_SafeSeek(s, 4))
423wStream* rdp_send_stream_init(rdpRdp* rdp, UINT16* sec_flags)
428 WINPR_ASSERT(rdp->transport);
430 s = transport_send_stream_init(rdp->transport, 4096);
435 if (!Stream_SafeSeek(s, RDP_PACKET_HEADER_MAX_LENGTH))
438 if (!rdp_security_stream_init(rdp, s, FALSE, sec_flags))
447wStream* rdp_send_stream_pdu_init(rdpRdp* rdp, UINT16* sec_flags)
449 wStream* s = rdp_send_stream_init(rdp, sec_flags);
454 if (!Stream_SafeSeek(s, RDP_SHARE_CONTROL_HEADER_LENGTH))
463wStream* rdp_data_pdu_init(rdpRdp* rdp, UINT16* sec_flags)
465 wStream* s = rdp_send_stream_pdu_init(rdp, sec_flags);
470 if (!Stream_SafeSeek(s, RDP_SHARE_DATA_HEADER_LENGTH))
479BOOL rdp_set_error_info(rdpRdp* rdp, UINT32 errorInfo)
483 rdp->errorInfo = errorInfo;
485 if (rdp->errorInfo != ERRINFO_SUCCESS)
487 rdpContext* context = rdp->context;
488 WINPR_ASSERT(context);
490 rdp_print_errinfo(rdp->errorInfo);
494 freerdp_set_last_error_log(context, MAKE_FREERDP_ERROR(
ERRINFO, errorInfo));
498 ErrorInfoEventArgs e = { 0 };
499 EventArgsInit(&e,
"freerdp");
500 e.code = rdp->errorInfo;
501 PubSub_OnErrorInfo(context->pubSub, context, &e);
505 WLog_Print(rdp->log, WLOG_ERROR,
"missing context=%p", context);
509 freerdp_set_last_error_log(rdp->context, FREERDP_ERROR_SUCCESS);
515wStream* rdp_message_channel_pdu_init(rdpRdp* rdp, UINT16* sec_flags)
521 s = transport_send_stream_init(rdp->transport, 4096);
526 if (!Stream_SafeSeek(s, RDP_PACKET_HEADER_MAX_LENGTH))
529 if (!rdp_security_stream_init(rdp, s, TRUE, sec_flags))
548BOOL rdp_read_header(rdpRdp* rdp,
wStream* s, UINT16* length, UINT16* channelId)
553 UINT16 initiator = 0;
556 WINPR_ASSERT(rdp->settings);
558 DomainMCSPDU MCSPDU = (rdp->settings->ServerMode) ? DomainMCSPDU_SendDataRequest
559 : DomainMCSPDU_SendDataIndication;
562 if (!tpkt_read_header(s, length))
565 if (!tpdu_read_header(s, &code, &li, *length))
568 if (code != X224_TPDU_DATA)
570 if (code == X224_TPDU_DISCONNECT_REQUEST)
572 WLog_Print(rdp->log, WLOG_WARN,
"Received X224_TPDU_DISCONNECT_REQUEST, terminating");
573 utils_abort_connect(rdp);
577 WLog_Print(rdp->log, WLOG_WARN,
578 "Unexpected X224 TPDU type %s [%08" PRIx32
"] instead of %s",
579 tpdu_type_to_string(code), code, tpdu_type_to_string(X224_TPDU_DATA));
583 if (!per_read_choice(s, &choice))
586 const DomainMCSPDU domainMCSPDU = (DomainMCSPDU)(choice >> 2);
588 if (domainMCSPDU != MCSPDU)
590 if (domainMCSPDU != DomainMCSPDU_DisconnectProviderUltimatum)
592 WLog_Print(rdp->log, WLOG_WARN,
"Received %s instead of %s",
593 mcs_domain_pdu_string(domainMCSPDU), mcs_domain_pdu_string(MCSPDU));
598 MCSPDU = domainMCSPDU;
602 WLog_Print(rdp->log, WLOG_WARN,
"TPDU invalid length, got %" PRIu16
", expected at least 8",
607 if (!Stream_CheckAndLogRequiredLengthWLog(rdp->log, s, *length - 8))
610 if (MCSPDU == DomainMCSPDU_DisconnectProviderUltimatum)
613 TerminateEventArgs e = { 0 };
615 if (!mcs_recv_disconnect_provider_ultimatum(rdp->mcs, s, &reason))
618 rdpContext* context = rdp->context;
619 WINPR_ASSERT(context);
620 context->disconnectUltimatum = reason;
622 if (rdp->errorInfo == ERRINFO_SUCCESS)
629 UINT32 errorInfo = ERRINFO_RPC_INITIATED_DISCONNECT;
630 if (reason == Disconnect_Ultimatum_provider_initiated)
631 errorInfo = ERRINFO_RPC_INITIATED_DISCONNECT;
632 else if (reason == Disconnect_Ultimatum_user_requested)
633 errorInfo = ERRINFO_LOGOFF_BY_USER;
635 rdp_set_error_info(rdp, errorInfo);
638 WLog_Print(rdp->log, WLOG_DEBUG,
"DisconnectProviderUltimatum: reason: %d", reason);
639 utils_abort_connect(rdp);
640 EventArgsInit(&e,
"freerdp");
642 PubSub_OnTerminate(rdp->pubSub, context, &e);
646 if (!Stream_CheckAndLogRequiredLengthWLog(rdp->log, s, 5))
649 if (!per_read_integer16(s, &initiator, MCS_BASE_CHANNEL_ID))
652 if (!per_read_integer16(s, channelId, 0))
655 const uint8_t dataPriority = Stream_Get_UINT8(s);
656 WLog_Print(rdp->log, WLOG_TRACE,
"dataPriority=%" PRIu8, dataPriority);
658 if (!per_read_length(s, length))
661 if (!Stream_CheckAndLogRequiredLengthWLog(rdp->log, s, *length))
677BOOL rdp_write_header(rdpRdp* rdp,
wStream* s,
size_t length, UINT16 channelId, UINT16 sec_flags)
680 WINPR_ASSERT(rdp->settings);
682 WINPR_ASSERT(length >= RDP_PACKET_HEADER_MAX_LENGTH);
683 if (length > UINT16_MAX)
686 DomainMCSPDU MCSPDU = (rdp->settings->ServerMode) ? DomainMCSPDU_SendDataIndication
687 : DomainMCSPDU_SendDataRequest;
689 if ((sec_flags & SEC_ENCRYPT) && (rdp->settings->EncryptionMethods == ENCRYPTION_METHOD_FIPS))
691 const UINT16 body_length = (UINT16)length - RDP_PACKET_HEADER_MAX_LENGTH;
692 const UINT16 pad = 8 - (body_length % 8);
698 if (!mcs_write_domain_mcspdu_header(s, MCSPDU, (UINT16)length, 0))
700 if (!per_write_integer16(s, rdp->mcs->userId, MCS_BASE_CHANNEL_ID))
702 if (!per_write_integer16(s, channelId, 0))
704 if (!Stream_EnsureRemainingCapacity(s, 3))
706 Stream_Write_UINT8(s, 0x70);
713 length = (length - RDP_PACKET_HEADER_MAX_LENGTH) | 0x8000;
714 Stream_Write_UINT16_BE(
715 s, WINPR_ASSERTING_INT_CAST(uint16_t, length));
719static BOOL rdp_security_stream_out(rdpRdp* rdp,
wStream* s,
size_t length, UINT16 sec_flags,
724 if (length > UINT16_MAX)
731 WINPR_ASSERT(sec_flags <= UINT16_MAX);
732 if (!rdp_write_security_header(rdp, s, sec_flags))
735 if (sec_flags & SEC_ENCRYPT)
737 if (rdp->settings->EncryptionMethods == ENCRYPTION_METHOD_FIPS)
739 BYTE* data = Stream_PointerAs(s, BYTE) + 12;
740 const size_t size = WINPR_ASSERTING_INT_CAST(
size_t, (data - Stream_Buffer(s)));
746 Stream_Write_UINT16(s, 0x10);
747 Stream_Write_UINT8(s, 0x1);
749 *pad = 8 - (length % 8);
755 memset(data + length, 0, *pad);
757 Stream_Write_UINT8(s, WINPR_ASSERTING_INT_CAST(uint8_t, *pad));
759 if (!Stream_CheckAndLogRequiredCapacityWLog(rdp->log, s, 8))
761 if (!security_hmac_signature(data, length, Stream_Pointer(s), 8, rdp))
765 if (!security_fips_encrypt(data, length + *pad, rdp))
770 const BYTE* data = Stream_PointerAs(s,
const BYTE) + 8;
771 const size_t diff = Stream_GetPosition(s) + 8ULL;
776 if (!Stream_CheckAndLogRequiredCapacityWLog(rdp->log, s, 8))
778 if (sec_flags & SEC_SECURE_CHECKSUM)
779 status = security_salted_mac_signature(rdp, data, (UINT32)length, TRUE,
780 Stream_Pointer(s), 8);
782 status = security_mac_signature(rdp, data, (UINT32)length,
783 Stream_PointerAs(s, BYTE), 8);
790 if (!security_encrypt(Stream_Pointer(s), length, rdp))
799static UINT32 rdp_get_sec_bytes(rdpRdp* rdp, UINT16 sec_flags)
801 UINT32 sec_bytes = 0;
803 if (sec_flags & SEC_ENCRYPT)
807 if (rdp->settings->EncryptionMethods == ENCRYPTION_METHOD_FIPS)
810 else if (sec_flags != 0)
829BOOL rdp_send(rdpRdp* rdp,
wStream* s, UINT16 channel_id, UINT16 sec_flags)
833 BOOL should_unlock = FALSE;
841 if (sec_flags & SEC_ENCRYPT)
843 if (!security_lock(rdp))
845 should_unlock = TRUE;
848 size_t length = Stream_GetPosition(s);
849 Stream_SetPosition(s, 0);
850 if (!rdp_write_header(rdp, s, length, channel_id, sec_flags))
853 if (!rdp_security_stream_out(rdp, s, length, sec_flags, &pad))
857 Stream_SetPosition(s, length);
858 Stream_SealLength(s);
860 if (transport_write(rdp->transport, s) < 0)
865 if (should_unlock && !security_unlock(rdp))
871BOOL rdp_send_pdu(rdpRdp* rdp,
wStream* s, UINT16 type, UINT16 channel_id, UINT16 sec_flags)
874 UINT32 sec_bytes = 0;
877 BOOL should_unlock = FALSE;
885 if (sec_flags & SEC_ENCRYPT)
887 if (!security_lock(rdp))
889 should_unlock = TRUE;
892 size_t length = Stream_GetPosition(s);
893 Stream_SetPosition(s, 0);
894 if (!rdp_write_header(rdp, s, length, MCS_GLOBAL_CHANNEL_ID, sec_flags))
896 sec_bytes = rdp_get_sec_bytes(rdp, sec_flags);
897 sec_hold = Stream_GetPosition(s);
898 Stream_Seek(s, sec_bytes);
899 if (!rdp_write_share_control_header(rdp, s, length - sec_bytes, type, channel_id))
901 Stream_SetPosition(s, sec_hold);
903 if (!rdp_security_stream_out(rdp, s, length, sec_flags, &pad))
907 Stream_SetPosition(s, length);
908 Stream_SealLength(s);
910 if (transport_write(rdp->transport, s) < 0)
915 if (should_unlock && !security_unlock(rdp))
920BOOL rdp_send_data_pdu(rdpRdp* rdp,
wStream* s, BYTE type, UINT16 channel_id, UINT16 sec_flags)
923 UINT32 sec_bytes = 0;
926 BOOL should_unlock = FALSE;
934 if (sec_flags & SEC_ENCRYPT)
936 if (!security_lock(rdp))
938 should_unlock = TRUE;
941 size_t length = Stream_GetPosition(s);
942 Stream_SetPosition(s, 0);
943 if (!rdp_write_header(rdp, s, length, MCS_GLOBAL_CHANNEL_ID, sec_flags))
945 sec_bytes = rdp_get_sec_bytes(rdp, sec_flags);
946 sec_hold = Stream_GetPosition(s);
947 Stream_Seek(s, sec_bytes);
948 if (!rdp_write_share_control_header(rdp, s, length - sec_bytes, PDU_TYPE_DATA, channel_id))
950 if (!rdp_write_share_data_header(rdp, s, length - sec_bytes, type, rdp->settings->ShareId))
952 Stream_SetPosition(s, sec_hold);
954 if (!rdp_security_stream_out(rdp, s, length, sec_flags, &pad))
958 Stream_SetPosition(s, length);
959 Stream_SealLength(s);
960 WLog_Print(rdp->log, WLOG_DEBUG,
961 "sending data (type=0x%x size=%" PRIuz
" channelId=%" PRIu16
")", type,
962 Stream_Length(s), channel_id);
965 if (transport_write(rdp->transport, s) < 0)
970 if (should_unlock && !security_unlock(rdp))
976BOOL rdp_send_message_channel_pdu(rdpRdp* rdp,
wStream* s, UINT16 sec_flags)
980 BOOL should_unlock = FALSE;
985 if (sec_flags & SEC_ENCRYPT)
987 if (!security_lock(rdp))
989 should_unlock = TRUE;
992 size_t length = Stream_GetPosition(s);
993 Stream_SetPosition(s, 0);
994 if (!rdp_write_header(rdp, s, length, rdp->mcs->messageChannelId, sec_flags))
997 if (!rdp_security_stream_out(rdp, s, length, sec_flags, &pad))
1001 Stream_SetPosition(s, length);
1002 Stream_SealLength(s);
1004 if (transport_write(rdp->transport, s) < 0)
1009 if (should_unlock && !security_unlock(rdp))
1015static BOOL rdp_recv_server_shutdown_denied_pdu(WINPR_ATTR_UNUSED rdpRdp* rdp,
1021static BOOL rdp_recv_server_set_keyboard_indicators_pdu(rdpRdp* rdp,
wStream* s)
1026 rdpContext* context = rdp->context;
1027 WINPR_ASSERT(context);
1028 WINPR_ASSERT(context->update);
1030 if (!Stream_CheckAndLogRequiredLengthWLog(rdp->log, s, 4))
1033 const uint16_t unitId = Stream_Get_UINT16(s);
1036 WLog_Print(rdp->log, WLOG_WARN,
1037 "[MS-RDPBCGR] 2.2.8.2.1.1 Set Keyboard Indicators PDU Data "
1038 "(TS_SET_KEYBOARD_INDICATORS_PDU)::unitId should be 0, is %" PRIu8,
1041 const UINT16 ledFlags = Stream_Get_UINT16(s);
1042 return IFCALLRESULT(TRUE, context->update->SetKeyboardIndicators, context, ledFlags);
1045static BOOL rdp_recv_server_set_keyboard_ime_status_pdu(rdpRdp* rdp,
wStream* s)
1047 if (!rdp || !rdp->input)
1050 if (!Stream_CheckAndLogRequiredLengthWLog(rdp->log, s, 10))
1053 const uint16_t unitId = Stream_Get_UINT16(s);
1056 WLog_Print(rdp->log, WLOG_WARN,
1057 "[MS-RDPBCGR] 2.2.8.2.2.1 Set Keyboard IME Status PDU Data "
1058 "(TS_SET_KEYBOARD_IME_STATUS_PDU)::unitId should be 0, is %" PRIu8,
1061 const uint32_t imeState = Stream_Get_UINT32(s);
1062 const uint32_t imeConvMode = Stream_Get_UINT32(s);
1063 return IFCALLRESULT(TRUE, rdp->update->SetKeyboardImeStatus, rdp->context, unitId, imeState,
1067static BOOL rdp_recv_set_error_info_data_pdu(rdpRdp* rdp,
wStream* s)
1069 UINT32 errorInfo = 0;
1071 if (!Stream_CheckAndLogRequiredLengthWLog(rdp->log, s, 4))
1074 Stream_Read_UINT32(s, errorInfo);
1075 return rdp_set_error_info(rdp, errorInfo);
1078static BOOL rdp_recv_server_auto_reconnect_status_pdu(rdpRdp* rdp,
wStream* s)
1080 UINT32 arcStatus = 0;
1082 if (!Stream_CheckAndLogRequiredLengthWLog(rdp->log, s, 4))
1085 Stream_Read_UINT32(s, arcStatus);
1086 WLog_Print(rdp->log, WLOG_WARN,
"AutoReconnectStatus: 0x%08" PRIX32
"", arcStatus);
1090static BOOL rdp_recv_server_status_info_pdu(rdpRdp* rdp,
wStream* s)
1092 UINT32 statusCode = 0;
1094 if (!Stream_CheckAndLogRequiredLengthWLog(rdp->log, s, 4))
1097 Stream_Read_UINT32(s, statusCode);
1099 if (rdp->update->ServerStatusInfo)
1100 return rdp->update->ServerStatusInfo(rdp->context, statusCode);
1105static BOOL rdp_recv_monitor_layout_pdu(rdpRdp* rdp,
wStream* s)
1107 UINT32 monitorCount = 0;
1112 if (!Stream_CheckAndLogRequiredLengthWLog(rdp->log, s, 4))
1115 Stream_Read_UINT32(s, monitorCount);
1117 if (!Stream_CheckAndLogRequiredLengthOfSizeWLog(rdp->log, s, monitorCount, 20ull))
1122 if (!monitorDefArray)
1125 for (UINT32 index = 0; index < monitorCount; index++)
1128 Stream_Read_INT32(s, monitor->left);
1129 Stream_Read_INT32(s, monitor->top);
1130 Stream_Read_INT32(s, monitor->right);
1131 Stream_Read_INT32(s, monitor->bottom);
1132 Stream_Read_UINT32(s, monitor->flags);
1135 IFCALLRET(rdp->update->RemoteMonitors, ret, rdp->context, monitorCount, monitorDefArray);
1136 free(monitorDefArray);
1139 return rdp_set_monitor_layout_pdu_state(rdp, TRUE);
1142state_run_t rdp_recv_data_pdu(rdpRdp* rdp,
wStream* s)
1148 BYTE compressedType = 0;
1149 UINT16 compressedLength = 0;
1152 if (!rdp_read_share_data_header(rdp, s, &length, &type, &shareId, &compressedType,
1155 WLog_Print(rdp->log, WLOG_ERROR,
"rdp_read_share_data_header() failed");
1156 return STATE_RUN_FAILED;
1161 if (compressedType & PACKET_COMPRESSED)
1163 if (compressedLength < 18)
1165 WLog_Print(rdp->log, WLOG_ERROR,
1166 "bulk_decompress: not enough bytes for compressedLength %" PRIu16
"",
1168 return STATE_RUN_FAILED;
1172 const BYTE* pDstData = NULL;
1173 UINT16 SrcSize = compressedLength - 18;
1175 if (!Stream_CheckAndLogRequiredLengthWLog(rdp->log, s, SrcSize))
1177 WLog_Print(rdp->log, WLOG_ERROR,
1178 "bulk_decompress: not enough bytes for compressedLength %" PRIu16
"",
1180 return STATE_RUN_FAILED;
1183 if (bulk_decompress(rdp->bulk, Stream_ConstPointer(s), SrcSize, &pDstData, &DstSize,
1186 cs = transport_take_from_pool(rdp->transport, DstSize);
1189 WLog_Print(rdp->log, WLOG_ERROR,
"Couldn't take stream from pool");
1190 return STATE_RUN_FAILED;
1193 Stream_SetPosition(cs, 0);
1194 Stream_Write(cs, pDstData, DstSize);
1195 Stream_SealLength(cs);
1196 Stream_SetPosition(cs, 0);
1200 WLog_Print(rdp->log, WLOG_ERROR,
"bulk_decompress() failed");
1201 return STATE_RUN_FAILED;
1204 Stream_Seek(s, SrcSize);
1207 WLog_Print(rdp->log, WLOG_DEBUG,
"recv %s Data PDU (0x%02" PRIX8
"), length: %" PRIu16
"",
1208 data_pdu_type_to_string(type), type, length);
1212 case DATA_PDU_TYPE_UPDATE:
1213 if (!update_recv(rdp->update, cs))
1215 WLog_Print(rdp->log, WLOG_ERROR,
"DATA_PDU_TYPE_UPDATE - update_recv() failed");
1221 case DATA_PDU_TYPE_CONTROL:
1222 if (!rdp_recv_server_control_pdu(rdp, cs))
1224 WLog_Print(rdp->log, WLOG_ERROR,
1225 "DATA_PDU_TYPE_CONTROL - rdp_recv_server_control_pdu() failed");
1231 case DATA_PDU_TYPE_POINTER:
1232 if (!update_recv_pointer(rdp->update, cs))
1234 WLog_Print(rdp->log, WLOG_ERROR,
1235 "DATA_PDU_TYPE_POINTER - update_recv_pointer() failed");
1241 case DATA_PDU_TYPE_SYNCHRONIZE:
1242 if (!rdp_recv_server_synchronize_pdu(rdp, cs))
1244 WLog_Print(rdp->log, WLOG_ERROR,
1245 "DATA_PDU_TYPE_SYNCHRONIZE - rdp_recv_synchronize_pdu() failed");
1251 case DATA_PDU_TYPE_PLAY_SOUND:
1252 if (!update_recv_play_sound(rdp->update, cs))
1254 WLog_Print(rdp->log, WLOG_ERROR,
1255 "DATA_PDU_TYPE_PLAY_SOUND - update_recv_play_sound() failed");
1261 case DATA_PDU_TYPE_SHUTDOWN_DENIED:
1262 if (!rdp_recv_server_shutdown_denied_pdu(rdp, cs))
1265 rdp->log, WLOG_ERROR,
1266 "DATA_PDU_TYPE_SHUTDOWN_DENIED - rdp_recv_server_shutdown_denied_pdu() failed");
1272 case DATA_PDU_TYPE_SAVE_SESSION_INFO:
1273 if (!rdp_recv_save_session_info(rdp, cs))
1275 WLog_Print(rdp->log, WLOG_ERROR,
1276 "DATA_PDU_TYPE_SAVE_SESSION_INFO - rdp_recv_save_session_info() failed");
1282 case DATA_PDU_TYPE_FONT_MAP:
1283 if (!rdp_recv_font_map_pdu(rdp, cs))
1285 WLog_Print(rdp->log, WLOG_ERROR,
1286 "DATA_PDU_TYPE_FONT_MAP - rdp_recv_font_map_pdu() failed");
1292 case DATA_PDU_TYPE_SET_KEYBOARD_INDICATORS:
1293 if (!rdp_recv_server_set_keyboard_indicators_pdu(rdp, cs))
1295 WLog_Print(rdp->log, WLOG_ERROR,
1296 "DATA_PDU_TYPE_SET_KEYBOARD_INDICATORS - "
1297 "rdp_recv_server_set_keyboard_indicators_pdu() failed");
1303 case DATA_PDU_TYPE_SET_KEYBOARD_IME_STATUS:
1304 if (!rdp_recv_server_set_keyboard_ime_status_pdu(rdp, cs))
1306 WLog_Print(rdp->log, WLOG_ERROR,
1307 "DATA_PDU_TYPE_SET_KEYBOARD_IME_STATUS - "
1308 "rdp_recv_server_set_keyboard_ime_status_pdu() failed");
1314 case DATA_PDU_TYPE_SET_ERROR_INFO:
1315 if (!rdp_recv_set_error_info_data_pdu(rdp, cs))
1318 rdp->log, WLOG_ERROR,
1319 "DATA_PDU_TYPE_SET_ERROR_INFO - rdp_recv_set_error_info_data_pdu() failed");
1325 case DATA_PDU_TYPE_ARC_STATUS:
1326 if (!rdp_recv_server_auto_reconnect_status_pdu(rdp, cs))
1328 WLog_Print(rdp->log, WLOG_ERROR,
1329 "DATA_PDU_TYPE_ARC_STATUS - "
1330 "rdp_recv_server_auto_reconnect_status_pdu() failed");
1336 case DATA_PDU_TYPE_STATUS_INFO:
1337 if (!rdp_recv_server_status_info_pdu(rdp, cs))
1339 WLog_Print(rdp->log, WLOG_ERROR,
1340 "DATA_PDU_TYPE_STATUS_INFO - rdp_recv_server_status_info_pdu() failed");
1346 case DATA_PDU_TYPE_MONITOR_LAYOUT:
1347 if (!rdp_recv_monitor_layout_pdu(rdp, cs))
1349 WLog_Print(rdp->log, WLOG_ERROR,
1350 "DATA_PDU_TYPE_MONITOR_LAYOUT - rdp_recv_monitor_layout_pdu() failed");
1357 WLog_Print(rdp->log, WLOG_WARN,
1358 "[UNHANDLED] %s Data PDU (0x%02" PRIX8
"), length: %" PRIu16
"",
1359 data_pdu_type_to_string(type), type, length);
1366 return STATE_RUN_SUCCESS;
1372 return STATE_RUN_FAILED;
1375state_run_t rdp_recv_message_channel_pdu(rdpRdp* rdp,
wStream* s, UINT16 securityFlags)
1380 if (securityFlags & SEC_AUTODETECT_REQ)
1383 return autodetect_recv_request_packet(rdp->autodetect, RDP_TRANSPORT_TCP, s);
1386 if (securityFlags & SEC_AUTODETECT_RSP)
1389 return autodetect_recv_response_packet(rdp->autodetect, RDP_TRANSPORT_TCP, s);
1392 if (securityFlags & SEC_HEARTBEAT)
1395 return rdp_recv_heartbeat_packet(rdp, s);
1398 if (securityFlags & SEC_TRANSPORT_REQ)
1400 return multitransport_recv_request(rdp->multitransport, s);
1403 if (securityFlags & SEC_TRANSPORT_RSP)
1405 return multitransport_recv_response(rdp->multitransport, s);
1408 if (securityFlags & SEC_LICENSE_PKT)
1410 return license_recv(rdp->license, s);
1413 if (securityFlags & SEC_LICENSE_ENCRYPT_CS)
1415 return license_recv(rdp->license, s);
1418 if (securityFlags & SEC_LICENSE_ENCRYPT_SC)
1420 return license_recv(rdp->license, s);
1423 return STATE_RUN_SUCCESS;
1426state_run_t rdp_recv_out_of_sequence_pdu(rdpRdp* rdp,
wStream* s, UINT16 pduType, UINT16 length)
1428 state_run_t rc = STATE_RUN_FAILED;
1434 rc = rdp_recv_data_pdu(rdp, s);
1436 case PDU_TYPE_SERVER_REDIRECTION:
1437 rc = rdp_recv_enhanced_security_redirection_packet(rdp, s);
1439 case PDU_TYPE_FLOW_RESPONSE:
1440 case PDU_TYPE_FLOW_STOP:
1441 case PDU_TYPE_FLOW_TEST:
1442 rc = STATE_RUN_SUCCESS;
1446 char buffer1[256] = { 0 };
1447 char buffer2[256] = { 0 };
1449 WLog_Print(rdp->log, WLOG_ERROR,
"expected %s, got %s",
1450 pdu_type_to_str(PDU_TYPE_DEMAND_ACTIVE, buffer1,
sizeof(buffer1)),
1451 pdu_type_to_str(pduType, buffer2,
sizeof(buffer2)));
1452 rc = STATE_RUN_FAILED;
1457 if (!tpkt_ensure_stream_consumed(rdp->log, s, length))
1458 return STATE_RUN_FAILED;
1462BOOL rdp_read_flow_control_pdu(rdpRdp* rdp,
wStream* s, UINT16* type, UINT16* channel_id)
1476 WINPR_ASSERT(channel_id);
1478 if (!Stream_CheckAndLogRequiredLengthWLog(rdp->log, s, 6))
1480 Stream_Read_UINT8(s, pduType);
1482 Stream_Seek_UINT8(s);
1483 Stream_Seek_UINT8(s);
1484 Stream_Seek_UINT8(s);
1485 Stream_Read_UINT16(s, *channel_id);
1500BOOL rdp_decrypt(rdpRdp* rdp,
wStream* s, UINT16* pLength, UINT16 securityFlags)
1503 BYTE cmac[8] = { 0 };
1504 BYTE wmac[8] = { 0 };
1505 BOOL status = FALSE;
1508 WINPR_ASSERT(rdp->settings);
1510 WINPR_ASSERT(pLength);
1512 if (!security_lock(rdp))
1515 INT32 length = *pLength;
1516 if (rdp->settings->EncryptionMethods == ENCRYPTION_METHOD_NONE)
1519 if (rdp->settings->EncryptionMethods == ENCRYPTION_METHOD_FIPS)
1521 if (!Stream_CheckAndLogRequiredLengthWLog(rdp->log, s, 12))
1525 Stream_Read_UINT16(s, len);
1527 WLog_Print(rdp->log, WLOG_WARN,
"ENCRYPTION_METHOD_FIPS length %" PRIu16
" != 0x10",
1531 Stream_Read_UINT8(s, version);
1533 WLog_Print(rdp->log, WLOG_WARN,
"ENCRYPTION_METHOD_FIPS version %" PRIu16
" != 1",
1537 Stream_Read_UINT8(s, pad);
1538 const BYTE* sig = Stream_ConstPointer(s);
1541 const INT32 padLength = length - pad;
1543 if ((length <= 0) || (padLength <= 0) || (padLength > UINT16_MAX))
1545 WLog_Print(rdp->log, WLOG_ERROR,
"FATAL: invalid pad length %" PRId32, padLength);
1549 if (!security_fips_decrypt(Stream_Pointer(s), (
size_t)length, rdp))
1552 if (!security_fips_check_signature(Stream_ConstPointer(s), (
size_t)padLength, sig, 8, rdp))
1555 Stream_SetLength(s, Stream_Length(s) - pad);
1556 *pLength = (UINT16)padLength;
1560 if (!Stream_CheckAndLogRequiredLengthWLog(rdp->log, s,
sizeof(wmac)))
1563 Stream_Read(s, wmac,
sizeof(wmac));
1564 length -=
sizeof(wmac);
1568 WLog_Print(rdp->log, WLOG_ERROR,
"FATAL: invalid length field");
1572 if (!security_decrypt(Stream_PointerAs(s, BYTE), (
size_t)length, rdp))
1575 if (securityFlags & SEC_SECURE_CHECKSUM)
1576 status = security_salted_mac_signature(rdp, Stream_ConstPointer(s), (UINT32)length,
1577 FALSE, cmac,
sizeof(cmac));
1579 status = security_mac_signature(rdp, Stream_ConstPointer(s), (UINT32)length, cmac,
1585 if (memcmp(wmac, cmac,
sizeof(wmac)) != 0)
1587 WLog_Print(rdp->log, WLOG_ERROR,
"WARNING: invalid packet signature");
1598 *pLength = (UINT16)length;
1602 if (!security_unlock(rdp))
1607const char* pdu_type_to_str(UINT16 pduType,
char* buffer,
size_t length)
1609 const char* str = NULL;
1612 case PDU_TYPE_DEMAND_ACTIVE:
1613 str =
"PDU_TYPE_DEMAND_ACTIVE";
1615 case PDU_TYPE_CONFIRM_ACTIVE:
1616 str =
"PDU_TYPE_CONFIRM_ACTIVE";
1618 case PDU_TYPE_DEACTIVATE_ALL:
1619 str =
"PDU_TYPE_DEACTIVATE_ALL";
1622 str =
"PDU_TYPE_DATA";
1624 case PDU_TYPE_SERVER_REDIRECTION:
1625 str =
"PDU_TYPE_SERVER_REDIRECTION";
1627 case PDU_TYPE_FLOW_TEST:
1628 str =
"PDU_TYPE_FLOW_TEST";
1630 case PDU_TYPE_FLOW_RESPONSE:
1631 str =
"PDU_TYPE_FLOW_RESPONSE";
1633 case PDU_TYPE_FLOW_STOP:
1634 str =
"PDU_TYPE_FLOW_STOP";
1637 str =
"PDU_TYPE_UNKNOWN";
1641 winpr_str_append(str, buffer, length,
"");
1643 char msg[32] = { 0 };
1644 (void)_snprintf(msg,
sizeof(msg),
"[0x%08" PRIx32
"]", pduType);
1645 winpr_str_append(msg, buffer, length,
"");
1656static state_run_t rdp_recv_tpkt_pdu(rdpRdp* rdp,
wStream* s)
1658 state_run_t rc = STATE_RUN_SUCCESS;
1661 UINT16 pduSource = 0;
1662 UINT16 channelId = 0;
1663 UINT16 securityFlags = 0;
1666 WINPR_ASSERT(rdp->context);
1669 freerdp* instance = rdp->context->instance;
1670 WINPR_ASSERT(instance);
1672 if (!rdp_read_header(rdp, s, &length, &channelId))
1673 return STATE_RUN_FAILED;
1675 if (freerdp_shall_disconnect_context(rdp->context))
1676 return STATE_RUN_SUCCESS;
1678 if (rdp->autodetect->bandwidthMeasureStarted)
1680 rdp->autodetect->bandwidthMeasureByteCount += length;
1683 if (rdp->mcs->messageChannelId && (channelId == rdp->mcs->messageChannelId))
1686 return rdp_handle_message_channel(rdp, s, channelId, length);
1689 if (rdp->settings->UseRdpSecurityLayer)
1691 if (!rdp_read_security_header(rdp, s, &securityFlags, &length))
1692 return STATE_RUN_FAILED;
1694 if (securityFlags & (SEC_ENCRYPT | SEC_REDIRECTION_PKT))
1696 if (!rdp_decrypt(rdp, s, &length, securityFlags))
1697 return STATE_RUN_FAILED;
1700 if (securityFlags & SEC_REDIRECTION_PKT)
1706 Stream_Rewind(s, 2);
1709 rc = rdp_recv_enhanced_security_redirection_packet(rdp, s);
1714 if (channelId == MCS_GLOBAL_CHANNEL_ID)
1716 while (Stream_GetRemainingLength(s) > 3)
1723 if (!rdp_read_share_control_header(rdp, s, NULL, &remain, &pduType, &pduSource))
1724 return STATE_RUN_FAILED;
1726 sub = Stream_StaticInit(&subbuffer, Stream_Pointer(s), remain);
1727 if (!Stream_SafeSeek(s, remain))
1728 return STATE_RUN_FAILED;
1730 rdp->settings->PduSource = pduSource;
1736 rc = rdp_recv_data_pdu(rdp, sub);
1737 if (state_run_failed(rc))
1741 case PDU_TYPE_DEACTIVATE_ALL:
1742 if (!rdp_recv_deactivate_all(rdp, sub))
1744 WLog_Print(rdp->log, WLOG_ERROR,
1745 "rdp_recv_tpkt_pdu: rdp_recv_deactivate_all() fail");
1746 return STATE_RUN_FAILED;
1751 case PDU_TYPE_SERVER_REDIRECTION:
1752 return rdp_recv_enhanced_security_redirection_packet(rdp, sub);
1754 case PDU_TYPE_FLOW_RESPONSE:
1755 case PDU_TYPE_FLOW_STOP:
1756 case PDU_TYPE_FLOW_TEST:
1757 WLog_Print(rdp->log, WLOG_DEBUG,
"flow message 0x%04" PRIX16
"", pduType);
1759 if (!Stream_SafeSeek(sub, remain))
1760 return STATE_RUN_FAILED;
1765 char buffer[256] = { 0 };
1766 WLog_Print(rdp->log, WLOG_ERROR,
"incorrect PDU type: %s",
1767 pdu_type_to_str(pduType, buffer,
sizeof(buffer)));
1772 diff = Stream_GetRemainingLength(sub);
1775 char buffer[256] = { 0 };
1776 WLog_Print(rdp->log, WLOG_WARN,
1777 "pduType %s not properly parsed, %" PRIdz
1778 " bytes remaining unhandled. Skipping.",
1779 pdu_type_to_str(pduType, buffer,
sizeof(buffer)), diff);
1787 if (!freerdp_channel_process(instance, s, channelId, length))
1788 return STATE_RUN_FAILED;
1792 if (!tpkt_ensure_stream_consumed(rdp->log, s, length))
1793 return STATE_RUN_FAILED;
1797static state_run_t rdp_recv_fastpath_pdu(rdpRdp* rdp,
wStream* s)
1802 rdpFastPath* fastpath = rdp->fastpath;
1804 if (!fastpath_read_header_rdp(fastpath, s, &length))
1806 WLog_Print(rdp->log, WLOG_ERROR,
"rdp_recv_fastpath_pdu: fastpath_read_header_rdp() fail");
1807 return STATE_RUN_FAILED;
1810 if ((length == 0) || (!Stream_CheckAndLogRequiredLengthWLog(rdp->log, s, length)))
1812 WLog_Print(rdp->log, WLOG_ERROR,
"incorrect FastPath PDU header length %" PRIu16
"",
1814 return STATE_RUN_FAILED;
1817 if (rdp->autodetect->bandwidthMeasureStarted)
1819 rdp->autodetect->bandwidthMeasureByteCount += length;
1822 if (!fastpath_decrypt(fastpath, s, &length))
1823 return STATE_RUN_FAILED;
1825 return fastpath_recv_updates(rdp->fastpath, s);
1828static state_run_t rdp_recv_pdu(rdpRdp* rdp,
wStream* s)
1830 const int rc = tpkt_verify_header(s);
1832 return rdp_recv_tpkt_pdu(rdp, s);
1834 return rdp_recv_fastpath_pdu(rdp, s);
1836 return STATE_RUN_FAILED;
1839static state_run_t rdp_handle_sc_flags(rdpRdp* rdp,
wStream* s, UINT32 flag,
1840 CONNECTION_STATE nextState)
1842 const UINT32 mask = FINALIZE_SC_SYNCHRONIZE_PDU | FINALIZE_SC_CONTROL_COOPERATE_PDU |
1843 FINALIZE_SC_CONTROL_GRANTED_PDU | FINALIZE_SC_FONT_MAP_PDU;
1845 state_run_t status = rdp_recv_pdu(rdp, s);
1846 if (state_run_success(status))
1848 const UINT32 flags = rdp->finalize_sc_pdus & mask;
1849 if ((flags & flag) == flag)
1851 if (!rdp_client_transition_to_state(rdp, nextState))
1852 status = STATE_RUN_FAILED;
1854 status = STATE_RUN_SUCCESS;
1858 char flag_buffer[256] = { 0 };
1859 char mask_buffer[256] = { 0 };
1860 WLog_Print(rdp->log, WLOG_WARN,
1861 "[%s] unexpected server message, expected flag %s [have %s]",
1862 rdp_get_state_string(rdp),
1863 rdp_finalize_flags_to_str(flag, flag_buffer,
sizeof(flag_buffer)),
1864 rdp_finalize_flags_to_str(flags, mask_buffer,
sizeof(mask_buffer)));
1870static state_run_t rdp_client_exchange_monitor_layout(rdpRdp* rdp,
wStream* s)
1874 if (!rdp_check_monitor_layout_pdu_state(rdp, FALSE))
1880 const UINT32 old = rdp->finalize_sc_pdus;
1881 state_run_t status = rdp_recv_pdu(rdp, s);
1882 const UINT32 now = rdp->finalize_sc_pdus;
1883 const BOOL changed = (old != now) || rdp->monitor_layout_pdu;
1886 if (state_run_success(status) && changed)
1888 if (!rdp->monitor_layout_pdu)
1890 if (!rdp_finalize_is_flag_set(rdp, FINALIZE_SC_SYNCHRONIZE_PDU))
1891 return STATE_RUN_FAILED;
1894 status = rdp_client_connect_finalize(rdp);
1895 if (state_run_success(status) && !rdp->monitor_layout_pdu)
1896 status = STATE_RUN_TRY_AGAIN;
1901static state_run_t rdp_recv_callback_int(WINPR_ATTR_UNUSED rdpTransport* transport,
wStream* s,
1904 state_run_t status = STATE_RUN_SUCCESS;
1905 rdpRdp* rdp = (rdpRdp*)extra;
1907 WINPR_ASSERT(transport);
1911 switch (rdp_get_state(rdp))
1913 case CONNECTION_STATE_NEGO:
1914 if (!rdp_client_transition_to_state(rdp, CONNECTION_STATE_MCS_CREATE_REQUEST))
1915 status = STATE_RUN_FAILED;
1917 status = STATE_RUN_CONTINUE;
1919 case CONNECTION_STATE_NLA:
1920 if (nla_get_state(rdp->nla) < NLA_STATE_AUTH_INFO)
1922 if (nla_recv_pdu(rdp->nla, s) < 1)
1924 WLog_Print(rdp->log, WLOG_ERROR,
"%s - nla_recv_pdu() fail",
1925 rdp_get_state_string(rdp));
1926 status = STATE_RUN_FAILED;
1929 else if (nla_get_state(rdp->nla) == NLA_STATE_POST_NEGO)
1931 nego_recv(rdp->transport, s, (
void*)rdp->nego);
1933 if (!nego_update_settings_from_state(rdp->nego, rdp->settings))
1936 if (nego_get_state(rdp->nego) != NEGO_STATE_FINAL)
1938 WLog_Print(rdp->log, WLOG_ERROR,
"%s - nego_recv() fail",
1939 rdp_get_state_string(rdp));
1940 status = STATE_RUN_FAILED;
1942 else if (!nla_set_state(rdp->nla, NLA_STATE_FINAL))
1943 status = STATE_RUN_FAILED;
1946 if (state_run_success(status))
1948 if (nla_get_state(rdp->nla) == NLA_STATE_AUTH_INFO)
1950 transport_set_nla_mode(rdp->transport, FALSE);
1952 if (rdp->settings->VmConnectMode)
1954 if (!nego_set_state(rdp->nego, NEGO_STATE_NLA))
1955 status = STATE_RUN_FAILED;
1956 else if (!nego_set_requested_protocols(rdp->nego,
1957 PROTOCOL_HYBRID | PROTOCOL_SSL))
1958 status = STATE_RUN_FAILED;
1959 else if (!nego_send_negotiation_request(rdp->nego))
1960 status = STATE_RUN_FAILED;
1961 else if (!nla_set_state(rdp->nla, NLA_STATE_POST_NEGO))
1962 status = STATE_RUN_FAILED;
1966 if (!nla_set_state(rdp->nla, NLA_STATE_FINAL))
1967 status = STATE_RUN_FAILED;
1971 if (state_run_success(status))
1974 if (nla_get_state(rdp->nla) == NLA_STATE_FINAL)
1976 if (!rdp_client_transition_to_state(rdp, CONNECTION_STATE_MCS_CREATE_REQUEST))
1977 status = STATE_RUN_FAILED;
1979 status = STATE_RUN_CONTINUE;
1984 case CONNECTION_STATE_AAD:
1985 if (aad_recv(rdp->aad, s) < 1)
1987 WLog_Print(rdp->log, WLOG_ERROR,
"%s - aad_recv() fail", rdp_get_state_string(rdp));
1988 status = STATE_RUN_FAILED;
1990 if (state_run_success(status))
1992 if (aad_get_state(rdp->aad) == AAD_STATE_FINAL)
1994 transport_set_aad_mode(rdp->transport, FALSE);
1995 if (!rdp_client_transition_to_state(rdp, CONNECTION_STATE_MCS_CREATE_REQUEST))
1996 status = STATE_RUN_FAILED;
1998 status = STATE_RUN_CONTINUE;
2003 case CONNECTION_STATE_MCS_CREATE_REQUEST:
2004 if (!mcs_client_begin(rdp->mcs))
2006 WLog_Print(rdp->log, WLOG_ERROR,
"%s - mcs_client_begin() fail",
2007 rdp_get_state_string(rdp));
2008 status = STATE_RUN_FAILED;
2010 else if (!rdp_client_transition_to_state(rdp, CONNECTION_STATE_MCS_CREATE_RESPONSE))
2011 status = STATE_RUN_FAILED;
2012 else if (Stream_GetRemainingLength(s) > 0)
2013 status = STATE_RUN_CONTINUE;
2016 case CONNECTION_STATE_MCS_CREATE_RESPONSE:
2017 if (!mcs_recv_connect_response(rdp->mcs, s))
2019 WLog_Print(rdp->log, WLOG_ERROR,
"mcs_recv_connect_response failure");
2020 status = STATE_RUN_FAILED;
2024 if (!rdp_client_transition_to_state(rdp, CONNECTION_STATE_MCS_ERECT_DOMAIN))
2025 status = STATE_RUN_FAILED;
2026 else if (!mcs_send_erect_domain_request(rdp->mcs))
2028 WLog_Print(rdp->log, WLOG_ERROR,
"mcs_send_erect_domain_request failure");
2029 status = STATE_RUN_FAILED;
2031 else if (!rdp_client_transition_to_state(rdp, CONNECTION_STATE_MCS_ATTACH_USER))
2032 status = STATE_RUN_FAILED;
2033 else if (!mcs_send_attach_user_request(rdp->mcs))
2035 WLog_Print(rdp->log, WLOG_ERROR,
"mcs_send_attach_user_request failure");
2036 status = STATE_RUN_FAILED;
2038 else if (!rdp_client_transition_to_state(rdp,
2039 CONNECTION_STATE_MCS_ATTACH_USER_CONFIRM))
2040 status = STATE_RUN_FAILED;
2044 case CONNECTION_STATE_MCS_ATTACH_USER_CONFIRM:
2045 if (!mcs_recv_attach_user_confirm(rdp->mcs, s))
2047 WLog_Print(rdp->log, WLOG_ERROR,
"mcs_recv_attach_user_confirm failure");
2048 status = STATE_RUN_FAILED;
2052 if (!rdp_client_transition_to_state(rdp, CONNECTION_STATE_MCS_CHANNEL_JOIN_REQUEST))
2053 status = STATE_RUN_FAILED;
2054 else if (!mcs_send_channel_join_request(rdp->mcs, rdp->mcs->userId))
2056 WLog_Print(rdp->log, WLOG_ERROR,
"mcs_send_channel_join_request failure");
2057 status = STATE_RUN_FAILED;
2059 else if (!rdp_client_transition_to_state(
2060 rdp, CONNECTION_STATE_MCS_CHANNEL_JOIN_RESPONSE))
2061 status = STATE_RUN_FAILED;
2066 if (!rdp_client_skip_mcs_channel_join(rdp))
2067 status = STATE_RUN_FAILED;
2071 case CONNECTION_STATE_MCS_CHANNEL_JOIN_RESPONSE:
2072 if (!rdp_client_connect_mcs_channel_join_confirm(rdp, s))
2074 WLog_Print(rdp->log, WLOG_ERROR,
2076 "rdp_client_connect_mcs_channel_join_confirm() fail",
2077 rdp_get_state_string(rdp));
2078 status = STATE_RUN_FAILED;
2083 case CONNECTION_STATE_CONNECT_TIME_AUTO_DETECT_REQUEST:
2084 if (!rdp_client_connect_auto_detect(rdp, s))
2086 if (!rdp_client_transition_to_state(rdp, CONNECTION_STATE_LICENSING))
2087 status = STATE_RUN_FAILED;
2089 status = STATE_RUN_TRY_AGAIN;
2093 case CONNECTION_STATE_LICENSING:
2094 status = rdp_client_connect_license(rdp, s);
2096 if (state_run_failed(status))
2098 char buffer[64] = { 0 };
2099 WLog_Print(rdp->log, WLOG_DEBUG,
"%s - rdp_client_connect_license() - %s",
2100 rdp_get_state_string(rdp),
2101 state_run_result_string(status, buffer, ARRAYSIZE(buffer)));
2106 case CONNECTION_STATE_MULTITRANSPORT_BOOTSTRAPPING_REQUEST:
2107 if (!rdp_client_connect_auto_detect(rdp, s))
2109 (void)rdp_client_transition_to_state(
2110 rdp, CONNECTION_STATE_CAPABILITIES_EXCHANGE_DEMAND_ACTIVE);
2111 status = STATE_RUN_TRY_AGAIN;
2115 case CONNECTION_STATE_CAPABILITIES_EXCHANGE_DEMAND_ACTIVE:
2116 status = rdp_client_connect_demand_active(rdp, s);
2118 if (state_run_failed(status))
2120 char buffer[64] = { 0 };
2121 WLog_Print(rdp->log, WLOG_DEBUG,
2123 "rdp_client_connect_demand_active() - %s",
2124 rdp_get_state_string(rdp),
2125 state_run_result_string(status, buffer, ARRAYSIZE(buffer)));
2127 else if (status == STATE_RUN_ACTIVE)
2129 if (!rdp_client_transition_to_state(
2130 rdp, CONNECTION_STATE_CAPABILITIES_EXCHANGE_CONFIRM_ACTIVE))
2131 status = STATE_RUN_FAILED;
2133 status = STATE_RUN_CONTINUE;
2137 case CONNECTION_STATE_CAPABILITIES_EXCHANGE_MONITOR_LAYOUT:
2138 status = rdp_client_exchange_monitor_layout(rdp, s);
2141 case CONNECTION_STATE_CAPABILITIES_EXCHANGE_CONFIRM_ACTIVE:
2142 status = rdp_client_connect_confirm_active(rdp, s);
2145 case CONNECTION_STATE_FINALIZATION_CLIENT_SYNC:
2146 status = rdp_handle_sc_flags(rdp, s, FINALIZE_SC_SYNCHRONIZE_PDU,
2147 CONNECTION_STATE_FINALIZATION_CLIENT_COOPERATE);
2149 case CONNECTION_STATE_FINALIZATION_CLIENT_COOPERATE:
2150 status = rdp_handle_sc_flags(rdp, s, FINALIZE_SC_CONTROL_COOPERATE_PDU,
2151 CONNECTION_STATE_FINALIZATION_CLIENT_GRANTED_CONTROL);
2153 case CONNECTION_STATE_FINALIZATION_CLIENT_GRANTED_CONTROL:
2154 status = rdp_handle_sc_flags(rdp, s, FINALIZE_SC_CONTROL_GRANTED_PDU,
2155 CONNECTION_STATE_FINALIZATION_CLIENT_FONT_MAP);
2157 case CONNECTION_STATE_FINALIZATION_CLIENT_FONT_MAP:
2158 status = rdp_handle_sc_flags(rdp, s, FINALIZE_SC_FONT_MAP_PDU, CONNECTION_STATE_ACTIVE);
2161 case CONNECTION_STATE_ACTIVE:
2162 status = rdp_recv_pdu(rdp, s);
2164 if (state_run_failed(status))
2166 char buffer[64] = { 0 };
2167 WLog_Print(rdp->log, WLOG_DEBUG,
"%s - rdp_recv_pdu() - %s",
2168 rdp_get_state_string(rdp),
2169 state_run_result_string(status, buffer, ARRAYSIZE(buffer)));
2174 WLog_Print(rdp->log, WLOG_ERROR,
"%s state %d", rdp_get_state_string(rdp),
2175 rdp_get_state(rdp));
2176 status = STATE_RUN_FAILED;
2180 if (state_run_failed(status))
2182 char buffer[64] = { 0 };
2183 WLog_Print(rdp->log, WLOG_ERROR,
"%s status %s", rdp_get_state_string(rdp),
2184 state_run_result_string(status, buffer, ARRAYSIZE(buffer)));
2189state_run_t rdp_recv_callback(rdpTransport* transport,
wStream* s,
void* extra)
2191 char buffer[64] = { 0 };
2192 state_run_t rc = STATE_RUN_FAILED;
2193 const size_t start = Stream_GetPosition(s);
2194 const rdpContext* context = transport_get_context(transport);
2196 WINPR_ASSERT(context);
2199 const rdpRdp* rdp = context->rdp;
2202 if (rc == STATE_RUN_TRY_AGAIN)
2203 Stream_SetPosition(s, start);
2205 const char* old = rdp_get_state_string(rdp);
2206 const size_t orem = Stream_GetRemainingLength(s);
2207 rc = rdp_recv_callback_int(transport, s, extra);
2209 const char* now = rdp_get_state_string(rdp);
2210 const size_t rem = Stream_GetRemainingLength(s);
2212 WLog_Print(rdp->log, WLOG_TRACE,
2213 "(client)[%s -> %s] current return %s [feeding %" PRIuz
" bytes, %" PRIuz
2214 " bytes not processed]",
2215 old, now, state_run_result_string(rc, buffer,
sizeof(buffer)), orem, rem);
2216 }
while ((rc == STATE_RUN_TRY_AGAIN) || (rc == STATE_RUN_CONTINUE));
2220BOOL rdp_send_channel_data(rdpRdp* rdp, UINT16 channelId,
const BYTE* data,
size_t size)
2222 return freerdp_channel_send(rdp, channelId, data, size);
2225BOOL rdp_channel_send_packet(rdpRdp* rdp, UINT16 channelId,
size_t totalSize, UINT32 flags,
2226 const BYTE* data,
size_t chunkSize)
2228 return freerdp_channel_send_packet(rdp, channelId, totalSize, flags, data, chunkSize);
2231BOOL rdp_send_error_info(rdpRdp* rdp)
2233 UINT16 sec_flags = 0;
2237 if (rdp->errorInfo == ERRINFO_SUCCESS)
2240 s = rdp_data_pdu_init(rdp, &sec_flags);
2245 Stream_Write_UINT32(s, rdp->errorInfo);
2246 status = rdp_send_data_pdu(rdp, s, DATA_PDU_TYPE_SET_ERROR_INFO, 0, sec_flags);
2250int rdp_check_fds(rdpRdp* rdp)
2254 rdpTransport* transport = NULL;
2257 transport = rdp->transport;
2259 tsg = transport_get_tsg(transport);
2262 if (!tsg_check_event_handles(tsg))
2264 WLog_Print(rdp->log, WLOG_ERROR,
"rdp_check_fds: tsg_check_event_handles()");
2268 if (tsg_get_state(tsg) != TSG_STATE_PIPE_CREATED)
2272 status = transport_check_fds(transport);
2276 if (!rdp_client_redirect(rdp))
2281 WLog_Print(rdp->log, WLOG_DEBUG,
"transport_check_fds() - %i", status);
2286BOOL freerdp_get_stats(rdpRdp* rdp, UINT64* inBytes, UINT64* outBytes, UINT64* inPackets,
2293 *inBytes = rdp->inBytes;
2295 *outBytes = rdp->outBytes;
2297 *inPackets = rdp->inPackets;
2299 *outPackets = rdp->outPackets;
2309rdpRdp* rdp_new(rdpContext* context)
2313 rdp = (rdpRdp*)calloc(1,
sizeof(rdpRdp));
2318 rdp->log = WLog_Get(RDP_TAG);
2319 WINPR_ASSERT(rdp->log);
2321 (void)_snprintf(rdp->log_context,
sizeof(rdp->log_context),
"%p", (
void*)context);
2322 WLog_SetContext(rdp->log, NULL, rdp->log_context);
2324 InitializeCriticalSection(&rdp->critical);
2325 rdp->context = context;
2326 WINPR_ASSERT(rdp->context);
2328 if (context->ServerMode)
2331 if (!context->settings)
2339 rdp->settings = context->settings;
2342 if (!rdp_set_backup_settings(rdp))
2345 rdp->settings->instance = context->instance;
2347 context->settings = rdp->settings;
2348 if (context->instance)
2349 context->settings->instance = context->instance;
2350 else if (context->peer)
2352 rdp->settings->instance = context->peer;
2354#if defined(WITH_FREERDP_DEPRECATED)
2355 context->peer->settings = rdp->settings;
2359 rdp->transport = transport_new(context);
2361 if (!rdp->transport)
2365 const rdpTransportIo* io = transport_get_io_callbacks(rdp->transport);
2368 rdp->io = calloc(1,
sizeof(rdpTransportIo));
2374 rdp->aad = aad_new(context, rdp->transport);
2378 rdp->license = license_new(rdp);
2383 rdp->input = input_new(rdp);
2388 rdp->update = update_new(rdp);
2393 rdp->fastpath = fastpath_new(rdp);
2398 rdp->nego = nego_new(rdp->transport);
2403 rdp->mcs = mcs_new(rdp->transport);
2408 rdp->redirection = redirection_new();
2410 if (!rdp->redirection)
2413 rdp->autodetect = autodetect_new(rdp->context);
2415 if (!rdp->autodetect)
2418 rdp->heartbeat = heartbeat_new();
2420 if (!rdp->heartbeat)
2423 rdp->multitransport = multitransport_new(rdp, INITIATE_REQUEST_PROTOCOL_UDPFECL |
2424 INITIATE_REQUEST_PROTOCOL_UDPFECR);
2426 if (!rdp->multitransport)
2429 rdp->bulk = bulk_new(context);
2434 rdp->pubSub = PubSub_New(TRUE);
2438 rdp->abortEvent = CreateEvent(NULL, TRUE, FALSE, NULL);
2439 if (!rdp->abortEvent)
2444 WINPR_PRAGMA_DIAG_PUSH
2445 WINPR_PRAGMA_DIAG_IGNORED_MISMATCHED_DEALLOC
2447 WINPR_PRAGMA_DIAG_POP
2451static void rdp_reset_free(rdpRdp* rdp)
2455 (void)security_lock(rdp);
2456 rdp_free_rc4_decrypt_keys(rdp);
2457 rdp_free_rc4_encrypt_keys(rdp);
2459 winpr_Cipher_Free(rdp->fips_encrypt);
2460 winpr_Cipher_Free(rdp->fips_decrypt);
2461 rdp->fips_encrypt = NULL;
2462 rdp->fips_decrypt = NULL;
2463 (void)security_unlock(rdp);
2466 nego_free(rdp->nego);
2467 license_free(rdp->license);
2468 transport_free(rdp->transport);
2469 fastpath_free(rdp->fastpath);
2473 rdp->license = NULL;
2474 rdp->transport = NULL;
2475 rdp->fastpath = NULL;
2478BOOL rdp_reset(rdpRdp* rdp)
2481 rdpContext* context = NULL;
2482 rdpSettings* settings = NULL;
2486 context = rdp->context;
2487 WINPR_ASSERT(context);
2489 settings = rdp->settings;
2490 WINPR_ASSERT(settings);
2492 bulk_reset(rdp->bulk);
2494 rdp_reset_free(rdp);
2509 rdp->transport = transport_new(context);
2510 if (!rdp->transport)
2515 if (!transport_set_io_callbacks(rdp->transport, rdp->io))
2520 rdp->aad = aad_new(context, rdp->transport);
2524 rdp->nego = nego_new(rdp->transport);
2528 rdp->mcs = mcs_new(rdp->transport);
2532 if (!transport_set_layer(rdp->transport, TRANSPORT_LAYER_TCP))
2535 rdp->license = license_new(rdp);
2539 rdp->fastpath = fastpath_new(rdp);
2544 rc = rdp_finalize_reset_flags(rdp, TRUE);
2555void rdp_free(rdpRdp* rdp)
2559 rdp_reset_free(rdp);
2565 input_free(rdp->input);
2566 update_free(rdp->update);
2568 redirection_free(rdp->redirection);
2569 autodetect_free(rdp->autodetect);
2570 heartbeat_free(rdp->heartbeat);
2571 multitransport_free(rdp->multitransport);
2572 bulk_free(rdp->bulk);
2574 PubSub_Free(rdp->pubSub);
2575 if (rdp->abortEvent)
2576 (void)CloseHandle(rdp->abortEvent);
2579 DeleteCriticalSection(&rdp->critical);
2584BOOL rdp_io_callback_set_event(rdpRdp* rdp, BOOL set)
2588 return transport_io_callback_set_event(rdp->transport, set);
2591const rdpTransportIo* rdp_get_io_callbacks(rdpRdp* rdp)
2598BOOL rdp_set_io_callbacks(rdpRdp* rdp,
const rdpTransportIo* io_callbacks)
2606 rdp->io = malloc(
sizeof(rdpTransportIo));
2609 *rdp->io = *io_callbacks;
2610 return transport_set_io_callbacks(rdp->transport, rdp->io);
2615BOOL rdp_set_io_callback_context(rdpRdp* rdp,
void* usercontext)
2618 rdp->ioContext = usercontext;
2622void* rdp_get_io_callback_context(rdpRdp* rdp)
2625 return rdp->ioContext;
2628const char* rdp_finalize_flags_to_str(UINT32 flags,
char* buffer,
size_t size)
2630 char number[32] = { 0 };
2632 (uint32_t)~(FINALIZE_SC_SYNCHRONIZE_PDU | FINALIZE_SC_CONTROL_COOPERATE_PDU |
2633 FINALIZE_SC_CONTROL_GRANTED_PDU | FINALIZE_SC_FONT_MAP_PDU |
2634 FINALIZE_CS_SYNCHRONIZE_PDU | FINALIZE_CS_CONTROL_COOPERATE_PDU |
2635 FINALIZE_CS_CONTROL_REQUEST_PDU | FINALIZE_CS_PERSISTENT_KEY_LIST_PDU |
2636 FINALIZE_CS_FONT_LIST_PDU | FINALIZE_DEACTIVATE_REACTIVATE);
2638 if (flags & FINALIZE_SC_SYNCHRONIZE_PDU)
2639 winpr_str_append(
"FINALIZE_SC_SYNCHRONIZE_PDU", buffer, size,
"|");
2640 if (flags & FINALIZE_SC_CONTROL_COOPERATE_PDU)
2641 winpr_str_append(
"FINALIZE_SC_CONTROL_COOPERATE_PDU", buffer, size,
"|");
2642 if (flags & FINALIZE_SC_CONTROL_GRANTED_PDU)
2643 winpr_str_append(
"FINALIZE_SC_CONTROL_GRANTED_PDU", buffer, size,
"|");
2644 if (flags & FINALIZE_SC_FONT_MAP_PDU)
2645 winpr_str_append(
"FINALIZE_SC_FONT_MAP_PDU", buffer, size,
"|");
2646 if (flags & FINALIZE_CS_SYNCHRONIZE_PDU)
2647 winpr_str_append(
"FINALIZE_CS_SYNCHRONIZE_PDU", buffer, size,
"|");
2648 if (flags & FINALIZE_CS_CONTROL_COOPERATE_PDU)
2649 winpr_str_append(
"FINALIZE_CS_CONTROL_COOPERATE_PDU", buffer, size,
"|");
2650 if (flags & FINALIZE_CS_CONTROL_REQUEST_PDU)
2651 winpr_str_append(
"FINALIZE_CS_CONTROL_REQUEST_PDU", buffer, size,
"|");
2652 if (flags & FINALIZE_CS_PERSISTENT_KEY_LIST_PDU)
2653 winpr_str_append(
"FINALIZE_CS_PERSISTENT_KEY_LIST_PDU", buffer, size,
"|");
2654 if (flags & FINALIZE_CS_FONT_LIST_PDU)
2655 winpr_str_append(
"FINALIZE_CS_FONT_LIST_PDU", buffer, size,
"|");
2656 if (flags & FINALIZE_DEACTIVATE_REACTIVATE)
2657 winpr_str_append(
"FINALIZE_DEACTIVATE_REACTIVATE", buffer, size,
"|");
2659 winpr_str_append(
"UNKNOWN_FLAG", buffer, size,
"|");
2661 winpr_str_append(
"NO_FLAG_SET", buffer, size,
"|");
2662 (void)_snprintf(number,
sizeof(number),
" [0x%08" PRIx32
"]", flags);
2663 winpr_str_append(number, buffer, size,
"");
2667BOOL rdp_finalize_reset_flags(rdpRdp* rdp, BOOL clearAll)
2670 WLog_Print(rdp->log, WLOG_DEBUG,
"[%s] reset finalize_sc_pdus", rdp_get_state_string(rdp));
2672 rdp->finalize_sc_pdus = 0;
2674 rdp->finalize_sc_pdus &= FINALIZE_DEACTIVATE_REACTIVATE;
2676 return rdp_set_monitor_layout_pdu_state(rdp, FALSE);
2679BOOL rdp_finalize_set_flag(rdpRdp* rdp, UINT32 flag)
2681 char buffer[1024] = { 0 };
2685 WLog_Print(rdp->log, WLOG_DEBUG,
"[%s] received flag %s", rdp_get_state_string(rdp),
2686 rdp_finalize_flags_to_str(flag, buffer,
sizeof(buffer)));
2687 rdp->finalize_sc_pdus |= flag;
2691BOOL rdp_finalize_is_flag_set(rdpRdp* rdp, UINT32 flag)
2694 return (rdp->finalize_sc_pdus & flag) == flag;
2697BOOL rdp_reset_rc4_encrypt_keys(rdpRdp* rdp)
2700 rdp_free_rc4_encrypt_keys(rdp);
2701 rdp->rc4_encrypt_key = winpr_RC4_New(rdp->encrypt_key, rdp->rc4_key_len);
2703 rdp->encrypt_use_count = 0;
2704 return rdp->rc4_encrypt_key != NULL;
2707void rdp_free_rc4_encrypt_keys(rdpRdp* rdp)
2710 winpr_RC4_Free(rdp->rc4_encrypt_key);
2711 rdp->rc4_encrypt_key = NULL;
2714void rdp_free_rc4_decrypt_keys(rdpRdp* rdp)
2717 winpr_RC4_Free(rdp->rc4_decrypt_key);
2718 rdp->rc4_decrypt_key = NULL;
2721BOOL rdp_reset_rc4_decrypt_keys(rdpRdp* rdp)
2724 rdp_free_rc4_decrypt_keys(rdp);
2725 rdp->rc4_decrypt_key = winpr_RC4_New(rdp->decrypt_key, rdp->rc4_key_len);
2727 rdp->decrypt_use_count = 0;
2728 return rdp->rc4_decrypt_key != NULL;
2731const char* rdp_security_flag_string(UINT32 securityFlags,
char* buffer,
size_t size)
2733 if (securityFlags & SEC_EXCHANGE_PKT)
2734 winpr_str_append(
"SEC_EXCHANGE_PKT", buffer, size,
"|");
2735 if (securityFlags & SEC_TRANSPORT_REQ)
2736 winpr_str_append(
"SEC_TRANSPORT_REQ", buffer, size,
"|");
2737 if (securityFlags & SEC_TRANSPORT_RSP)
2738 winpr_str_append(
"SEC_TRANSPORT_RSP", buffer, size,
"|");
2739 if (securityFlags & SEC_ENCRYPT)
2740 winpr_str_append(
"SEC_ENCRYPT", buffer, size,
"|");
2741 if (securityFlags & SEC_RESET_SEQNO)
2742 winpr_str_append(
"SEC_RESET_SEQNO", buffer, size,
"|");
2743 if (securityFlags & SEC_IGNORE_SEQNO)
2744 winpr_str_append(
"SEC_IGNORE_SEQNO", buffer, size,
"|");
2745 if (securityFlags & SEC_INFO_PKT)
2746 winpr_str_append(
"SEC_INFO_PKT", buffer, size,
"|");
2747 if (securityFlags & SEC_LICENSE_PKT)
2748 winpr_str_append(
"SEC_LICENSE_PKT", buffer, size,
"|");
2749 if (securityFlags & SEC_LICENSE_ENCRYPT_CS)
2750 winpr_str_append(
"SEC_LICENSE_ENCRYPT_CS", buffer, size,
"|");
2751 if (securityFlags & SEC_LICENSE_ENCRYPT_SC)
2752 winpr_str_append(
"SEC_LICENSE_ENCRYPT_SC", buffer, size,
"|");
2753 if (securityFlags & SEC_REDIRECTION_PKT)
2754 winpr_str_append(
"SEC_REDIRECTION_PKT", buffer, size,
"|");
2755 if (securityFlags & SEC_SECURE_CHECKSUM)
2756 winpr_str_append(
"SEC_SECURE_CHECKSUM", buffer, size,
"|");
2757 if (securityFlags & SEC_AUTODETECT_REQ)
2758 winpr_str_append(
"SEC_AUTODETECT_REQ", buffer, size,
"|");
2759 if (securityFlags & SEC_AUTODETECT_RSP)
2760 winpr_str_append(
"SEC_AUTODETECT_RSP", buffer, size,
"|");
2761 if (securityFlags & SEC_HEARTBEAT)
2762 winpr_str_append(
"SEC_HEARTBEAT", buffer, size,
"|");
2763 if (securityFlags & SEC_FLAGSHI_VALID)
2764 winpr_str_append(
"SEC_FLAGSHI_VALID", buffer, size,
"|");
2766 char msg[32] = { 0 };
2768 (void)_snprintf(msg,
sizeof(msg),
"[0x%08" PRIx32
"]", securityFlags);
2769 winpr_str_append(msg, buffer, size,
"");
2774static BOOL rdp_reset_remote_settings(rdpRdp* rdp)
2776 UINT32 flags = FREERDP_SETTINGS_REMOTE_MODE;
2783 return rdp->remoteSettings != NULL;
2786BOOL rdp_set_backup_settings(rdpRdp* rdp)
2791 if (!rdp->originalSettings)
2793 return rdp_reset_remote_settings(rdp);
2796BOOL rdp_reset_runtime_settings(rdpRdp* rdp)
2799 WINPR_ASSERT(rdp->context);
2806 return rdp_reset_remote_settings(rdp);
2809static BOOL starts_with(
const char* tok,
const char* val)
2811 const size_t len = strlen(val);
2812 if (strncmp(tok, val, len) != 0)
2814 if (tok[len] !=
'=')
2819static BOOL option_equals(
const char* what,
const char* val)
2821 return _stricmp(what, val) == 0;
2824static BOOL parse_on_off_option(
const char* value)
2826 WINPR_ASSERT(value);
2827 const char* sep = strchr(value,
'=');
2830 if (option_equals(
"on", &sep[1]))
2832 if (option_equals(
"true", &sep[1]))
2834 if (option_equals(
"off", &sep[1]))
2836 if (option_equals(
"false", &sep[1]))
2840 long val = strtol(value, NULL, 0);
2842 return val == 0 ? FALSE : TRUE;
2849static BOOL option_is_runtime_checks(WINPR_ATTR_UNUSED wLog* log,
const char* tok)
2851 const char* experimental[] = { STR(WITH_VERBOSE_WINPR_ASSERT) };
2852 for (
size_t x = 0; x < ARRAYSIZE(experimental); x++)
2854 const char* opt = experimental[x];
2855 if (starts_with(tok, opt))
2857 return parse_on_off_option(tok);
2863static BOOL option_is_experimental(WINPR_ATTR_UNUSED wLog* log,
const char* tok)
2865 const char* experimental[] = { STR(WITH_DSP_EXPERIMENTAL), STR(WITH_VAAPI) };
2866 for (
size_t x = 0; x < ARRAYSIZE(experimental); x++)
2868 const char* opt = experimental[x];
2869 if (starts_with(tok, opt))
2871 return parse_on_off_option(tok);
2877static BOOL option_is_debug(wLog* log,
const char* tok)
2880 const char* debug[] = { STR(WITH_DEBUG_ALL),
2881 STR(WITH_DEBUG_CERTIFICATE),
2882 STR(WITH_DEBUG_CAPABILITIES),
2883 STR(WITH_DEBUG_CHANNELS),
2884 STR(WITH_DEBUG_CLIPRDR),
2885 STR(WITH_DEBUG_CODECS),
2886 STR(WITH_DEBUG_RDPGFX),
2887 STR(WITH_DEBUG_DVC),
2888 STR(WITH_DEBUG_TSMF),
2889 STR(WITH_DEBUG_KBD),
2890 STR(WITH_DEBUG_LICENSE),
2891 STR(WITH_DEBUG_NEGO),
2892 STR(WITH_DEBUG_NLA),
2893 STR(WITH_DEBUG_TSG),
2894 STR(WITH_DEBUG_RAIL),
2895 STR(WITH_DEBUG_RDP),
2896 STR(WITH_DEBUG_RDPEI),
2897 STR(WITH_DEBUG_REDIR),
2898 STR(WITH_DEBUG_RDPDR),
2899 STR(WITH_DEBUG_RFX),
2900 STR(WITH_DEBUG_SCARD),
2901 STR(WITH_DEBUG_SND),
2902 STR(WITH_DEBUG_SVC),
2903 STR(WITH_DEBUG_TRANSPORT),
2904 STR(WITH_DEBUG_TIMEZONE),
2905 STR(WITH_DEBUG_WND),
2906 STR(WITH_DEBUG_X11_CLIPRDR),
2907 STR(WITH_DEBUG_X11_LOCAL_MOVESIZE),
2908 STR(WITH_DEBUG_X11),
2910 STR(WITH_DEBUG_RINGBUFFER),
2911 STR(WITH_DEBUG_SYMBOLS),
2912 STR(WITH_DEBUG_EVENTS),
2913 STR(WITH_DEBUG_MUTEX),
2914 STR(WITH_DEBUG_NTLM),
2915 STR(WITH_DEBUG_SDL_EVENTS),
2916 STR(WITH_DEBUG_SDL_KBD_EVENTS),
2917 STR(WITH_DEBUG_THREADS),
2918 STR(WITH_DEBUG_URBDRC) };
2920 for (
size_t x = 0; x < ARRAYSIZE(debug); x++)
2922 const char* opt = debug[x];
2923 if (starts_with(tok, opt))
2924 return parse_on_off_option(tok);
2927 if (starts_with(tok,
"WITH_DEBUG"))
2929 WLog_Print(log, WLOG_WARN,
"[BUG] Unmapped Debug-Build option '%s'.", tok);
2930 return parse_on_off_option(tok);
2936static void log_build_warn(rdpRdp* rdp,
const char* what,
const char* msg,
2937 BOOL (*cmp)(wLog* log,
const char* tok))
2940 WINPR_PRAGMA_DIAG_PUSH
2941 WINPR_PRAGMA_DIAG_IGNORED_OVERLENGTH_STRINGS
2943 size_t len =
sizeof(FREERDP_BUILD_CONFIG);
2944 char* list = calloc(len,
sizeof(
char));
2945 char* config = _strdup(FREERDP_BUILD_CONFIG);
2946 WINPR_PRAGMA_DIAG_POP
2950 char* saveptr = NULL;
2951 char* tok = strtok_s(config,
" ", &saveptr);
2954 if (cmp(rdp->log, tok))
2955 winpr_str_append(tok, list, len,
" ");
2957 tok = strtok_s(NULL,
" ", &saveptr);
2964 if (strlen(list) > 0)
2966 WLog_Print(rdp->log, WLOG_WARN,
"*************************************************");
2967 WLog_Print(rdp->log, WLOG_WARN,
"This build is using [%s] build options:", what);
2969 char* saveptr = NULL;
2970 char* tok = strtok_s(list,
" ", &saveptr);
2973 WLog_Print(rdp->log, WLOG_WARN,
"* '%s'", tok);
2974 tok = strtok_s(NULL,
" ", &saveptr);
2976 WLog_Print(rdp->log, WLOG_WARN,
"");
2977 WLog_Print(rdp->log, WLOG_WARN,
"[%s] build options %s", what, msg);
2978 WLog_Print(rdp->log, WLOG_WARN,
"*************************************************");
2984#define print_first_line(log, firstLine, what) \
2985 print_first_line_int((log), (firstLine), (what), __FILE__, __func__, __LINE__)
2986static void print_first_line_int(wLog* log, log_line_t* firstLine,
const char* what,
2987 const char* file,
const char* fkt,
size_t line)
2989 WINPR_ASSERT(firstLine);
2990 if (!firstLine->fkt)
2992 const DWORD level = WLOG_WARN;
2993 if (WLog_IsLevelActive(log, level))
2995 WLog_PrintMessage(log, WLOG_MESSAGE_TEXT, level, line, file, fkt,
2996 "*************************************************");
2997 WLog_PrintMessage(log, WLOG_MESSAGE_TEXT, level, line, file, fkt,
2998 "[SSL] {%s} build or configuration missing:", what);
3000 firstLine->line = line;
3001 firstLine->file = file;
3002 firstLine->fkt = fkt;
3003 firstLine->level = level;
3007static void print_last_line(wLog* log,
const log_line_t* firstLine)
3009 WINPR_ASSERT(firstLine);
3012 if (WLog_IsLevelActive(log, firstLine->level))
3013 WLog_PrintMessage(log, WLOG_MESSAGE_TEXT, firstLine->level, firstLine->line,
3014 firstLine->file, firstLine->fkt,
3015 "*************************************************");
3019static void log_build_warn_cipher(rdpRdp* rdp, log_line_t* firstLine, WINPR_CIPHER_TYPE md,
3022 BOOL haveCipher = FALSE;
3024 char key[WINPR_CIPHER_MAX_KEY_LENGTH] = { 0 };
3025 char iv[WINPR_CIPHER_MAX_IV_LENGTH] = { 0 };
3029 if (md == WINPR_CIPHER_ARC4_128)
3031 WINPR_RC4_CTX* enc = winpr_RC4_New(key,
sizeof(key));
3032 haveCipher = enc != NULL;
3033 winpr_RC4_Free(enc);
3037 WINPR_CIPHER_CTX* enc =
3038 winpr_Cipher_NewEx(md, WINPR_ENCRYPT, key,
sizeof(key), iv,
sizeof(iv));
3039 WINPR_CIPHER_CTX* dec =
3040 winpr_Cipher_NewEx(md, WINPR_DECRYPT, key,
sizeof(key), iv,
sizeof(iv));
3044 winpr_Cipher_Free(enc);
3045 winpr_Cipher_Free(dec);
3050 print_first_line(rdp->log, firstLine,
"Cipher");
3051 WLog_Print(rdp->log, WLOG_WARN,
"* %s: %s", winpr_cipher_type_to_string(md), what);
3055static void log_build_warn_hmac(rdpRdp* rdp, log_line_t* firstLine, WINPR_MD_TYPE md,
3058 BOOL haveHmacX = FALSE;
3059 WINPR_HMAC_CTX* hmac = winpr_HMAC_New();
3065 char key[WINPR_CIPHER_MAX_KEY_LENGTH] = { 0 };
3066 haveHmacX = winpr_HMAC_Init(hmac, md, key,
sizeof(key));
3068 winpr_HMAC_Free(hmac);
3072 print_first_line(rdp->log, firstLine,
"HMAC");
3073 WLog_Print(rdp->log, WLOG_WARN,
" * %s: %s", winpr_md_type_to_string(md), what);
3077static void log_build_warn_hash(rdpRdp* rdp, log_line_t* firstLine, WINPR_MD_TYPE md,
3080 BOOL haveDigestX = FALSE;
3082 WINPR_DIGEST_CTX* digest = winpr_Digest_New();
3084 haveDigestX = winpr_Digest_Init(digest, md);
3085 winpr_Digest_Free(digest);
3089 print_first_line(rdp->log, firstLine,
"Digest");
3090 WLog_Print(rdp->log, WLOG_WARN,
" * %s: %s", winpr_md_type_to_string(md), what);
3094static void log_build_warn_ssl(rdpRdp* rdp)
3098 log_line_t firstHashLine = { 0 };
3099 log_build_warn_hash(rdp, &firstHashLine, WINPR_MD_MD4,
"NTLM support not available");
3100 log_build_warn_hash(rdp, &firstHashLine, WINPR_MD_MD5,
3101 "NTLM, assistance files with encrypted passwords, autoreconnect cookies, "
3102 "licensing and RDP security will not work");
3103 log_build_warn_hash(rdp, &firstHashLine, WINPR_MD_SHA1,
3104 "assistance files with encrypted passwords, Kerberos, Smartcard Logon, RDP "
3105 "security support not available");
3106 log_build_warn_hash(
3107 rdp, &firstHashLine, WINPR_MD_SHA256,
3108 "file clipboard, AAD gateway, NLA security and certificates might not work");
3109 print_last_line(rdp->log, &firstHashLine);
3111 log_line_t firstHmacLine = { 0 };
3112 log_build_warn_hmac(rdp, &firstHmacLine, WINPR_MD_MD5,
"Autoreconnect cookie not supported");
3113 log_build_warn_hmac(rdp, &firstHmacLine, WINPR_MD_SHA1,
"RDP security not supported");
3114 print_last_line(rdp->log, &firstHmacLine);
3116 log_line_t firstCipherLine = { 0 };
3117 log_build_warn_cipher(rdp, &firstCipherLine, WINPR_CIPHER_ARC4_128,
3118 "assistance files with encrypted passwords, NTLM, RDP licensing and RDP "
3119 "security will not work");
3120 log_build_warn_cipher(rdp, &firstCipherLine, WINPR_CIPHER_DES_EDE3_CBC,
3121 "RDP security FIPS mode will not work");
3122 log_build_warn_cipher(
3123 rdp, &firstCipherLine, WINPR_CIPHER_AES_128_CBC,
3124 "assistance file encrypted LHTicket will not work and ARM gateway might not");
3125 log_build_warn_cipher(rdp, &firstCipherLine, WINPR_CIPHER_AES_192_CBC,
3126 "ARM gateway might not work");
3127 log_build_warn_cipher(rdp, &firstCipherLine, WINPR_CIPHER_AES_256_CBC,
3128 "ARM gateway might not work");
3129 print_last_line(rdp->log, &firstCipherLine);
3132void rdp_log_build_warnings(rdpRdp* rdp)
3134 static unsigned count = 0;
3143 log_build_warn(rdp,
"experimental",
"might crash the application", option_is_experimental);
3144 log_build_warn(rdp,
"debug",
"might leak sensitive information (credentials, ...)",
3146 log_build_warn(rdp,
"runtime-check",
"might slow down the application",
3147 option_is_runtime_checks);
3148 log_build_warn_ssl(rdp);
WINPR_API void WINPR_JSON_Delete(WINPR_JSON *item)
Delete a WinPR JSON wrapper object.
FREERDP_API BOOL freerdp_settings_set_string(rdpSettings *settings, FreeRDP_Settings_Keys_String id, const char *param)
Sets a string settings value. The param is copied.
FREERDP_API BOOL freerdp_settings_get_bool(const rdpSettings *settings, FreeRDP_Settings_Keys_Bool id)
Returns a boolean settings value.
FREERDP_API rdpSettings * freerdp_settings_new(DWORD flags)
creates a new setting struct
FREERDP_API rdpSettings * freerdp_settings_clone(const rdpSettings *settings)
Creates a deep copy of settings.
FREERDP_API BOOL freerdp_settings_set_pointer_len(rdpSettings *settings, FreeRDP_Settings_Keys_Pointer id, const void *data, size_t len)
Set a pointer to value data.
FREERDP_API void freerdp_settings_free(rdpSettings *settings)
Free a settings struct with all data in it.
#define FREERDP_SETTINGS_SERVER_MODE