Coverage Report

Created: 2026-07-16 07:14

next uncovered line (L), next uncovered region (R), next uncovered branch (B)
/src/FreeRDP/libfreerdp/core/message.c
Line
Count
Source
1
/**
2
 * FreeRDP: A Remote Desktop Protocol Implementation
3
 * Asynchronous Message Queue
4
 *
5
 * Copyright 2012 Marc-Andre Moreau <marcandre.moreau@gmail.com>
6
 * Copyright 2017 Armin Novak <armin.novak@thincast.com>
7
 * Copyright 2017 Thincast Technologies GmbH
8
 *
9
 * Licensed under the Apache License, Version 2.0 (the "License");
10
 * you may not use this file except in compliance with the License.
11
 * You may obtain a copy of the License at
12
 *
13
 *     http://www.apache.org/licenses/LICENSE-2.0
14
 *
15
 * Unless required by applicable law or agreed to in writing, software
16
 * distributed under the License is distributed on an "AS IS" BASIS,
17
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
18
 * See the License for the specific language governing permissions and
19
 * limitations under the License.
20
 */
21
22
#include <freerdp/config.h>
23
24
#include <winpr/assert.h>
25
26
#include "rdp.h"
27
#include "message.h"
28
#include "transport.h"
29
30
#include <freerdp/log.h>
31
#include <freerdp/freerdp.h>
32
33
#include <winpr/crt.h>
34
#include <winpr/stream.h>
35
#include <winpr/collections.h>
36
37
#include "../cache/pointer.h"
38
#include "../cache/bitmap.h"
39
#include "../cache/palette.h"
40
#include "../cache/glyph.h"
41
#include "../cache/brush.h"
42
#include "../cache/cache.h"
43
44
#define TAG FREERDP_TAG("core.message")
45
46
/* Update */
47
48
static BOOL update_message_BeginPaint(rdpContext* context)
49
0
{
50
0
  rdp_update_internal* up = nullptr;
51
52
0
  if (!context || !context->update)
53
0
    return FALSE;
54
55
0
  up = update_cast(context->update);
56
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(Update, BeginPaint), nullptr,
57
0
                           nullptr);
58
0
}
59
60
static BOOL update_message_EndPaint(rdpContext* context)
61
0
{
62
0
  rdp_update_internal* up = nullptr;
63
64
0
  if (!context || !context->update)
65
0
    return FALSE;
66
67
0
  up = update_cast(context->update);
68
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(Update, EndPaint), nullptr,
69
0
                           nullptr);
70
0
}
71
72
static BOOL update_message_SetBounds(rdpContext* context, const rdpBounds* bounds)
73
0
{
74
0
  rdpBounds* wParam = nullptr;
75
0
  rdp_update_internal* up = nullptr;
76
77
0
  if (!context || !context->update)
78
0
    return FALSE;
79
80
0
  if (bounds)
81
0
  {
82
0
    wParam = (rdpBounds*)malloc(sizeof(rdpBounds));
83
84
0
    if (!wParam)
85
0
      return FALSE;
86
87
0
    CopyMemory(wParam, bounds, sizeof(rdpBounds));
88
0
  }
89
90
0
  up = update_cast(context->update);
91
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(Update, SetBounds),
92
0
                           (void*)wParam, nullptr);
93
0
}
94
95
static BOOL update_message_Synchronize(rdpContext* context)
96
0
{
97
0
  rdp_update_internal* up = nullptr;
98
99
0
  if (!context || !context->update)
100
0
    return FALSE;
101
102
0
  up = update_cast(context->update);
103
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(Update, Synchronize), nullptr,
104
0
                           nullptr);
105
0
}
106
107
static BOOL update_message_DesktopResize(rdpContext* context)
108
0
{
109
0
  rdp_update_internal* up = nullptr;
110
111
0
  if (!context || !context->update)
112
0
    return FALSE;
113
114
0
  up = update_cast(context->update);
115
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(Update, DesktopResize),
116
0
                           nullptr, nullptr);
117
0
}
118
119
static BOOL update_message_BitmapUpdate(rdpContext* context, const BITMAP_UPDATE* bitmap)
120
0
{
121
0
  BITMAP_UPDATE* wParam = nullptr;
122
0
  rdp_update_internal* up = nullptr;
123
124
0
  if (!context || !context->update || !bitmap)
125
0
    return FALSE;
126
127
0
  wParam = copy_bitmap_update(context, bitmap);
128
129
0
  if (!wParam)
130
0
    return FALSE;
131
132
0
  up = update_cast(context->update);
133
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(Update, BitmapUpdate),
134
0
                           (void*)wParam, nullptr);
135
0
}
136
137
static BOOL update_message_Palette(rdpContext* context, const PALETTE_UPDATE* palette)
138
0
{
139
0
  PALETTE_UPDATE* wParam = nullptr;
140
0
  rdp_update_internal* up = nullptr;
141
142
0
  if (!context || !context->update || !palette)
143
0
    return FALSE;
144
145
0
  wParam = copy_palette_update(context, palette);
146
147
0
  if (!wParam)
148
0
    return FALSE;
149
150
0
  up = update_cast(context->update);
151
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(Update, Palette),
152
0
                           (void*)wParam, nullptr);
153
0
}
154
155
static BOOL update_message_PlaySound(rdpContext* context, const PLAY_SOUND_UPDATE* playSound)
156
0
{
157
0
  PLAY_SOUND_UPDATE* wParam = nullptr;
158
0
  rdp_update_internal* up = nullptr;
159
160
0
  if (!context || !context->update || !playSound)
161
0
    return FALSE;
162
163
0
  wParam = (PLAY_SOUND_UPDATE*)malloc(sizeof(PLAY_SOUND_UPDATE));
164
165
0
  if (!wParam)
166
0
    return FALSE;
167
168
0
  CopyMemory(wParam, playSound, sizeof(PLAY_SOUND_UPDATE));
169
170
0
  up = update_cast(context->update);
171
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(Update, PlaySound),
172
0
                           (void*)wParam, nullptr);
173
0
}
174
175
static BOOL update_message_SetKeyboardIndicators(rdpContext* context, UINT16 led_flags)
176
0
{
177
0
  rdp_update_internal* up = nullptr;
178
179
0
  if (!context || !context->update)
180
0
    return FALSE;
181
182
0
  up = update_cast(context->update);
183
0
  return MessageQueue_Post(up->queue, (void*)context,
184
0
                           MakeMessageId(Update, SetKeyboardIndicators), (void*)(size_t)led_flags,
185
0
                           nullptr);
186
0
}
187
188
static BOOL update_message_SetKeyboardImeStatus(rdpContext* context, UINT16 imeId, UINT32 imeState,
189
                                                UINT32 imeConvMode)
190
0
{
191
0
  rdp_update_internal* up = nullptr;
192
193
0
  if (!context || !context->update)
194
0
    return FALSE;
195
196
0
  up = update_cast(context->update);
197
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(Update, SetKeyboardImeStatus),
198
0
                           (void*)(size_t)((((UINT32)imeId << 16UL) & 0xFFFF0000) | imeState),
199
0
                           (void*)(size_t)imeConvMode);
200
0
}
201
202
static BOOL update_message_RefreshRect(rdpContext* context, BYTE count, const RECTANGLE_16* areas)
203
0
{
204
0
  RECTANGLE_16* lParam = nullptr;
205
0
  rdp_update_internal* up = nullptr;
206
207
0
  if (!context || !context->update || !areas)
208
0
    return FALSE;
209
210
0
  lParam = (RECTANGLE_16*)calloc(count, sizeof(RECTANGLE_16));
211
212
0
  if (!lParam)
213
0
    return FALSE;
214
215
0
  CopyMemory(lParam, areas, sizeof(RECTANGLE_16) * count);
216
217
0
  up = update_cast(context->update);
218
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(Update, RefreshRect),
219
0
                           (void*)(size_t)count, (void*)lParam);
220
0
}
221
222
static BOOL update_message_SuppressOutput(rdpContext* context, BYTE allow, const RECTANGLE_16* area)
223
0
{
224
0
  RECTANGLE_16* lParam = nullptr;
225
0
  rdp_update_internal* up = nullptr;
226
227
0
  if (!context || !context->update)
228
0
    return FALSE;
229
230
0
  if (area)
231
0
  {
232
0
    lParam = (RECTANGLE_16*)malloc(sizeof(RECTANGLE_16));
233
234
0
    if (!lParam)
235
0
      return FALSE;
236
237
0
    CopyMemory(lParam, area, sizeof(RECTANGLE_16));
238
0
  }
239
240
0
  up = update_cast(context->update);
241
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(Update, SuppressOutput),
242
0
                           (void*)(size_t)allow, (void*)lParam);
243
0
}
244
245
static BOOL update_message_SurfaceCommand(rdpContext* context, wStream* s)
246
0
{
247
0
  wStream* wParam = nullptr;
248
0
  rdp_update_internal* up = nullptr;
249
250
0
  if (!context || !context->update || !s)
251
0
    return FALSE;
252
253
0
  wParam = Stream_New(nullptr, Stream_GetRemainingLength(s));
254
255
0
  if (!wParam)
256
0
    return FALSE;
257
258
0
  Stream_Copy(s, wParam, Stream_GetRemainingLength(s));
259
0
  Stream_ResetPosition(wParam);
260
261
0
  up = update_cast(context->update);
262
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(Update, SurfaceCommand),
263
0
                           (void*)wParam, nullptr);
264
0
}
265
266
static BOOL update_message_SurfaceBits(rdpContext* context,
267
                                       const SURFACE_BITS_COMMAND* surfaceBitsCommand)
268
0
{
269
0
  SURFACE_BITS_COMMAND* wParam = nullptr;
270
0
  rdp_update_internal* up = nullptr;
271
272
0
  if (!context || !context->update || !surfaceBitsCommand)
273
0
    return FALSE;
274
275
0
  wParam = copy_surface_bits_command(context, surfaceBitsCommand);
276
277
0
  if (!wParam)
278
0
    return FALSE;
279
280
0
  up = update_cast(context->update);
281
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(Update, SurfaceBits),
282
0
                           (void*)wParam, nullptr);
283
0
}
284
285
static BOOL update_message_SurfaceFrameMarker(rdpContext* context,
286
                                              const SURFACE_FRAME_MARKER* surfaceFrameMarker)
287
0
{
288
0
  SURFACE_FRAME_MARKER* wParam = nullptr;
289
0
  rdp_update_internal* up = nullptr;
290
291
0
  if (!context || !context->update || !surfaceFrameMarker)
292
0
    return FALSE;
293
294
0
  wParam = (SURFACE_FRAME_MARKER*)malloc(sizeof(SURFACE_FRAME_MARKER));
295
296
0
  if (!wParam)
297
0
    return FALSE;
298
299
0
  CopyMemory(wParam, surfaceFrameMarker, sizeof(SURFACE_FRAME_MARKER));
300
301
0
  up = update_cast(context->update);
302
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(Update, SurfaceFrameMarker),
303
0
                           (void*)wParam, nullptr);
304
0
}
305
306
static BOOL update_message_SurfaceFrameAcknowledge(rdpContext* context, UINT32 frameId)
307
0
{
308
0
  rdp_update_internal* up = nullptr;
309
310
0
  if (!context || !context->update)
311
0
    return FALSE;
312
313
0
  up = update_cast(context->update);
314
0
  return MessageQueue_Post(up->queue, (void*)context,
315
0
                           MakeMessageId(Update, SurfaceFrameAcknowledge), (void*)(size_t)frameId,
316
0
                           nullptr);
317
0
}
318
319
/* Primary Update */
320
321
static BOOL update_message_DstBlt(rdpContext* context, const DSTBLT_ORDER* dstBlt)
322
0
{
323
0
  DSTBLT_ORDER* wParam = nullptr;
324
0
  rdp_update_internal* up = nullptr;
325
326
0
  if (!context || !context->update || !dstBlt)
327
0
    return FALSE;
328
329
0
  wParam = (DSTBLT_ORDER*)malloc(sizeof(DSTBLT_ORDER));
330
331
0
  if (!wParam)
332
0
    return FALSE;
333
334
0
  CopyMemory(wParam, dstBlt, sizeof(DSTBLT_ORDER));
335
336
0
  up = update_cast(context->update);
337
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(PrimaryUpdate, DstBlt),
338
0
                           (void*)wParam, nullptr);
339
0
}
340
341
static BOOL update_message_PatBlt(rdpContext* context, PATBLT_ORDER* patBlt)
342
0
{
343
0
  PATBLT_ORDER* wParam = nullptr;
344
0
  rdp_update_internal* up = nullptr;
345
346
0
  if (!context || !context->update || !patBlt)
347
0
    return FALSE;
348
349
0
  wParam = (PATBLT_ORDER*)malloc(sizeof(PATBLT_ORDER));
350
351
0
  if (!wParam)
352
0
    return FALSE;
353
354
0
  CopyMemory(wParam, patBlt, sizeof(PATBLT_ORDER));
355
0
  wParam->brush.data = (BYTE*)wParam->brush.p8x8;
356
357
0
  up = update_cast(context->update);
358
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(PrimaryUpdate, PatBlt),
359
0
                           (void*)wParam, nullptr);
360
0
}
361
362
static BOOL update_message_ScrBlt(rdpContext* context, const SCRBLT_ORDER* scrBlt)
363
0
{
364
0
  SCRBLT_ORDER* wParam = nullptr;
365
0
  rdp_update_internal* up = nullptr;
366
367
0
  if (!context || !context->update || !scrBlt)
368
0
    return FALSE;
369
370
0
  wParam = (SCRBLT_ORDER*)malloc(sizeof(SCRBLT_ORDER));
371
372
0
  if (!wParam)
373
0
    return FALSE;
374
375
0
  CopyMemory(wParam, scrBlt, sizeof(SCRBLT_ORDER));
376
377
0
  up = update_cast(context->update);
378
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(PrimaryUpdate, ScrBlt),
379
0
                           (void*)wParam, nullptr);
380
0
}
381
382
static BOOL update_message_OpaqueRect(rdpContext* context, const OPAQUE_RECT_ORDER* opaqueRect)
383
0
{
384
0
  OPAQUE_RECT_ORDER* wParam = nullptr;
385
0
  rdp_update_internal* up = nullptr;
386
387
0
  if (!context || !context->update || !opaqueRect)
388
0
    return FALSE;
389
390
0
  wParam = (OPAQUE_RECT_ORDER*)malloc(sizeof(OPAQUE_RECT_ORDER));
391
392
0
  if (!wParam)
393
0
    return FALSE;
394
395
0
  CopyMemory(wParam, opaqueRect, sizeof(OPAQUE_RECT_ORDER));
396
397
0
  up = update_cast(context->update);
398
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(PrimaryUpdate, OpaqueRect),
399
0
                           (void*)wParam, nullptr);
400
0
}
401
402
static BOOL update_message_DrawNineGrid(rdpContext* context,
403
                                        const DRAW_NINE_GRID_ORDER* drawNineGrid)
404
0
{
405
0
  DRAW_NINE_GRID_ORDER* wParam = nullptr;
406
0
  rdp_update_internal* up = nullptr;
407
408
0
  if (!context || !context->update || !drawNineGrid)
409
0
    return FALSE;
410
411
0
  wParam = (DRAW_NINE_GRID_ORDER*)malloc(sizeof(DRAW_NINE_GRID_ORDER));
412
413
0
  if (!wParam)
414
0
    return FALSE;
415
416
0
  CopyMemory(wParam, drawNineGrid, sizeof(DRAW_NINE_GRID_ORDER));
417
418
0
  up = update_cast(context->update);
419
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(PrimaryUpdate, DrawNineGrid),
420
0
                           (void*)wParam, nullptr);
421
0
}
422
423
static BOOL update_message_MultiDstBlt(rdpContext* context, const MULTI_DSTBLT_ORDER* multiDstBlt)
424
0
{
425
0
  MULTI_DSTBLT_ORDER* wParam = nullptr;
426
0
  rdp_update_internal* up = nullptr;
427
428
0
  if (!context || !context->update || !multiDstBlt)
429
0
    return FALSE;
430
431
0
  wParam = (MULTI_DSTBLT_ORDER*)malloc(sizeof(MULTI_DSTBLT_ORDER));
432
433
0
  if (!wParam)
434
0
    return FALSE;
435
436
0
  CopyMemory(wParam, multiDstBlt, sizeof(MULTI_DSTBLT_ORDER));
437
438
0
  up = update_cast(context->update);
439
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(PrimaryUpdate, MultiDstBlt),
440
0
                           (void*)wParam, nullptr);
441
0
}
442
443
static BOOL update_message_MultiPatBlt(rdpContext* context, const MULTI_PATBLT_ORDER* multiPatBlt)
444
0
{
445
0
  MULTI_PATBLT_ORDER* wParam = nullptr;
446
0
  rdp_update_internal* up = nullptr;
447
448
0
  if (!context || !context->update || !multiPatBlt)
449
0
    return FALSE;
450
451
0
  wParam = (MULTI_PATBLT_ORDER*)malloc(sizeof(MULTI_PATBLT_ORDER));
452
453
0
  if (!wParam)
454
0
    return FALSE;
455
456
0
  CopyMemory(wParam, multiPatBlt, sizeof(MULTI_PATBLT_ORDER));
457
0
  wParam->brush.data = (BYTE*)wParam->brush.p8x8;
458
459
0
  up = update_cast(context->update);
460
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(PrimaryUpdate, MultiPatBlt),
461
0
                           (void*)wParam, nullptr);
462
0
}
463
464
static BOOL update_message_MultiScrBlt(rdpContext* context, const MULTI_SCRBLT_ORDER* multiScrBlt)
465
0
{
466
0
  MULTI_SCRBLT_ORDER* wParam = nullptr;
467
0
  rdp_update_internal* up = nullptr;
468
469
0
  if (!context || !context->update || !multiScrBlt)
470
0
    return FALSE;
471
472
0
  wParam = (MULTI_SCRBLT_ORDER*)malloc(sizeof(MULTI_SCRBLT_ORDER));
473
474
0
  if (!wParam)
475
0
    return FALSE;
476
477
0
  CopyMemory(wParam, multiScrBlt, sizeof(MULTI_SCRBLT_ORDER));
478
479
0
  up = update_cast(context->update);
480
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(PrimaryUpdate, MultiScrBlt),
481
0
                           (void*)wParam, nullptr);
482
0
}
483
484
static BOOL update_message_MultiOpaqueRect(rdpContext* context,
485
                                           const MULTI_OPAQUE_RECT_ORDER* multiOpaqueRect)
486
0
{
487
0
  MULTI_OPAQUE_RECT_ORDER* wParam = nullptr;
488
0
  rdp_update_internal* up = nullptr;
489
490
0
  if (!context || !context->update || !multiOpaqueRect)
491
0
    return FALSE;
492
493
0
  wParam = (MULTI_OPAQUE_RECT_ORDER*)malloc(sizeof(MULTI_OPAQUE_RECT_ORDER));
494
495
0
  if (!wParam)
496
0
    return FALSE;
497
498
0
  CopyMemory(wParam, multiOpaqueRect, sizeof(MULTI_OPAQUE_RECT_ORDER));
499
500
0
  up = update_cast(context->update);
501
0
  return MessageQueue_Post(up->queue, (void*)context,
502
0
                           MakeMessageId(PrimaryUpdate, MultiOpaqueRect), (void*)wParam, nullptr);
503
0
}
504
505
static BOOL update_message_MultiDrawNineGrid(rdpContext* context,
506
                                             const MULTI_DRAW_NINE_GRID_ORDER* multiDrawNineGrid)
507
0
{
508
0
  MULTI_DRAW_NINE_GRID_ORDER* wParam = nullptr;
509
0
  rdp_update_internal* up = nullptr;
510
511
0
  if (!context || !context->update || !multiDrawNineGrid)
512
0
    return FALSE;
513
514
0
  wParam = (MULTI_DRAW_NINE_GRID_ORDER*)malloc(sizeof(MULTI_DRAW_NINE_GRID_ORDER));
515
516
0
  if (!wParam)
517
0
    return FALSE;
518
519
0
  CopyMemory(wParam, multiDrawNineGrid, sizeof(MULTI_DRAW_NINE_GRID_ORDER));
520
  /* TODO: complete copy */
521
522
0
  up = update_cast(context->update);
523
0
  return MessageQueue_Post(up->queue, (void*)context,
524
0
                           MakeMessageId(PrimaryUpdate, MultiDrawNineGrid), (void*)wParam,
525
0
                           nullptr);
526
0
}
527
528
static BOOL update_message_LineTo(rdpContext* context, const LINE_TO_ORDER* lineTo)
529
0
{
530
0
  LINE_TO_ORDER* wParam = nullptr;
531
0
  rdp_update_internal* up = nullptr;
532
533
0
  if (!context || !context->update || !lineTo)
534
0
    return FALSE;
535
536
0
  wParam = (LINE_TO_ORDER*)malloc(sizeof(LINE_TO_ORDER));
537
538
0
  if (!wParam)
539
0
    return FALSE;
540
541
0
  CopyMemory(wParam, lineTo, sizeof(LINE_TO_ORDER));
542
543
0
  up = update_cast(context->update);
544
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(PrimaryUpdate, LineTo),
545
0
                           (void*)wParam, nullptr);
546
0
}
547
548
static BOOL update_message_Polyline(rdpContext* context, const POLYLINE_ORDER* polyline)
549
0
{
550
0
  POLYLINE_ORDER* wParam = nullptr;
551
0
  rdp_update_internal* up = nullptr;
552
553
0
  if (!context || !context->update || !polyline)
554
0
    return FALSE;
555
556
0
  wParam = (POLYLINE_ORDER*)malloc(sizeof(POLYLINE_ORDER));
557
558
0
  if (!wParam)
559
0
    return FALSE;
560
561
0
  CopyMemory(wParam, polyline, sizeof(POLYLINE_ORDER));
562
0
  wParam->points = (DELTA_POINT*)calloc(wParam->numDeltaEntries, sizeof(DELTA_POINT));
563
564
0
  if (!wParam->points)
565
0
  {
566
0
    free(wParam);
567
0
    return FALSE;
568
0
  }
569
570
0
  CopyMemory(wParam->points, polyline->points, sizeof(DELTA_POINT) * wParam->numDeltaEntries);
571
572
0
  up = update_cast(context->update);
573
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(PrimaryUpdate, Polyline),
574
0
                           (void*)wParam, nullptr);
575
0
}
576
577
static BOOL update_message_MemBlt(rdpContext* context, MEMBLT_ORDER* memBlt)
578
0
{
579
0
  MEMBLT_ORDER* wParam = nullptr;
580
0
  rdp_update_internal* up = nullptr;
581
582
0
  if (!context || !context->update || !memBlt)
583
0
    return FALSE;
584
585
0
  wParam = (MEMBLT_ORDER*)malloc(sizeof(MEMBLT_ORDER));
586
587
0
  if (!wParam)
588
0
    return FALSE;
589
590
0
  CopyMemory(wParam, memBlt, sizeof(MEMBLT_ORDER));
591
592
0
  up = update_cast(context->update);
593
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(PrimaryUpdate, MemBlt),
594
0
                           (void*)wParam, nullptr);
595
0
}
596
597
static BOOL update_message_Mem3Blt(rdpContext* context, MEM3BLT_ORDER* mem3Blt)
598
0
{
599
0
  MEM3BLT_ORDER* wParam = nullptr;
600
0
  rdp_update_internal* up = nullptr;
601
602
0
  if (!context || !context->update || !mem3Blt)
603
0
    return FALSE;
604
605
0
  wParam = (MEM3BLT_ORDER*)malloc(sizeof(MEM3BLT_ORDER));
606
607
0
  if (!wParam)
608
0
    return FALSE;
609
610
0
  CopyMemory(wParam, mem3Blt, sizeof(MEM3BLT_ORDER));
611
0
  wParam->brush.data = (BYTE*)wParam->brush.p8x8;
612
613
0
  up = update_cast(context->update);
614
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(PrimaryUpdate, Mem3Blt),
615
0
                           (void*)wParam, nullptr);
616
0
}
617
618
static BOOL update_message_SaveBitmap(rdpContext* context, const SAVE_BITMAP_ORDER* saveBitmap)
619
0
{
620
0
  SAVE_BITMAP_ORDER* wParam = nullptr;
621
0
  rdp_update_internal* up = nullptr;
622
623
0
  if (!context || !context->update || !saveBitmap)
624
0
    return FALSE;
625
626
0
  wParam = (SAVE_BITMAP_ORDER*)malloc(sizeof(SAVE_BITMAP_ORDER));
627
628
0
  if (!wParam)
629
0
    return FALSE;
630
631
0
  CopyMemory(wParam, saveBitmap, sizeof(SAVE_BITMAP_ORDER));
632
633
0
  up = update_cast(context->update);
634
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(PrimaryUpdate, SaveBitmap),
635
0
                           (void*)wParam, nullptr);
636
0
}
637
638
static BOOL update_message_GlyphIndex(rdpContext* context, GLYPH_INDEX_ORDER* glyphIndex)
639
0
{
640
0
  GLYPH_INDEX_ORDER* wParam = nullptr;
641
0
  rdp_update_internal* up = nullptr;
642
643
0
  if (!context || !context->update || !glyphIndex)
644
0
    return FALSE;
645
646
0
  wParam = (GLYPH_INDEX_ORDER*)malloc(sizeof(GLYPH_INDEX_ORDER));
647
648
0
  if (!wParam)
649
0
    return FALSE;
650
651
0
  CopyMemory(wParam, glyphIndex, sizeof(GLYPH_INDEX_ORDER));
652
0
  wParam->brush.data = (BYTE*)wParam->brush.p8x8;
653
654
0
  up = update_cast(context->update);
655
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(PrimaryUpdate, GlyphIndex),
656
0
                           (void*)wParam, nullptr);
657
0
}
658
659
static BOOL update_message_FastIndex(rdpContext* context, const FAST_INDEX_ORDER* fastIndex)
660
0
{
661
0
  FAST_INDEX_ORDER* wParam = nullptr;
662
0
  rdp_update_internal* up = nullptr;
663
664
0
  if (!context || !context->update || !fastIndex)
665
0
    return FALSE;
666
667
0
  wParam = (FAST_INDEX_ORDER*)malloc(sizeof(FAST_INDEX_ORDER));
668
669
0
  if (!wParam)
670
0
    return FALSE;
671
672
0
  CopyMemory(wParam, fastIndex, sizeof(FAST_INDEX_ORDER));
673
674
0
  up = update_cast(context->update);
675
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(PrimaryUpdate, FastIndex),
676
0
                           (void*)wParam, nullptr);
677
0
}
678
679
static BOOL update_message_FastGlyph(rdpContext* context, const FAST_GLYPH_ORDER* fastGlyph)
680
0
{
681
0
  FAST_GLYPH_ORDER* wParam = nullptr;
682
0
  rdp_update_internal* up = nullptr;
683
684
0
  if (!context || !context->update || !fastGlyph)
685
0
    return FALSE;
686
687
0
  wParam = (FAST_GLYPH_ORDER*)malloc(sizeof(FAST_GLYPH_ORDER));
688
689
0
  if (!wParam)
690
0
    return FALSE;
691
692
0
  CopyMemory(wParam, fastGlyph, sizeof(FAST_GLYPH_ORDER));
693
694
0
  if (wParam->cbData > 1)
695
0
  {
696
0
    wParam->glyphData.aj = (BYTE*)malloc(fastGlyph->glyphData.cb);
697
698
0
    if (!wParam->glyphData.aj)
699
0
    {
700
0
      free(wParam);
701
0
      return FALSE;
702
0
    }
703
704
0
    CopyMemory(wParam->glyphData.aj, fastGlyph->glyphData.aj, fastGlyph->glyphData.cb);
705
0
  }
706
0
  else
707
0
  {
708
0
    wParam->glyphData.aj = nullptr;
709
0
  }
710
711
0
  up = update_cast(context->update);
712
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(PrimaryUpdate, FastGlyph),
713
0
                           (void*)wParam, nullptr);
714
0
}
715
716
static BOOL update_message_PolygonSC(rdpContext* context, const POLYGON_SC_ORDER* polygonSC)
717
0
{
718
0
  if (!context || !context->update || !polygonSC)
719
0
    return FALSE;
720
721
0
  POLYGON_SC_ORDER* wParam = (POLYGON_SC_ORDER*)malloc(sizeof(POLYGON_SC_ORDER));
722
723
0
  if (!wParam)
724
0
    return FALSE;
725
726
0
  *wParam = *polygonSC;
727
0
  if (polygonSC->numPoints > 0)
728
0
  {
729
0
    wParam->points = (DELTA_POINT*)calloc(polygonSC->numPoints, sizeof(DELTA_POINT));
730
731
0
    if (!wParam->points)
732
0
    {
733
0
      free(wParam);
734
0
      return FALSE;
735
0
    }
736
737
0
    CopyMemory(wParam->points, polygonSC->points, sizeof(DELTA_POINT) * wParam->numPoints);
738
0
  }
739
740
0
  rdp_update_internal* up = update_cast(context->update);
741
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(PrimaryUpdate, PolygonSC),
742
0
                           (void*)wParam, nullptr);
743
0
}
744
745
static BOOL update_message_PolygonCB(rdpContext* context, POLYGON_CB_ORDER* polygonCB)
746
0
{
747
0
  if (!context || !context->update || !polygonCB)
748
0
    return FALSE;
749
750
0
  POLYGON_CB_ORDER* wParam = (POLYGON_CB_ORDER*)malloc(sizeof(POLYGON_CB_ORDER));
751
752
0
  if (!wParam)
753
0
    return FALSE;
754
755
0
  *wParam = *polygonCB;
756
0
  if (polygonCB->numPoints > 0)
757
0
  {
758
0
    wParam->points = (DELTA_POINT*)calloc(polygonCB->numPoints, sizeof(DELTA_POINT));
759
760
0
    if (!wParam->points)
761
0
    {
762
0
      free(wParam);
763
0
      return FALSE;
764
0
    }
765
766
0
    CopyMemory(wParam->points, polygonCB->points, sizeof(DELTA_POINT) * wParam->numPoints);
767
0
  }
768
769
0
  wParam->brush.data = (BYTE*)wParam->brush.p8x8;
770
771
0
  rdp_update_internal* up = update_cast(context->update);
772
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(PrimaryUpdate, PolygonCB),
773
0
                           (void*)wParam, nullptr);
774
0
}
775
776
static BOOL update_message_EllipseSC(rdpContext* context, const ELLIPSE_SC_ORDER* ellipseSC)
777
0
{
778
0
  if (!context || !context->update || !ellipseSC)
779
0
    return FALSE;
780
781
0
  ELLIPSE_SC_ORDER* wParam = (ELLIPSE_SC_ORDER*)malloc(sizeof(ELLIPSE_SC_ORDER));
782
783
0
  if (!wParam)
784
0
    return FALSE;
785
786
0
  CopyMemory(wParam, ellipseSC, sizeof(ELLIPSE_SC_ORDER));
787
788
0
  rdp_update_internal* up = update_cast(context->update);
789
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(PrimaryUpdate, EllipseSC),
790
0
                           (void*)wParam, nullptr);
791
0
}
792
793
static BOOL update_message_EllipseCB(rdpContext* context, const ELLIPSE_CB_ORDER* ellipseCB)
794
0
{
795
0
  ELLIPSE_CB_ORDER* wParam = nullptr;
796
0
  rdp_update_internal* up = nullptr;
797
798
0
  if (!context || !context->update || !ellipseCB)
799
0
    return FALSE;
800
801
0
  wParam = (ELLIPSE_CB_ORDER*)malloc(sizeof(ELLIPSE_CB_ORDER));
802
803
0
  if (!wParam)
804
0
    return FALSE;
805
806
0
  CopyMemory(wParam, ellipseCB, sizeof(ELLIPSE_CB_ORDER));
807
0
  wParam->brush.data = (BYTE*)wParam->brush.p8x8;
808
809
0
  up = update_cast(context->update);
810
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(PrimaryUpdate, EllipseCB),
811
0
                           (void*)wParam, nullptr);
812
0
}
813
814
/* Secondary Update */
815
816
static BOOL update_message_CacheBitmap(rdpContext* context,
817
                                       const CACHE_BITMAP_ORDER* cacheBitmapOrder)
818
0
{
819
0
  CACHE_BITMAP_ORDER* wParam = nullptr;
820
0
  rdp_update_internal* up = nullptr;
821
822
0
  if (!context || !context->update || !cacheBitmapOrder)
823
0
    return FALSE;
824
825
0
  wParam = copy_cache_bitmap_order(context, cacheBitmapOrder);
826
827
0
  if (!wParam)
828
0
    return FALSE;
829
830
0
  up = update_cast(context->update);
831
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(SecondaryUpdate, CacheBitmap),
832
0
                           (void*)wParam, nullptr);
833
0
}
834
835
static BOOL update_message_CacheBitmapV2(rdpContext* context,
836
                                         CACHE_BITMAP_V2_ORDER* cacheBitmapV2Order)
837
0
{
838
0
  CACHE_BITMAP_V2_ORDER* wParam = nullptr;
839
0
  rdp_update_internal* up = nullptr;
840
841
0
  if (!context || !context->update || !cacheBitmapV2Order)
842
0
    return FALSE;
843
844
0
  wParam = copy_cache_bitmap_v2_order(context, cacheBitmapV2Order);
845
846
0
  if (!wParam)
847
0
    return FALSE;
848
849
0
  up = update_cast(context->update);
850
0
  return MessageQueue_Post(up->queue, (void*)context,
851
0
                           MakeMessageId(SecondaryUpdate, CacheBitmapV2), (void*)wParam, nullptr);
852
0
}
853
854
static BOOL update_message_CacheBitmapV3(rdpContext* context,
855
                                         CACHE_BITMAP_V3_ORDER* cacheBitmapV3Order)
856
0
{
857
0
  CACHE_BITMAP_V3_ORDER* wParam = nullptr;
858
0
  rdp_update_internal* up = nullptr;
859
860
0
  if (!context || !context->update || !cacheBitmapV3Order)
861
0
    return FALSE;
862
863
0
  wParam = copy_cache_bitmap_v3_order(context, cacheBitmapV3Order);
864
865
0
  if (!wParam)
866
0
    return FALSE;
867
868
0
  up = update_cast(context->update);
869
0
  return MessageQueue_Post(up->queue, (void*)context,
870
0
                           MakeMessageId(SecondaryUpdate, CacheBitmapV3), (void*)wParam, nullptr);
871
0
}
872
873
static BOOL update_message_CacheColorTable(rdpContext* context,
874
                                           const CACHE_COLOR_TABLE_ORDER* cacheColorTableOrder)
875
0
{
876
0
  CACHE_COLOR_TABLE_ORDER* wParam = nullptr;
877
0
  rdp_update_internal* up = nullptr;
878
879
0
  if (!context || !context->update || !cacheColorTableOrder)
880
0
    return FALSE;
881
882
0
  wParam = copy_cache_color_table_order(context, cacheColorTableOrder);
883
884
0
  if (!wParam)
885
0
    return FALSE;
886
887
0
  up = update_cast(context->update);
888
0
  return MessageQueue_Post(up->queue, (void*)context,
889
0
                           MakeMessageId(SecondaryUpdate, CacheColorTable), (void*)wParam,
890
0
                           nullptr);
891
0
}
892
893
static BOOL update_message_CacheGlyph(rdpContext* context, const CACHE_GLYPH_ORDER* cacheGlyphOrder)
894
0
{
895
0
  CACHE_GLYPH_ORDER* wParam = nullptr;
896
0
  rdp_update_internal* up = nullptr;
897
898
0
  if (!context || !context->update || !cacheGlyphOrder)
899
0
    return FALSE;
900
901
0
  wParam = copy_cache_glyph_order(context, cacheGlyphOrder);
902
903
0
  if (!wParam)
904
0
    return FALSE;
905
906
0
  up = update_cast(context->update);
907
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(SecondaryUpdate, CacheGlyph),
908
0
                           (void*)wParam, nullptr);
909
0
}
910
911
static BOOL update_message_CacheGlyphV2(rdpContext* context,
912
                                        const CACHE_GLYPH_V2_ORDER* cacheGlyphV2Order)
913
0
{
914
0
  CACHE_GLYPH_V2_ORDER* wParam = nullptr;
915
0
  rdp_update_internal* up = nullptr;
916
917
0
  if (!context || !context->update || !cacheGlyphV2Order)
918
0
    return FALSE;
919
920
0
  wParam = copy_cache_glyph_v2_order(context, cacheGlyphV2Order);
921
922
0
  if (!wParam)
923
0
    return FALSE;
924
925
0
  up = update_cast(context->update);
926
0
  return MessageQueue_Post(up->queue, (void*)context,
927
0
                           MakeMessageId(SecondaryUpdate, CacheGlyphV2), (void*)wParam, nullptr);
928
0
}
929
930
static BOOL update_message_CacheBrush(rdpContext* context, const CACHE_BRUSH_ORDER* cacheBrushOrder)
931
0
{
932
0
  CACHE_BRUSH_ORDER* wParam = nullptr;
933
0
  rdp_update_internal* up = nullptr;
934
935
0
  if (!context || !context->update || !cacheBrushOrder)
936
0
    return FALSE;
937
938
0
  wParam = copy_cache_brush_order(context, cacheBrushOrder);
939
940
0
  if (!wParam)
941
0
    return FALSE;
942
943
0
  up = update_cast(context->update);
944
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(SecondaryUpdate, CacheBrush),
945
0
                           (void*)wParam, nullptr);
946
0
}
947
948
/* Alternate Secondary Update */
949
950
static BOOL
951
update_message_CreateOffscreenBitmap(rdpContext* context,
952
                                     const CREATE_OFFSCREEN_BITMAP_ORDER* createOffscreenBitmap)
953
0
{
954
0
  CREATE_OFFSCREEN_BITMAP_ORDER* wParam = nullptr;
955
0
  rdp_update_internal* up = nullptr;
956
957
0
  if (!context || !context->update || !createOffscreenBitmap)
958
0
    return FALSE;
959
960
0
  wParam = (CREATE_OFFSCREEN_BITMAP_ORDER*)malloc(sizeof(CREATE_OFFSCREEN_BITMAP_ORDER));
961
962
0
  if (!wParam)
963
0
    return FALSE;
964
965
0
  CopyMemory(wParam, createOffscreenBitmap, sizeof(CREATE_OFFSCREEN_BITMAP_ORDER));
966
0
  wParam->deleteList.cIndices = createOffscreenBitmap->deleteList.cIndices;
967
0
  wParam->deleteList.sIndices = wParam->deleteList.cIndices;
968
0
  wParam->deleteList.indices = (UINT16*)calloc(wParam->deleteList.cIndices, sizeof(UINT16));
969
970
0
  if (!wParam->deleteList.indices)
971
0
  {
972
0
    free(wParam);
973
0
    return FALSE;
974
0
  }
975
976
0
  CopyMemory(wParam->deleteList.indices, createOffscreenBitmap->deleteList.indices,
977
0
             wParam->deleteList.cIndices);
978
979
0
  up = update_cast(context->update);
980
0
  return MessageQueue_Post(up->queue, (void*)context,
981
0
                           MakeMessageId(AltSecUpdate, CreateOffscreenBitmap), (void*)wParam,
982
0
                           nullptr);
983
0
}
984
985
static BOOL update_message_SwitchSurface(rdpContext* context,
986
                                         const SWITCH_SURFACE_ORDER* switchSurface)
987
0
{
988
0
  SWITCH_SURFACE_ORDER* wParam = nullptr;
989
0
  rdp_update_internal* up = nullptr;
990
991
0
  if (!context || !context->update || !switchSurface)
992
0
    return FALSE;
993
994
0
  wParam = (SWITCH_SURFACE_ORDER*)malloc(sizeof(SWITCH_SURFACE_ORDER));
995
996
0
  if (!wParam)
997
0
    return FALSE;
998
999
0
  CopyMemory(wParam, switchSurface, sizeof(SWITCH_SURFACE_ORDER));
1000
1001
0
  up = update_cast(context->update);
1002
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(AltSecUpdate, SwitchSurface),
1003
0
                           (void*)wParam, nullptr);
1004
0
}
1005
1006
static BOOL
1007
update_message_CreateNineGridBitmap(rdpContext* context,
1008
                                    const CREATE_NINE_GRID_BITMAP_ORDER* createNineGridBitmap)
1009
0
{
1010
0
  CREATE_NINE_GRID_BITMAP_ORDER* wParam = nullptr;
1011
0
  rdp_update_internal* up = nullptr;
1012
1013
0
  if (!context || !context->update || !createNineGridBitmap)
1014
0
    return FALSE;
1015
1016
0
  wParam = (CREATE_NINE_GRID_BITMAP_ORDER*)malloc(sizeof(CREATE_NINE_GRID_BITMAP_ORDER));
1017
1018
0
  if (!wParam)
1019
0
    return FALSE;
1020
1021
0
  CopyMemory(wParam, createNineGridBitmap, sizeof(CREATE_NINE_GRID_BITMAP_ORDER));
1022
1023
0
  up = update_cast(context->update);
1024
0
  return MessageQueue_Post(up->queue, (void*)context,
1025
0
                           MakeMessageId(AltSecUpdate, CreateNineGridBitmap), (void*)wParam,
1026
0
                           nullptr);
1027
0
}
1028
1029
static BOOL update_message_FrameMarker(rdpContext* context, const FRAME_MARKER_ORDER* frameMarker)
1030
0
{
1031
0
  FRAME_MARKER_ORDER* wParam = nullptr;
1032
0
  rdp_update_internal* up = nullptr;
1033
1034
0
  if (!context || !context->update || !frameMarker)
1035
0
    return FALSE;
1036
1037
0
  wParam = (FRAME_MARKER_ORDER*)malloc(sizeof(FRAME_MARKER_ORDER));
1038
1039
0
  if (!wParam)
1040
0
    return FALSE;
1041
1042
0
  CopyMemory(wParam, frameMarker, sizeof(FRAME_MARKER_ORDER));
1043
1044
0
  up = update_cast(context->update);
1045
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(AltSecUpdate, FrameMarker),
1046
0
                           (void*)wParam, nullptr);
1047
0
}
1048
1049
static BOOL update_message_StreamBitmapFirst(rdpContext* context,
1050
                                             const STREAM_BITMAP_FIRST_ORDER* streamBitmapFirst)
1051
0
{
1052
0
  STREAM_BITMAP_FIRST_ORDER* wParam = nullptr;
1053
0
  rdp_update_internal* up = nullptr;
1054
1055
0
  if (!context || !context->update || !streamBitmapFirst)
1056
0
    return FALSE;
1057
1058
0
  wParam = (STREAM_BITMAP_FIRST_ORDER*)malloc(sizeof(STREAM_BITMAP_FIRST_ORDER));
1059
1060
0
  if (!wParam)
1061
0
    return FALSE;
1062
1063
0
  CopyMemory(wParam, streamBitmapFirst, sizeof(STREAM_BITMAP_FIRST_ORDER));
1064
  /* TODO: complete copy */
1065
1066
0
  up = update_cast(context->update);
1067
0
  return MessageQueue_Post(up->queue, (void*)context,
1068
0
                           MakeMessageId(AltSecUpdate, StreamBitmapFirst), (void*)wParam,
1069
0
                           nullptr);
1070
0
}
1071
1072
static BOOL update_message_StreamBitmapNext(rdpContext* context,
1073
                                            const STREAM_BITMAP_NEXT_ORDER* streamBitmapNext)
1074
0
{
1075
0
  STREAM_BITMAP_NEXT_ORDER* wParam = nullptr;
1076
0
  rdp_update_internal* up = nullptr;
1077
1078
0
  if (!context || !context->update || !streamBitmapNext)
1079
0
    return FALSE;
1080
1081
0
  wParam = (STREAM_BITMAP_NEXT_ORDER*)malloc(sizeof(STREAM_BITMAP_NEXT_ORDER));
1082
1083
0
  if (!wParam)
1084
0
    return FALSE;
1085
1086
0
  CopyMemory(wParam, streamBitmapNext, sizeof(STREAM_BITMAP_NEXT_ORDER));
1087
  /* TODO: complete copy */
1088
1089
0
  up = update_cast(context->update);
1090
0
  return MessageQueue_Post(up->queue, (void*)context,
1091
0
                           MakeMessageId(AltSecUpdate, StreamBitmapNext), (void*)wParam, nullptr);
1092
0
}
1093
1094
static BOOL update_message_DrawGdiPlusFirst(rdpContext* context,
1095
                                            const DRAW_GDIPLUS_FIRST_ORDER* drawGdiPlusFirst)
1096
0
{
1097
0
  DRAW_GDIPLUS_FIRST_ORDER* wParam = nullptr;
1098
0
  rdp_update_internal* up = nullptr;
1099
1100
0
  if (!context || !context->update || !drawGdiPlusFirst)
1101
0
    return FALSE;
1102
1103
0
  wParam = (DRAW_GDIPLUS_FIRST_ORDER*)malloc(sizeof(DRAW_GDIPLUS_FIRST_ORDER));
1104
1105
0
  if (!wParam)
1106
0
    return FALSE;
1107
1108
0
  CopyMemory(wParam, drawGdiPlusFirst, sizeof(DRAW_GDIPLUS_FIRST_ORDER));
1109
  /* TODO: complete copy */
1110
0
  up = update_cast(context->update);
1111
0
  return MessageQueue_Post(up->queue, (void*)context,
1112
0
                           MakeMessageId(AltSecUpdate, DrawGdiPlusFirst), (void*)wParam, nullptr);
1113
0
}
1114
1115
static BOOL update_message_DrawGdiPlusNext(rdpContext* context,
1116
                                           const DRAW_GDIPLUS_NEXT_ORDER* drawGdiPlusNext)
1117
0
{
1118
0
  DRAW_GDIPLUS_NEXT_ORDER* wParam = nullptr;
1119
0
  rdp_update_internal* up = nullptr;
1120
1121
0
  if (!context || !context->update || !drawGdiPlusNext)
1122
0
    return FALSE;
1123
1124
0
  wParam = (DRAW_GDIPLUS_NEXT_ORDER*)malloc(sizeof(DRAW_GDIPLUS_NEXT_ORDER));
1125
1126
0
  if (!wParam)
1127
0
    return FALSE;
1128
1129
0
  CopyMemory(wParam, drawGdiPlusNext, sizeof(DRAW_GDIPLUS_NEXT_ORDER));
1130
  /* TODO: complete copy */
1131
1132
0
  up = update_cast(context->update);
1133
0
  return MessageQueue_Post(up->queue, (void*)context,
1134
0
                           MakeMessageId(AltSecUpdate, DrawGdiPlusNext), (void*)wParam, nullptr);
1135
0
}
1136
1137
static BOOL update_message_DrawGdiPlusEnd(rdpContext* context,
1138
                                          const DRAW_GDIPLUS_END_ORDER* drawGdiPlusEnd)
1139
0
{
1140
0
  DRAW_GDIPLUS_END_ORDER* wParam = nullptr;
1141
0
  rdp_update_internal* up = nullptr;
1142
1143
0
  if (!context || !context->update || !drawGdiPlusEnd)
1144
0
    return FALSE;
1145
1146
0
  wParam = (DRAW_GDIPLUS_END_ORDER*)malloc(sizeof(DRAW_GDIPLUS_END_ORDER));
1147
1148
0
  if (!wParam)
1149
0
    return FALSE;
1150
1151
0
  CopyMemory(wParam, drawGdiPlusEnd, sizeof(DRAW_GDIPLUS_END_ORDER));
1152
  /* TODO: complete copy */
1153
1154
0
  up = update_cast(context->update);
1155
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(AltSecUpdate, DrawGdiPlusEnd),
1156
0
                           (void*)wParam, nullptr);
1157
0
}
1158
1159
static BOOL
1160
update_message_DrawGdiPlusCacheFirst(rdpContext* context,
1161
                                     const DRAW_GDIPLUS_CACHE_FIRST_ORDER* drawGdiPlusCacheFirst)
1162
0
{
1163
0
  DRAW_GDIPLUS_CACHE_FIRST_ORDER* wParam = nullptr;
1164
0
  rdp_update_internal* up = nullptr;
1165
1166
0
  if (!context || !context->update || !drawGdiPlusCacheFirst)
1167
0
    return FALSE;
1168
1169
0
  wParam = (DRAW_GDIPLUS_CACHE_FIRST_ORDER*)malloc(sizeof(DRAW_GDIPLUS_CACHE_FIRST_ORDER));
1170
1171
0
  if (!wParam)
1172
0
    return FALSE;
1173
1174
0
  CopyMemory(wParam, drawGdiPlusCacheFirst, sizeof(DRAW_GDIPLUS_CACHE_FIRST_ORDER));
1175
  /* TODO: complete copy */
1176
1177
0
  up = update_cast(context->update);
1178
0
  return MessageQueue_Post(up->queue, (void*)context,
1179
0
                           MakeMessageId(AltSecUpdate, DrawGdiPlusCacheFirst), (void*)wParam,
1180
0
                           nullptr);
1181
0
}
1182
1183
static BOOL
1184
update_message_DrawGdiPlusCacheNext(rdpContext* context,
1185
                                    const DRAW_GDIPLUS_CACHE_NEXT_ORDER* drawGdiPlusCacheNext)
1186
0
{
1187
0
  DRAW_GDIPLUS_CACHE_NEXT_ORDER* wParam = nullptr;
1188
0
  rdp_update_internal* up = nullptr;
1189
1190
0
  if (!context || !context->update || !drawGdiPlusCacheNext)
1191
0
    return FALSE;
1192
1193
0
  wParam = (DRAW_GDIPLUS_CACHE_NEXT_ORDER*)malloc(sizeof(DRAW_GDIPLUS_CACHE_NEXT_ORDER));
1194
1195
0
  if (!wParam)
1196
0
    return FALSE;
1197
1198
0
  CopyMemory(wParam, drawGdiPlusCacheNext, sizeof(DRAW_GDIPLUS_CACHE_NEXT_ORDER));
1199
  /* TODO: complete copy */
1200
1201
0
  up = update_cast(context->update);
1202
0
  return MessageQueue_Post(up->queue, (void*)context,
1203
0
                           MakeMessageId(AltSecUpdate, DrawGdiPlusCacheNext), (void*)wParam,
1204
0
                           nullptr);
1205
0
}
1206
1207
static BOOL
1208
update_message_DrawGdiPlusCacheEnd(rdpContext* context,
1209
                                   const DRAW_GDIPLUS_CACHE_END_ORDER* drawGdiPlusCacheEnd)
1210
0
{
1211
0
  DRAW_GDIPLUS_CACHE_END_ORDER* wParam = nullptr;
1212
0
  rdp_update_internal* up = nullptr;
1213
1214
0
  if (!context || !context->update || !drawGdiPlusCacheEnd)
1215
0
    return FALSE;
1216
1217
0
  wParam = (DRAW_GDIPLUS_CACHE_END_ORDER*)malloc(sizeof(DRAW_GDIPLUS_CACHE_END_ORDER));
1218
1219
0
  if (!wParam)
1220
0
    return FALSE;
1221
1222
0
  CopyMemory(wParam, drawGdiPlusCacheEnd, sizeof(DRAW_GDIPLUS_CACHE_END_ORDER));
1223
  /* TODO: complete copy */
1224
1225
0
  up = update_cast(context->update);
1226
0
  return MessageQueue_Post(up->queue, (void*)context,
1227
0
                           MakeMessageId(AltSecUpdate, DrawGdiPlusCacheEnd), (void*)wParam,
1228
0
                           nullptr);
1229
0
}
1230
1231
/* Window Update */
1232
static RAIL_UNICODE_STRING rail_unicode_string_clone(const RAIL_UNICODE_STRING* str)
1233
0
{
1234
0
  WINPR_ASSERT(str);
1235
0
  WINPR_ASSERT(((str->length == 0) && (str->string == nullptr)) ||
1236
0
               (str->length == _wcsnlen(str->string, str->length)));
1237
0
  RAIL_UNICODE_STRING clone = { .string = wcsndup(str->string, str->length),
1238
0
                              .length = str->length };
1239
0
  return clone;
1240
0
}
1241
1242
static void window_state_order_free(WINDOW_STATE_ORDER* order)
1243
0
{
1244
0
  if (!order)
1245
0
    return;
1246
0
  free(order->windowRects);
1247
0
  free(order->visibilityRects);
1248
0
  rail_unicode_string_free(&order->titleInfo);
1249
0
  rail_unicode_string_free(&order->OverlayDescription);
1250
1251
0
  free(order);
1252
0
}
1253
1254
static WINDOW_STATE_ORDER* window_state_order_clone(const WINDOW_STATE_ORDER* order)
1255
0
{
1256
0
  WINDOW_STATE_ORDER* clone = calloc(1, sizeof(WINDOW_STATE_ORDER));
1257
0
  if (!clone)
1258
0
    return nullptr;
1259
0
  *clone = *order;
1260
1261
0
  clone->titleInfo = rail_unicode_string_clone(&order->titleInfo);
1262
0
  clone->OverlayDescription = rail_unicode_string_clone(&order->OverlayDescription);
1263
0
  clone->windowRects = rectangles_clone(order->windowRects, order->numWindowRects);
1264
0
  clone->visibilityRects = rectangles_clone(order->visibilityRects, order->numVisibilityRects);
1265
0
  if (!clone->windowRects || !clone->visibilityRects ||
1266
0
      (!clone->titleInfo.string && (clone->titleInfo.length > 0)) ||
1267
0
      (!clone->OverlayDescription.string && (clone->OverlayDescription.length > 0)))
1268
0
  {
1269
0
    window_state_order_free(clone);
1270
0
    return nullptr;
1271
0
  }
1272
0
  return clone;
1273
0
}
1274
1275
static BOOL update_message_WindowCreate(rdpContext* context, const WINDOW_ORDER_INFO* orderInfo,
1276
                                        const WINDOW_STATE_ORDER* windowState)
1277
0
{
1278
0
  if (!context || !context->update || !orderInfo || !windowState)
1279
0
    return FALSE;
1280
1281
0
  WINDOW_ORDER_INFO* wParam = (WINDOW_ORDER_INFO*)malloc(sizeof(WINDOW_ORDER_INFO));
1282
1283
0
  if (!wParam)
1284
0
    return FALSE;
1285
1286
0
  *wParam = *orderInfo;
1287
1288
0
  WINDOW_STATE_ORDER* lParam = window_state_order_clone(windowState);
1289
1290
0
  if (!lParam)
1291
0
  {
1292
0
    free(wParam);
1293
0
    return FALSE;
1294
0
  }
1295
1296
0
  rdp_update_internal* up = update_cast(context->update);
1297
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(WindowUpdate, WindowCreate),
1298
0
                           (void*)wParam, (void*)lParam);
1299
0
}
1300
1301
static BOOL update_message_WindowUpdate(rdpContext* context, const WINDOW_ORDER_INFO* orderInfo,
1302
                                        const WINDOW_STATE_ORDER* windowState)
1303
0
{
1304
0
  if (!context || !context->update || !orderInfo || !windowState)
1305
0
    return FALSE;
1306
1307
0
  WINDOW_ORDER_INFO* wParam = (WINDOW_ORDER_INFO*)malloc(sizeof(WINDOW_ORDER_INFO));
1308
1309
0
  if (!wParam)
1310
0
    return FALSE;
1311
1312
0
  *wParam = *orderInfo;
1313
1314
0
  WINDOW_STATE_ORDER* lParam = window_state_order_clone(windowState);
1315
1316
0
  if (!lParam)
1317
0
  {
1318
0
    free(wParam);
1319
0
    return FALSE;
1320
0
  }
1321
1322
0
  rdp_update_internal* up = update_cast(context->update);
1323
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(WindowUpdate, WindowUpdate),
1324
0
                           (void*)wParam, (void*)lParam);
1325
0
}
1326
1327
static BOOL update_message_WindowIcon(rdpContext* context, const WINDOW_ORDER_INFO* orderInfo,
1328
                                      const WINDOW_ICON_ORDER* windowIcon)
1329
0
{
1330
0
  if (!context || !context->update || !orderInfo || !windowIcon)
1331
0
    return FALSE;
1332
1333
0
  WINDOW_ORDER_INFO* wParam = (WINDOW_ORDER_INFO*)malloc(sizeof(WINDOW_ORDER_INFO));
1334
1335
0
  if (!wParam)
1336
0
    return FALSE;
1337
1338
0
  *wParam = *orderInfo;
1339
1340
0
  WINDOW_ICON_ORDER* lParam = (WINDOW_ICON_ORDER*)calloc(1, sizeof(WINDOW_ICON_ORDER));
1341
1342
0
  if (!lParam)
1343
0
    goto out_fail;
1344
1345
0
  *lParam = *windowIcon;
1346
0
  lParam->iconInfo = calloc(1, sizeof(ICON_INFO));
1347
1348
0
  if (!lParam->iconInfo)
1349
0
    goto out_fail;
1350
1351
0
  *lParam->iconInfo = *windowIcon->iconInfo;
1352
1353
0
  WLog_VRB(TAG, "update_message_WindowIcon");
1354
1355
0
  if (windowIcon->iconInfo->cbBitsColor > 0)
1356
0
  {
1357
0
    lParam->iconInfo->bitsColor = (BYTE*)malloc(windowIcon->iconInfo->cbBitsColor);
1358
1359
0
    if (!lParam->iconInfo->bitsColor)
1360
0
      goto out_fail;
1361
1362
0
    CopyMemory(lParam->iconInfo->bitsColor, windowIcon->iconInfo->bitsColor,
1363
0
               windowIcon->iconInfo->cbBitsColor);
1364
0
  }
1365
1366
0
  if (windowIcon->iconInfo->cbBitsMask > 0)
1367
0
  {
1368
0
    lParam->iconInfo->bitsMask = (BYTE*)malloc(windowIcon->iconInfo->cbBitsMask);
1369
1370
0
    if (!lParam->iconInfo->bitsMask)
1371
0
      goto out_fail;
1372
1373
0
    CopyMemory(lParam->iconInfo->bitsMask, windowIcon->iconInfo->bitsMask,
1374
0
               windowIcon->iconInfo->cbBitsMask);
1375
0
  }
1376
1377
0
  if (windowIcon->iconInfo->cbColorTable > 0)
1378
0
  {
1379
0
    lParam->iconInfo->colorTable = (BYTE*)malloc(windowIcon->iconInfo->cbColorTable);
1380
1381
0
    if (!lParam->iconInfo->colorTable)
1382
0
      goto out_fail;
1383
1384
0
    CopyMemory(lParam->iconInfo->colorTable, windowIcon->iconInfo->colorTable,
1385
0
               windowIcon->iconInfo->cbColorTable);
1386
0
  }
1387
1388
0
  rdp_update_internal* up = update_cast(context->update);
1389
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(WindowUpdate, WindowIcon),
1390
0
                           (void*)wParam, (void*)lParam);
1391
0
out_fail:
1392
1393
0
  if (lParam && lParam->iconInfo)
1394
0
  {
1395
0
    free(lParam->iconInfo->bitsColor);
1396
0
    free(lParam->iconInfo->bitsMask);
1397
0
    free(lParam->iconInfo->colorTable);
1398
0
    free(lParam->iconInfo);
1399
0
  }
1400
1401
0
  free(lParam);
1402
0
  free(wParam);
1403
0
  return FALSE;
1404
0
}
1405
1406
static BOOL update_message_WindowCachedIcon(rdpContext* context, const WINDOW_ORDER_INFO* orderInfo,
1407
                                            const WINDOW_CACHED_ICON_ORDER* windowCachedIcon)
1408
0
{
1409
0
  WINDOW_ORDER_INFO* wParam = nullptr;
1410
0
  WINDOW_CACHED_ICON_ORDER* lParam = nullptr;
1411
0
  rdp_update_internal* up = nullptr;
1412
1413
0
  if (!context || !context->update || !orderInfo || !windowCachedIcon)
1414
0
    return FALSE;
1415
1416
0
  wParam = (WINDOW_ORDER_INFO*)malloc(sizeof(WINDOW_ORDER_INFO));
1417
1418
0
  if (!wParam)
1419
0
    return FALSE;
1420
1421
0
  CopyMemory(wParam, orderInfo, sizeof(WINDOW_ORDER_INFO));
1422
0
  lParam = (WINDOW_CACHED_ICON_ORDER*)malloc(sizeof(WINDOW_CACHED_ICON_ORDER));
1423
1424
0
  if (!lParam)
1425
0
  {
1426
0
    free(wParam);
1427
0
    return FALSE;
1428
0
  }
1429
1430
0
  CopyMemory(lParam, windowCachedIcon, sizeof(WINDOW_CACHED_ICON_ORDER));
1431
1432
0
  up = update_cast(context->update);
1433
0
  return MessageQueue_Post(up->queue, (void*)context,
1434
0
                           MakeMessageId(WindowUpdate, WindowCachedIcon), (void*)wParam,
1435
0
                           (void*)lParam);
1436
0
}
1437
1438
static BOOL update_message_WindowDelete(rdpContext* context, const WINDOW_ORDER_INFO* orderInfo)
1439
0
{
1440
0
  WINDOW_ORDER_INFO* wParam = nullptr;
1441
0
  rdp_update_internal* up = nullptr;
1442
1443
0
  if (!context || !context->update || !orderInfo)
1444
0
    return FALSE;
1445
1446
0
  wParam = (WINDOW_ORDER_INFO*)malloc(sizeof(WINDOW_ORDER_INFO));
1447
1448
0
  if (!wParam)
1449
0
    return FALSE;
1450
1451
0
  CopyMemory(wParam, orderInfo, sizeof(WINDOW_ORDER_INFO));
1452
1453
0
  up = update_cast(context->update);
1454
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(WindowUpdate, WindowDelete),
1455
0
                           (void*)wParam, nullptr);
1456
0
}
1457
1458
static BOOL update_message_NotifyIconCreate(rdpContext* context, const WINDOW_ORDER_INFO* orderInfo,
1459
                                            const NOTIFY_ICON_STATE_ORDER* notifyIconState)
1460
0
{
1461
0
  WINDOW_ORDER_INFO* wParam = nullptr;
1462
0
  NOTIFY_ICON_STATE_ORDER* lParam = nullptr;
1463
0
  rdp_update_internal* up = nullptr;
1464
1465
0
  if (!context || !context->update || !orderInfo || !notifyIconState)
1466
0
    return FALSE;
1467
1468
0
  wParam = (WINDOW_ORDER_INFO*)malloc(sizeof(WINDOW_ORDER_INFO));
1469
1470
0
  if (!wParam)
1471
0
    return FALSE;
1472
1473
0
  CopyMemory(wParam, orderInfo, sizeof(WINDOW_ORDER_INFO));
1474
0
  lParam = (NOTIFY_ICON_STATE_ORDER*)malloc(sizeof(NOTIFY_ICON_STATE_ORDER));
1475
1476
0
  if (!lParam)
1477
0
  {
1478
0
    free(wParam);
1479
0
    return FALSE;
1480
0
  }
1481
1482
0
  CopyMemory(lParam, notifyIconState, sizeof(NOTIFY_ICON_STATE_ORDER));
1483
1484
0
  up = update_cast(context->update);
1485
0
  return MessageQueue_Post(up->queue, (void*)context,
1486
0
                           MakeMessageId(WindowUpdate, NotifyIconCreate), (void*)wParam,
1487
0
                           (void*)lParam);
1488
0
}
1489
1490
static BOOL update_message_NotifyIconUpdate(rdpContext* context, const WINDOW_ORDER_INFO* orderInfo,
1491
                                            const NOTIFY_ICON_STATE_ORDER* notifyIconState)
1492
0
{
1493
0
  WINDOW_ORDER_INFO* wParam = nullptr;
1494
0
  NOTIFY_ICON_STATE_ORDER* lParam = nullptr;
1495
0
  rdp_update_internal* up = nullptr;
1496
1497
0
  if (!context || !context->update || !orderInfo || !notifyIconState)
1498
0
    return FALSE;
1499
1500
0
  wParam = (WINDOW_ORDER_INFO*)malloc(sizeof(WINDOW_ORDER_INFO));
1501
1502
0
  if (!wParam)
1503
0
    return FALSE;
1504
1505
0
  CopyMemory(wParam, orderInfo, sizeof(WINDOW_ORDER_INFO));
1506
0
  lParam = (NOTIFY_ICON_STATE_ORDER*)malloc(sizeof(NOTIFY_ICON_STATE_ORDER));
1507
1508
0
  if (!lParam)
1509
0
  {
1510
0
    free(wParam);
1511
0
    return FALSE;
1512
0
  }
1513
1514
0
  CopyMemory(lParam, notifyIconState, sizeof(NOTIFY_ICON_STATE_ORDER));
1515
1516
0
  up = update_cast(context->update);
1517
0
  return MessageQueue_Post(up->queue, (void*)context,
1518
0
                           MakeMessageId(WindowUpdate, NotifyIconUpdate), (void*)wParam,
1519
0
                           (void*)lParam);
1520
0
}
1521
1522
static BOOL update_message_NotifyIconDelete(rdpContext* context, const WINDOW_ORDER_INFO* orderInfo)
1523
0
{
1524
0
  WINDOW_ORDER_INFO* wParam = nullptr;
1525
0
  rdp_update_internal* up = nullptr;
1526
1527
0
  if (!context || !context->update || !orderInfo)
1528
0
    return FALSE;
1529
1530
0
  wParam = (WINDOW_ORDER_INFO*)malloc(sizeof(WINDOW_ORDER_INFO));
1531
1532
0
  if (!wParam)
1533
0
    return FALSE;
1534
1535
0
  CopyMemory(wParam, orderInfo, sizeof(WINDOW_ORDER_INFO));
1536
1537
0
  up = update_cast(context->update);
1538
0
  return MessageQueue_Post(up->queue, (void*)context,
1539
0
                           MakeMessageId(WindowUpdate, NotifyIconDelete), (void*)wParam, nullptr);
1540
0
}
1541
1542
static BOOL update_message_MonitoredDesktop(rdpContext* context, const WINDOW_ORDER_INFO* orderInfo,
1543
                                            const MONITORED_DESKTOP_ORDER* monitoredDesktop)
1544
0
{
1545
0
  WINDOW_ORDER_INFO* wParam = nullptr;
1546
0
  MONITORED_DESKTOP_ORDER* lParam = nullptr;
1547
0
  rdp_update_internal* up = nullptr;
1548
1549
0
  if (!context || !context->update || !orderInfo || !monitoredDesktop)
1550
0
    return FALSE;
1551
1552
0
  wParam = (WINDOW_ORDER_INFO*)malloc(sizeof(WINDOW_ORDER_INFO));
1553
1554
0
  if (!wParam)
1555
0
    return FALSE;
1556
1557
0
  CopyMemory(wParam, orderInfo, sizeof(WINDOW_ORDER_INFO));
1558
0
  lParam = (MONITORED_DESKTOP_ORDER*)malloc(sizeof(MONITORED_DESKTOP_ORDER));
1559
1560
0
  if (!lParam)
1561
0
  {
1562
0
    free(wParam);
1563
0
    return FALSE;
1564
0
  }
1565
1566
0
  CopyMemory(lParam, monitoredDesktop, sizeof(MONITORED_DESKTOP_ORDER));
1567
0
  lParam->windowIds = nullptr;
1568
1569
0
  if (lParam->numWindowIds)
1570
0
  {
1571
0
    lParam->windowIds = (UINT32*)calloc(lParam->numWindowIds, sizeof(UINT32));
1572
0
    CopyMemory(lParam->windowIds, monitoredDesktop->windowIds, lParam->numWindowIds);
1573
0
  }
1574
1575
0
  up = update_cast(context->update);
1576
0
  return MessageQueue_Post(up->queue, (void*)context,
1577
0
                           MakeMessageId(WindowUpdate, MonitoredDesktop), (void*)wParam,
1578
0
                           (void*)lParam);
1579
0
}
1580
1581
static BOOL update_message_NonMonitoredDesktop(rdpContext* context,
1582
                                               const WINDOW_ORDER_INFO* orderInfo)
1583
0
{
1584
0
  WINDOW_ORDER_INFO* wParam = nullptr;
1585
0
  rdp_update_internal* up = nullptr;
1586
1587
0
  if (!context || !context->update || !orderInfo)
1588
0
    return FALSE;
1589
1590
0
  wParam = (WINDOW_ORDER_INFO*)malloc(sizeof(WINDOW_ORDER_INFO));
1591
1592
0
  if (!wParam)
1593
0
    return FALSE;
1594
1595
0
  CopyMemory(wParam, orderInfo, sizeof(WINDOW_ORDER_INFO));
1596
1597
0
  up = update_cast(context->update);
1598
0
  return MessageQueue_Post(up->queue, (void*)context,
1599
0
                           MakeMessageId(WindowUpdate, NonMonitoredDesktop), (void*)wParam,
1600
0
                           nullptr);
1601
0
}
1602
1603
/* Pointer Update */
1604
1605
static BOOL update_message_PointerPosition(rdpContext* context,
1606
                                           const POINTER_POSITION_UPDATE* pointerPosition)
1607
0
{
1608
0
  POINTER_POSITION_UPDATE* wParam = nullptr;
1609
0
  rdp_update_internal* up = nullptr;
1610
1611
0
  if (!context || !context->update || !pointerPosition)
1612
0
    return FALSE;
1613
1614
0
  wParam = copy_pointer_position_update(context, pointerPosition);
1615
1616
0
  if (!wParam)
1617
0
    return FALSE;
1618
1619
0
  up = update_cast(context->update);
1620
0
  return MessageQueue_Post(up->queue, (void*)context,
1621
0
                           MakeMessageId(PointerUpdate, PointerPosition), (void*)wParam, nullptr);
1622
0
}
1623
1624
static BOOL update_message_PointerSystem(rdpContext* context,
1625
                                         const POINTER_SYSTEM_UPDATE* pointerSystem)
1626
0
{
1627
0
  POINTER_SYSTEM_UPDATE* wParam = nullptr;
1628
0
  rdp_update_internal* up = nullptr;
1629
1630
0
  if (!context || !context->update || !pointerSystem)
1631
0
    return FALSE;
1632
1633
0
  wParam = copy_pointer_system_update(context, pointerSystem);
1634
1635
0
  if (!wParam)
1636
0
    return FALSE;
1637
1638
0
  up = update_cast(context->update);
1639
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(PointerUpdate, PointerSystem),
1640
0
                           (void*)wParam, nullptr);
1641
0
}
1642
1643
static BOOL update_message_PointerColor(rdpContext* context,
1644
                                        const POINTER_COLOR_UPDATE* pointerColor)
1645
0
{
1646
0
  POINTER_COLOR_UPDATE* wParam = nullptr;
1647
0
  rdp_update_internal* up = nullptr;
1648
1649
0
  if (!context || !context->update || !pointerColor)
1650
0
    return FALSE;
1651
1652
0
  wParam = copy_pointer_color_update(context, pointerColor);
1653
1654
0
  if (!wParam)
1655
0
    return FALSE;
1656
1657
0
  up = update_cast(context->update);
1658
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(PointerUpdate, PointerColor),
1659
0
                           (void*)wParam, nullptr);
1660
0
}
1661
1662
static BOOL update_message_PointerLarge(rdpContext* context, const POINTER_LARGE_UPDATE* pointer)
1663
0
{
1664
0
  POINTER_LARGE_UPDATE* wParam = nullptr;
1665
0
  rdp_update_internal* up = nullptr;
1666
1667
0
  if (!context || !context->update || !pointer)
1668
0
    return FALSE;
1669
1670
0
  wParam = copy_pointer_large_update(context, pointer);
1671
1672
0
  if (!wParam)
1673
0
    return FALSE;
1674
1675
0
  up = update_cast(context->update);
1676
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(PointerUpdate, PointerLarge),
1677
0
                           (void*)wParam, nullptr);
1678
0
}
1679
1680
static BOOL update_message_PointerNew(rdpContext* context, const POINTER_NEW_UPDATE* pointerNew)
1681
0
{
1682
0
  POINTER_NEW_UPDATE* wParam = nullptr;
1683
0
  rdp_update_internal* up = nullptr;
1684
1685
0
  if (!context || !context->update || !pointerNew)
1686
0
    return FALSE;
1687
1688
0
  wParam = copy_pointer_new_update(context, pointerNew);
1689
1690
0
  if (!wParam)
1691
0
    return FALSE;
1692
1693
0
  up = update_cast(context->update);
1694
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(PointerUpdate, PointerNew),
1695
0
                           (void*)wParam, nullptr);
1696
0
}
1697
1698
static BOOL update_message_PointerCached(rdpContext* context,
1699
                                         const POINTER_CACHED_UPDATE* pointerCached)
1700
0
{
1701
0
  POINTER_CACHED_UPDATE* wParam = nullptr;
1702
0
  rdp_update_internal* up = nullptr;
1703
1704
0
  if (!context || !context->update || !pointerCached)
1705
0
    return FALSE;
1706
1707
0
  wParam = copy_pointer_cached_update(context, pointerCached);
1708
1709
0
  if (!wParam)
1710
0
    return FALSE;
1711
1712
0
  up = update_cast(context->update);
1713
0
  return MessageQueue_Post(up->queue, (void*)context, MakeMessageId(PointerUpdate, PointerCached),
1714
0
                           (void*)wParam, nullptr);
1715
0
}
1716
1717
/* Message Queue */
1718
static BOOL update_message_free_update_class(wMessage* msg, int type)
1719
0
{
1720
0
  rdpContext* context = nullptr;
1721
1722
0
  if (!msg)
1723
0
    return FALSE;
1724
1725
0
  context = (rdpContext*)msg->context;
1726
1727
0
  switch (type)
1728
0
  {
1729
0
    case Update_BeginPaint:
1730
0
      break;
1731
1732
0
    case Update_EndPaint:
1733
0
      break;
1734
1735
0
    case Update_SetBounds:
1736
0
      free(msg->wParam);
1737
0
      break;
1738
1739
0
    case Update_Synchronize:
1740
0
      break;
1741
1742
0
    case Update_DesktopResize:
1743
0
      break;
1744
1745
0
    case Update_BitmapUpdate:
1746
0
    {
1747
0
      BITMAP_UPDATE* wParam = (BITMAP_UPDATE*)msg->wParam;
1748
0
      free_bitmap_update(context, wParam);
1749
0
    }
1750
0
    break;
1751
1752
0
    case Update_Palette:
1753
0
    {
1754
0
      PALETTE_UPDATE* palette = (PALETTE_UPDATE*)msg->wParam;
1755
0
      free_palette_update(context, palette);
1756
0
    }
1757
0
    break;
1758
1759
0
    case Update_PlaySound:
1760
0
      free(msg->wParam);
1761
0
      break;
1762
1763
0
    case Update_RefreshRect:
1764
0
      free(msg->lParam);
1765
0
      break;
1766
1767
0
    case Update_SuppressOutput:
1768
0
      free(msg->lParam);
1769
0
      break;
1770
1771
0
    case Update_SurfaceCommand:
1772
0
    {
1773
0
      wStream* s = (wStream*)msg->wParam;
1774
0
      Stream_Free(s, TRUE);
1775
0
    }
1776
0
    break;
1777
1778
0
    case Update_SurfaceBits:
1779
0
    {
1780
0
      SURFACE_BITS_COMMAND* wParam = (SURFACE_BITS_COMMAND*)msg->wParam;
1781
0
      free_surface_bits_command(context, wParam);
1782
0
    }
1783
0
    break;
1784
1785
0
    case Update_SurfaceFrameMarker:
1786
0
      free(msg->wParam);
1787
0
      break;
1788
1789
0
    case Update_SurfaceFrameAcknowledge:
1790
0
    case Update_SetKeyboardIndicators:
1791
0
    case Update_SetKeyboardImeStatus:
1792
0
      break;
1793
1794
0
    default:
1795
0
      return FALSE;
1796
0
  }
1797
1798
0
  return TRUE;
1799
0
}
1800
1801
static BOOL update_message_process_update_class(rdpUpdateProxy* proxy, wMessage* msg, int type)
1802
0
{
1803
0
  BOOL rc = FALSE;
1804
1805
0
  if (!proxy || !msg)
1806
0
    return FALSE;
1807
1808
0
  switch (type)
1809
0
  {
1810
0
    case Update_BeginPaint:
1811
0
      rc = IFCALLRESULT(TRUE, proxy->BeginPaint, msg->context);
1812
0
      break;
1813
1814
0
    case Update_EndPaint:
1815
0
      rc = IFCALLRESULT(TRUE, proxy->EndPaint, msg->context);
1816
0
      break;
1817
1818
0
    case Update_SetBounds:
1819
0
      rc = IFCALLRESULT(TRUE, proxy->SetBounds, msg->context, (rdpBounds*)msg->wParam);
1820
0
      break;
1821
1822
0
    case Update_Synchronize:
1823
0
      rc = IFCALLRESULT(TRUE, proxy->Synchronize, msg->context);
1824
0
      break;
1825
1826
0
    case Update_DesktopResize:
1827
0
      rc = IFCALLRESULT(TRUE, proxy->DesktopResize, msg->context);
1828
0
      break;
1829
1830
0
    case Update_BitmapUpdate:
1831
0
      rc = IFCALLRESULT(TRUE, proxy->BitmapUpdate, msg->context, (BITMAP_UPDATE*)msg->wParam);
1832
0
      break;
1833
1834
0
    case Update_Palette:
1835
0
      rc = IFCALLRESULT(TRUE, proxy->Palette, msg->context, (PALETTE_UPDATE*)msg->wParam);
1836
0
      break;
1837
1838
0
    case Update_PlaySound:
1839
0
      rc =
1840
0
          IFCALLRESULT(TRUE, proxy->PlaySound, msg->context, (PLAY_SOUND_UPDATE*)msg->wParam);
1841
0
      break;
1842
1843
0
    case Update_RefreshRect:
1844
0
      rc = IFCALLRESULT(TRUE, proxy->RefreshRect, msg->context, (BYTE)(size_t)msg->wParam,
1845
0
                        (RECTANGLE_16*)msg->lParam);
1846
0
      break;
1847
1848
0
    case Update_SuppressOutput:
1849
0
      rc = IFCALLRESULT(TRUE, proxy->SuppressOutput, msg->context, (BYTE)(size_t)msg->wParam,
1850
0
                        (RECTANGLE_16*)msg->lParam);
1851
0
      break;
1852
1853
0
    case Update_SurfaceCommand:
1854
0
      rc = IFCALLRESULT(TRUE, proxy->SurfaceCommand, msg->context, (wStream*)msg->wParam);
1855
0
      break;
1856
1857
0
    case Update_SurfaceBits:
1858
0
      rc = IFCALLRESULT(TRUE, proxy->SurfaceBits, msg->context,
1859
0
                        (SURFACE_BITS_COMMAND*)msg->wParam);
1860
0
      break;
1861
1862
0
    case Update_SurfaceFrameMarker:
1863
0
      rc = IFCALLRESULT(TRUE, proxy->SurfaceFrameMarker, msg->context,
1864
0
                        (SURFACE_FRAME_MARKER*)msg->wParam);
1865
0
      break;
1866
1867
0
    case Update_SurfaceFrameAcknowledge:
1868
0
      rc = IFCALLRESULT(TRUE, proxy->SurfaceFrameAcknowledge, msg->context,
1869
0
                        (UINT32)(size_t)msg->wParam);
1870
0
      break;
1871
1872
0
    case Update_SetKeyboardIndicators:
1873
0
      rc = IFCALLRESULT(TRUE, proxy->SetKeyboardIndicators, msg->context,
1874
0
                        (UINT16)(size_t)msg->wParam);
1875
0
      break;
1876
1877
0
    case Update_SetKeyboardImeStatus:
1878
0
    {
1879
0
      const UINT16 imeId = ((size_t)msg->wParam) >> 16 & 0xFFFF;
1880
0
      const UINT32 imeState = ((size_t)msg->wParam) & 0xFFFF;
1881
0
      const UINT32 imeConvMode = ((size_t)msg->lParam) & 0xFFFFFFFFUL;
1882
0
      rc = IFCALLRESULT(TRUE, proxy->SetKeyboardImeStatus, msg->context, imeId, imeState,
1883
0
                        imeConvMode);
1884
0
    }
1885
0
    break;
1886
1887
0
    default:
1888
0
      break;
1889
0
  }
1890
1891
0
  return rc;
1892
0
}
1893
1894
static BOOL update_message_free_primary_update_class(wMessage* msg, int type)
1895
0
{
1896
0
  if (!msg)
1897
0
    return FALSE;
1898
1899
0
  switch (type)
1900
0
  {
1901
0
    case PrimaryUpdate_DstBlt:
1902
0
      free(msg->wParam);
1903
0
      break;
1904
1905
0
    case PrimaryUpdate_PatBlt:
1906
0
      free(msg->wParam);
1907
0
      break;
1908
1909
0
    case PrimaryUpdate_ScrBlt:
1910
0
      free(msg->wParam);
1911
0
      break;
1912
1913
0
    case PrimaryUpdate_OpaqueRect:
1914
0
      free(msg->wParam);
1915
0
      break;
1916
1917
0
    case PrimaryUpdate_DrawNineGrid:
1918
0
      free(msg->wParam);
1919
0
      break;
1920
1921
0
    case PrimaryUpdate_MultiDstBlt:
1922
0
      free(msg->wParam);
1923
0
      break;
1924
1925
0
    case PrimaryUpdate_MultiPatBlt:
1926
0
      free(msg->wParam);
1927
0
      break;
1928
1929
0
    case PrimaryUpdate_MultiScrBlt:
1930
0
      free(msg->wParam);
1931
0
      break;
1932
1933
0
    case PrimaryUpdate_MultiOpaqueRect:
1934
0
      free(msg->wParam);
1935
0
      break;
1936
1937
0
    case PrimaryUpdate_MultiDrawNineGrid:
1938
0
      free(msg->wParam);
1939
0
      break;
1940
1941
0
    case PrimaryUpdate_LineTo:
1942
0
      free(msg->wParam);
1943
0
      break;
1944
1945
0
    case PrimaryUpdate_Polyline:
1946
0
    {
1947
0
      POLYLINE_ORDER* wParam = (POLYLINE_ORDER*)msg->wParam;
1948
0
      free(wParam->points);
1949
0
      free(wParam);
1950
0
    }
1951
0
    break;
1952
1953
0
    case PrimaryUpdate_MemBlt:
1954
0
      free(msg->wParam);
1955
0
      break;
1956
1957
0
    case PrimaryUpdate_Mem3Blt:
1958
0
      free(msg->wParam);
1959
0
      break;
1960
1961
0
    case PrimaryUpdate_SaveBitmap:
1962
0
      free(msg->wParam);
1963
0
      break;
1964
1965
0
    case PrimaryUpdate_GlyphIndex:
1966
0
      free(msg->wParam);
1967
0
      break;
1968
1969
0
    case PrimaryUpdate_FastIndex:
1970
0
      free(msg->wParam);
1971
0
      break;
1972
1973
0
    case PrimaryUpdate_FastGlyph:
1974
0
    {
1975
0
      FAST_GLYPH_ORDER* wParam = (FAST_GLYPH_ORDER*)msg->wParam;
1976
0
      free(wParam->glyphData.aj);
1977
0
      free(wParam);
1978
0
    }
1979
0
    break;
1980
1981
0
    case PrimaryUpdate_PolygonSC:
1982
0
    {
1983
0
      POLYGON_SC_ORDER* wParam = (POLYGON_SC_ORDER*)msg->wParam;
1984
0
      free(wParam->points);
1985
0
      free(wParam);
1986
0
    }
1987
0
    break;
1988
1989
0
    case PrimaryUpdate_PolygonCB:
1990
0
    {
1991
0
      POLYGON_CB_ORDER* wParam = (POLYGON_CB_ORDER*)msg->wParam;
1992
0
      free(wParam->points);
1993
0
      free(wParam);
1994
0
    }
1995
0
    break;
1996
1997
0
    case PrimaryUpdate_EllipseSC:
1998
0
      free(msg->wParam);
1999
0
      break;
2000
2001
0
    case PrimaryUpdate_EllipseCB:
2002
0
      free(msg->wParam);
2003
0
      break;
2004
2005
0
    default:
2006
0
      return FALSE;
2007
0
  }
2008
2009
0
  return TRUE;
2010
0
}
2011
2012
static BOOL update_message_process_primary_update_class(rdpUpdateProxy* proxy, wMessage* msg,
2013
                                                        int type)
2014
0
{
2015
0
  if (!proxy || !msg)
2016
0
    return FALSE;
2017
2018
0
  switch (type)
2019
0
  {
2020
0
    case PrimaryUpdate_DstBlt:
2021
0
      return IFCALLRESULT(TRUE, proxy->DstBlt, msg->context, (DSTBLT_ORDER*)msg->wParam);
2022
2023
0
    case PrimaryUpdate_PatBlt:
2024
0
      return IFCALLRESULT(TRUE, proxy->PatBlt, msg->context, (PATBLT_ORDER*)msg->wParam);
2025
2026
0
    case PrimaryUpdate_ScrBlt:
2027
0
      return IFCALLRESULT(TRUE, proxy->ScrBlt, msg->context, (SCRBLT_ORDER*)msg->wParam);
2028
2029
0
    case PrimaryUpdate_OpaqueRect:
2030
0
      return IFCALLRESULT(TRUE, proxy->OpaqueRect, msg->context,
2031
0
                          (OPAQUE_RECT_ORDER*)msg->wParam);
2032
2033
0
    case PrimaryUpdate_DrawNineGrid:
2034
0
      return IFCALLRESULT(TRUE, proxy->DrawNineGrid, msg->context,
2035
0
                          (DRAW_NINE_GRID_ORDER*)msg->wParam);
2036
2037
0
    case PrimaryUpdate_MultiDstBlt:
2038
0
      return IFCALLRESULT(TRUE, proxy->MultiDstBlt, msg->context,
2039
0
                          (MULTI_DSTBLT_ORDER*)msg->wParam);
2040
2041
0
    case PrimaryUpdate_MultiPatBlt:
2042
0
      return IFCALLRESULT(TRUE, proxy->MultiPatBlt, msg->context,
2043
0
                          (MULTI_PATBLT_ORDER*)msg->wParam);
2044
2045
0
    case PrimaryUpdate_MultiScrBlt:
2046
0
      return IFCALLRESULT(TRUE, proxy->MultiScrBlt, msg->context,
2047
0
                          (MULTI_SCRBLT_ORDER*)msg->wParam);
2048
2049
0
    case PrimaryUpdate_MultiOpaqueRect:
2050
0
      return IFCALLRESULT(TRUE, proxy->MultiOpaqueRect, msg->context,
2051
0
                          (MULTI_OPAQUE_RECT_ORDER*)msg->wParam);
2052
2053
0
    case PrimaryUpdate_MultiDrawNineGrid:
2054
0
      return IFCALLRESULT(TRUE, proxy->MultiDrawNineGrid, msg->context,
2055
0
                          (MULTI_DRAW_NINE_GRID_ORDER*)msg->wParam);
2056
2057
0
    case PrimaryUpdate_LineTo:
2058
0
      return IFCALLRESULT(TRUE, proxy->LineTo, msg->context, (LINE_TO_ORDER*)msg->wParam);
2059
2060
0
    case PrimaryUpdate_Polyline:
2061
0
      return IFCALLRESULT(TRUE, proxy->Polyline, msg->context, (POLYLINE_ORDER*)msg->wParam);
2062
2063
0
    case PrimaryUpdate_MemBlt:
2064
0
      return IFCALLRESULT(TRUE, proxy->MemBlt, msg->context, (MEMBLT_ORDER*)msg->wParam);
2065
2066
0
    case PrimaryUpdate_Mem3Blt:
2067
0
      return IFCALLRESULT(TRUE, proxy->Mem3Blt, msg->context, (MEM3BLT_ORDER*)msg->wParam);
2068
2069
0
    case PrimaryUpdate_SaveBitmap:
2070
0
      return IFCALLRESULT(TRUE, proxy->SaveBitmap, msg->context,
2071
0
                          (SAVE_BITMAP_ORDER*)msg->wParam);
2072
2073
0
    case PrimaryUpdate_GlyphIndex:
2074
0
      return IFCALLRESULT(TRUE, proxy->GlyphIndex, msg->context,
2075
0
                          (GLYPH_INDEX_ORDER*)msg->wParam);
2076
2077
0
    case PrimaryUpdate_FastIndex:
2078
0
      return IFCALLRESULT(TRUE, proxy->FastIndex, msg->context,
2079
0
                          (FAST_INDEX_ORDER*)msg->wParam);
2080
2081
0
    case PrimaryUpdate_FastGlyph:
2082
0
      return IFCALLRESULT(TRUE, proxy->FastGlyph, msg->context,
2083
0
                          (FAST_GLYPH_ORDER*)msg->wParam);
2084
2085
0
    case PrimaryUpdate_PolygonSC:
2086
0
      return IFCALLRESULT(TRUE, proxy->PolygonSC, msg->context,
2087
0
                          (POLYGON_SC_ORDER*)msg->wParam);
2088
2089
0
    case PrimaryUpdate_PolygonCB:
2090
0
      return IFCALLRESULT(TRUE, proxy->PolygonCB, msg->context,
2091
0
                          (POLYGON_CB_ORDER*)msg->wParam);
2092
2093
0
    case PrimaryUpdate_EllipseSC:
2094
0
      return IFCALLRESULT(TRUE, proxy->EllipseSC, msg->context,
2095
0
                          (ELLIPSE_SC_ORDER*)msg->wParam);
2096
2097
0
    case PrimaryUpdate_EllipseCB:
2098
0
      return IFCALLRESULT(TRUE, proxy->EllipseCB, msg->context,
2099
0
                          (ELLIPSE_CB_ORDER*)msg->wParam);
2100
2101
0
    default:
2102
0
      return FALSE;
2103
0
  }
2104
0
}
2105
2106
static BOOL update_message_free_secondary_update_class(wMessage* msg, int type)
2107
0
{
2108
0
  rdpContext* context = nullptr;
2109
2110
0
  if (!msg)
2111
0
    return FALSE;
2112
2113
0
  context = msg->context;
2114
2115
0
  switch (type)
2116
0
  {
2117
0
    case SecondaryUpdate_CacheBitmap:
2118
0
    {
2119
0
      CACHE_BITMAP_ORDER* wParam = (CACHE_BITMAP_ORDER*)msg->wParam;
2120
0
      free_cache_bitmap_order(context, wParam);
2121
0
    }
2122
0
    break;
2123
2124
0
    case SecondaryUpdate_CacheBitmapV2:
2125
0
    {
2126
0
      CACHE_BITMAP_V2_ORDER* wParam = (CACHE_BITMAP_V2_ORDER*)msg->wParam;
2127
0
      free_cache_bitmap_v2_order(context, wParam);
2128
0
    }
2129
0
    break;
2130
2131
0
    case SecondaryUpdate_CacheBitmapV3:
2132
0
    {
2133
0
      CACHE_BITMAP_V3_ORDER* wParam = (CACHE_BITMAP_V3_ORDER*)msg->wParam;
2134
0
      free_cache_bitmap_v3_order(context, wParam);
2135
0
    }
2136
0
    break;
2137
2138
0
    case SecondaryUpdate_CacheColorTable:
2139
0
    {
2140
0
      CACHE_COLOR_TABLE_ORDER* wParam = (CACHE_COLOR_TABLE_ORDER*)msg->wParam;
2141
0
      free_cache_color_table_order(context, wParam);
2142
0
    }
2143
0
    break;
2144
2145
0
    case SecondaryUpdate_CacheGlyph:
2146
0
    {
2147
0
      CACHE_GLYPH_ORDER* wParam = (CACHE_GLYPH_ORDER*)msg->wParam;
2148
0
      free_cache_glyph_order(context, wParam);
2149
0
    }
2150
0
    break;
2151
2152
0
    case SecondaryUpdate_CacheGlyphV2:
2153
0
    {
2154
0
      CACHE_GLYPH_V2_ORDER* wParam = (CACHE_GLYPH_V2_ORDER*)msg->wParam;
2155
0
      free_cache_glyph_v2_order(context, wParam);
2156
0
    }
2157
0
    break;
2158
2159
0
    case SecondaryUpdate_CacheBrush:
2160
0
    {
2161
0
      CACHE_BRUSH_ORDER* wParam = (CACHE_BRUSH_ORDER*)msg->wParam;
2162
0
      free_cache_brush_order(context, wParam);
2163
0
    }
2164
0
    break;
2165
2166
0
    default:
2167
0
      return FALSE;
2168
0
  }
2169
2170
0
  return TRUE;
2171
0
}
2172
2173
static BOOL update_message_process_secondary_update_class(rdpUpdateProxy* proxy, wMessage* msg,
2174
                                                          int type)
2175
0
{
2176
0
  if (!proxy || !msg)
2177
0
    return FALSE;
2178
2179
0
  switch (type)
2180
0
  {
2181
0
    case SecondaryUpdate_CacheBitmap:
2182
0
      return IFCALLRESULT(TRUE, proxy->CacheBitmap, msg->context,
2183
0
                          (CACHE_BITMAP_ORDER*)msg->wParam);
2184
2185
0
    case SecondaryUpdate_CacheBitmapV2:
2186
0
      return IFCALLRESULT(TRUE, proxy->CacheBitmapV2, msg->context,
2187
0
                          (CACHE_BITMAP_V2_ORDER*)msg->wParam);
2188
2189
0
    case SecondaryUpdate_CacheBitmapV3:
2190
0
      return IFCALLRESULT(TRUE, proxy->CacheBitmapV3, msg->context,
2191
0
                          (CACHE_BITMAP_V3_ORDER*)msg->wParam);
2192
2193
0
    case SecondaryUpdate_CacheColorTable:
2194
0
      return IFCALLRESULT(TRUE, proxy->CacheColorTable, msg->context,
2195
0
                          (CACHE_COLOR_TABLE_ORDER*)msg->wParam);
2196
2197
0
    case SecondaryUpdate_CacheGlyph:
2198
0
      return IFCALLRESULT(TRUE, proxy->CacheGlyph, msg->context,
2199
0
                          (CACHE_GLYPH_ORDER*)msg->wParam);
2200
2201
0
    case SecondaryUpdate_CacheGlyphV2:
2202
0
      return IFCALLRESULT(TRUE, proxy->CacheGlyphV2, msg->context,
2203
0
                          (CACHE_GLYPH_V2_ORDER*)msg->wParam);
2204
2205
0
    case SecondaryUpdate_CacheBrush:
2206
0
      return IFCALLRESULT(TRUE, proxy->CacheBrush, msg->context,
2207
0
                          (CACHE_BRUSH_ORDER*)msg->wParam);
2208
2209
0
    default:
2210
0
      return FALSE;
2211
0
  }
2212
0
}
2213
2214
static BOOL update_message_free_altsec_update_class(wMessage* msg, int type)
2215
0
{
2216
0
  if (!msg)
2217
0
    return FALSE;
2218
2219
0
  switch (type)
2220
0
  {
2221
0
    case AltSecUpdate_CreateOffscreenBitmap:
2222
0
    {
2223
0
      CREATE_OFFSCREEN_BITMAP_ORDER* wParam = (CREATE_OFFSCREEN_BITMAP_ORDER*)msg->wParam;
2224
0
      free(wParam->deleteList.indices);
2225
0
      free(wParam);
2226
0
    }
2227
0
    break;
2228
2229
0
    case AltSecUpdate_SwitchSurface:
2230
0
      free(msg->wParam);
2231
0
      break;
2232
2233
0
    case AltSecUpdate_CreateNineGridBitmap:
2234
0
      free(msg->wParam);
2235
0
      break;
2236
2237
0
    case AltSecUpdate_FrameMarker:
2238
0
      free(msg->wParam);
2239
0
      break;
2240
2241
0
    case AltSecUpdate_StreamBitmapFirst:
2242
0
      free(msg->wParam);
2243
0
      break;
2244
2245
0
    case AltSecUpdate_StreamBitmapNext:
2246
0
      free(msg->wParam);
2247
0
      break;
2248
2249
0
    case AltSecUpdate_DrawGdiPlusFirst:
2250
0
      free(msg->wParam);
2251
0
      break;
2252
2253
0
    case AltSecUpdate_DrawGdiPlusNext:
2254
0
      free(msg->wParam);
2255
0
      break;
2256
2257
0
    case AltSecUpdate_DrawGdiPlusEnd:
2258
0
      free(msg->wParam);
2259
0
      break;
2260
2261
0
    case AltSecUpdate_DrawGdiPlusCacheFirst:
2262
0
      free(msg->wParam);
2263
0
      break;
2264
2265
0
    case AltSecUpdate_DrawGdiPlusCacheNext:
2266
0
      free(msg->wParam);
2267
0
      break;
2268
2269
0
    case AltSecUpdate_DrawGdiPlusCacheEnd:
2270
0
      free(msg->wParam);
2271
0
      break;
2272
2273
0
    default:
2274
0
      return FALSE;
2275
0
  }
2276
2277
0
  return TRUE;
2278
0
}
2279
2280
static BOOL update_message_process_altsec_update_class(rdpUpdateProxy* proxy, wMessage* msg,
2281
                                                       int type)
2282
0
{
2283
0
  if (!proxy || !msg)
2284
0
    return FALSE;
2285
2286
0
  switch (type)
2287
0
  {
2288
0
    case AltSecUpdate_CreateOffscreenBitmap:
2289
0
      return IFCALLRESULT(TRUE, proxy->CreateOffscreenBitmap, msg->context,
2290
0
                          (CREATE_OFFSCREEN_BITMAP_ORDER*)msg->wParam);
2291
2292
0
    case AltSecUpdate_SwitchSurface:
2293
0
      return IFCALLRESULT(TRUE, proxy->SwitchSurface, msg->context,
2294
0
                          (SWITCH_SURFACE_ORDER*)msg->wParam);
2295
2296
0
    case AltSecUpdate_CreateNineGridBitmap:
2297
0
      return IFCALLRESULT(TRUE, proxy->CreateNineGridBitmap, msg->context,
2298
0
                          (CREATE_NINE_GRID_BITMAP_ORDER*)msg->wParam);
2299
2300
0
    case AltSecUpdate_FrameMarker:
2301
0
      return IFCALLRESULT(TRUE, proxy->FrameMarker, msg->context,
2302
0
                          (FRAME_MARKER_ORDER*)msg->wParam);
2303
2304
0
    case AltSecUpdate_StreamBitmapFirst:
2305
0
      return IFCALLRESULT(TRUE, proxy->StreamBitmapFirst, msg->context,
2306
0
                          (STREAM_BITMAP_FIRST_ORDER*)msg->wParam);
2307
2308
0
    case AltSecUpdate_StreamBitmapNext:
2309
0
      return IFCALLRESULT(TRUE, proxy->StreamBitmapNext, msg->context,
2310
0
                          (STREAM_BITMAP_NEXT_ORDER*)msg->wParam);
2311
2312
0
    case AltSecUpdate_DrawGdiPlusFirst:
2313
0
      return IFCALLRESULT(TRUE, proxy->DrawGdiPlusFirst, msg->context,
2314
0
                          (DRAW_GDIPLUS_FIRST_ORDER*)msg->wParam);
2315
2316
0
    case AltSecUpdate_DrawGdiPlusNext:
2317
0
      return IFCALLRESULT(TRUE, proxy->DrawGdiPlusNext, msg->context,
2318
0
                          (DRAW_GDIPLUS_NEXT_ORDER*)msg->wParam);
2319
2320
0
    case AltSecUpdate_DrawGdiPlusEnd:
2321
0
      return IFCALLRESULT(TRUE, proxy->DrawGdiPlusEnd, msg->context,
2322
0
                          (DRAW_GDIPLUS_END_ORDER*)msg->wParam);
2323
2324
0
    case AltSecUpdate_DrawGdiPlusCacheFirst:
2325
0
      return IFCALLRESULT(TRUE, proxy->DrawGdiPlusCacheFirst, msg->context,
2326
0
                          (DRAW_GDIPLUS_CACHE_FIRST_ORDER*)msg->wParam);
2327
2328
0
    case AltSecUpdate_DrawGdiPlusCacheNext:
2329
0
      return IFCALLRESULT(TRUE, proxy->DrawGdiPlusCacheNext, msg->context,
2330
0
                          (DRAW_GDIPLUS_CACHE_NEXT_ORDER*)msg->wParam);
2331
2332
0
    case AltSecUpdate_DrawGdiPlusCacheEnd:
2333
0
      return IFCALLRESULT(TRUE, proxy->DrawGdiPlusCacheEnd, msg->context,
2334
0
                          (DRAW_GDIPLUS_CACHE_END_ORDER*)msg->wParam);
2335
2336
0
    default:
2337
0
      return FALSE;
2338
0
  }
2339
0
}
2340
2341
static BOOL update_message_free_window_update_class(wMessage* msg, int type)
2342
0
{
2343
0
  if (!msg)
2344
0
    return FALSE;
2345
2346
0
  switch (type)
2347
0
  {
2348
0
    case WindowUpdate_WindowCreate:
2349
0
      free(msg->wParam);
2350
0
      window_state_order_free(msg->lParam);
2351
0
      break;
2352
2353
0
    case WindowUpdate_WindowUpdate:
2354
0
      free(msg->wParam);
2355
0
      window_state_order_free(msg->lParam);
2356
0
      break;
2357
2358
0
    case WindowUpdate_WindowIcon:
2359
0
    {
2360
0
      WINDOW_ORDER_INFO* orderInfo = (WINDOW_ORDER_INFO*)msg->wParam;
2361
0
      WINDOW_ICON_ORDER* windowIcon = (WINDOW_ICON_ORDER*)msg->lParam;
2362
2363
0
      if (windowIcon->iconInfo->cbBitsColor > 0)
2364
0
      {
2365
0
        free(windowIcon->iconInfo->bitsColor);
2366
0
      }
2367
2368
0
      if (windowIcon->iconInfo->cbBitsMask > 0)
2369
0
      {
2370
0
        free(windowIcon->iconInfo->bitsMask);
2371
0
      }
2372
2373
0
      if (windowIcon->iconInfo->cbColorTable > 0)
2374
0
      {
2375
0
        free(windowIcon->iconInfo->colorTable);
2376
0
      }
2377
2378
0
      free(orderInfo);
2379
0
      free(windowIcon->iconInfo);
2380
0
      free(windowIcon);
2381
0
    }
2382
0
    break;
2383
2384
0
    case WindowUpdate_WindowCachedIcon:
2385
0
      free(msg->wParam);
2386
0
      free(msg->lParam);
2387
0
      break;
2388
2389
0
    case WindowUpdate_WindowDelete:
2390
0
      free(msg->wParam);
2391
0
      break;
2392
2393
0
    case WindowUpdate_NotifyIconCreate:
2394
0
      free(msg->wParam);
2395
0
      free(msg->lParam);
2396
0
      break;
2397
2398
0
    case WindowUpdate_NotifyIconUpdate:
2399
0
      free(msg->wParam);
2400
0
      free(msg->lParam);
2401
0
      break;
2402
2403
0
    case WindowUpdate_NotifyIconDelete:
2404
0
      free(msg->wParam);
2405
0
      break;
2406
2407
0
    case WindowUpdate_MonitoredDesktop:
2408
0
    {
2409
0
      MONITORED_DESKTOP_ORDER* lParam = (MONITORED_DESKTOP_ORDER*)msg->lParam;
2410
0
      free(msg->wParam);
2411
0
      free(lParam->windowIds);
2412
0
      free(lParam);
2413
0
    }
2414
0
    break;
2415
2416
0
    case WindowUpdate_NonMonitoredDesktop:
2417
0
      free(msg->wParam);
2418
0
      break;
2419
2420
0
    default:
2421
0
      return FALSE;
2422
0
  }
2423
2424
0
  return TRUE;
2425
0
}
2426
2427
static BOOL update_message_process_window_update_class(rdpUpdateProxy* proxy, wMessage* msg,
2428
                                                       int type)
2429
0
{
2430
0
  if (!proxy || !msg)
2431
0
    return FALSE;
2432
2433
0
  switch (type)
2434
0
  {
2435
0
    case WindowUpdate_WindowCreate:
2436
0
      return IFCALLRESULT(TRUE, proxy->WindowCreate, msg->context,
2437
0
                          (WINDOW_ORDER_INFO*)msg->wParam, (WINDOW_STATE_ORDER*)msg->lParam);
2438
2439
0
    case WindowUpdate_WindowUpdate:
2440
0
      return IFCALLRESULT(TRUE, proxy->WindowCreate, msg->context,
2441
0
                          (WINDOW_ORDER_INFO*)msg->wParam, (WINDOW_STATE_ORDER*)msg->lParam);
2442
2443
0
    case WindowUpdate_WindowIcon:
2444
0
    {
2445
0
      WINDOW_ORDER_INFO* orderInfo = (WINDOW_ORDER_INFO*)msg->wParam;
2446
0
      WINDOW_ICON_ORDER* windowIcon = (WINDOW_ICON_ORDER*)msg->lParam;
2447
0
      return IFCALLRESULT(TRUE, proxy->WindowIcon, msg->context, orderInfo, windowIcon);
2448
0
    }
2449
2450
0
    case WindowUpdate_WindowCachedIcon:
2451
0
      return IFCALLRESULT(TRUE, proxy->WindowCachedIcon, msg->context,
2452
0
                          (WINDOW_ORDER_INFO*)msg->wParam,
2453
0
                          (WINDOW_CACHED_ICON_ORDER*)msg->lParam);
2454
2455
0
    case WindowUpdate_WindowDelete:
2456
0
      return IFCALLRESULT(TRUE, proxy->WindowDelete, msg->context,
2457
0
                          (WINDOW_ORDER_INFO*)msg->wParam);
2458
2459
0
    case WindowUpdate_NotifyIconCreate:
2460
0
      return IFCALLRESULT(TRUE, proxy->NotifyIconCreate, msg->context,
2461
0
                          (WINDOW_ORDER_INFO*)msg->wParam,
2462
0
                          (NOTIFY_ICON_STATE_ORDER*)msg->lParam);
2463
2464
0
    case WindowUpdate_NotifyIconUpdate:
2465
0
      return IFCALLRESULT(TRUE, proxy->NotifyIconUpdate, msg->context,
2466
0
                          (WINDOW_ORDER_INFO*)msg->wParam,
2467
0
                          (NOTIFY_ICON_STATE_ORDER*)msg->lParam);
2468
2469
0
    case WindowUpdate_NotifyIconDelete:
2470
0
      return IFCALLRESULT(TRUE, proxy->NotifyIconDelete, msg->context,
2471
0
                          (WINDOW_ORDER_INFO*)msg->wParam);
2472
2473
0
    case WindowUpdate_MonitoredDesktop:
2474
0
      return IFCALLRESULT(TRUE, proxy->MonitoredDesktop, msg->context,
2475
0
                          (WINDOW_ORDER_INFO*)msg->wParam,
2476
0
                          (MONITORED_DESKTOP_ORDER*)msg->lParam);
2477
2478
0
    case WindowUpdate_NonMonitoredDesktop:
2479
0
      return IFCALLRESULT(TRUE, proxy->NonMonitoredDesktop, msg->context,
2480
0
                          (WINDOW_ORDER_INFO*)msg->wParam);
2481
2482
0
    default:
2483
0
      return FALSE;
2484
0
  }
2485
0
}
2486
2487
static BOOL update_message_free_pointer_update_class(wMessage* msg, int type)
2488
0
{
2489
0
  rdpContext* context = nullptr;
2490
2491
0
  if (!msg)
2492
0
    return FALSE;
2493
2494
0
  context = msg->context;
2495
2496
0
  switch (type)
2497
0
  {
2498
0
    case PointerUpdate_PointerPosition:
2499
0
    {
2500
0
      POINTER_POSITION_UPDATE* wParam = (POINTER_POSITION_UPDATE*)msg->wParam;
2501
0
      free_pointer_position_update(context, wParam);
2502
0
    }
2503
0
    break;
2504
2505
0
    case PointerUpdate_PointerSystem:
2506
0
    {
2507
0
      POINTER_SYSTEM_UPDATE* wParam = (POINTER_SYSTEM_UPDATE*)msg->wParam;
2508
0
      free_pointer_system_update(context, wParam);
2509
0
    }
2510
0
    break;
2511
2512
0
    case PointerUpdate_PointerCached:
2513
0
    {
2514
0
      POINTER_CACHED_UPDATE* wParam = (POINTER_CACHED_UPDATE*)msg->wParam;
2515
0
      free_pointer_cached_update(context, wParam);
2516
0
    }
2517
0
    break;
2518
2519
0
    case PointerUpdate_PointerColor:
2520
0
    {
2521
0
      POINTER_COLOR_UPDATE* wParam = (POINTER_COLOR_UPDATE*)msg->wParam;
2522
0
      free_pointer_color_update(context, wParam);
2523
0
    }
2524
0
    break;
2525
2526
0
    case PointerUpdate_PointerNew:
2527
0
    {
2528
0
      POINTER_NEW_UPDATE* wParam = (POINTER_NEW_UPDATE*)msg->wParam;
2529
0
      free_pointer_new_update(context, wParam);
2530
0
    }
2531
0
    break;
2532
2533
0
    default:
2534
0
      return FALSE;
2535
0
  }
2536
2537
0
  return TRUE;
2538
0
}
2539
2540
static BOOL update_message_process_pointer_update_class(rdpUpdateProxy* proxy, wMessage* msg,
2541
                                                        int type)
2542
0
{
2543
0
  if (!proxy || !msg)
2544
0
    return FALSE;
2545
2546
0
  switch (type)
2547
0
  {
2548
0
    case PointerUpdate_PointerPosition:
2549
0
      return IFCALLRESULT(TRUE, proxy->PointerPosition, msg->context,
2550
0
                          (POINTER_POSITION_UPDATE*)msg->wParam);
2551
2552
0
    case PointerUpdate_PointerSystem:
2553
0
      return IFCALLRESULT(TRUE, proxy->PointerSystem, msg->context,
2554
0
                          (POINTER_SYSTEM_UPDATE*)msg->wParam);
2555
2556
0
    case PointerUpdate_PointerColor:
2557
0
      return IFCALLRESULT(TRUE, proxy->PointerColor, msg->context,
2558
0
                          (POINTER_COLOR_UPDATE*)msg->wParam);
2559
2560
0
    case PointerUpdate_PointerNew:
2561
0
      return IFCALLRESULT(TRUE, proxy->PointerNew, msg->context,
2562
0
                          (POINTER_NEW_UPDATE*)msg->wParam);
2563
2564
0
    case PointerUpdate_PointerCached:
2565
0
      return IFCALLRESULT(TRUE, proxy->PointerCached, msg->context,
2566
0
                          (POINTER_CACHED_UPDATE*)msg->wParam);
2567
2568
0
    default:
2569
0
      return FALSE;
2570
0
  }
2571
0
}
2572
2573
static BOOL update_message_free_class(wMessage* msg, int msgClass, int msgType)
2574
0
{
2575
0
  BOOL status = FALSE;
2576
2577
0
  switch (msgClass)
2578
0
  {
2579
0
    case Update_Class:
2580
0
      status = update_message_free_update_class(msg, msgType);
2581
0
      break;
2582
2583
0
    case PrimaryUpdate_Class:
2584
0
      status = update_message_free_primary_update_class(msg, msgType);
2585
0
      break;
2586
2587
0
    case SecondaryUpdate_Class:
2588
0
      status = update_message_free_secondary_update_class(msg, msgType);
2589
0
      break;
2590
2591
0
    case AltSecUpdate_Class:
2592
0
      status = update_message_free_altsec_update_class(msg, msgType);
2593
0
      break;
2594
2595
0
    case WindowUpdate_Class:
2596
0
      status = update_message_free_window_update_class(msg, msgType);
2597
0
      break;
2598
2599
0
    case PointerUpdate_Class:
2600
0
      status = update_message_free_pointer_update_class(msg, msgType);
2601
0
      break;
2602
2603
0
    default:
2604
0
      break;
2605
0
  }
2606
2607
0
  if (!status)
2608
0
    WLog_ERR(TAG, "Unknown message: class: %d type: %d", msgClass, msgType);
2609
2610
0
  return status;
2611
0
}
2612
2613
static int update_message_process_class(rdpUpdateProxy* proxy, wMessage* msg, int msgClass,
2614
                                        int msgType)
2615
0
{
2616
0
  BOOL status = FALSE;
2617
2618
0
  switch (msgClass)
2619
0
  {
2620
0
    case Update_Class:
2621
0
      status = update_message_process_update_class(proxy, msg, msgType);
2622
0
      break;
2623
2624
0
    case PrimaryUpdate_Class:
2625
0
      status = update_message_process_primary_update_class(proxy, msg, msgType);
2626
0
      break;
2627
2628
0
    case SecondaryUpdate_Class:
2629
0
      status = update_message_process_secondary_update_class(proxy, msg, msgType);
2630
0
      break;
2631
2632
0
    case AltSecUpdate_Class:
2633
0
      status = update_message_process_altsec_update_class(proxy, msg, msgType);
2634
0
      break;
2635
2636
0
    case WindowUpdate_Class:
2637
0
      status = update_message_process_window_update_class(proxy, msg, msgType);
2638
0
      break;
2639
2640
0
    case PointerUpdate_Class:
2641
0
      status = update_message_process_pointer_update_class(proxy, msg, msgType);
2642
0
      break;
2643
2644
0
    default:
2645
0
      status = FALSE;
2646
0
      break;
2647
0
  }
2648
2649
0
  if (!status)
2650
0
  {
2651
0
    WLog_ERR(TAG, "message: class: %d type: %d failed", msgClass, msgType);
2652
0
    return -1;
2653
0
  }
2654
2655
0
  return 0;
2656
0
}
2657
2658
int update_message_queue_process_message(rdpUpdate* update, wMessage* message)
2659
0
{
2660
0
  int status = 0;
2661
0
  int msgClass = 0;
2662
0
  int msgType = 0;
2663
0
  rdp_update_internal* up = update_cast(update);
2664
2665
0
  if (!update || !message)
2666
0
    return -1;
2667
2668
0
  if (message->id == WMQ_QUIT)
2669
0
    return 0;
2670
2671
0
  msgClass = GetMessageClass(message->id);
2672
0
  msgType = GetMessageType(message->id);
2673
0
  status = update_message_process_class(up->proxy, message, msgClass, msgType);
2674
0
  update_message_free_class(message, msgClass, msgType);
2675
2676
0
  if (status < 0)
2677
0
    return -1;
2678
2679
0
  return 1;
2680
0
}
2681
2682
int update_message_queue_free_message(wMessage* message)
2683
0
{
2684
0
  int msgClass = 0;
2685
0
  int msgType = 0;
2686
2687
0
  if (!message)
2688
0
    return -1;
2689
2690
0
  if (message->id == WMQ_QUIT)
2691
0
    return 0;
2692
2693
0
  msgClass = GetMessageClass(message->id);
2694
0
  msgType = GetMessageType(message->id);
2695
0
  return update_message_free_class(message, msgClass, msgType);
2696
0
}
2697
2698
int update_message_queue_process_pending_messages(rdpUpdate* update)
2699
0
{
2700
0
  int status = 1;
2701
0
  wMessage message = WINPR_C_ARRAY_INIT;
2702
0
  rdp_update_internal* up = update_cast(update);
2703
2704
0
  wMessageQueue* queue = up->queue;
2705
2706
0
  while (MessageQueue_Peek(queue, &message, TRUE))
2707
0
  {
2708
0
    status = update_message_queue_process_message(update, &message);
2709
2710
0
    if (!status)
2711
0
      break;
2712
0
  }
2713
2714
0
  return status;
2715
0
}
2716
2717
static BOOL update_message_register_interface(rdpUpdateProxy* message, rdpUpdate* update)
2718
0
{
2719
0
  rdpPrimaryUpdate* primary = nullptr;
2720
0
  rdpSecondaryUpdate* secondary = nullptr;
2721
0
  rdpAltSecUpdate* altsec = nullptr;
2722
0
  rdpWindowUpdate* window = nullptr;
2723
0
  rdpPointerUpdate* pointer = nullptr;
2724
2725
0
  if (!message || !update)
2726
0
    return FALSE;
2727
2728
0
  primary = update->primary;
2729
0
  secondary = update->secondary;
2730
0
  altsec = update->altsec;
2731
0
  window = update->window;
2732
0
  pointer = update->pointer;
2733
2734
0
  if (!primary || !secondary || !altsec || !window || !pointer)
2735
0
    return FALSE;
2736
2737
  /* Update */
2738
0
  message->BeginPaint = update->BeginPaint;
2739
0
  message->EndPaint = update->EndPaint;
2740
0
  message->SetBounds = update->SetBounds;
2741
0
  message->Synchronize = update->Synchronize;
2742
0
  message->DesktopResize = update->DesktopResize;
2743
0
  message->BitmapUpdate = update->BitmapUpdate;
2744
0
  message->Palette = update->Palette;
2745
0
  message->PlaySound = update->PlaySound;
2746
0
  message->SetKeyboardIndicators = update->SetKeyboardIndicators;
2747
0
  message->SetKeyboardImeStatus = update->SetKeyboardImeStatus;
2748
0
  message->RefreshRect = update->RefreshRect;
2749
0
  message->SuppressOutput = update->SuppressOutput;
2750
0
  message->SurfaceCommand = update->SurfaceCommand;
2751
0
  message->SurfaceBits = update->SurfaceBits;
2752
0
  message->SurfaceFrameMarker = update->SurfaceFrameMarker;
2753
0
  message->SurfaceFrameAcknowledge = update->SurfaceFrameAcknowledge;
2754
0
  update->BeginPaint = update_message_BeginPaint;
2755
0
  update->EndPaint = update_message_EndPaint;
2756
0
  update->SetBounds = update_message_SetBounds;
2757
0
  update->Synchronize = update_message_Synchronize;
2758
0
  update->DesktopResize = update_message_DesktopResize;
2759
0
  update->BitmapUpdate = update_message_BitmapUpdate;
2760
0
  update->Palette = update_message_Palette;
2761
0
  update->PlaySound = update_message_PlaySound;
2762
0
  update->SetKeyboardIndicators = update_message_SetKeyboardIndicators;
2763
0
  update->SetKeyboardImeStatus = update_message_SetKeyboardImeStatus;
2764
0
  update->RefreshRect = update_message_RefreshRect;
2765
0
  update->SuppressOutput = update_message_SuppressOutput;
2766
0
  update->SurfaceCommand = update_message_SurfaceCommand;
2767
0
  update->SurfaceBits = update_message_SurfaceBits;
2768
0
  update->SurfaceFrameMarker = update_message_SurfaceFrameMarker;
2769
0
  update->SurfaceFrameAcknowledge = update_message_SurfaceFrameAcknowledge;
2770
  /* Primary Update */
2771
0
  message->DstBlt = primary->DstBlt;
2772
0
  message->PatBlt = primary->PatBlt;
2773
0
  message->ScrBlt = primary->ScrBlt;
2774
0
  message->OpaqueRect = primary->OpaqueRect;
2775
0
  message->DrawNineGrid = primary->DrawNineGrid;
2776
0
  message->MultiDstBlt = primary->MultiDstBlt;
2777
0
  message->MultiPatBlt = primary->MultiPatBlt;
2778
0
  message->MultiScrBlt = primary->MultiScrBlt;
2779
0
  message->MultiOpaqueRect = primary->MultiOpaqueRect;
2780
0
  message->MultiDrawNineGrid = primary->MultiDrawNineGrid;
2781
0
  message->LineTo = primary->LineTo;
2782
0
  message->Polyline = primary->Polyline;
2783
0
  message->MemBlt = primary->MemBlt;
2784
0
  message->Mem3Blt = primary->Mem3Blt;
2785
0
  message->SaveBitmap = primary->SaveBitmap;
2786
0
  message->GlyphIndex = primary->GlyphIndex;
2787
0
  message->FastIndex = primary->FastIndex;
2788
0
  message->FastGlyph = primary->FastGlyph;
2789
0
  message->PolygonSC = primary->PolygonSC;
2790
0
  message->PolygonCB = primary->PolygonCB;
2791
0
  message->EllipseSC = primary->EllipseSC;
2792
0
  message->EllipseCB = primary->EllipseCB;
2793
0
  primary->DstBlt = update_message_DstBlt;
2794
0
  primary->PatBlt = update_message_PatBlt;
2795
0
  primary->ScrBlt = update_message_ScrBlt;
2796
0
  primary->OpaqueRect = update_message_OpaqueRect;
2797
0
  primary->DrawNineGrid = update_message_DrawNineGrid;
2798
0
  primary->MultiDstBlt = update_message_MultiDstBlt;
2799
0
  primary->MultiPatBlt = update_message_MultiPatBlt;
2800
0
  primary->MultiScrBlt = update_message_MultiScrBlt;
2801
0
  primary->MultiOpaqueRect = update_message_MultiOpaqueRect;
2802
0
  primary->MultiDrawNineGrid = update_message_MultiDrawNineGrid;
2803
0
  primary->LineTo = update_message_LineTo;
2804
0
  primary->Polyline = update_message_Polyline;
2805
0
  primary->MemBlt = update_message_MemBlt;
2806
0
  primary->Mem3Blt = update_message_Mem3Blt;
2807
0
  primary->SaveBitmap = update_message_SaveBitmap;
2808
0
  primary->GlyphIndex = update_message_GlyphIndex;
2809
0
  primary->FastIndex = update_message_FastIndex;
2810
0
  primary->FastGlyph = update_message_FastGlyph;
2811
0
  primary->PolygonSC = update_message_PolygonSC;
2812
0
  primary->PolygonCB = update_message_PolygonCB;
2813
0
  primary->EllipseSC = update_message_EllipseSC;
2814
0
  primary->EllipseCB = update_message_EllipseCB;
2815
  /* Secondary Update */
2816
0
  message->CacheBitmap = secondary->CacheBitmap;
2817
0
  message->CacheBitmapV2 = secondary->CacheBitmapV2;
2818
0
  message->CacheBitmapV3 = secondary->CacheBitmapV3;
2819
0
  message->CacheColorTable = secondary->CacheColorTable;
2820
0
  message->CacheGlyph = secondary->CacheGlyph;
2821
0
  message->CacheGlyphV2 = secondary->CacheGlyphV2;
2822
0
  message->CacheBrush = secondary->CacheBrush;
2823
0
  secondary->CacheBitmap = update_message_CacheBitmap;
2824
0
  secondary->CacheBitmapV2 = update_message_CacheBitmapV2;
2825
0
  secondary->CacheBitmapV3 = update_message_CacheBitmapV3;
2826
0
  secondary->CacheColorTable = update_message_CacheColorTable;
2827
0
  secondary->CacheGlyph = update_message_CacheGlyph;
2828
0
  secondary->CacheGlyphV2 = update_message_CacheGlyphV2;
2829
0
  secondary->CacheBrush = update_message_CacheBrush;
2830
  /* Alternate Secondary Update */
2831
0
  message->CreateOffscreenBitmap = altsec->CreateOffscreenBitmap;
2832
0
  message->SwitchSurface = altsec->SwitchSurface;
2833
0
  message->CreateNineGridBitmap = altsec->CreateNineGridBitmap;
2834
0
  message->FrameMarker = altsec->FrameMarker;
2835
0
  message->StreamBitmapFirst = altsec->StreamBitmapFirst;
2836
0
  message->StreamBitmapNext = altsec->StreamBitmapNext;
2837
0
  message->DrawGdiPlusFirst = altsec->DrawGdiPlusFirst;
2838
0
  message->DrawGdiPlusNext = altsec->DrawGdiPlusNext;
2839
0
  message->DrawGdiPlusEnd = altsec->DrawGdiPlusEnd;
2840
0
  message->DrawGdiPlusCacheFirst = altsec->DrawGdiPlusCacheFirst;
2841
0
  message->DrawGdiPlusCacheNext = altsec->DrawGdiPlusCacheNext;
2842
0
  message->DrawGdiPlusCacheEnd = altsec->DrawGdiPlusCacheEnd;
2843
0
  altsec->CreateOffscreenBitmap = update_message_CreateOffscreenBitmap;
2844
0
  altsec->SwitchSurface = update_message_SwitchSurface;
2845
0
  altsec->CreateNineGridBitmap = update_message_CreateNineGridBitmap;
2846
0
  altsec->FrameMarker = update_message_FrameMarker;
2847
0
  altsec->StreamBitmapFirst = update_message_StreamBitmapFirst;
2848
0
  altsec->StreamBitmapNext = update_message_StreamBitmapNext;
2849
0
  altsec->DrawGdiPlusFirst = update_message_DrawGdiPlusFirst;
2850
0
  altsec->DrawGdiPlusNext = update_message_DrawGdiPlusNext;
2851
0
  altsec->DrawGdiPlusEnd = update_message_DrawGdiPlusEnd;
2852
0
  altsec->DrawGdiPlusCacheFirst = update_message_DrawGdiPlusCacheFirst;
2853
0
  altsec->DrawGdiPlusCacheNext = update_message_DrawGdiPlusCacheNext;
2854
0
  altsec->DrawGdiPlusCacheEnd = update_message_DrawGdiPlusCacheEnd;
2855
  /* Window Update */
2856
0
  message->WindowCreate = window->WindowCreate;
2857
0
  message->WindowUpdate = window->WindowUpdate;
2858
0
  message->WindowIcon = window->WindowIcon;
2859
0
  message->WindowCachedIcon = window->WindowCachedIcon;
2860
0
  message->WindowDelete = window->WindowDelete;
2861
0
  message->NotifyIconCreate = window->NotifyIconCreate;
2862
0
  message->NotifyIconUpdate = window->NotifyIconUpdate;
2863
0
  message->NotifyIconDelete = window->NotifyIconDelete;
2864
0
  message->MonitoredDesktop = window->MonitoredDesktop;
2865
0
  message->NonMonitoredDesktop = window->NonMonitoredDesktop;
2866
0
  window->WindowCreate = update_message_WindowCreate;
2867
0
  window->WindowUpdate = update_message_WindowUpdate;
2868
0
  window->WindowIcon = update_message_WindowIcon;
2869
0
  window->WindowCachedIcon = update_message_WindowCachedIcon;
2870
0
  window->WindowDelete = update_message_WindowDelete;
2871
0
  window->NotifyIconCreate = update_message_NotifyIconCreate;
2872
0
  window->NotifyIconUpdate = update_message_NotifyIconUpdate;
2873
0
  window->NotifyIconDelete = update_message_NotifyIconDelete;
2874
0
  window->MonitoredDesktop = update_message_MonitoredDesktop;
2875
0
  window->NonMonitoredDesktop = update_message_NonMonitoredDesktop;
2876
  /* Pointer Update */
2877
0
  message->PointerPosition = pointer->PointerPosition;
2878
0
  message->PointerSystem = pointer->PointerSystem;
2879
0
  message->PointerColor = pointer->PointerColor;
2880
0
  message->PointerLarge = pointer->PointerLarge;
2881
0
  message->PointerNew = pointer->PointerNew;
2882
0
  message->PointerCached = pointer->PointerCached;
2883
0
  pointer->PointerPosition = update_message_PointerPosition;
2884
0
  pointer->PointerSystem = update_message_PointerSystem;
2885
0
  pointer->PointerColor = update_message_PointerColor;
2886
0
  pointer->PointerLarge = update_message_PointerLarge;
2887
0
  pointer->PointerNew = update_message_PointerNew;
2888
0
  pointer->PointerCached = update_message_PointerCached;
2889
0
  return TRUE;
2890
0
}
2891
2892
static DWORD WINAPI update_message_proxy_thread(LPVOID arg)
2893
0
{
2894
0
  rdpUpdate* update = (rdpUpdate*)arg;
2895
0
  wMessage message = WINPR_C_ARRAY_INIT;
2896
0
  rdp_update_internal* up = update_cast(update);
2897
2898
0
  while (MessageQueue_Wait(up->queue))
2899
0
  {
2900
0
    int status = 0;
2901
2902
0
    if (MessageQueue_Peek(up->queue, &message, TRUE))
2903
0
      status = update_message_queue_process_message(update, &message);
2904
2905
0
    if (!status)
2906
0
      break;
2907
0
  }
2908
2909
0
  ExitThread(0);
2910
0
  return 0;
2911
0
}
2912
2913
rdpUpdateProxy* update_message_proxy_new(rdpUpdate* update)
2914
0
{
2915
0
  rdpUpdateProxy* message = nullptr;
2916
2917
0
  if (!update)
2918
0
    return nullptr;
2919
2920
0
  if (!(message = (rdpUpdateProxy*)calloc(1, sizeof(rdpUpdateProxy))))
2921
0
    return nullptr;
2922
2923
0
  message->update = update;
2924
0
  update_message_register_interface(message, update);
2925
2926
0
  if (!(message->thread =
2927
0
            CreateThread(nullptr, 0, update_message_proxy_thread, update, 0, nullptr)))
2928
0
  {
2929
0
    WLog_ERR(TAG, "Failed to create proxy thread");
2930
0
    free(message);
2931
0
    return nullptr;
2932
0
  }
2933
2934
0
  return message;
2935
0
}
2936
2937
void update_message_proxy_free(rdpUpdateProxy* message)
2938
0
{
2939
0
  if (message)
2940
0
  {
2941
0
    rdp_update_internal* up = update_cast(message->update);
2942
0
    if (MessageQueue_PostQuit(up->queue, 0))
2943
0
      (void)WaitForSingleObject(message->thread, INFINITE);
2944
2945
0
    (void)CloseHandle(message->thread);
2946
0
    free(message);
2947
0
  }
2948
0
}
2949
2950
/* Event Queue */
2951
static int input_message_free_input_class(wMessage* msg, int type)
2952
0
{
2953
0
  int status = 0;
2954
2955
0
  WINPR_UNUSED(msg);
2956
2957
0
  switch (type)
2958
0
  {
2959
0
    case Input_SynchronizeEvent:
2960
0
      break;
2961
2962
0
    case Input_KeyboardEvent:
2963
0
      break;
2964
2965
0
    case Input_UnicodeKeyboardEvent:
2966
0
      break;
2967
2968
0
    case Input_MouseEvent:
2969
0
      break;
2970
2971
0
    case Input_ExtendedMouseEvent:
2972
0
      break;
2973
2974
0
    case Input_FocusInEvent:
2975
0
      break;
2976
2977
0
    case Input_KeyboardPauseEvent:
2978
0
      break;
2979
2980
0
    default:
2981
0
      status = -1;
2982
0
      break;
2983
0
  }
2984
2985
0
  return status;
2986
0
}
2987
2988
static int input_message_process_input_class(rdpInputProxy* proxy, wMessage* msg, int type)
2989
0
{
2990
0
  int status = 0;
2991
2992
0
  if (!proxy || !msg)
2993
0
    return -1;
2994
2995
0
  switch (type)
2996
0
  {
2997
0
    case Input_SynchronizeEvent:
2998
0
      IFCALL(proxy->SynchronizeEvent, msg->context, (UINT32)(size_t)msg->wParam);
2999
0
      break;
3000
3001
0
    case Input_KeyboardEvent:
3002
0
      IFCALL(proxy->KeyboardEvent, msg->context, (UINT16)(size_t)msg->wParam,
3003
0
             (UINT8)(size_t)msg->lParam);
3004
0
      break;
3005
3006
0
    case Input_UnicodeKeyboardEvent:
3007
0
      IFCALL(proxy->UnicodeKeyboardEvent, msg->context, (UINT16)(size_t)msg->wParam,
3008
0
             (UINT16)(size_t)msg->lParam);
3009
0
      break;
3010
3011
0
    case Input_MouseEvent:
3012
0
    {
3013
0
      UINT32 pos = 0;
3014
0
      UINT16 x = 0;
3015
0
      UINT16 y = 0;
3016
0
      pos = (UINT32)(size_t)msg->lParam;
3017
0
      x = ((pos & 0xFFFF0000) >> 16);
3018
0
      y = (pos & 0x0000FFFF);
3019
0
      IFCALL(proxy->MouseEvent, msg->context, (UINT16)(size_t)msg->wParam, x, y);
3020
0
    }
3021
0
    break;
3022
3023
0
    case Input_ExtendedMouseEvent:
3024
0
    {
3025
0
      UINT32 pos = 0;
3026
0
      UINT16 x = 0;
3027
0
      UINT16 y = 0;
3028
0
      pos = (UINT32)(size_t)msg->lParam;
3029
0
      x = ((pos & 0xFFFF0000) >> 16);
3030
0
      y = (pos & 0x0000FFFF);
3031
0
      IFCALL(proxy->ExtendedMouseEvent, msg->context, (UINT16)(size_t)msg->wParam, x, y);
3032
0
    }
3033
0
    break;
3034
3035
0
    case Input_FocusInEvent:
3036
0
      IFCALL(proxy->FocusInEvent, msg->context, (UINT16)(size_t)msg->wParam);
3037
0
      break;
3038
3039
0
    case Input_KeyboardPauseEvent:
3040
0
      IFCALL(proxy->KeyboardPauseEvent, msg->context);
3041
0
      break;
3042
3043
0
    default:
3044
0
      status = -1;
3045
0
      break;
3046
0
  }
3047
3048
0
  return status;
3049
0
}
3050
3051
static int input_message_free_class(wMessage* msg, int msgClass, int msgType)
3052
0
{
3053
0
  int status = 0;
3054
3055
0
  switch (msgClass)
3056
0
  {
3057
0
    case Input_Class:
3058
0
      status = input_message_free_input_class(msg, msgType);
3059
0
      break;
3060
3061
0
    default:
3062
0
      status = -1;
3063
0
      break;
3064
0
  }
3065
3066
0
  if (status < 0)
3067
0
    WLog_ERR(TAG, "Unknown event: class: %d type: %d", msgClass, msgType);
3068
3069
0
  return status;
3070
0
}
3071
3072
static int input_message_process_class(rdpInputProxy* proxy, wMessage* msg, int msgClass,
3073
                                       int msgType)
3074
0
{
3075
0
  int status = 0;
3076
3077
0
  switch (msgClass)
3078
0
  {
3079
0
    case Input_Class:
3080
0
      status = input_message_process_input_class(proxy, msg, msgType);
3081
0
      break;
3082
3083
0
    default:
3084
0
      status = -1;
3085
0
      break;
3086
0
  }
3087
3088
0
  if (status < 0)
3089
0
    WLog_ERR(TAG, "Unknown event: class: %d type: %d", msgClass, msgType);
3090
3091
0
  return status;
3092
0
}
3093
3094
int input_message_queue_free_message(wMessage* message)
3095
0
{
3096
0
  int status = 0;
3097
0
  int msgClass = 0;
3098
0
  int msgType = 0;
3099
3100
0
  if (!message)
3101
0
    return -1;
3102
3103
0
  if (message->id == WMQ_QUIT)
3104
0
    return 0;
3105
3106
0
  msgClass = GetMessageClass(message->id);
3107
0
  msgType = GetMessageType(message->id);
3108
0
  status = input_message_free_class(message, msgClass, msgType);
3109
3110
0
  if (status < 0)
3111
0
    return -1;
3112
3113
0
  return 1;
3114
0
}
3115
3116
int input_message_queue_process_message(rdpInput* input, wMessage* message)
3117
0
{
3118
0
  int status = 0;
3119
0
  int msgClass = 0;
3120
0
  int msgType = 0;
3121
0
  rdp_input_internal* in = input_cast(input);
3122
3123
0
  if (!message)
3124
0
    return -1;
3125
3126
0
  if (message->id == WMQ_QUIT)
3127
0
    return 0;
3128
3129
0
  msgClass = GetMessageClass(message->id);
3130
0
  msgType = GetMessageType(message->id);
3131
0
  status = input_message_process_class(in->proxy, message, msgClass, msgType);
3132
0
  input_message_free_class(message, msgClass, msgType);
3133
3134
0
  if (status < 0)
3135
0
    return -1;
3136
3137
0
  return 1;
3138
0
}
3139
3140
int input_message_queue_process_pending_messages(rdpInput* input)
3141
0
{
3142
0
  int status = 1;
3143
0
  wMessage message = WINPR_C_ARRAY_INIT;
3144
0
  rdp_input_internal* in = input_cast(input);
3145
3146
0
  if (!in->queue)
3147
0
    return -1;
3148
3149
0
  wMessageQueue* queue = in->queue;
3150
3151
0
  while (MessageQueue_Peek(queue, &message, TRUE))
3152
0
  {
3153
0
    status = input_message_queue_process_message(input, &message);
3154
3155
0
    if (!status)
3156
0
      break;
3157
0
  }
3158
3159
0
  return status;
3160
0
}