/** * FreeRDP: A Remote Desktop Protocol Implementation * X11 Client Interface * * Copyright 2013 Marc-Andre Moreau * Copyright 2013 Corey Clayton * * 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. */ #ifdef HAVE_CONFIG_H #include "config.h" #endif #include #include #ifdef WITH_XI #include #endif #ifdef WITH_XCURSOR #include #endif #ifdef WITH_XINERAMA #include #endif #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include "xf_gdi.h" #include "xf_rail.h" #include "xf_tsmf.h" #include "xf_event.h" #include "xf_cliprdr.h" #include "xf_monitor.h" #include "xf_graphics.h" #include "xf_keyboard.h" #include "xf_input.h" #include static int initialized_xi = 0; static int rtest = 0; static long xv_port = 0; static const size_t password_size = 512; void * scaledBuf; XImage* scaled_image; Pixmap scaled_pixmap; void setScale(rdpContext* context, double scale) { int w2, h2; rdpGdi* gdi; xfInfo* xfi; xfi = ((xfContext*) context)->xfi; gdi = context->gdi; //for now only run once if(rtest == 0) { rtest++; //must be careful here with rounding w2 = (int)(gdi->width * scale); h2 = (int)(gdi->height * scale); printf("###########################/n"); printf("gdi: %dx%d, xfi: %dx%d\n", gdi->width, gdi->height, xfi->width, xfi->height); printf("creating scaled buffer\n"); printf("%dx%d -> %.2f -> %dx%d (%d bytes)\n", gdi->width, gdi->height, scale, w2, h2, 4*w2*h2); scaledBuf = malloc(4 * w2 * h2); scaled_image = XCreateImage(xfi->display, xfi->visual, xfi->depth, ZPixmap, 0, (char*) scaledBuf, w2, h2, xfi->scanline_pad, 0); scaled_pixmap = XCreatePixmap(xfi->display, xfi->drawable, w2, h2, xfi->depth); printf("done\n"); } return; } void xf_context_new(freerdp* instance, rdpContext* context) { context->channels = freerdp_channels_new(); } void xf_context_free(freerdp* instance, rdpContext* context) { } void xf_sw_begin_paint(rdpContext* context) { rdpGdi* gdi = context->gdi; gdi->primary->hdc->hwnd->invalid->null = 1; gdi->primary->hdc->hwnd->ninvalid = 0; } void xf_sw_end_paint(rdpContext* context) { rdpGdi* gdi; xfInfo* xfi; INT32 x, y; UINT32 w, h; xfi = ((xfContext*) context)->xfi; gdi = context->gdi; if (xfi->remote_app != TRUE) { if (xfi->complex_regions != TRUE) { if (gdi->primary->hdc->hwnd->invalid->null) return; x = gdi->primary->hdc->hwnd->invalid->x; y = gdi->primary->hdc->hwnd->invalid->y; w = gdi->primary->hdc->hwnd->invalid->w; h = gdi->primary->hdc->hwnd->invalid->h; xf_lock_x11(xfi, FALSE); printf("sw1"); XPutImage(xfi->display, xfi->primary, xfi->gc, xfi->image, x, y, x, y, w, h); XCopyArea(xfi->display, xfi->primary, xfi->window->handle, xfi->gc, x, y, w, h, x, y); xf_unlock_x11(xfi, FALSE); } else { int i; int ninvalid; HGDI_RGN cinvalid; if (gdi->primary->hdc->hwnd->ninvalid < 1) return; ninvalid = gdi->primary->hdc->hwnd->ninvalid; cinvalid = gdi->primary->hdc->hwnd->cinvalid; xf_lock_x11(xfi, FALSE); for (i = 0; i < ninvalid; i++) { x = cinvalid[i].x; y = cinvalid[i].y; w = cinvalid[i].w; h = cinvalid[i].h; //here --sw //combine xfi->primary with xfi->image XPutImage(xfi->display, xfi->primary, xfi->gc, xfi->image, x, y, x, y, w, h); /* if(1)//(rtest < 2) { if(1)//(w > 100 && h > 100) { printf("first rect: %dx%d @ (%d, %d)\n", w, h, x, y); printf("\tXImage: %dx%d, offset:%d, format=%d, bpp:%d\n", xfi->image->width, xfi->image->height, xfi->image->xoffset, xfi->image->format, xfi->image->bits_per_pixel); testIM(w, h, xfi->image->data); rtest++; } } */ /////////////////////////////////////////////////// //copy from xfi->primary to xfi->window->handle //XCopyArea(xfi->display, xfi->primary, xfi->window->handle, xfi->gc, x, y, w, h, x, y); { //try resizing the entire screen //int w, h; int w2, h2; int x2, y2; int i; XImage xi_small; Image* im_orig; Image* im_re; ExceptionInfo* e; MagickBooleanType ret; double scale; scale = 0.5; setScale(context, scale); w2 = (int)(w * scale); h2 = (int)(h * scale); x2 = (int)(x * scale); y2 = (int)(y * scale); if(w2 == 0) w2++; if(h2 == 0) h2++; MagickCoreGenesis("/tmp/", MagickTrue); e = AcquireExceptionInfo(); //XPutImage(xfi->display, xfi->primary, xfi->gc, xfi->image, 0, 0, 0, 0, 1024, 768); im_orig = ConstituteImage(w, h, "RGBA", CharPixel, (void *)xfi->image->data, e); im_re = ResizeImage(im_orig, w2, h2, LanczosFilter, 1.0, e); //ret = CompositeImage(im_orig, AtopCompositeOp, im_re, 0, 0); //printf("putimage\n"); //XPutImage(xfi->display, scaled_pixmap, xfi->gc, scaled_image, x2, y2, x2, y2, w2, h2); XPutImage(xfi->display, scaled_pixmap, xfi->gc, scaled_image, x2, y2, x2, y2, w2, h2); //printf("export bpl:%d calc:%d\n", scaled_image->bytes_per_line, 4*w2); //ret = ExportImagePixels(im_re, 0, 0, w2, h2, "RGBA", CharPixel, scaled_image->data, e); //??? printf("rect: %dx%d @ %d, %d\n", w2, h2, x2, y2); printf("im_re: %dx%d\n", im_re->columns, im_re->rows); printf("address of data: %p\naddress of scaledBuf: %p\naddress of calculated offset: %p\n", scaled_image->data, scaledBuf, scaled_image->data + (scaled_image->bytes_per_line * y2)); for(i = 0; i < h2; i++) { int offset; offset = scaled_image->bytes_per_line * (i); offset += x2 * 4; //printf("\toffset:%d i:%d/%d \n", offset, i, h2-1); ret = ExportImagePixels(im_re, 0, i, im_re->columns, 1, "RGBA", CharPixel, scaled_image->data + offset, e); } //printf("copy\n"); XCopyArea(xfi->display, scaled_pixmap, xfi->window->handle, xfi->gc, x2, y2, w, h, x2, y2); im_orig = DestroyImage(im_orig); im_re = DestroyImage(im_re); /*{ char tmp; printf("Continue?\n"); scanf("%c", &tmp); } */ } } XFlush(xfi->display); xf_unlock_x11(xfi, FALSE); } } else { if (gdi->primary->hdc->hwnd->invalid->null) return; x = gdi->primary->hdc->hwnd->invalid->x; y = gdi->primary->hdc->hwnd->invalid->y; w = gdi->primary->hdc->hwnd->invalid->w; h = gdi->primary->hdc->hwnd->invalid->h; xf_lock_x11(xfi, FALSE); xf_rail_paint(xfi, context->rail, x, y, x + w - 1, y + h - 1); xf_unlock_x11(xfi, FALSE); } } void xf_sw_desktop_resize(rdpContext* context) { xfInfo* xfi; rdpSettings* settings; xfi = ((xfContext*) context)->xfi; settings = xfi->instance->settings; xf_lock_x11(xfi, TRUE); if (xfi->fullscreen != TRUE) { rdpGdi* gdi = context->gdi; gdi_resize(gdi, xfi->width, xfi->height); if (xfi->image) { xfi->image->data = NULL; XDestroyImage(xfi->image); xfi->image = XCreateImage(xfi->display, xfi->visual, xfi->depth, ZPixmap, 0, (char*) gdi->primary_buffer, gdi->width, gdi->height, xfi->scanline_pad, 0); } } xf_unlock_x11(xfi, TRUE); } void xf_hw_begin_paint(rdpContext* context) { xfInfo* xfi; xfi = ((xfContext*) context)->xfi; xfi->hdc->hwnd->invalid->null = 1; xfi->hdc->hwnd->ninvalid = 0; } void xf_hw_end_paint(rdpContext* context) { xfInfo* xfi; INT32 x, y; UINT32 w, h; xfi = ((xfContext*) context)->xfi; if (!xfi->remote_app) { if (!xfi->complex_regions) { if (xfi->hdc->hwnd->invalid->null) return; x = xfi->hdc->hwnd->invalid->x; y = xfi->hdc->hwnd->invalid->y; w = xfi->hdc->hwnd->invalid->w; h = xfi->hdc->hwnd->invalid->h; xf_lock_x11(xfi, FALSE); printf("hw1"); XCopyArea(xfi->display, xfi->primary, xfi->drawable, xfi->gc, x, y, w, h, x, y); xf_unlock_x11(xfi, FALSE); } else { int i; int ninvalid; HGDI_RGN cinvalid; if (xfi->hdc->hwnd->ninvalid < 1) return; ninvalid = xfi->hdc->hwnd->ninvalid; cinvalid = xfi->hdc->hwnd->cinvalid; xf_lock_x11(xfi, FALSE); for (i = 0; i < ninvalid; i++) { x = cinvalid[i].x; y = cinvalid[i].y; w = cinvalid[i].w; h = cinvalid[i].h; XCopyArea(xfi->display, xfi->primary, xfi->drawable, xfi->gc, x, y, w, h, x, y); } printf("hw1"); XFlush(xfi->display); xf_unlock_x11(xfi, FALSE); } } else { if (xfi->hdc->hwnd->invalid->null) return; x = xfi->hdc->hwnd->invalid->x; y = xfi->hdc->hwnd->invalid->y; w = xfi->hdc->hwnd->invalid->w; h = xfi->hdc->hwnd->invalid->h; xf_lock_x11(xfi, FALSE); xf_rail_paint(xfi, context->rail, x, y, x + w - 1, y + h - 1); xf_unlock_x11(xfi, FALSE); } } void xf_hw_desktop_resize(rdpContext* context) { xfInfo* xfi; BOOL same; rdpSettings* settings; xfi = ((xfContext*) context)->xfi; settings = xfi->instance->settings; xf_lock_x11(xfi, TRUE); if (xfi->fullscreen != TRUE) { xfi->width = settings->DesktopWidth; xfi->height = settings->DesktopHeight; if (xfi->window) xf_ResizeDesktopWindow(xfi, xfi->window, settings->DesktopWidth, settings->DesktopHeight); if (xfi->primary) { same = (xfi->primary == xfi->drawing) ? TRUE : FALSE; XFreePixmap(xfi->display, xfi->primary); xfi->primary = XCreatePixmap(xfi->display, xfi->drawable, xfi->width, xfi->height, xfi->depth); if (same) xfi->drawing = xfi->primary; } } else { XSetFunction(xfi->display, xfi->gc, GXcopy); XSetFillStyle(xfi->display, xfi->gc, FillSolid); XSetForeground(xfi->display, xfi->gc, 0); XFillRectangle(xfi->display, xfi->drawable, xfi->gc, 0, 0, xfi->width, xfi->height); } xf_unlock_x11(xfi, TRUE); } BOOL xf_get_fds(freerdp* instance, void** rfds, int* rcount, void** wfds, int* wcount) { xfInfo* xfi = ((xfContext*) instance->context)->xfi; rfds[*rcount] = (void*)(long)(xfi->xfds); (*rcount)++; return TRUE; } BOOL xf_process_x_events(freerdp* instance) { BOOL status; XEvent xevent; int pending_status; xfInfo* xfi = ((xfContext*) instance->context)->xfi; if (initialized_xi == 0) { initialized_xi++; xf_input_init(xfi); } status = TRUE; pending_status = TRUE; while (pending_status) { xf_lock_x11(xfi, FALSE); pending_status = XPending(xfi->display); xf_unlock_x11(xfi, FALSE); if (pending_status) { ZeroMemory(&xevent, sizeof(xevent)); XNextEvent(xfi->display, &xevent); status = xf_event_process(instance, &xevent); if (!status) return status; } } return status; } void xf_create_window(xfInfo* xfi) { XEvent xevent; int width, height; char* windowTitle; ZeroMemory(&xevent, sizeof(xevent)); width = xfi->width; height = xfi->height; if (!xfi->remote_app) { xfi->attribs.background_pixel = BlackPixelOfScreen(xfi->screen); xfi->attribs.border_pixel = WhitePixelOfScreen(xfi->screen); xfi->attribs.backing_store = xfi->primary ? NotUseful : Always; xfi->attribs.override_redirect = xfi->grab_keyboard ? xfi->fullscreen : False; xfi->attribs.colormap = xfi->colormap; xfi->attribs.bit_gravity = NorthWestGravity; xfi->attribs.win_gravity = NorthWestGravity; if (xfi->instance->settings->WindowTitle) { windowTitle = _strdup(xfi->instance->settings->WindowTitle); } else if (xfi->instance->settings->ServerPort == 3389) { windowTitle = malloc(1 + sizeof("FreeRDP: ") + strlen(xfi->instance->settings->ServerHostname)); sprintf(windowTitle, "FreeRDP: %s", xfi->instance->settings->ServerHostname); } else { windowTitle = malloc(1 + sizeof("FreeRDP: ") + strlen(xfi->instance->settings->ServerHostname) + sizeof(":00000")); sprintf(windowTitle, "FreeRDP: %s:%i", xfi->instance->settings->ServerHostname, xfi->instance->settings->ServerPort); } xfi->window = xf_CreateDesktopWindow(xfi, windowTitle, width, height, xfi->settings->Decorations); free(windowTitle); if (xfi->fullscreen) xf_SetWindowFullscreen(xfi, xfi->window, xfi->fullscreen); xfi->unobscured = (xevent.xvisibility.state == VisibilityUnobscured); XSetWMProtocols(xfi->display, xfi->window->handle, &(xfi->WM_DELETE_WINDOW), 1); xfi->drawable = xfi->window->handle; } else { xfi->drawable = DefaultRootWindow(xfi->display); } } void xf_toggle_fullscreen(xfInfo* xfi) { Pixmap contents = 0; xf_lock_x11(xfi, TRUE); contents = XCreatePixmap(xfi->display, xfi->window->handle, xfi->width, xfi->height, xfi->depth); XCopyArea(xfi->display, xfi->primary, contents, xfi->gc, 0, 0, xfi->width, xfi->height, 0, 0); XDestroyWindow(xfi->display, xfi->window->handle); xfi->fullscreen = (xfi->fullscreen) ? FALSE : TRUE; xf_create_window(xfi); XCopyArea(xfi->display, contents, xfi->primary, xfi->gc, 0, 0, xfi->width, xfi->height, 0, 0); XFreePixmap(xfi->display, contents); xf_unlock_x11(xfi, TRUE); } void xf_lock_x11(xfInfo* xfi, BOOL display) { if (!xfi->UseXThreads) { WaitForSingleObject(xfi->mutex, INFINITE); } else { if (display) XLockDisplay(xfi->display); } } void xf_unlock_x11(xfInfo* xfi, BOOL display) { if (!xfi->UseXThreads) { ReleaseMutex(xfi->mutex); } else { if (display) XUnlockDisplay(xfi->display); } } BOOL xf_get_pixmap_info(xfInfo* xfi) { int i; int vi_count; int pf_count; XVisualInfo* vi; XVisualInfo* vis; XVisualInfo template; XPixmapFormatValues* pf; XPixmapFormatValues* pfs; XWindowAttributes window_attributes; pfs = XListPixmapFormats(xfi->display, &pf_count); if (pfs == NULL) { fprintf(stderr, "xf_get_pixmap_info: XListPixmapFormats failed\n"); return 1; } for (i = 0; i < pf_count; i++) { pf = pfs + i; if (pf->depth == xfi->depth) { xfi->bpp = pf->bits_per_pixel; xfi->scanline_pad = pf->scanline_pad; break; } } XFree(pfs); ZeroMemory(&template, sizeof(template)); template.class = TrueColor; template.screen = xfi->screen_number; if (XGetWindowAttributes(xfi->display, RootWindowOfScreen(xfi->screen), &window_attributes) == 0) { fprintf(stderr, "xf_get_pixmap_info: XGetWindowAttributes failed\n"); return FALSE; } vis = XGetVisualInfo(xfi->display, VisualClassMask | VisualScreenMask, &template, &vi_count); if (vis == NULL) { fprintf(stderr, "xf_get_pixmap_info: XGetVisualInfo failed\n"); return FALSE; } vi = NULL; for (i = 0; i < vi_count; i++) { vi = vis + i; if (vi->visual == window_attributes.visual) { xfi->visual = vi->visual; break; } } if (vi) { /* * Detect if the server visual has an inverted colormap * (BGR vs RGB, or red being the least significant byte) */ if (vi->red_mask & 0xFF) { xfi->clrconv->invert = TRUE; } } XFree(vis); if ((xfi->visual == NULL) || (xfi->scanline_pad == 0)) { return FALSE; } return TRUE; } static int (*_def_error_handler)(Display*, XErrorEvent*); int xf_error_handler(Display* d, XErrorEvent* ev) { char buf[256]; int do_abort = TRUE; XGetErrorText(d, ev->error_code, buf, sizeof(buf)); fprintf(stderr, "%s", buf); if (do_abort) abort(); _def_error_handler(d, ev); return FALSE; } int _xf_error_handler(Display* d, XErrorEvent* ev) { /* * ungrab the keyboard, in case a debugger is running in * another window. This make xf_error_handler() a potential * debugger breakpoint. */ XUngrabKeyboard(d, CurrentTime); return xf_error_handler(d, ev); } /** * Callback given to freerdp_connect() to process the pre-connect operations. * It will fill the rdp_freerdp structure (instance) with the appropriate options to use for the connection. * * @param instance - pointer to the rdp_freerdp structure that contains the connection's parameters, and will * be filled with the appropriate informations. * * @return TRUE if successful. FALSE otherwise. * Can exit with error code XF_EXIT_PARSE_ARGUMENTS if there is an error in the parameters. */ BOOL xf_pre_connect(freerdp* instance) { xfInfo* xfi; rdpSettings* settings; xfi = ((xfContext*) instance->context)->xfi; xfi->mutex = CreateMutex(NULL, FALSE, NULL); xfi->_context = instance->context; xfi->context = (xfContext*) instance->context; xfi->context->settings = instance->settings; xfi->instance = instance; settings = instance->settings; //if (status < 0) // exit(XF_EXIT_PARSE_ARGUMENTS); freerdp_client_load_addins(instance->context->channels, instance->settings); freerdp_channels_pre_connect(xfi->_context->channels, instance); if (settings->AuthenticationOnly) { /* Check --authonly has a username and password. */ if (settings->Username == NULL) { fprintf(stderr, "--authonly, but no -u username. Please provide one.\n"); exit(1); } if (settings->Password == NULL) { fprintf(stderr, "--authonly, but no -p password. Please provide one.\n"); exit(1); } fprintf(stderr, "%s:%d: Authentication only. Don't connect to X.\n", __FILE__, __LINE__); /* Avoid XWindows initialization and configuration below. */ return TRUE; } xfi->UseXThreads = TRUE; if (xfi->UseXThreads) { if (!XInitThreads()) { fprintf(stderr, "warning: XInitThreads() failure\n"); xfi->UseXThreads = FALSE; } } xfi->display = XOpenDisplay(NULL); if (xfi->display == NULL) { fprintf(stderr, "xf_pre_connect: failed to open display: %s\n", XDisplayName(NULL)); fprintf(stderr, "Please check that the $DISPLAY environment variable is properly set.\n"); return FALSE; } if (xfi->debug) { fprintf(stderr, "Enabling X11 debug mode.\n"); XSynchronize(xfi->display, TRUE); _def_error_handler = XSetErrorHandler(_xf_error_handler); } xfi->_NET_WM_ICON = XInternAtom(xfi->display, "_NET_WM_ICON", False); xfi->_MOTIF_WM_HINTS = XInternAtom(xfi->display, "_MOTIF_WM_HINTS", False); xfi->_NET_CURRENT_DESKTOP = XInternAtom(xfi->display, "_NET_CURRENT_DESKTOP", False); xfi->_NET_WORKAREA = XInternAtom(xfi->display, "_NET_WORKAREA", False); xfi->_NET_WM_STATE = XInternAtom(xfi->display, "_NET_WM_STATE", False); xfi->_NET_WM_STATE_FULLSCREEN = XInternAtom(xfi->display, "_NET_WM_STATE_FULLSCREEN", False); xfi->_NET_WM_WINDOW_TYPE = XInternAtom(xfi->display, "_NET_WM_WINDOW_TYPE", False); xfi->_NET_WM_WINDOW_TYPE_NORMAL = XInternAtom(xfi->display, "_NET_WM_WINDOW_TYPE_NORMAL", False); xfi->_NET_WM_WINDOW_TYPE_DIALOG = XInternAtom(xfi->display, "_NET_WM_WINDOW_TYPE_DIALOG", False); xfi->_NET_WM_WINDOW_TYPE_POPUP = XInternAtom(xfi->display, "_NET_WM_WINDOW_TYPE_POPUP", False); xfi->_NET_WM_WINDOW_TYPE_UTILITY = XInternAtom(xfi->display, "_NET_WM_WINDOW_TYPE_UTILITY", False); xfi->_NET_WM_WINDOW_TYPE_DROPDOWN_MENU = XInternAtom(xfi->display, "_NET_WM_WINDOW_TYPE_DROPDOWN_MENU", False); xfi->_NET_WM_STATE_SKIP_TASKBAR = XInternAtom(xfi->display, "_NET_WM_STATE_SKIP_TASKBAR", False); xfi->_NET_WM_STATE_SKIP_PAGER = XInternAtom(xfi->display, "_NET_WM_STATE_SKIP_PAGER", False); xfi->_NET_WM_MOVERESIZE = XInternAtom(xfi->display, "_NET_WM_MOVERESIZE", False); xfi->_NET_MOVERESIZE_WINDOW = XInternAtom(xfi->display, "_NET_MOVERESIZE_WINDOW", False); xfi->WM_PROTOCOLS = XInternAtom(xfi->display, "WM_PROTOCOLS", False); xfi->WM_DELETE_WINDOW = XInternAtom(xfi->display, "WM_DELETE_WINDOW", False); xfi->WM_STATE = XInternAtom(xfi->display, "WM_STATE", False); xf_kbd_init(xfi); xfi->clrconv = freerdp_clrconv_new(CLRCONV_ALPHA); instance->context->cache = cache_new(instance->settings); xfi->xfds = ConnectionNumber(xfi->display); xfi->screen_number = DefaultScreen(xfi->display); xfi->screen = ScreenOfDisplay(xfi->display, xfi->screen_number); xfi->depth = DefaultDepthOfScreen(xfi->screen); xfi->big_endian = (ImageByteOrder(xfi->display) == MSBFirst); xfi->complex_regions = TRUE; xfi->fullscreen = settings->Fullscreen; xfi->grab_keyboard = settings->GrabKeyboard; xfi->fullscreen_toggle = settings->ToggleFullscreen; xf_detect_monitors(xfi, settings); return TRUE; } /** * Callback given to freerdp_connect() to perform post-connection operations. * It will be called only if the connection was initialized properly, and will continue the initialization based on the * newly created connection. */ BOOL xf_post_connect(freerdp* instance) { xfInfo* xfi; XGCValues gcv; rdpCache* cache; rdpChannels* channels; rdpSettings* settings; RFX_CONTEXT* rfx_context = NULL; NSC_CONTEXT* nsc_context = NULL; xfi = ((xfContext*) instance->context)->xfi; cache = instance->context->cache; channels = xfi->_context->channels; settings = instance->settings; if (!xf_get_pixmap_info(xfi)) return FALSE; xf_register_graphics(instance->context->graphics); if (xfi->settings->SoftwareGdi) { rdpGdi* gdi; UINT32 flags; flags = CLRCONV_ALPHA; if (xfi->bpp > 16) flags |= CLRBUF_32BPP; else flags |= CLRBUF_16BPP; gdi_init(instance, flags, NULL); gdi = instance->context->gdi; xfi->primary_buffer = gdi->primary_buffer; rfx_context = gdi->rfx_context; } else { xfi->srcBpp = instance->settings->ColorDepth; xf_gdi_register_update_callbacks(instance->update); xfi->hdc = gdi_CreateDC(xfi->clrconv, xfi->bpp); if (instance->settings->RemoteFxCodec) { rfx_context = (void*) rfx_context_new(); xfi->rfx_context = rfx_context; } if (instance->settings->NSCodec) { nsc_context = (void*) nsc_context_new(); xfi->nsc_context = nsc_context; } } xfi->width = settings->DesktopWidth; xfi->height = settings->DesktopHeight; if (settings->RemoteApplicationMode) xfi->remote_app = TRUE; xf_create_window(xfi); ZeroMemory(&gcv, sizeof(gcv)); xfi->modifier_map = XGetModifierMapping(xfi->display); xfi->gc = XCreateGC(xfi->display, xfi->drawable, GCGraphicsExposures, &gcv); xfi->primary = XCreatePixmap(xfi->display, xfi->drawable, xfi->width, xfi->height, xfi->depth); xfi->drawing = xfi->primary; xfi->bitmap_mono = XCreatePixmap(xfi->display, xfi->drawable, 8, 8, 1); xfi->gc_mono = XCreateGC(xfi->display, xfi->bitmap_mono, GCGraphicsExposures, &gcv); XSetFunction(xfi->display, xfi->gc, GXcopy); XSetFillStyle(xfi->display, xfi->gc, FillSolid); XSetForeground(xfi->display, xfi->gc, BlackPixelOfScreen(xfi->screen)); XFillRectangle(xfi->display, xfi->primary, xfi->gc, 0, 0, xfi->width, xfi->height); XFlush(xfi->display); xfi->image = XCreateImage(xfi->display, xfi->visual, xfi->depth, ZPixmap, 0, (char*) xfi->primary_buffer, xfi->width, xfi->height, xfi->scanline_pad, 0); xfi->bmp_codec_none = (BYTE*) malloc(64 * 64 * 4); if (xfi->settings->SoftwareGdi) { instance->update->BeginPaint = xf_sw_begin_paint; instance->update->EndPaint = xf_sw_end_paint; instance->update->DesktopResize = xf_sw_desktop_resize; } else { instance->update->BeginPaint = xf_hw_begin_paint; instance->update->EndPaint = xf_hw_end_paint; instance->update->DesktopResize = xf_hw_desktop_resize; } pointer_cache_register_callbacks(instance->update); if (!xfi->settings->SoftwareGdi) { glyph_cache_register_callbacks(instance->update); brush_cache_register_callbacks(instance->update); bitmap_cache_register_callbacks(instance->update); offscreen_cache_register_callbacks(instance->update); palette_cache_register_callbacks(instance->update); } instance->context->rail = rail_new(instance->settings); rail_register_update_callbacks(instance->context->rail, instance->update); xf_rail_register_callbacks(xfi, instance->context->rail); freerdp_channels_post_connect(channels, instance); xf_tsmf_init(xfi, xv_port); xf_cliprdr_init(xfi, channels); //begin init touch input { } //end init touch input IFCALL(xfi->client->OnResizeWindow, instance, settings->DesktopWidth, settings->DesktopHeight); return TRUE; } /** Callback set in the rdp_freerdp structure, and used to get the user's password, * if required to establish the connection. * This function is actually called in credssp_ntlmssp_client_init() * @see rdp_server_accept_nego() and rdp_check_fds() * @param instance - pointer to the rdp_freerdp structure that contains the connection settings * @param username - unused * @param password - on return: pointer to a character string that will be filled by the password entered by the user. * Note that this character string will be allocated inside the function, and needs to be deallocated by the caller * using free(), even in case this function fails. * @param domain - unused * @return TRUE if a password was successfully entered. See freerdp_passphrase_read() for more details. */ BOOL xf_authenticate(freerdp* instance, char** username, char** password, char** domain) { // FIXME: seems this callback may be called when 'username' is not known. // But it doesn't do anything to fix it... *password = malloc(password_size * sizeof(char)); if (freerdp_passphrase_read("Password: ", *password, password_size, instance->settings->CredentialsFromStdin) == NULL) return FALSE; return TRUE; } /** Callback set in the rdp_freerdp structure, and used to make a certificate validation * when the connection requires it. * This function will actually be called by tls_verify_certificate(). * @see rdp_client_connect() and tls_connect() * @param instance - pointer to the rdp_freerdp structure that contains the connection settings * @param subject * @param issuer * @param fingerprint * @return TRUE if the certificate is trusted. FALSE otherwise. */ BOOL xf_verify_certificate(freerdp* instance, char* subject, char* issuer, char* fingerprint) { char answer; printf("Certificate details:\n"); printf("\tSubject: %s\n", subject); printf("\tIssuer: %s\n", issuer); printf("\tThumbprint: %s\n", fingerprint); printf("The above X.509 certificate could not be verified, possibly because you do not have " "the CA certificate in your certificate store, or the certificate has expired. " "Please look at the documentation on how to create local certificate store for a private CA.\n"); while (1) { printf("Do you trust the above certificate? (Y/N) "); answer = fgetc(stdin); if (feof(stdin)) { printf("\nError: Could not read answer from stdin."); if (instance->settings->CredentialsFromStdin) printf(" - Run without parameter \"--from-stdin\" to set trust."); printf("\n"); return FALSE; } if (answer == 'y' || answer == 'Y') { return TRUE; } else if (answer == 'n' || answer == 'N') { break; } printf("\n"); } return FALSE; } int xf_logon_error_info(freerdp* instance, UINT32 data, UINT32 type) { xfInfo* xfi; xfi = ((xfContext*) instance->context)->xfi; xf_rail_disable_remoteapp_mode(xfi); return 1; } int xf_receive_channel_data(freerdp* instance, int channelId, BYTE* data, int size, int flags, int total_size) { return freerdp_channels_data(instance, channelId, data, size, flags, total_size); } void xf_process_channel_event(rdpChannels* channels, freerdp* instance) { xfInfo* xfi; wMessage* event; xfi = ((xfContext*) instance->context)->xfi; event = freerdp_channels_pop_event(channels); if (event) { switch (GetMessageClass(event->id)) { case RailChannel_Class: xf_process_rail_event(xfi, channels, event); break; case TsmfChannel_Class: xf_process_tsmf_event(xfi, event); break; case CliprdrChannel_Class: xf_process_cliprdr_event(xfi, event); break; default: break; } freerdp_event_free(event); } } void xf_window_free(xfInfo* xfi) { rdpContext* context = xfi->instance->context; XFreeModifiermap(xfi->modifier_map); xfi->modifier_map = 0; if (xfi->gc) { XFreeGC(xfi->display, xfi->gc); xfi->gc = 0; } if (xfi->gc_mono) { XFreeGC(xfi->display, xfi->gc_mono); xfi->gc_mono = 0; } if (xfi->window) { xf_DestroyWindow(xfi, xfi->window); xfi->window = NULL; } if (xfi->primary) { XFreePixmap(xfi->display, xfi->primary); xfi->primary = 0; } if (xfi->bitmap_mono) { XFreePixmap(xfi->display, xfi->bitmap_mono); xfi->bitmap_mono = 0; } if (xfi->image) { xfi->image->data = NULL; XDestroyImage(xfi->image); xfi->image = NULL; } if (context) { cache_free(context->cache); context->cache = NULL; rail_free(context->rail); context->rail = NULL; } if (xfi->rfx_context) { rfx_context_free(xfi->rfx_context); xfi->rfx_context = NULL; } if (xfi->nsc_context) { nsc_context_free(xfi->nsc_context); xfi->nsc_context = NULL; } freerdp_clrconv_free(xfi->clrconv); xfi->clrconv = NULL; if (xfi->hdc) gdi_DeleteDC(xfi->hdc); xf_tsmf_uninit(xfi); xf_cliprdr_uninit(xfi); } void* xf_update_thread(void* arg) { int status; wMessage message; wMessageQueue* queue; freerdp* instance = (freerdp*) arg; status = 1; queue = freerdp_get_message_queue(instance, FREERDP_UPDATE_MESSAGE_QUEUE); while (MessageQueue_Wait(queue)) { while (MessageQueue_Peek(queue, &message, TRUE)) { status = freerdp_message_queue_process_message(instance, FREERDP_UPDATE_MESSAGE_QUEUE, &message); if (!status) break; } if (!status) break; } return NULL; } void* xf_input_thread(void* arg) { xfInfo* xfi; HANDLE event; XEvent xevent; wMessageQueue* queue; int pending_status = 1; int process_status = 1; freerdp* instance = (freerdp*) arg; xfi = ((xfContext*) instance->context)->xfi; xf_input_init(xfi); event = CreateFileDescriptorEvent(NULL, FALSE, FALSE, xfi->xfds); while (WaitForSingleObject(event, INFINITE) == WAIT_OBJECT_0) { do { xf_lock_x11(xfi, FALSE); pending_status = XPending(xfi->display); xf_unlock_x11(xfi, FALSE); if (pending_status) { xf_lock_x11(xfi, FALSE); ZeroMemory(&xevent, sizeof(xevent)); XNextEvent(xfi->display, &xevent); process_status = xf_event_process(instance, &xevent); xf_unlock_x11(xfi, FALSE); if (!process_status) break; } } while (pending_status); if (!process_status) break; } queue = freerdp_get_message_queue(instance, FREERDP_INPUT_MESSAGE_QUEUE); MessageQueue_PostQuit(queue, 0); return NULL; } void* xf_channels_thread(void* arg) { int status; xfInfo* xfi; HANDLE event; rdpChannels* channels; freerdp* instance = (freerdp*) arg; xfi = ((xfContext*) instance->context)->xfi; channels = instance->context->channels; event = freerdp_channels_get_event_handle(instance); while (WaitForSingleObject(event, INFINITE) == WAIT_OBJECT_0) { status = freerdp_channels_process_pending_messages(instance); xf_process_channel_event(channels, instance); } return NULL; } /** Main loop for the rdp connection. * It will be run from the thread's entry point (thread_func()). * It initiates the connection, and will continue to run until the session ends, * processing events as they are received. * @param instance - pointer to the rdp_freerdp structure that contains the session's settings * @return A code from the enum XF_EXIT_CODE (0 if successful) */ void* xf_thread(void* param) { int i; int fds; xfInfo* xfi; int max_fds; int rcount; int wcount; BOOL status; int exit_code; void* rfds[32]; void* wfds[32]; fd_set rfds_set; fd_set wfds_set; freerdp* instance; int fd_input_event; HANDLE input_event; int select_status; BOOL async_update; BOOL async_input; BOOL async_channels; BOOL async_transport; HANDLE update_thread; HANDLE input_thread; HANDLE channels_thread; rdpChannels* channels; rdpSettings* settings; struct timeval timeout; exit_code = 0; input_event = NULL; instance = (freerdp*) param; ZeroMemory(rfds, sizeof(rfds)); ZeroMemory(wfds, sizeof(wfds)); ZeroMemory(&timeout, sizeof(struct timeval)); status = freerdp_connect(instance); xfi = ((xfContext*) instance->context)->xfi; /* Connection succeeded. --authonly ? */ if (instance->settings->AuthenticationOnly) { freerdp_disconnect(instance); fprintf(stderr, "%s:%d: Authentication only, exit status %d\n", __FILE__, __LINE__, !status); exit(!status); } if (!status) { exit_code = XF_EXIT_CONN_FAILED; ExitThread(exit_code); } channels = instance->context->channels; settings = instance->context->settings; async_update = settings->AsyncUpdate; async_input = settings->AsyncInput; async_channels = settings->AsyncChannels; async_transport = settings->AsyncTransport; if (async_update) { update_thread = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE) xf_update_thread, instance, 0, NULL); } if (async_input) { input_thread = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE) xf_input_thread, instance, 0, NULL); } if (async_channels) { channels_thread = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE) xf_channels_thread, instance, 0, NULL); } while (!xfi->disconnect && !freerdp_shall_disconnect(instance)) { rcount = 0; wcount = 0; if (!async_transport) { if (freerdp_get_fds(instance, rfds, &rcount, wfds, &wcount) != TRUE) { fprintf(stderr, "Failed to get FreeRDP file descriptor\n"); exit_code = XF_EXIT_CONN_FAILED; break; } } if (!async_channels) { if (freerdp_channels_get_fds(channels, instance, rfds, &rcount, wfds, &wcount) != TRUE) { fprintf(stderr, "Failed to get channel manager file descriptor\n"); exit_code = XF_EXIT_CONN_FAILED; break; } } if (!async_input) { if (xf_get_fds(instance, rfds, &rcount, wfds, &wcount) != TRUE) { fprintf(stderr, "Failed to get xfreerdp file descriptor\n"); exit_code = XF_EXIT_CONN_FAILED; break; } } else { input_event = freerdp_get_message_queue_event_handle(instance, FREERDP_INPUT_MESSAGE_QUEUE); fd_input_event = GetEventFileDescriptor(input_event); rfds[rcount++] = (void*) (long) fd_input_event; } max_fds = 0; FD_ZERO(&rfds_set); FD_ZERO(&wfds_set); for (i = 0; i < rcount; i++) { fds = (int)(long)(rfds[i]); if (fds > max_fds) max_fds = fds; FD_SET(fds, &rfds_set); } if (max_fds == 0) break; timeout.tv_sec = 1; timeout.tv_usec = 0; select_status = select(max_fds + 1, &rfds_set, NULL, NULL, &timeout); if (select_status == 0) { continue; /* select timeout */ } else if (select_status == -1) { /* these are not really errors */ if (!((errno == EAGAIN) || (errno == EWOULDBLOCK) || (errno == EINPROGRESS) || (errno == EINTR))) /* signal occurred */ { fprintf(stderr, "xfreerdp_run: select failed\n"); break; } } if (!async_transport) { if (freerdp_check_fds(instance) != TRUE) { fprintf(stderr, "Failed to check FreeRDP file descriptor\n"); break; } } if (!async_channels) { if (freerdp_channels_check_fds(channels, instance) != TRUE) { fprintf(stderr, "Failed to check channel manager file descriptor\n"); break; } xf_process_channel_event(channels, instance); } if (!async_input) { if (xf_process_x_events(instance) != TRUE) { fprintf(stderr, "Closed from X11\n"); break; } } else { if (WaitForSingleObject(input_event, 0) == WAIT_OBJECT_0) { if (!freerdp_message_queue_process_pending_messages(instance, FREERDP_INPUT_MESSAGE_QUEUE)) { fprintf(stderr, "User Disconnect\n"); xfi->disconnect = TRUE; break; } } } } if (async_update) { wMessageQueue* update_queue = freerdp_get_message_queue(instance, FREERDP_UPDATE_MESSAGE_QUEUE); MessageQueue_PostQuit(update_queue, 0); WaitForSingleObject(update_thread, INFINITE); CloseHandle(update_thread); } FILE* fin = fopen("/tmp/tsmf.tid", "rt"); if (fin) { FILE* fin1; int thid = 0; int timeout; fscanf(fin, "%d", &thid); fclose(fin); pthread_kill((pthread_t) (size_t) thid, SIGUSR1); fin1 = fopen("/tmp/tsmf.tid", "rt"); timeout = 5; while (fin1) { fclose(fin1); sleep(1); timeout--; if (timeout <= 0) { unlink("/tmp/tsmf.tid"); pthread_kill((pthread_t) (size_t) thid, SIGKILL); break; } fin1 = fopen("/tmp/tsmf.tid", "rt"); } } if (!exit_code) exit_code = freerdp_error_info(instance); freerdp_channels_close(channels, instance); freerdp_channels_free(channels); freerdp_disconnect(instance); gdi_free(instance); ExitThread(exit_code); } DWORD xf_exit_code_from_disconnect_reason(DWORD reason) { if (reason == 0 || (reason >= XF_EXIT_PARSE_ARGUMENTS && reason <= XF_EXIT_CONN_FAILED)) return reason; /* License error set */ else if (reason >= 0x100 && reason <= 0x10A) reason -= 0x100 + XF_EXIT_LICENSE_INTERNAL; /* RDP protocol error set */ else if (reason >= 0x10c9 && reason <= 0x1193) reason = XF_EXIT_RDP; /* There's no need to test protocol-independent codes: they match */ else if (!(reason <= 0xB)) reason = XF_EXIT_UNKNOWN; return reason; } /** * Client Interface */ int freerdp_client_global_init() { setlocale(LC_ALL, ""); freerdp_handle_signals(); freerdp_channels_global_init(); return 0; } int freerdp_client_global_uninit() { freerdp_channels_global_uninit(); return 0; } int freerdp_client_start(xfInfo* xfi) { xfi->thread = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE) xf_thread, (void*) xfi->instance, 0, NULL); return 0; } int freerdp_client_stop(xfInfo* xfi) { if (xfi->instance->settings->AsyncInput) { wMessageQueue* queue; queue = freerdp_get_message_queue(xfi->instance, FREERDP_INPUT_MESSAGE_QUEUE); MessageQueue_PostQuit(queue, 0); } else { xfi->disconnect = TRUE; } return 0; } xfInfo* freerdp_client_new(int argc, char** argv) { int index; int status; xfInfo* xfi; rdpFile* file; freerdp* instance; rdpSettings* settings; instance = freerdp_new(); instance->PreConnect = xf_pre_connect; instance->PostConnect = xf_post_connect; instance->Authenticate = xf_authenticate; instance->VerifyCertificate = xf_verify_certificate; instance->LogonErrorInfo = xf_logon_error_info; instance->ReceiveChannelData = xf_receive_channel_data; instance->context_size = sizeof(xfContext); instance->ContextNew = (pContextNew) xf_context_new; instance->ContextFree = (pContextFree) xf_context_free; freerdp_context_new(instance); instance->context->argc = argc; instance->context->argv = (char**) malloc(sizeof(char*) * argc); for (index = 0; index < argc; index++) instance->context->argv[index] = _strdup(argv[index]); xfi = (xfInfo*) malloc(sizeof(xfInfo)); ZeroMemory(xfi, sizeof(xfInfo)); ((xfContext*) instance->context)->xfi = xfi; xfi->instance = instance; settings = instance->settings; xfi->client = instance->context->client; xfi->settings = instance->context->settings; status = freerdp_client_parse_command_line_arguments(instance->context->argc, instance->context->argv, settings); if (status < 0) { freerdp_context_free(xfi->instance); freerdp_free(xfi->instance); free(xfi); return NULL; } if (settings->ConnectionFile) { file = freerdp_client_rdp_file_new(); fprintf(stderr, "Using connection file: %s\n", settings->ConnectionFile); freerdp_client_parse_rdp_file(file, settings->ConnectionFile); freerdp_client_populate_settings_from_rdp_file(file, settings); } settings->OsMajorType = OSMAJORTYPE_UNIX; settings->OsMinorType = OSMINORTYPE_NATIVE_XSERVER; settings->OrderSupport[NEG_DSTBLT_INDEX] = TRUE; settings->OrderSupport[NEG_PATBLT_INDEX] = TRUE; settings->OrderSupport[NEG_SCRBLT_INDEX] = TRUE; settings->OrderSupport[NEG_OPAQUE_RECT_INDEX] = TRUE; settings->OrderSupport[NEG_DRAWNINEGRID_INDEX] = FALSE; settings->OrderSupport[NEG_MULTIDSTBLT_INDEX] = FALSE; settings->OrderSupport[NEG_MULTIPATBLT_INDEX] = FALSE; settings->OrderSupport[NEG_MULTISCRBLT_INDEX] = FALSE; settings->OrderSupport[NEG_MULTIOPAQUERECT_INDEX] = TRUE; settings->OrderSupport[NEG_MULTI_DRAWNINEGRID_INDEX] = FALSE; settings->OrderSupport[NEG_LINETO_INDEX] = TRUE; settings->OrderSupport[NEG_POLYLINE_INDEX] = TRUE; settings->OrderSupport[NEG_MEMBLT_INDEX] = settings->BitmapCacheEnabled; settings->OrderSupport[NEG_MEM3BLT_INDEX] = (settings->SoftwareGdi) ? TRUE : FALSE; settings->OrderSupport[NEG_MEMBLT_V2_INDEX] = settings->BitmapCacheEnabled; settings->OrderSupport[NEG_MEM3BLT_V2_INDEX] = FALSE; settings->OrderSupport[NEG_SAVEBITMAP_INDEX] = FALSE; settings->OrderSupport[NEG_GLYPH_INDEX_INDEX] = TRUE; settings->OrderSupport[NEG_FAST_INDEX_INDEX] = TRUE; settings->OrderSupport[NEG_FAST_GLYPH_INDEX] = TRUE; settings->OrderSupport[NEG_POLYGON_SC_INDEX] = (settings->SoftwareGdi) ? FALSE : TRUE; settings->OrderSupport[NEG_POLYGON_CB_INDEX] = (settings->SoftwareGdi) ? FALSE : TRUE; settings->OrderSupport[NEG_ELLIPSE_SC_INDEX] = FALSE; settings->OrderSupport[NEG_ELLIPSE_CB_INDEX] = FALSE; return xfi; } void freerdp_client_free(xfInfo* xfi) { if (xfi) { int index; rdpContext* context; xf_window_free(xfi); free(xfi->bmp_codec_none); XCloseDisplay(xfi->display); context = (rdpContext*) xfi->context; for (index = 0; index < context->argc; index++) free(context->argv[index]); free(context->argv); freerdp_context_free(xfi->instance); freerdp_free(xfi->instance); free(xfi); } }