gem-graph-server/include/base.h

//=-------------------------------------------------------------------------=//
//  base definition                                                         //
//                                                                           //
//  Copyright © 2021 The Gem-graph Project                                   //
//                                                                           //
//  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 <https://www.gnu.org/licenses/>.   //
//=-------------------------------------------------------------------------=//

#include <sys/param.h>
#include <stdbool.h>
#include <pthread.h>
#include <unistd.h>
#include <malloc.h>
#include <string.h>
#include <stdlib.h>
#include <errno.h>
#include <stdio.h>
#include <netinet/in.h>

#define BASE_H

/* -------------------------------------------------------------------------- */

#define LOGMSG "[%s]"
#define printLog(FORMAT, ...) printf("\e[0m" LOGMSG " " FORMAT "\e[0m", \
                                                 __func__, ##__VA_ARGS__)
#define LEN(x)  (sizeof(x) / sizeof((x)[0]))

/* -------------------------------------------------------------------------- */

struct {
    size_t size;
    int *space;
} typedef IntArray_t;

struct {
    int x;
    int y;
    int z;
    int siteId;
} typedef Arrow_t;

struct {
    size_t size;
    pthread_spinlock_t lock;
    Arrow_t *array;
} typedef ArrowArray_t;

struct {
    char *label;
    int nArrow;
} typedef Site_t;

struct {
    int nSite;
    char *label;
    Site_t *sites;
} typedef SpaceUnit_t;

struct {
    int xMax;
    int yMax;
    int zMax;
    size_t size;
    SpaceUnit_t *space;
} typedef Space_t;

/* -------------------------------------------------------------------------- */

//
// Scheduler
//
struct {
    pthread_t id;
    bool pleaseStop;
    Space_t *globalDrawingSpace;
    IntArray_t *conditionTree;
    ArrowArray_t *arrowArray;
    int nMaxThread;
    int nMaxCycles;
    int ruleRadius;
} typedef Scheduler_t;

/* -------------------------------------------------------------------------- */

//
// Local threads
//
struct Center_t {
    int x;
    int y;
    int z;
    struct Center_t *next;
    struct Center_t *prev;
} typedef Center_t;

struct {
    pthread_t id;
    Center_t *localWorkAreaCenter;
    Space_t *globalDrawingSpace;
    IntArray_t *conditionTree;
    ArrowArray_t *arrowArray;
    bool pleaseStop;
    bool terminated;
    int returnValue;
} typedef Worker_t;

/* -------------------------------------------------------------------------- */

//
// Server
//
struct {
    pthread_t id;
    bool pleaseStop;
    int returnValue;
    int sockfd;
} typedef Server_t;

struct {
    pthread_t id;
    bool pleaseStop;
    Server_t *parent;
    int sockfd;
    struct sockaddr_in clientAddr;
    socklen_t socklen;
} typedef ServerCommunication_t;

/* -------------------------------------------------------------------------- */

//
// Supervisor
//
struct {
    pthread_t id;
    bool pleaseStop;
    int *workerCreationOccurency;
} typedef Supervisor_t;

/* -------------------------------------------------------------------------- */

//
// Model
//
struct {
    int id;
    char *name;
    char *filename;
    int space_xMax;
    int space_yMax;
    int space_zMax;
    int nmaxThread;
    int nmaxCycles;
    int siteNumber;
    bool isRunning;
    Scheduler_t *scheduler;
    Supervisor_t *supervisor;
} typedef Model_t;

/* -------------------------------------------------------------------------- */

//
// Parameters
//
struct {
    char *configDir;
    char *modelDir;
    char *userDir;
} typedef Parameters_t;