From bd58ece2d79f57b43c127fa92a937ced8036b4c0 Mon Sep 17 00:00:00 2001 From: jsorg71 Date: Tue, 3 Aug 2004 03:35:13 +0000 Subject: [PATCH] add xrdp_process.c --- xrdp/xrdp_process.c | 97 +++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 97 insertions(+) create mode 100644 xrdp/xrdp_process.c diff --git a/xrdp/xrdp_process.c b/xrdp/xrdp_process.c new file mode 100644 index 00000000..875829e6 --- /dev/null +++ b/xrdp/xrdp_process.c @@ -0,0 +1,97 @@ +/* + 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. + + Copyright (C) Jay Sorg 2004 + + main rdp process + +*/ + +#include "xrdp.h" + +/*****************************************************************************/ +struct xrdp_process* xrdp_process_create(struct xrdp_listen* owner) +{ + struct xrdp_process* self; + + self = (struct xrdp_process*)g_malloc(sizeof(struct xrdp_process), 1); + self->lis_layer = owner; + self->rdp_layer = xrdp_rdp_create(self); + return self; +} + +/*****************************************************************************/ +void xrdp_process_delete(struct xrdp_process* self) +{ + xrdp_rdp_delete(self->rdp_layer); + g_free(self->in_s.data); + g_free(self->out_s.data); + g_free(self); +} + +/*****************************************************************************/ +int xrdp_process_main_loop(struct xrdp_process* self) +{ + int code; + int i; + int cont; + + self->status = 1; + self->rdp_layer = xrdp_rdp_create(self); + g_tcp_set_non_blocking(self->sck); + if (xrdp_rdp_incoming(self->rdp_layer) == 0) + { + while (!g_is_term() && !self->term) + { + i = g_tcp_select(self->sck); + if (i == 1) + { + cont = 1; + while (cont) + { + if (xrdp_rdp_recv(self->rdp_layer, &code) != 0) + break; + DEBUG(("xrdp_process_main_loop code %d\n", code)); + switch (code) + { + case -1: + xrdp_rdp_send_demand_active(self->rdp_layer); + break; + case 0: + break; + case RDP_PDU_CONFIRM_ACTIVE: + xrdp_rdp_process_confirm_active(self->rdp_layer); /* 3 */ + break; + case RDP_PDU_DATA: + xrdp_rdp_process_data(self->rdp_layer); /* 7 */ + break; + default: + g_printf("unknown in xrdp_process_main_loop\n"); + break; + } + cont = self->rdp_layer->next_packet < self->rdp_layer->in_s->end; + } + if (cont) /* we must have errored out */ + break; + } + else + break; + } + } + xrdp_rdp_delete(self->rdp_layer); + g_tcp_close(self->sck); + self->status = -1; + return 0; +}