WorkerPool.h

Go to the documentation of this file.

#ifndef SIMPT_PAREX_WORKER_POOL_H_INCLUDED
#define SIMPT_PAREX_WORKER_POOL_H_INCLUDED
/*
 * Copyright 2011-2016 Universiteit Antwerpen
 *
 * Licensed under the EUPL, Version 1.1 or  as soon they will be approved by
 * the European Commission - subsequent versions of the EUPL (the "Licence");
 * You may not use this work except in compliance with the Licence.
 * You may obtain a copy of the Licence at: http://ec.europa.eu/idabc/eupl5
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the Licence is distributed on an "AS IS" basis,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the Licence for the specific language governing
 * permissions and limitations under the Licence.
 */
#include "WorkerRepresentative.h"

#include <QUdpSocket>
#include <QTcpSocket>
#include <QObject>
#include <QString>
#include <QSignalMapper>
#include <QTimer>
#include <list>

namespace SimPT_Parex {

class WorkerPool: public QObject
{
        Q_OBJECT
public:
        virtual ~WorkerPool();

        WorkerRepresentative *getProcess();

        static WorkerPool *globalInstance();

        bool WorkerAvailable();

        void SetMinNumWorkers(int);

        void Delete(std::string name);

signals:
        void NewWorkerAvailable();

        void WorkerReconnected(WorkerRepresentative*);

public slots:
        void ReleaseWorker(QObject*);
        void ReleaseWorker(WorkerRepresentative*);

        void MakeProcessAvailable(QObject*);
        void MakeProcessAvailable(WorkerRepresentative*);

private slots:
        void handleDatagrams();
        void Initialize();
        void StartWorkers();
        void PeriodicCheck();

private:
        void StartWorker();
        WorkerPool();

        QUdpSocket *m_socket;
        QTcpSocket *m_tcpSocket;

        QSignalMapper *m_mapper;
        QSignalMapper *m_release_mapper;
        std::list<WorkerRepresentative*> m_available_list;
        std::list<WorkerRepresentative*> m_busy_list;
        std::list<QString> m_connected_list;
        bool m_initialized;
        QTimer *m_initialize_timer;

        int m_min_nodes;

        QTimer *m_check_timer;
};

} // namespace

#endif // end-of-include-guard