AERA
Public Member Functions | List of all members
r_exec::MemStatic Class Reference
Inheritance diagram for r_exec::MemStatic:
r_exec::_Mem r_code::Mem

Public Member Functions

void delete_object (r_code::Code *object) override
 
r_comp::Imageget_objects (bool include_invalidated=false) override
 
- Public Member Functions inherited from r_exec::_Mem
void init (std::chrono::microseconds base_period, uint32 reduction_core_count, uint32 time_core_count, float32 mdl_inertia_sr_thr, uint32 mdl_inertia_cnt_thr, float32 tpx_dsr_thr, std::chrono::microseconds min_sim_time_horizon, std::chrono::microseconds max_sim_time_horizon, float32 sim_time_horizon_factor, std::chrono::microseconds tpx_time_horizon, std::chrono::microseconds perf_sampling_period, float32 float_tolerance, std::chrono::microseconds time_tolerance, std::chrono::microseconds primary_thz, std::chrono::microseconds secondary_thz, bool debug, uint32 ntf_mk_res, uint32 goal_pred_success_res, uint32 probe_level, uint32 traces, bool keep_invalidated_objects)
 
State get_state () const
 
std::chrono::microseconds get_sampling_period () const
 
uint64 get_probe_level () const
 
uint32 get_reduction_core_count () const
 
uint32 get_time_core_count () const
 
float32 get_mdl_inertia_sr_thr () const
 
uint32 get_mdl_inertia_cnt_thr () const
 
float32 get_tpx_dsr_thr () const
 
std::chrono::microseconds get_min_sim_time_horizon () const
 
std::chrono::microseconds get_max_sim_time_horizon () const
 
std::chrono::microseconds get_sim_time_horizon (std::chrono::microseconds horizon) const
 
std::chrono::microseconds get_tpx_time_horizon () const
 
std::chrono::microseconds get_primary_thz () const
 
std::chrono::microseconds get_secondary_thz () const
 
bool get_debug () const
 
uint32 get_ntf_mk_res () const
 
uint32 get_goal_pred_success_res (Group *host, Timestamp now, Timestamp::duration time_to_live) const
 
r_code::Codeget_root () const
 
r_code::Codeget_stdin () const
 
r_code::Codeget_stdout () const
 
r_code::Codeget_self () const
 
State check_state ()
 
void start_core ()
 
void shutdown_core ()
 
virtual bool load (const std::vector< r_code::Code * > *objects, uint32 stdin_oid, uint32 stdout_oid, uint32 self_oid)
 
Timestamp start ()
 
void run_in_diagnostic_time (std::chrono::milliseconds run_time)
 
virtual void on_diagnostic_time_tick ()
 
void stop ()
 
P< _ReductionJobpop_reduction_job (bool waitForItem=true)
 
void push_reduction_job (_ReductionJob *j)
 
P< TimeJobpop_time_job (bool waitForItem=true)
 
void push_time_job (TimeJob *j)
 
void inject_from_io_device (View *view)
 
Viewinject_marker_value_from_io_device (r_code::Code *obj, r_code::Code *prop, Atom val, Timestamp after, Timestamp before, View::SyncMode sync_mode, r_code::Code *group)
 
Viewinject_marker_value_from_io_device (r_code::Code *obj, r_code::Code *prop, std::vector< Atom > val, Timestamp after, Timestamp before, View::SyncMode sync_mode, r_code::Code *group)
 
Viewinject_marker_value_from_io_device (r_code::Code *obj, r_code::Code *prop, Atom val, Timestamp after, Timestamp before, View::SyncMode sync_mode)
 
Viewinject_marker_value_from_io_device (r_code::Code *obj, r_code::Code *prop, Atom val, Timestamp after, Timestamp before, r_code::Code *group)
 
Viewinject_marker_value_from_io_device (r_code::Code *obj, r_code::Code *prop, Atom val, Timestamp after, Timestamp before)
 
Viewinject_marker_value_from_io_device (r_code::Code *obj, r_code::Code *prop, r_code::Code *val, Timestamp after, Timestamp before, View::SyncMode sync_mode, r_code::Code *group)
 
Viewinject_marker_value_from_io_device (r_code::Code *obj, r_code::Code *prop, r_code::Code *val, Timestamp after, Timestamp before, View::SyncMode sync_mode)
 
Viewinject_marker_value_from_io_device (r_code::Code *obj, r_code::Code *prop, r_code::Code *val, Timestamp after, Timestamp before, r_code::Code *group)
 
Viewinject_marker_value_from_io_device (r_code::Code *obj, r_code::Code *prop, r_code::Code *val, Timestamp after, Timestamp before)
 
Viewinject_marker_value_from_io_device (r_code::Code *obj, r_code::Code *prop, const std::string &val, Timestamp after, Timestamp before, View::SyncMode sync_mode, r_code::Code *group)
 
Viewinject_marker_value_from_io_device (r_code::Code *obj, r_code::Code *prop, const std::string &val, Timestamp after, Timestamp before, View::SyncMode sync_mode)
 
Viewinject_marker_value_from_io_device (r_code::Code *obj, r_code::Code *prop, const std::string &val, Timestamp after, Timestamp before, r_code::Code *group)
 
Viewinject_marker_value_from_io_device (r_code::Code *obj, r_code::Code *prop, const std::string &val, Timestamp after, Timestamp before)
 
Viewinject_marker_value_from_io_device (r_code::Code *obj, r_code::Code *prop, const std::vector< r_code::Code * > &val, Timestamp after, Timestamp before, View::SyncMode sync_mode, r_code::Code *group)
 
Viewinject_marker_value_from_io_device (r_code::Code *obj, r_code::Code *prop, const std::vector< r_code::Code * > &val, Timestamp after, Timestamp before, View::SyncMode sync_mode)
 
Viewinject_marker_value_from_io_device (r_code::Code *obj, r_code::Code *prop, const std::vector< r_code::Code * > &val, Timestamp after, Timestamp before, r_code::Code *group)
 
Viewinject_marker_value_from_io_device (r_code::Code *obj, r_code::Code *prop, const std::vector< r_code::Code * > &val, Timestamp after, Timestamp before)
 
Viewinject_marker_value_from_io_device (r_code::Code *obj, r_code::Code *prop, uint16 opcode, const std::vector< r_code::Atom > &vals, Timestamp after, Timestamp before, View::SyncMode sync_mode, r_code::Code *group)
 
Viewinject_marker_value_from_io_device (r_code::Code *obj, r_code::Code *prop, uint16 opcode, const std::vector< r_code::Atom > &vals, Timestamp after, Timestamp before, View::SyncMode sync_mode)
 
Viewinject_marker_value_from_io_device (r_code::Code *obj, r_code::Code *prop, uint16 opcode, const std::vector< r_code::Atom > &vals, Timestamp after, Timestamp before, r_code::Code *group)
 
Viewinject_marker_value_from_io_device (r_code::Code *obj, r_code::Code *prop, uint16 opcode, const std::vector< r_code::Atom > &vals, Timestamp after, Timestamp before)
 
Viewinject_fact_from_io_device (r_code::Code *object, Timestamp after, Timestamp before, View::SyncMode sync_mode, r_code::Code *group)
 
Viewinject_fact_from_io_device (r_code::Code *object, Timestamp after, Timestamp before, r_code::Code *group)
 
void inject (View *view, bool is_from_io_device=false)
 
void inject_async (View *view)
 
void inject_new_object (View *view)
 
void inject_existing_object (View *view, r_code::Code *object, Group *host)
 
void inject_null_program (Controller *c, Group *group, std::chrono::microseconds time_to_live, bool take_past_inputs)
 
void inject_hlps (std::vector< View * > views, Group *destination)
 
void inject_notification (View *view, bool lock)
 
virtual r_code::Codecheck_existence (r_code::Code *object)=0
 
void propagate_sln (r_code::Code *object, float32 change, float32 source_sln_thr)
 
void inject_copy (View *view, Group *destination)
 
void register_reduction_job_latency (std::chrono::microseconds latency)
 
void register_time_job_latency (std::chrono::microseconds latency)
 
void inject_perf_stats ()
 
virtual void eject (View *view, uint16 node_id)
 
virtual r_code::Codeeject (r_code::Code *command)
 
virtual r_code::Code_build_object (Atom head) const =0
 
virtual r_code::Codebuild_object (Atom head) const =0
 
void pack_hlp (r_code::Code *hlp) const
 
r_code::Codeclone (r_code::Code *original) const
 
r_comp::Imageget_models ()
 
bool matches_axiom (r_code::Code *obj)
 
void set_default_runtime_output_stream (std::ostream *default_runtime_output_stream)
 
- Public Member Functions inherited from r_code::Mem
virtual Codebuild_object (SysObject *source) const =0
 

Additional Inherited Members

- Public Types inherited from r_exec::_Mem
enum  State { NOT_STARTED = 0, RUNNING = 1, STOPPED = 2 }
 
enum  STDGroupID { STDIN = 0, STDOUT = 1 }
 
- Static Public Member Functions inherited from r_exec::_Mem
static _MemGet ()
 
static Timestamp get_diagnostic_time_now ()
 
static void unpack_hlp (r_code::Code *hlp)
 
static r_code::Codeunpack_fact (r_code::Code *hlp, uint16 fact_index)
 
static r_code::Codeunpack_fact_object (r_code::Code *hlp, uint16 fact_object_index)
 
static void pack_fact (r_code::Code *fact, r_code::Code *hlp, uint16 &write_index, std::vector< P< r_code::Code > > *references)
 
static void pack_fact_object (r_code::Code *fact_object, r_code::Code *hlp, uint16 &write_index, std::vector< P< r_code::Code > > *references)
 
static r_code::Codefind_object (const std::vector< r_code::Code * > *objects, const char *name)
 
static void init_timestamps (Timestamp time_reference, const r_code::list< P< r_code::Code >> &objects)
 
static std::ostream & Output (TraceLevel l)
 
- Static Public Member Functions inherited from r_code::Mem
static MemGet ()
 
- Static Public Attributes inherited from r_exec::_Mem
static Timestamp diagnostic_time_now_ = Timestamp(microseconds(1))
 
- Protected Member Functions inherited from r_exec::_Mem
void reset ()
 
void store (r_code::Code *object)
 
- Static Protected Member Functions inherited from r_exec::_Mem
static void _unpack_code (r_code::Code *hlp, uint16 fact_object_index, r_code::Code *fact_object, uint16 read_index)
 
- Protected Attributes inherited from r_exec::_Mem
std::chrono::microseconds base_period_
 
uint32 reduction_core_count_
 
uint32 time_core_count_
 
float32 mdl_inertia_sr_thr_
 
uint32 mdl_inertia_cnt_thr_
 
float32 tpx_dsr_thr_
 
std::chrono::microseconds min_sim_time_horizon_
 
std::chrono::microseconds max_sim_time_horizon_
 
float32 sim_time_horizon_factor_
 
std::chrono::microseconds tpx_time_horizon_
 
std::chrono::microseconds perf_sampling_period_
 
float32 float_tolerance_
 
std::chrono::microseconds time_tolerance_
 
std::chrono::microseconds primary_thz_
 
std::chrono::microseconds secondary_thz_
 
bool debug_
 
uint32 ntf_mk_res_
 
uint32 goal_pred_success_res_
 
bool keep_invalidated_objects_
 
uint32 probe_level_
 
PipeNN< P< _ReductionJob >, 1024 > * reduction_job_queue_
 
PipeNN< P< TimeJob >, 1024 > * time_job_queue_
 
ReductionCore ** reduction_cores_
 
TimeCore ** time_cores_
 
uint32 reduction_job_count_
 
std::chrono::microseconds reduction_job_avg_latency_
 
std::chrono::microseconds _reduction_job_avg_latency_
 
uint32 time_job_count_
 
std::chrono::microseconds time_job_avg_latency_
 
std::chrono::microseconds _time_job_avg_latency_
 
CriticalSection time_jobCS_
 
CriticalSection reduction_jobCS_
 
uint32 core_count_
 
CriticalSection core_countCS_
 
State state_
 
CriticalSection stateCS_
 
Semaphorestop_sem_
 
r_code::list< P< r_code::Code > > objects_
 
P< Grouproot_
 
r_code::Codestdin_
 
r_code::Codestdout_
 
r_code::Codeself_
 
std::vector< Group * > initial_groups_
 
bool deleted_
 
std::ostream * runtime_output_streams_ [RUNTIME_OUTPUT_STREAM_COUNT]
 
std::ostream * default_runtime_output_stream_
 
std::vector< P< r_code::Code > > axiom_values_
 
- Static Protected Attributes inherited from r_exec::_Mem
static const uint32 RUNTIME_OUTPUT_STREAM_COUNT = 10
 
- Static Protected Attributes inherited from r_code::Mem
static Memsingleton_ = NULL
 

Detailed Description

Definition at line 936 of file mem.h.


The documentation for this class was generated from the following files: