libxrdp: added xrdp_surface.c

1 files changed, 155 insertions, 0 deletions

diff --git a/libxrdp/xrdp_surface.c b/libxrdp/xrdp_surface.c
new file mode 100644
index 00000000..34f0c933
--- /dev/null
+++ b/libxrdp/xrdp_surface.c
@@ -0,0 +1,155 @@
+/**
+ * xrdp: A Remote Desktop Protocol server.
+ *
+ * Copyright (C) Jay Sorg 2012
+ * Copyright (C) Kevin Zhou 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.
+ */
+
+#include "libxrdp.h"
+#include "freerdp/codec/rfx.h"
+
+/*****************************************************************************/
+struct xrdp_surface* APP_CC
+xrdp_surface_create(struct xrdp_session* session, struct xrdp_fastpath* fastpath)
+{
+  struct xrdp_surface *self;
+
+  self = (struct xrdp_surface*)g_malloc(sizeof(struct xrdp_surface), 1);
+  self->session = session;
+  self->fastpath = fastpath;
+  self->rfx_context = rfx_context_new();
+  self->s = stream_new(16384);
+  return self;
+}
+
+/*****************************************************************************/
+void APP_CC
+xrdp_surface_delete(struct xrdp_surface* self)
+{
+  STREAM* s = (STREAM*)self->s;
+  RFX_CONTEXT* rfx_context = (RFX_CONTEXT*)self->rfx_context;
+
+  if (self == 0)
+  {
+    return;
+  }
+  free_stream(self->out_s);
+  stream_free(s);
+  rfx_context_free(rfx_context);
+  g_free(self);
+}
+
+/*****************************************************************************/
+/* returns error */
+int APP_CC
+xrdp_surface_reset(struct xrdp_surface* self)
+{
+  return 0;
+}
+
+int APP_CC
+xrdp_surface_init(struct xrdp_surface* self)
+{
+  int width;
+  int height;
+  RFX_CONTEXT* rfx_context = (RFX_CONTEXT*)self->rfx_context;
+
+  width = self->session->client_info->width;
+  height= self->session->client_info->height;
+
+  rfx_context->mode = self->session->client_info->rfx_entropy;
+  rfx_context->width = width;
+  rfx_context->height= height;
+
+  make_stream(self->out_s);
+  init_stream(self->out_s, 2 * 3 * width * height + 22);
+
+  return 0;
+}
+
+/*****************************************************************************/
+int APP_CC
+xrdp_surface_send_surface_bits(struct xrdp_surface* self,int bpp, char* data,
+                               int x, int y, int cx, int cy)
+{
+  RFX_RECT rect;
+  char* buf;
+  int Bpp;
+  int i;
+  int j;
+  int codecId;
+  uint32 bitmapDataLength;
+  STREAM* s = (STREAM*)self->s;
+  RFX_CONTEXT* rfx_context = (RFX_CONTEXT*)self->rfx_context;
+
+  if ((bpp == 24) || (bpp == 32))
+  {
+  }
+  else
+  {
+    g_writeln("bpp = %d is not supported\n",bpp);
+    return 1;
+  }
+  Bpp = 4;
+
+  rect.x = 0;
+  rect.y = 0;
+  rect.width  = cx;
+  rect.height = cy;
+
+  init_stream(self->out_s,0);
+
+  stream_set_pos(s, 0);
+  rfx_compose_message(rfx_context, s, &rect, 1, data, cx, cy, Bpp * cx);
+
+  codecId = self->session->client_info->rfx_codecId;
+  /* surface_bits_command */
+  out_uint16_le(self->out_s, CMDTYPE_STREAM_SURFACE_BITS); /* cmdType */
+  out_uint16_le(self->out_s, x);                           /* destLeft */
+  out_uint16_le(self->out_s, y);                           /* destTop */
+  out_uint16_le(self->out_s, x + cx);                      /* destRight */
+  out_uint16_le(self->out_s, y + cy);                      /* destBottom */
+  out_uint8(self->out_s, 32);                              /* bpp */
+  out_uint8(self->out_s, 0);                               /* reserved1 */
+  out_uint8(self->out_s, 0);                               /* reserved2 */
+  out_uint8(self->out_s, codecId);                         /* codecId */
+  out_uint16_le(self->out_s, cx);                          /* width */
+  out_uint16_le(self->out_s, cy);                          /* height */
+  bitmapDataLength = stream_get_length(s);
+  out_uint32_le(self->out_s, bitmapDataLength); /* bitmapDataLength */
+
+  /* rfx bit stream */
+  out_uint8p(self->out_s, s->data, bitmapDataLength);
+
+  s_mark_end(self->out_s);
+  return xrdp_fastpath_send_update_pdu(self->fastpath,
+                                       FASTPATH_UPDATETYPE_SURFCMDS,
+                                       self->out_s);
+}
+
+/*****************************************************************************/
+int APP_CC
+xrdp_surface_send_frame_marker(struct xrdp_surface* self,
+                               uint16 frameAction,uint32 frameId)
+{
+  init_stream(self->out_s, 0);
+  out_uint16_le(self->out_s, CMDTYPE_FRAME_MARKER);
+  out_uint16_le(self->out_s, frameAction);
+  out_uint32_le(self->out_s, frameId);
+  s_mark_end(self->out_s);
+  return xrdp_fastpath_send_update_pdu(self->fastpath,
+                                       FASTPATH_UPDATETYPE_SURFCMDS,
+                                       self->out_s);
+}