19#include <freerdp/config.h>
22#include <winpr/assert.h>
23#include <winpr/print.h>
24#include <winpr/assert.h>
26#include <freerdp/log.h>
30#define TAG SERVER_TAG("shadow.win")
32static void shw_OnChannelConnectedEventHandler(
void* context,
const ChannelConnectedEventArgs* e)
34 shwContext* shw = (shwContext*)context;
36 WLog_INFO(TAG,
"OnChannelConnected: %s", e->name);
39static void shw_OnChannelDisconnectedEventHandler(
void* context,
40 const ChannelDisconnectedEventArgs* e)
42 shwContext* shw = (shwContext*)context;
44 WLog_INFO(TAG,
"OnChannelDisconnected: %s", e->name);
47static BOOL shw_begin_paint(rdpContext* context)
52 WINPR_ASSERT(context);
55 shw = (shwContext*)context;
56 gdi->primary->hdc->hwnd->invalid->null = TRUE;
57 gdi->primary->hdc->hwnd->ninvalid = 0;
61static BOOL shw_end_paint(rdpContext* context)
66 rdpGdi* gdi = context->gdi;
67 shwContext* shw = (shwContext*)context;
68 winShadowSubsystem* subsystem = shw->subsystem;
69 rdpShadowSurface* surface = subsystem->base.server->surface;
70 ninvalid = gdi->primary->hdc->hwnd->ninvalid;
71 cinvalid = gdi->primary->hdc->hwnd->cinvalid;
73 for (
int index = 0; index < ninvalid; index++)
75 invalidRect.left = cinvalid[index].x;
76 invalidRect.top = cinvalid[index].y;
77 invalidRect.right = cinvalid[index].x + cinvalid[index].w;
78 invalidRect.bottom = cinvalid[index].y + cinvalid[index].h;
79 region16_union_rect(&(surface->invalidRegion), &(surface->invalidRegion), &invalidRect);
82 (void)SetEvent(subsystem->RdpUpdateEnterEvent);
83 (void)WaitForSingleObject(subsystem->RdpUpdateLeaveEvent, INFINITE);
84 (void)ResetEvent(subsystem->RdpUpdateLeaveEvent);
88BOOL shw_desktop_resize(rdpContext* context)
90 WLog_WARN(TAG,
"Desktop resizing not implemented!");
94static BOOL shw_surface_frame_marker(rdpContext* context,
97 shwContext* shw = (shwContext*)context;
101static BOOL shw_authenticate(freerdp* instance,
char** username,
char** password,
char** domain,
102 rdp_auth_reason reason)
104 WINPR_UNUSED(reason);
105 WLog_WARN(TAG,
"Authentication not implemented, access granted to everyone!");
109static int shw_verify_x509_certificate(freerdp* instance,
const BYTE* data,
size_t length,
110 const char* hostname, UINT16 port, DWORD flags)
112 WLog_WARN(TAG,
"Certificate checks not implemented, access granted to everyone!");
116static void shw_OnConnectionResultEventHandler(
void* context,
const ConnectionResultEventArgs* e)
118 shwContext* shw = (shwContext*)context;
120 WLog_INFO(TAG,
"OnConnectionResult: %d", e->result);
123static BOOL shw_pre_connect(freerdp* instance)
126 rdpContext* context = instance->context;
127 shw = (shwContext*)context;
128 PubSub_SubscribeConnectionResult(context->pubSub, shw_OnConnectionResultEventHandler);
129 PubSub_SubscribeChannelConnected(context->pubSub, shw_OnChannelConnectedEventHandler);
130 PubSub_SubscribeChannelDisconnected(context->pubSub, shw_OnChannelDisconnectedEventHandler);
135static BOOL shw_post_connect(freerdp* instance)
140 rdpSettings* settings;
142 WINPR_ASSERT(instance);
144 shw = (shwContext*)instance->context;
147 update = instance->context->update;
148 WINPR_ASSERT(update);
150 settings = instance->context->settings;
151 WINPR_ASSERT(settings);
153 if (!gdi_init(instance, PIXEL_FORMAT_BGRX32))
156 gdi = instance->context->gdi;
157 update->BeginPaint = shw_begin_paint;
158 update->EndPaint = shw_end_paint;
159 update->DesktopResize = shw_desktop_resize;
160 update->SurfaceFrameMarker = shw_surface_frame_marker;
164static DWORD WINAPI shw_client_thread(LPVOID arg)
166 freerdp* instance = (freerdp*)arg;
167 WINPR_ASSERT(instance);
169 rdpContext* context = (rdpContext*)instance->context;
170 WINPR_ASSERT(context);
172 shwContext* shw = (shwContext*)context;
174 const BOOL bSuccess = freerdp_connect(instance);
175 WLog_INFO(TAG,
"freerdp_connect: %d", bSuccess);
183 rdpChannels* channels = context->channels;
184 WINPR_ASSERT(channels);
188 HANDLE handles[MAXIMUM_WAIT_OBJECTS] = WINPR_C_ARRAY_INIT;
189 DWORD count = freerdp_get_event_handles(instance->context, handles, ARRAYSIZE(handles));
191 if ((count == 0) || (count == MAXIMUM_WAIT_OBJECTS))
193 WLog_ERR(TAG,
"Failed to get FreeRDP event handles");
197 handles[count++] = freerdp_channels_get_event_handle(instance);
199 if (MsgWaitForMultipleObjects(count, handles, FALSE, 1000, QS_ALLINPUT) == WAIT_FAILED)
201 WLog_ERR(TAG,
"MsgWaitForMultipleObjects failure: 0x%08lX", GetLastError());
205 if (!freerdp_check_fds(instance))
207 WLog_ERR(TAG,
"Failed to check FreeRDP file descriptor");
211 if (freerdp_shall_disconnect_context(instance->context))
216 if (!freerdp_channels_check_fds(channels, instance))
218 WLog_ERR(TAG,
"Failed to check channels file descriptor");
223 freerdp_free(instance);
232static BOOL shw_freerdp_client_global_init(
void)
237static void shw_freerdp_client_global_uninit(
void)
241static int shw_freerdp_client_start(rdpContext* context)
244 freerdp* instance = context->instance;
245 shw = (shwContext*)context;
247 if (!(shw->common.thread = CreateThread(
nullptr, 0, shw_client_thread, instance, 0,
nullptr)))
249 WLog_ERR(TAG,
"Failed to create thread");
256static int shw_freerdp_client_stop(rdpContext* context)
258 shwContext* shw = (shwContext*)context;
259 (void)SetEvent(shw->StopEvent);
263static BOOL shw_freerdp_client_new(freerdp* instance, rdpContext* context)
266 rdpSettings* settings;
268 WINPR_ASSERT(instance);
269 WINPR_ASSERT(context);
271 shw = (shwContext*)instance->context;
274 if (!(shw->StopEvent = CreateEvent(
nullptr, TRUE, FALSE,
nullptr)))
277 instance->LoadChannels = freerdp_client_load_channels;
278 instance->PreConnect = shw_pre_connect;
279 instance->PostConnect = shw_post_connect;
280 instance->AuthenticateEx = shw_authenticate;
281 instance->VerifyX509Certificate = shw_verify_x509_certificate;
283 settings = context->settings;
284 WINPR_ASSERT(settings);
286 shw->settings = settings;
363static void shw_freerdp_client_free(freerdp* instance, rdpContext* context)
365 shwContext* shw = (shwContext*)instance->context;
368int shw_RdpClientEntry(RDP_CLIENT_ENTRY_POINTS* pEntryPoints)
370 pEntryPoints->Version = 1;
371 pEntryPoints->Size =
sizeof(RDP_CLIENT_ENTRY_POINTS_V1);
372 pEntryPoints->settings =
nullptr;
373 pEntryPoints->ContextSize =
sizeof(shwContext);
374 pEntryPoints->GlobalInit = shw_freerdp_client_global_init;
375 pEntryPoints->GlobalUninit = shw_freerdp_client_global_uninit;
376 pEntryPoints->ClientNew = shw_freerdp_client_new;
377 pEntryPoints->ClientFree = shw_freerdp_client_free;
378 pEntryPoints->ClientStart = shw_freerdp_client_start;
379 pEntryPoints->ClientStop = shw_freerdp_client_stop;
383int win_shadow_rdp_init(winShadowSubsystem* subsystem)
386 RDP_CLIENT_ENTRY_POINTS clientEntryPoints = WINPR_C_ARRAY_INIT;
388 clientEntryPoints.Size =
sizeof(RDP_CLIENT_ENTRY_POINTS);
389 clientEntryPoints.Version = RDP_CLIENT_INTERFACE_VERSION;
390 shw_RdpClientEntry(&clientEntryPoints);
392 if (!(subsystem->RdpUpdateEnterEvent = CreateEvent(
nullptr, TRUE, FALSE,
nullptr)))
393 goto fail_enter_event;
395 if (!(subsystem->RdpUpdateLeaveEvent = CreateEvent(
nullptr, TRUE, FALSE,
nullptr)))
396 goto fail_leave_event;
398 if (!(context = freerdp_client_context_new(&clientEntryPoints)))
401 subsystem->shw = (shwContext*)context;
402 subsystem->shw->settings = context->settings;
403 subsystem->shw->subsystem = subsystem;
406 (void)CloseHandle(subsystem->RdpUpdateLeaveEvent);
408 (void)CloseHandle(subsystem->RdpUpdateEnterEvent);
413int win_shadow_rdp_start(winShadowSubsystem* subsystem)
416 shwContext* shw = subsystem->shw;
417 rdpContext* context = (rdpContext*)shw;
418 status = freerdp_client_start(context);
422int win_shadow_rdp_stop(winShadowSubsystem* subsystem)
425 shwContext* shw = subsystem->shw;
426 rdpContext* context = (rdpContext*)shw;
427 status = freerdp_client_stop(context);
431int win_shadow_rdp_uninit(winShadowSubsystem* subsystem)
433 win_shadow_rdp_stop(subsystem);
WINPR_ATTR_NODISCARD FREERDP_API BOOL freerdp_settings_set_bool(rdpSettings *settings, FreeRDP_Settings_Keys_Bool id, BOOL val)
Sets a BOOL settings value.
WINPR_ATTR_NODISCARD FREERDP_API void * freerdp_settings_get_pointer_writable(rdpSettings *settings, FreeRDP_Settings_Keys_Pointer id)
Returns a mutable pointer settings value.
WINPR_ATTR_NODISCARD FREERDP_API BOOL freerdp_settings_set_uint32(rdpSettings *settings, FreeRDP_Settings_Keys_UInt32 id, UINT32 val)
Sets a UINT32 settings value.