531 lines
16 KiB
C
531 lines
16 KiB
C
/*
|
|
This program is free software; you can redistribute it and/or modify
|
|
it under the terms of the GNU General Public License as published by
|
|
the Free Software Foundation; either version 2 of the License, or
|
|
(at your option) any later version.
|
|
|
|
This program is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License
|
|
along with this program; if not, write to the Free Software
|
|
Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
|
|
|
|
xrdp: A Remote Desktop Protocol server.
|
|
Copyright (C) Jay Sorg 2004-2005
|
|
|
|
this is the interface to libxrdp
|
|
|
|
*/
|
|
|
|
#include "libxrdp.h"
|
|
|
|
/******************************************************************************/
|
|
struct xrdp_session* EXPORT_CC
|
|
libxrdp_init(long id, int sck)
|
|
{
|
|
struct xrdp_session* session;
|
|
|
|
session = (struct xrdp_session*)g_malloc(sizeof(struct xrdp_session), 1);
|
|
session->id = id;
|
|
session->rdp = xrdp_rdp_create(session, sck);
|
|
session->orders = xrdp_orders_create(session, (struct xrdp_rdp*)session->rdp);
|
|
session->client_info = &(((struct xrdp_rdp*)session->rdp)->client_info);
|
|
return session;
|
|
}
|
|
|
|
/******************************************************************************/
|
|
int EXPORT_CC
|
|
libxrdp_exit(struct xrdp_session* session)
|
|
{
|
|
if (session == 0)
|
|
{
|
|
return 0;
|
|
}
|
|
xrdp_orders_delete((struct xrdp_orders*)session->orders);
|
|
xrdp_rdp_delete((struct xrdp_rdp*)session->rdp);
|
|
g_free(session);
|
|
return 0;
|
|
}
|
|
|
|
/******************************************************************************/
|
|
int EXPORT_CC
|
|
libxrdp_disconnect(struct xrdp_session* session)
|
|
{
|
|
return xrdp_rdp_disconnect((struct xrdp_rdp*)session->rdp);
|
|
}
|
|
|
|
/******************************************************************************/
|
|
int EXPORT_CC
|
|
libxrdp_process_incomming(struct xrdp_session* session)
|
|
{
|
|
return xrdp_rdp_incoming((struct xrdp_rdp*)session->rdp);
|
|
}
|
|
|
|
/******************************************************************************/
|
|
int EXPORT_CC
|
|
libxrdp_process_data(struct xrdp_session* session)
|
|
{
|
|
struct stream* s;
|
|
int cont;
|
|
int rv;
|
|
int code;
|
|
|
|
cont = 1;
|
|
rv = 0;
|
|
make_stream(s);
|
|
init_stream(s, 8192);
|
|
while (cont && !session->term)
|
|
{
|
|
code = 0;
|
|
if (xrdp_rdp_recv((struct xrdp_rdp*)session->rdp, s, &code) != 0)
|
|
{
|
|
rv = 1;
|
|
break;
|
|
}
|
|
DEBUG(("libxrdp_process_data code %d\n\r", code));
|
|
switch (code)
|
|
{
|
|
case -1:
|
|
xrdp_rdp_send_demand_active((struct xrdp_rdp*)session->rdp);
|
|
break;
|
|
case 0:
|
|
break;
|
|
case RDP_PDU_CONFIRM_ACTIVE: /* 3 */
|
|
xrdp_rdp_process_confirm_active((struct xrdp_rdp*)session->rdp, s);
|
|
break;
|
|
case RDP_PDU_DATA: /* 7 */
|
|
if (xrdp_rdp_process_data((struct xrdp_rdp*)session->rdp, s) != 0)
|
|
{
|
|
DEBUG(("libxrdp_process_data returned non zero\n\r"));
|
|
cont = 0;
|
|
session->term = 1;
|
|
}
|
|
break;
|
|
default:
|
|
g_printf("unknown in libxrdp_process_data\n\r");
|
|
break;
|
|
}
|
|
if (cont)
|
|
{
|
|
cont = s->next_packet < s->end;
|
|
}
|
|
}
|
|
free_stream(s);
|
|
return rv;
|
|
}
|
|
|
|
/******************************************************************************/
|
|
int EXPORT_CC
|
|
libxrdp_send_palette(struct xrdp_session* session, int* palette)
|
|
{
|
|
int i;
|
|
int color;
|
|
struct stream* s;
|
|
|
|
if (session->client_info->bpp > 8)
|
|
{
|
|
return 0;
|
|
}
|
|
/* clear orders */
|
|
libxrdp_orders_force_send(session);
|
|
make_stream(s);
|
|
init_stream(s, 8192);
|
|
xrdp_rdp_init_data((struct xrdp_rdp*)session->rdp, s);
|
|
out_uint16_le(s, RDP_UPDATE_PALETTE);
|
|
out_uint16_le(s, 0);
|
|
out_uint16_le(s, 256); /* # of colors */
|
|
out_uint16_le(s, 0);
|
|
for (i = 0; i < 256; i++)
|
|
{
|
|
color = palette[i];
|
|
out_uint8(s, color >> 16);
|
|
out_uint8(s, color >> 8);
|
|
out_uint8(s, color);
|
|
}
|
|
s_mark_end(s);
|
|
xrdp_rdp_send_data((struct xrdp_rdp*)session->rdp, s, RDP_DATA_PDU_UPDATE);
|
|
free_stream(s);
|
|
/* send the orders palette too */
|
|
libxrdp_orders_init(session);
|
|
libxrdp_orders_send_palette(session, palette, 0);
|
|
libxrdp_orders_send(session);
|
|
return 0;
|
|
}
|
|
|
|
/*****************************************************************************/
|
|
int EXPORT_CC
|
|
libxrdp_send_bitmap(struct xrdp_session* session, int width, int height,
|
|
int bpp, char* data, int x, int y, int cx, int cy)
|
|
{
|
|
int data_size;
|
|
int line_size;
|
|
int i;
|
|
int j;
|
|
int total_lines;
|
|
int lines_sending;
|
|
int Bpp;
|
|
int e;
|
|
int bufsize;
|
|
int total_bufsize;
|
|
int num_updates;
|
|
char* p_num_updates;
|
|
char* p;
|
|
char* q;
|
|
struct stream* s;
|
|
struct stream* temp_s;
|
|
|
|
Bpp = (bpp + 7) / 8;
|
|
e = width % 4;
|
|
if (e != 0)
|
|
{
|
|
e = 4 - e;
|
|
}
|
|
line_size = width * Bpp;
|
|
make_stream(s);
|
|
init_stream(s, 8192);
|
|
if (session->client_info->use_bitmap_comp)
|
|
{
|
|
make_stream(temp_s);
|
|
init_stream(temp_s, 65536);
|
|
i = 0;
|
|
if (cy <= height)
|
|
{
|
|
i = cy;
|
|
}
|
|
while (i > 0)
|
|
{
|
|
total_bufsize = 0;
|
|
num_updates = 0;
|
|
xrdp_rdp_init_data((struct xrdp_rdp*)session->rdp, s);
|
|
out_uint16_le(s, RDP_UPDATE_BITMAP);
|
|
p_num_updates = s->p;
|
|
out_uint8s(s, 2); /* num_updates set later */
|
|
do
|
|
{
|
|
if (session->client_info->op1)
|
|
{
|
|
s_push_layer(s, channel_hdr, 18);
|
|
}
|
|
else
|
|
{
|
|
s_push_layer(s, channel_hdr, 26);
|
|
}
|
|
p = s->p;
|
|
lines_sending = xrdp_bitmap_compress(data, width, height,
|
|
s, bpp,
|
|
4096 - total_bufsize,
|
|
i - 1, temp_s, e);
|
|
if (lines_sending == 0)
|
|
{
|
|
break;
|
|
}
|
|
num_updates++;
|
|
bufsize = s->p - p;
|
|
total_bufsize += bufsize;
|
|
i = i - lines_sending;
|
|
s_mark_end(s);
|
|
s_pop_layer(s, channel_hdr);
|
|
out_uint16_le(s, x); /* left */
|
|
out_uint16_le(s, y + i); /* top */
|
|
out_uint16_le(s, (x + cx) - 1); /* right */
|
|
out_uint16_le(s, (y + i + lines_sending) - 1); /* bottom */
|
|
out_uint16_le(s, width + e); /* width */
|
|
out_uint16_le(s, lines_sending); /* height */
|
|
out_uint16_le(s, bpp); /* bpp */
|
|
if (session->client_info->op1)
|
|
{
|
|
out_uint16_le(s, 0x401); /* compress */
|
|
out_uint16_le(s, bufsize); /* compressed size */
|
|
j = (width + e) * Bpp;
|
|
j = j * lines_sending;
|
|
}
|
|
else
|
|
{
|
|
out_uint16_le(s, 0x1); /* compress */
|
|
out_uint16_le(s, bufsize + 8);
|
|
out_uint8s(s, 2); /* pad */
|
|
out_uint16_le(s, bufsize); /* compressed size */
|
|
j = (width + e) * Bpp;
|
|
out_uint16_le(s, j); /* line size */
|
|
j = j * lines_sending;
|
|
out_uint16_le(s, j); /* final size */
|
|
}
|
|
if (j > 32768)
|
|
{
|
|
g_printf("error, decompressed size too big, its %d\n\r", j);
|
|
}
|
|
if (bufsize > 8192)
|
|
{
|
|
g_printf("error, compressed size too big, its %d\n\r", bufsize);
|
|
}
|
|
s->p = s->end;
|
|
} while (total_bufsize < 4096 && i > 0);
|
|
p_num_updates[0] = num_updates;
|
|
p_num_updates[1] = num_updates >> 8;
|
|
xrdp_rdp_send_data((struct xrdp_rdp*)session->rdp, s,
|
|
RDP_DATA_PDU_UPDATE);
|
|
if (total_bufsize > 8192)
|
|
{
|
|
g_printf("error, total compressed size too big, its %d\n\r",
|
|
total_bufsize);
|
|
}
|
|
}
|
|
free_stream(temp_s);
|
|
}
|
|
else
|
|
{
|
|
lines_sending = 0;
|
|
data_size = width * height * Bpp;
|
|
total_lines = height;
|
|
i = 0;
|
|
p = data;
|
|
if (line_size > 0 && total_lines > 0)
|
|
{
|
|
while (i < total_lines)
|
|
{
|
|
lines_sending = 4096 / (line_size + e * Bpp);
|
|
if (i + lines_sending > total_lines)
|
|
{
|
|
lines_sending = total_lines - i;
|
|
}
|
|
p = p + line_size * lines_sending;
|
|
xrdp_rdp_init_data((struct xrdp_rdp*)session->rdp, s);
|
|
out_uint16_le(s, RDP_UPDATE_BITMAP);
|
|
out_uint16_le(s, 1); /* num updates */
|
|
out_uint16_le(s, x);
|
|
out_uint16_le(s, y + i);
|
|
out_uint16_le(s, (x + cx) - 1);
|
|
out_uint16_le(s, (y + i + lines_sending) - 1);
|
|
out_uint16_le(s, width + e);
|
|
out_uint16_le(s, lines_sending);
|
|
out_uint16_le(s, bpp); /* bpp */
|
|
out_uint16_le(s, 0); /* compress */
|
|
out_uint16_le(s, (line_size + e * Bpp) * lines_sending); /* bufsize */
|
|
q = p;
|
|
for (j = 0; j < lines_sending; j++)
|
|
{
|
|
q = q - line_size;
|
|
out_uint8a(s, q, line_size) /* B_ENDIAN doesn't work here, todo */
|
|
out_uint8s(s, e * Bpp);
|
|
}
|
|
s_mark_end(s);
|
|
xrdp_rdp_send_data((struct xrdp_rdp*)session->rdp, s,
|
|
RDP_DATA_PDU_UPDATE);
|
|
i = i + lines_sending;
|
|
}
|
|
}
|
|
}
|
|
free_stream(s);
|
|
return 0;
|
|
}
|
|
|
|
/*****************************************************************************/
|
|
int EXPORT_CC
|
|
libxrdp_send_pointer(struct xrdp_session* session, int cache_idx,
|
|
char* data, char* mask, int x, int y)
|
|
{
|
|
struct stream* s;
|
|
char* p;
|
|
int i;
|
|
int j;
|
|
|
|
make_stream(s);
|
|
init_stream(s, 8192);
|
|
xrdp_rdp_init_data((struct xrdp_rdp*)session->rdp, s);
|
|
out_uint16_le(s, RDP_POINTER_COLOR);
|
|
out_uint16_le(s, 0); /* pad */
|
|
out_uint16_le(s, cache_idx); /* cache_idx */
|
|
out_uint16_le(s, x);
|
|
out_uint16_le(s, y);
|
|
out_uint16_le(s, 32);
|
|
out_uint16_le(s, 32);
|
|
out_uint16_le(s, 128);
|
|
out_uint16_le(s, 3072);
|
|
p = data;
|
|
for (i = 0; i < 32; i++)
|
|
{
|
|
for (j = 0; j < 32; j++)
|
|
{
|
|
out_uint8(s, *p);
|
|
p++;
|
|
out_uint8(s, *p);
|
|
p++;
|
|
out_uint8(s, *p);
|
|
p++;
|
|
}
|
|
}
|
|
out_uint8a(s, mask, 128); /* mask */
|
|
s_mark_end(s);
|
|
xrdp_rdp_send_data((struct xrdp_rdp*)session->rdp, s, RDP_DATA_PDU_POINTER);
|
|
free_stream(s);
|
|
return 0;
|
|
}
|
|
|
|
/*****************************************************************************/
|
|
int EXPORT_CC
|
|
libxrdp_set_pointer(struct xrdp_session* session, int cache_idx)
|
|
{
|
|
struct stream* s;
|
|
|
|
make_stream(s);
|
|
init_stream(s, 8192);
|
|
xrdp_rdp_init_data((struct xrdp_rdp*)session->rdp, s);
|
|
out_uint16_le(s, RDP_POINTER_CACHED);
|
|
out_uint16_le(s, 0); /* pad */
|
|
out_uint16_le(s, cache_idx); /* cache_idx */
|
|
s_mark_end(s);
|
|
xrdp_rdp_send_data((struct xrdp_rdp*)session->rdp, s, RDP_DATA_PDU_POINTER);
|
|
free_stream(s);
|
|
return 0;
|
|
}
|
|
|
|
/******************************************************************************/
|
|
int EXPORT_CC
|
|
libxrdp_orders_init(struct xrdp_session* session)
|
|
{
|
|
return xrdp_orders_init((struct xrdp_orders*)session->orders);
|
|
}
|
|
|
|
/******************************************************************************/
|
|
int EXPORT_CC
|
|
libxrdp_orders_send(struct xrdp_session* session)
|
|
{
|
|
return xrdp_orders_send((struct xrdp_orders*)session->orders);
|
|
}
|
|
|
|
/******************************************************************************/
|
|
int EXPORT_CC
|
|
libxrdp_orders_force_send(struct xrdp_session* session)
|
|
{
|
|
return xrdp_orders_force_send((struct xrdp_orders*)session->orders);
|
|
}
|
|
|
|
/******************************************************************************/
|
|
int EXPORT_CC
|
|
libxrdp_orders_rect(struct xrdp_session* session, int x, int y,
|
|
int cx, int cy, int color, struct xrdp_rect* rect)
|
|
{
|
|
return xrdp_orders_rect((struct xrdp_orders*)session->orders,
|
|
x, y, cx, cy, color, rect);
|
|
}
|
|
|
|
/******************************************************************************/
|
|
int EXPORT_CC
|
|
libxrdp_orders_screen_blt(struct xrdp_session* session, int x, int y,
|
|
int cx, int cy, int srcx, int srcy,
|
|
int rop, struct xrdp_rect* rect)
|
|
{
|
|
return xrdp_orders_screen_blt((struct xrdp_orders*)session->orders,
|
|
x, y, cx, cy, srcx, srcy, rop, rect);
|
|
}
|
|
|
|
/******************************************************************************/
|
|
int EXPORT_CC
|
|
libxrdp_orders_pat_blt(struct xrdp_session* session, int x, int y,
|
|
int cx, int cy, int rop, int bg_color,
|
|
int fg_color, struct xrdp_brush* brush,
|
|
struct xrdp_rect* rect)
|
|
{
|
|
return xrdp_orders_pat_blt((struct xrdp_orders*)session->orders,
|
|
x, y, cx, cy, rop, bg_color, fg_color,
|
|
brush, rect);
|
|
}
|
|
|
|
/******************************************************************************/
|
|
int EXPORT_CC
|
|
libxrdp_orders_dest_blt(struct xrdp_session* session, int x, int y,
|
|
int cx, int cy, int rop,
|
|
struct xrdp_rect* rect)
|
|
{
|
|
return xrdp_orders_dest_blt((struct xrdp_orders*)session->orders,
|
|
x, y, cx, cy, rop, rect);
|
|
}
|
|
|
|
/******************************************************************************/
|
|
int EXPORT_CC
|
|
libxrdp_orders_line(struct xrdp_session* session, int mix_mode,
|
|
int startx, int starty,
|
|
int endx, int endy, int rop, int bg_color,
|
|
struct xrdp_pen* pen,
|
|
struct xrdp_rect* rect)
|
|
{
|
|
return xrdp_orders_line((struct xrdp_orders*)session->orders,
|
|
mix_mode, startx, starty, endx, endy,
|
|
rop, bg_color, pen, rect);
|
|
}
|
|
|
|
/******************************************************************************/
|
|
int EXPORT_CC
|
|
libxrdp_orders_mem_blt(struct xrdp_session* session, int cache_id,
|
|
int color_table, int x, int y, int cx, int cy,
|
|
int rop, int srcx, int srcy,
|
|
int cache_idx, struct xrdp_rect* rect)
|
|
{
|
|
return xrdp_orders_mem_blt((struct xrdp_orders*)session->orders,
|
|
cache_id, color_table, x, y, cx, cy, rop,
|
|
srcx, srcy, cache_idx, rect);
|
|
}
|
|
|
|
/******************************************************************************/
|
|
int EXPORT_CC
|
|
libxrdp_orders_text(struct xrdp_session* session,
|
|
int font, int flags, int mixmode,
|
|
int fg_color, int bg_color,
|
|
int clip_left, int clip_top,
|
|
int clip_right, int clip_bottom,
|
|
int box_left, int box_top,
|
|
int box_right, int box_bottom,
|
|
int x, int y, char* data, int data_len,
|
|
struct xrdp_rect* rect)
|
|
{
|
|
return xrdp_orders_text((struct xrdp_orders*)session->orders,
|
|
font, flags, mixmode, fg_color, bg_color,
|
|
clip_left, clip_top, clip_right, clip_bottom,
|
|
box_left, box_top, box_right, box_bottom,
|
|
x, y, data, data_len, rect);
|
|
}
|
|
|
|
/******************************************************************************/
|
|
int EXPORT_CC
|
|
libxrdp_orders_send_palette(struct xrdp_session* session, int* palette,
|
|
int cache_id)
|
|
{
|
|
return xrdp_orders_send_palette((struct xrdp_orders*)session->orders,
|
|
palette, cache_id);
|
|
}
|
|
|
|
/*****************************************************************************/
|
|
int EXPORT_CC
|
|
libxrdp_orders_send_raw_bitmap(struct xrdp_session* session,
|
|
int width, int height, int bpp, char* data,
|
|
int cache_id, int cache_idx)
|
|
{
|
|
return xrdp_orders_send_raw_bitmap((struct xrdp_orders*)session->orders,
|
|
width, height, bpp, data,
|
|
cache_id, cache_idx);
|
|
}
|
|
|
|
/*****************************************************************************/
|
|
int EXPORT_CC
|
|
libxrdp_orders_send_bitmap(struct xrdp_session* session,
|
|
int width, int height, int bpp, char* data,
|
|
int cache_id, int cache_idx)
|
|
{
|
|
return xrdp_orders_send_bitmap((struct xrdp_orders*)session->orders,
|
|
width, height, bpp, data,
|
|
cache_id, cache_idx);
|
|
}
|
|
|
|
/*****************************************************************************/
|
|
int EXPORT_CC
|
|
libxrdp_orders_send_font(struct xrdp_session* session,
|
|
struct xrdp_font_char* font_char,
|
|
int font_index, int char_index)
|
|
{
|
|
return xrdp_orders_send_font((struct xrdp_orders*)session->orders,
|
|
font_char, font_index, char_index);
|
|
}
|