RequestQueue.cpp

Go to the documentation of this file.

/***************************** License **********************************

 Copyright (C) 2008 by Communicative Machines
 http://www.cmlabs.com   All rights reserved.

 This library is free software; you can redistribute it and/or
 modify it under the terms of the GNU Lesser General Public
 License as published by the Free Software Foundation; either
 version 2.1 of the License, or (at your option) any later version.

 This library 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
 Lesser General Public License for more details.

 You should have received a copy of the GNU Lesser General Public
 License along with this library; if not, write to the Free Software
 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA

************************************************************************/
// RequestQueue.cpp: implementation of the RequestQueue class.
//
//////////////////////////////////////////////////////////////////////

#include "RequestQueue.h"

namespace cmlabs {

//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////

RequestQueue::RequestQueue() {
        inQueue = new Queue();
        outQueue = new Queue();
}

RequestQueue::~RequestQueue()
{
        delete(inQueue);
        delete(outQueue);
}


JString RequestQueue::enterRequest(JString req) {
        JString id = inQueue->add(req);
        wait(0);
        return id;
}

JString RequestQueue::waitForReply(JString id, long ms) {
        return outQueue->waitForNewEntry(id, ms);
}
        
bool RequestQueue::isEmpty() {
        return inQueue->isEmpty();
}

int RequestQueue::getCount() {
        return inQueue->getCount();
}

//! Get total size of payload
unsigned long RequestQueue::getPayloadSize() const {
        return inQueue->getPayloadSize() + outQueue->getPayloadSize();
}


JString RequestQueue::waitForNewRequestID(int ms) {
        return inQueue->waitForNewEntryID(ms);
}

JString RequestQueue::getRequest(JString id) {
        return inQueue->retrieveEntry(id);
}

bool RequestQueue::reply(JString id, JString rep) {
        return (outQueue->add(id, rep).length() > 0);
}


bool RequestQueue::unitTest() {
        
        RequestQueue* rq = new RequestQueue();

        JTime t;
        if (rq->waitForReply("bla", 500).length() > 0)
                return false;
        if (t.getAge() < 490) {
                this->addUnitTestLog(JString::format("RequestQueue triggered too early, after only %.3f ms instead of %d ms", t.getMicroAge()/1000.0, 500));
                return false;
        }
        
        t = JTime();
        if (rq->waitForNewRequestID(500).length() > 0)
                return false;
        if (t.getAge() < 490) {
                this->addUnitTestLog(JString::format("RequestQueue triggered the id too early, after only %.3f ms instead of %d ms", t.getMicroAge()/1000.0, 500));
                return false;
        }

        // now we add a request
        JString id = rq->enterRequest("Test");

        // There should be no reply yet...
        if (rq->waitForReply(id, 500).length() > 0)
                return false;
        
        JString id2 = rq->waitForNewRequestID(500);

        if (!id.equals(id2))
                return false;

        JString request = rq->getRequest(id2);
        
        if (!request.equals("Test"))
                return false;

        // reply to request
        if (!rq->reply(id, "TestReply"))
                return false;

        // Now we should have a reply
        if (!rq->waitForReply(id, 500).equals("TestReply"))
                return false;

        delete(rq);

        return true;
}














} // namespace cmlabs

---