VFS_threadpool.cpp

Go to the documentation of this file.

 
#include "VFS_threadpool.h"
 
#include <QCoreApplication>
 
#include "VFS.h"
#include "VFS_creator.h"
#include "VFS_thread.h"
 
const QStringList VFS_threadpool::modeStrings { "roundrobin", "available" };
 
VFS_threadpool::VFS_threadpool(uint count, VFS_threadpool::mode mode, QDomElement nodeConfig, QVariantMap env, bool printConfig)
: VFS_node()
, _count(count)
, _index(0)
, _mode(mode)
{
        VFS::LOG( QString(" -Creating thread pool '%1:%2'").arg(nodeConfig.tagName()).arg(nodeConfig.attribute("name")), 9 );
 
        QString nameTemplate = QString("%1:%2").arg(nodeConfig.attribute("name"));
 
        VFS_node *node;
        QString name;
 
        for (uint i=0;i<_count;i++)
        {
                name = nameTemplate.arg(i);
                nodeConfig.setAttribute("name",name);
                node = new VFS_thread(nodeConfig, env, printConfig);
                if (!append(name,node,false))
                        delete node;
        }
}
 
 
VFS_threadpool::~VFS_threadpool()
{
}
 
 
bool VFS_threadpool::isContainer()
{
        return true;
}
 
 
VFS_node *VFS_threadpool::find(VFS_request *r)
{
        QMutexLocker l(&_lock);
 
        QStringList keys = _children.keys();
        VFS_node *n = nullptr;
 
        //printf("INDEX: %d\n",_index);
 
        switch (_mode)
        {
                case VFS_threadpool::available:
 
 
                case VFS_threadpool::roundrobin:
                                                        n = _children[ keys[ _index ] ];
                                                        _index = (_index + 1) % _count;         //round robin style
                                                        break;
 
                //default:                              break;
        }
 
        if (n)
                return n->find(r);
        else
                return nullptr;
}
 
 
void VFS_threadpool::subtreeRequest(VFS_request *t)
{
        Q_UNUSED(t)
 
        VFS::ERROR("threadpool::subtreeRequest should never be called.  You have a bug in your code.");
}
 
 
void VFS_threadpool::executeRequest(VFS_request *t)
{
        Q_UNUSED(t)
 
        VFS::ERROR("threadpool::executeRequest should never be called.  You have a bug in your code.");
}