git.oblomov.eu Git - wine/blob - windows/queue.c

   1 /* * Message queues related functions
   2  *
   3  * Copyright 1993, 1994 Alexandre Julliard
   4  */
   5
   6 #include <string.h>
   7 #include <signal.h>
   8 #include "wine/winbase16.h"
   9 #include "wine/winuser16.h"
  10 #include "miscemu.h"
  11 #include "syslevel.h"
  12 #include "module.h"
  13 #include "queue.h"
  14 #include "task.h"
  15 #include "win.h"
  16 #include "clipboard.h"
  17 #include "hook.h"
  18 #include "heap.h"
  19 #include "thread.h"
  20 #include "process.h"
  21 #include <assert.h>
  22 #include "debugtools.h"
  23 #include "spy.h"
  24
  25 DECLARE_DEBUG_CHANNEL(msg)
  26 DECLARE_DEBUG_CHANNEL(sendmsg)
  27
  28 #define MAX_QUEUE_SIZE   120  /* Max. size of a message queue */
  29
  30 static HQUEUE16 hFirstQueue = 0;
  31 static HQUEUE16 hExitingQueue = 0;
  32 static HQUEUE16 hmemSysMsgQueue = 0;
  33 static MESSAGEQUEUE *sysMsgQueue = NULL;
  34 static PERQUEUEDATA *pQDataWin16 = NULL;  /* Global perQData for Win16 tasks */
  35
  36 static MESSAGEQUEUE *pMouseQueue = NULL;  /* Queue for last mouse message */
  37 static MESSAGEQUEUE *pKbdQueue = NULL;    /* Queue for last kbd message */
  38
  39 HQUEUE16 hCursorQueue = 0;
  40 HQUEUE16 hActiveQueue = 0;
  41
  42
  43 /***********************************************************************
  44  *           PERQDATA_CreateInstance
  45  *
  46  * Creates an instance of a reference counted PERQUEUEDATA element
  47  * for the message queue. perQData is stored globally for 16 bit tasks.
  48  *
  49  * Note: We don't implement perQdata exactly the same way Windows does.
  50  * Each perQData element is reference counted since it may be potentially
  51  * shared by multiple message Queues (via AttachThreadInput).
  52  * We only store the current values for Active, Capture and focus windows
  53  * currently.
  54  */
  55 PERQUEUEDATA * PERQDATA_CreateInstance( )
  56 {
  57     PERQUEUEDATA *pQData;
  58
  59     BOOL16 bIsWin16 = 0;
  60
  61     TRACE_(msg)("()\n");
  62
  63     /* Share a single instance of perQData for all 16 bit tasks */
  64     if ( ( bIsWin16 = THREAD_IsWin16( NtCurrentTeb() ) ) )
  65     {
  66         /* If previously allocated, just bump up ref count */
  67         if ( pQDataWin16 )
  68         {
  69             PERQDATA_Addref( pQDataWin16 );
  70             return pQDataWin16;
  71         }
  72     }
  73
  74     /* Allocate PERQUEUEDATA from the system heap */
  75     if (!( pQData = (PERQUEUEDATA *) HeapAlloc( SystemHeap, 0,
  76                                                     sizeof(PERQUEUEDATA) ) ))
  77         return 0;
  78
  79     /* Initialize */
  80     pQData->hWndCapture = pQData->hWndFocus = pQData->hWndActive = 0;
  81     pQData->ulRefCount = 1;
  82     pQData->nCaptureHT = HTCLIENT;
  83
  84     /* Note: We have an independent critical section for the per queue data
  85      * since this may be shared by different threads. see AttachThreadInput()
  86      */
  87     InitializeCriticalSection( &pQData->cSection );
  88     /* FIXME: not all per queue data critical sections should be global */
  89     MakeCriticalSectionGlobal( &pQData->cSection );
  90
  91     /* Save perQData globally for 16 bit tasks */
  92     if ( bIsWin16 )
  93         pQDataWin16 = pQData;
  94
  95     return pQData;
  96 }
  97
  98
  99 /***********************************************************************
 100  *           PERQDATA_Addref
 101  *
 102  * Increment reference count for the PERQUEUEDATA instance
 103  * Returns reference count for debugging purposes
 104  */
 105 ULONG PERQDATA_Addref( PERQUEUEDATA *pQData )
 106 {
 107     assert(pQData != 0 );
 108     TRACE_(msg)("(): current refcount %lu ...\n", pQData->ulRefCount);
 109
 110     EnterCriticalSection( &pQData->cSection );
 111     ++pQData->ulRefCount;
 112     LeaveCriticalSection( &pQData->cSection );
 113
 114     return pQData->ulRefCount;
 115 }
 116
 117
 118 /***********************************************************************
 119  *           PERQDATA_Release
 120  *
 121  * Release a reference to a PERQUEUEDATA instance.
 122  * Destroy the instance if no more references exist
 123  * Returns reference count for debugging purposes
 124  */
 125 ULONG PERQDATA_Release( PERQUEUEDATA *pQData )
 126 {
 127     assert(pQData != 0 );
 128     TRACE_(msg)("(): current refcount %lu ...\n",
 129           (LONG)pQData->ulRefCount );
 130
 131     EnterCriticalSection( &pQData->cSection );
 132     if ( --pQData->ulRefCount == 0 )
 133     {
 134         LeaveCriticalSection( &pQData->cSection );
 135         DeleteCriticalSection( &pQData->cSection );
 136
 137         TRACE_(msg)("(): deleting PERQUEUEDATA instance ...\n" );
 138
 139         /* Deleting our global 16 bit perQData? */
 140         if ( pQData == pQDataWin16 )
 141             pQDataWin16 = 0;
 142
 143         /* Free the PERQUEUEDATA instance */
 144         HeapFree( SystemHeap, 0, pQData );
 145
 146         return 0;
 147     }
 148     LeaveCriticalSection( &pQData->cSection );
 149
 150     return pQData->ulRefCount;
 151 }
 152
 153
 154 /***********************************************************************
 155  *           PERQDATA_GetFocusWnd
 156  *
 157  * Get the focus hwnd member in a threadsafe manner
 158  */
 159 HWND PERQDATA_GetFocusWnd( PERQUEUEDATA *pQData )
 160 {
 161     HWND hWndFocus;
 162     assert(pQData != 0 );
 163
 164     EnterCriticalSection( &pQData->cSection );
 165     hWndFocus = pQData->hWndFocus;
 166     LeaveCriticalSection( &pQData->cSection );
 167
 168     return hWndFocus;
 169 }
 170
 171
 172 /***********************************************************************
 173  *           PERQDATA_SetFocusWnd
 174  *
 175  * Set the focus hwnd member in a threadsafe manner
 176  */
 177 HWND PERQDATA_SetFocusWnd( PERQUEUEDATA *pQData, HWND hWndFocus )
 178 {
 179     HWND hWndFocusPrv;
 180     assert(pQData != 0 );
 181
 182     EnterCriticalSection( &pQData->cSection );
 183     hWndFocusPrv = pQData->hWndFocus;
 184     pQData->hWndFocus = hWndFocus;
 185     LeaveCriticalSection( &pQData->cSection );
 186
 187     return hWndFocusPrv;
 188 }
 189
 190
 191 /***********************************************************************
 192  *           PERQDATA_GetActiveWnd
 193  *
 194  * Get the active hwnd member in a threadsafe manner
 195  */
 196 HWND PERQDATA_GetActiveWnd( PERQUEUEDATA *pQData )
 197 {
 198     HWND hWndActive;
 199     assert(pQData != 0 );
 200
 201     EnterCriticalSection( &pQData->cSection );
 202     hWndActive = pQData->hWndActive;
 203     LeaveCriticalSection( &pQData->cSection );
 204
 205     return hWndActive;
 206 }
 207
 208
 209 /***********************************************************************
 210  *           PERQDATA_SetActiveWnd
 211  *
 212  * Set the active focus hwnd member in a threadsafe manner
 213  */
 214 HWND PERQDATA_SetActiveWnd( PERQUEUEDATA *pQData, HWND hWndActive )
 215 {
 216     HWND hWndActivePrv;
 217     assert(pQData != 0 );
 218
 219     EnterCriticalSection( &pQData->cSection );
 220     hWndActivePrv = pQData->hWndActive;
 221     pQData->hWndActive = hWndActive;
 222     LeaveCriticalSection( &pQData->cSection );
 223
 224     return hWndActivePrv;
 225 }
 226
 227
 228 /***********************************************************************
 229  *           PERQDATA_GetCaptureWnd
 230  *
 231  * Get the capture hwnd member in a threadsafe manner
 232  */
 233 HWND PERQDATA_GetCaptureWnd( PERQUEUEDATA *pQData )
 234 {
 235     HWND hWndCapture;
 236     assert(pQData != 0 );
 237
 238     EnterCriticalSection( &pQData->cSection );
 239     hWndCapture = pQData->hWndCapture;
 240     LeaveCriticalSection( &pQData->cSection );
 241
 242     return hWndCapture;
 243 }
 244
 245
 246 /***********************************************************************
 247  *           PERQDATA_SetCaptureWnd
 248  *
 249  * Set the capture hwnd member in a threadsafe manner
 250  */
 251 HWND PERQDATA_SetCaptureWnd( PERQUEUEDATA *pQData, HWND hWndCapture )
 252 {
 253     HWND hWndCapturePrv;
 254     assert(pQData != 0 );
 255
 256     EnterCriticalSection( &pQData->cSection );
 257     hWndCapturePrv = pQData->hWndCapture;
 258     pQData->hWndCapture = hWndCapture;
 259     LeaveCriticalSection( &pQData->cSection );
 260
 261     return hWndCapturePrv;
 262 }
 263
 264
 265 /***********************************************************************
 266  *           PERQDATA_GetCaptureInfo
 267  *
 268  * Get the capture info member in a threadsafe manner
 269  */
 270 INT16 PERQDATA_GetCaptureInfo( PERQUEUEDATA *pQData )
 271 {
 272     INT16 nCaptureHT;
 273     assert(pQData != 0 );
 274
 275     EnterCriticalSection( &pQData->cSection );
 276     nCaptureHT = pQData->nCaptureHT;
 277     LeaveCriticalSection( &pQData->cSection );
 278
 279     return nCaptureHT;
 280 }
 281
 282
 283 /***********************************************************************
 284  *           PERQDATA_SetCaptureInfo
 285  *
 286  * Set the capture info member in a threadsafe manner
 287  */
 288 INT16 PERQDATA_SetCaptureInfo( PERQUEUEDATA *pQData, INT16 nCaptureHT )
 289 {
 290     INT16 nCaptureHTPrv;
 291     assert(pQData != 0 );
 292
 293     EnterCriticalSection( &pQData->cSection );
 294     nCaptureHTPrv = pQData->nCaptureHT;
 295     pQData->nCaptureHT = nCaptureHT;
 296     LeaveCriticalSection( &pQData->cSection );
 297
 298     return nCaptureHTPrv;
 299 }
 300
 301
 302 /***********************************************************************
 303  *           QUEUE_Lock
 304  *
 305  * Function for getting a 32 bit pointer on queue strcture. For thread
 306  * safeness programmers should use this function instead of GlobalLock to
 307  * retrieve a pointer on the structure. QUEUE_Unlock should also be called
 308  * when access to the queue structure is not required anymore.
 309  */
 310 MESSAGEQUEUE *QUEUE_Lock( HQUEUE16 hQueue )
 311 {
 312     MESSAGEQUEUE *queue;
 313
 314     HeapLock( SystemHeap );  /* FIXME: a bit overkill */
 315     queue = GlobalLock16( hQueue );
 316     if ( !queue || (queue->magic != QUEUE_MAGIC) )
 317     {
 318         HeapUnlock( SystemHeap );
 319         return NULL;
 320     }
 321
 322     queue->lockCount++;
 323     HeapUnlock( SystemHeap );
 324     return queue;
 325 }
 326
 327
 328 /***********************************************************************
 329  *           QUEUE_Unlock
 330  *
 331  * Use with QUEUE_Lock to get a thread safe access to message queue
 332  * structure
 333  */
 334 void QUEUE_Unlock( MESSAGEQUEUE *queue )
 335 {
 336     if (queue)
 337     {
 338         HeapLock( SystemHeap );  /* FIXME: a bit overkill */
 339
 340         if ( --queue->lockCount == 0 )
 341         {
 342             DeleteCriticalSection ( &queue->cSection );
 343             if (queue->hEvent)
 344                 CloseHandle( queue->hEvent );
 345             GlobalFree16( queue->self );
 346         }
 347
 348         HeapUnlock( SystemHeap );
 349     }
 350 }
 351
 352
 353 /***********************************************************************
 354  *           QUEUE_DumpQueue
 355  */
 356 void QUEUE_DumpQueue( HQUEUE16 hQueue )
 357 {
 358     MESSAGEQUEUE *pq;
 359
 360     if (!(pq = (MESSAGEQUEUE*) QUEUE_Lock( hQueue )) )
 361     {
 362         WARN_(msg)("%04x is not a queue handle\n", hQueue );
 363         return;
 364     }
 365
 366     DPRINTF( "next: %12.4x  Intertask SendMessage:\n"
 367              "thread: %10p  ----------------------\n"
 368              "firstMsg: %8p   smWaiting:     %10p\n"
 369              "lastMsg:  %8p   smPending:     %10p\n"
 370              "msgCount: %8.4x   smProcessing:  %10p\n"
 371              "lockCount: %7.4x\n"
 372              "wWinVer: %9.4x\n"
 373              "paints: %10.4x\n"
 374              "timers: %10.4x\n"
 375              "wakeBits: %8.4x\n"
 376              "wakeMask: %8.4x\n"
 377              "hCurHook: %8.4x\n",
 378              pq->next, pq->teb, pq->firstMsg, pq->smWaiting, pq->lastMsg,
 379              pq->smPending, pq->msgCount, pq->smProcessing,
 380              (unsigned)pq->lockCount, pq->wWinVersion,
 381              pq->wPaintCount, pq->wTimerCount,
 382              pq->wakeBits, pq->wakeMask, pq->hCurHook);
 383
 384     QUEUE_Unlock( pq );
 385 }
 386
 387
 388 /***********************************************************************
 389  *           QUEUE_WalkQueues
 390  */
 391 void QUEUE_WalkQueues(void)
 392 {
 393     char module[10];
 394     HQUEUE16 hQueue = hFirstQueue;
 395
 396     DPRINTF( "Queue Msgs Thread   Task Module\n" );
 397     while (hQueue)
 398     {
 399         MESSAGEQUEUE *queue = (MESSAGEQUEUE *)QUEUE_Lock( hQueue );
 400         if (!queue)
 401         {
 402             WARN_(msg)("Bad queue handle %04x\n", hQueue );
 403             return;
 404         }
 405         if (!GetModuleName16( queue->teb->process->task, module, sizeof(module )))
 406             strcpy( module, "???" );
 407         DPRINTF( "%04x %4d %p %04x %s\n", hQueue,queue->msgCount,
 408                  queue->teb, queue->teb->process->task, module );
 409         hQueue = queue->next;
 410         QUEUE_Unlock( queue );
 411     }
 412     DPRINTF( "\n" );
 413 }
 414
 415
 416 /***********************************************************************
 417  *           QUEUE_IsExitingQueue
 418  */
 419 BOOL QUEUE_IsExitingQueue( HQUEUE16 hQueue )
 420 {
 421     return (hExitingQueue && (hQueue == hExitingQueue));
 422 }
 423
 424
 425 /***********************************************************************
 426  *           QUEUE_SetExitingQueue
 427  */
 428 void QUEUE_SetExitingQueue( HQUEUE16 hQueue )
 429 {
 430     hExitingQueue = hQueue;
 431 }
 432
 433
 434 /***********************************************************************
 435  *           QUEUE_CreateMsgQueue
 436  *
 437  * Creates a message queue. Doesn't link it into queue list!
 438  */
 439 static HQUEUE16 QUEUE_CreateMsgQueue( BOOL16 bCreatePerQData )
 440 {
 441     HQUEUE16 hQueue;
 442     MESSAGEQUEUE * msgQueue;
 443     TDB *pTask = (TDB *)GlobalLock16( GetCurrentTask() );
 444
 445     TRACE_(msg)("(): Creating message queue...\n");
 446
 447     if (!(hQueue = GlobalAlloc16( GMEM_FIXED | GMEM_ZEROINIT,
 448                                   sizeof(MESSAGEQUEUE) )))
 449         return 0;
 450
 451     msgQueue = (MESSAGEQUEUE *) GlobalLock16( hQueue );
 452     if ( !msgQueue )
 453         return 0;
 454
 455     msgQueue->self        = hQueue;
 456     msgQueue->wakeBits    = msgQueue->changeBits = 0;
 457     msgQueue->wWinVersion = pTask ? pTask->version : 0;
 458
 459     InitializeCriticalSection( &msgQueue->cSection );
 460     MakeCriticalSectionGlobal( &msgQueue->cSection );
 461
 462     /* Create an Event object for waiting on message, used by win32 thread
 463        only */
 464     if ( !THREAD_IsWin16( NtCurrentTeb() ) )
 465     {
 466         msgQueue->hEvent = CreateEventA( NULL, FALSE, FALSE, NULL);
 467
 468         if (msgQueue->hEvent == 0)
 469         {
 470             WARN_(msg)("CreateEvent32A is not able to create an event object");
 471             return 0;
 472         }
 473         msgQueue->hEvent = ConvertToGlobalHandle( msgQueue->hEvent );
 474     }
 475     else
 476         msgQueue->hEvent = 0;
 477
 478     msgQueue->lockCount = 1;
 479     msgQueue->magic = QUEUE_MAGIC;
 480
 481     /* Create and initialize our per queue data */
 482     msgQueue->pQData = bCreatePerQData ? PERQDATA_CreateInstance() : NULL;
 483
 484     return hQueue;
 485 }
 486
 487
 488 /***********************************************************************
 489  *           QUEUE_FlushMessage
 490  *
 491  * Try to reply to all pending sent messages on exit.
 492  */
 493 static void QUEUE_FlushMessages( MESSAGEQUEUE *queue )
 494 {
 495     SMSG *smsg;
 496     MESSAGEQUEUE *senderQ = 0;
 497
 498     if( queue )
 499     {
 500         EnterCriticalSection( &queue->cSection );
 501
 502         /* empty the list of pending SendMessage waiting to be received */
 503         while (queue->smPending)
 504         {
 505             smsg = QUEUE_RemoveSMSG( queue, SM_PENDING_LIST, 0);
 506
 507             senderQ = (MESSAGEQUEUE*)QUEUE_Lock( smsg->hSrcQueue );
 508             if ( !senderQ )
 509                 continue;
 510
 511             /* return 0, to unblock other thread */
 512             smsg->lResult = 0;
 513             smsg->flags |= SMSG_HAVE_RESULT;
 514             QUEUE_SetWakeBit( senderQ, QS_SMRESULT);
 515
 516             QUEUE_Unlock( senderQ );
 517         }
 518
 519         QUEUE_ClearWakeBit( queue, QS_SENDMESSAGE );
 520
 521         LeaveCriticalSection( &queue->cSection );
 522     }
 523 }
 524
 525
 526 /***********************************************************************
 527  *           QUEUE_DeleteMsgQueue
 528  *
 529  * Unlinks and deletes a message queue.
 530  *
 531  * Note: We need to mask asynchronous events to make sure PostMessage works
 532  * even in the signal handler.
 533  */
 534 BOOL QUEUE_DeleteMsgQueue( HQUEUE16 hQueue )
 535 {
 536     MESSAGEQUEUE * msgQueue = (MESSAGEQUEUE*)QUEUE_Lock(hQueue);
 537     HQUEUE16 *pPrev;
 538
 539     TRACE_(msg)("(): Deleting message queue %04x\n", hQueue);
 540
 541     if (!hQueue || !msgQueue)
 542     {
 543         WARN_(msg)("invalid argument.\n");
 544         return 0;
 545     }
 546
 547     msgQueue->magic = 0;
 548
 549     if( hCursorQueue == hQueue ) hCursorQueue = 0;
 550     if( hActiveQueue == hQueue ) hActiveQueue = 0;
 551
 552     /* flush sent messages */
 553     QUEUE_FlushMessages( msgQueue );
 554
 555     HeapLock( SystemHeap );  /* FIXME: a bit overkill */
 556
 557     /* Release per queue data if present */
 558     if ( msgQueue->pQData )
 559     {
 560         PERQDATA_Release( msgQueue->pQData );
 561         msgQueue->pQData = 0;
 562     }
 563
 564     /* remove the message queue from the global link list */
 565     pPrev = &hFirstQueue;
 566     while (*pPrev && (*pPrev != hQueue))
 567     {
 568         MESSAGEQUEUE *msgQ = (MESSAGEQUEUE*)GlobalLock16(*pPrev);
 569
 570         /* sanity check */
 571         if ( !msgQ || (msgQ->magic != QUEUE_MAGIC) )
 572         {
 573             /* HQUEUE link list is corrupted, try to exit gracefully */
 574             WARN_(msg)("HQUEUE link list corrupted!\n");
 575             pPrev = 0;
 576             break;
 577         }
 578         pPrev = &msgQ->next;
 579     }
 580     if (pPrev && *pPrev) *pPrev = msgQueue->next;
 581     msgQueue->self = 0;
 582
 583     HeapUnlock( SystemHeap );
 584
 585     /* free up resource used by MESSAGEQUEUE strcture */
 586     msgQueue->lockCount--;
 587     QUEUE_Unlock( msgQueue );
 588
 589     return 1;
 590 }
 591
 592
 593 /***********************************************************************
 594  *           QUEUE_CreateSysMsgQueue
 595  *
 596  * Create the system message queue, and set the double-click speed.
 597  * Must be called only once.
 598  */
 599 BOOL QUEUE_CreateSysMsgQueue( int size )
 600 {
 601     /* Note: We dont need perQ data for the system message queue */
 602     if (!(hmemSysMsgQueue = QUEUE_CreateMsgQueue( FALSE )))
 603         return FALSE;
 604
 605     sysMsgQueue = (MESSAGEQUEUE *) GlobalLock16( hmemSysMsgQueue );
 606     return TRUE;
 607 }
 608
 609
 610 /***********************************************************************
 611  *           QUEUE_GetSysQueue
 612  */
 613 MESSAGEQUEUE *QUEUE_GetSysQueue(void)
 614 {
 615     return sysMsgQueue;
 616 }
 617
 618
 619 /***********************************************************************
 620  *           QUEUE_SetWakeBit
 621  *
 622  * See "Windows Internals", p.449
 623  */
 624 void QUEUE_SetWakeBit( MESSAGEQUEUE *queue, WORD bit )
 625 {
 626     TRACE_(msg)("queue = %04x (wm=%04x), bit = %04x\n",
 627                         queue->self, queue->wakeMask, bit );
 628
 629     if (bit & QS_MOUSE) pMouseQueue = queue;
 630     if (bit & QS_KEY) pKbdQueue = queue;
 631     queue->changeBits |= bit;
 632     queue->wakeBits   |= bit;
 633     if (queue->wakeMask & bit)
 634     {
 635         queue->wakeMask = 0;
 636
 637         /* Wake up thread waiting for message */
 638         if ( THREAD_IsWin16( queue->teb ) )
 639         {
 640             int iWndsLock = WIN_SuspendWndsLock();
 641             PostEvent16( queue->teb->process->task );
 642             WIN_RestoreWndsLock( iWndsLock );
 643         }
 644         else
 645         {
 646             SetEvent( queue->hEvent );
 647         }
 648     }
 649 }
 650
 651
 652 /***********************************************************************
 653  *           QUEUE_ClearWakeBit
 654  */
 655 void QUEUE_ClearWakeBit( MESSAGEQUEUE *queue, WORD bit )
 656 {
 657     queue->changeBits &= ~bit;
 658     queue->wakeBits   &= ~bit;
 659 }
 660
 661
 662 /***********************************************************************
 663  *           QUEUE_WaitBits
 664  *
 665  * See "Windows Internals", p.447
 666  *
 667  * return values:
 668  *    0 if exit with timeout
 669  *    1 otherwise
 670  */
 671 int QUEUE_WaitBits( WORD bits, DWORD timeout )
 672 {
 673     MESSAGEQUEUE *queue;
 674     DWORD curTime = 0;
 675
 676     TRACE_(msg)("q %04x waiting for %04x\n", GetFastQueue16(), bits);
 677
 678     if ( THREAD_IsWin16( NtCurrentTeb() ) && (timeout != INFINITE) )
 679         curTime = GetTickCount();
 680
 681     if (!(queue = (MESSAGEQUEUE *)QUEUE_Lock( GetFastQueue16() ))) return 0;
 682
 683     for (;;)
 684     {
 685         if (queue->changeBits & bits)
 686         {
 687             /* One of the bits is set; we can return */
 688             queue->wakeMask = 0;
 689             QUEUE_Unlock( queue );
 690             return 1;
 691         }
 692         if (queue->wakeBits & QS_SENDMESSAGE)
 693         {
 694             /* Process the sent message immediately */
 695
 696             queue->wakeMask = 0;
 697             QUEUE_ReceiveMessage( queue );
 698             continue;                           /* nested sm crux */
 699         }
 700
 701         queue->wakeMask = bits | QS_SENDMESSAGE;
 702         if(queue->changeBits & bits)
 703         {
 704             continue;
 705         }
 706
 707         TRACE_(msg)("%04x) wakeMask is %04x, waiting\n", queue->self, queue->wakeMask);
 708
 709         if ( !THREAD_IsWin16( NtCurrentTeb() ) )
 710         {
 711             BOOL                bHasWin16Lock;
 712             DWORD               dwlc;
 713
 714             if ( (bHasWin16Lock = _ConfirmWin16Lock()) )
 715             {
 716                 TRACE_(msg)("bHasWin16Lock=TRUE\n");
 717                 ReleaseThunkLock( &dwlc );
 718             }
 719             WaitForSingleObject( queue->hEvent, timeout );
 720             if ( bHasWin16Lock )
 721             {
 722                 RestoreThunkLock( dwlc );
 723             }
 724         }
 725         else
 726         {
 727             if ( timeout == INFINITE )
 728                 WaitEvent16( 0 );  /* win 16 thread, use WaitEvent */
 729             else
 730             {
 731                 /* check for timeout, then give control to other tasks */
 732                 if (GetTickCount() - curTime > timeout)
 733                 {
 734
 735                     QUEUE_Unlock( queue );
 736                     return 0;   /* exit with timeout */
 737                 }
 738                 Yield16();
 739             }
 740         }
 741     }
 742 }
 743
 744
 745 /***********************************************************************
 746  *           QUEUE_AddSMSG
 747  *
 748  * This routine is called when a SMSG need to be added to one of the three
 749  * SM list.  (SM_PROCESSING_LIST, SM_PENDING_LIST, SM_WAITING_LIST)
 750  */
 751 BOOL QUEUE_AddSMSG( MESSAGEQUEUE *queue, int list, SMSG *smsg )
 752 {
 753     TRACE_(sendmsg)("queue=%x, list=%d, smsg=%p msg=%s\n", queue->self, list,
 754           smsg, SPY_GetMsgName(smsg->msg));
 755
 756     switch (list)
 757     {
 758         case SM_PROCESSING_LIST:
 759             /* don't need to be thread safe, only accessed by the
 760              thread associated with the sender queue */
 761             smsg->nextProcessing = queue->smProcessing;
 762             queue->smProcessing = smsg;
 763             break;
 764
 765         case SM_WAITING_LIST:
 766             /* don't need to be thread safe, only accessed by the
 767              thread associated with the receiver queue */
 768             smsg->nextWaiting = queue->smWaiting;
 769             queue->smWaiting = smsg;
 770             break;
 771
 772         case SM_PENDING_LIST:
 773         {
 774             /* make it thread safe, could be accessed by the sender and
 775              receiver thread */
 776             SMSG **prev;
 777
 778             EnterCriticalSection( &queue->cSection );
 779             smsg->nextPending = NULL;
 780             prev = &queue->smPending;
 781             while ( *prev )
 782                 prev = &(*prev)->nextPending;
 783             *prev = smsg;
 784             LeaveCriticalSection( &queue->cSection );
 785
 786             QUEUE_SetWakeBit( queue, QS_SENDMESSAGE );
 787             break;
 788         }
 789
 790         default:
 791             WARN_(sendmsg)("Invalid list: %d", list);
 792             break;
 793     }
 794
 795     return TRUE;
 796 }
 797
 798
 799 /***********************************************************************
 800  *           QUEUE_RemoveSMSG
 801  *
 802  * This routine is called when a SMSG need to be remove from one of the three
 803  * SM list.  (SM_PROCESSING_LIST, SM_PENDING_LIST, SM_WAITING_LIST)
 804  * If smsg == 0, remove the first smsg from the specified list
 805  */
 806 SMSG *QUEUE_RemoveSMSG( MESSAGEQUEUE *queue, int list, SMSG *smsg )
 807 {
 808
 809     switch (list)
 810     {
 811         case SM_PROCESSING_LIST:
 812             /* don't need to be thread safe, only accessed by the
 813              thread associated with the sender queue */
 814
 815             /* if smsg is equal to null, it means the first in the list */
 816             if (!smsg)
 817                 smsg = queue->smProcessing;
 818
 819             TRACE_(sendmsg)("queue=%x, list=%d, smsg=%p msg=%s\n", queue->self, list,
 820                   smsg, SPY_GetMsgName(smsg->msg));
 821             /* In fact SM_PROCESSING_LIST is a stack, and smsg
 822              should be always at the top of the list */
 823             if ( (smsg != queue->smProcessing) || !queue->smProcessing )
 824         {
 825                 ERR_(sendmsg)("smsg not at the top of Processing list, smsg=0x%p queue=0x%p", smsg, queue);
 826                 return 0;
 827             }
 828             else
 829             {
 830                 queue->smProcessing = smsg->nextProcessing;
 831                 smsg->nextProcessing = 0;
 832         }
 833             return smsg;
 834
 835         case SM_WAITING_LIST:
 836             /* don't need to be thread safe, only accessed by the
 837              thread associated with the receiver queue */
 838
 839             /* if smsg is equal to null, it means the first in the list */
 840             if (!smsg)
 841                 smsg = queue->smWaiting;
 842
 843             TRACE_(sendmsg)("queue=%x, list=%d, smsg=%p msg=%s\n", queue->self, list,
 844                   smsg, SPY_GetMsgName(smsg->msg));
 845             /* In fact SM_WAITING_LIST is a stack, and smsg
 846              should be always at the top of the list */
 847             if ( (smsg != queue->smWaiting) || !queue->smWaiting )
 848             {
 849                 ERR_(sendmsg)("smsg not at the top of Waiting list, smsg=0x%p queue=0x%p", smsg, queue);
 850                 return 0;
 851             }
 852             else
 853             {
 854                 queue->smWaiting = smsg->nextWaiting;
 855                 smsg->nextWaiting = 0;
 856     }
 857             return smsg;
 858
 859         case SM_PENDING_LIST:
 860             /* make it thread safe, could be accessed by the sender and
 861              receiver thread */
 862             EnterCriticalSection( &queue->cSection );
 863
 864             if (!smsg || !queue->smPending)
 865                 smsg = queue->smPending;
 866             else
 867             {
 868                 ERR_(sendmsg)("should always remove the top one in Pending list, smsg=0x%p queue=0x%p", smsg, queue);
 869                                 LeaveCriticalSection( &queue->cSection );
 870                 return 0;
 871             }
 872
 873             TRACE_(sendmsg)("queue=%x, list=%d, smsg=%p msg=%s\n", queue->self, list,
 874                   smsg, SPY_GetMsgName(smsg->msg));
 875
 876             queue->smPending = smsg->nextPending;
 877             smsg->nextPending = 0;
 878
 879             /* if no more SMSG in Pending list, clear QS_SENDMESSAGE flag */
 880             if (!queue->smPending)
 881                 QUEUE_ClearWakeBit( queue, QS_SENDMESSAGE );
 882
 883             LeaveCriticalSection( &queue->cSection );
 884             return smsg;
 885
 886         default:
 887             WARN_(sendmsg)("Invalid list: %d", list);
 888             break;
 889     }
 890
 891     return 0;
 892 }
 893
 894
 895 /***********************************************************************
 896  *           QUEUE_ReceiveMessage
 897  *
 898  * This routine is called when a sent message is waiting for the queue.
 899  */
 900 void QUEUE_ReceiveMessage( MESSAGEQUEUE *queue )
 901 {
 902     LRESULT       result = 0;
 903     SMSG          *smsg;
 904     MESSAGEQUEUE  *senderQ;
 905
 906     TRACE_(sendmsg)("queue %04x\n", queue->self );
 907
 908     if ( !(queue->wakeBits & QS_SENDMESSAGE) && queue->smPending )
 909     {
 910         TRACE_(sendmsg)("\trcm: nothing to do\n");
 911         return;
 912     }
 913
 914     /* remove smsg on the top of the pending list and put it in the processing list */
 915     smsg = QUEUE_RemoveSMSG(queue, SM_PENDING_LIST, 0);
 916     QUEUE_AddSMSG(queue, SM_WAITING_LIST, smsg);
 917
 918     TRACE_(sendmsg)("RM: %s [%04x] (%04x -> %04x)\n",
 919             SPY_GetMsgName(smsg->msg), smsg->msg, smsg->hSrcQueue, smsg->hDstQueue );
 920
 921     if (IsWindow( smsg->hWnd ))
 922     {
 923         WND *wndPtr = WIN_FindWndPtr( smsg->hWnd );
 924         DWORD extraInfo = queue->GetMessageExtraInfoVal; /* save ExtraInfo */
 925
 926         /* use sender queue extra info value while calling the window proc */
 927         senderQ = (MESSAGEQUEUE*)QUEUE_Lock( smsg->hSrcQueue );
 928         if (senderQ)
 929   {
 930             queue->GetMessageExtraInfoVal = senderQ->GetMessageExtraInfoVal;
 931             QUEUE_Unlock( senderQ );
 932         }
 933
 934         /* call the right version of CallWindowProcXX */
 935         if (smsg->flags & SMSG_WIN32)
 936         {
 937             TRACE_(sendmsg)("\trcm: msg is Win32\n" );
 938             if (smsg->flags & SMSG_UNICODE)
 939                 result = CallWindowProcW( wndPtr->winproc,
 940                                             smsg->hWnd, smsg->msg,
 941                                             smsg->wParam, smsg->lParam );
 942             else
 943                 result = CallWindowProcA( wndPtr->winproc,
 944                                             smsg->hWnd, smsg->msg,
 945                                             smsg->wParam, smsg->lParam );
 946         }
 947         else  /* Win16 message */
 948             result = CallWindowProc16( (WNDPROC16)wndPtr->winproc,
 949                                        (HWND16) smsg->hWnd,
 950                                        (UINT16) smsg->msg,
 951                                        LOWORD (smsg->wParam),
 952                                        smsg->lParam );
 953
 954         queue->GetMessageExtraInfoVal = extraInfo;  /* Restore extra info */
 955         WIN_ReleaseWndPtr(wndPtr);
 956         TRACE_(sendmsg)("result =  %08x\n", (unsigned)result );
 957     }
 958     else WARN_(sendmsg)("\trcm: bad hWnd\n");
 959
 960
 961         /* set SMSG_SENDING_REPLY flag to tell ReplyMessage16, it's not
 962          an early reply */
 963         smsg->flags |= SMSG_SENDING_REPLY;
 964         ReplyMessage( result );
 965
 966     TRACE_(sendmsg)("done! \n" );
 967 }
 968
 969
 970
 971 /***********************************************************************
 972  *           QUEUE_AddMsg
 973  *
 974  * Add a message to the queue. Return FALSE if queue is full.
 975  */
 976 BOOL QUEUE_AddMsg( HQUEUE16 hQueue, MSG *msg, DWORD extraInfo )
 977 {
 978     MESSAGEQUEUE *msgQueue;
 979     QMSG         *qmsg;
 980
 981
 982     if (!(msgQueue = (MESSAGEQUEUE *)QUEUE_Lock( hQueue ))) return FALSE;
 983
 984     /* allocate new message in global heap for now */
 985     if (!(qmsg = (QMSG *) HeapAlloc( SystemHeap, 0, sizeof(QMSG) ) ))
 986     {
 987         QUEUE_Unlock( msgQueue );
 988         return 0;
 989     }
 990
 991     EnterCriticalSection( &msgQueue->cSection );
 992
 993       /* Store message */
 994     qmsg->msg = *msg;
 995     qmsg->extraInfo = extraInfo;
 996
 997     /* insert the message in the link list */
 998     qmsg->nextMsg = 0;
 999     qmsg->prevMsg = msgQueue->lastMsg;
1000
1001     if (msgQueue->lastMsg)
1002         msgQueue->lastMsg->nextMsg = qmsg;
1003
1004     /* update first and last anchor in message queue */
1005     msgQueue->lastMsg = qmsg;
1006     if (!msgQueue->firstMsg)
1007         msgQueue->firstMsg = qmsg;
1008
1009     msgQueue->msgCount++;
1010
1011     LeaveCriticalSection( &msgQueue->cSection );
1012
1013     QUEUE_SetWakeBit( msgQueue, QS_POSTMESSAGE );
1014     QUEUE_Unlock( msgQueue );
1015
1016     return TRUE;
1017 }
1018
1019
1020
1021 /***********************************************************************
1022  *           QUEUE_FindMsg
1023  *
1024  * Find a message matching the given parameters. Return -1 if none available.
1025  */
1026 QMSG* QUEUE_FindMsg( MESSAGEQUEUE * msgQueue, HWND hwnd, int first, int last )
1027 {
1028     QMSG* qmsg;
1029
1030     EnterCriticalSection( &msgQueue->cSection );
1031
1032     if (!msgQueue->msgCount)
1033         qmsg = 0;
1034     else if (!hwnd && !first && !last)
1035         qmsg = msgQueue->firstMsg;
1036     else
1037     {
1038         /* look in linked list for message matching first and last criteria */
1039         for (qmsg = msgQueue->firstMsg; qmsg; qmsg = qmsg->nextMsg)
1040     {
1041             MSG *msg = &(qmsg->msg);
1042
1043         if (!hwnd || (msg->hwnd == hwnd))
1044         {
1045                 if (!first && !last)
1046                     break;   /* found it */
1047
1048                 if ((msg->message >= first) && (!last || (msg->message <= last)))
1049                     break;   /* found it */
1050             }
1051         }
1052     }
1053
1054     LeaveCriticalSection( &msgQueue->cSection );
1055
1056     return qmsg;
1057 }
1058
1059
1060
1061 /***********************************************************************
1062  *           QUEUE_RemoveMsg
1063  *
1064  * Remove a message from the queue (pos must be a valid position).
1065  */
1066 void QUEUE_RemoveMsg( MESSAGEQUEUE * msgQueue, QMSG *qmsg )
1067 {
1068     EnterCriticalSection( &msgQueue->cSection );
1069
1070     /* set the linked list */
1071     if (qmsg->prevMsg)
1072         qmsg->prevMsg->nextMsg = qmsg->nextMsg;
1073
1074     if (qmsg->nextMsg)
1075         qmsg->nextMsg->prevMsg = qmsg->prevMsg;
1076
1077     if (msgQueue->firstMsg == qmsg)
1078         msgQueue->firstMsg = qmsg->nextMsg;
1079
1080     if (msgQueue->lastMsg == qmsg)
1081         msgQueue->lastMsg = qmsg->prevMsg;
1082
1083     /* deallocate the memory for the message */
1084     HeapFree( SystemHeap, 0, qmsg );
1085
1086     msgQueue->msgCount--;
1087     if (!msgQueue->msgCount) msgQueue->wakeBits &= ~QS_POSTMESSAGE;
1088
1089     LeaveCriticalSection( &msgQueue->cSection );
1090 }
1091
1092
1093 /***********************************************************************
1094  *           QUEUE_WakeSomeone
1095  *
1096  * Wake a queue upon reception of a hardware event.
1097  */
1098 static void QUEUE_WakeSomeone( UINT message )
1099 {
1100     WND*          wndPtr = NULL;
1101     WORD          wakeBit;
1102     HWND hwnd;
1103     HQUEUE16     hQueue = 0;
1104     MESSAGEQUEUE *queue = NULL;
1105
1106     if (hCursorQueue)
1107         hQueue = hCursorQueue;
1108
1109     if( (message >= WM_KEYFIRST) && (message <= WM_KEYLAST) )
1110     {
1111        wakeBit = QS_KEY;
1112        if( hActiveQueue )
1113            hQueue = hActiveQueue;
1114     }
1115     else
1116     {
1117        wakeBit = (message == WM_MOUSEMOVE) ? QS_MOUSEMOVE : QS_MOUSEBUTTON;
1118        if( (hwnd = GetCapture()) )
1119          if( (wndPtr = WIN_FindWndPtr( hwnd )) )
1120            {
1121                hQueue = wndPtr->hmemTaskQ;
1122                WIN_ReleaseWndPtr(wndPtr);
1123            }
1124     }
1125
1126     if( (hwnd = GetSysModalWindow16()) )
1127     {
1128       if( (wndPtr = WIN_FindWndPtr( hwnd )) )
1129         {
1130             hQueue = wndPtr->hmemTaskQ;
1131             WIN_ReleaseWndPtr(wndPtr);
1132         }
1133     }
1134
1135     if (hQueue)
1136         queue = QUEUE_Lock( hQueue );
1137
1138     if( !queue )
1139     {
1140         queue = QUEUE_Lock( hFirstQueue );
1141       while( queue )
1142       {
1143         if (queue->wakeMask & wakeBit) break;
1144
1145             QUEUE_Unlock(queue);
1146             queue = QUEUE_Lock( queue->next );
1147       }
1148       if( !queue )
1149       {
1150         WARN_(msg)("couldn't find queue\n");
1151         return;
1152       }
1153     }
1154
1155     QUEUE_SetWakeBit( queue, wakeBit );
1156
1157     QUEUE_Unlock( queue );
1158 }
1159
1160
1161 /***********************************************************************
1162  *           hardware_event
1163  *
1164  * Add an event to the system message queue.
1165  * Note: the position is relative to the desktop window.
1166  */
1167 void hardware_event( UINT message, WPARAM wParam, LPARAM lParam,
1168                      int xPos, int yPos, DWORD time, DWORD extraInfo )
1169 {
1170     MSG *msg;
1171     QMSG  *qmsg;
1172     int  mergeMsg = 0;
1173
1174     if (!sysMsgQueue) return;
1175
1176     EnterCriticalSection( &sysMsgQueue->cSection );
1177
1178     /* Merge with previous event if possible */
1179     qmsg = sysMsgQueue->lastMsg;
1180
1181     if ((message == WM_MOUSEMOVE) && sysMsgQueue->lastMsg)
1182     {
1183         msg = &(sysMsgQueue->lastMsg->msg);
1184
1185         if ((msg->message == message) && (msg->wParam == wParam))
1186         {
1187             /* Merge events */
1188             qmsg = sysMsgQueue->lastMsg;
1189             mergeMsg = 1;
1190     }
1191     }
1192
1193     if (!mergeMsg)
1194     {
1195         /* Should I limit the number of message in
1196           the system message queue??? */
1197
1198         /* Don't merge allocate a new msg in the global heap */
1199
1200         if (!(qmsg = (QMSG *) HeapAlloc( SystemHeap, 0, sizeof(QMSG) ) ))
1201         {
1202             LeaveCriticalSection( &sysMsgQueue->cSection );
1203             return;
1204         }
1205
1206         /* put message at the end of the linked list */
1207         qmsg->nextMsg = 0;
1208         qmsg->prevMsg = sysMsgQueue->lastMsg;
1209
1210         if (sysMsgQueue->lastMsg)
1211             sysMsgQueue->lastMsg->nextMsg = qmsg;
1212
1213         /* set last and first anchor index in system message queue */
1214         sysMsgQueue->lastMsg = qmsg;
1215         if (!sysMsgQueue->firstMsg)
1216             sysMsgQueue->firstMsg = qmsg;
1217
1218         sysMsgQueue->msgCount++;
1219     }
1220
1221       /* Store message */
1222     msg = &(qmsg->msg);
1223     msg->hwnd    = 0;
1224     msg->message = message;
1225     msg->wParam  = wParam;
1226     msg->lParam  = lParam;
1227     msg->time    = time;
1228     msg->pt.x    = xPos;
1229     msg->pt.y    = yPos;
1230     qmsg->extraInfo = extraInfo;
1231
1232     LeaveCriticalSection( &sysMsgQueue->cSection );
1233
1234     QUEUE_WakeSomeone( message );
1235 }
1236
1237
1238 /***********************************************************************
1239  *           QUEUE_GetQueueTask
1240  */
1241 HTASK16 QUEUE_GetQueueTask( HQUEUE16 hQueue )
1242 {
1243     HTASK16 hTask = 0;
1244
1245     MESSAGEQUEUE *queue = QUEUE_Lock( hQueue );
1246
1247     if (queue)
1248 {
1249         hTask = queue->teb->process->task;
1250         QUEUE_Unlock( queue );
1251 }
1252
1253     return hTask;
1254 }
1255
1256
1257
1258 /***********************************************************************
1259  *           QUEUE_IncPaintCount
1260  */
1261 void QUEUE_IncPaintCount( HQUEUE16 hQueue )
1262 {
1263     MESSAGEQUEUE *queue;
1264
1265     if (!(queue = (MESSAGEQUEUE *)QUEUE_Lock( hQueue ))) return;
1266     queue->wPaintCount++;
1267     QUEUE_SetWakeBit( queue, QS_PAINT );
1268     QUEUE_Unlock( queue );
1269 }
1270
1271
1272 /***********************************************************************
1273  *           QUEUE_DecPaintCount
1274  */
1275 void QUEUE_DecPaintCount( HQUEUE16 hQueue )
1276 {
1277     MESSAGEQUEUE *queue;
1278
1279     if (!(queue = (MESSAGEQUEUE *)QUEUE_Lock( hQueue ))) return;
1280     queue->wPaintCount--;
1281     if (!queue->wPaintCount) queue->wakeBits &= ~QS_PAINT;
1282     QUEUE_Unlock( queue );
1283 }
1284
1285
1286 /***********************************************************************
1287  *           QUEUE_IncTimerCount
1288  */
1289 void QUEUE_IncTimerCount( HQUEUE16 hQueue )
1290 {
1291     MESSAGEQUEUE *queue;
1292
1293     if (!(queue = (MESSAGEQUEUE *)QUEUE_Lock( hQueue ))) return;
1294     queue->wTimerCount++;
1295     QUEUE_SetWakeBit( queue, QS_TIMER );
1296     QUEUE_Unlock( queue );
1297 }
1298
1299
1300 /***********************************************************************
1301  *           QUEUE_DecTimerCount
1302  */
1303 void QUEUE_DecTimerCount( HQUEUE16 hQueue )
1304 {
1305     MESSAGEQUEUE *queue;
1306
1307     if (!(queue = (MESSAGEQUEUE *)QUEUE_Lock( hQueue ))) return;
1308     queue->wTimerCount--;
1309     if (!queue->wTimerCount) queue->wakeBits &= ~QS_TIMER;
1310     QUEUE_Unlock( queue );
1311 }
1312
1313
1314 /***********************************************************************
1315  *           PostQuitMessage16   (USER.6)
1316  */
1317 void WINAPI PostQuitMessage16( INT16 exitCode )
1318 {
1319     PostQuitMessage( exitCode );
1320 }
1321
1322
1323 /***********************************************************************
1324  *           PostQuitMessage32   (USER32.421)
1325  *
1326  * PostQuitMessage() posts a message to the system requesting an
1327  * application to terminate execution. As a result of this function,
1328  * the WM_QUIT message is posted to the application, and
1329  * PostQuitMessage() returns immediately.  The exitCode parameter
1330  * specifies an application-defined exit code, which appears in the
1331  * _wParam_ parameter of the WM_QUIT message posted to the application.
1332  *
1333  * CONFORMANCE
1334  *
1335  *  ECMA-234, Win32
1336  */
1337 void WINAPI PostQuitMessage( INT exitCode )
1338 {
1339     MESSAGEQUEUE *queue;
1340
1341     if (!(queue = (MESSAGEQUEUE *)QUEUE_Lock( GetFastQueue16() ))) return;
1342     queue->wPostQMsg = TRUE;
1343     queue->wExitCode = (WORD)exitCode;
1344     QUEUE_Unlock( queue );
1345 }
1346
1347
1348 /***********************************************************************
1349  *           GetWindowTask16   (USER.224)
1350  */
1351 HTASK16 WINAPI GetWindowTask16( HWND16 hwnd )
1352 {
1353     HTASK16 retvalue;
1354     WND *wndPtr = WIN_FindWndPtr( hwnd );
1355
1356     if (!wndPtr) return 0;
1357     retvalue = QUEUE_GetQueueTask( wndPtr->hmemTaskQ );
1358     WIN_ReleaseWndPtr(wndPtr);
1359     return retvalue;
1360 }
1361
1362 /***********************************************************************
1363  *           GetWindowThreadProcessId   (USER32.313)
1364  */
1365 DWORD WINAPI GetWindowThreadProcessId( HWND hwnd, LPDWORD process )
1366 {
1367     DWORD retvalue;
1368     MESSAGEQUEUE *queue;
1369
1370     WND *wndPtr = WIN_FindWndPtr( hwnd );
1371     if (!wndPtr) return 0;
1372
1373     queue = QUEUE_Lock( wndPtr->hmemTaskQ );
1374     WIN_ReleaseWndPtr(wndPtr);
1375
1376     if (!queue) return 0;
1377
1378     if ( process ) *process = (DWORD)queue->teb->process->server_pid;
1379     retvalue = (DWORD)queue->teb->tid;
1380
1381     QUEUE_Unlock( queue );
1382     return retvalue;
1383 }
1384
1385
1386 /***********************************************************************
1387  *           SetMessageQueue16   (USER.266)
1388  */
1389 BOOL16 WINAPI SetMessageQueue16( INT16 size )
1390 {
1391     return SetMessageQueue( size );
1392 }
1393
1394
1395 /***********************************************************************
1396  *           SetMessageQueue32   (USER32.494)
1397  */
1398 BOOL WINAPI SetMessageQueue( INT size )
1399 {
1400     /* now obsolete the message queue will be expanded dynamically
1401      as necessary */
1402
1403     /* access the queue to create it if it's not existing */
1404     GetFastQueue16();
1405
1406     return TRUE;
1407 }
1408
1409 /***********************************************************************
1410  *           InitThreadInput   (USER.409)
1411  */
1412 HQUEUE16 WINAPI InitThreadInput16( WORD unknown, WORD flags )
1413 {
1414     HQUEUE16 hQueue;
1415     MESSAGEQUEUE *queuePtr;
1416
1417     TEB *teb = NtCurrentTeb();
1418
1419     if (!teb)
1420         return 0;
1421
1422     hQueue = teb->queue;
1423
1424     if ( !hQueue )
1425     {
1426         /* Create thread message queue */
1427         if( !(hQueue = QUEUE_CreateMsgQueue( TRUE )))
1428         {
1429             WARN_(msg)("failed!\n");
1430             return FALSE;
1431     }
1432
1433         /* Link new queue into list */
1434         queuePtr = (MESSAGEQUEUE *)QUEUE_Lock( hQueue );
1435         queuePtr->teb = NtCurrentTeb();
1436
1437         HeapLock( SystemHeap );  /* FIXME: a bit overkill */
1438         SetThreadQueue16( 0, hQueue );
1439         teb->queue = hQueue;
1440
1441         queuePtr->next  = hFirstQueue;
1442         hFirstQueue = hQueue;
1443         HeapUnlock( SystemHeap );
1444
1445         QUEUE_Unlock( queuePtr );
1446     }
1447
1448     return hQueue;
1449 }
1450
1451 /***********************************************************************
1452  *           GetQueueStatus16   (USER.334)
1453  */
1454 DWORD WINAPI GetQueueStatus16( UINT16 flags )
1455 {
1456     MESSAGEQUEUE *queue;
1457     DWORD ret;
1458
1459     if (!(queue = (MESSAGEQUEUE *)QUEUE_Lock( GetFastQueue16() ))) return 0;
1460     ret = MAKELONG( queue->changeBits, queue->wakeBits );
1461     queue->changeBits = 0;
1462     QUEUE_Unlock( queue );
1463
1464     return ret & MAKELONG( flags, flags );
1465 }
1466
1467 /***********************************************************************
1468  *           GetQueueStatus32   (USER32.283)
1469  */
1470 DWORD WINAPI GetQueueStatus( UINT flags )
1471 {
1472     MESSAGEQUEUE *queue;
1473     DWORD ret;
1474
1475     if (!(queue = (MESSAGEQUEUE *)QUEUE_Lock( GetFastQueue16() ))) return 0;
1476     ret = MAKELONG( queue->changeBits, queue->wakeBits );
1477     queue->changeBits = 0;
1478     QUEUE_Unlock( queue );
1479
1480     return ret & MAKELONG( flags, flags );
1481 }
1482
1483
1484 /***********************************************************************
1485  *           GetInputState16   (USER.335)
1486  */
1487 BOOL16 WINAPI GetInputState16(void)
1488 {
1489     return GetInputState();
1490 }
1491
1492 /***********************************************************************
1493  *           WaitForInputIdle   (USER32.577)
1494  */
1495 DWORD WINAPI WaitForInputIdle (HANDLE hProcess, DWORD dwTimeOut)
1496 {
1497   FIXME_(msg)("(hProcess=%d, dwTimeOut=%ld): stub\n", hProcess, dwTimeOut);
1498
1499   return WAIT_TIMEOUT;
1500 }
1501
1502
1503 /***********************************************************************
1504  *           GetInputState32   (USER32.244)
1505  */
1506 BOOL WINAPI GetInputState(void)
1507 {
1508     MESSAGEQUEUE *queue;
1509     BOOL ret;
1510
1511     if (!(queue = (MESSAGEQUEUE *)QUEUE_Lock( GetFastQueue16() )))
1512         return FALSE;
1513     ret = queue->wakeBits & (QS_KEY | QS_MOUSEBUTTON);
1514     QUEUE_Unlock( queue );
1515
1516     return ret;
1517 }
1518
1519 /***********************************************************************
1520  *           UserYield  (USER.332)
1521  */
1522 void WINAPI UserYield16(void)
1523 {
1524     MESSAGEQUEUE *queue;
1525
1526     /* Handle sent messages */
1527     queue = (MESSAGEQUEUE *)QUEUE_Lock( GetFastQueue16() );
1528
1529     while (queue && (queue->wakeBits & QS_SENDMESSAGE))
1530         QUEUE_ReceiveMessage( queue );
1531
1532     QUEUE_Unlock( queue );
1533
1534     /* Yield */
1535     if ( THREAD_IsWin16( NtCurrentTeb() ) )
1536         OldYield16();
1537     else
1538         WIN32_OldYield16();
1539
1540     /* Handle sent messages again */
1541     queue = (MESSAGEQUEUE *)QUEUE_Lock( GetFastQueue16() );
1542
1543     while (queue && (queue->wakeBits & QS_SENDMESSAGE))
1544         QUEUE_ReceiveMessage( queue );
1545
1546     QUEUE_Unlock( queue );
1547 }
1548
1549 /***********************************************************************
1550  *           GetMessagePos   (USER.119) (USER32.272)
1551  *
1552  * The GetMessagePos() function returns a long value representing a
1553  * cursor position, in screen coordinates, when the last message
1554  * retrieved by the GetMessage() function occurs. The x-coordinate is
1555  * in the low-order word of the return value, the y-coordinate is in
1556  * the high-order word. The application can use the MAKEPOINT()
1557  * macro to obtain a POINT structure from the return value.
1558  *
1559  * For the current cursor position, use GetCursorPos().
1560  *
1561  * RETURNS
1562  *
1563  * Cursor position of last message on success, zero on failure.
1564  *
1565  * CONFORMANCE
1566  *
1567  * ECMA-234, Win32
1568  *
1569  */
1570 DWORD WINAPI GetMessagePos(void)
1571 {
1572     MESSAGEQUEUE *queue;
1573     DWORD ret;
1574
1575     if (!(queue = (MESSAGEQUEUE *)QUEUE_Lock( GetFastQueue16() ))) return 0;
1576     ret = queue->GetMessagePosVal;
1577     QUEUE_Unlock( queue );
1578
1579     return ret;
1580 }
1581
1582
1583 /***********************************************************************
1584  *           GetMessageTime   (USER.120) (USER32.273)
1585  *
1586  * GetMessageTime() returns the message time for the last message
1587  * retrieved by the function. The time is measured in milliseconds with
1588  * the same offset as GetTickCount().
1589  *
1590  * Since the tick count wraps, this is only useful for moderately short
1591  * relative time comparisons.
1592  *
1593  * RETURNS
1594  *
1595  * Time of last message on success, zero on failure.
1596  *
1597  * CONFORMANCE
1598  *
1599  * ECMA-234, Win32
1600  *
1601  */
1602 LONG WINAPI GetMessageTime(void)
1603 {
1604     MESSAGEQUEUE *queue;
1605     LONG ret;
1606
1607     if (!(queue = (MESSAGEQUEUE *)QUEUE_Lock( GetFastQueue16() ))) return 0;
1608     ret = queue->GetMessageTimeVal;
1609     QUEUE_Unlock( queue );
1610
1611     return ret;
1612 }
1613
1614
1615 /***********************************************************************
1616  *           GetMessageExtraInfo   (USER.288) (USER32.271)
1617  */
1618 LONG WINAPI GetMessageExtraInfo(void)
1619 {
1620     MESSAGEQUEUE *queue;
1621     LONG ret;
1622
1623     if (!(queue = (MESSAGEQUEUE *)QUEUE_Lock( GetFastQueue16() ))) return 0;
1624     ret = queue->GetMessageExtraInfoVal;
1625     QUEUE_Unlock( queue );
1626
1627     return ret;
1628 }