Changeset 10430 for trunk/src/user32/windowmsg.cpp

Timestamp:

Jan 30, 2004, 11:10:07 PM (22 years ago)

Author:

bird

Message:

#682: Drag & Drop - AttachThreadInput().

File:

• trunk/src/user32/windowmsg.cpp (modified) (7 diffs)

trunk/src/user32/windowmsg.cpp

@@ -1 @@
-/* $Id: windowmsg.cpp,v 1.47 2003-08-08 13:30:22 sandervl Exp $ */
+/* $Id: windowmsg.cpp,v 1.48 2004-01-30 22:10:07 bird Exp $ */
 /*
  * Win32 window message APIs for OS/2
@@ -40 +40 @@
 ODINDEBUGCHANNEL(USER32-WINDOWMSG)
 
-
 //******************************************************************************
 //******************************************************************************
@@ -121 +120 @@
 {
     BOOL ret;
+    TEB *pTeb = GetThreadTEB();
 
     dprintf2(("GetMessageA %x %x-%x", hwnd, uMsgFilterMin, uMsgFilterMax));
-    ret = OSLibWinGetMsg(pMsg, hwnd, uMsgFilterMin, uMsgFilterMax);
-    if(ret) dprintf2(("GetMessageA %x %x %x %x", hwnd, pMsg->message, pMsg->wParam, pMsg->lParam));
+    do
+    {
+        ret = OSLibWinGetMsg(pMsg, hwnd, uMsgFilterMin, uMsgFilterMax);
+        if(ret) dprintf2(("GetMessageA %x %x %x %x", hwnd, pMsg->message, pMsg->wParam, pMsg->lParam));
+    } while (   pTeb->o.odin.tidAttachedInputThread
+             && OSLibForwardMessageToAttachedThread(pTeb, pMsg, NULL));
     HOOK_CallHooksA(WH_GETMESSAGE, HC_ACTION, PM_REMOVE, (LPARAM)pMsg);
     return ret;
@@ -133 +137 @@
 {
     BOOL ret;
+    TEB *pTeb = GetThreadTEB();
 
     dprintf2(("GetMessageW %x %x-%x", hwnd, uMsgFilterMin, uMsgFilterMax));
-    ret = OSLibWinGetMsg(pMsg, hwnd, uMsgFilterMin, uMsgFilterMax, TRUE);
+    do
+    {
+        ret = OSLibWinGetMsg(pMsg, hwnd, uMsgFilterMin, uMsgFilterMax, TRUE);
+    } while (   pTeb->o.odin.tidAttachedInputThread
+             && OSLibForwardMessageToAttachedThread(pTeb, pMsg, NULL));
     HOOK_CallHooksW(WH_GETMESSAGE, HC_ACTION, PM_REMOVE, (LPARAM)pMsg);
     return ret;
@@ -145 +154 @@
 {
     BOOL fFoundMsg;
+    TEB *pTeb = GetThreadTEB();
 
     dprintf2(("PeekMessageA %x %d-%d %d", hwndOwner, uMsgFilterMin, uMsgFilterMax, fuRemoveMsg));
-    fFoundMsg = OSLibWinPeekMsg(msg, hwndOwner, uMsgFilterMin, uMsgFilterMax,
-                                fuRemoveMsg, FALSE);
-    if(fFoundMsg) {
+    do
+    {
+        fFoundMsg = OSLibWinPeekMsg(msg, hwndOwner, uMsgFilterMin, uMsgFilterMax, fuRemoveMsg, FALSE);
+        if (   fFoundMsg
+            && pTeb->o.odin.tidAttachedInputThread
+            && OSLibForwardMessageToAttachedThread(pTeb, msg, NULL));
+        {
+            if (!fuRemoveMsg)
+                OSLibWinPeekMsg(msg, hwndOwner, uMsgFilterMin, uMsgFilterMax, TRUE, FALSE);
+            continue;
+        }
+    } while (0);
+
+    if (fFoundMsg) {
         dprintf2(("PeekMessageA %x %d-%d %d found message %x %d %x %x", hwndOwner, uMsgFilterMin, uMsgFilterMax, fuRemoveMsg, msg->hwnd, msg->message, msg->wParam, msg->lParam));
         HOOK_CallHooksA(WH_GETMESSAGE, HC_ACTION, fuRemoveMsg & PM_REMOVE, (LPARAM)msg );
@@ -164 +185 @@
 {
     BOOL fFoundMsg;
+    TEB *pTeb = GetThreadTEB();
 
     dprintf2(("PeekMessageW %x %d-%d %d", hwndOwner, uMsgFilterMin, uMsgFilterMax, fuRemoveMsg));
-    fFoundMsg = OSLibWinPeekMsg(msg, hwndOwner, uMsgFilterMin, uMsgFilterMax,
-                                fuRemoveMsg, TRUE);
+    do
+    {
+        fFoundMsg = OSLibWinPeekMsg(msg, hwndOwner, uMsgFilterMin, uMsgFilterMax, fuRemoveMsg, TRUE);
+        if (   fFoundMsg
+            && pTeb->o.odin.tidAttachedInputThread
+            && OSLibForwardMessageToAttachedThread(pTeb, msg, NULL));
+        {
+            if (!fuRemoveMsg)
+                OSLibWinPeekMsg(msg, hwndOwner, uMsgFilterMin, uMsgFilterMax, TRUE, TRUE);
+            continue;
+        }
+    } while (0);
+
     if(fFoundMsg) {
         dprintf2(("PeekMessageW %x %d-%d %d found message %x %d %x %x", hwndOwner, uMsgFilterMin, uMsgFilterMax, fuRemoveMsg, msg->hwnd, msg->message, msg->wParam, msg->lParam));
@@ -277 +310 @@
 }
 //******************************************************************************
+
+/**
+ * Attach one threads input queue to another thread.
+ *
+ * @returns Success indicator.
+ * @param   idAttach    Thread ID of the thread to attach/detach the input
+ *                      of idAttachTo to.
+ * @param   idAttachTo  The Thread ID of the thread which input is to be taken
+ *                      over or reattached.
+ * @param   fAttach     If set attach the input queue of thread idAttachTo
+ *                      to idAttach.
+ *                      If clear detach the input queue of thread idAttach
+ *                      reattaching it to idAttachTo.
+ * @status  partially implemented.
+ * @author  knut st. osmundsen <bird-srcspam@anduin.net>
+ * @remark  One cannot attach a threads input queue to it self.
+ * @todo    Not sure if all this is 100% ok according to the windows reality.
+ *          I'm sure some error cases aren't caught.
+ */
+BOOL WIN32API AttachThreadInput(DWORD idAttach, DWORD idAttachTo, BOOL fAttach)
+{
+    dprintf(("USER32: AttachThreadInput\n"));
+    if (idAttach != idAttachTo)
+    {
+        /* pray noone frees the TEB while we're working on it... */
+        TEB *pTeb = GetTEBFromThreadId(idAttach);
+        if (pTeb)
+        {
+            TEB *pTebTo = GetTEBFromThreadId(idAttachTo);
+            if (pTebTo)
+            {
+                if (fAttach)
+                {   /* attach. */
+                    if (pTebTo->o.odin.tidAttachedInputThread)
+                    {
+                        dprintf(("USER32: AttachThreadInput: WARNING! %#x is already attached to %#x\n", idAttachTo, pTebTo->o.odin.tidAttachedInputThread));
+                        DebugInt3();
+                    }
+                    pTebTo->o.odin.tidAttachedInputThread = idAttach;
+                    dprintf(("USER32: AttachThreadInput: Attached input from %#x to %#x\n", idAttachTo, idAttach));
+                }
+                else
+                {   /* deattach - i.e. undo previous AttachThreadInput(,,TRUE). */
+                    if (pTebTo->o.odin.tidAttachedInputThread != idAttach)
+                    {
+                        dprintf(("USER32: AttachThreadInput: WARNING! %#x is not attached to %#x\n", idAttachTo, pTebTo->o.odin.tidAttachedInputThread));
+                        DebugInt3();
+                    }
+                    pTebTo->o.odin.tidAttachedInputThread = 0;
+                    dprintf(("USER32: AttachThreadInput: Detached input from %#x to %#x\n", idAttach, idAttachTo));
+                }
+                return TRUE;
+            }
+            else
+            {
+                dprintf(("USER32: AttachThreadInput: Invalid tid=%#x\n", idAttachTo));
+                SetLastError(ERROR_INVALID_PARAMETER);
+            }
+        }
+        else
+        {
+            dprintf(("USER32: AttachThreadInput: Invalid tid=%#x\n", idAttach));
+            SetLastError(ERROR_INVALID_PARAMETER);
+        }
+    }
+    else
+    {
+        dprintf(("USER32: AttachThreadInput idAttach == idAttachTo (== %#x)\n", idAttach));
+        SetLastError(ERROR_ACCESS_DENIED);
+    }
+    return FALSE;
+}
+
 //******************************************************************************
 /**********************************************************************