wf_peer.c

 
#include <freerdp/config.h>
 
#include <winpr/assert.h>
#include <winpr/tchar.h>
#include <winpr/stream.h>
#include <winpr/windows.h>
 
#include <freerdp/listener.h>
#include <freerdp/codec/rfx.h>
#include <freerdp/build-config.h>
#include <freerdp/crypto/certificate.h>
 
#include "wf_info.h"
#include "wf_input.h"
#include "wf_mirage.h"
#include "wf_update.h"
#include "wf_settings.h"
#include "wf_rdpsnd.h"
 
#include "wf_peer.h"
#include <freerdp/peer.h>
 
#include <freerdp/log.h>
#define TAG SERVER_TAG("windows")
 
#define SERVER_KEY "Software\\" FREERDP_VENDOR_STRING "\\" FREERDP_PRODUCT_STRING
 
static DWORD WINAPI wf_peer_main_loop(LPVOID lpParam);
 
static BOOL wf_peer_context_new(freerdp_peer* client, rdpContext* ctx)
{
  wfPeerContext* context = (wfPeerContext*)ctx;
  WINPR_ASSERT(context);
 
  if (!(context->info = wf_info_get_instance()))
    return FALSE;
 
  context->vcm = WTSOpenServerA((LPSTR)client->context);
 
  if (!context->vcm || context->vcm == INVALID_HANDLE_VALUE)
    return FALSE;
 
  if (!wf_info_peer_register(context->info, context))
  {
    WTSCloseServer(context->vcm);
    context->vcm = NULL;
    return FALSE;
  }
 
  return TRUE;
}
 
static void wf_peer_context_free(freerdp_peer* client, rdpContext* ctx)
{
  wfPeerContext* context = (wfPeerContext*)ctx;
  WINPR_ASSERT(context);
 
  wf_info_peer_unregister(context->info, context);
 
  if (context->rdpsnd)
  {
    wf_rdpsnd_lock();
    context->info->snd_stop = TRUE;
    rdpsnd_server_context_free(context->rdpsnd);
    wf_rdpsnd_unlock();
  }
 
  WTSCloseServer(context->vcm);
}
 
static BOOL wf_peer_init(freerdp_peer* client)
{
  client->ContextSize = sizeof(wfPeerContext);
  client->ContextNew = wf_peer_context_new;
  client->ContextFree = wf_peer_context_free;
  return freerdp_peer_context_new(client);
}
 
static BOOL wf_peer_post_connect(freerdp_peer* client)
{
  wfInfo* wfi;
  rdpSettings* settings;
  wfPeerContext* context;
 
  WINPR_ASSERT(client);
 
  context = (wfPeerContext*)client->context;
  WINPR_ASSERT(context);
 
  wfi = context->info;
  WINPR_ASSERT(wfi);
 
  settings = client->context->settings;
  WINPR_ASSERT(settings);
 
  if ((get_screen_info(wfi->screenID, NULL, 0, &wfi->servscreen_width, &wfi->servscreen_height,
                       &wfi->bitsPerPixel) == 0) ||
      (wfi->servscreen_width == 0) || (wfi->servscreen_height == 0) || (wfi->bitsPerPixel == 0))
  {
    WLog_ERR(TAG, "postconnect: error getting screen info for screen %d", wfi->screenID);
    WLog_ERR(TAG, "\t%dx%dx%d", wfi->servscreen_height, wfi->servscreen_width,
             wfi->bitsPerPixel);
    return FALSE;
  }
 
  if ((freerdp_settings_get_uint32(settings, FreeRDP_DesktopWidth) != wfi->servscreen_width) ||
      (freerdp_settings_get_uint32(settings, FreeRDP_DesktopHeight) != wfi->servscreen_height))
  {
    /*
    WLog_DBG(TAG, "Client requested resolution %"PRIu32"x%"PRIu32", but will resize to %dx%d",
        freerdp_settings_get_uint32(settings, FreeRDP_DesktopWidth),
    freerdp_settings_get_uint32(settings, FreeRDP_DesktopHeight), wfi->servscreen_width,
    wfi->servscreen_height);
        */
    if (!freerdp_settings_set_uint32(settings, FreeRDP_DesktopWidth, wfi->servscreen_width) ||
        !freerdp_settings_set_uint32(settings, FreeRDP_DesktopHeight, wfi->servscreen_height) ||
        !freerdp_settings_set_uint32(settings, FreeRDP_ColorDepth, wfi->bitsPerPixel))
      return FALSE;
 
    WINPR_ASSERT(client->context->update);
    WINPR_ASSERT(client->context->update->DesktopResize);
    client->context->update->DesktopResize(client->context);
  }
 
  if (WTSVirtualChannelManagerIsChannelJoined(context->vcm, "rdpsnd"))
  {
    wf_peer_rdpsnd_init(context); /* Audio Output */
  }
 
  return TRUE;
}
 
static BOOL wf_peer_activate(freerdp_peer* client)
{
  wfInfo* wfi;
  wfPeerContext* context = (wfPeerContext*)client->context;
  wfi = context->info;
  client->activated = TRUE;
  wf_update_peer_activate(wfi, context);
  wfreerdp_server_peer_callback_event(((rdpContext*)context)->peer->pId,
                                      FREERDP_SERVER_WIN_SRV_CALLBACK_EVENT_ACTIVATE);
  return TRUE;
}
 
static BOOL wf_peer_logon(freerdp_peer* client, const SEC_WINNT_AUTH_IDENTITY* identity,
                          BOOL automatic)
{
  wfreerdp_server_peer_callback_event(((rdpContext*)client->context)->peer->pId,
                                      FREERDP_SERVER_WIN_SRV_CALLBACK_EVENT_AUTH);
  return TRUE;
}
 
static BOOL wf_peer_synchronize_event(rdpInput* input, UINT32 flags)
{
  return TRUE;
}
 
BOOL wf_peer_accepted(freerdp_listener* instance, freerdp_peer* client)
{
  HANDLE hThread;
 
  if (!(hThread = CreateThread(NULL, 0, wf_peer_main_loop, client, 0, NULL)))
    return FALSE;
 
  (void)CloseHandle(hThread);
  return TRUE;
}
 
static DWORD WINAPI wf_peer_socket_listener(LPVOID lpParam)
{
  wfPeerContext* context;
  freerdp_peer* client = (freerdp_peer*)lpParam;
 
  WINPR_ASSERT(client);
  WINPR_ASSERT(client->GetEventHandles);
  WINPR_ASSERT(client->CheckFileDescriptor);
 
  context = (wfPeerContext*)client->context;
  WINPR_ASSERT(context);
 
  while (1)
  {
    DWORD status;
    HANDLE handles[MAXIMUM_WAIT_OBJECTS] = { 0 };
    DWORD count = client->GetEventHandles(client, handles, ARRAYSIZE(handles));
 
    if (count == 0)
    {
      WLog_ERR(TAG, "Failed to get FreeRDP file descriptor");
      break;
    }
 
    status = WaitForMultipleObjects(count, handles, FALSE, INFINITE);
    if (status == WAIT_FAILED)
    {
      WLog_ERR(TAG, "WaitForMultipleObjects failed");
      break;
    }
 
    (void)SetEvent(context->socketEvent);
    (void)WaitForSingleObject(context->socketSemaphore, INFINITE);
 
    if (context->socketClose)
      break;
  }
 
  return 0;
}
 
static BOOL wf_peer_read_settings(freerdp_peer* client)
{
  rdpSettings* settings;
 
  WINPR_ASSERT(client);
  WINPR_ASSERT(client->context);
 
  settings = client->context->settings;
  WINPR_ASSERT(settings);
 
  char* CertificateFile = NULL;
  if (!wf_settings_read_string_ascii(HKEY_LOCAL_MACHINE, SERVER_KEY, _T("CertificateFile"),
                                     &(CertificateFile)))
    CertificateFile = _strdup("server.crt");
 
  rdpCertificate* cert = freerdp_certificate_new_from_file(CertificateFile);
  free(CertificateFile);
  if (!cert)
    return FALSE;
 
  if (!freerdp_settings_set_pointer_len(settings, FreeRDP_RdpServerCertificate, cert, 1))
    return FALSE;
 
  char* PrivateKeyFile = NULL;
  if (!wf_settings_read_string_ascii(HKEY_LOCAL_MACHINE, SERVER_KEY, _T("PrivateKeyFile"),
                                     &(PrivateKeyFile)))
    PrivateKeyFile = _strdup("server.key");
 
  rdpPrivateKey* key = freerdp_key_new_from_file(PrivateKeyFile);
  free(PrivateKeyFile);
 
  if (!key)
    return FALSE;
 
  if (!freerdp_settings_set_pointer_len(settings, FreeRDP_RdpServerRsaKey, key, 1))
    return FALSE;
 
  return TRUE;
}
 
DWORD WINAPI wf_peer_main_loop(LPVOID lpParam)
{
  wfInfo* wfi;
  DWORD nCount;
  DWORD status;
  HANDLE handles[32];
  rdpSettings* settings;
  wfPeerContext* context;
  freerdp_peer* client = (freerdp_peer*)lpParam;
 
  if (!wf_peer_init(client))
    goto fail_peer_init;
 
  WINPR_ASSERT(client->context);
 
  settings = client->context->settings;
  WINPR_ASSERT(settings);
 
  if (!freerdp_settings_set_bool(settings, FreeRDP_RemoteFxCodec, TRUE))
    goto fail_peer_init;
  if (!freerdp_settings_set_uint32(settings, FreeRDP_ColorDepth, 32))
    goto fail_peer_init;
  if (!freerdp_settings_set_bool(settings, FreeRDP_NSCodec, FALSE))
    goto fail_peer_init;
  if (!freerdp_settings_set_bool(settings, FreeRDP_JpegCodec, FALSE))
    goto fail_peer_init;
 
  if (!wf_peer_read_settings(client))
    goto fail_peer_init;
 
  client->PostConnect = wf_peer_post_connect;
  client->Activate = wf_peer_activate;
  client->Logon = wf_peer_logon;
 
  WINPR_ASSERT(client->context->input);
  client->context->input->SynchronizeEvent = wf_peer_synchronize_event;
  client->context->input->KeyboardEvent = wf_peer_keyboard_event;
  client->context->input->UnicodeKeyboardEvent = wf_peer_unicode_keyboard_event;
  client->context->input->MouseEvent = wf_peer_mouse_event;
  client->context->input->ExtendedMouseEvent = wf_peer_extended_mouse_event;
 
  WINPR_ASSERT(client->Initialize);
  if (!client->Initialize(client))
    goto fail_client_initialize;
 
  context = (wfPeerContext*)client->context;
 
  if (context->socketClose)
    goto fail_socked_closed;
 
  wfi = context->info;
 
  if (wfi->input_disabled)
  {
    WLog_INFO(TAG, "client input is disabled");
    client->context->input->KeyboardEvent = wf_peer_keyboard_event_dummy;
    client->context->input->UnicodeKeyboardEvent = wf_peer_unicode_keyboard_event_dummy;
    client->context->input->MouseEvent = wf_peer_mouse_event_dummy;
    client->context->input->ExtendedMouseEvent = wf_peer_extended_mouse_event_dummy;
  }
 
  if (!(context->socketEvent = CreateEvent(NULL, TRUE, FALSE, NULL)))
    goto fail_socket_event;
 
  if (!(context->socketSemaphore = CreateSemaphore(NULL, 0, 1, NULL)))
    goto fail_socket_semaphore;
 
  if (!(context->socketThread = CreateThread(NULL, 0, wf_peer_socket_listener, client, 0, NULL)))
    goto fail_socket_thread;
 
  WLog_INFO(TAG, "We've got a client %s", client->local ? "(local)" : client->hostname);
  nCount = 0;
  handles[nCount++] = context->updateEvent;
  handles[nCount++] = context->socketEvent;
 
  while (1)
  {
    status = WaitForMultipleObjects(nCount, handles, FALSE, INFINITE);
 
    if ((status == WAIT_FAILED) || (status == WAIT_TIMEOUT))
    {
      WLog_ERR(TAG, "WaitForMultipleObjects failed");
      break;
    }
 
    if (WaitForSingleObject(context->updateEvent, 0) == 0)
    {
      if (client->activated)
        wf_update_peer_send(wfi, context);
 
      (void)ResetEvent(context->updateEvent);
      ReleaseSemaphore(wfi->updateSemaphore, 1, NULL);
    }
 
    if (WaitForSingleObject(context->socketEvent, 0) == 0)
    {
      if (client->CheckFileDescriptor(client) != TRUE)
      {
        WLog_ERR(TAG, "Failed to check peer file descriptor");
        context->socketClose = TRUE;
      }
 
      (void)ResetEvent(context->socketEvent);
      ReleaseSemaphore(context->socketSemaphore, 1, NULL);
 
      if (context->socketClose)
        break;
    }
 
    // force disconnect
    if (wfi->force_all_disconnect == TRUE)
    {
      WLog_INFO(TAG, "Forcing Disconnect -> ");
      break;
    }
 
    /* FIXME: we should wait on this, instead of calling it every time */
    if (WTSVirtualChannelManagerCheckFileDescriptor(context->vcm) != TRUE)
      break;
  }
 
  WLog_INFO(TAG, "Client %s disconnected.", client->local ? "(local)" : client->hostname);
 
  if (WaitForSingleObject(context->updateEvent, 0) == 0)
  {
    (void)ResetEvent(context->updateEvent);
    ReleaseSemaphore(wfi->updateSemaphore, 1, NULL);
  }
 
  wf_update_peer_deactivate(wfi, context);
  client->Disconnect(client);
fail_socket_thread:
  (void)CloseHandle(context->socketSemaphore);
  context->socketSemaphore = NULL;
fail_socket_semaphore:
  (void)CloseHandle(context->socketEvent);
  context->socketEvent = NULL;
fail_socket_event:
fail_socked_closed:
fail_client_initialize:
  freerdp_peer_context_free(client);
fail_peer_init:
  freerdp_peer_free(client);
  return 0;
}