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;
 
  // Pointer to an optional custom data structure that each scheduler can define.
  // The type is forward declared here and must be declared again in the scheduler source file
  // Is not touched by `init_sched_instance` and must be initialized by each scheduler that needs it
  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