//=-------------------------------------------------------------------------=// // Local workers 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/scheduler.h" #include "../include/arrows.h" /* -------------------------------------------------------------------------- */ enum { // quitting values WORKER_NORMAL_EXIT, WORKER_OMP_ERROR, WORKER_UNKNOWN_ERROR, // non-quitting / non-fatal errors WORKER_NON_FATAL_ERRORS, //meta-code WORKER_MODEL_ERROR, WORKER_CONTINUE }; struct scheduler_t; struct worker_t { int id; int thread_num; int status; struct arrow_t *elected_arrow; }; // -------------------------------------------------------------------------- // // Worker init function // // -------------------------------------------------------------------------- // void worker_start(struct worker_t *self, struct scheduler_t *scheduler); // -------------------------------------------------------------------------- // // Worker destructor function // // -------------------------------------------------------------------------- // // static inline void worker_destroy(worker_t *worker) // { // worker->pleaseStop = false; // worker->terminated = false; // worker->returnValue = false; // worker->id = 0; // free(worker->localWorkAreaCenter); // worker->localWorkAreaCenter = NULL; // }