---

EvtQueue.cpp

Go to the documentation of this file.

/*
 * EvtQueue.cpp
 *
 * Copyright 2003, MobileSpear Inc. (www.mobilespear.com). All rights reserved.
 * Copyright 2003, David Resnick. All rights reserved.
 *
 * See the file doc\license.txt for the terms of usage and distribution.
 */

#include <bogotel/Portability.h>
#include <bogotel/EvtQueue.h>
#include <bogotel/BgtErrors.h>
#include <bogotel/util.h>
#include <bogotel/SignalDev.h>
#include <bogotel/VoiceDev.h>

#include <srllib.h>
#include <gclib.h> // for DT_GC

#include <boost/thread/xtime.hpp>

#include <bogotel/STLhelp.h>

namespace bogotel {

    CEvtQueue::CEvtQueue()
    {

    }

    CEvtQueue::~CEvtQueue()
    {
    }

    int CEvtQueue::wait(long lTimeout, CEvt** ppEvt)
    {
        int rc;
        // get item (if any) from queue
        if ((rc = getFromQueue(ppEvt)) != resultSUCCESS) {
            g_util->log(3, -1, "CEvtQueue::wait(): getFromQueue() failed. rc is %d", rc);
            return rc;
        }
        // we have an event, return
        if (*ppEvt) {
            g_util->log(9, -1, "CEvtQueue::wait() completed. An event was returned.");
            return resultSUCCESS;
        }

        // we weren't asked to wait for new events, just return now
        if (lTimeout == 0) {
            (*ppEvt) = NULL;
            g_util->log(9, -1, "CEvtQueue::wait() completed. No event was returned.");
            return resultSUCCESS;
        }

        {
            boost::mutex::scoped_lock lock(m_mtxWait);
            boost::xtime xt;
            ContainerNotEmpty<DEQUE_EVT> notEmpty(m_dequeEvt);

            // wait until a new event is posted
            boost::xtime_get(&xt, boost::TIME_UTC);
            xt.sec += lTimeout / 1000;
            if (! m_condEvent.timed_wait(lock, xt, notEmpty)) {
                // timeout, return empty handed
    //          g_util->log(9, -1, "CEvtQueue::wait() completed. Timeout reached; no event was posted.");
                return resultSUCCESS;
            }
        }

        // because our sleep was interrupted there should be an item in the queue
        if ((rc = getFromQueue(ppEvt)) != resultSUCCESS) {
            g_util->log(3, -1, "CEvtQueue::wait(): getFromQueue() failed.");
            return rc;
        }
        if ((*ppEvt) == NULL) {
            g_util->log(3, -1, "CEvtQueue::wait(): event expected.");
            return resultUNEXPECTED;
        }
        g_util->log(9, -1, "CEvtQueue::wait() completed. Event posted.");
        return resultSUCCESS;
    }

    int CEvtQueue::getFromQueue(CEvt** ppEvt)
    {
        boost::mutex::scoped_lock lock(m_mtxQueue);

        if (!m_dequeEvt.empty()) {
            (*ppEvt) = m_dequeEvt.front();
            m_dequeEvt.pop_front();
        } else {
            (*ppEvt) = NULL;
        }

        return resultSUCCESS;
    }

    int CEvtQueue::add(CEvt* pEvt)
    {
        if (pEvt == NULL) {
            return resultUNEXPECTED;
        }

        {
            boost::mutex::scoped_lock lock(m_mtxQueue);
            m_dequeEvt.push_back(pEvt);
        }

        std::string strEvent = pEvt->toString();

        m_condEvent.notify_one();

        g_util->log(9, -1, "CEvtQueue::add completed. Event: %s", strEvent);

        return resultSUCCESS;
    }

    const std::string& CEvt::toString()
    {
        if (m_lType & DT_GC) {
            return CSignalDev::getEventName(m_lType);
        } else {
            return CVoiceDev::getEventName(m_lType);
        }
    }

}

---