DBEnvironmentQueue.cpp

Go to the documentation of this file.

/*
 * DBEnvironmentQueue.cpp
 *
 *  This file is part of the HausmiSEP project
 *
 *  Copyright (C) 2012, 2013 Marco Alvarado (malvcr@gmail.com)
 *
 *  This program is free software: you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation, either version 3 of the License, or
 *  (at your option) any later version.
 *
 *  This program 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.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */

#include <HSEPData/DBEnvironmentQueue.h>

#include <unistd.h>

namespace HSEPData {

    DBEnvironmentQueue::DBEnvironmentQueue() {
        aFree.clear();
        aUsed.clear();
    } // DBEnvironmentQueue constructor

    DBEnvironmentQueue::~DBEnvironmentQueue() {

        DBEnvironmentListIterator vIter;

        ExclusiveScope vScope(&aMutex);

        for (vIter = aFree.begin(); vIter != aFree.end(); vIter++) {
            delete (*vIter);
        }

        for (vIter = aUsed.begin(); vIter != aUsed.end(); vIter++) {
            delete (*vIter);
        }


    } // DBEnvironmentQueue destructor

    DBEnvironment* DBEnvironmentQueue::getEnvironmentPtr() {

        DBEnvironment* vResult = nullptr;
        bool vEndLoop = false;

        while (!vEndLoop) {

            {
                ExclusiveScope vScope(&aMutex);

                if (aFree.size() > 0) {
                    vResult = aFree.front();
                    aFree.pop_front();
                    aUsed.push_back(vResult);
                    vEndLoop = true;
                }
            }

            if (!vEndLoop) {
                usleep(10);
                // TODO: C++11 sleeping thread functions are not ready in this moment ... when ready, update this.
            }

        } // while (!vEndLoop)

        return vResult;

    } // DBEnvironmentQueue::getEnvironment

    void DBEnvironmentQueue::releaseEnvironment(DBEnvironment* pEnvironmentPtr) {
        ExclusiveScope vScope(&aMutex);
        aUsed.remove   (pEnvironmentPtr);
        aFree.push_back(pEnvironmentPtr);
    } // DBEnvironmentQueue::releaseEnvironment

    void DBEnvironmentQueue::addEnvironment(DBEnvironment* pEnvironmentPtr) {
        ExclusiveScope vScope(&aMutex);
        aFree.push_back(pEnvironmentPtr);
    } // DBEnvironmentQueue::addEnvironment

} // HSEPData namespace