source: trunk/synergy/lib/platform/CPMEventQueueBuffer.cpp@ 2755

/*
 * 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
 * modify it under the terms of the GNU General Public License
 * found in the file COPYING that should have accompanied this file.
 *
 * This package is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 */

#include "CPMEventQueueBuffer.h"
#include "CThread.h"
#include "IEventQueue.h"

//
// CEventQueueTimer
//

class CEventQueueTimer { };


//
// CPMEventQueueBuffer
//

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);

        // create a message type for custom events
        m_userEvent  = WM_USER + 42 + 42 + 42;

        // get message type for daemon quit
        m_daemonQuit = WM_USER + 666;

    // 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);
}

CPMEventQueueBuffer::~CPMEventQueueBuffer()
{
        // do nothing
    DosCloseEventSem(m_hev);
    WinDestroyMsgQueue(m_hmq);
    WinTerminate(m_hab);
}

void
CPMEventQueueBuffer::waitForEvent(double timeout)
{
        // 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
CPMEventQueueBuffer::getEvent(CEvent& event, UInt32& dataID)
{
        // peek at messages first.
    QMSG qmsg;
    if (!WinPeekMsg(m_hab, &qmsg, NULLHANDLE, 0, 0, PM_NOREMOVE)) {
                return kNone;
    }

    // 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;
        }

    if (m_event.msg == m_userEvent) {
                dataID = (UInt32)(uintptr_t)m_event.mp1;
                return kUser;
        }

    event = CEvent(CEvent::kSystem, IEventQueue::getSystemTarget(), &m_event);
    return kSystem;
}

bool
CPMEventQueueBuffer::addEvent(UInt32 dataID)
{
    return WinPostQueueMsg(m_hmq, m_userEvent, (MPARAM)dataID, 0) != FALSE;
}

bool
CPMEventQueueBuffer::isEmpty() const
{
    ULONG fStatus = WinQueryQueueStatus(HWND_DESKTOP);
        return fStatus != 0;
}

CEventQueueTimer*
CPMEventQueueBuffer::newTimer(double, bool) const
{
        return new CEventQueueTimer;
}

void
CPMEventQueueBuffer::deleteTimer(CEventQueueTimer* timer) const
{
        delete timer;
}

/*
 * Local Variables:
 *  mode: c
 *  c-file-style: "k&r"
 *  c-basic-offset: 4
 *  tab-width: 4
 *  indent-tabs-mode: t
 * End:
 */