reactor.h

Go to the documentation of this file.

 
#ifndef REACTOR_H
#define REACTOR_H
 
#include "lf_types.h"
#include "low_level_platform.h" // For lf_cond_t in lf_async_state_t.
#include "modes.h"              // Modal model support
#include "port.h"
#include "tag.h"   // Time-related functions.
#include "clock.h" // Time-related functions.
#include "tracepoint.h"
#include "util.h"

#define SUPPRESS_UNUSED_WARNING(x) (void)(x)


bool lf_is_tag_after_stop_tag(environment_t* env, tag_t tag);

void lf_set_present(lf_port_base_t* port);

void lf_set_stop_tag(environment_t* env, tag_t tag);
 
#ifdef FEDERATED

void lf_set_federation_id(const char* fid);

const char* lf_get_federation_id();

bool lf_rti_has_failed(void);
 
#endif // FEDERATED
 
#ifdef FEDERATED_DECENTRALIZED

interval_t lf_get_stp_offset(void);

interval_t lf_get_sta(void);

interval_t lf_get_fed_maxwait(void);

void lf_set_stp_offset(interval_t offset);

void lf_set_sta(interval_t offset);

void lf_set_fed_maxwait(interval_t offset);
 
#endif // FEDERATED_DECENTRALIZED

void lf_print_snapshot(environment_t* env);

void lf_request_stop(void);

int lf_add_worker_thread(environment_t* env);

int lf_added_worker_thread_count(environment_t* env);

typedef struct lf_async_state_t {
  self_base_t* self;
  reaction_t* reaction;
  lf_action_base_t* action;
  lf_port_base_t* port;
  bool resumed;
  bool function_done;
  bool resume_waiting;
  bool left_pool;
  tag_t resume_tag;
  bool event_pending;
  struct lf_async_state_t* next;
#if !defined(LF_SINGLE_THREADED)
  lf_cond_t resumed_cond;
#endif
} lf_async_state_t;

void _lf_async_begin(lf_async_state_t* state, void* self, void* action, void* port);

void _lf_async_end(lf_async_state_t* state);

void lf_async_resume(void* action);

void _lf_await(void* self, void* port);

void _lf_await_resume(void* self, void* port);

void* lf_allocate(size_t count, size_t size, struct allocation_record_t** head);

self_base_t* lf_new_reactor(size_t size);

void lf_free_all_reactors(void);

void lf_free_reactor(self_base_t* self);

const char* lf_reactor_name(self_base_t* self);

const char* lf_reactor_full_name(self_base_t* self);
 
#endif /* REACTOR_H */