windows/queue.c

   1 /*
   2  * Message queues related functions
   3  *
   4  * Copyright 1993, 1994 Alexandre Julliard
   5  */
   6
   7 #include <stdlib.h>
   8 #include <signal.h>
   9 #include "miscemu.h"
  10 #include "module.h"
  11 #include "queue.h"
  12 #include "task.h"
  13 #include "win.h"
  14 #include "clipboard.h"
  15 #include "hook.h"
  16 #include "heap.h"
  17 #include "thread.h"
  18 #include "process.h"
  19 #include "debug.h"
  20
  21 #define MAX_QUEUE_SIZE   120  /* Max. size of a message queue */
  22
  23 static HQUEUE16 hFirstQueue = 0;
  24 static HQUEUE16 hExitingQueue = 0;
  25 static HQUEUE16 hmemSysMsgQueue = 0;
  26 static MESSAGEQUEUE *sysMsgQueue = NULL;
  27
  28 static MESSAGEQUEUE *pMouseQueue = NULL;  /* Queue for last mouse message */
  29 static MESSAGEQUEUE *pKbdQueue = NULL;    /* Queue for last kbd message */
  30
  31 MESSAGEQUEUE *pCursorQueue = NULL;
  32 MESSAGEQUEUE *pActiveQueue = NULL;
  33
  34 /***********************************************************************
  35  *           QUEUE_DumpQueue
  36  */
  37 void QUEUE_DumpQueue( HQUEUE16 hQueue )
  38 {
  39     MESSAGEQUEUE *pq;
  40
  41     if (!(pq = (MESSAGEQUEUE*) GlobalLock16( hQueue )) ||
  42         GlobalSize16(hQueue) < sizeof(MESSAGEQUEUE)+pq->queueSize*sizeof(QMSG))
  43     {
  44         WARN(msg, "%04x is not a queue handle\n", hQueue );
  45         return;
  46     }
  47
  48     DUMP(    "next: %12.4x  Intertask SendMessage:\n"
  49              "hTask: %11.4x  ----------------------\n"
  50              "msgSize: %9.4x  hWnd: %10.4x\n"
  51              "msgCount: %8.4x  msg: %11.4x\n"
  52              "msgNext: %9.4x  wParam: %8.4x\n"
  53              "msgFree: %9.4x  lParam: %8.8x\n"
  54              "qSize: %11.4x  lRet: %10.8x\n"
  55              "wWinVer: %9.4x  ISMH: %10.4x\n"
  56              "paints: %10.4x  hSendTask: %5.4x\n"
  57              "timers: %10.4x  hPrevSend: %5.4x\n"
  58              "wakeBits: %8.4x\n"
  59              "wakeMask: %8.4x\n"
  60              "hCurHook: %8.4x\n",
  61              pq->next, pq->hTask, pq->msgSize, pq->hWnd,
  62              pq->msgCount, pq->msg, pq->nextMessage, pq->wParam,
  63              pq->nextFreeMessage, (unsigned)pq->lParam, pq->queueSize,
  64              (unsigned)pq->SendMessageReturn, pq->wWinVersion, pq->InSendMessageHandle,
  65              pq->wPaintCount, pq->hSendingTask, pq->wTimerCount,
  66              pq->hPrevSendingTask, pq->wakeBits, pq->wakeMask, pq->hCurHook);
  67 }
  68
  69
  70 /***********************************************************************
  71  *           QUEUE_WalkQueues
  72  */
  73 void QUEUE_WalkQueues(void)
  74 {
  75     char module[10];
  76     HQUEUE16 hQueue = hFirstQueue;
  77
  78     DUMP( "Queue Size Msgs Task\n" );
  79     while (hQueue)
  80     {
  81         MESSAGEQUEUE *queue = (MESSAGEQUEUE *)GlobalLock16( hQueue );
  82         if (!queue)
  83         {
  84             WARN( msg, "Bad queue handle %04x\n", hQueue );
  85             return;
  86         }
  87         if (!GetModuleName( queue->hTask, module, sizeof(module )))
  88             strcpy( module, "???" );
  89         DUMP( "%04x %5d %4d %04x %s\n", hQueue, queue->msgSize,
  90                  queue->msgCount, queue->hTask, module );
  91         hQueue = queue->next;
  92     }
  93     DUMP( "\n" );
  94 }
  95
  96
  97 /***********************************************************************
  98  *           QUEUE_IsExitingQueue
  99  */
 100 BOOL32 QUEUE_IsExitingQueue( HQUEUE16 hQueue )
 101 {
 102     return (hExitingQueue && (hQueue == hExitingQueue));
 103 }
 104
 105
 106 /***********************************************************************
 107  *           QUEUE_SetExitingQueue
 108  */
 109 void QUEUE_SetExitingQueue( HQUEUE16 hQueue )
 110 {
 111     hExitingQueue = hQueue;
 112 }
 113
 114
 115 /***********************************************************************
 116  *           QUEUE_CreateMsgQueue
 117  *
 118  * Creates a message queue. Doesn't link it into queue list!
 119  */
 120 static HQUEUE16 QUEUE_CreateMsgQueue( int size )
 121 {
 122     HQUEUE16 hQueue;
 123     MESSAGEQUEUE * msgQueue;
 124     int queueSize;
 125     TDB *pTask = (TDB *)GlobalLock16( GetCurrentTask() );
 126
 127     TRACE(msg,"Creating message queue...\n");
 128
 129     queueSize = sizeof(MESSAGEQUEUE) + size * sizeof(QMSG);
 130     if (!(hQueue = GlobalAlloc16( GMEM_FIXED | GMEM_ZEROINIT, queueSize )))
 131         return 0;
 132     msgQueue = (MESSAGEQUEUE *) GlobalLock16( hQueue );
 133     msgQueue->self        = hQueue;
 134     msgQueue->msgSize     = sizeof(QMSG);
 135     msgQueue->queueSize   = size;
 136     msgQueue->wakeBits    = msgQueue->changeBits = QS_SMPARAMSFREE;
 137     msgQueue->wWinVersion = pTask ? pTask->version : 0;
 138     GlobalUnlock16( hQueue );
 139     return hQueue;
 140 }
 141
 142
 143 /***********************************************************************
 144  *           QUEUE_DeleteMsgQueue
 145  *
 146  * Unlinks and deletes a message queue.
 147  *
 148  * Note: We need to mask asynchronous events to make sure PostMessage works
 149  * even in the signal handler.
 150  */
 151 BOOL32 QUEUE_DeleteMsgQueue( HQUEUE16 hQueue )
 152 {
 153     MESSAGEQUEUE * msgQueue = (MESSAGEQUEUE*)GlobalLock16(hQueue);
 154     HQUEUE16  senderQ;
 155     HQUEUE16 *pPrev;
 156
 157     TRACE(msg,"Deleting message queue %04x\n", hQueue);
 158
 159     if (!hQueue || !msgQueue)
 160     {
 161         WARN(msg, "invalid argument.\n");
 162         return 0;
 163     }
 164     if( pCursorQueue == msgQueue ) pCursorQueue = NULL;
 165     if( pActiveQueue == msgQueue ) pActiveQueue = NULL;
 166
 167     /* flush sent messages */
 168     senderQ = msgQueue->hSendingTask;
 169     while( senderQ )
 170     {
 171       MESSAGEQUEUE* sq = (MESSAGEQUEUE*)GlobalLock16(senderQ);
 172       if( !sq ) break;
 173       sq->SendMessageReturn = 0L;
 174       QUEUE_SetWakeBit( sq, QS_SMRESULT );
 175       senderQ = sq->hPrevSendingTask;
 176     }
 177
 178     SIGNAL_MaskAsyncEvents( TRUE );
 179
 180     pPrev = &hFirstQueue;
 181     while (*pPrev && (*pPrev != hQueue))
 182     {
 183         MESSAGEQUEUE *msgQ = (MESSAGEQUEUE*)GlobalLock16(*pPrev);
 184         pPrev = &msgQ->next;
 185     }
 186     if (*pPrev) *pPrev = msgQueue->next;
 187     msgQueue->self = 0;
 188
 189     SIGNAL_MaskAsyncEvents( FALSE );
 190
 191     GlobalFree16( hQueue );
 192     return 1;
 193 }
 194
 195
 196 /***********************************************************************
 197  *           QUEUE_CreateSysMsgQueue
 198  *
 199  * Create the system message queue, and set the double-click speed.
 200  * Must be called only once.
 201  */
 202 BOOL32 QUEUE_CreateSysMsgQueue( int size )
 203 {
 204     if (size > MAX_QUEUE_SIZE) size = MAX_QUEUE_SIZE;
 205     else if (size <= 0) size = 1;
 206     if (!(hmemSysMsgQueue = QUEUE_CreateMsgQueue( size ))) return FALSE;
 207     sysMsgQueue = (MESSAGEQUEUE *) GlobalLock16( hmemSysMsgQueue );
 208     return TRUE;
 209 }
 210
 211
 212 /***********************************************************************
 213  *           QUEUE_GetSysQueue
 214  */
 215 MESSAGEQUEUE *QUEUE_GetSysQueue(void)
 216 {
 217     return sysMsgQueue;
 218 }
 219
 220 /***********************************************************************
 221  *           QUEUE_Signal
 222  */
 223 void QUEUE_Signal( HTASK16 hTask )
 224 {
 225     PDB32 *pdb;
 226     THREAD_ENTRY *entry;
 227     int wakeup = FALSE;
 228
 229     TDB *pTask = (TDB *)GlobalLock16( hTask );
 230     if ( !pTask ) return;
 231
 232     TRACE(msg, "calling SYNC_MsgWakeUp\n");
 233
 234     /* Wake up thread waiting for message */
 235     /* NOTE: This should really wake up *the* thread that owns
 236              the queue. Since we dont't have thread-local message
 237              queues yet, we wake up all waiting threads ... */
 238     SYSTEM_LOCK();
 239     pdb = pTask->thdb->process;
 240     entry = pdb? pdb->thread_list->next : NULL;
 241
 242     if (entry)
 243         for (;;)
 244         {
 245             if (entry->thread->wait_struct.wait_msg)
 246             {
 247                 SYNC_MsgWakeUp( entry->thread );
 248                 wakeup = TRUE;
 249             }
 250             if (entry == pdb->thread_list) break;
 251             entry = entry->next;
 252         }
 253     SYSTEM_UNLOCK();
 254
 255     if ( !wakeup && THREAD_IsWin16( THREAD_Current() ) )
 256         PostEvent( hTask );
 257 }
 258
 259 /***********************************************************************
 260  *           QUEUE_Wait
 261  */
 262 void QUEUE_Wait( void )
 263 {
 264     if ( THREAD_IsWin16( THREAD_Current() ) )
 265         WaitEvent( 0 );
 266     else
 267     {
 268         TRACE(msg, "current task is 32-bit, calling SYNC_DoWait\n");
 269         SYNC_DoWait( 0, NULL, FALSE, INFINITE32, FALSE, TRUE );
 270     }
 271 }
 272
 273
 274 /***********************************************************************
 275  *           QUEUE_SetWakeBit
 276  *
 277  * See "Windows Internals", p.449
 278  */
 279 void QUEUE_SetWakeBit( MESSAGEQUEUE *queue, WORD bit )
 280 {
 281     TRACE(msg,"queue = %04x (wm=%04x), bit = %04x\n",
 282                         queue->self, queue->wakeMask, bit );
 283
 284     if (bit & QS_MOUSE) pMouseQueue = queue;
 285     if (bit & QS_KEY) pKbdQueue = queue;
 286     queue->changeBits |= bit;
 287     queue->wakeBits   |= bit;
 288     if (queue->wakeMask & bit)
 289     {
 290         queue->wakeMask = 0;
 291         QUEUE_Signal( queue->hTask );
 292     }
 293 }
 294
 295
 296 /***********************************************************************
 297  *           QUEUE_ClearWakeBit
 298  */
 299 void QUEUE_ClearWakeBit( MESSAGEQUEUE *queue, WORD bit )
 300 {
 301     queue->changeBits &= ~bit;
 302     queue->wakeBits   &= ~bit;
 303 }
 304
 305
 306 /***********************************************************************
 307  *           QUEUE_WaitBits
 308  *
 309  * See "Windows Internals", p.447
 310  */
 311 void QUEUE_WaitBits( WORD bits )
 312 {
 313     MESSAGEQUEUE *queue;
 314
 315     TRACE(msg,"q %04x waiting for %04x\n", GetTaskQueue(0), bits);
 316
 317     for (;;)
 318     {
 319         if (!(queue = (MESSAGEQUEUE *)GlobalLock16( GetTaskQueue(0) ))) return;
 320
 321         if (queue->changeBits & bits)
 322         {
 323             /* One of the bits is set; we can return */
 324             queue->wakeMask = 0;
 325             return;
 326         }
 327         if (queue->wakeBits & QS_SENDMESSAGE)
 328         {
 329             /* Process the sent message immediately */
 330
 331             queue->wakeMask = 0;
 332             QUEUE_ReceiveMessage( queue );
 333             continue;                           /* nested sm crux */
 334         }
 335
 336         queue->wakeMask = bits | QS_SENDMESSAGE;
 337         if(queue->changeBits & bits) continue;
 338
 339         TRACE(msg,"%04x) wakeMask is %04x, waiting\n", queue->self, queue->wakeMask);
 340
 341         QUEUE_Wait();
 342     }
 343 }
 344
 345
 346 /***********************************************************************
 347  *           QUEUE_ReceiveMessage
 348  *
 349  * This routine is called when a sent message is waiting for the queue.
 350  */
 351 void QUEUE_ReceiveMessage( MESSAGEQUEUE *queue )
 352 {
 353     MESSAGEQUEUE *senderQ = NULL;
 354     HQUEUE16      prevSender = 0;
 355     QSMCTRL*      prevCtrlPtr = NULL;
 356     LRESULT       result = 0;
 357
 358     TRACE(msg, "ReceiveMessage, queue %04x\n", queue->self );
 359     if (!(queue->wakeBits & QS_SENDMESSAGE) ||
 360         !(senderQ = (MESSAGEQUEUE*)GlobalLock16( queue->hSendingTask)))
 361         { TRACE(msg,"\trcm: nothing to do\n"); return; }
 362
 363     if( !senderQ->hPrevSendingTask )
 364     {
 365       queue->wakeBits &= ~QS_SENDMESSAGE;       /* no more sent messages */
 366       queue->changeBits &= ~QS_SENDMESSAGE;
 367     }
 368
 369     /* Save current state on stack */
 370     prevSender                 = queue->InSendMessageHandle;
 371     prevCtrlPtr                = queue->smResultCurrent;
 372
 373     /* Remove sending queue from the list */
 374     queue->InSendMessageHandle = queue->hSendingTask;
 375     queue->smResultCurrent     = senderQ->smResultInit;
 376     queue->hSendingTask        = senderQ->hPrevSendingTask;
 377
 378     TRACE(msg, "\trcm: smResultCurrent = %08x, prevCtrl = %08x\n",
 379                                 (unsigned)queue->smResultCurrent, (unsigned)prevCtrlPtr );
 380     QUEUE_SetWakeBit( senderQ, QS_SMPARAMSFREE );
 381
 382     TRACE(msg, "\trcm: calling wndproc - %04x %04x %04x%04x %08x\n",
 383                 senderQ->hWnd, senderQ->msg, senderQ->wParamHigh,
 384                 senderQ->wParam, (unsigned)senderQ->lParam );
 385
 386     if (IsWindow32( senderQ->hWnd ))
 387     {
 388         WND *wndPtr = WIN_FindWndPtr( senderQ->hWnd );
 389         DWORD extraInfo = queue->GetMessageExtraInfoVal;
 390         queue->GetMessageExtraInfoVal = senderQ->GetMessageExtraInfoVal;
 391
 392         if (senderQ->flags & QUEUE_SM_WIN32)
 393         {
 394             WPARAM32 wParam = MAKELONG( senderQ->wParam, senderQ->wParamHigh );
 395             TRACE(msg, "\trcm: msg is Win32\n" );
 396             if (senderQ->flags & QUEUE_SM_UNICODE)
 397                 result = CallWindowProc32W( wndPtr->winproc,
 398                                             senderQ->hWnd, senderQ->msg,
 399                                             wParam, senderQ->lParam );
 400             else
 401                 result = CallWindowProc32A( wndPtr->winproc,
 402                                             senderQ->hWnd, senderQ->msg,
 403                                             wParam, senderQ->lParam );
 404         }
 405         else  /* Win16 message */
 406             result = CallWindowProc16( (WNDPROC16)wndPtr->winproc,
 407                                        senderQ->hWnd, senderQ->msg,
 408                                        senderQ->wParam, senderQ->lParam );
 409
 410         queue->GetMessageExtraInfoVal = extraInfo;  /* Restore extra info */
 411         TRACE(msg,"\trcm: result =  %08x\n", (unsigned)result );
 412     }
 413     else WARN(msg, "\trcm: bad hWnd\n");
 414
 415     /* Return the result to the sender task */
 416     ReplyMessage16( result );
 417
 418     queue->InSendMessageHandle = prevSender;
 419     queue->smResultCurrent     = prevCtrlPtr;
 420
 421     TRACE(msg,"done!\n");
 422 }
 423
 424 /***********************************************************************
 425  *           QUEUE_FlushMessage
 426  *
 427  * Try to reply to all pending sent messages on exit.
 428  */
 429 void QUEUE_FlushMessages( HQUEUE16 hQueue )
 430 {
 431   MESSAGEQUEUE *queue = (MESSAGEQUEUE*)GlobalLock16( hQueue );
 432
 433   if( queue )
 434   {
 435     MESSAGEQUEUE *senderQ = (MESSAGEQUEUE*)GlobalLock16( queue->hSendingTask);
 436     QSMCTRL*      CtrlPtr = queue->smResultCurrent;
 437
 438     while( senderQ )
 439     {
 440       if( !(queue->hSendingTask = senderQ->hPrevSendingTask) )
 441             queue->wakeBits &= ~QS_SENDMESSAGE;
 442       QUEUE_SetWakeBit( senderQ, QS_SMPARAMSFREE );
 443
 444       queue->smResultCurrent = CtrlPtr;
 445       while( senderQ->wakeBits & QS_SMRESULT ) OldYield();
 446
 447       senderQ->SendMessageReturn = 0;
 448       senderQ->smResult = queue->smResultCurrent;
 449       QUEUE_SetWakeBit( senderQ, QS_SMRESULT);
 450
 451       if( (senderQ = (MESSAGEQUEUE*)GlobalLock16( queue->hSendingTask)) )
 452            CtrlPtr = senderQ->smResultInit;
 453     }
 454     queue->InSendMessageHandle = 0;
 455   }
 456 }
 457
 458 /***********************************************************************
 459  *           QUEUE_AddMsg
 460  *
 461  * Add a message to the queue. Return FALSE if queue is full.
 462  */
 463 BOOL32 QUEUE_AddMsg( HQUEUE16 hQueue, MSG16 * msg, DWORD extraInfo )
 464 {
 465     int pos;
 466     MESSAGEQUEUE *msgQueue;
 467
 468     SIGNAL_MaskAsyncEvents( TRUE );
 469
 470     if (!(msgQueue = (MESSAGEQUEUE *)GlobalLock16( hQueue ))) return FALSE;
 471     pos = msgQueue->nextFreeMessage;
 472
 473       /* Check if queue is full */
 474     if ((pos == msgQueue->nextMessage) && (msgQueue->msgCount > 0))
 475     {
 476         SIGNAL_MaskAsyncEvents( FALSE );
 477         WARN( msg,"Queue is full!\n" );
 478         return FALSE;
 479     }
 480
 481       /* Store message */
 482     msgQueue->messages[pos].msg = *msg;
 483     msgQueue->messages[pos].extraInfo = extraInfo;
 484     if (pos < msgQueue->queueSize-1) pos++;
 485     else pos = 0;
 486     msgQueue->nextFreeMessage = pos;
 487     msgQueue->msgCount++;
 488
 489     SIGNAL_MaskAsyncEvents( FALSE );
 490
 491     QUEUE_SetWakeBit( msgQueue, QS_POSTMESSAGE );
 492     return TRUE;
 493 }
 494
 495
 496 /***********************************************************************
 497  *           QUEUE_FindMsg
 498  *
 499  * Find a message matching the given parameters. Return -1 if none available.
 500  */
 501 int QUEUE_FindMsg( MESSAGEQUEUE * msgQueue, HWND32 hwnd, int first, int last )
 502 {
 503     int i, pos = msgQueue->nextMessage;
 504
 505     TRACE(msg,"hwnd=%04x pos=%d\n", hwnd, pos );
 506
 507     if (!msgQueue->msgCount) return -1;
 508     if (!hwnd && !first && !last) return pos;
 509
 510     for (i = 0; i < msgQueue->msgCount; i++)
 511     {
 512         MSG16 * msg = &msgQueue->messages[pos].msg;
 513
 514         if (!hwnd || (msg->hwnd == hwnd))
 515         {
 516             if (!first && !last) return pos;
 517             if ((msg->message >= first) && (msg->message <= last)) return pos;
 518         }
 519         if (pos < msgQueue->queueSize-1) pos++;
 520         else pos = 0;
 521     }
 522     return -1;
 523 }
 524
 525
 526 /***********************************************************************
 527  *           QUEUE_RemoveMsg
 528  *
 529  * Remove a message from the queue (pos must be a valid position).
 530  */
 531 void QUEUE_RemoveMsg( MESSAGEQUEUE * msgQueue, int pos )
 532 {
 533     SIGNAL_MaskAsyncEvents( TRUE );
 534
 535     if (pos >= msgQueue->nextMessage)
 536     {
 537         for ( ; pos > msgQueue->nextMessage; pos--)
 538             msgQueue->messages[pos] = msgQueue->messages[pos-1];
 539         msgQueue->nextMessage++;
 540         if (msgQueue->nextMessage >= msgQueue->queueSize)
 541             msgQueue->nextMessage = 0;
 542     }
 543     else
 544     {
 545         for ( ; pos < msgQueue->nextFreeMessage; pos++)
 546             msgQueue->messages[pos] = msgQueue->messages[pos+1];
 547         if (msgQueue->nextFreeMessage) msgQueue->nextFreeMessage--;
 548         else msgQueue->nextFreeMessage = msgQueue->queueSize-1;
 549     }
 550     msgQueue->msgCount--;
 551     if (!msgQueue->msgCount) msgQueue->wakeBits &= ~QS_POSTMESSAGE;
 552
 553     SIGNAL_MaskAsyncEvents( FALSE );
 554 }
 555
 556
 557 /***********************************************************************
 558  *           QUEUE_WakeSomeone
 559  *
 560  * Wake a queue upon reception of a hardware event.
 561  */
 562 static void QUEUE_WakeSomeone( UINT32 message )
 563 {
 564     WND*          wndPtr = NULL;
 565     WORD          wakeBit;
 566     HWND32 hwnd;
 567     MESSAGEQUEUE *queue = pCursorQueue;
 568
 569     if( (message >= WM_KEYFIRST) && (message <= WM_KEYLAST) )
 570     {
 571        wakeBit = QS_KEY;
 572        if( pActiveQueue ) queue = pActiveQueue;
 573     }
 574     else
 575     {
 576        wakeBit = (message == WM_MOUSEMOVE) ? QS_MOUSEMOVE : QS_MOUSEBUTTON;
 577        if( (hwnd = GetCapture32()) )
 578          if( (wndPtr = WIN_FindWndPtr( hwnd )) )
 579            queue = (MESSAGEQUEUE *)GlobalLock16( wndPtr->hmemTaskQ );
 580     }
 581
 582     if( (hwnd = GetSysModalWindow16()) )
 583       if( (wndPtr = WIN_FindWndPtr( hwnd )) )
 584         queue = (MESSAGEQUEUE *)GlobalLock16( wndPtr->hmemTaskQ );
 585
 586     if( !queue )
 587     {
 588       queue = GlobalLock16( hFirstQueue );
 589       while( queue )
 590       {
 591         if (queue->wakeMask & wakeBit) break;
 592         queue = GlobalLock16( queue->next );
 593       }
 594       if( !queue )
 595       {
 596         WARN(msg, "couldn't find queue\n");
 597         return;
 598       }
 599     }
 600
 601     QUEUE_SetWakeBit( queue, wakeBit );
 602 }
 603
 604
 605 /***********************************************************************
 606  *           hardware_event
 607  *
 608  * Add an event to the system message queue.
 609  * Note: the position is relative to the desktop window.
 610  */
 611 void hardware_event( WORD message, WORD wParam, LONG lParam,
 612                      int xPos, int yPos, DWORD time, DWORD extraInfo )
 613 {
 614     MSG16 *msg;
 615     int pos;
 616
 617     if (!sysMsgQueue) return;
 618     pos = sysMsgQueue->nextFreeMessage;
 619
 620       /* Merge with previous event if possible */
 621
 622     if ((message == WM_MOUSEMOVE) && sysMsgQueue->msgCount)
 623     {
 624         if (pos > 0) pos--;
 625         else pos = sysMsgQueue->queueSize - 1;
 626         msg = &sysMsgQueue->messages[pos].msg;
 627         if ((msg->message == message) && (msg->wParam == wParam))
 628             sysMsgQueue->msgCount--;  /* Merge events */
 629         else
 630             pos = sysMsgQueue->nextFreeMessage;  /* Don't merge */
 631     }
 632
 633       /* Check if queue is full */
 634
 635     if ((pos == sysMsgQueue->nextMessage) && sysMsgQueue->msgCount)
 636     {
 637         /* Queue is full, beep (but not on every mouse motion...) */
 638         if (message != WM_MOUSEMOVE) MessageBeep32(0);
 639         return;
 640     }
 641
 642       /* Store message */
 643
 644     msg = &sysMsgQueue->messages[pos].msg;
 645     msg->hwnd    = 0;
 646     msg->message = message;
 647     msg->wParam  = wParam;
 648     msg->lParam  = lParam;
 649     msg->time    = time;
 650     msg->pt.x    = xPos & 0xffff;
 651     msg->pt.y    = yPos & 0xffff;
 652     sysMsgQueue->messages[pos].extraInfo = extraInfo;
 653     if (pos < sysMsgQueue->queueSize - 1) pos++;
 654     else pos = 0;
 655     sysMsgQueue->nextFreeMessage = pos;
 656     sysMsgQueue->msgCount++;
 657     QUEUE_WakeSomeone( message );
 658 }
 659
 660
 661 /***********************************************************************
 662  *           QUEUE_GetQueueTask
 663  */
 664 HTASK16 QUEUE_GetQueueTask( HQUEUE16 hQueue )
 665 {
 666     MESSAGEQUEUE *queue = GlobalLock16( hQueue );
 667     return (queue) ? queue->hTask : 0 ;
 668 }
 669
 670
 671 /***********************************************************************
 672  *           QUEUE_IncPaintCount
 673  */
 674 void QUEUE_IncPaintCount( HQUEUE16 hQueue )
 675 {
 676     MESSAGEQUEUE *queue;
 677
 678     if (!(queue = (MESSAGEQUEUE *)GlobalLock16( hQueue ))) return;
 679     queue->wPaintCount++;
 680     QUEUE_SetWakeBit( queue, QS_PAINT );
 681 }
 682
 683
 684 /***********************************************************************
 685  *           QUEUE_DecPaintCount
 686  */
 687 void QUEUE_DecPaintCount( HQUEUE16 hQueue )
 688 {
 689     MESSAGEQUEUE *queue;
 690
 691     if (!(queue = (MESSAGEQUEUE *)GlobalLock16( hQueue ))) return;
 692     queue->wPaintCount--;
 693     if (!queue->wPaintCount) queue->wakeBits &= ~QS_PAINT;
 694 }
 695
 696
 697 /***********************************************************************
 698  *           QUEUE_IncTimerCount
 699  */
 700 void QUEUE_IncTimerCount( HQUEUE16 hQueue )
 701 {
 702     MESSAGEQUEUE *queue;
 703
 704     if (!(queue = (MESSAGEQUEUE *)GlobalLock16( hQueue ))) return;
 705     queue->wTimerCount++;
 706     QUEUE_SetWakeBit( queue, QS_TIMER );
 707 }
 708
 709
 710 /***********************************************************************
 711  *           QUEUE_DecTimerCount
 712  */
 713 void QUEUE_DecTimerCount( HQUEUE16 hQueue )
 714 {
 715     MESSAGEQUEUE *queue;
 716
 717     if (!(queue = (MESSAGEQUEUE *)GlobalLock16( hQueue ))) return;
 718     queue->wTimerCount--;
 719     if (!queue->wTimerCount) queue->wakeBits &= ~QS_TIMER;
 720 }
 721
 722
 723 /***********************************************************************
 724  *           PostQuitMessage16   (USER.6)
 725  */
 726 void WINAPI PostQuitMessage16( INT16 exitCode )
 727 {
 728     PostQuitMessage32( exitCode );
 729 }
 730
 731
 732 /***********************************************************************
 733  *           PostQuitMessage32   (USER32.421)
 734  */
 735 void WINAPI PostQuitMessage32( INT32 exitCode )
 736 {
 737     MESSAGEQUEUE *queue;
 738
 739     if (!(queue = (MESSAGEQUEUE *)GlobalLock16( GetTaskQueue(0) ))) return;
 740     queue->wPostQMsg = TRUE;
 741     queue->wExitCode = (WORD)exitCode;
 742 }
 743
 744
 745 /***********************************************************************
 746  *           GetWindowTask16   (USER.224)
 747  */
 748 HTASK16 WINAPI GetWindowTask16( HWND16 hwnd )
 749 {
 750     WND *wndPtr = WIN_FindWndPtr( hwnd );
 751
 752     if (!wndPtr) return 0;
 753     return QUEUE_GetQueueTask( wndPtr->hmemTaskQ );
 754 }
 755
 756 /***********************************************************************
 757  *           GetWindowThreadProcessId   (USER32.313)
 758  */
 759 DWORD WINAPI GetWindowThreadProcessId( HWND32 hwnd, LPDWORD process )
 760 {
 761     HTASK16 htask;
 762     TDB *tdb;
 763
 764     WND *wndPtr = WIN_FindWndPtr( hwnd );
 765
 766     if (!wndPtr) return 0;
 767     htask=QUEUE_GetQueueTask( wndPtr->hmemTaskQ );
 768     tdb = (TDB*)GlobalLock16(htask);
 769     if (!tdb || !tdb->thdb) return 0;
 770     if (process) *process = PDB_TO_PROCESS_ID( tdb->thdb->process );
 771     return THDB_TO_THREAD_ID( tdb->thdb );
 772 }
 773
 774
 775 /***********************************************************************
 776  *           SetMessageQueue16   (USER.266)
 777  */
 778 BOOL16 WINAPI SetMessageQueue16( INT16 size )
 779 {
 780     return SetMessageQueue32( size );
 781 }
 782
 783
 784 /***********************************************************************
 785  *           SetMessageQueue32   (USER32.494)
 786  */
 787 BOOL32 WINAPI SetMessageQueue32( INT32 size )
 788 {
 789     HQUEUE16 hQueue, hNewQueue;
 790     MESSAGEQUEUE *queuePtr;
 791
 792     TRACE(msg,"task %04x size %i\n", GetCurrentTask(), size);
 793
 794     if ((size > MAX_QUEUE_SIZE) || (size <= 0)) return TRUE;
 795
 796     if( !(hNewQueue = QUEUE_CreateMsgQueue( size )))
 797     {
 798         WARN(msg, "failed!\n");
 799         return FALSE;
 800     }
 801     queuePtr = (MESSAGEQUEUE *)GlobalLock16( hNewQueue );
 802
 803     SIGNAL_MaskAsyncEvents( TRUE );
 804
 805     /* Copy data and free the old message queue */
 806     if ((hQueue = GetTaskQueue(0)) != 0)
 807     {
 808        MESSAGEQUEUE *oldQ = (MESSAGEQUEUE *)GlobalLock16( hQueue );
 809        memcpy( &queuePtr->wParamHigh, &oldQ->wParamHigh,
 810                         (int)oldQ->messages - (int)(&oldQ->wParamHigh) );
 811        HOOK_ResetQueueHooks( hNewQueue );
 812        if( WIN_GetDesktop()->hmemTaskQ == hQueue )
 813            WIN_GetDesktop()->hmemTaskQ = hNewQueue;
 814        WIN_ResetQueueWindows( WIN_GetDesktop(), hQueue, hNewQueue );
 815        CLIPBOARD_ResetLock( hQueue, hNewQueue );
 816        QUEUE_DeleteMsgQueue( hQueue );
 817     }
 818
 819     /* Link new queue into list */
 820     queuePtr->hTask = GetCurrentTask();
 821     queuePtr->next  = hFirstQueue;
 822     hFirstQueue = hNewQueue;
 823
 824     if( !queuePtr->next ) pCursorQueue = queuePtr;
 825     SetTaskQueue( 0, hNewQueue );
 826
 827     SIGNAL_MaskAsyncEvents( FALSE );
 828     return TRUE;
 829 }
 830
 831
 832 /***********************************************************************
 833  *           GetQueueStatus16   (USER.334)
 834  */
 835 DWORD WINAPI GetQueueStatus16( UINT16 flags )
 836 {
 837     MESSAGEQUEUE *queue;
 838     DWORD ret;
 839
 840     if (!(queue = (MESSAGEQUEUE *)GlobalLock16( GetTaskQueue(0) ))) return 0;
 841     ret = MAKELONG( queue->changeBits, queue->wakeBits );
 842     queue->changeBits = 0;
 843     return ret & MAKELONG( flags, flags );
 844 }
 845
 846 /***********************************************************************
 847  *           GetQueueStatus32   (USER32.283)
 848  */
 849 DWORD WINAPI GetQueueStatus32( UINT32 flags )
 850 {
 851     MESSAGEQUEUE *queue;
 852     DWORD ret;
 853
 854     if (!(queue = (MESSAGEQUEUE *)GlobalLock16( GetTaskQueue(0) ))) return 0;
 855     ret = MAKELONG( queue->changeBits, queue->wakeBits );
 856     queue->changeBits = 0;
 857     return ret & MAKELONG( flags, flags );
 858 }
 859
 860
 861 /***********************************************************************
 862  *           GetInputState16   (USER.335)
 863  */
 864 BOOL16 WINAPI GetInputState16(void)
 865 {
 866     return GetInputState32();
 867 }
 868
 869 /***********************************************************************
 870  *           WaitForInputIdle   (USER32.577)
 871  */
 872 DWORD WINAPI WaitForInputIdle (HANDLE32 hProcess, DWORD dwTimeOut)
 873 {
 874   FIXME (msg, "(hProcess=%d, dwTimeOut=%ld): stub\n", hProcess, dwTimeOut);
 875
 876   return WAIT_TIMEOUT;
 877 }
 878
 879
 880 /***********************************************************************
 881  *           GetInputState32   (USER32.244)
 882  */
 883 BOOL32 WINAPI GetInputState32(void)
 884 {
 885     MESSAGEQUEUE *queue;
 886
 887     if (!(queue = (MESSAGEQUEUE *)GlobalLock16( GetTaskQueue(0) )))
 888         return FALSE;
 889     return queue->wakeBits & (QS_KEY | QS_MOUSEBUTTON);
 890 }
 891
 892
 893 /***********************************************************************
 894  *           GetMessagePos   (USER.119) (USER32.272)
 895  */
 896 DWORD WINAPI GetMessagePos(void)
 897 {
 898     MESSAGEQUEUE *queue;
 899
 900     if (!(queue = (MESSAGEQUEUE *)GlobalLock16( GetTaskQueue(0) ))) return 0;
 901     return queue->GetMessagePosVal;
 902 }
 903
 904
 905 /***********************************************************************
 906  *           GetMessageTime   (USER.120) (USER32.273)
 907  */
 908 LONG WINAPI GetMessageTime(void)
 909 {
 910     MESSAGEQUEUE *queue;
 911
 912     if (!(queue = (MESSAGEQUEUE *)GlobalLock16( GetTaskQueue(0) ))) return 0;
 913     return queue->GetMessageTimeVal;
 914 }
 915
 916
 917 /***********************************************************************
 918  *           GetMessageExtraInfo   (USER.288) (USER32.271)
 919  */
 920 LONG WINAPI GetMessageExtraInfo(void)
 921 {
 922     MESSAGEQUEUE *queue;
 923
 924     if (!(queue = (MESSAGEQUEUE *)GlobalLock16( GetTaskQueue(0) ))) return 0;
 925     return queue->GetMessageExtraInfoVal;
 926 }