//=-------------------------------------------------------------------------=// // Scheduler definition // // // // Copyright © 2021 Libre en Communs (contact@a-lec.org) // // Copyright © 2021 Adrien Bourmault (neox@a-lec.org) // // // // This file is part of gem-graph. // // // // This program is free software: you can redistribute it and/or modify // // it under the terms of the GNU Affero 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 Affero General Public License for more details. // // // // You should have received a copy of the GNU Affero General Public License // // along with this program. If not, see . // //=-------------------------------------------------------------------------=// #pragma once #ifndef BASE_H #include "../include/base.h" #endif #include #include "../include/worker.h" #include "../include/model.h" /* -------------------------------------------------------------------------- */ enum { // quitting values SCHED_NORMAL_EXIT, SCHED_OMP_ERROR, SCHED_UNKNOWN_ERROR, // non-quitting / non-fatal errors SCHED_NON_FATAL_ERRORS, //meta-code SCHED_MODEL_ERROR, SCHED_CONTINUE }; struct scheduler_t { int id; int n_workers; int pleaseStop; struct model_t **models; struct worker_t **workers; }; // -------------------------------------------------------------------------- // // Scheduler main function // // -------------------------------------------------------------------------- // int sched_start (struct scheduler_t *scheduler, struct parameters_t *parameters); // -------------------------------------------------------------------------- // // Scheduler content destructor function // // -------------------------------------------------------------------------- // // static inline void sched_clean (scheduler_t *scheduler) // { // assert(scheduler); // if (scheduler->globalDrawingSpace) { // if (scheduler->globalDrawingSpace->space) { // free(scheduler->globalDrawingSpace->space); // scheduler->globalDrawingSpace->space = NULL; // } // free(scheduler->globalDrawingSpace); // scheduler->globalDrawingSpace = NULL; // } // if (scheduler->arrowArray) { // if (scheduler->arrowArray->array) { // free(scheduler->arrowArray->array); // scheduler->arrowArray->array = NULL; // } // free(scheduler->arrowArray); // scheduler->arrowArray = NULL; // } // } // -------------------------------------------------------------------------- // // Scheduler destructor function // // -------------------------------------------------------------------------- // // static inline void sched_shutdown (scheduler_t *scheduler) // { // assert(scheduler); // free(scheduler); // scheduler = NULL; // }