/** * xrdp : A Remote Desktop Protocol server . * * Copyright ( C ) Jay Sorg 2019 * * 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 . * * MS - RDPEGFX /** * * @ file xrdp_egfx . c * @ brief Stream functions for the EGFX extension to the MSRDP protocol . * @ author Jay Sorg , Christopher Pitstick * #if defined (HAVE_CONFIG_H)#include <config_ac.h>#endif #include <stdio.h>#include <stdlib.h>#include <string.h>#include "arch.h" #include "os_calls.h" #include "parse.h" #include "xrdp_egfx.h" #include "libxrdp.h" #include "xrdp_channel.h" #include <limits.h>#define MAX_PART_SIZE 0 xFFFF#define PACKET_COMPR_TYPE_RDP8 0 x04 /* MS-RDPEGFX 2.2.5.3 */ /******************************************************************************/ int struct xrdp_egfx *egfx, const char *data, int bytes)int error;int to_send;"xrdp_egfx_send_data:" );if (bytes <= 1500 )else 1500 , bytes);1500 ;1500 ;while ((bytes > 0 ) && (error == 0 ))if (to_send > 1500 )1500 ;return error;/******************************************************************************/ int struct xrdp_egfx *egfx, struct stream *s)int error;int bytes;if (s == NULL)return 1 ;int ) (s->end - s->data);return error;/******************************************************************************/ struct stream *struct xrdp_egfx_bulk *bulk, int surface_id,int width, int height, int pixel_format)int bytes;struct stream *s;"xrdp_egfx_create_surface:" );8192 );/* RDP_SEGMENTED_DATA */ 0 xE0); /* descriptor = SINGLE */ /* RDP8_BULK_ENCODED_DATA */ /* header */ /* RDPGFX_HEADER */ /* cmdId */ 0 ); /* flags = 0 */ 4 ); /* pduLength, set later */ int ) ((s->end - s->iso_hdr) + 4 );return s;/******************************************************************************/ int struct xrdp_egfx *egfx, int surface_id,int width, int height, int pixel_format)int error;struct stream *s;"xrdp_egfx_send_create_surface:" );"xrdp_egfx_send_create_surface: xrdp_egfx_send_s " "error %d" , error);return error;/******************************************************************************/ struct stream *struct xrdp_egfx_bulk *bulk, int surface_id)int bytes;struct stream *s;"xrdp_egfx_delete_surface:" );8192 );/* RDP_SEGMENTED_DATA */ 0 xE0); /* descriptor = SINGLE */ /* RDP8_BULK_ENCODED_DATA */ /* header */ /* RDPGFX_HEADER */ /* cmdId */ 0 ); /* flags = 0 */ 4 ); /* pduLength, set later */ int ) ((s->end - s->iso_hdr) + 4 );return s;/******************************************************************************/ int struct xrdp_egfx *egfx, int surface_id)int error;struct stream *s;"xrdp_egfx_send_delete_surface:" );"xrdp_egfx_send_delete_surface: xrdp_egfx_send_s " "error %d" , error);return error;/******************************************************************************/ struct stream *struct xrdp_egfx_bulk *bulk, int surface_id,int x, int y)int bytes;struct stream *s;"xrdp_egfx_map_surface:" );8192 );/* RDP_SEGMENTED_DATA */ 0 xE0); /* descriptor = SINGLE */ /* RDP8_BULK_ENCODED_DATA */ /* header */ /* RDPGFX_HEADER */ /* cmdId */ 0 ); /* flags = 0 */ 4 ); /* pduLength, set later */ 0 );int ) ((s->end - s->iso_hdr) + 4 );return s;/******************************************************************************/ int struct xrdp_egfx *egfx, int surface_id,int x, int y)int error;struct stream *s;"xrdp_egfx_send_map_surface:" );"xrdp_egfx_send_map_surface: xrdp_egfx_send_s " "error %d" , error);return error;/******************************************************************************/ struct stream *struct xrdp_egfx_bulk *bulk, int surface_id,int fill_color, int num_rects,const struct xrdp_egfx_rect *rects)int bytes;int index;struct stream *s;"xrdp_egfx_fill_surface:" );1024 + num_rects * 8 );/* RDP_SEGMENTED_DATA */ 0 xE0); /* descriptor = SINGLE */ /* RDP8_BULK_ENCODED_DATA */ /* header */ /* RDPGFX_HEADER */ /* cmdId */ 0 ); /* flags = 0 */ 4 ); /* pduLength, set later */ for (index = 0 ; index < num_rects; index++)int ) ((s->end - s->iso_hdr) + 4 );return s;/******************************************************************************/ int struct xrdp_egfx *egfx, int surface_id,int fill_color, int num_rects,const struct xrdp_egfx_rect *rects)int error;struct stream *s;"xrdp_egfx_send_fill_surface:" );"xrdp_egfx_send_fill_surface: xrdp_egfx_send_s " "error %d" , error);return error;/******************************************************************************/ struct stream *struct xrdp_egfx_bulk *bulk, int src_surface_id,int dst_surface_id,const struct xrdp_egfx_rect *src_rect,int num_dst_points,const struct xrdp_egfx_point *dst_points)int bytes;int index;struct stream *s;"xrdp_egfx_surface_to_surface:" );1024 + num_dst_points * 4 );/* RDP_SEGMENTED_DATA */ 0 xE0); /* descriptor = SINGLE */ /* RDP8_BULK_ENCODED_DATA */ /* header */ /* RDPGFX_HEADER */ /* cmdId */ 0 ); /* flags = 0 */ 4 ); /* pduLength, set later */ for (index = 0 ; index < num_dst_points; index++)int ) ((s->end - s->iso_hdr) + 4 );return s;/******************************************************************************/ int struct xrdp_egfx *egfx, int src_surface_id,int dst_surface_id,const struct xrdp_egfx_rect *src_rect,int num_dst_points,const struct xrdp_egfx_point *dst_points)int error;struct stream *s;"xrdp_egfx_send_surface_to_surface:" );"xrdp_egfx_send_surface_to_surface: xrdp_egfx_send_s " "error %d" , error);return error;/******************************************************************************/ struct stream *struct xrdp_egfx_bulk *bulk, int frame_id, int timestamp)int bytes;struct stream *s;"xrdp_egfx_frame_start:" );8192 );/* RDP_SEGMENTED_DATA */ 0 xE0); /* descriptor = SINGLE */ /* RDP8_BULK_ENCODED_DATA */ /* header */ /* RDPGFX_HEADER */ /* cmdId */ 0 ); /* flags = 0 */ 4 ); /* pduLength, set later */ int ) ((s->end - s->iso_hdr) + 4 );return s;/******************************************************************************/ int struct xrdp_egfx *egfx, int frame_id, int timestamp)int error;struct stream *s;"xrdp_egfx_send_frame_start:" );if (error != 0 )"xrdp_egfx_send_frame_start: xrdp_egfx_send_s " "error %d" , error);return error;/******************************************************************************/ struct stream *struct xrdp_egfx_bulk *bulk, int frame_id)int bytes;struct stream *s;"xrdp_egfx_frame_end:" );8192 );/* RDP_SEGMENTED_DATA */ 0 xE0); /* descriptor = SINGLE */ /* RDP8_BULK_ENCODED_DATA */ /* header */ /* RDPGFX_HEADER */ /* cmdId */ 0 ); /* flags = 0 */ 4 ); /* pduLength, set later */ int ) ((s->end - s->iso_hdr) + 4 );return s;/******************************************************************************/ int struct xrdp_egfx *egfx, int frame_id)int error;struct stream *s;"xrdp_egfx_send_frame_end:" );if (error != 0 )"xrdp_egfx_send_frame_end: xrdp_egfx_send_s " "error %d" , error);return error;/******************************************************************************/ struct stream *struct xrdp_egfx_bulk *bulk, int version, int flags)int bytes;struct stream *s;"xrdp_egfx_capsconfirm:" );8192 );/* RDP_SEGMENTED_DATA */ 0 xE0); /* descriptor = SINGLE */ /* RDP8_BULK_ENCODED_DATA */ /* header */ /* RDPGFX_HEADER */ /* cmdId */ 0 ); /* flags = 0 */ 4 ); /* pduLength, set later */ /* version */ 4 ); /* capsDataLength */ int ) ((s->end - s->iso_hdr) + 4 );return s;/******************************************************************************/ int struct xrdp_egfx *egfx, int version, int flags)int error;struct stream *s;"xrdp_egfx_send_capsconfirm:" );"xrdp_egfx_send_capsconfirm: xrdp_egfx_send_s " "error %d" , error);return error;/******************************************************************************/ struct stream *struct xrdp_egfx_bulk *bulk, int surface_id,int codec_id, int pixel_format,struct xrdp_egfx_rect *dest_rect,void *bitmap_data, int bitmap_data_length)int bytes;int index;int segment_size;int segment_count;struct stream *s;char *bitmap_data8;"xrdp_egfx_wire_to_surface1:" );8192 ;5 * (bitmap_data_length / MAX_PART_SIZE);/* RDP_SEGMENTED_DATA */ 0 xE1); /* descriptor = MULTIPART */ 2 ); /* segmentCount, set later */ 25 + bitmap_data_length); /* uncompressedSize */ /* RDP_DATA_SEGMENT */ 1 + 25 ); /* segmentArray size */ /* RDP8_BULK_ENCODED_DATA */ /* header */ /* RDPGFX_HEADER */ /* cmdId */ 0 ); /* flags = 0 */ 25 + bitmap_data_length); /* pduLength */ 1 ;0 ;char *) bitmap_data;while (index < bitmap_data_length)if (segment_size > MAX_PART_SIZE)/* RDP_DATA_SEGMENT */ 1 + segment_size); /* segmentArray size */ /* RDP8_BULK_ENCODED_DATA */ /* header */ " segment index %d segment_size %d" ,"xrdp_egfx_wire_to_surface1: segment_count %d" ,return s;/******************************************************************************/ int struct xrdp_egfx *egfx, int surface_id,int codec_id, int pixel_format,struct xrdp_egfx_rect *dest_rect,void *bitmap_data, int bitmap_data_length)int error;struct stream *s;"xrdp_egfx_send_wire_to_surface1:" );"xrdp_egfx_send_wire_to_surface1: xrdp_egfx_send_s " "error %d" , error);return error;/******************************************************************************/ struct stream *struct xrdp_egfx_bulk *bulk, int surface_id,int codec_id, int codec_context_id,int pixel_format,void *bitmap_data, int bitmap_data_length)int bytes;int index;int segment_size;int segment_count;struct stream *s;char *bitmap_data8;"xrdp_egfx_wire_to_surface2:" );8192 ;5 * (bitmap_data_length / MAX_PART_SIZE);/* RDP_SEGMENTED_DATA */ 0 xE1); /* descriptor = MULTIPART */ 2 ); /* segmentCount, set later */ 21 + bitmap_data_length); /* uncompressedSize */ /* RDP_DATA_SEGMENT */ 1 + 21 ); /* segmentArray size */ /* RDP8_BULK_ENCODED_DATA */ /* header */ /* RDPGFX_HEADER */ /* cmdId */ 0 ); /* flags = 0 */ 21 + bitmap_data_length); /* pduLength */ 1 ;0 ;char *) bitmap_data;while (index < bitmap_data_length)if (segment_size > MAX_PART_SIZE)/* RDP_DATA_SEGMENT */ 1 + segment_size); /* segmentArray size */ /* RDP8_BULK_ENCODED_DATA */ /* header */ " segment index %d segment_size %d" ,"xrdp_egfx_wire_to_surface2: segment_count %d" ,return s;/******************************************************************************/ int struct xrdp_egfx *egfx, int surface_id,int codec_id, int codec_context_id,int pixel_format,void *bitmap_data, int bitmap_data_length)int error;struct stream *s;"xrdp_egfx_send_wire_to_surface2:" );"xrdp_egfx_send_wire_to_surface2: xrdp_egfx_send_s " "error %d" , error);return error;/******************************************************************************/ struct stream *struct xrdp_egfx_bulk *bulk, int width, int height,int monitor_count, struct monitor_info *mi)int bytes;int index;struct stream *s;"xrdp_egfx_reset_graphics:" );if (monitor_count > 16 )return NULL;/* this should always be enough because limited to 16 monitors 8192 );/* RDP_SEGMENTED_DATA */ 0 xE0); /* descriptor = SINGLE */ /* RDP8_BULK_ENCODED_DATA */ /* header */ /* RDPGFX_HEADER */ /* cmdId */ 0 ); /* flags = 0 */ 340 ); /* pduLength */ /* TODO : Fix hack where working around 0 monitors is necessary . In cases where multi - mon is not used for XRDP , internally 0 monitors are represented , even though we implicitly have one : The entire session ! Some Microsoft clients ( Mainly the Mac OS one ) require that at least one monitor be transmitted for EGFX to function , which is why this change was necessary . See https : //github.com/neutrinolabs/xrdp/pull/2338#discussion_r944685856 https : //github.com/neutrinolabs/xrdp/issues/2503 0 ? 1 : monitor_count);if (monitor_count == 0 )0 );0 );1 );1 );1 );1 ;else for (index = 0 ; index < monitor_count; ++index)"xrdp_egfx_reset_graphics: (index %d) " "monitor left %d top %d right %d bottom %d is_primary %d" ,"xrdp_egfx_reset_graphics: width %d height %d " "monitorcount %d" , width, height, monitor_count);if (monitor_count < 16 )340 - (20 + (monitor_count * 20 ));return s;/******************************************************************************/ int struct xrdp_egfx *egfx, int width, int height,int monitor_count, struct monitor_info *mi)int error;struct stream *s;"xrdp_egfx_send_reset_graphics:" );"xrdp_egfx_send_reset_graphics: xrdp_egfx_send_s " "error %d" , error);return error;/******************************************************************************/ /* RDPGFX_CMDID_FRAMEACKNOWLEDGE */ static int struct xrdp_egfx *egfx, struct stream *s)"xrdp_egfx_process_frame_ack:" );if (!s_check_rem(s, 12 ))return 1 ;"xrdp_egfx_process_frame_ack: queueDepth %d" " intframeId %d totalFramesDecoded %d" ,if (egfx->frame_ack != NULL)return 0 ;/******************************************************************************/ /* RDPGFX_CMDID_CAPSADVERTISE */ static int struct xrdp_egfx *egfx, struct stream *s)int index;int capsSetCount;int caps_count;int version;int capsDataLength;int flags;char *holdp;int *versions;int *flagss;int rv = 0 ;"xrdp_egfx_process_capsadvertise:" );if (egfx->caps_advertise == NULL)return 0 ;if ((capsSetCount < 1 ) || (capsSetCount > 1024 ))return 1 ;0 ;int , capsSetCount);int , capsSetCount);if (versions == NULL || flagss == NULL)1 ;else for (index = 0 ; index < capsSetCount; index++)if (!s_check_rem(s, 8 ))1 ;break ;if (!s_check_rem(s, capsDataLength))1 ;break ;// This implicity excludes caps version 101. if (capsDataLength == 4 )if (rv == 0 && caps_count > 0 )return rv;/******************************************************************************/ static int struct xrdp_egfx *egfx, struct stream *s)int error;int cmdId;int flags;int pduLength;char *holdp;char *holdend;"xrdp_egfx_process:" );0 ;while (s_check_rem(s, 8 ))"xrdp_egfx_process: cmdId 0x%x flags %d" " pduLength %d" , cmdId, flags, pduLength);if (pduLength < 8 )return 1 ;if (!s_check_rem(s, pduLength - 8 ))return 1 ;switch (cmdId)case XR_RDPGFX_CMDID_FRAMEACKNOWLEDGE:break ;case XR_RDPGFX_CMDID_CAPSADVERTISE:break ;case XR_RDPGFX_CMDID_QOEFRAMEACKNOWLEDGE:break ;/* TODO : Handle Cache Import PDU here . https : //github.com/neutrinolabs/xrdp/issues/2502 case XR_RDPGFX_CMDID_CACHEIMPORTOFFER : 2 . 2 . 2 . 16 RDPGFX_CACHE_IMPORT_OFFER_PDU Reply with 2 . 2 . 2 . 17 RDPGFX_CACHE_IMPORT_REPLY_PDU default :"xrdp_egfx_process:" " unknown cmdId 0x%x" , cmdId);break ;if (error != 0 )"xrdp_egfx_process: error %d" , error);return error;return error;/******************************************************************************/ /* from client */ static int int chan_id, int creation_status)"xrdp_egfx_open_response:" );return 0 ;int struct xrdp_mm *mm,enum display_resize_state new_state);/******************************************************************************/ /* from client */ static int int chan_id)struct xrdp_process *process;struct xrdp_mm *mm;"xrdp_egfx_close_response:" );struct xrdp_process *) id;if (mm->resize_queue == 0 || mm->resize_queue->count <= 0 )return 0 ;if (mm->resize_data != NULL"xrdp_egfx_close_response: egfx deleted." );return 0 ;/******************************************************************************/ /* from client */ static int int chan_id, char *data, int bytes,int total_bytes)struct xrdp_process *process;struct xrdp_egfx *egfx;"xrdp_egfx_data_first: bytes %d" " total_bytes %d" , bytes, total_bytes);struct xrdp_process *) id;if (egfx->s != NULL)"DYNVC_DATA_FIRST PDU received while" " another stream is active on channel %d" , chan_id);return 1 ;// Caller has checked total_bytes is >= 0 and bytes is < total_bytes return 0 ;/******************************************************************************/ /* from client */ static int int chan_id, char *data, int bytes)int error;struct stream ls;struct xrdp_process *process;struct xrdp_wm *wm;struct xrdp_mm *mm;struct xrdp_egfx *egfx;"xrdp_egfx_data:" );struct xrdp_process *) id;if (process == NULL)return 0 ;if (wm == NULL)return 0 ;if (mm == NULL)return 0 ;if (egfx == NULL)return 0 ;if (egfx->s == NULL)0 , sizeof (ls));return xrdp_egfx_process(egfx, &ls);if (!s_check_rem_out(egfx->s, bytes))"DYNVC_DATA PDU data overflow on channel %d" ,return 1 ;if (!s_check_rem_out(egfx->s, 1 ))return error;return 0 ;/******************************************************************************/ int struct xrdp_mm *mm, struct xrdp_egfx **egfx)int error;struct xrdp_drdynvc_procs procs;struct xrdp_egfx *self;struct xrdp_process *process;"xrdp_egfx_create:" );struct xrdp_egfx, 1 );if (self == NULL)return 1 ;"Microsoft::Windows::RDS::Graphics" ,1 , /* WTS_CHANNEL_OPTION_DYNAMIC */ "xrdp_egfx_create: error %d channel_id %d" ,0 ;return 0 ;/******************************************************************************/ int struct xrdp_egfx *egfx)int error;"xrdp_egfx_shutdown_delete_surface:" );if (egfx == 0 )"xrdp_egfx_shutdown_delete_surface:" " EGFX is already null!" );return 0 ;if (error != 0 )"xrdp_egfx_shutdown_delete_surface:" " xrdp_egfx_send_delete_surface failed %d" , error);return error;/******************************************************************************/ int struct xrdp_egfx *egfx)int error;"xrdp_egfx_shutdown_close_connection:" );if (egfx == 0 )"xrdp_egfx_shutdown_close_connection:" " EGFX is already null!" );return 0 ;if (error != 0 )"xrdp_egfx_shutdown_close_connection:" " libxrdp_drdynvc_close failed %d" , error);return error;// Ignore any messages we haven't processed yet return error;/******************************************************************************/ int struct xrdp_egfx *egfx)int error = 0 ;"xrdp_egfx_delete:" );if (egfx == 0 )"xrdp_egfx_delete: EGFX is already null!" );return 0 ;return error;/******************************************************************************/ int struct xrdp_egfx *egfx)int error;"xrdp_egfx_shutdown_full:" );if (egfx == 0 )"xrdp_egfx_shutdown_full: EGFX is already null!" );return 0 ;if (error != 0 )"xrdp_egfx_shutdown_full:" " xrdp_egfx_shutdown_delete_surface failed %d" , error);return error;if (error != 0 )"xrdp_egfx_shutdown_full:" " xrdp_egfx_shutdown_close_connection failed %d" , error);return error;if (error != 0 )"xrdp_egfx_shutdown_full:" " xrdp_egfx_shutdown_delete failed %d" , error);return error;return error;
Messung V0.5 in Prozent C=93 H=93 G=92
¤ Dauer der Verarbeitung: 0.19 Sekunden
(vorverarbeitet am 2026-07-10)
¤ *© Formatika GbR, Deutschland
