scheduler_instance.h

Go to the documentation of this file.

 
#ifndef LF_SCHEDULER_PARAMS_H
#define LF_SCHEDULER_PARAMS_H
 
#ifndef NUMBER_OF_WORKERS // Enable thread-related platform functions
#define NUMBER_OF_WORKERS 1
#endif // NUMBER_OF_WORKERS
 
#include <stdbool.h>
#include <stddef.h> // for size_t
 
#define DEFAULT_MAX_REACTION_LEVEL 100
 
// Forward declarations
typedef struct environment_t environment_t;
typedef struct custom_scheduler_data_t custom_scheduler_data_t;

typedef struct lf_scheduler_t {
  struct environment_t* env;

  size_t max_reaction_level;

  volatile bool should_stop;

  volatile int* indexes;

  void* transfer_reactions;

  size_t number_of_workers;

  volatile size_t number_of_idle_workers;

  custom_scheduler_data_t* custom_data;
} lf_scheduler_t;

typedef struct {
  size_t* num_reactions_per_level;

  size_t num_reactions_per_level_size;
} sched_params_t;

bool init_sched_instance(struct environment_t* env, lf_scheduler_t** instance, size_t number_of_workers,
                         sched_params_t* params);
 
#endif // LF_SCHEDULER_PARAMS_H