reactor_threaded.h

Go to the documentation of this file.

 
#ifndef REACTOR_THREADED_H
#define REACTOR_THREADED_H
 
#include "lf_types.h"
 
void try_advance_level(environment_t* env, volatile size_t* next_reaction_level);
 
void lf_enqueue_port_absent_reactions(environment_t* env);
 
void _lf_increment_tag_barrier(environment_t* env, tag_t future_tag);
 
void _lf_increment_tag_barrier_locked(environment_t* env, tag_t future_tag);
 
void _lf_decrement_tag_barrier_locked(environment_t* env);
 
int _lf_wait_on_tag_barrier(environment_t* env, tag_t proposed_tag);
void lf_synchronize_with_other_federates(void);
bool wait_until(instant_t logical_time_ns, lf_cond_t* condition);
tag_t get_next_event_tag(environment_t* env);
tag_t send_next_event_tag(environment_t* env, tag_t tag, bool wait_for_reply);
void _lf_next_locked(environment_t* env);
#endif // REACTOR_THREADED_H