diff options
Diffstat (limited to 'backend/rdp')
| -rw-r--r-- | backend/rdp/backend.c | 133 | ||||
| -rw-r--r-- | backend/rdp/keyboard.c | 219 | ||||
| -rw-r--r-- | backend/rdp/listener.c | 61 | ||||
| -rw-r--r-- | backend/rdp/meson.build | 36 | ||||
| -rw-r--r-- | backend/rdp/output.c | 331 | ||||
| -rw-r--r-- | backend/rdp/peer.c | 360 | ||||
| -rw-r--r-- | backend/rdp/pointer.c | 40 |
7 files changed, 0 insertions, 1180 deletions
diff --git a/backend/rdp/backend.c b/backend/rdp/backend.c deleted file mode 100644 index c0b63921..00000000 --- a/backend/rdp/backend.c +++ /dev/null @@ -1,133 +0,0 @@ -#define _POSIX_C_SOURCE 200809L -#include <assert.h> -#include <stdlib.h> -#include <string.h> -#include <wlr/render/egl.h> -#include <wlr/render/gles2.h> -#include <wlr/util/log.h> -#include "backend/rdp.h" -#include "util/signal.h" - -struct wlr_rdp_backend *rdp_backend_from_backend( - struct wlr_backend *wlr_backend) { - assert(wlr_backend_is_rdp(wlr_backend)); - return (struct wlr_rdp_backend *)wlr_backend; -} - -static bool backend_start(struct wlr_backend *wlr_backend) { - struct wlr_rdp_backend *backend = - rdp_backend_from_backend(wlr_backend); - assert(backend->listener == NULL); - wlr_log(WLR_INFO, "Starting RDP backend"); - if (!rdp_configure_listener(backend)) { - return false; - } - return true; -} - -void wlr_rdp_backend_set_address(struct wlr_backend *wlr_backend, - const char *address) { - struct wlr_rdp_backend *backend = - rdp_backend_from_backend(wlr_backend); - assert(backend->listener == NULL); - backend->address = strdup(address); -} - -void wlr_rdp_backend_set_port(struct wlr_backend *wlr_backend, int port) { - struct wlr_rdp_backend *backend = - rdp_backend_from_backend(wlr_backend); - assert(backend->listener == NULL); - backend->port = port; -} - -static void backend_destroy(struct wlr_backend *wlr_backend) { - struct wlr_rdp_backend *backend = - rdp_backend_from_backend(wlr_backend); - if (!wlr_backend) { - return; - } - - wl_list_remove(&backend->display_destroy.link); - - struct wlr_rdp_peer_context *client; - wl_list_for_each(client, &backend->clients, link) { - freerdp_peer_context_free(client->peer); - freerdp_peer_free(client->peer); - } - - wlr_signal_emit_safe(&wlr_backend->events.destroy, backend); - - wlr_renderer_destroy(backend->renderer); - wlr_egl_finish(&backend->egl); - free(backend->address); - free(backend); -} - -static struct wlr_renderer *backend_get_renderer( - struct wlr_backend *wlr_backend) { - struct wlr_rdp_backend *backend = - rdp_backend_from_backend(wlr_backend); - return backend->renderer; -} - -static const struct wlr_backend_impl backend_impl = { - .start = backend_start, - .destroy = backend_destroy, - .get_renderer = backend_get_renderer, -}; - -static void handle_display_destroy(struct wl_listener *listener, void *data) { - struct wlr_rdp_backend *backend = - wl_container_of(listener, backend, display_destroy); - backend_destroy(&backend->backend); -} - -struct wlr_backend *wlr_rdp_backend_create(struct wl_display *display, - wlr_renderer_create_func_t create_renderer_func, - const char *tls_cert_path, const char *tls_key_path) { - wlr_log(WLR_INFO, "Creating RDP backend"); - - struct wlr_rdp_backend *backend = - calloc(1, sizeof(struct wlr_rdp_backend)); - if (!backend) { - wlr_log(WLR_ERROR, "Failed to allocate wlr_rdp_backend"); - return NULL; - } - wlr_backend_init(&backend->backend, &backend_impl); - backend->display = display; - backend->tls_cert_path = tls_cert_path; - backend->tls_key_path = tls_key_path; - backend->address = strdup("127.0.0.1"); - backend->port = 3389; - wl_list_init(&backend->clients); - - static const EGLint config_attribs[] = { - EGL_SURFACE_TYPE, EGL_PBUFFER_BIT, - EGL_ALPHA_SIZE, 0, - EGL_BLUE_SIZE, 1, - EGL_GREEN_SIZE, 1, - EGL_RED_SIZE, 1, - EGL_NONE, - }; - - if (!create_renderer_func) { - create_renderer_func = wlr_renderer_autocreate; - } - - backend->renderer = create_renderer_func(&backend->egl, - EGL_PLATFORM_SURFACELESS_MESA, NULL, (EGLint*)config_attribs, 0); - if (!backend->renderer) { - wlr_log(WLR_ERROR, "Failed to create renderer"); - free(backend); - return NULL; - } - - backend->display_destroy.notify = handle_display_destroy; - wl_display_add_destroy_listener(display, &backend->display_destroy); - - return &backend->backend; -} - -bool wlr_backend_is_rdp(struct wlr_backend *backend) { - return backend->impl == &backend_impl; -} diff --git a/backend/rdp/keyboard.c b/backend/rdp/keyboard.c deleted file mode 100644 index 78dd8b08..00000000 --- a/backend/rdp/keyboard.c +++ /dev/null @@ -1,219 +0,0 @@ -#include <stdlib.h> -#include <wayland-server-core.h> -#include <wlr/types/wlr_input_device.h> -#include <wlr/types/wlr_keyboard.h> -#include <wlr/interfaces/wlr_keyboard.h> -#include <wlr/interfaces/wlr_input_device.h> -#include <wlr/util/log.h> -#include <xkbcommon/xkbcommon.h> -#include "backend/rdp.h" -#include "util/signal.h" - -struct rdp_to_xkb_keyboard_layout { - UINT32 rdp_layout_code; - const char *xkb_layout; - const char *xkb_variant; -}; - -/* table reversed from - https://github.com/awakecoding/FreeRDP/blob/master/libfreerdp/locale/xkb_layout_ids.c#L811 */ -static struct rdp_to_xkb_keyboard_layout rdp_keyboards[] = { - {KBD_ARABIC_101, "ara", 0}, - {KBD_BULGARIAN, 0, 0}, - {KBD_CHINESE_TRADITIONAL_US, 0, 0}, - {KBD_CZECH, "cz", 0}, - {KBD_CZECH_PROGRAMMERS, "cz", "bksl"}, - {KBD_CZECH_QWERTY, "cz", "qwerty"}, - {KBD_DANISH, "dk", 0}, - {KBD_GERMAN, "de", 0}, - {KBD_GERMAN_NEO, "de", "neo"}, - {KBD_GERMAN_IBM, "de", "qwerty"}, - {KBD_GREEK, "gr", 0}, - {KBD_GREEK_220, "gr", "simple"}, - {KBD_GREEK_319, "gr", "extended"}, - {KBD_GREEK_POLYTONIC, "gr", "polytonic"}, - {KBD_US, "us", 0}, - {KBD_US_ENGLISH_TABLE_FOR_IBM_ARABIC_238_L, "ara", "buckwalter"}, - {KBD_SPANISH, "es", 0}, - {KBD_SPANISH_VARIATION, "es", "nodeadkeys"}, - {KBD_FINNISH, "fi", 0}, - {KBD_FRENCH, "fr", 0}, - {KBD_HEBREW, "il", 0}, - {KBD_HUNGARIAN, "hu", 0}, - {KBD_HUNGARIAN_101_KEY, "hu", "standard"}, - {KBD_ICELANDIC, "is", 0}, - {KBD_ITALIAN, "it", 0}, - {KBD_ITALIAN_142, "it", "nodeadkeys"}, - {KBD_JAPANESE, "jp", 0}, - {KBD_JAPANESE_INPUT_SYSTEM_MS_IME2002, "jp", "kana"}, - {KBD_KOREAN, "kr", 0}, - {KBD_KOREAN_INPUT_SYSTEM_IME_2000, "kr", "kr104"}, - {KBD_DUTCH, "nl", 0}, - {KBD_NORWEGIAN, "no", 0}, - {KBD_POLISH_PROGRAMMERS, "pl", 0}, - {KBD_POLISH_214, "pl", "qwertz"}, - {KBD_ROMANIAN, "ro", 0}, - {KBD_RUSSIAN, "ru", 0}, - {KBD_RUSSIAN_TYPEWRITER, "ru", "typewriter"}, - {KBD_CROATIAN, "hr", 0}, - {KBD_SLOVAK, "sk", 0}, - {KBD_SLOVAK_QWERTY, "sk", "qwerty"}, - {KBD_ALBANIAN, 0, 0}, - {KBD_SWEDISH, "se", 0}, - {KBD_THAI_KEDMANEE, "th", 0}, - {KBD_THAI_KEDMANEE_NON_SHIFTLOCK, "th", "tis"}, - {KBD_TURKISH_Q, "tr", 0}, - {KBD_TURKISH_F, "tr", "f"}, - {KBD_URDU, "in", "urd-phonetic3"}, - {KBD_UKRAINIAN, "ua", 0}, - {KBD_BELARUSIAN, "by", 0}, - {KBD_SLOVENIAN, "si", 0}, - {KBD_ESTONIAN, "ee", 0}, - {KBD_LATVIAN, "lv", 0}, - {KBD_LITHUANIAN_IBM, "lt", "ibm"}, - {KBD_FARSI, "af", 0}, - {KBD_VIETNAMESE, "vn", 0}, - {KBD_ARMENIAN_EASTERN, "am", 0}, - {KBD_AZERI_LATIN, 0, 0}, - {KBD_FYRO_MACEDONIAN, "mk", 0}, - {KBD_GEORGIAN, "ge", 0}, - {KBD_FAEROESE, 0, 0}, - {KBD_DEVANAGARI_INSCRIPT, 0, 0}, - {KBD_MALTESE_47_KEY, 0, 0}, - {KBD_NORWEGIAN_WITH_SAMI, "no", "smi"}, - {KBD_KAZAKH, "kz", 0}, - {KBD_KYRGYZ_CYRILLIC, "kg", "phonetic"}, - {KBD_TATAR, "ru", "tt"}, - {KBD_BENGALI, "bd", 0}, - {KBD_BENGALI_INSCRIPT, "bd", "probhat"}, - {KBD_PUNJABI, 0, 0}, - {KBD_GUJARATI, "in", "guj"}, - {KBD_TAMIL, "in", "tam"}, - {KBD_TELUGU, "in", "tel"}, - {KBD_KANNADA, "in", "kan"}, - {KBD_MALAYALAM, "in", "mal"}, - {KBD_HINDI_TRADITIONAL, "in", 0}, - {KBD_MARATHI, 0, 0}, - {KBD_MONGOLIAN_CYRILLIC, "mn", 0}, - {KBD_UNITED_KINGDOM_EXTENDED, "gb", "intl"}, - {KBD_SYRIAC, "syc", 0}, - {KBD_SYRIAC_PHONETIC, "syc", "syc_phonetic"}, - {KBD_NEPALI, "np", 0}, - {KBD_PASHTO, "af", "ps"}, - {KBD_DIVEHI_PHONETIC, 0, 0}, - {KBD_LUXEMBOURGISH, 0, 0}, - {KBD_MAORI, "mao", 0}, - {KBD_CHINESE_SIMPLIFIED_US, 0, 0}, - {KBD_SWISS_GERMAN, "ch", "de_nodeadkeys"}, - {KBD_UNITED_KINGDOM, "gb", 0}, - {KBD_LATIN_AMERICAN, "latam", 0}, - {KBD_BELGIAN_FRENCH, "be", 0}, - {KBD_BELGIAN_PERIOD, "be", "oss_sundeadkeys"}, - {KBD_PORTUGUESE, "pt", 0}, - {KBD_SERBIAN_LATIN, "rs", 0}, - {KBD_AZERI_CYRILLIC, "az", "cyrillic"}, - {KBD_SWEDISH_WITH_SAMI, "se", "smi"}, - {KBD_UZBEK_CYRILLIC, "af", "uz"}, - {KBD_INUKTITUT_LATIN, "ca", "ike"}, - {KBD_CANADIAN_FRENCH_LEGACY, "ca", "fr-legacy"}, - {KBD_SERBIAN_CYRILLIC, "rs", 0}, - {KBD_CANADIAN_FRENCH, "ca", "fr-legacy"}, - {KBD_SWISS_FRENCH, "ch", "fr"}, - {KBD_BOSNIAN, "ba", 0}, - {KBD_IRISH, 0, 0}, - {KBD_BOSNIAN_CYRILLIC, "ba", "us"}, - {KBD_UNITED_STATES_DVORAK, "us", "dvorak"}, - {KBD_PORTUGUESE_BRAZILIAN_ABNT2, "br", "nativo"}, - {KBD_CANADIAN_MULTILINGUAL_STANDARD, "ca", "multix"}, - {KBD_GAELIC, "ie", "CloGaelach"}, - - {0x00000000, 0, 0}, -}; - -/* taken from 2.2.7.1.6 Input Capability Set (TS_INPUT_CAPABILITYSET) */ -static char *rdp_keyboard_types[] = { - "", /* 0: unused */ - "", /* 1: IBM PC/XT or compatible (83-key) keyboard */ - "", /* 2: Olivetti "ICO" (102-key) keyboard */ - "", /* 3: IBM PC/AT (84-key) or similar keyboard */ - "pc102",/* 4: IBM enhanced (101- or 102-key) keyboard */ - "", /* 5: Nokia 1050 and similar keyboards */ - "", /* 6: Nokia 9140 and similar keyboards */ - "" /* 7: Japanese keyboard */ -}; - -static void keyboard_destroy(struct wlr_input_device *wlr_device) { - struct wlr_rdp_keyboard *keyboard = - (struct wlr_rdp_keyboard *)wlr_device->keyboard; - xkb_keymap_unref(keyboard->keymap); - free(keyboard); -} - -static struct wlr_input_device_impl input_device_impl = { - .destroy = keyboard_destroy, -}; - -struct wlr_rdp_input_device *wlr_rdp_keyboard_create( - struct wlr_rdp_backend *backend, rdpSettings *settings) { - struct wlr_rdp_input_device *device = - calloc(1, sizeof(struct wlr_rdp_input_device)); - if (!device) { - wlr_log(WLR_ERROR, "Failed to allcoate RDP input device"); - return NULL; - } - - int vendor = 0; - int product = 0; - const char *name = "rdp"; - struct wlr_input_device *wlr_device = &device->wlr_input_device; - wlr_input_device_init(wlr_device, WLR_INPUT_DEVICE_KEYBOARD, - &input_device_impl, name, vendor, product); - - struct wlr_rdp_keyboard *keyboard = - calloc(1, sizeof(struct wlr_rdp_keyboard)); - if (!keyboard) { - wlr_log(WLR_ERROR, "Failed to allocate RDP pointer device"); - goto error; - } - wlr_device->keyboard = (struct wlr_keyboard *)keyboard; - wlr_keyboard_init(wlr_device->keyboard, NULL); - - wlr_log(WLR_DEBUG, "RDP keyboard layout: 0x%x type: 0x%x subtype: 0x%x " - "function_keys 0x%x", settings->KeyboardLayout, - settings->KeyboardType, settings->KeyboardSubType, - settings->KeyboardFunctionKey); - - // We need to set up an XKB context and jump through some hoops to convert - // RDP input events into scancodes - struct xkb_rule_names xkb_rule_names = { 0 }; - if (settings->KeyboardType <= 7) { - xkb_rule_names.model = rdp_keyboard_types[settings->KeyboardType]; - } - for (int i = 0; rdp_keyboards[i].rdp_layout_code; ++i) { - if (rdp_keyboards[i].rdp_layout_code == settings->KeyboardLayout) { - xkb_rule_names.layout = rdp_keyboards[i].xkb_layout; - xkb_rule_names.variant = rdp_keyboards[i].xkb_variant; - wlr_log(WLR_DEBUG, "Mapped RDP keyboard to xkb layout %s variant " - "%s", xkb_rule_names.layout, xkb_rule_names.variant); - break; - } - } - if (xkb_rule_names.layout) { - struct xkb_context *xkb_context = xkb_context_new(0); - if (!xkb_context) { - wlr_log(WLR_DEBUG, "Failed to allocate xkb context"); - goto error; - } - keyboard->keymap = - xkb_keymap_new_from_names(xkb_context, &xkb_rule_names, 0); - xkb_context_unref(xkb_context); - } - - wlr_keyboard_set_keymap(wlr_device->keyboard, keyboard->keymap); - - wlr_signal_emit_safe(&backend->backend.events.new_input, wlr_device); - return device; -error: - wlr_input_device_destroy(wlr_device); - return NULL; -} diff --git a/backend/rdp/listener.c b/backend/rdp/listener.c deleted file mode 100644 index cfbdc537..00000000 --- a/backend/rdp/listener.c +++ /dev/null @@ -1,61 +0,0 @@ -#include <stdlib.h> -#include <wlr/util/log.h> -#include "backend/rdp.h" - -static int rdp_incoming_peer( - freerdp_listener *listener, freerdp_peer *client) { - struct wlr_rdp_backend *backend = - (struct wlr_rdp_backend *)listener->param4; - if (rdp_peer_init(client, backend) < 0) { - wlr_log(WLR_ERROR, "Error initializing incoming peer"); - return false; - } - return true; -} - -static int rdp_listener_activity(int fd, uint32_t mask, void *data) { - freerdp_listener *listener = data; - if (!(mask & WL_EVENT_READABLE)) { - return 0; - } - if (!listener->CheckFileDescriptor(listener)) { - wlr_log(WLR_ERROR, "Failed to check FreeRDP file descriptor"); - return -1; - } - return 0; -} - -bool rdp_configure_listener(struct wlr_rdp_backend *backend) { - backend->listener = freerdp_listener_new(); - if (!backend->listener) { - wlr_log(WLR_ERROR, "Failed to allocate FreeRDP listener"); - return false; - } - backend->listener->PeerAccepted = rdp_incoming_peer; - backend->listener->param4 = backend; - if (!backend->listener->Open(backend->listener, - backend->address, backend->port)) { - wlr_log(WLR_ERROR, "Failed to bind to RDP socket"); - return false; - } - int rcount = 0; - void *rfds[MAX_FREERDP_FDS]; - if (!backend->listener->GetFileDescriptor( - backend->listener, rfds, &rcount)) { - wlr_log(WLR_ERROR, "Failed to get FreeRDP file descriptors"); - return false; - } - struct wl_event_loop *event_loop = - wl_display_get_event_loop(backend->display); - int i; - for (i = 0; i < rcount; ++i) { - int fd = (int)(long)(rfds[i]); - backend->listener_events[i] = wl_event_loop_add_fd( - event_loop, fd, WL_EVENT_READABLE, rdp_listener_activity, - backend->listener); - } - for (; i < MAX_FREERDP_FDS; ++i) { - backend->listener_events[i] = NULL; - } - return true; -} diff --git a/backend/rdp/meson.build b/backend/rdp/meson.build deleted file mode 100644 index 40259c65..00000000 --- a/backend/rdp/meson.build +++ /dev/null @@ -1,36 +0,0 @@ -rdp_libs = [] -rdp_required = [ - 'freerdp2', - 'winpr2', -] - -msg = [] -if get_option('freerdp').enabled() - msg += 'Install "@0@" or pass "-Dfreerdp=disabled".' -endif -if not get_option('freerdp').disabled() - msg += 'Required for RDP backend support.' -endif - -foreach lib : rdp_required - dep = dependency(lib, - required: get_option('freerdp'), - not_found_message: '\n'.join(msg).format(lib), - ) - if not dep.found() - subdir_done() - endif - - rdp_libs += dep -endforeach - -wlr_files += files( - 'backend.c', - 'keyboard.c', - 'listener.c', - 'output.c', - 'peer.c', - 'pointer.c', -) -wlr_deps += rdp_libs -conf_data.set10('WLR_HAS_RDP_BACKEND', true) diff --git a/backend/rdp/output.c b/backend/rdp/output.c deleted file mode 100644 index 3043d2c8..00000000 --- a/backend/rdp/output.c +++ /dev/null @@ -1,331 +0,0 @@ -#include <assert.h> -#include <EGL/egl.h> -#include <EGL/eglext.h> -#include <stdlib.h> -#include <wayland-server-core.h> -#include <wlr/types/wlr_output.h> -#include <wlr/interfaces/wlr_output.h> -#include <wlr/util/log.h> -#include <wlr/render/wlr_renderer.h> -#include "backend/rdp.h" -#include "util/signal.h" - -static struct wlr_rdp_output *rdp_output_from_output( - struct wlr_output *wlr_output) { - assert(wlr_output_is_rdp(wlr_output)); - return (struct wlr_rdp_output *)wlr_output; -} - -static EGLSurface egl_create_surface(struct wlr_egl *egl, unsigned int width, - unsigned int height) { - EGLint attribs[] = { - EGL_WIDTH, width, - EGL_HEIGHT, height, - EGL_NONE, - }; - EGLSurface surf = eglCreatePbufferSurface(egl->display, egl->config, attribs); - if (surf == EGL_NO_SURFACE) { - wlr_log(WLR_ERROR, "Failed to create EGL surface"); - return EGL_NO_SURFACE; - } - return surf; -} - -static bool output_set_custom_mode(struct wlr_output *wlr_output, int32_t width, - int32_t height, int32_t refresh) { - struct wlr_rdp_output *output = - rdp_output_from_output(wlr_output); - struct wlr_rdp_backend *backend = output->backend; - - if (refresh <= 0) { - refresh = 60 * 1000; // 60 Hz - } - - wlr_egl_destroy_surface(&backend->egl, output->egl_surface); - - output->egl_surface = egl_create_surface(&backend->egl, width, height); - if (output->egl_surface == EGL_NO_SURFACE) { - wlr_log(WLR_ERROR, "Failed to recreate EGL surface"); - wlr_output_destroy(wlr_output); - return false; - } - - output->frame_delay = 1000000 / refresh; - - if (output->shadow_surface) { - pixman_image_unref(output->shadow_surface); - } - output->shadow_surface = pixman_image_create_bits(PIXMAN_x8r8g8b8, - width, height, NULL, width * 4); - - wlr_output_update_custom_mode(&output->wlr_output, width, height, refresh); - return true; -} - -static bool output_attach_render(struct wlr_output *wlr_output, - int *buffer_age) { - struct wlr_rdp_output *output = - rdp_output_from_output(wlr_output); - return wlr_egl_make_current(&output->backend->egl, output->egl_surface, - buffer_age); -} - -static bool rfx_swap_buffers( - struct wlr_rdp_output *output, pixman_region32_t *damage) { - if (!pixman_region32_not_empty(damage)) { - return true; - } - struct wlr_rdp_peer_context *context = output->context; - freerdp_peer *peer = context->peer; - rdpUpdate *update = peer->update; - - Stream_Clear(context->encode_stream); - Stream_SetPosition(context->encode_stream, 0); - int width = damage->extents.x2 - damage->extents.x1; - int height = damage->extents.y2 - damage->extents.y1; - - SURFACE_BITS_COMMAND cmd; - cmd.skipCompression = TRUE; - cmd.destLeft = damage->extents.x1; - cmd.destTop = damage->extents.y1; - cmd.destRight = damage->extents.x2; - cmd.destBottom = damage->extents.y2; - cmd.bmp.bpp = pixman_image_get_depth(output->shadow_surface); - cmd.bmp.codecID = peer->settings->RemoteFxCodecId; - cmd.bmp.width = width; - cmd.bmp.height = height; - - uint32_t *ptr = pixman_image_get_data(output->shadow_surface) + - damage->extents.x1 + damage->extents.y1 * - (pixman_image_get_stride(output->shadow_surface) / sizeof(uint32_t)); - - RFX_RECT *rfx_rect; - int nrects; - pixman_box32_t *rects = - pixman_region32_rectangles(damage, &nrects); - rfx_rect = realloc(context->rfx_rects, nrects * sizeof(*rfx_rect)); - if (rfx_rect == NULL) { - wlr_log(WLR_ERROR, "RDP swap buffers failed: could not realloc rects"); - return false; - } - context->rfx_rects = rfx_rect; - - for (int i = 0; i < nrects; ++i) { - pixman_box32_t *region = &rects[i]; - rfx_rect = &context->rfx_rects[i]; - rfx_rect->x = region->x1 - damage->extents.x1; - rfx_rect->y = region->y1 - damage->extents.y1; - rfx_rect->width = region->x2 - region->x1; - rfx_rect->height = region->y2 - region->y1; - } - - rfx_compose_message(context->rfx_context, context->encode_stream, - context->rfx_rects, nrects, (BYTE *)ptr, width, height, - pixman_image_get_stride(output->shadow_surface)); - cmd.bmp.bitmapDataLength = Stream_GetPosition(context->encode_stream); - cmd.bmp.bitmapData = Stream_Buffer(context->encode_stream); - - update->SurfaceBits(update->context, &cmd); - return true; -} - -static bool nsc_swap_buffers( - struct wlr_rdp_output *output, pixman_region32_t *damage) { - struct wlr_rdp_peer_context *context = output->context; - freerdp_peer *peer = context->peer; - rdpUpdate *update = peer->update; - - Stream_Clear(context->encode_stream); - Stream_SetPosition(context->encode_stream, 0); - int width = damage->extents.x2 - damage->extents.x1; - int height = damage->extents.y2 - damage->extents.y1; - - SURFACE_BITS_COMMAND cmd; - cmd.skipCompression = TRUE; - cmd.destLeft = damage->extents.x1; - cmd.destTop = damage->extents.y1; - cmd.destRight = damage->extents.x2; - cmd.destBottom = damage->extents.y2; - cmd.bmp.bpp = pixman_image_get_depth(output->shadow_surface); - cmd.bmp.codecID = peer->settings->NSCodecId; - cmd.bmp.width = width; - cmd.bmp.height = height; - - uint32_t *ptr = pixman_image_get_data(output->shadow_surface) + - damage->extents.x1 + damage->extents.y1 * - (pixman_image_get_stride(output->shadow_surface) / sizeof(uint32_t)); - - nsc_compose_message(context->nsc_context, context->encode_stream, - (BYTE *)ptr, width, height, - pixman_image_get_stride(output->shadow_surface)); - - cmd.bmp.bitmapDataLength = Stream_GetPosition(context->encode_stream); - cmd.bmp.bitmapData = Stream_Buffer(context->encode_stream); - - update->SurfaceBits(update->context, &cmd); - return true; -} - -static bool output_commit_buffer(struct wlr_rdp_output *output) { - struct wlr_output *wlr_output = &output->wlr_output; - - bool ret = false; - - pixman_region32_t output_region; - pixman_region32_init(&output_region); - pixman_region32_union_rect(&output_region, &output_region, - 0, 0, wlr_output->width, wlr_output->height); - - pixman_region32_t *damage = &output_region; - if (wlr_output->pending.committed & WLR_OUTPUT_STATE_DAMAGE) { - damage = &wlr_output->pending.damage; - } - - int x = damage->extents.x1; - int y = damage->extents.y1; - int width = damage->extents.x2 - damage->extents.x1; - int height = damage->extents.y2 - damage->extents.y1; - - // Update shadow buffer - struct wlr_renderer *renderer = - wlr_backend_get_renderer(&output->backend->backend); - // TODO performance: add support for flags - ret = wlr_renderer_read_pixels(renderer, WL_SHM_FORMAT_XRGB8888, - NULL, pixman_image_get_stride(output->shadow_surface), - width, height, x, y, x, y, - pixman_image_get_data(output->shadow_surface)); - if (!ret) { - goto out; - } - - // Send along to clients - rdpSettings *settings = output->context->peer->settings; - if (settings->RemoteFxCodec) { - ret = rfx_swap_buffers(output, damage); - } else if (settings->NSCodec) { - ret = nsc_swap_buffers(output, damage); - } else { - // This would perform like ass so why bother - wlr_log(WLR_ERROR, "Raw updates are not supported; use rfx or nsc"); - ret = false; - } - if (!ret) { - goto out; - } - - wlr_output_send_present(wlr_output, NULL); - -out: - pixman_region32_fini(&output_region); - return ret; -} - -static bool output_commit(struct wlr_output *wlr_output) { - struct wlr_rdp_output *output = rdp_output_from_output(wlr_output); - - if (wlr_output->pending.committed & WLR_OUTPUT_STATE_ENABLED) { - wlr_log(WLR_DEBUG, "Cannot disable an RDP output"); - return false; - } - - if (wlr_output->pending.committed & WLR_OUTPUT_STATE_MODE) { - assert(wlr_output->pending.mode_type == WLR_OUTPUT_STATE_MODE_CUSTOM); - if (!output_set_custom_mode(wlr_output, - wlr_output->pending.custom_mode.width, - wlr_output->pending.custom_mode.height, - wlr_output->pending.custom_mode.refresh)) { - return false; - } - } - - if (wlr_output->pending.committed & WLR_OUTPUT_STATE_BUFFER) { - if (!output_commit_buffer(output)) { - return false; - } - } - - return true; -} - -static void output_destroy(struct wlr_output *wlr_output) { - struct wlr_rdp_output *output = - rdp_output_from_output(wlr_output); - if (output->frame_timer) { - wl_event_source_remove(output->frame_timer); - } - wlr_egl_destroy_surface(&output->backend->egl, output->egl_surface); - if (output->shadow_surface) { - pixman_image_unref(output->shadow_surface); - } - free(output); -} - -static const struct wlr_output_impl output_impl = { - .destroy = output_destroy, - .attach_render = output_attach_render, - .commit = output_commit, -}; - -bool wlr_output_is_rdp(struct wlr_output *wlr_output) { - return wlr_output->impl == &output_impl; -} - -static int signal_frame(void *data) { - struct wlr_rdp_output *output = data; - wlr_output_send_frame(&output->wlr_output); - wl_event_source_timer_update(output->frame_timer, output->frame_delay); - return 0; -} - -struct wlr_rdp_output *wlr_rdp_output_create(struct wlr_rdp_backend *backend, - struct wlr_rdp_peer_context *context, unsigned int width, - unsigned int height) { - struct wlr_rdp_output *output = - calloc(1, sizeof(struct wlr_rdp_output)); - if (output == NULL) { - wlr_log(WLR_ERROR, "Failed to allocate wlr_rdp_output"); - return NULL; - } - output->backend = backend; - output->context = context; - wlr_output_init(&output->wlr_output, &backend->backend, &output_impl, - backend->display); - struct wlr_output *wlr_output = &output->wlr_output; - - output->egl_surface = egl_create_surface(&backend->egl, width, height); - if (output->egl_surface == EGL_NO_SURFACE) { - wlr_log(WLR_ERROR, "Failed to create EGL surface"); - goto error; - } - - output_set_custom_mode(wlr_output, width, height, 0); - strncpy(wlr_output->make, "RDP", sizeof(wlr_output->make)); - strncpy(wlr_output->model, "RDP", sizeof(wlr_output->model)); - snprintf(wlr_output->name, sizeof(wlr_output->name), "RDP-%d", - wl_list_length(&backend->clients)); - - char description[128]; - snprintf(description, sizeof(description), - "RDP output %d", wl_list_length(&backend->clients)); - wlr_output_set_description(wlr_output, description); - - if (!wlr_egl_make_current(&output->backend->egl, output->egl_surface, - NULL)) { - goto error; - } - - wlr_renderer_begin(backend->renderer, wlr_output->width, wlr_output->height); - wlr_renderer_clear(backend->renderer, (float[]){ 1.0, 1.0, 1.0, 1.0 }); - wlr_renderer_end(backend->renderer); - - struct wl_event_loop *ev = wl_display_get_event_loop(backend->display); - output->frame_timer = wl_event_loop_add_timer(ev, signal_frame, output); - wl_event_source_timer_update(output->frame_timer, output->frame_delay); - wlr_output_update_enabled(wlr_output, true); - wlr_signal_emit_safe(&backend->backend.events.new_output, wlr_output); - return output; - -error: - wlr_output_destroy(&output->wlr_output); - return NULL; -} diff --git a/backend/rdp/peer.c b/backend/rdp/peer.c deleted file mode 100644 index 350a4721..00000000 --- a/backend/rdp/peer.c +++ /dev/null @@ -1,360 +0,0 @@ -#define _POSIX_C_SOURCE 200809L -#include <linux/input.h> -#include <stdlib.h> -#include <string.h> -#include <wlr/types/wlr_output.h> -#include <wlr/interfaces/wlr_input_device.h> -#include <wlr/interfaces/wlr_keyboard.h> -#include <wlr/interfaces/wlr_output.h> -#include <wlr/util/log.h> -#include "backend/rdp.h" -#include "util/signal.h" - -static BOOL xf_peer_capabilities(freerdp_peer *client) { - return TRUE; -} - -static BOOL xf_peer_post_connect(freerdp_peer *client) { - return TRUE; -} - -static BOOL xf_peer_activate(freerdp_peer *client) { - struct wlr_rdp_peer_context *context = - (struct wlr_rdp_peer_context *)client->context; - struct wlr_rdp_backend *backend = context->backend; - rdpSettings *settings = client->settings; - - if (!settings->SurfaceCommandsEnabled) { - wlr_log(WLR_ERROR, "RDP peer does not support SurfaceCommands"); - return FALSE; - } - - context->output = wlr_rdp_output_create(backend, context, - (int)settings->DesktopWidth, (int)settings->DesktopHeight); - if (!context->output) { - wlr_log(WLR_ERROR, "Failed to allcoate output for RDP peer"); - return FALSE; - } - rfx_context_reset(context->rfx_context, - context->output->wlr_output.width, - context->output->wlr_output.height); - nsc_context_reset(context->nsc_context, - context->output->wlr_output.width, - context->output->wlr_output.height); - - if (context->flags & RDP_PEER_ACTIVATED) { - return TRUE; - } - - context->pointer = wlr_rdp_pointer_create(backend, context); - if (!context->pointer) { - wlr_log(WLR_ERROR, "Failed to allocate pointer for RDP peer"); - return FALSE; - } - - // Use wlroots' software cursors instead of remote cursors - POINTER_SYSTEM_UPDATE pointer_system; - rdpPointerUpdate *pointer = client->update->pointer; - pointer_system.type = SYSPTR_NULL; - pointer->PointerSystem(client->context, &pointer_system); - - context->keyboard = wlr_rdp_keyboard_create(backend, settings); - if (!context->keyboard) { - wlr_log(WLR_ERROR, "Failed to allocate keyboard for RDP peer"); - return FALSE; - } - - context->flags |= RDP_PEER_ACTIVATED; - return TRUE; -} - -static int xf_suppress_output(rdpContext *context, - BYTE allow, const RECTANGLE_16 *area) { - struct wlr_rdp_peer_context *peer_context = - (struct wlr_rdp_peer_context *)context; - if (allow) { - peer_context->flags |= RDP_PEER_OUTPUT_ENABLED; - } else { - peer_context->flags &= ~RDP_PEER_OUTPUT_ENABLED; - } - return true; -} - -static int xf_input_synchronize_event(rdpInput *input, UINT32 flags) { - struct wlr_rdp_peer_context *context = - (struct wlr_rdp_peer_context *)input->context; - wlr_output_damage_whole(&context->output->wlr_output); - return true; -} - -static inline int64_t timespec_to_msec(const struct timespec *a) { - return (int64_t)a->tv_sec * 1000 + a->tv_nsec / 1000000; -} - -static int xf_input_mouse_event(rdpInput *input, - UINT16 flags, UINT16 x, UINT16 y) { - struct wlr_rdp_peer_context *context = - (struct wlr_rdp_peer_context *)input->context; - struct wlr_input_device *wlr_device = &context->pointer->wlr_input_device; - struct wlr_pointer *pointer = wlr_device->pointer; - bool frame = false; - struct timespec now; - clock_gettime(CLOCK_MONOTONIC, &now); - - if (flags & PTR_FLAGS_MOVE) { - struct wlr_event_pointer_motion_absolute event = { 0 }; - event.device = wlr_device; - event.time_msec = timespec_to_msec(&now); - event.x = x / (double)context->output->wlr_output.width; - event.y = y / (double)context->output->wlr_output.height; - wlr_signal_emit_safe(&pointer->events.motion_absolute, &event); - frame = true; - } - - uint32_t button = 0; - if (flags & PTR_FLAGS_BUTTON1) { - button = BTN_LEFT; - } else if (flags & PTR_FLAGS_BUTTON2) { - button = BTN_RIGHT; - } else if (flags & PTR_FLAGS_BUTTON3) { - button = BTN_MIDDLE; - } - - if (button) { - struct wlr_event_pointer_button event = { 0 }; - event.device = wlr_device; - event.time_msec = timespec_to_msec(&now); - event.button = button; - event.state = (flags & PTR_FLAGS_DOWN) ? - WLR_BUTTON_PRESSED : WLR_BUTTON_RELEASED; - wlr_signal_emit_safe(&pointer->events.button, &event); - frame = true; - } - - if (flags & PTR_FLAGS_WHEEL) { - double value = -(flags & 0xFF) / 120.0; - if (flags & PTR_FLAGS_WHEEL_NEGATIVE) { - value = -value; - } - struct wlr_event_pointer_axis event = { 0 }; - event.device = &context->pointer->wlr_input_device; - event.time_msec = timespec_to_msec(&now); - event.source = WLR_AXIS_SOURCE_WHEEL; - event.orientation = WLR_AXIS_ORIENTATION_VERTICAL; - event.delta = value; - event.delta_discrete = (int32_t)value; - wlr_signal_emit_safe(&pointer->events.axis, &event); - frame = true; - } - - if (frame) { - wlr_signal_emit_safe(&pointer->events.frame, pointer); - } - - return true; -} - -static int xf_input_extended_mouse_event( - rdpInput *input, UINT16 flags, UINT16 x, UINT16 y) { - struct wlr_rdp_peer_context *context = - (struct wlr_rdp_peer_context *)input->context; - struct wlr_input_device *wlr_device = &context->pointer->wlr_input_device; - struct wlr_pointer *pointer = wlr_device->pointer; - struct timespec now; - clock_gettime(CLOCK_MONOTONIC, &now); - struct wlr_event_pointer_motion_absolute event = { 0 }; - event.device = wlr_device; - event.time_msec = timespec_to_msec(&now); - event.x = x / (double)context->output->wlr_output.width; - event.y = y / (double)context->output->wlr_output.height; - wlr_signal_emit_safe(&pointer->events.motion_absolute, &event); - wlr_signal_emit_safe(&pointer->events.frame, pointer); - return true; -} - -static int xf_input_keyboard_event(rdpInput *input, UINT16 flags, UINT16 code) { - struct wlr_rdp_peer_context *context = - (struct wlr_rdp_peer_context *)input->context; - struct wlr_input_device *wlr_device = &context->keyboard->wlr_input_device; - struct wlr_keyboard *keyboard = wlr_device->keyboard; - struct timespec now; - clock_gettime(CLOCK_MONOTONIC, &now); - - if (!(context->flags & RDP_PEER_ACTIVATED)) { - return true; - } - - bool notify = false; - enum wlr_key_state state; - if ((flags & KBD_FLAGS_DOWN)) { - state = WLR_KEY_PRESSED; - notify = true; - } else if ((flags & KBD_FLAGS_RELEASE)) { - state = WLR_KEY_RELEASED; - notify = true; - } - - if (notify) { - uint32_t full_code = code; - if (flags & KBD_FLAGS_EXTENDED) { - full_code |= KBD_FLAGS_EXTENDED; - } - uint32_t vk_code = GetVirtualKeyCodeFromVirtualScanCode(full_code, 4); - if (flags & KBD_FLAGS_EXTENDED) { - vk_code |= KBDEXT; - } - uint32_t scan_code = GetKeycodeFromVirtualKeyCode( - vk_code, KEYCODE_TYPE_EVDEV); - struct wlr_event_keyboard_key event = { 0 }; - event.time_msec = timespec_to_msec(&now); - event.keycode = scan_code - 8; - event.state = state; - event.update_state = true; - wlr_keyboard_notify_key(keyboard, &event); - } - - return true; -} - -static int xf_input_unicode_keyboard_event(rdpInput *input, - UINT16 flags, UINT16 code) { - wlr_log(WLR_DEBUG, "Unhandled RDP unicode keyboard event " - "(flags:0x%X code:0x%X)\n", flags, code); - return true; -} - -static int rdp_client_activity(int fd, uint32_t mask, void *data) { - freerdp_peer *client = (freerdp_peer *)data; - if (!client->CheckFileDescriptor(client)) { - wlr_log(WLR_ERROR, - "Unable to check client file descriptor for %p", client); - freerdp_peer_context_free(client); - freerdp_peer_free(client); - } - return 0; -} - -static int rdp_peer_context_new( - freerdp_peer *client, struct wlr_rdp_peer_context *context) { - context->peer = client; - context->flags = RDP_PEER_OUTPUT_ENABLED; - context->rfx_context = rfx_context_new(TRUE); - if (!context->rfx_context) { - return false; - } - context->rfx_context->mode = RLGR3; - context->rfx_context->width = client->settings->DesktopWidth; - context->rfx_context->height = client->settings->DesktopHeight; - rfx_context_set_pixel_format(context->rfx_context, PIXEL_FORMAT_BGRA32); - - context->nsc_context = nsc_context_new(); - if (!context->nsc_context) { - rfx_context_free(context->rfx_context); - return false; - } - - nsc_context_set_pixel_format(context->nsc_context, PIXEL_FORMAT_BGRA32); - - context->encode_stream = Stream_New(NULL, 65536); - if (!context->encode_stream) { - nsc_context_free(context->nsc_context); - rfx_context_free(context->rfx_context); - return false; - } - return true; -} - -static void rdp_peer_context_free( - freerdp_peer *client, struct wlr_rdp_peer_context *context) { - if (!context) { - return; - } - - for (int i = 0; i < MAX_FREERDP_FDS; ++i) { - if (context->events[i]) { - wl_event_source_remove(context->events[i]); - } - } - - if (context->flags & RDP_PEER_ACTIVATED) { - wlr_output_destroy(&context->output->wlr_output); - wlr_input_device_destroy(&context->pointer->wlr_input_device); - wlr_input_device_destroy(&context->keyboard->wlr_input_device); - } - - wl_list_remove(&context->link); - wlr_output_destroy(&context->output->wlr_output); - - Stream_Free(context->encode_stream, TRUE); - nsc_context_free(context->nsc_context); - rfx_context_free(context->rfx_context); - free(context->rfx_rects); -} - -int rdp_peer_init(freerdp_peer *client, - struct wlr_rdp_backend *backend) { - client->ContextSize = sizeof(struct wlr_rdp_peer_context); - client->ContextNew = (psPeerContextNew)rdp_peer_context_new; - client->ContextFree = (psPeerContextFree)rdp_peer_context_free; - freerdp_peer_context_new(client); - - struct wlr_rdp_peer_context *peer_context = - (struct wlr_rdp_peer_context *)client->context; - peer_context->backend = backend; - - client->settings->CertificateFile = strdup(backend->tls_cert_path); - client->settings->PrivateKeyFile = strdup(backend->tls_key_path); - client->settings->NlaSecurity = FALSE; - - if (!client->Initialize(client)) { - wlr_log(WLR_ERROR, "Failed to initialize FreeRDP peer"); - goto err_init; - } - - client->settings->OsMajorType = OSMAJORTYPE_UNIX; - client->settings->OsMinorType = OSMINORTYPE_PSEUDO_XSERVER; - client->settings->ColorDepth = 32; - client->settings->RefreshRect = TRUE; - client->settings->RemoteFxCodec = TRUE; - client->settings->NSCodec = TRUE; - client->settings->FrameMarkerCommandEnabled = TRUE; - client->settings->SurfaceFrameMarkerEnabled = TRUE; - - client->Capabilities = xf_peer_capabilities; - client->PostConnect = xf_peer_post_connect; - client->Activate = xf_peer_activate; - - client->update->SuppressOutput = (pSuppressOutput)xf_suppress_output; - - client->input->SynchronizeEvent = xf_input_synchronize_event; - client->input->MouseEvent = xf_input_mouse_event; - client->input->ExtendedMouseEvent = xf_input_extended_mouse_event; - client->input->KeyboardEvent = xf_input_keyboard_event; - client->input->UnicodeKeyboardEvent = xf_input_unicode_keyboard_event; - - int rcount = 0; - void *rfds[MAX_FREERDP_FDS]; - if (!client->GetFileDescriptor(client, rfds, &rcount)) { - wlr_log(WLR_ERROR, "Unable to retrieve client file descriptors"); - goto err_init; - } - struct wl_event_loop *event_loop = - wl_display_get_event_loop(backend->display); - int i; - for (i = 0; i < rcount; ++i) { - int fd = (int)(long)(rfds[i]); - peer_context->events[i] = wl_event_loop_add_fd( - event_loop, fd, WL_EVENT_READABLE, rdp_client_activity, - client); - } - for (; i < MAX_FREERDP_FDS; ++i) { - peer_context->events[i] = NULL; - } - - wl_list_insert(&backend->clients, &peer_context->link); - return 0; - -err_init: - client->Close(client); - return -1; -} diff --git a/backend/rdp/pointer.c b/backend/rdp/pointer.c deleted file mode 100644 index b3fdcd73..00000000 --- a/backend/rdp/pointer.c +++ /dev/null @@ -1,40 +0,0 @@ -#define _POSIX_C_SOURCE 200809L -#include <stdlib.h> -#include <string.h> -#include <wayland-server-core.h> -#include <wlr/types/wlr_input_device.h> -#include <wlr/types/wlr_pointer.h> -#include <wlr/interfaces/wlr_pointer.h> -#include <wlr/interfaces/wlr_input_device.h> -#include <wlr/util/log.h> -#include "backend/rdp.h" -#include "util/signal.h" - -static struct wlr_input_device_impl input_device_impl = { 0 }; - -struct wlr_rdp_input_device *wlr_rdp_pointer_create( - struct wlr_rdp_backend *backend, struct wlr_rdp_peer_context *context) { - struct wlr_rdp_input_device *device = - calloc(1, sizeof(struct wlr_rdp_input_device)); - if (!device) { - wlr_log(WLR_ERROR, "Failed to allocate RDP input device"); - return NULL; - } - - int vendor = 0; - int product = 0; - const char *name = "rdp"; - struct wlr_input_device *wlr_device = &device->wlr_input_device; - wlr_input_device_init(wlr_device, WLR_INPUT_DEVICE_POINTER, - &input_device_impl, name, vendor, product); - - if (!(wlr_device->pointer = calloc(1, sizeof(struct wlr_pointer)))) { - wlr_log(WLR_ERROR, "Failed to allocate RDP pointer device"); - return NULL; - } - wlr_device->output_name = strdup(context->output->wlr_output.name); - wlr_pointer_init(wlr_device->pointer, NULL); - - wlr_signal_emit_safe(&backend->backend.events.new_input, wlr_device); - return device; -} |