diff options
author | Laxmikant Rashinkar <LK.Rashinkar@gmail.com> | 2012-09-19 20:51:34 -0700 |
---|---|---|
committer | Laxmikant Rashinkar <LK.Rashinkar@gmail.com> | 2012-09-19 20:51:34 -0700 |
commit | 1123323fda6d128fb98b0427e0ea5f6a2dc9e632 (patch) | |
tree | 3407a3771a069f812554312ce7c36db625139cc2 /libxrdp/xrdp_channel.c | |
parent | 3cedfae76a2351bc8b1e5bd2ee33bbf8630dbacf (diff) | |
download | xrdp-proprietary-1123323fda6d128fb98b0427e0ea5f6a2dc9e632.tar.gz xrdp-proprietary-1123323fda6d128fb98b0427e0ea5f6a2dc9e632.zip |
o moved from GNU General Public License to Apache License, Version 2.0
o applied new coding standards to all .c files
o moved some files around
Diffstat (limited to 'libxrdp/xrdp_channel.c')
-rw-r--r-- | libxrdp/xrdp_channel.c | 254 |
1 files changed, 133 insertions, 121 deletions
diff --git a/libxrdp/xrdp_channel.c b/libxrdp/xrdp_channel.c index 2b3d23a5..6f40b751 100644 --- a/libxrdp/xrdp_channel.c +++ b/libxrdp/xrdp_channel.c @@ -1,24 +1,22 @@ -/* - 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 2006-2010 - - channel layer - -*/ +/** + * xrdp: A Remote Desktop Protocol server. + * + * Copyright (C) Jay Sorg 2006-2012 + * + * 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. + * + * channel layer + */ #include "libxrdp.h" @@ -31,86 +29,96 @@ /*****************************************************************************/ /* returns pointer or nil on error */ -static struct mcs_channel_item* APP_CC -xrdp_channel_get_item(struct xrdp_channel* self, int channel_id) +static struct mcs_channel_item *APP_CC +xrdp_channel_get_item(struct xrdp_channel *self, int channel_id) { - struct mcs_channel_item* channel; - if(self->mcs_layer->channel_list==NULL) - { - g_writeln("xrdp_channel_get_item - No channel initialized"); - return NULL ; - } - channel = (struct mcs_channel_item*) - list_get_item(self->mcs_layer->channel_list, channel_id); - return channel; + struct mcs_channel_item *channel; + + if (self->mcs_layer->channel_list == NULL) + { + g_writeln("xrdp_channel_get_item - No channel initialized"); + return NULL ; + } + + channel = (struct mcs_channel_item *) + list_get_item(self->mcs_layer->channel_list, channel_id); + return channel; } /*****************************************************************************/ -struct xrdp_channel* APP_CC -xrdp_channel_create(struct xrdp_sec* owner, struct xrdp_mcs* mcs_layer) +struct xrdp_channel *APP_CC +xrdp_channel_create(struct xrdp_sec *owner, struct xrdp_mcs *mcs_layer) { - struct xrdp_channel* self; + struct xrdp_channel *self; - self = (struct xrdp_channel*)g_malloc(sizeof(struct xrdp_channel), 1); - self->sec_layer = owner; - self->mcs_layer = mcs_layer; - return self; + self = (struct xrdp_channel *)g_malloc(sizeof(struct xrdp_channel), 1); + self->sec_layer = owner; + self->mcs_layer = mcs_layer; + return self; } /*****************************************************************************/ /* returns error */ void APP_CC -xrdp_channel_delete(struct xrdp_channel* self) +xrdp_channel_delete(struct xrdp_channel *self) { - if (self == 0) - { - return; - } - g_memset(self,0,sizeof(struct xrdp_channel)); - g_free(self); + if (self == 0) + { + return; + } + + g_memset(self, 0, sizeof(struct xrdp_channel)); + g_free(self); } /*****************************************************************************/ /* returns error */ int APP_CC -xrdp_channel_init(struct xrdp_channel* self, struct stream* s) +xrdp_channel_init(struct xrdp_channel *self, struct stream *s) { - if (xrdp_sec_init(self->sec_layer, s) != 0) - { - return 1; - } - s_push_layer(s, channel_hdr, 8); - return 0; + if (xrdp_sec_init(self->sec_layer, s) != 0) + { + return 1; + } + + s_push_layer(s, channel_hdr, 8); + return 0; } /*****************************************************************************/ /* returns error */ /* This sends data out to the secure layer. */ int APP_CC -xrdp_channel_send(struct xrdp_channel* self, struct stream* s, int channel_id, +xrdp_channel_send(struct xrdp_channel *self, struct stream *s, int channel_id, int total_data_len, int flags) { - struct mcs_channel_item* channel; - - channel = xrdp_channel_get_item(self, channel_id); - if (channel == NULL) - { - g_writeln("xrdp_channel_send - no such channel"); - return 1; - } - s_pop_layer(s, channel_hdr); - out_uint32_le(s, total_data_len); - if (channel->flags & XR_CHANNEL_OPTION_SHOW_PROTOCOL) - { - flags |= CHANNEL_FLAG_SHOW_PROTOCOL; - } - out_uint32_le(s, flags); - if (xrdp_sec_send(self->sec_layer, s, channel->chanid) != 0) - { - g_writeln("xrdp_channel_send - failure sending data"); - return 1; - } - return 0; + struct mcs_channel_item *channel; + + channel = xrdp_channel_get_item(self, channel_id); + + if (channel == NULL) + { + g_writeln("xrdp_channel_send - no such channel"); + return 1; + } + + s_pop_layer(s, channel_hdr); + out_uint32_le(s, total_data_len); + + if (channel->flags & XR_CHANNEL_OPTION_SHOW_PROTOCOL) + { + flags |= CHANNEL_FLAG_SHOW_PROTOCOL; + } + + out_uint32_le(s, flags); + + if (xrdp_sec_send(self->sec_layer, s, channel->chanid) != 0) + { + g_writeln("xrdp_channel_send - failure sending data"); + return 1; + } + + return 0; } /*****************************************************************************/ @@ -118,36 +126,38 @@ xrdp_channel_send(struct xrdp_channel* self, struct stream* s, int channel_id, /* this will inform the callback, whatever it is that some channel data is ready. the default for this is a call to xrdp_wm.c. */ static int APP_CC -xrdp_channel_call_callback(struct xrdp_channel* self, struct stream* s, +xrdp_channel_call_callback(struct xrdp_channel *self, struct stream *s, int channel_id, int total_data_len, int flags) { - struct xrdp_session* session; - int rv; - int size; - - rv = 0; - session = self->sec_layer->rdp_layer->session; - if (session != 0) - { - if (session->callback != 0) + struct xrdp_session *session; + int rv; + int size; + + rv = 0; + session = self->sec_layer->rdp_layer->session; + + if (session != 0) { - size = (int)(s->end - s->p); - /* in xrdp_wm.c */ - rv = session->callback(session->id, 0x5555, - MAKELONG(channel_id, flags), - size, (tbus)(s->p), total_data_len); + if (session->callback != 0) + { + size = (int)(s->end - s->p); + /* in xrdp_wm.c */ + rv = session->callback(session->id, 0x5555, + MAKELONG(channel_id, flags), + size, (tbus)(s->p), total_data_len); + } + else + { + g_writeln("in xrdp_channel_call_callback, session->callback is nil"); + } } else { - g_writeln("in xrdp_channel_call_callback, session->callback is nil"); + g_writeln("in xrdp_channel_call_callback, session is nil"); } - } - else - { - g_writeln("in xrdp_channel_call_callback, session is nil"); - } - return rv; + + return rv; } /*****************************************************************************/ @@ -157,30 +167,32 @@ xrdp_channel_call_callback(struct xrdp_channel* self, struct stream* s, 'chanid' passed in here is the mcs channel id so it MCS_GLOBAL_CHANNEL plus something. */ int APP_CC -xrdp_channel_process(struct xrdp_channel* self, struct stream* s, +xrdp_channel_process(struct xrdp_channel *self, struct stream *s, int chanid) { - int length; - int flags; - int rv; - int channel_id; - struct mcs_channel_item* channel; - - - /* this assumes that the channels are in order of chanid(mcs channel id) - but they should be, see xrdp_sec_process_mcs_data_channels - the first channel should be MCS_GLOBAL_CHANNEL + 1, second - one should be MCS_GLOBAL_CHANNEL + 2, and so on */ - channel_id = (chanid - MCS_GLOBAL_CHANNEL) - 1; - channel = xrdp_channel_get_item(self, channel_id); - if (channel == NULL) - { - g_writeln("xrdp_channel_process, channel not found"); - return 1; - } - rv = 0; - in_uint32_le(s, length); - in_uint32_le(s, flags); - rv = xrdp_channel_call_callback(self, s, channel_id, length, flags); - return rv; + int length; + int flags; + int rv; + int channel_id; + struct mcs_channel_item *channel; + + + /* this assumes that the channels are in order of chanid(mcs channel id) + but they should be, see xrdp_sec_process_mcs_data_channels + the first channel should be MCS_GLOBAL_CHANNEL + 1, second + one should be MCS_GLOBAL_CHANNEL + 2, and so on */ + channel_id = (chanid - MCS_GLOBAL_CHANNEL) - 1; + channel = xrdp_channel_get_item(self, channel_id); + + if (channel == NULL) + { + g_writeln("xrdp_channel_process, channel not found"); + return 1; + } + + rv = 0; + in_uint32_le(s, length); + in_uint32_le(s, flags); + rv = xrdp_channel_call_callback(self, s, channel_id, length, flags); + return rv; } |