Queue.h

Go to the documentation of this file.

/*--------------------------------*- VMlib -*----------------*---------------*\
| ##  ## ##   ## ##   ##  ##    |                            | Version 1.12   |
| ##  ## ### ### ##       ##    |  VMlib: VM2D/VM3D Library  | 2024/01/14     |
| ##  ## ## # ## ##   ##  ####  |  Open Source Code          *----------------*
|  ####  ##   ## ##   ##  ## ## |  https://www.github.com/vortexmethods/VM2D  |
|   ##   ##   ## #### ### ####  |  https://www.github.com/vortexmethods/VM3D  |
|                                                                             |
| Copyright (C) 2017-2024 Ilia Marchevsky                                     |
*-----------------------------------------------------------------------------*
| File name: Queue.h                                                          |
| Info: Source code of VMlib                                                  |
|                                                                             |
| This file is part of VMlib.                                                 |
| VMLib 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.                                         |
|                                                                             |
| VMlib 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 VMlib.  If not, see <http://www.gnu.org/licenses/>.              |
\*---------------------------------------------------------------------------*/


#ifndef QUEUE_H
#define QUEUE_H

#include "defs.h"
#include "Parallel.h"
#include "Task.h"

#ifdef CODE2D
    namespace VM2D
    {
        class World2D;
    }//namespace VM2D
#endif

#ifdef CODE3D
    namespace VM3D
    {
        class World3D;
    }//namespace VM3D
#endif

namespace VMlib
{
    
    class WorldGen;

    class Queue
    {
    private:

        struct
        {
            int prepared;

            int solving;

            int finished;
        } numberOfTask;

        std::vector<int> procState;

        std::vector<int> procStateVar;

        std::vector<int> flagFinish;

        int myidAll;

        int nProcAll;

#ifdef USE_MPI
        MPI_Group groupAll;

        MPI_Group groupStarting;

        MPI_Comm commStarting;

        MPI_Group groupSolving;

        MPI_Comm commSolving;
#else
        int groupAll;
        int groupStarting;
        int commStarting;
        int groupSolving;
        int commSolving;
#endif

        int sizeCommSolving;

        void ConstructProcStateVar();

        void AddTask(int _nProc, std::unique_ptr<PassportGen> _passport);

        LogStream info;

    public:
        std::vector<Task> task;

        std::unique_ptr<WorldGen> world;

        int myProcState;

        int myProcStateVar;

        const double kvantTime = 10.0;

        int currentKvant;

        int nextKvant;

        Parallel parallel;

        Queue(int& argc, char**& argv, void(*_CreateMpiTypes)());

        ~Queue();

        void TaskSplit();

        void TaskUpdate();

        void RunConveyer();

        void LoadTasksList(const std::string& _tasksFile, const std::string& _mechanicsFile, const std::string& _defaultsFile, const std::string& _switchersFile);
    };

}//namespace VMlib

#endif