diff options
Diffstat (limited to 'libxrdp/libxrdp.c')
| -rw-r--r-- | libxrdp/libxrdp.c | 530 |
1 files changed, 530 insertions, 0 deletions
diff --git a/libxrdp/libxrdp.c b/libxrdp/libxrdp.c new file mode 100644 index 00000000..263a99ae --- /dev/null +++ b/libxrdp/libxrdp.c @@ -0,0 +1,530 @@ +/* + 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) + 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); +} |