git.oblomov.eu Git - wine/blob - dlls/user/message.c

   1 /*
   2  * Window messaging support
   3  *
   4  * Copyright 2001 Alexandre Julliard
   5  *
   6  * This library is free software; you can redistribute it and/or
   7  * modify it under the terms of the GNU Lesser General Public
   8  * License as published by the Free Software Foundation; either
   9  * version 2.1 of the License, or (at your option) any later version.
  10  *
  11  * This library is distributed in the hope that it will be useful,
  12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  14  * Lesser General Public License for more details.
  15  *
  16  * You should have received a copy of the GNU Lesser General Public
  17  * License along with this library; if not, write to the Free Software
  18  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
  19  */
  20
  21 #include "config.h"
  22 #include "wine/port.h"
  23
  24 #include <assert.h>
  25 #include <stdarg.h>
  26
  27 #include "ntstatus.h"
  28 #include "windef.h"
  29 #include "winbase.h"
  30 #include "wingdi.h"
  31 #include "winuser.h"
  32 #include "winerror.h"
  33 #include "winnls.h"
  34 #include "dde.h"
  35 #include "wine/unicode.h"
  36 #include "wine/server.h"
  37 #include "message.h"
  38 #include "user_private.h"
  39 #include "win.h"
  40 #include "winproc.h"
  41 #include "wine/debug.h"
  42
  43 WINE_DEFAULT_DEBUG_CHANNEL(msg);
  44 WINE_DECLARE_DEBUG_CHANNEL(relay);
  45
  46 #define WM_NCMOUSEFIRST WM_NCMOUSEMOVE
  47 #define WM_NCMOUSELAST  WM_NCMBUTTONDBLCLK
  48
  49 #define MAX_PACK_COUNT 4
  50
  51 #define SYS_TIMER_RATE  55   /* min. timer rate in ms (actually 54.925)*/
  52
  53 /* description of the data fields that need to be packed along with a sent message */
  54 struct packed_message
  55 {
  56     int         count;
  57     const void *data[MAX_PACK_COUNT];
  58     size_t      size[MAX_PACK_COUNT];
  59 };
  60
  61 /* info about the message currently being received by the current thread */
  62 struct received_message_info
  63 {
  64     enum message_type type;
  65     MSG               msg;
  66     UINT              flags;  /* InSendMessageEx return flags */
  67     HWINEVENTHOOK     hook;   /* winevent hook handle */
  68     WINEVENTPROC      hook_proc; /* winevent hook proc address */
  69 };
  70
  71 /* structure to group all parameters for sent messages of the various kinds */
  72 struct send_message_info
  73 {
  74     enum message_type type;
  75     HWND              hwnd;
  76     UINT              msg;
  77     WPARAM            wparam;
  78     LPARAM            lparam;
  79     UINT              flags;      /* flags for SendMessageTimeout */
  80     UINT              timeout;    /* timeout for SendMessageTimeout */
  81     SENDASYNCPROC     callback;   /* callback function for SendMessageCallback */
  82     ULONG_PTR         data;       /* callback data */
  83 };
  84
  85
  86 /* flag for messages that contain pointers */
  87 /* 32 messages per entry, messages 0..31 map to bits 0..31 */
  88
  89 #define SET(msg) (1 << ((msg) & 31))
  90
  91 static const unsigned int message_pointer_flags[] =
  92 {
  93     /* 0x00 - 0x1f */
  94     SET(WM_CREATE) | SET(WM_SETTEXT) | SET(WM_GETTEXT) |
  95     SET(WM_WININICHANGE) | SET(WM_DEVMODECHANGE),
  96     /* 0x20 - 0x3f */
  97     SET(WM_GETMINMAXINFO) | SET(WM_DRAWITEM) | SET(WM_MEASUREITEM) | SET(WM_DELETEITEM) |
  98     SET(WM_COMPAREITEM),
  99     /* 0x40 - 0x5f */
 100     SET(WM_WINDOWPOSCHANGING) | SET(WM_WINDOWPOSCHANGED) | SET(WM_COPYDATA) |
 101     SET(WM_NOTIFY) | SET(WM_HELP),
 102     /* 0x60 - 0x7f */
 103     SET(WM_STYLECHANGING) | SET(WM_STYLECHANGED),
 104     /* 0x80 - 0x9f */
 105     SET(WM_NCCREATE) | SET(WM_NCCALCSIZE) | SET(WM_GETDLGCODE),
 106     /* 0xa0 - 0xbf */
 107     SET(EM_GETSEL) | SET(EM_GETRECT) | SET(EM_SETRECT) | SET(EM_SETRECTNP),
 108     /* 0xc0 - 0xdf */
 109     SET(EM_REPLACESEL) | SET(EM_GETLINE) | SET(EM_SETTABSTOPS),
 110     /* 0xe0 - 0xff */
 111     SET(SBM_GETRANGE) | SET(SBM_SETSCROLLINFO) | SET(SBM_GETSCROLLINFO) | SET(SBM_GETSCROLLBARINFO),
 112     /* 0x100 - 0x11f */
 113     0,
 114     /* 0x120 - 0x13f */
 115     0,
 116     /* 0x140 - 0x15f */
 117     SET(CB_GETEDITSEL) | SET(CB_ADDSTRING) | SET(CB_DIR) | SET(CB_GETLBTEXT) |
 118     SET(CB_INSERTSTRING) | SET(CB_FINDSTRING) | SET(CB_SELECTSTRING) |
 119     SET(CB_GETDROPPEDCONTROLRECT) | SET(CB_FINDSTRINGEXACT),
 120     /* 0x160 - 0x17f */
 121     0,
 122     /* 0x180 - 0x19f */
 123     SET(LB_ADDSTRING) | SET(LB_INSERTSTRING) | SET(LB_GETTEXT) | SET(LB_SELECTSTRING) |
 124     SET(LB_DIR) | SET(LB_FINDSTRING) |
 125     SET(LB_GETSELITEMS) | SET(LB_SETTABSTOPS) | SET(LB_ADDFILE) | SET(LB_GETITEMRECT),
 126     /* 0x1a0 - 0x1bf */
 127     SET(LB_FINDSTRINGEXACT),
 128     /* 0x1c0 - 0x1df */
 129     0,
 130     /* 0x1e0 - 0x1ff */
 131     0,
 132     /* 0x200 - 0x21f */
 133     SET(WM_NEXTMENU) | SET(WM_SIZING) | SET(WM_MOVING) | SET(WM_DEVICECHANGE),
 134     /* 0x220 - 0x23f */
 135     SET(WM_MDICREATE) | SET(WM_MDIGETACTIVE) | SET(WM_DROPOBJECT) |
 136     SET(WM_QUERYDROPOBJECT) | SET(WM_DRAGLOOP) | SET(WM_DRAGSELECT) | SET(WM_DRAGMOVE),
 137     /* 0x240 - 0x25f */
 138     0,
 139     /* 0x260 - 0x27f */
 140     0,
 141     /* 0x280 - 0x29f */
 142     0,
 143     /* 0x2a0 - 0x2bf */
 144     0,
 145     /* 0x2c0 - 0x2df */
 146     0,
 147     /* 0x2e0 - 0x2ff */
 148     0,
 149     /* 0x300 - 0x31f */
 150     SET(WM_ASKCBFORMATNAME)
 151 };
 152
 153 /* flags for messages that contain Unicode strings */
 154 static const unsigned int message_unicode_flags[] =
 155 {
 156     /* 0x00 - 0x1f */
 157     SET(WM_CREATE) | SET(WM_SETTEXT) | SET(WM_GETTEXT) | SET(WM_GETTEXTLENGTH) |
 158     SET(WM_WININICHANGE) | SET(WM_DEVMODECHANGE),
 159     /* 0x20 - 0x3f */
 160     SET(WM_CHARTOITEM),
 161     /* 0x40 - 0x5f */
 162     0,
 163     /* 0x60 - 0x7f */
 164     0,
 165     /* 0x80 - 0x9f */
 166     SET(WM_NCCREATE),
 167     /* 0xa0 - 0xbf */
 168     0,
 169     /* 0xc0 - 0xdf */
 170     SET(EM_REPLACESEL) | SET(EM_GETLINE) | SET(EM_SETPASSWORDCHAR),
 171     /* 0xe0 - 0xff */
 172     0,
 173     /* 0x100 - 0x11f */
 174     SET(WM_CHAR) | SET(WM_DEADCHAR) | SET(WM_SYSCHAR) | SET(WM_SYSDEADCHAR),
 175     /* 0x120 - 0x13f */
 176     SET(WM_MENUCHAR),
 177     /* 0x140 - 0x15f */
 178     SET(CB_ADDSTRING) | SET(CB_DIR) | SET(CB_GETLBTEXT) | SET(CB_GETLBTEXTLEN) |
 179     SET(CB_INSERTSTRING) | SET(CB_FINDSTRING) | SET(CB_SELECTSTRING) | SET(CB_FINDSTRINGEXACT),
 180     /* 0x160 - 0x17f */
 181     0,
 182     /* 0x180 - 0x19f */
 183     SET(LB_ADDSTRING) | SET(LB_INSERTSTRING) | SET(LB_GETTEXT) | SET(LB_GETTEXTLEN) |
 184     SET(LB_SELECTSTRING) | SET(LB_DIR) | SET(LB_FINDSTRING) | SET(LB_ADDFILE),
 185     /* 0x1a0 - 0x1bf */
 186     SET(LB_FINDSTRINGEXACT),
 187     /* 0x1c0 - 0x1df */
 188     0,
 189     /* 0x1e0 - 0x1ff */
 190     0,
 191     /* 0x200 - 0x21f */
 192     0,
 193     /* 0x220 - 0x23f */
 194     SET(WM_MDICREATE),
 195     /* 0x240 - 0x25f */
 196     0,
 197     /* 0x260 - 0x27f */
 198     0,
 199     /* 0x280 - 0x29f */
 200     SET(WM_IME_CHAR),
 201     /* 0x2a0 - 0x2bf */
 202     0,
 203     /* 0x2c0 - 0x2df */
 204     0,
 205     /* 0x2e0 - 0x2ff */
 206     0,
 207     /* 0x300 - 0x31f */
 208     SET(WM_PAINTCLIPBOARD) | SET(WM_SIZECLIPBOARD) | SET(WM_ASKCBFORMATNAME)
 209 };
 210
 211 /* check whether a given message type includes pointers */
 212 inline static int is_pointer_message( UINT message )
 213 {
 214     if (message >= 8*sizeof(message_pointer_flags)) return FALSE;
 215     return (message_pointer_flags[message / 32] & SET(message)) != 0;
 216 }
 217
 218 /* check whether a given message type contains Unicode (or ASCII) chars */
 219 inline static int is_unicode_message( UINT message )
 220 {
 221     if (message >= 8*sizeof(message_unicode_flags)) return FALSE;
 222     return (message_unicode_flags[message / 32] & SET(message)) != 0;
 223 }
 224
 225 #undef SET
 226
 227 /* add a data field to a packed message */
 228 inline static void push_data( struct packed_message *data, const void *ptr, size_t size )
 229 {
 230     data->data[data->count] = ptr;
 231     data->size[data->count] = size;
 232     data->count++;
 233 }
 234
 235 /* add a string to a packed message */
 236 inline static void push_string( struct packed_message *data, LPCWSTR str )
 237 {
 238     push_data( data, str, (strlenW(str) + 1) * sizeof(WCHAR) );
 239 }
 240
 241 /* retrieve a pointer to data from a packed message and increment the buffer pointer */
 242 inline static void *get_data( void **buffer, size_t size )
 243 {
 244     void *ret = *buffer;
 245     *buffer = (char *)*buffer + size;
 246     return ret;
 247 }
 248
 249 /* make sure that the buffer contains a valid null-terminated Unicode string */
 250 inline static BOOL check_string( LPCWSTR str, size_t size )
 251 {
 252     for (size /= sizeof(WCHAR); size; size--, str++)
 253         if (!*str) return TRUE;
 254     return FALSE;
 255 }
 256
 257 /* make sure that there is space for 'size' bytes in buffer, growing it if needed */
 258 inline static void *get_buffer_space( void **buffer, size_t size )
 259 {
 260     void *ret;
 261
 262     if (*buffer)
 263     {
 264         if (!(ret = HeapReAlloc( GetProcessHeap(), 0, *buffer, size )))
 265             HeapFree( GetProcessHeap(), 0, *buffer );
 266     }
 267     else ret = HeapAlloc( GetProcessHeap(), 0, size );
 268
 269     *buffer = ret;
 270     return ret;
 271 }
 272
 273 /* retrieve a string pointer from packed data */
 274 inline static LPWSTR get_string( void **buffer )
 275 {
 276     return get_data( buffer, (strlenW( (LPWSTR)*buffer ) + 1) * sizeof(WCHAR) );
 277 }
 278
 279 /* check whether a combobox expects strings or ids in CB_ADDSTRING/CB_INSERTSTRING */
 280 inline static BOOL combobox_has_strings( HWND hwnd )
 281 {
 282     DWORD style = GetWindowLongA( hwnd, GWL_STYLE );
 283     return (!(style & (CBS_OWNERDRAWFIXED | CBS_OWNERDRAWVARIABLE)) || (style & CBS_HASSTRINGS));
 284 }
 285
 286 /* check whether a listbox expects strings or ids in LB_ADDSTRING/LB_INSERTSTRING */
 287 inline static BOOL listbox_has_strings( HWND hwnd )
 288 {
 289     DWORD style = GetWindowLongA( hwnd, GWL_STYLE );
 290     return (!(style & (LBS_OWNERDRAWFIXED | LBS_OWNERDRAWVARIABLE)) || (style & LBS_HASSTRINGS));
 291 }
 292
 293
 294 /***********************************************************************
 295  *              broadcast_message_callback
 296  *
 297  * Helper callback for broadcasting messages.
 298  */
 299 static BOOL CALLBACK broadcast_message_callback( HWND hwnd, LPARAM lparam )
 300 {
 301     struct send_message_info *info = (struct send_message_info *)lparam;
 302     if (!(GetWindowLongW( hwnd, GWL_STYLE ) & (WS_POPUP|WS_CAPTION))) return TRUE;
 303     switch(info->type)
 304     {
 305     case MSG_UNICODE:
 306         SendMessageTimeoutW( hwnd, info->msg, info->wparam, info->lparam,
 307                              info->flags, info->timeout, NULL );
 308         break;
 309     case MSG_ASCII:
 310         SendMessageTimeoutA( hwnd, info->msg, info->wparam, info->lparam,
 311                              info->flags, info->timeout, NULL );
 312         break;
 313     case MSG_NOTIFY:
 314         SendNotifyMessageW( hwnd, info->msg, info->wparam, info->lparam );
 315         break;
 316     case MSG_CALLBACK:
 317         SendMessageCallbackW( hwnd, info->msg, info->wparam, info->lparam,
 318                               info->callback, info->data );
 319         break;
 320     case MSG_POSTED:
 321         PostMessageW( hwnd, info->msg, info->wparam, info->lparam );
 322         break;
 323     default:
 324         ERR( "bad type %d\n", info->type );
 325         break;
 326     }
 327     return TRUE;
 328 }
 329
 330
 331 /***********************************************************************
 332  *              map_wparam_AtoW
 333  *
 334  * Convert the wparam of an ASCII message to Unicode.
 335  */
 336 static WPARAM map_wparam_AtoW( UINT message, WPARAM wparam )
 337 {
 338     switch(message)
 339     {
 340     case WM_CHARTOITEM:
 341     case EM_SETPASSWORDCHAR:
 342     case WM_CHAR:
 343     case WM_DEADCHAR:
 344     case WM_SYSCHAR:
 345     case WM_SYSDEADCHAR:
 346     case WM_MENUCHAR:
 347         {
 348             char ch = LOWORD(wparam);
 349             WCHAR wch;
 350             MultiByteToWideChar(CP_ACP, 0, &ch, 1, &wch, 1);
 351             wparam = MAKEWPARAM( wch, HIWORD(wparam) );
 352         }
 353         break;
 354     case WM_IME_CHAR:
 355         {
 356             char ch[2];
 357             WCHAR wch;
 358             ch[0] = (wparam >> 8);
 359             ch[1] = (wparam & 0xff);
 360             if (ch[0]) MultiByteToWideChar(CP_ACP, 0, ch, 2, &wch, 1);
 361             else MultiByteToWideChar(CP_ACP, 0, &ch[1], 1, &wch, 1);
 362             wparam = MAKEWPARAM( wch, HIWORD(wparam) );
 363         }
 364         break;
 365     }
 366     return wparam;
 367 }
 368
 369
 370 /***********************************************************************
 371  *              map_wparam_WtoA
 372  *
 373  * Convert the wparam of a Unicode message to ASCII.
 374  */
 375 static WPARAM map_wparam_WtoA( UINT message, WPARAM wparam )
 376 {
 377     switch(message)
 378     {
 379     case WM_CHARTOITEM:
 380     case EM_SETPASSWORDCHAR:
 381     case WM_CHAR:
 382     case WM_DEADCHAR:
 383     case WM_SYSCHAR:
 384     case WM_SYSDEADCHAR:
 385     case WM_MENUCHAR:
 386         {
 387             WCHAR wch = LOWORD(wparam);
 388             BYTE ch;
 389             WideCharToMultiByte( CP_ACP, 0, &wch, 1, &ch, 1, NULL, NULL );
 390             wparam = MAKEWPARAM( ch, HIWORD(wparam) );
 391         }
 392         break;
 393     case WM_IME_CHAR:
 394         {
 395             WCHAR wch = LOWORD(wparam);
 396             BYTE ch[2];
 397
 398             if (WideCharToMultiByte( CP_ACP, 0, &wch, 1, ch, 2, NULL, NULL ) == 2)
 399                 wparam = MAKEWPARAM( (ch[0] << 8) | ch[1], HIWORD(wparam) );
 400             else
 401                 wparam = MAKEWPARAM( ch[0], HIWORD(wparam) );
 402         }
 403         break;
 404     }
 405     return wparam;
 406 }
 407
 408
 409 /***********************************************************************
 410  *              pack_message
 411  *
 412  * Pack a message for sending to another process.
 413  * Return the size of the data we expect in the message reply.
 414  * Set data->count to -1 if there is an error.
 415  */
 416 static size_t pack_message( HWND hwnd, UINT message, WPARAM wparam, LPARAM lparam,
 417                             struct packed_message *data )
 418 {
 419     data->count = 0;
 420     switch(message)
 421     {
 422     case WM_NCCREATE:
 423     case WM_CREATE:
 424     {
 425         CREATESTRUCTW *cs = (CREATESTRUCTW *)lparam;
 426         push_data( data, cs, sizeof(*cs) );
 427         if (HIWORD(cs->lpszName)) push_string( data, cs->lpszName );
 428         if (HIWORD(cs->lpszClass)) push_string( data, cs->lpszClass );
 429         return sizeof(*cs);
 430     }
 431     case WM_GETTEXT:
 432     case WM_ASKCBFORMATNAME:
 433         return wparam * sizeof(WCHAR);
 434     case WM_WININICHANGE:
 435         if (lparam) push_string(data, (LPWSTR)lparam );
 436         return 0;
 437     case WM_SETTEXT:
 438     case WM_DEVMODECHANGE:
 439     case CB_DIR:
 440     case LB_DIR:
 441     case LB_ADDFILE:
 442     case EM_REPLACESEL:
 443         push_string( data, (LPWSTR)lparam );
 444         return 0;
 445     case WM_GETMINMAXINFO:
 446         push_data( data, (MINMAXINFO *)lparam, sizeof(MINMAXINFO) );
 447         return sizeof(MINMAXINFO);
 448     case WM_DRAWITEM:
 449         push_data( data, (DRAWITEMSTRUCT *)lparam, sizeof(DRAWITEMSTRUCT) );
 450         return 0;
 451     case WM_MEASUREITEM:
 452         push_data( data, (MEASUREITEMSTRUCT *)lparam, sizeof(MEASUREITEMSTRUCT) );
 453         return sizeof(MEASUREITEMSTRUCT);
 454     case WM_DELETEITEM:
 455         push_data( data, (DELETEITEMSTRUCT *)lparam, sizeof(DELETEITEMSTRUCT) );
 456         return 0;
 457     case WM_COMPAREITEM:
 458         push_data( data, (COMPAREITEMSTRUCT *)lparam, sizeof(COMPAREITEMSTRUCT) );
 459         return 0;
 460     case WM_WINDOWPOSCHANGING:
 461     case WM_WINDOWPOSCHANGED:
 462         push_data( data, (WINDOWPOS *)lparam, sizeof(WINDOWPOS) );
 463         return sizeof(WINDOWPOS);
 464     case WM_COPYDATA:
 465     {
 466         COPYDATASTRUCT *cp = (COPYDATASTRUCT *)lparam;
 467         push_data( data, cp, sizeof(*cp) );
 468         if (cp->lpData) push_data( data, cp->lpData, cp->cbData );
 469         return 0;
 470     }
 471     case WM_NOTIFY:
 472         /* WM_NOTIFY cannot be sent across processes (MSDN) */
 473         data->count = -1;
 474         return 0;
 475     case WM_HELP:
 476         push_data( data, (HELPINFO *)lparam, sizeof(HELPINFO) );
 477         return 0;
 478     case WM_STYLECHANGING:
 479     case WM_STYLECHANGED:
 480         push_data( data, (STYLESTRUCT *)lparam, sizeof(STYLESTRUCT) );
 481         return 0;
 482     case WM_NCCALCSIZE:
 483         if (!wparam)
 484         {
 485             push_data( data, (RECT *)lparam, sizeof(RECT) );
 486             return sizeof(RECT);
 487         }
 488         else
 489         {
 490             NCCALCSIZE_PARAMS *nc = (NCCALCSIZE_PARAMS *)lparam;
 491             push_data( data, nc, sizeof(*nc) );
 492             push_data( data, nc->lppos, sizeof(*nc->lppos) );
 493             return sizeof(*nc) + sizeof(*nc->lppos);
 494         }
 495     case WM_GETDLGCODE:
 496         if (lparam) push_data( data, (MSG *)lparam, sizeof(MSG) );
 497         return sizeof(MSG);
 498     case SBM_SETSCROLLINFO:
 499         push_data( data, (SCROLLINFO *)lparam, sizeof(SCROLLINFO) );
 500         return 0;
 501     case SBM_GETSCROLLINFO:
 502         push_data( data, (SCROLLINFO *)lparam, sizeof(SCROLLINFO) );
 503         return sizeof(SCROLLINFO);
 504     case SBM_GETSCROLLBARINFO:
 505     {
 506         const SCROLLBARINFO *info = (const SCROLLBARINFO *)lparam;
 507         size_t size = min( info->cbSize, sizeof(SCROLLBARINFO) );
 508         push_data( data, info, size );
 509         return size;
 510     }
 511     case EM_GETSEL:
 512     case SBM_GETRANGE:
 513     case CB_GETEDITSEL:
 514     {
 515         size_t size = 0;
 516         if (wparam) size += sizeof(DWORD);
 517         if (lparam) size += sizeof(DWORD);
 518         return size;
 519     }
 520     case EM_GETRECT:
 521     case LB_GETITEMRECT:
 522     case CB_GETDROPPEDCONTROLRECT:
 523         return sizeof(RECT);
 524     case EM_SETRECT:
 525     case EM_SETRECTNP:
 526         push_data( data, (RECT *)lparam, sizeof(RECT) );
 527         return 0;
 528     case EM_GETLINE:
 529     {
 530         WORD *pw = (WORD *)lparam;
 531         push_data( data, pw, sizeof(*pw) );
 532         return *pw * sizeof(WCHAR);
 533     }
 534     case EM_SETTABSTOPS:
 535     case LB_SETTABSTOPS:
 536         if (wparam) push_data( data, (UINT *)lparam, sizeof(UINT) * wparam );
 537         return 0;
 538     case CB_ADDSTRING:
 539     case CB_INSERTSTRING:
 540     case CB_FINDSTRING:
 541     case CB_FINDSTRINGEXACT:
 542     case CB_SELECTSTRING:
 543         if (combobox_has_strings( hwnd )) push_string( data, (LPWSTR)lparam );
 544         return 0;
 545     case CB_GETLBTEXT:
 546         if (!combobox_has_strings( hwnd )) return sizeof(ULONG_PTR);
 547         return (SendMessageW( hwnd, CB_GETLBTEXTLEN, wparam, 0 ) + 1) * sizeof(WCHAR);
 548     case LB_ADDSTRING:
 549     case LB_INSERTSTRING:
 550     case LB_FINDSTRING:
 551     case LB_FINDSTRINGEXACT:
 552     case LB_SELECTSTRING:
 553         if (listbox_has_strings( hwnd )) push_string( data, (LPWSTR)lparam );
 554         return 0;
 555     case LB_GETTEXT:
 556         if (!listbox_has_strings( hwnd )) return sizeof(ULONG_PTR);
 557         return (SendMessageW( hwnd, LB_GETTEXTLEN, wparam, 0 ) + 1) * sizeof(WCHAR);
 558     case LB_GETSELITEMS:
 559         return wparam * sizeof(UINT);
 560     case WM_NEXTMENU:
 561         push_data( data, (MDINEXTMENU *)lparam, sizeof(MDINEXTMENU) );
 562         return sizeof(MDINEXTMENU);
 563     case WM_SIZING:
 564     case WM_MOVING:
 565         push_data( data, (RECT *)lparam, sizeof(RECT) );
 566         return sizeof(RECT);
 567     case WM_MDICREATE:
 568     {
 569         MDICREATESTRUCTW *cs = (MDICREATESTRUCTW *)lparam;
 570         push_data( data, cs, sizeof(*cs) );
 571         if (HIWORD(cs->szTitle)) push_string( data, cs->szTitle );
 572         if (HIWORD(cs->szClass)) push_string( data, cs->szClass );
 573         return sizeof(*cs);
 574     }
 575     case WM_MDIGETACTIVE:
 576         if (lparam) return sizeof(BOOL);
 577         return 0;
 578     case WM_WINE_SETWINDOWPOS:
 579         push_data( data, (WINDOWPOS *)lparam, sizeof(WINDOWPOS) );
 580         return 0;
 581     case WM_WINE_KEYBOARD_LL_HOOK:
 582         push_data( data, (KBDLLHOOKSTRUCT *)lparam, sizeof(KBDLLHOOKSTRUCT) );
 583         return 0;
 584     case WM_WINE_MOUSE_LL_HOOK:
 585         push_data( data, (MSLLHOOKSTRUCT *)lparam, sizeof(MSLLHOOKSTRUCT) );
 586         return 0;
 587
 588     /* these contain an HFONT */
 589     case WM_SETFONT:
 590     case WM_GETFONT:
 591     /* these contain an HDC */
 592     case WM_PAINT:
 593     case WM_ERASEBKGND:
 594     case WM_ICONERASEBKGND:
 595     case WM_NCPAINT:
 596     case WM_CTLCOLORMSGBOX:
 597     case WM_CTLCOLOREDIT:
 598     case WM_CTLCOLORLISTBOX:
 599     case WM_CTLCOLORBTN:
 600     case WM_CTLCOLORDLG:
 601     case WM_CTLCOLORSCROLLBAR:
 602     case WM_CTLCOLORSTATIC:
 603     case WM_PRINT:
 604     case WM_PRINTCLIENT:
 605     /* these contain an HGLOBAL */
 606     case WM_PAINTCLIPBOARD:
 607     case WM_SIZECLIPBOARD:
 608     /* these contain HICON */
 609     case WM_GETICON:
 610     case WM_SETICON:
 611     case WM_QUERYDRAGICON:
 612     case WM_QUERYPARKICON:
 613     /* these contain pointers */
 614     case WM_DROPOBJECT:
 615     case WM_QUERYDROPOBJECT:
 616     case WM_DRAGLOOP:
 617     case WM_DRAGSELECT:
 618     case WM_DRAGMOVE:
 619     case WM_DEVICECHANGE:
 620         FIXME( "msg %x (%s) not supported yet\n", message, SPY_GetMsgName(message, hwnd) );
 621         data->count = -1;
 622         return 0;
 623     }
 624     return 0;
 625 }
 626
 627
 628 /***********************************************************************
 629  *              unpack_message
 630  *
 631  * Unpack a message received from another process.
 632  */
 633 static BOOL unpack_message( HWND hwnd, UINT message, WPARAM *wparam, LPARAM *lparam,
 634                             void **buffer, size_t size )
 635 {
 636     size_t minsize = 0;
 637
 638     switch(message)
 639     {
 640     case WM_NCCREATE:
 641     case WM_CREATE:
 642     {
 643         CREATESTRUCTW *cs = *buffer;
 644         WCHAR *str = (WCHAR *)(cs + 1);
 645         if (size < sizeof(*cs)) return FALSE;
 646         size -= sizeof(*cs);
 647         if (HIWORD(cs->lpszName))
 648         {
 649             if (!check_string( str, size )) return FALSE;
 650             cs->lpszName = str;
 651             size -= (strlenW(str) + 1) * sizeof(WCHAR);
 652             str += strlenW(str) + 1;
 653         }
 654         if (HIWORD(cs->lpszClass))
 655         {
 656             if (!check_string( str, size )) return FALSE;
 657             cs->lpszClass = str;
 658         }
 659         break;
 660     }
 661     case WM_GETTEXT:
 662     case WM_ASKCBFORMATNAME:
 663         if (!get_buffer_space( buffer, (*wparam * sizeof(WCHAR)) )) return FALSE;
 664         break;
 665     case WM_WININICHANGE:
 666         if (!*lparam) return TRUE;
 667         /* fall through */
 668     case WM_SETTEXT:
 669     case WM_DEVMODECHANGE:
 670     case CB_DIR:
 671     case LB_DIR:
 672     case LB_ADDFILE:
 673     case EM_REPLACESEL:
 674         if (!check_string( *buffer, size )) return FALSE;
 675         break;
 676     case WM_GETMINMAXINFO:
 677         minsize = sizeof(MINMAXINFO);
 678         break;
 679     case WM_DRAWITEM:
 680         minsize = sizeof(DRAWITEMSTRUCT);
 681         break;
 682     case WM_MEASUREITEM:
 683         minsize = sizeof(MEASUREITEMSTRUCT);
 684         break;
 685     case WM_DELETEITEM:
 686         minsize = sizeof(DELETEITEMSTRUCT);
 687         break;
 688     case WM_COMPAREITEM:
 689         minsize = sizeof(COMPAREITEMSTRUCT);
 690         break;
 691     case WM_WINDOWPOSCHANGING:
 692     case WM_WINDOWPOSCHANGED:
 693     case WM_WINE_SETWINDOWPOS:
 694         minsize = sizeof(WINDOWPOS);
 695         break;
 696     case WM_COPYDATA:
 697     {
 698         COPYDATASTRUCT *cp = *buffer;
 699         if (size < sizeof(*cp)) return FALSE;
 700         if (cp->lpData)
 701         {
 702             minsize = sizeof(*cp) + cp->cbData;
 703             cp->lpData = cp + 1;
 704         }
 705         break;
 706     }
 707     case WM_NOTIFY:
 708         /* WM_NOTIFY cannot be sent across processes (MSDN) */
 709         return FALSE;
 710     case WM_HELP:
 711         minsize = sizeof(HELPINFO);
 712         break;
 713     case WM_STYLECHANGING:
 714     case WM_STYLECHANGED:
 715         minsize = sizeof(STYLESTRUCT);
 716         break;
 717     case WM_NCCALCSIZE:
 718         if (!*wparam) minsize = sizeof(RECT);
 719         else
 720         {
 721             NCCALCSIZE_PARAMS *nc = *buffer;
 722             if (size < sizeof(*nc) + sizeof(*nc->lppos)) return FALSE;
 723             nc->lppos = (WINDOWPOS *)(nc + 1);
 724         }
 725         break;
 726     case WM_GETDLGCODE:
 727         if (!*lparam) return TRUE;
 728         minsize = sizeof(MSG);
 729         break;
 730     case SBM_SETSCROLLINFO:
 731         minsize = sizeof(SCROLLINFO);
 732         break;
 733     case SBM_GETSCROLLINFO:
 734         if (!get_buffer_space( buffer, sizeof(SCROLLINFO ))) return FALSE;
 735         break;
 736     case SBM_GETSCROLLBARINFO:
 737         if (!get_buffer_space( buffer, sizeof(SCROLLBARINFO ))) return FALSE;
 738         break;
 739     case EM_GETSEL:
 740     case SBM_GETRANGE:
 741     case CB_GETEDITSEL:
 742         if (*wparam || *lparam)
 743         {
 744             if (!get_buffer_space( buffer, 2*sizeof(DWORD) )) return FALSE;
 745             if (*wparam) *wparam = (WPARAM)*buffer;
 746             if (*lparam) *lparam = (LPARAM)((DWORD *)*buffer + 1);
 747         }
 748         return TRUE;
 749     case EM_GETRECT:
 750     case LB_GETITEMRECT:
 751     case CB_GETDROPPEDCONTROLRECT:
 752         if (!get_buffer_space( buffer, sizeof(RECT) )) return FALSE;
 753         break;
 754     case EM_SETRECT:
 755     case EM_SETRECTNP:
 756         minsize = sizeof(RECT);
 757         break;
 758     case EM_GETLINE:
 759     {
 760         WORD len;
 761         if (size < sizeof(WORD)) return FALSE;
 762         len = *(WORD *)*buffer;
 763         if (!get_buffer_space( buffer, (len + 1) * sizeof(WCHAR) )) return FALSE;
 764         *lparam = (LPARAM)*buffer + sizeof(WORD);  /* don't erase WORD at start of buffer */
 765         return TRUE;
 766     }
 767     case EM_SETTABSTOPS:
 768     case LB_SETTABSTOPS:
 769         if (!*wparam) return TRUE;
 770         minsize = *wparam * sizeof(UINT);
 771         break;
 772     case CB_ADDSTRING:
 773     case CB_INSERTSTRING:
 774     case CB_FINDSTRING:
 775     case CB_FINDSTRINGEXACT:
 776     case CB_SELECTSTRING:
 777     case LB_ADDSTRING:
 778     case LB_INSERTSTRING:
 779     case LB_FINDSTRING:
 780     case LB_FINDSTRINGEXACT:
 781     case LB_SELECTSTRING:
 782         if (!*buffer) return TRUE;
 783         if (!check_string( *buffer, size )) return FALSE;
 784         break;
 785     case CB_GETLBTEXT:
 786     {
 787         size = sizeof(ULONG_PTR);
 788         if (combobox_has_strings( hwnd ))
 789             size = (SendMessageW( hwnd, CB_GETLBTEXTLEN, *wparam, 0 ) + 1) * sizeof(WCHAR);
 790         if (!get_buffer_space( buffer, size )) return FALSE;
 791         break;
 792     }
 793     case LB_GETTEXT:
 794     {
 795         size = sizeof(ULONG_PTR);
 796         if (listbox_has_strings( hwnd ))
 797             size = (SendMessageW( hwnd, LB_GETTEXTLEN, *wparam, 0 ) + 1) * sizeof(WCHAR);
 798         if (!get_buffer_space( buffer, size )) return FALSE;
 799         break;
 800     }
 801     case LB_GETSELITEMS:
 802         if (!get_buffer_space( buffer, *wparam * sizeof(UINT) )) return FALSE;
 803         break;
 804     case WM_NEXTMENU:
 805         minsize = sizeof(MDINEXTMENU);
 806         if (!get_buffer_space( buffer, sizeof(MDINEXTMENU) )) return FALSE;
 807         break;
 808     case WM_SIZING:
 809     case WM_MOVING:
 810         minsize = sizeof(RECT);
 811         if (!get_buffer_space( buffer, sizeof(RECT) )) return FALSE;
 812         break;
 813     case WM_MDICREATE:
 814     {
 815         MDICREATESTRUCTW *cs = *buffer;
 816         WCHAR *str = (WCHAR *)(cs + 1);
 817         if (size < sizeof(*cs)) return FALSE;
 818         size -= sizeof(*cs);
 819         if (HIWORD(cs->szTitle))
 820         {
 821             if (!check_string( str, size )) return FALSE;
 822             cs->szTitle = str;
 823             size -= (strlenW(str) + 1) * sizeof(WCHAR);
 824             str += strlenW(str) + 1;
 825         }
 826         if (HIWORD(cs->szClass))
 827         {
 828             if (!check_string( str, size )) return FALSE;
 829             cs->szClass = str;
 830         }
 831         break;
 832     }
 833     case WM_MDIGETACTIVE:
 834         if (!*lparam) return TRUE;
 835         if (!get_buffer_space( buffer, sizeof(BOOL) )) return FALSE;
 836         break;
 837     case WM_WINE_KEYBOARD_LL_HOOK:
 838         minsize = sizeof(KBDLLHOOKSTRUCT);
 839         break;
 840     case WM_WINE_MOUSE_LL_HOOK:
 841         minsize = sizeof(MSLLHOOKSTRUCT);
 842         break;
 843
 844     /* these contain an HFONT */
 845     case WM_SETFONT:
 846     case WM_GETFONT:
 847     /* these contain an HDC */
 848     case WM_PAINT:
 849     case WM_ERASEBKGND:
 850     case WM_ICONERASEBKGND:
 851     case WM_NCPAINT:
 852     case WM_CTLCOLORMSGBOX:
 853     case WM_CTLCOLOREDIT:
 854     case WM_CTLCOLORLISTBOX:
 855     case WM_CTLCOLORBTN:
 856     case WM_CTLCOLORDLG:
 857     case WM_CTLCOLORSCROLLBAR:
 858     case WM_CTLCOLORSTATIC:
 859     case WM_PRINT:
 860     case WM_PRINTCLIENT:
 861     /* these contain an HGLOBAL */
 862     case WM_PAINTCLIPBOARD:
 863     case WM_SIZECLIPBOARD:
 864     /* these contain HICON */
 865     case WM_GETICON:
 866     case WM_SETICON:
 867     case WM_QUERYDRAGICON:
 868     case WM_QUERYPARKICON:
 869     /* these contain pointers */
 870     case WM_DROPOBJECT:
 871     case WM_QUERYDROPOBJECT:
 872     case WM_DRAGLOOP:
 873     case WM_DRAGSELECT:
 874     case WM_DRAGMOVE:
 875     case WM_DEVICECHANGE:
 876         FIXME( "msg %x (%s) not supported yet\n", message, SPY_GetMsgName(message, hwnd) );
 877         return FALSE;
 878
 879     default:
 880         return TRUE; /* message doesn't need any unpacking */
 881     }
 882
 883     /* default exit for most messages: check minsize and store buffer in lparam */
 884     if (size < minsize) return FALSE;
 885     *lparam = (LPARAM)*buffer;
 886     return TRUE;
 887 }
 888
 889
 890 /***********************************************************************
 891  *              pack_reply
 892  *
 893  * Pack a reply to a message for sending to another process.
 894  */
 895 static void pack_reply( HWND hwnd, UINT message, WPARAM wparam, LPARAM lparam,
 896                         LRESULT res, struct packed_message *data )
 897 {
 898     data->count = 0;
 899     switch(message)
 900     {
 901     case WM_NCCREATE:
 902     case WM_CREATE:
 903         push_data( data, (CREATESTRUCTW *)lparam, sizeof(CREATESTRUCTW) );
 904         break;
 905     case WM_GETTEXT:
 906     case CB_GETLBTEXT:
 907     case LB_GETTEXT:
 908         push_data( data, (WCHAR *)lparam, (res + 1) * sizeof(WCHAR) );
 909         break;
 910     case WM_GETMINMAXINFO:
 911         push_data( data, (MINMAXINFO *)lparam, sizeof(MINMAXINFO) );
 912         break;
 913     case WM_MEASUREITEM:
 914         push_data( data, (MEASUREITEMSTRUCT *)lparam, sizeof(MEASUREITEMSTRUCT) );
 915         break;
 916     case WM_WINDOWPOSCHANGING:
 917     case WM_WINDOWPOSCHANGED:
 918         push_data( data, (WINDOWPOS *)lparam, sizeof(WINDOWPOS) );
 919         break;
 920     case WM_GETDLGCODE:
 921         if (lparam) push_data( data, (MSG *)lparam, sizeof(MSG) );
 922         break;
 923     case SBM_GETSCROLLINFO:
 924         push_data( data, (SCROLLINFO *)lparam, sizeof(SCROLLINFO) );
 925         break;
 926     case EM_GETRECT:
 927     case LB_GETITEMRECT:
 928     case CB_GETDROPPEDCONTROLRECT:
 929     case WM_SIZING:
 930     case WM_MOVING:
 931         push_data( data, (RECT *)lparam, sizeof(RECT) );
 932         break;
 933     case EM_GETLINE:
 934     {
 935         WORD *ptr = (WORD *)lparam;
 936         push_data( data, ptr, ptr[-1] * sizeof(WCHAR) );
 937         break;
 938     }
 939     case LB_GETSELITEMS:
 940         push_data( data, (UINT *)lparam, wparam * sizeof(UINT) );
 941         break;
 942     case WM_MDIGETACTIVE:
 943         if (lparam) push_data( data, (BOOL *)lparam, sizeof(BOOL) );
 944         break;
 945     case WM_NCCALCSIZE:
 946         if (!wparam)
 947             push_data( data, (RECT *)lparam, sizeof(RECT) );
 948         else
 949         {
 950             NCCALCSIZE_PARAMS *nc = (NCCALCSIZE_PARAMS *)lparam;
 951             push_data( data, nc, sizeof(*nc) );
 952             push_data( data, nc->lppos, sizeof(*nc->lppos) );
 953         }
 954         break;
 955     case EM_GETSEL:
 956     case SBM_GETRANGE:
 957     case CB_GETEDITSEL:
 958         if (wparam) push_data( data, (DWORD *)wparam, sizeof(DWORD) );
 959         if (lparam) push_data( data, (DWORD *)lparam, sizeof(DWORD) );
 960         break;
 961     case WM_NEXTMENU:
 962         push_data( data, (MDINEXTMENU *)lparam, sizeof(MDINEXTMENU) );
 963         break;
 964     case WM_MDICREATE:
 965         push_data( data, (MDICREATESTRUCTW *)lparam, sizeof(MDICREATESTRUCTW) );
 966         break;
 967     case WM_ASKCBFORMATNAME:
 968         push_data( data, (WCHAR *)lparam, (strlenW((WCHAR *)lparam) + 1) * sizeof(WCHAR) );
 969         break;
 970     }
 971 }
 972
 973
 974 /***********************************************************************
 975  *              unpack_reply
 976  *
 977  * Unpack a message reply received from another process.
 978  */
 979 static void unpack_reply( HWND hwnd, UINT message, WPARAM wparam, LPARAM lparam,
 980                           void *buffer, size_t size )
 981 {
 982     switch(message)
 983     {
 984     case WM_NCCREATE:
 985     case WM_CREATE:
 986     {
 987         CREATESTRUCTW *cs = (CREATESTRUCTW *)lparam;
 988         LPCWSTR name = cs->lpszName, class = cs->lpszClass;
 989         memcpy( cs, buffer, min( sizeof(*cs), size ));
 990         cs->lpszName = name;  /* restore the original pointers */
 991         cs->lpszClass = class;
 992         break;
 993     }
 994     case WM_GETTEXT:
 995     case WM_ASKCBFORMATNAME:
 996         memcpy( (WCHAR *)lparam, buffer, min( wparam*sizeof(WCHAR), size ));
 997         break;
 998     case WM_GETMINMAXINFO:
 999         memcpy( (MINMAXINFO *)lparam, buffer, min( sizeof(MINMAXINFO), size ));
1000         break;
1001     case WM_MEASUREITEM:
1002         memcpy( (MEASUREITEMSTRUCT *)lparam, buffer, min( sizeof(MEASUREITEMSTRUCT), size ));
1003         break;
1004     case WM_WINDOWPOSCHANGING:
1005     case WM_WINDOWPOSCHANGED:
1006         memcpy( (WINDOWPOS *)lparam, buffer, min( sizeof(WINDOWPOS), size ));
1007         break;
1008     case WM_GETDLGCODE:
1009         if (lparam) memcpy( (MSG *)lparam, buffer, min( sizeof(MSG), size ));
1010         break;
1011     case SBM_GETSCROLLINFO:
1012         memcpy( (SCROLLINFO *)lparam, buffer, min( sizeof(SCROLLINFO), size ));
1013         break;
1014     case SBM_GETSCROLLBARINFO:
1015         memcpy( (SCROLLBARINFO *)lparam, buffer, min( sizeof(SCROLLBARINFO), size ));
1016         break;
1017     case EM_GETRECT:
1018     case CB_GETDROPPEDCONTROLRECT:
1019     case LB_GETITEMRECT:
1020     case WM_SIZING:
1021     case WM_MOVING:
1022         memcpy( (RECT *)lparam, buffer, min( sizeof(RECT), size ));
1023         break;
1024     case EM_GETLINE:
1025         size = min( size, (size_t)*(WORD *)lparam );
1026         memcpy( (WCHAR *)lparam, buffer, size );
1027         break;
1028     case LB_GETSELITEMS:
1029         memcpy( (UINT *)lparam, buffer, min( wparam*sizeof(UINT), size ));
1030         break;
1031     case LB_GETTEXT:
1032     case CB_GETLBTEXT:
1033         memcpy( (WCHAR *)lparam, buffer, size );
1034         break;
1035     case WM_NEXTMENU:
1036         memcpy( (MDINEXTMENU *)lparam, buffer, min( sizeof(MDINEXTMENU), size ));
1037         break;
1038     case WM_MDIGETACTIVE:
1039         if (lparam) memcpy( (BOOL *)lparam, buffer, min( sizeof(BOOL), size ));
1040         break;
1041     case WM_NCCALCSIZE:
1042         if (!wparam)
1043             memcpy( (RECT *)lparam, buffer, min( sizeof(RECT), size ));
1044         else
1045         {
1046             NCCALCSIZE_PARAMS *nc = (NCCALCSIZE_PARAMS *)lparam;
1047             WINDOWPOS *wp = nc->lppos;
1048             memcpy( nc, buffer, min( sizeof(*nc), size ));
1049             if (size > sizeof(*nc))
1050             {
1051                 size -= sizeof(*nc);
1052                 memcpy( wp, (NCCALCSIZE_PARAMS*)buffer + 1, min( sizeof(*wp), size ));
1053             }
1054             nc->lppos = wp;  /* restore the original pointer */
1055         }
1056         break;
1057     case EM_GETSEL:
1058     case SBM_GETRANGE:
1059     case CB_GETEDITSEL:
1060         if (wparam)
1061         {
1062             memcpy( (DWORD *)wparam, buffer, min( sizeof(DWORD), size ));
1063             if (size <= sizeof(DWORD)) break;
1064             size -= sizeof(DWORD);
1065             buffer = (DWORD *)buffer + 1;
1066         }
1067         if (lparam) memcpy( (DWORD *)lparam, buffer, min( sizeof(DWORD), size ));
1068         break;
1069     case WM_MDICREATE:
1070     {
1071         MDICREATESTRUCTW *cs = (MDICREATESTRUCTW *)lparam;
1072         LPCWSTR title = cs->szTitle, class = cs->szClass;
1073         memcpy( cs, buffer, min( sizeof(*cs), size ));
1074         cs->szTitle = title;  /* restore the original pointers */
1075         cs->szClass = class;
1076         break;
1077     }
1078     default:
1079         ERR( "should not happen: unexpected message %x\n", message );
1080         break;
1081     }
1082 }
1083
1084
1085 /***********************************************************************
1086  *           reply_message
1087  *
1088  * Send a reply to a sent message.
1089  */
1090 static void reply_message( struct received_message_info *info, LRESULT result, BOOL remove )
1091 {
1092     struct packed_message data;
1093     int i, replied = info->flags & ISMEX_REPLIED;
1094
1095     if (info->flags & ISMEX_NOTIFY) return;  /* notify messages don't get replies */
1096     if (!remove && replied) return;  /* replied already */
1097
1098     data.count = 0;
1099     info->flags |= ISMEX_REPLIED;
1100
1101     if (info->type == MSG_OTHER_PROCESS && !replied)
1102     {
1103         pack_reply( info->msg.hwnd, info->msg.message, info->msg.wParam,
1104                     info->msg.lParam, result, &data );
1105     }
1106
1107     SERVER_START_REQ( reply_message )
1108     {
1109         req->type   = info->type;
1110         req->result = result;
1111         req->remove = remove;
1112         for (i = 0; i < data.count; i++) wine_server_add_data( req, data.data[i], data.size[i] );
1113         wine_server_call( req );
1114     }
1115     SERVER_END_REQ;
1116 }
1117
1118
1119 /***********************************************************************
1120  *           handle_internal_message
1121  *
1122  * Handle an internal Wine message instead of calling the window proc.
1123  */
1124 static LRESULT handle_internal_message( HWND hwnd, UINT msg, WPARAM wparam, LPARAM lparam )
1125 {
1126     if (hwnd == GetDesktopWindow()) return 0;
1127     switch(msg)
1128     {
1129     case WM_WINE_DESTROYWINDOW:
1130         return WIN_DestroyWindow( hwnd );
1131     case WM_WINE_SETWINDOWPOS:
1132         if (USER_Driver.pSetWindowPos)
1133             return USER_Driver.pSetWindowPos( (WINDOWPOS *)lparam );
1134         return 0;
1135     case WM_WINE_SHOWWINDOW:
1136         return ShowWindow( hwnd, wparam );
1137     case WM_WINE_SETPARENT:
1138         return (LRESULT)SetParent( hwnd, (HWND)wparam );
1139     case WM_WINE_SETWINDOWLONG:
1140         return (LRESULT)SetWindowLongW( hwnd, wparam, lparam );
1141     case WM_WINE_ENABLEWINDOW:
1142         return EnableWindow( hwnd, wparam );
1143     case WM_WINE_SETACTIVEWINDOW:
1144         return (LRESULT)SetActiveWindow( (HWND)wparam );
1145     case WM_WINE_KEYBOARD_LL_HOOK:
1146         return HOOK_CallHooks( WH_KEYBOARD_LL, HC_ACTION, wparam, lparam, TRUE );
1147     case WM_WINE_MOUSE_LL_HOOK:
1148         return HOOK_CallHooks( WH_MOUSE_LL, HC_ACTION, wparam, lparam, TRUE );
1149     default:
1150         FIXME( "unknown internal message %x\n", msg );
1151         return 0;
1152     }
1153 }
1154
1155 /* since the WM_DDE_ACK response to a WM_DDE_EXECUTE message should contain the handle
1156  * to the memory handle, we keep track (in the server side) of all pairs of handle
1157  * used (the client passes its value and the content of the memory handle), and
1158  * the server stored both values (the client, and the local one, created after the
1159  * content). When a ACK message is generated, the list of pair is searched for a
1160  * matching pair, so that the client memory handle can be returned.
1161  */
1162 struct DDE_pair {
1163     HGLOBAL     client_hMem;
1164     HGLOBAL     server_hMem;
1165 };
1166
1167 static      struct DDE_pair*    dde_pairs;
1168 static      int                 dde_num_alloc;
1169 static      int                 dde_num_used;
1170
1171 static CRITICAL_SECTION dde_crst;
1172 static CRITICAL_SECTION_DEBUG critsect_debug =
1173 {
1174     0, 0, &dde_crst,
1175     { &critsect_debug.ProcessLocksList, &critsect_debug.ProcessLocksList },
1176       0, 0, { 0, (DWORD)(__FILE__ ": dde_crst") }
1177 };
1178 static CRITICAL_SECTION dde_crst = { &critsect_debug, -1, 0, 0, 0, 0 };
1179
1180 static BOOL dde_add_pair(HGLOBAL chm, HGLOBAL shm)
1181 {
1182     int  i;
1183 #define GROWBY  4
1184
1185     EnterCriticalSection(&dde_crst);
1186
1187     /* now remember the pair of hMem on both sides */
1188     if (dde_num_used == dde_num_alloc)
1189     {
1190         struct DDE_pair* tmp;
1191         if (dde_pairs)
1192             tmp  = HeapReAlloc( GetProcessHeap(), 0, dde_pairs,
1193                                             (dde_num_alloc + GROWBY) * sizeof(struct DDE_pair));
1194         else
1195             tmp  = HeapAlloc( GetProcessHeap(), 0,
1196                                             (dde_num_alloc + GROWBY) * sizeof(struct DDE_pair));
1197
1198         if (!tmp)
1199         {
1200             LeaveCriticalSection(&dde_crst);
1201             return FALSE;
1202         }
1203         dde_pairs = tmp;
1204         /* zero out newly allocated part */
1205         memset(&dde_pairs[dde_num_alloc], 0, GROWBY * sizeof(struct DDE_pair));
1206         dde_num_alloc += GROWBY;
1207     }
1208 #undef GROWBY
1209     for (i = 0; i < dde_num_alloc; i++)
1210     {
1211         if (dde_pairs[i].server_hMem == 0)
1212         {
1213             dde_pairs[i].client_hMem = chm;
1214             dde_pairs[i].server_hMem = shm;
1215             dde_num_used++;
1216             break;
1217         }
1218     }
1219     LeaveCriticalSection(&dde_crst);
1220     return TRUE;
1221 }
1222
1223 static HGLOBAL dde_get_pair(HGLOBAL shm)
1224 {
1225     int  i;
1226     HGLOBAL     ret = 0;
1227
1228     EnterCriticalSection(&dde_crst);
1229     for (i = 0; i < dde_num_alloc; i++)
1230     {
1231         if (dde_pairs[i].server_hMem == shm)
1232         {
1233             /* free this pair */
1234             dde_pairs[i].server_hMem = 0;
1235             dde_num_used--;
1236             ret = dde_pairs[i].client_hMem;
1237             break;
1238         }
1239     }
1240     LeaveCriticalSection(&dde_crst);
1241     return ret;
1242 }
1243
1244 /***********************************************************************
1245  *              post_dde_message
1246  *
1247  * Post a DDE message
1248  */
1249 static BOOL post_dde_message( DWORD dest_tid, struct packed_message *data, const struct send_message_info *info )
1250 {
1251     void*       ptr = NULL;
1252     int         size = 0;
1253     UINT        uiLo, uiHi;
1254     LPARAM      lp = 0;
1255     HGLOBAL     hunlock = 0;
1256     int         i;
1257     DWORD       res;
1258
1259     if (!UnpackDDElParam( info->msg, info->lparam, &uiLo, &uiHi ))
1260         return FALSE;
1261
1262     lp = info->lparam;
1263     switch (info->msg)
1264     {
1265         /* DDE messages which don't require packing are:
1266          * WM_DDE_INITIATE
1267          * WM_DDE_TERMINATE
1268          * WM_DDE_REQUEST
1269          * WM_DDE_UNADVISE
1270          */
1271     case WM_DDE_ACK:
1272         if (HIWORD(uiHi))
1273         {
1274             /* uiHi should contain a hMem from WM_DDE_EXECUTE */
1275             HGLOBAL h = dde_get_pair( (HANDLE)uiHi );
1276             if (h)
1277             {
1278                 /* send back the value of h on the other side */
1279                 push_data( data, &h, sizeof(HGLOBAL) );
1280                 lp = uiLo;
1281                 TRACE( "send dde-ack %x %08x => %08lx\n", uiLo, uiHi, (DWORD)h );
1282             }
1283         }
1284         else
1285         {
1286             /* uiHi should contain either an atom or 0 */
1287             TRACE( "send dde-ack %x atom=%x\n", uiLo, uiHi );
1288             lp = MAKELONG( uiLo, uiHi );
1289         }
1290         break;
1291     case WM_DDE_ADVISE:
1292     case WM_DDE_DATA:
1293     case WM_DDE_POKE:
1294         size = 0;
1295         if (uiLo)
1296         {
1297             size = GlobalSize( (HGLOBAL)uiLo ) ;
1298             if ((info->msg == WM_DDE_ADVISE && size < sizeof(DDEADVISE)) ||
1299                 (info->msg == WM_DDE_DATA   && size < sizeof(DDEDATA))   ||
1300                 (info->msg == WM_DDE_POKE   && size < sizeof(DDEPOKE))
1301                 )
1302             return FALSE;
1303         }
1304         else if (info->msg != WM_DDE_DATA) return FALSE;
1305
1306         lp = uiHi;
1307         if (uiLo)
1308         {
1309             if ((ptr = GlobalLock( (HGLOBAL)uiLo) ))
1310             {
1311                 DDEDATA *dde_data = (DDEDATA *)ptr;
1312                 TRACE("unused %d, fResponse %d, fRelease %d, fDeferUpd %d, fAckReq %d, cfFormat %d\n",
1313                        dde_data->unused, dde_data->fResponse, dde_data->fRelease,
1314                        dde_data->reserved, dde_data->fAckReq, dde_data->cfFormat);
1315                 push_data( data, ptr, size );
1316                 hunlock = (HGLOBAL)uiLo;
1317             }
1318         }
1319         TRACE( "send ddepack %u %x\n", size, uiHi );
1320         break;
1321     case WM_DDE_EXECUTE:
1322         if (info->lparam)
1323         {
1324             if ((ptr = GlobalLock( (HGLOBAL)info->lparam) ))
1325             {
1326                 push_data(data, ptr, GlobalSize( (HGLOBAL)info->lparam ));
1327                 /* so that the other side can send it back on ACK */
1328                 lp = info->lparam;
1329                 hunlock = (HGLOBAL)info->lparam;
1330             }
1331         }
1332         break;
1333     }
1334     SERVER_START_REQ( send_message )
1335     {
1336         req->id      = dest_tid;
1337         req->type    = info->type;
1338         req->flags   = 0;
1339         req->win     = info->hwnd;
1340         req->msg     = info->msg;
1341         req->wparam  = info->wparam;
1342         req->lparam  = lp;
1343         req->time    = GetCurrentTime();
1344         req->timeout = -1;
1345         for (i = 0; i < data->count; i++)
1346             wine_server_add_data( req, data->data[i], data->size[i] );
1347         if ((res = wine_server_call( req )))
1348         {
1349             if (res == STATUS_INVALID_PARAMETER)
1350                 /* FIXME: find a STATUS_ value for this one */
1351                 SetLastError( ERROR_INVALID_THREAD_ID );
1352             else
1353                 SetLastError( RtlNtStatusToDosError(res) );
1354         }
1355         else
1356             FreeDDElParam(info->msg, info->lparam);
1357     }
1358     SERVER_END_REQ;
1359     if (hunlock) GlobalUnlock(hunlock);
1360
1361     return !res;
1362 }
1363
1364 /***********************************************************************
1365  *              unpack_dde_message
1366  *
1367  * Unpack a posted DDE message received from another process.
1368  */
1369 static BOOL unpack_dde_message( HWND hwnd, UINT message, WPARAM *wparam, LPARAM *lparam,
1370                                 void **buffer, size_t size )
1371 {
1372     UINT        uiLo, uiHi;
1373     HGLOBAL     hMem = 0;
1374     void*       ptr;
1375
1376     switch (message)
1377     {
1378     case WM_DDE_ACK:
1379         if (size)
1380         {
1381             /* hMem is being passed */
1382             if (size != sizeof(HGLOBAL)) return FALSE;
1383             if (!buffer || !*buffer) return FALSE;
1384             uiLo = *lparam;
1385             memcpy( &hMem, *buffer, size );
1386             uiHi = (UINT)hMem;
1387             TRACE("recv dde-ack %x mem=%x[%lx]\n", uiLo, uiHi, GlobalSize( hMem ));
1388         }
1389         else
1390         {
1391             uiLo = LOWORD( *lparam );
1392             uiHi = HIWORD( *lparam );
1393             TRACE("recv dde-ack %x atom=%x\n", uiLo, uiHi);
1394         }
1395         *lparam = PackDDElParam( WM_DDE_ACK, uiLo, uiHi );
1396         break;
1397     case WM_DDE_ADVISE:
1398     case WM_DDE_DATA:
1399     case WM_DDE_POKE:
1400         if ((!buffer || !*buffer) && message != WM_DDE_DATA) return FALSE;
1401         uiHi = *lparam;
1402         TRACE( "recv ddepack %u %x\n", size, uiHi );
1403         if (size)
1404         {
1405             hMem = GlobalAlloc( GMEM_MOVEABLE|GMEM_DDESHARE, size );
1406             if (hMem && (ptr = GlobalLock( hMem )))
1407             {
1408                 memcpy( ptr, *buffer, size );
1409                 GlobalUnlock( hMem );
1410             }
1411             else return FALSE;
1412         }
1413         uiLo = (UINT)hMem;
1414
1415         *lparam = PackDDElParam( message, uiLo, uiHi );
1416         break;
1417     case WM_DDE_EXECUTE:
1418         if (size)
1419         {
1420             if (!buffer || !*buffer) return FALSE;
1421             hMem = GlobalAlloc( GMEM_MOVEABLE|GMEM_DDESHARE, size );
1422             if (hMem && (ptr = GlobalLock( hMem )))
1423             {
1424                 memcpy( ptr, *buffer, size );
1425                 GlobalUnlock( hMem );
1426                 TRACE( "exec: pairing c=%08lx s=%08lx\n", *lparam, (DWORD)hMem );
1427                 if (!dde_add_pair( (HGLOBAL)*lparam, hMem ))
1428                 {
1429                     GlobalFree( hMem );
1430                     return FALSE;
1431                 }
1432             }
1433         } else return FALSE;
1434         *lparam = (LPARAM)hMem;
1435         break;
1436     }
1437     return TRUE;
1438 }
1439
1440 /***********************************************************************
1441  *           call_window_proc
1442  *
1443  * Call a window procedure and the corresponding hooks.
1444  */
1445 static LRESULT call_window_proc( HWND hwnd, UINT msg, WPARAM wparam, LPARAM lparam,
1446                                  BOOL unicode, BOOL same_thread )
1447 {
1448     LRESULT result = 0;
1449     WNDPROC winproc;
1450     CWPSTRUCT cwp;
1451     CWPRETSTRUCT cwpret;
1452     MESSAGEQUEUE *queue = QUEUE_Current();
1453
1454     if (queue->recursion_count > MAX_SENDMSG_RECURSION) return 0;
1455     queue->recursion_count++;
1456
1457     if (msg & 0x80000000)
1458     {
1459         result = handle_internal_message( hwnd, msg, wparam, lparam );
1460         goto done;
1461     }
1462
1463     /* first the WH_CALLWNDPROC hook */
1464     hwnd = WIN_GetFullHandle( hwnd );
1465     cwp.lParam  = lparam;
1466     cwp.wParam  = wparam;
1467     cwp.message = msg;
1468     cwp.hwnd    = hwnd;
1469     HOOK_CallHooks( WH_CALLWNDPROC, HC_ACTION, same_thread, (LPARAM)&cwp, unicode );
1470
1471     /* now call the window procedure */
1472     if (unicode)
1473     {
1474         if (!(winproc = (WNDPROC)GetWindowLongPtrW( hwnd, GWLP_WNDPROC ))) goto done;
1475         result = CallWindowProcW( winproc, hwnd, msg, wparam, lparam );
1476     }
1477     else
1478     {
1479         if (!(winproc = (WNDPROC)GetWindowLongPtrA( hwnd, GWLP_WNDPROC ))) goto done;
1480         result = CallWindowProcA( winproc, hwnd, msg, wparam, lparam );
1481     }
1482
1483     /* and finally the WH_CALLWNDPROCRET hook */
1484     cwpret.lResult = result;
1485     cwpret.lParam  = lparam;
1486     cwpret.wParam  = wparam;
1487     cwpret.message = msg;
1488     cwpret.hwnd    = hwnd;
1489     HOOK_CallHooks( WH_CALLWNDPROCRET, HC_ACTION, same_thread, (LPARAM)&cwpret, unicode );
1490  done:
1491     queue->recursion_count--;
1492     return result;
1493 }
1494
1495
1496 /***********************************************************************
1497  *           process_hardware_message
1498  *
1499  * Process a hardware message; return TRUE if message should be passed on to the app
1500  */
1501 static BOOL process_hardware_message( MSG *msg, ULONG_PTR extra_info, HWND hwnd,
1502                                       UINT first, UINT last, BOOL remove )
1503 {
1504     BOOL ret;
1505
1506     if (!MSG_process_raw_hardware_message( msg, extra_info, hwnd, first, last, remove ))
1507         return FALSE;
1508
1509     ret = MSG_process_cooked_hardware_message( msg, extra_info, remove );
1510
1511     /* tell the server we have passed it to the app
1512      * (even though we may end up dropping it later on)
1513      */
1514     SERVER_START_REQ( reply_message )
1515     {
1516         req->type   = MSG_HARDWARE;
1517         req->result = 0;
1518         req->remove = remove || !ret;
1519         wine_server_call( req );
1520     }
1521     SERVER_END_REQ;
1522     return ret;
1523 }
1524
1525
1526 /***********************************************************************
1527  *           call_sendmsg_callback
1528  *
1529  * Call the callback function of SendMessageCallback.
1530  */
1531 static inline void call_sendmsg_callback( SENDASYNCPROC callback, HWND hwnd, UINT msg,
1532                                           ULONG_PTR data, LRESULT result )
1533 {
1534     if (TRACE_ON(relay))
1535         DPRINTF( "%04lx:Call message callback %p (hwnd=%p,msg=%s,data=%08lx,result=%08lx)\n",
1536                  GetCurrentThreadId(), callback, hwnd, SPY_GetMsgName( msg, hwnd ),
1537                  data, result );
1538     callback( hwnd, msg, data, result );
1539     if (TRACE_ON(relay))
1540         DPRINTF( "%04lx:Ret  message callback %p (hwnd=%p,msg=%s,data=%08lx,result=%08lx)\n",
1541                  GetCurrentThreadId(), callback, hwnd, SPY_GetMsgName( msg, hwnd ),
1542                  data, result );
1543 }
1544
1545
1546 /***********************************************************************
1547  *              get_hook_proc
1548  *
1549  * Retrieve the hook procedure real value for a module-relative proc
1550  */
1551 static void *get_hook_proc( void *proc, const WCHAR *module )
1552 {
1553     HMODULE mod;
1554
1555     if (!(mod = GetModuleHandleW(module)))
1556     {
1557         TRACE( "loading %s\n", debugstr_w(module) );
1558         /* FIXME: the library will never be freed */
1559         if (!(mod = LoadLibraryW(module))) return NULL;
1560     }
1561     return (char *)mod + (ULONG_PTR)proc;
1562 }
1563
1564
1565 /***********************************************************************
1566  *           MSG_peek_message
1567  *
1568  * Peek for a message matching the given parameters. Return FALSE if none available.
1569  * All pending sent messages are processed before returning.
1570  */
1571 BOOL MSG_peek_message( MSG *msg, HWND hwnd, UINT first, UINT last, int flags )
1572 {
1573     LRESULT result;
1574     ULONG_PTR extra_info = 0;
1575     MESSAGEQUEUE *queue = QUEUE_Current();
1576     struct received_message_info info, *old_info;
1577
1578     if (!first && !last) last = ~0;
1579
1580     for (;;)
1581     {
1582         NTSTATUS res;
1583         void *buffer = NULL;
1584         size_t size = 0, buffer_size = 0;
1585
1586         do  /* loop while buffer is too small */
1587         {
1588             if (buffer_size && !(buffer = HeapAlloc( GetProcessHeap(), 0, buffer_size )))
1589                 return FALSE;
1590             SERVER_START_REQ( get_message )
1591             {
1592                 req->flags     = flags;
1593                 req->get_win   = hwnd;
1594                 req->get_first = first;
1595                 req->get_last  = last;
1596                 if (buffer_size) wine_server_set_reply( req, buffer, buffer_size );
1597                 if (!(res = wine_server_call( req )))
1598                 {
1599                     size = wine_server_reply_size( reply );
1600                     info.type        = reply->type;
1601                     info.msg.hwnd    = reply->win;
1602                     info.msg.message = reply->msg;
1603                     info.msg.wParam  = reply->wparam;
1604                     info.msg.lParam  = reply->lparam;
1605                     info.msg.time    = reply->time;
1606                     info.msg.pt.x    = reply->x;
1607                     info.msg.pt.y    = reply->y;
1608                     info.hook        = reply->hook;
1609                     info.hook_proc   = reply->hook_proc;
1610                     extra_info       = reply->info;
1611                 }
1612                 else
1613                 {
1614                     HeapFree( GetProcessHeap(), 0, buffer );
1615                     buffer_size = reply->total;
1616                 }
1617             }
1618             SERVER_END_REQ;
1619         } while (res == STATUS_BUFFER_OVERFLOW);
1620
1621         if (res) return FALSE;
1622
1623         TRACE( "got type %d msg %x (%s) hwnd %p wp %x lp %lx\n",
1624                info.type, info.msg.message,
1625                (info.type == MSG_WINEVENT) ? "MSG_WINEVENT" : SPY_GetMsgName(info.msg.message, info.msg.hwnd),
1626                info.msg.hwnd, info.msg.wParam, info.msg.lParam );
1627
1628         switch(info.type)
1629         {
1630         case MSG_ASCII:
1631         case MSG_UNICODE:
1632             info.flags = ISMEX_SEND;
1633             break;
1634         case MSG_NOTIFY:
1635             info.flags = ISMEX_NOTIFY;
1636             break;
1637         case MSG_CALLBACK:
1638             info.flags = ISMEX_CALLBACK;
1639             break;
1640         case MSG_CALLBACK_RESULT:
1641             call_sendmsg_callback( (SENDASYNCPROC)info.msg.wParam, info.msg.hwnd,
1642                                    info.msg.message, extra_info, info.msg.lParam );
1643             goto next;
1644         case MSG_WINEVENT:
1645             if (size)
1646             {
1647                 WCHAR module[MAX_PATH];
1648                 size = min( size, (MAX_PATH - 1) * sizeof(WCHAR) );
1649                 memcpy( module, buffer, size );
1650                 module[size / sizeof(WCHAR)] = 0;
1651                 if (!(info.hook_proc = get_hook_proc( info.hook_proc, module )))
1652                 {
1653                     ERR( "invalid winevent hook module name %s\n", debugstr_w(module) );
1654                     goto next;
1655                 }
1656             }
1657             if (TRACE_ON(relay))
1658                 DPRINTF( "%04lx:Call winevent proc %p (hook=%p,event=%x,hwnd=%p,object_id=%x,child_id=%lx,tid=%04lx,time=%lx)\n",
1659                          GetCurrentThreadId(), info.hook_proc,
1660                          info.hook, info.msg.message, info.msg.hwnd, info.msg.wParam,
1661                          info.msg.lParam, extra_info, info.msg.time);
1662
1663             info.hook_proc( info.hook, info.msg.message, info.msg.hwnd, info.msg.wParam,
1664                             info.msg.lParam, extra_info, info.msg.time );
1665
1666             if (TRACE_ON(relay))
1667                 DPRINTF( "%04lx:Ret  winevent proc %p (hook=%p,event=%x,hwnd=%p,object_id=%x,child_id=%lx,tid=%04lx,time=%lx)\n",
1668                          GetCurrentThreadId(), info.hook_proc,
1669                          info.hook, info.msg.message, info.msg.hwnd, info.msg.wParam,
1670                          info.msg.lParam, extra_info, info.msg.time);
1671             goto next;
1672         case MSG_OTHER_PROCESS:
1673             info.flags = ISMEX_SEND;
1674             if (!unpack_message( info.msg.hwnd, info.msg.message, &info.msg.wParam,
1675                                  &info.msg.lParam, &buffer, size ))
1676             {
1677                 ERR( "invalid packed message %x (%s) hwnd %p wp %x lp %lx size %d\n",
1678                      info.msg.message, SPY_GetMsgName(info.msg.message, info.msg.hwnd), info.msg.hwnd,
1679                      info.msg.wParam, info.msg.lParam, size );
1680                 /* ignore it */
1681                 reply_message( &info, 0, TRUE );
1682                 goto next;
1683             }
1684             break;
1685         case MSG_HARDWARE:
1686             if (!process_hardware_message( &info.msg, extra_info,
1687                                            hwnd, first, last, flags & GET_MSG_REMOVE ))
1688             {
1689                 TRACE("dropping msg %x\n", info.msg.message );
1690                 goto next;  /* ignore it */
1691             }
1692             queue->GetMessagePosVal = MAKELONG( info.msg.pt.x, info.msg.pt.y );
1693             /* fall through */
1694         case MSG_POSTED:
1695             queue->GetMessageExtraInfoVal = extra_info;
1696             if (info.msg.message >= WM_DDE_FIRST && info.msg.message <= WM_DDE_LAST)
1697             {
1698                 if (!unpack_dde_message( info.msg.hwnd, info.msg.message, &info.msg.wParam,
1699                                          &info.msg.lParam, &buffer, size ))
1700                 {
1701                     ERR( "invalid packed dde-message %x (%s) hwnd %p wp %x lp %lx size %d\n",
1702                          info.msg.message, SPY_GetMsgName(info.msg.message, info.msg.hwnd),
1703                          info.msg.hwnd, info.msg.wParam, info.msg.lParam, size );
1704                     goto next;  /* ignore it */
1705                 }
1706             }
1707             *msg = info.msg;
1708             HeapFree( GetProcessHeap(), 0, buffer );
1709             return TRUE;
1710         }
1711
1712         /* if we get here, we have a sent message; call the window procedure */
1713         old_info = queue->receive_info;
1714         queue->receive_info = &info;
1715         result = call_window_proc( info.msg.hwnd, info.msg.message, info.msg.wParam,
1716                                    info.msg.lParam, (info.type != MSG_ASCII), FALSE );
1717         reply_message( &info, result, TRUE );
1718         queue->receive_info = old_info;
1719     next:
1720         HeapFree( GetProcessHeap(), 0, buffer );
1721     }
1722 }
1723
1724
1725 /***********************************************************************
1726  *           wait_message_reply
1727  *
1728  * Wait until a sent message gets replied to.
1729  */
1730 static void wait_message_reply( UINT flags )
1731 {
1732     MESSAGEQUEUE *queue;
1733
1734     if (!(queue = QUEUE_Current())) return;
1735
1736     for (;;)
1737     {
1738         unsigned int wake_bits = 0, changed_bits = 0;
1739         DWORD dwlc, res;
1740
1741         SERVER_START_REQ( set_queue_mask )
1742         {
1743             req->wake_mask    = QS_SMRESULT | ((flags & SMTO_BLOCK) ? 0 : QS_SENDMESSAGE);
1744             req->changed_mask = req->wake_mask;
1745             req->skip_wait    = 1;
1746             if (!wine_server_call( req ))
1747             {
1748                 wake_bits    = reply->wake_bits;
1749                 changed_bits = reply->changed_bits;
1750             }
1751         }
1752         SERVER_END_REQ;
1753
1754         if (wake_bits & QS_SMRESULT) return;  /* got a result */
1755         if (wake_bits & QS_SENDMESSAGE)
1756         {
1757             /* Process the sent message immediately */
1758             MSG msg;
1759             MSG_peek_message( &msg, 0, 0, 0, GET_MSG_REMOVE | GET_MSG_SENT_ONLY );
1760             continue;
1761         }
1762
1763         /* now wait for it */
1764
1765         ReleaseThunkLock( &dwlc );
1766
1767         if (USER_Driver.pMsgWaitForMultipleObjectsEx)
1768             res = USER_Driver.pMsgWaitForMultipleObjectsEx( 1, &queue->server_queue,
1769                                                             INFINITE, 0, 0 );
1770         else
1771             res = WaitForSingleObject( queue->server_queue, INFINITE );
1772
1773         if (dwlc) RestoreThunkLock( dwlc );
1774     }
1775 }
1776
1777 /***********************************************************************
1778  *              put_message_in_queue
1779  *
1780  * Put a sent message into the destination queue.
1781  * For inter-process message, reply_size is set to expected size of reply data.
1782  */
1783 static BOOL put_message_in_queue( DWORD dest_tid, const struct send_message_info *info,
1784                                   size_t *reply_size )
1785 {
1786     struct packed_message data;
1787     unsigned int res;
1788     int i, timeout = -1;
1789
1790     if (info->type != MSG_NOTIFY &&
1791         info->type != MSG_CALLBACK &&
1792         info->type != MSG_POSTED &&
1793         info->timeout != INFINITE)
1794         timeout = info->timeout;
1795
1796     data.count = 0;
1797     if (info->type == MSG_OTHER_PROCESS)
1798     {
1799         *reply_size = pack_message( info->hwnd, info->msg, info->wparam, info->lparam, &data );
1800         if (data.count == -1)
1801         {
1802             WARN( "cannot pack message %x\n", info->msg );
1803             return FALSE;
1804         }
1805     }
1806     else if (info->type == MSG_POSTED && info->msg >= WM_DDE_FIRST && info->msg <= WM_DDE_LAST)
1807     {
1808         return post_dde_message( dest_tid, &data, info );
1809     }
1810
1811     SERVER_START_REQ( send_message )
1812     {
1813         req->id      = dest_tid;
1814         req->type    = info->type;
1815         req->flags   = 0;
1816         req->win     = info->hwnd;
1817         req->msg     = info->msg;
1818         req->wparam  = info->wparam;
1819         req->lparam  = info->lparam;
1820         req->time    = GetCurrentTime();
1821         req->timeout = timeout;
1822
1823         if (info->type == MSG_CALLBACK)
1824         {
1825             req->callback = info->callback;
1826             req->info     = info->data;
1827         }
1828
1829         if (info->flags & SMTO_ABORTIFHUNG) req->flags |= SEND_MSG_ABORT_IF_HUNG;
1830         for (i = 0; i < data.count; i++) wine_server_add_data( req, data.data[i], data.size[i] );
1831         if ((res = wine_server_call( req )))
1832         {
1833             if (res == STATUS_INVALID_PARAMETER)
1834                 /* FIXME: find a STATUS_ value for this one */
1835                 SetLastError( ERROR_INVALID_THREAD_ID );
1836             else
1837                 SetLastError( RtlNtStatusToDosError(res) );
1838         }
1839     }
1840     SERVER_END_REQ;
1841     return !res;
1842 }
1843
1844
1845 /***********************************************************************
1846  *              retrieve_reply
1847  *
1848  * Retrieve a message reply from the server.
1849  */
1850 static LRESULT retrieve_reply( const struct send_message_info *info,
1851                                size_t reply_size, LRESULT *result )
1852 {
1853     NTSTATUS status;
1854     void *reply_data = NULL;
1855
1856     if (reply_size)
1857     {
1858         if (!(reply_data = HeapAlloc( GetProcessHeap(), 0, reply_size )))
1859         {
1860             WARN( "no memory for reply %d bytes, will be truncated\n", reply_size );
1861             reply_size = 0;
1862         }
1863     }
1864     SERVER_START_REQ( get_message_reply )
1865     {
1866         req->cancel = 1;
1867         if (reply_size) wine_server_set_reply( req, reply_data, reply_size );
1868         if (!(status = wine_server_call( req ))) *result = reply->result;
1869         reply_size = wine_server_reply_size( reply );
1870     }
1871     SERVER_END_REQ;
1872     if (!status && reply_size)
1873         unpack_reply( info->hwnd, info->msg, info->wparam, info->lparam, reply_data, reply_size );
1874
1875     HeapFree( GetProcessHeap(), 0, reply_data );
1876
1877     TRACE( "hwnd %p msg %x (%s) wp %x lp %lx got reply %lx (err=%ld)\n",
1878            info->hwnd, info->msg, SPY_GetMsgName(info->msg, info->hwnd), info->wparam,
1879            info->lparam, *result, status );
1880
1881     /* MSDN states that last error is 0 on timeout, but at least NT4 returns ERROR_TIMEOUT */
1882     if (status) SetLastError( RtlNtStatusToDosError(status) );
1883     return !status;
1884 }
1885
1886
1887 /***********************************************************************
1888  *              send_inter_thread_message
1889  */
1890 static LRESULT send_inter_thread_message( DWORD dest_tid, const struct send_message_info *info,
1891                                           LRESULT *res_ptr )
1892 {
1893     LRESULT ret;
1894     int locks;
1895     size_t reply_size = 0;
1896
1897     TRACE( "hwnd %p msg %x (%s) wp %x lp %lx\n",
1898            info->hwnd, info->msg, SPY_GetMsgName(info->msg, info->hwnd), info->wparam, info->lparam );
1899
1900     if (!put_message_in_queue( dest_tid, info, &reply_size )) return 0;
1901
1902     /* there's no reply to wait for on notify/callback messages */
1903     if (info->type == MSG_NOTIFY || info->type == MSG_CALLBACK) return 1;
1904
1905     locks = WIN_SuspendWndsLock();
1906
1907     wait_message_reply( info->flags );
1908     ret = retrieve_reply( info, reply_size, res_ptr );
1909
1910     WIN_RestoreWndsLock( locks );
1911     return ret;
1912 }
1913
1914
1915 /***********************************************************************
1916  *              MSG_SendInternalMessageTimeout
1917  *
1918  * Same as SendMessageTimeoutW but sends the message to a specific thread
1919  * without requiring a window handle. Only works for internal Wine messages.
1920  */
1921 LRESULT MSG_SendInternalMessageTimeout( DWORD dest_pid, DWORD dest_tid,
1922                                         UINT msg, WPARAM wparam, LPARAM lparam,
1923                                         UINT flags, UINT timeout, PDWORD_PTR res_ptr )
1924 {
1925     struct send_message_info info;
1926     LRESULT ret, result;
1927
1928     assert( msg & 0x80000000 );  /* must be an internal Wine message */
1929
1930     info.type    = MSG_UNICODE;
1931     info.hwnd    = 0;
1932     info.msg     = msg;
1933     info.wparam  = wparam;
1934     info.lparam  = lparam;
1935     info.flags   = flags;
1936     info.timeout = timeout;
1937
1938     if (USER_IsExitingThread( dest_tid )) return 0;
1939
1940     if (dest_tid == GetCurrentThreadId())
1941     {
1942         result = handle_internal_message( 0, msg, wparam, lparam );
1943         ret = 1;
1944     }
1945     else
1946     {
1947         if (dest_pid != GetCurrentProcessId()) info.type = MSG_OTHER_PROCESS;
1948         ret = send_inter_thread_message( dest_tid, &info, &result );
1949     }
1950     if (ret && res_ptr) *res_ptr = result;
1951     return ret;
1952 }
1953
1954
1955 /***********************************************************************
1956  *              SendMessageTimeoutW  (USER32.@)
1957  */
1958 LRESULT WINAPI SendMessageTimeoutW( HWND hwnd, UINT msg, WPARAM wparam, LPARAM lparam,
1959                                     UINT flags, UINT timeout, PDWORD_PTR res_ptr )
1960 {
1961     struct send_message_info info;
1962     DWORD dest_tid, dest_pid;
1963     LRESULT ret, result;
1964
1965     info.type    = MSG_UNICODE;
1966     info.hwnd    = hwnd;
1967     info.msg     = msg;
1968     info.wparam  = wparam;
1969     info.lparam  = lparam;
1970     info.flags   = flags;
1971     info.timeout = timeout;
1972
1973     if (is_broadcast(hwnd))
1974     {
1975         EnumWindows( broadcast_message_callback, (LPARAM)&info );
1976         if (res_ptr) *res_ptr = 1;
1977         return 1;
1978     }
1979
1980     if (!(dest_tid = GetWindowThreadProcessId( hwnd, &dest_pid ))) return 0;
1981
1982     if (USER_IsExitingThread( dest_tid )) return 0;
1983
1984     SPY_EnterMessage( SPY_SENDMESSAGE, hwnd, msg, wparam, lparam );
1985
1986     if (dest_tid == GetCurrentThreadId())
1987     {
1988         result = call_window_proc( hwnd, msg, wparam, lparam, TRUE, TRUE );
1989         ret = 1;
1990     }
1991     else
1992     {
1993         if (dest_pid != GetCurrentProcessId()) info.type = MSG_OTHER_PROCESS;
1994         ret = send_inter_thread_message( dest_tid, &info, &result );
1995     }
1996
1997     SPY_ExitMessage( SPY_RESULT_OK, hwnd, msg, result, wparam, lparam );
1998     if (ret && res_ptr) *res_ptr = result;
1999     return ret;
2000 }
2001
2002
2003 /***********************************************************************
2004  *              SendMessageTimeoutA  (USER32.@)
2005  */
2006 LRESULT WINAPI SendMessageTimeoutA( HWND hwnd, UINT msg, WPARAM wparam, LPARAM lparam,
2007                                     UINT flags, UINT timeout, PDWORD_PTR res_ptr )
2008 {
2009     struct send_message_info info;
2010     DWORD dest_tid, dest_pid;
2011     LRESULT ret, result;
2012
2013     info.type    = MSG_ASCII;
2014     info.hwnd    = hwnd;
2015     info.msg     = msg;
2016     info.wparam  = wparam;
2017     info.lparam  = lparam;
2018     info.flags   = flags;
2019     info.timeout = timeout;
2020
2021     if (is_broadcast(hwnd))
2022     {
2023         EnumWindows( broadcast_message_callback, (LPARAM)&info );
2024         if (res_ptr) *res_ptr = 1;
2025         return 1;
2026     }
2027
2028     if (!(dest_tid = GetWindowThreadProcessId( hwnd, &dest_pid ))) return 0;
2029
2030     if (USER_IsExitingThread( dest_tid )) return 0;
2031
2032     SPY_EnterMessage( SPY_SENDMESSAGE, hwnd, msg, wparam, lparam );
2033
2034     if (dest_tid == GetCurrentThreadId())
2035     {
2036         result = call_window_proc( hwnd, msg, wparam, lparam, FALSE, TRUE );
2037         ret = 1;
2038     }
2039     else if (dest_pid == GetCurrentProcessId())
2040     {
2041         ret = send_inter_thread_message( dest_tid, &info, &result );
2042     }
2043     else
2044     {
2045         /* inter-process message: need to map to Unicode */
2046         info.type = MSG_OTHER_PROCESS;
2047         if (is_unicode_message( info.msg ))
2048         {
2049             if (WINPROC_MapMsg32ATo32W( info.hwnd, info.msg, &info.wparam, &info.lparam ) == -1)
2050                 return 0;
2051             ret = send_inter_thread_message( dest_tid, &info, &result );
2052             result = WINPROC_UnmapMsg32ATo32W( info.hwnd, info.msg, info.wparam,
2053                                                info.lparam, result );
2054         }
2055         else ret = send_inter_thread_message( dest_tid, &info, &result );
2056     }
2057     SPY_ExitMessage( SPY_RESULT_OK, hwnd, msg, result, wparam, lparam );
2058     if (ret && res_ptr) *res_ptr = result;
2059     return ret;
2060 }
2061
2062
2063 /***********************************************************************
2064  *              SendMessageW  (USER32.@)
2065  */
2066 LRESULT WINAPI SendMessageW( HWND hwnd, UINT msg, WPARAM wparam, LPARAM lparam )
2067 {
2068     LRESULT res = 0;
2069     SendMessageTimeoutW( hwnd, msg, wparam, lparam, SMTO_NORMAL, INFINITE, &res );
2070     return res;
2071 }
2072
2073
2074 /***********************************************************************
2075  *              SendMessageA  (USER32.@)
2076  */
2077 LRESULT WINAPI SendMessageA( HWND hwnd, UINT msg, WPARAM wparam, LPARAM lparam )
2078 {
2079     LRESULT res = 0;
2080     SendMessageTimeoutA( hwnd, msg, wparam, lparam, SMTO_NORMAL, INFINITE, &res );
2081     return res;
2082 }
2083
2084
2085 /***********************************************************************
2086  *              SendNotifyMessageA  (USER32.@)
2087  */
2088 BOOL WINAPI SendNotifyMessageA( HWND hwnd, UINT msg, WPARAM wparam, LPARAM lparam )
2089 {
2090     return SendNotifyMessageW( hwnd, msg, map_wparam_AtoW( msg, wparam ), lparam );
2091 }
2092
2093
2094 /***********************************************************************
2095  *              SendNotifyMessageW  (USER32.@)
2096  */
2097 BOOL WINAPI SendNotifyMessageW( HWND hwnd, UINT msg, WPARAM wparam, LPARAM lparam )
2098 {
2099     struct send_message_info info;
2100     DWORD dest_tid;
2101     LRESULT result;
2102
2103     if (is_pointer_message(msg))
2104     {
2105         SetLastError( ERROR_MESSAGE_SYNC_ONLY );
2106         return FALSE;
2107     }
2108
2109     info.type    = MSG_NOTIFY;
2110     info.hwnd    = hwnd;
2111     info.msg     = msg;
2112     info.wparam  = wparam;
2113     info.lparam  = lparam;
2114     info.flags   = 0;
2115
2116     if (is_broadcast(hwnd))
2117     {
2118         EnumWindows( broadcast_message_callback, (LPARAM)&info );
2119         return TRUE;
2120     }
2121
2122     if (!(dest_tid = GetWindowThreadProcessId( hwnd, NULL ))) return FALSE;
2123
2124     if (USER_IsExitingThread( dest_tid )) return TRUE;
2125
2126     if (dest_tid == GetCurrentThreadId())
2127     {
2128         call_window_proc( hwnd, msg, wparam, lparam, TRUE, TRUE );
2129         return TRUE;
2130     }
2131     return send_inter_thread_message( dest_tid, &info, &result );
2132 }
2133
2134
2135 /***********************************************************************
2136  *              SendMessageCallbackA  (USER32.@)
2137  */
2138 BOOL WINAPI SendMessageCallbackA( HWND hwnd, UINT msg, WPARAM wparam, LPARAM lparam,
2139                                   SENDASYNCPROC callback, ULONG_PTR data )
2140 {
2141     return SendMessageCallbackW( hwnd, msg, map_wparam_AtoW( msg, wparam ),
2142                                  lparam, callback, data );
2143 }
2144
2145
2146 /***********************************************************************
2147  *              SendMessageCallbackW  (USER32.@)
2148  */
2149 BOOL WINAPI SendMessageCallbackW( HWND hwnd, UINT msg, WPARAM wparam, LPARAM lparam,
2150                                   SENDASYNCPROC callback, ULONG_PTR data )
2151 {
2152     struct send_message_info info;
2153     LRESULT result;
2154     DWORD dest_tid;
2155
2156     if (is_pointer_message(msg))
2157     {
2158         SetLastError( ERROR_MESSAGE_SYNC_ONLY );
2159         return FALSE;
2160     }
2161
2162     info.type     = MSG_CALLBACK;
2163     info.hwnd     = hwnd;
2164     info.msg      = msg;
2165     info.wparam   = wparam;
2166     info.lparam   = lparam;
2167     info.callback = callback;
2168     info.data     = data;
2169     info.flags    = 0;
2170
2171     if (is_broadcast(hwnd))
2172     {
2173         EnumWindows( broadcast_message_callback, (LPARAM)&info );
2174         return TRUE;
2175     }
2176
2177     if (!(dest_tid = GetWindowThreadProcessId( hwnd, NULL ))) return FALSE;
2178
2179     if (USER_IsExitingThread( dest_tid )) return TRUE;
2180
2181     if (dest_tid == GetCurrentThreadId())
2182     {
2183         result = call_window_proc( hwnd, msg, wparam, lparam, TRUE, TRUE );
2184         call_sendmsg_callback( callback, hwnd, msg, data, result );
2185         return TRUE;
2186     }
2187     FIXME( "callback will not be called\n" );
2188     return send_inter_thread_message( dest_tid, &info, &result );
2189 }
2190
2191
2192 /***********************************************************************
2193  *              ReplyMessage  (USER32.@)
2194  */
2195 BOOL WINAPI ReplyMessage( LRESULT result )
2196 {
2197     MESSAGEQUEUE *queue = QUEUE_Current();
2198     struct received_message_info *info = queue->receive_info;
2199
2200     if (!info) return FALSE;
2201     reply_message( info, result, FALSE );
2202     return TRUE;
2203 }
2204
2205
2206 /***********************************************************************
2207  *              InSendMessage  (USER32.@)
2208  */
2209 BOOL WINAPI InSendMessage(void)
2210 {
2211     return (InSendMessageEx(NULL) & (ISMEX_SEND|ISMEX_REPLIED)) == ISMEX_SEND;
2212 }
2213
2214
2215 /***********************************************************************
2216  *              InSendMessageEx  (USER32.@)
2217  */
2218 DWORD WINAPI InSendMessageEx( LPVOID reserved )
2219 {
2220     MESSAGEQUEUE *queue = QUEUE_Current();
2221     struct received_message_info *info = queue->receive_info;
2222
2223     if (info) return info->flags;
2224     return ISMEX_NOSEND;
2225 }
2226
2227
2228 /***********************************************************************
2229  *              PostMessageA  (USER32.@)
2230  */
2231 BOOL WINAPI PostMessageA( HWND hwnd, UINT msg, WPARAM wparam, LPARAM lparam )
2232 {
2233     return PostMessageW( hwnd, msg, map_wparam_AtoW( msg, wparam ), lparam );
2234 }
2235
2236
2237 /***********************************************************************
2238  *              PostMessageW  (USER32.@)
2239  */
2240 BOOL WINAPI PostMessageW( HWND hwnd, UINT msg, WPARAM wparam, LPARAM lparam )
2241 {
2242     struct send_message_info info;
2243     DWORD dest_tid;
2244
2245     if (is_pointer_message( msg ))
2246     {
2247         SetLastError( ERROR_MESSAGE_SYNC_ONLY );
2248         return FALSE;
2249     }
2250
2251     TRACE( "hwnd %p msg %x (%s) wp %x lp %lx\n",
2252            hwnd, msg, SPY_GetMsgName(msg, hwnd), wparam, lparam );
2253
2254     info.type   = MSG_POSTED;
2255     info.hwnd   = hwnd;
2256     info.msg    = msg;
2257     info.wparam = wparam;
2258     info.lparam = lparam;
2259     info.flags  = 0;
2260
2261     if (is_broadcast(hwnd))
2262     {
2263         EnumWindows( broadcast_message_callback, (LPARAM)&info );
2264         return TRUE;
2265     }
2266
2267     if (!hwnd) return PostThreadMessageW( GetCurrentThreadId(), msg, wparam, lparam );
2268
2269     if (!(dest_tid = GetWindowThreadProcessId( hwnd, NULL ))) return FALSE;
2270
2271     if (USER_IsExitingThread( dest_tid )) return TRUE;
2272
2273     return put_message_in_queue( dest_tid, &info, NULL );
2274 }
2275
2276
2277 /**********************************************************************
2278  *              PostThreadMessageA  (USER32.@)
2279  */
2280 BOOL WINAPI PostThreadMessageA( DWORD thread, UINT msg, WPARAM wparam, LPARAM lparam )
2281 {
2282     return PostThreadMessageW( thread, msg, map_wparam_AtoW( msg, wparam ), lparam );
2283 }
2284
2285
2286 /**********************************************************************
2287  *              PostThreadMessageW  (USER32.@)
2288  */
2289 BOOL WINAPI PostThreadMessageW( DWORD thread, UINT msg, WPARAM wparam, LPARAM lparam )
2290 {
2291     struct send_message_info info;
2292
2293     if (is_pointer_message( msg ))
2294     {
2295         SetLastError( ERROR_MESSAGE_SYNC_ONLY );
2296         return FALSE;
2297     }
2298     if (USER_IsExitingThread( thread )) return TRUE;
2299
2300     info.type   = MSG_POSTED;
2301     info.hwnd   = 0;
2302     info.msg    = msg;
2303     info.wparam = wparam;
2304     info.lparam = lparam;
2305     info.flags  = 0;
2306     return put_message_in_queue( thread, &info, NULL );
2307 }
2308
2309
2310 /***********************************************************************
2311  *              PostQuitMessage  (USER32.@)
2312  */
2313 void WINAPI PostQuitMessage( INT exitCode )
2314 {
2315     PostThreadMessageW( GetCurrentThreadId(), WM_QUIT, exitCode, 0 );
2316 }
2317
2318
2319 /***********************************************************************
2320  *              PeekMessageW  (USER32.@)
2321  */
2322 BOOL WINAPI PeekMessageW( MSG *msg_out, HWND hwnd, UINT first, UINT last, UINT flags )
2323 {
2324     MESSAGEQUEUE *queue;
2325     MSG msg;
2326     int locks;
2327
2328     /* check for graphics events */
2329     if (USER_Driver.pMsgWaitForMultipleObjectsEx)
2330         USER_Driver.pMsgWaitForMultipleObjectsEx( 0, NULL, 0, 0, 0 );
2331
2332     hwnd = WIN_GetFullHandle( hwnd );
2333     locks = WIN_SuspendWndsLock();
2334
2335     if (!MSG_peek_message( &msg, hwnd, first, last,
2336                            (flags & PM_REMOVE) ? GET_MSG_REMOVE : 0 ))
2337     {
2338         if (!(flags & PM_NOYIELD))
2339         {
2340             DWORD count;
2341             ReleaseThunkLock(&count);
2342             if (count) RestoreThunkLock(count);
2343         }
2344         WIN_RestoreWndsLock( locks );
2345         return FALSE;
2346     }
2347
2348     WIN_RestoreWndsLock( locks );
2349
2350     if (msg.message == WM_PAINT)  /* clear internal paint flag */
2351         RedrawWindow( msg.hwnd, NULL, 0, RDW_NOINTERNALPAINT | RDW_NOCHILDREN );
2352
2353     if ((queue = QUEUE_Current()))
2354     {
2355         queue->GetMessageTimeVal = msg.time;
2356         msg.pt.x = LOWORD( queue->GetMessagePosVal );
2357         msg.pt.y = HIWORD( queue->GetMessagePosVal );
2358     }
2359
2360     HOOK_CallHooks( WH_GETMESSAGE, HC_ACTION, flags & PM_REMOVE, (LPARAM)&msg, TRUE );
2361
2362     /* copy back our internal safe copy of message data to msg_out.
2363      * msg_out is a variable from the *program*, so it can't be used
2364      * internally as it can get "corrupted" by our use of SendMessage()
2365      * (back to the program) inside the message handling itself. */
2366     if (!msg_out)
2367     {
2368         SetLastError( ERROR_NOACCESS );
2369         return FALSE;
2370     }
2371     *msg_out = msg;
2372     return TRUE;
2373 }
2374
2375
2376 /***********************************************************************
2377  *              PeekMessageA  (USER32.@)
2378  */
2379 BOOL WINAPI PeekMessageA( MSG *msg, HWND hwnd, UINT first, UINT last, UINT flags )
2380 {
2381     BOOL ret = PeekMessageW( msg, hwnd, first, last, flags );
2382     if (ret) msg->wParam = map_wparam_WtoA( msg->message, msg->wParam );
2383     return ret;
2384 }
2385
2386
2387 /***********************************************************************
2388  *              GetMessageW  (USER32.@)
2389  */
2390 BOOL WINAPI GetMessageW( MSG *msg, HWND hwnd, UINT first, UINT last )
2391 {
2392     MESSAGEQUEUE *queue = QUEUE_Current();
2393     int mask, locks;
2394
2395     mask = QS_POSTMESSAGE | QS_SENDMESSAGE;  /* Always selected */
2396     if (first || last)
2397     {
2398         if ((first <= WM_KEYLAST) && (last >= WM_KEYFIRST)) mask |= QS_KEY;
2399         if ( ((first <= WM_MOUSELAST) && (last >= WM_MOUSEFIRST)) ||
2400              ((first <= WM_NCMOUSELAST) && (last >= WM_NCMOUSEFIRST)) ) mask |= QS_MOUSE;
2401         if ((first <= WM_TIMER) && (last >= WM_TIMER)) mask |= QS_TIMER;
2402         if ((first <= WM_SYSTIMER) && (last >= WM_SYSTIMER)) mask |= QS_TIMER;
2403         if ((first <= WM_PAINT) && (last >= WM_PAINT)) mask |= QS_PAINT;
2404     }
2405     else mask |= QS_MOUSE | QS_KEY | QS_TIMER | QS_PAINT;
2406
2407     locks = WIN_SuspendWndsLock();
2408
2409     while (!PeekMessageW( msg, hwnd, first, last, PM_REMOVE ))
2410     {
2411         /* wait until one of the bits is set */
2412         unsigned int wake_bits = 0, changed_bits = 0;
2413         DWORD dwlc;
2414
2415         SERVER_START_REQ( set_queue_mask )
2416         {
2417             req->wake_mask    = QS_SENDMESSAGE;
2418             req->changed_mask = mask;
2419             req->skip_wait    = 1;
2420             if (!wine_server_call( req ))
2421             {
2422                 wake_bits    = reply->wake_bits;
2423                 changed_bits = reply->changed_bits;
2424             }
2425         }
2426         SERVER_END_REQ;
2427
2428         if (changed_bits & mask) continue;
2429         if (wake_bits & QS_SENDMESSAGE) continue;
2430
2431         TRACE( "(%04x) mask=%08x, bits=%08x, changed=%08x, waiting\n",
2432                queue->self, mask, wake_bits, changed_bits );
2433
2434         ReleaseThunkLock( &dwlc );
2435         if (USER_Driver.pMsgWaitForMultipleObjectsEx)
2436             USER_Driver.pMsgWaitForMultipleObjectsEx( 1, &queue->server_queue, INFINITE, 0, 0 );
2437         else
2438             WaitForSingleObject( queue->server_queue, INFINITE );
2439         if (dwlc) RestoreThunkLock( dwlc );
2440     }
2441
2442     WIN_RestoreWndsLock( locks );
2443
2444     return (msg->message != WM_QUIT);
2445 }
2446
2447
2448 /***********************************************************************
2449  *              GetMessageA  (USER32.@)
2450  */
2451 BOOL WINAPI GetMessageA( MSG *msg, HWND hwnd, UINT first, UINT last )
2452 {
2453     GetMessageW( msg, hwnd, first, last );
2454     msg->wParam = map_wparam_WtoA( msg->message, msg->wParam );
2455     return (msg->message != WM_QUIT);
2456 }
2457
2458
2459 /***********************************************************************
2460  *              IsDialogMessage  (USER32.@)
2461  *              IsDialogMessageA (USER32.@)
2462  */
2463 BOOL WINAPI IsDialogMessageA( HWND hwndDlg, LPMSG pmsg )
2464 {
2465     MSG msg = *pmsg;
2466     msg.wParam = map_wparam_AtoW( msg.message, msg.wParam );
2467     return IsDialogMessageW( hwndDlg, &msg );
2468 }
2469
2470
2471 /***********************************************************************
2472  *              SetMessageQueue (USER32.@)
2473  */
2474 BOOL WINAPI SetMessageQueue( INT size )
2475 {
2476     /* now obsolete the message queue will be expanded dynamically as necessary */
2477     return TRUE;
2478 }
2479
2480
2481 /***********************************************************************
2482  *              MessageBeep (USER32.@)
2483  */
2484 BOOL WINAPI MessageBeep( UINT i )
2485 {
2486     BOOL active = TRUE;
2487     SystemParametersInfoA( SPI_GETBEEP, 0, &active, FALSE );
2488     if (active && USER_Driver.pBeep) USER_Driver.pBeep();
2489     return TRUE;
2490 }
2491
2492
2493 /***********************************************************************
2494  *              SetTimer (USER32.@)
2495  */
2496 UINT_PTR WINAPI SetTimer( HWND hwnd, UINT_PTR id, UINT timeout, TIMERPROC proc )
2497 {
2498     UINT_PTR ret;
2499     WNDPROC winproc = 0;
2500
2501     if (proc) winproc = WINPROC_AllocProc( (WNDPROC)proc, WIN_PROC_32A );
2502
2503     SERVER_START_REQ( set_win_timer )
2504     {
2505         req->win    = hwnd;
2506         req->msg    = WM_TIMER;
2507         req->id     = id;
2508         req->rate   = max( timeout, SYS_TIMER_RATE );
2509         req->lparam = (unsigned int)winproc;
2510         if (!wine_server_call_err( req ))
2511         {
2512             ret = reply->id;
2513             if (!ret) ret = TRUE;
2514         }
2515         else ret = 0;
2516     }
2517     SERVER_END_REQ;
2518
2519     TRACE("Added %p %x %p timeout %d\n", hwnd, id, winproc, timeout );
2520     return ret;
2521 }
2522
2523
2524 /***********************************************************************
2525  *              SetSystemTimer (USER32.@)
2526  */
2527 UINT_PTR WINAPI SetSystemTimer( HWND hwnd, UINT_PTR id, UINT timeout, TIMERPROC proc )
2528 {
2529     UINT_PTR ret;
2530     WNDPROC winproc = 0;
2531
2532     if (proc) winproc = WINPROC_AllocProc( (WNDPROC)proc, WIN_PROC_32A );
2533
2534     SERVER_START_REQ( set_win_timer )
2535     {
2536         req->win    = hwnd;
2537         req->msg    = WM_SYSTIMER;
2538         req->id     = id;
2539         req->rate   = max( timeout, SYS_TIMER_RATE );
2540         req->lparam = (unsigned int)winproc;
2541         if (!wine_server_call_err( req ))
2542         {
2543             ret = reply->id;
2544             if (!ret) ret = TRUE;
2545         }
2546         else ret = 0;
2547     }
2548     SERVER_END_REQ;
2549
2550     TRACE("Added %p %x %p timeout %d\n", hwnd, id, winproc, timeout );
2551     return ret;
2552 }
2553
2554
2555 /***********************************************************************
2556  *              KillTimer (USER32.@)
2557  */
2558 BOOL WINAPI KillTimer( HWND hwnd, UINT_PTR id )
2559 {
2560     BOOL ret;
2561
2562     TRACE("%p %d\n", hwnd, id );
2563
2564     SERVER_START_REQ( kill_win_timer )
2565     {
2566         req->win = hwnd;
2567         req->msg = WM_TIMER;
2568         req->id  = id;
2569         ret = !wine_server_call_err( req );
2570     }
2571     SERVER_END_REQ;
2572     return ret;
2573 }
2574
2575
2576 /***********************************************************************
2577  *              KillSystemTimer (USER32.@)
2578  */
2579 BOOL WINAPI KillSystemTimer( HWND hwnd, UINT_PTR id )
2580 {
2581     BOOL ret;
2582
2583     TRACE("%p %d\n", hwnd, id );
2584
2585     SERVER_START_REQ( kill_win_timer )
2586     {
2587         req->win = hwnd;
2588         req->msg = WM_SYSTIMER;
2589         req->id  = id;
2590         ret = !wine_server_call_err( req );
2591     }
2592     SERVER_END_REQ;
2593     return ret;
2594 }
2595
2596
2597 /**********************************************************************
2598  *              AttachThreadInput (USER32.@)
2599  *
2600  * Attaches the input processing mechanism of one thread to that of
2601  * another thread.
2602  */
2603 BOOL WINAPI AttachThreadInput( DWORD from, DWORD to, BOOL attach )
2604 {
2605     BOOL ret;
2606
2607     SERVER_START_REQ( attach_thread_input )
2608     {
2609         req->tid_from = from;
2610         req->tid_to   = to;
2611         req->attach   = attach;
2612         ret = !wine_server_call_err( req );
2613     }
2614     SERVER_END_REQ;
2615     return ret;
2616 }
2617
2618
2619 /**********************************************************************
2620  *              GetGUIThreadInfo  (USER32.@)
2621  */
2622 BOOL WINAPI GetGUIThreadInfo( DWORD id, GUITHREADINFO *info )
2623 {
2624     BOOL ret;
2625
2626     SERVER_START_REQ( get_thread_input )
2627     {
2628         req->tid = id;
2629         if ((ret = !wine_server_call_err( req )))
2630         {
2631             info->flags          = 0;
2632             info->hwndActive     = reply->active;
2633             info->hwndFocus      = reply->focus;
2634             info->hwndCapture    = reply->capture;
2635             info->hwndMenuOwner  = reply->menu_owner;
2636             info->hwndMoveSize   = reply->move_size;
2637             info->hwndCaret      = reply->caret;
2638             info->rcCaret.left   = reply->rect.left;
2639             info->rcCaret.top    = reply->rect.top;
2640             info->rcCaret.right  = reply->rect.right;
2641             info->rcCaret.bottom = reply->rect.bottom;
2642             if (reply->menu_owner) info->flags |= GUI_INMENUMODE;
2643             if (reply->move_size) info->flags |= GUI_INMOVESIZE;
2644             if (reply->caret) info->flags |= GUI_CARETBLINKING;
2645         }
2646     }
2647     SERVER_END_REQ;
2648     return ret;
2649 }
2650
2651
2652 /**********************************************************************
2653  *              GetKeyState (USER32.@)
2654  *
2655  * An application calls the GetKeyState function in response to a
2656  * keyboard-input message.  This function retrieves the state of the key
2657  * at the time the input message was generated.
2658  */
2659 SHORT WINAPI GetKeyState(INT vkey)
2660 {
2661     SHORT retval = 0;
2662
2663     SERVER_START_REQ( get_key_state )
2664     {
2665         req->tid = GetCurrentThreadId();
2666         req->key = vkey;
2667         if (!wine_server_call( req )) retval = (signed char)reply->state;
2668     }
2669     SERVER_END_REQ;
2670     TRACE("key (0x%x) -> %x\n", vkey, retval);
2671     return retval;
2672 }
2673
2674
2675 /**********************************************************************
2676  *              GetKeyboardState (USER32.@)
2677  */
2678 BOOL WINAPI GetKeyboardState( LPBYTE state )
2679 {
2680     BOOL ret;
2681
2682     TRACE("(%p)\n", state);
2683
2684     memset( state, 0, 256 );
2685     SERVER_START_REQ( get_key_state )
2686     {
2687         req->tid = GetCurrentThreadId();
2688         req->key = -1;
2689         wine_server_set_reply( req, state, 256 );
2690         ret = !wine_server_call_err( req );
2691     }
2692     SERVER_END_REQ;
2693     return ret;
2694 }
2695
2696
2697 /**********************************************************************
2698  *              SetKeyboardState (USER32.@)
2699  */
2700 BOOL WINAPI SetKeyboardState( LPBYTE state )
2701 {
2702     BOOL ret;
2703
2704     TRACE("(%p)\n", state);
2705
2706     SERVER_START_REQ( set_key_state )
2707     {
2708         req->tid = GetCurrentThreadId();
2709         wine_server_add_data( req, state, 256 );
2710         ret = !wine_server_call_err( req );
2711     }
2712     SERVER_END_REQ;
2713     return ret;
2714 }
2715
2716 /******************************************************************
2717  *              IsHungAppWindow (USER32.@)
2718  *
2719  */
2720 BOOL WINAPI IsHungAppWindow( HWND hWnd )
2721 {
2722     DWORD dwResult;
2723     return !SendMessageTimeoutA(hWnd, WM_NULL, 0, 0, SMTO_ABORTIFHUNG, 5000, &dwResult);
2724 }
2725
2726 /******************************************************************
2727  *              GetLastInputInfo (USER32.@)
2728  */
2729 BOOL WINAPI GetLastInputInfo(PLASTINPUTINFO plii)
2730 {
2731     FIXME("%p\n", plii);
2732     return FALSE;
2733 }