Changeset 2761 for trunk/synergy/lib/platform/CPMEventQueueBuffer.cpp

Timestamp:

Aug 13, 2006, 1:41:05 AM (19 years ago)

Author:

bird

Message:

Hacking and debugging.

File:

• trunk/synergy/lib/platform/CPMEventQueueBuffer.cpp (modified) (10 diffs)

trunk/synergy/lib/platform/CPMEventQueueBuffer.cpp

@@ -16 +16 @@
 #include "CPMEventQueueBuffer.h"
 #include "CThread.h"
+#include "CLog.h"
 #include "IEventQueue.h"
+#include "CPMUtil.h"
+#include <unistd.h>
 
 //
@@ -31 +34 @@
 CPMEventQueueBuffer::CPMEventQueueBuffer()
 {
-        // remember the queue (/ thread / hab).  we'll be posting messages to it.
-    m_hab = WinInitialize(0);
-    m_hmq = WinCreateMsgQueue(m_hab, 0);
-    assert(m_hmq != NULLHANDLE);
+    // the anchor block. Remeber it for use when waiting, peeking, and getting events.
+    m_hab = NULLHANDLE;
+    PTIB pTib;
+    PPIB pPib;
+    DosGetInfoBlocks(&pTib, &pPib);
+    LOG((CLOG_DEBUG2 "CPMEventQueueBuffer: ultype=%lx tid=%lx", pPib->pib_ultype, pTib->tib_ptib2->tib2_ultid));
+    if (pPib->pib_ultype != 3) {
+        pPib->pib_ultype = 3;
+        m_shallTerminate = true;
+        m_hab = WinInitialize(0);
+    }
+    if (m_hab == NULLHANDLE) {
+        m_hab = CPMUtil::getHAB();
+        if (m_hab == NULLHANDLE) {
+            m_shallTerminate = true;
+            m_hab = WinInitialize(0);
+        }
+    }
+     
+    // the message queue. remember it so we can post and get messages.
+    m_hmq = CPMUtil::getHMQ(m_hab);
+    if (m_hmq == NULLHANDLE) {
+        m_shallDestroyMsgQueue = true;
+        m_hmq = WinCreateMsgQueue(m_hab, 0);
+    }
+
+    // check that we succeeded the two previous steps.
+    if (m_hab == NULLHANDLE || m_hmq == NULLHANDLE) {
+                LOG((CLOG_CRIT "couldn't get the hab(%lx)/hmq(%lx) of the current thread!", m_hab, m_hmq));
+                assert(m_hab != NULLHANDLE && m_hmq != NULLHANDLE);
+        }
+    assert(CPMUtil::getHAB() == m_hab);
 
         // create a message type for custom events
@@ -46 +77 @@
     APIRET rc = DosCreateEventSem(NULL, &m_hev, 0, FALSE);
     assert(rc == NO_ERROR);
+    LOG((CLOG_DEBUG2 "CPMEventQueueBuffer: m_userEvent=%#lx m_daemonQuit=%#lx m_hev=%#lx m_hab=%#lx m_hmq=%#lx m_shallTermiate=%d m_shallDestroyMsgQueue=%d", 
+         m_userEvent, m_daemonQuit, m_hev, m_hab, m_hmq, m_shallTerminate, m_shallDestroyMsgQueue));
 }
 
@@ -52 +85 @@
         // do nothing
     DosCloseEventSem(m_hev);
-    WinDestroyMsgQueue(m_hmq);
-    WinTerminate(m_hab);
+    if (m_shallDestroyMsgQueue) {
+        WinDestroyMsgQueue(m_hmq);
+    }
+    if (m_shallTerminate) {
+        WinTerminate(m_hab);
+    }
 }
 
@@ -62 +99 @@
     ULONG fStatus = WinQueryQueueStatus(HWND_DESKTOP);
     if (!fStatus) {
+        ULONG cPosts;
+        DosResetEventSem(m_hev, &cPosts);
+        fStatus = WinQueryQueueStatus(HWND_DESKTOP);
+    }
+    LOG((CLOG_DEBUG2 "waitForEvent: %#lx", fStatus)); 
+    if (!fStatus) {
         // convert timeout and wait.
         ULONG ulPMTimeout = timeout < 0.0
@@ -67 +110 @@
                           : (ULONG)(1000.0 * timeout);
         WinWaitEventSem(m_hev, ulPMTimeout);
+        LOG((CLOG_DEBUG2 "waitForEvent: ulPMTimeout=%ld", ulPMTimeout)); 
     }
 }
@@ -76 +120 @@
     QMSG qmsg;
     if (!WinPeekMsg(m_hab, &qmsg, NULLHANDLE, 0, 0, PM_NOREMOVE)) {
+        LOG((CLOG_DEBUG2 "getEvent: kNone"));
                 return kNone;
     }
@@ -88 +133 @@
     if (m_event.msg == m_userEvent) {
                 dataID = (UInt32)(uintptr_t)m_event.mp1;
+        LOG((CLOG_DEBUG2 "getEvent: dataID=%#x", dataID));
                 return kUser;
         }
 
     event = CEvent(CEvent::kSystem, IEventQueue::getSystemTarget(), &m_event);
+    LOG((CLOG_DEBUG2 "getEvent: kSystem"));
     return kSystem;
 }
@@ -98 +145 @@
 CPMEventQueueBuffer::addEvent(UInt32 dataID)
 {
-    return WinPostQueueMsg(m_hmq, m_userEvent, (MPARAM)dataID, 0) != FALSE;
+    LOG((CLOG_DEBUG2 "addEvent: dataID=%#x", dataID));
+    BOOL fRc = WinPostQueueMsg(m_hmq, m_userEvent, (MPARAM)dataID, 0) != FALSE;
+    if (fRc) {
+        DosPostEventSem(m_hev);
+    } else {
+        LOG((CLOG_CRIT "addEvent: dataID=%#x fRc=%d lasterr=%d", dataID, WinGetLastError(CPMUtil::getHAB()))); 
+    }
+    return fRc;
 }
 
@@ -105 +159 @@
 {
     ULONG fStatus = WinQueryQueueStatus(HWND_DESKTOP);
-        return fStatus != 0;
+    LOG((CLOG_DEBUG2 "isEmpty: %#lx", fStatus)); 
+        return fStatus == 0;
 }