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

Timestamp:

Jul 29, 2006, 6:43:07 AM (19 years ago)

Author:

bird

Message:

Two classes (CPMScreen and CPMKeyState) + the hook dll left (and debugging of course).

File:

• trunk/synergy/lib/platform/CPMEventQueueBuffer.cpp (copied) (copied from trunk/synergy/lib/platform/CMSWindowsEventQueueBuffer.cpp ) (4 diffs)

trunk/synergy/lib/platform/CPMEventQueueBuffer.cpp

@@ -2 +2 @@
  * synergy -- mouse and keyboard sharing utility
  * Copyright (C) 2004 Chris Schoeneman
+ * Copyright (C) 2006 Knut St. Osmundsen
  * 
  * This package is free software; you can redistribute it and/or
@@ -13 +14 @@
  */
 
-#include "CMSWindowsEventQueueBuffer.h"
+#include "CPMEventQueueBuffer.h"
 #include "CThread.h"
 #include "IEventQueue.h"
-#include "CArchMiscWindows.h"
 
 //
@@ -26 +26 @@
 
 //
-// CMSWindowsEventQueueBuffer
+// CPMEventQueueBuffer
 //
 
-CMSWindowsEventQueueBuffer::CMSWindowsEventQueueBuffer()
+CPMEventQueueBuffer::CPMEventQueueBuffer()
 {
-        // remember thread.  we'll be posting messages to it.
-        m_thread     = GetCurrentThreadId();
+        // 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);
 
         // create a message type for custom events
-        m_userEvent  = RegisterWindowMessage("SYNERGY_USER_EVENT");
+        m_userEvent  = WM_USER + 42 + 42 + 42;
 
         // get message type for daemon quit
-        m_daemonQuit = CArchMiscWindows::getDaemonQuitMessage();
+        m_daemonQuit = WM_USER + 666;
 
-        // make sure this thread has a message queue
-        MSG dummy;
-        PeekMessage(&dummy, NULL, WM_USER, WM_USER, PM_NOREMOVE);
+    // create the event semaphore we'll be waiting on when waiting for messages.
+    m_hev = NULLHANDLE;
+    APIRET rc = DosCreateEventSem(NULL, &m_hev, 0, FALSE);
+    assert(rc == NO_ERROR);
 }
 
-CMSWindowsEventQueueBuffer::~CMSWindowsEventQueueBuffer()
+CPMEventQueueBuffer::~CPMEventQueueBuffer()
 {
         // do nothing
+    DosCloseEventSem(m_hev);
+    WinDestroyMsgQueue(m_hmq);
+    WinTerminate(m_hab);
 }
 
 void
-CMSWindowsEventQueueBuffer::waitForEvent(double timeout)
+CPMEventQueueBuffer::waitForEvent(double timeout)
 {
-        // check if messages are available first.  if we don't do this then
-        // MsgWaitForMultipleObjects() will block even if the queue isn't
-        // empty if the messages in the queue were there before the last
-        // call to GetMessage()/PeekMessage().
-        if (HIWORD(GetQueueStatus(QS_ALLINPUT)) != 0) {
-                return;
-        }
-
-        // convert timeout
-        DWORD t;
-        if (timeout < 0.0) {
-                t = INFINITE;
-        }
-        else {
-                t = (DWORD)(1000.0 * timeout);
-        }
-
-        // wait for a message.  we cannot be interrupted by thread
-        // cancellation but that's okay because we're run in the main
-        // thread and we never cancel that thread.
-        HANDLE dummy[1];
-        MsgWaitForMultipleObjects(0, dummy, FALSE, t, QS_ALLINPUT);
+        // check if messages are available first. 
+    ULONG fStatus = WinQueryQueueStatus(HWND_DESKTOP);
+    if (!fStatus) {
+        // convert timeout and wait.
+        ULONG ulPMTimeout = timeout < 0.0 
+                          ? SEM_INDEFINITE_WAIT
+                          : (ULONG)(1000.0 * timeout);
+        WinWaitEventSem(m_hev, ulPMTimeout);
+    }
 }
 
 IEventQueueBuffer::Type
-CMSWindowsEventQueueBuffer::getEvent(CEvent& event, UInt32& dataID)
+CPMEventQueueBuffer::getEvent(CEvent& event, UInt32& dataID)
 {
-        // peek at messages first.  waiting for QS_ALLINPUT will return
-        // if a message has been sent to our window but GetMessage will
-        // dispatch that message behind our backs and block.  PeekMessage
-        // will also dispatch behind our backs but won't block.
-        if (!PeekMessage(&m_event, NULL, 0, 0, PM_NOREMOVE) &&
-                !PeekMessage(&m_event, (HWND)-1, 0, 0, PM_NOREMOVE)) {
+        // peek at messages first.
+    QMSG qmsg;
+    if (!WinPeekMsg(m_hab, &qmsg, NULLHANDLE, 0, 0, PM_NOREMOVE)) {
                 return kNone;
-        }
+    }
 
-        // BOOL.  yeah, right.
-        BOOL result = GetMessage(&m_event, NULL, 0, 0);
-        if (result == -1) {
-                return kNone;
-        }
-        else if (result == 0) {
+    // get the message
+    if (    !WinGetMsg(m_hab, &m_event, NULLHANDLE, 0, 0)
+        ||  (m_event.msg == m_daemonQuit && m_daemonQuit != 0)) {
                 event = CEvent(CEvent::kQuit);
                 return kSystem;
         }
-        else if (m_daemonQuit != 0 && m_event.message == m_daemonQuit) {
-                event = CEvent(CEvent::kQuit);
-                return kSystem;
-        }
-        else if (m_event.message == m_userEvent) {
-                dataID = static_cast<UInt32>(m_event.wParam);
+        
+    if (m_event.msg == m_userEvent) {
+                dataID = (UInt32)(uintptr_t)m_event.mp1;
                 return kUser;
         }
-        else {
-                event = CEvent(CEvent::kSystem,
-                                                        IEventQueue::getSystemTarget(), &m_event);
-                return kSystem;
-        }
+    
+    event = CEvent(CEvent::kSystem, IEventQueue::getSystemTarget(), &m_event);
+    return kSystem;
 }
 
 bool
-CMSWindowsEventQueueBuffer::addEvent(UInt32 dataID)
+CPMEventQueueBuffer::addEvent(UInt32 dataID)
 {
-        return (PostThreadMessage(m_thread, m_userEvent,
-                                                        static_cast<WPARAM>(dataID), 0) != 0);
+    return WinPostQueueMsg(m_hmq, m_userEvent, (MPARAM)dataID, 0) != FALSE;
 }
 
 bool
-CMSWindowsEventQueueBuffer::isEmpty() const
+CPMEventQueueBuffer::isEmpty() const
 {
-        return (HIWORD(GetQueueStatus(QS_ALLINPUT)) == 0);
+    ULONG fStatus = WinQueryQueueStatus(HWND_DESKTOP);
+        return fStatus != 0; 
 }
 
 CEventQueueTimer*
-CMSWindowsEventQueueBuffer::newTimer(double, bool) const
+CPMEventQueueBuffer::newTimer(double, bool) const
 {
         return new CEventQueueTimer;
@@ -133 +115 @@
 
 void
-CMSWindowsEventQueueBuffer::deleteTimer(CEventQueueTimer* timer) const
+CPMEventQueueBuffer::deleteTimer(CEventQueueTimer* timer) const
 {
         delete timer;
 }
+