Multi-ApplicationOnlineProfiling
2.1
|
This is a component specialized in data processing. More...
Data Structures | |
struct | Knowledge_system |
The Knowledge_system structure. More... | |
struct | Knowledge_system_job |
struct representing a job that does the actual data processing (created by Knowledge_system) More... | |
Functions | |
void | Knowledge_system_init (struct Knowledge_system *ks, uint64_t type, uint64_t *sensivity_keys, uint32_t sensivity_count, void(*process)(struct MALP_blackboard *bb, struct Data_entry **de, uint32_t entry_count, void *arg), void *arg) |
Initializes a Knowledge_system. More... | |
void | Knowledge_system_release (struct Knowledge_system *ks) |
Knowledge_system release. More... | |
void | Knowledge_system_set_process (struct Knowledge_system *ks, void(*process)(struct MALP_blackboard *bb, struct Data_entry **de, uint32_t entry_count, void *arg), void *arg) |
sets the processing function to a Knowledge_system More... | |
void | Knowledge_system_set_serial (struct Knowledge_system *ks, int is_serial) |
sets the parallelism mode for this KS More... | |
int | Knowledge_system_has_unsatisfied_sensivities (struct Knowledge_system *ks) |
Knowledge_system_has_unsatisfied_sensivities. More... | |
struct Knowledge_system_job | Knowledge_system_job_new (struct Knowledge_system *ks) |
Knowledge_system_job_new. More... | |
void | Knowledge_system_job_release (struct Knowledge_system_job *ksj) |
Knowledge_system_job_release. More... | |
struct Knowledge_system_job | Knowledge_system_submit_data_entry (struct Knowledge_system *ks, struct Data_entry *de) |
Knowledge_system_submit_data_entry. More... | |
This is a component specialized in data processing.
Each Knowledge_System creates a set of workers (Pbb workers) in order to process data in parallel.
int Knowledge_system_has_unsatisfied_sensivities | ( | struct Knowledge_system * | ks | ) |
Knowledge_system_has_unsatisfied_sensivities.
ks |
Definition at line 132 of file Knowledge_System.c.
void Knowledge_system_init | ( | struct Knowledge_system * | ks, |
uint64_t | type, | ||
uint64_t * | sensivity_keys, | ||
uint32_t | sensivity_count, | ||
void(*)(struct MALP_blackboard *bb, struct Data_entry **de, uint32_t entry_count, void *arg) | process, | ||
void * | arg | ||
) |
Initializes a Knowledge_system.
ks | the Knowledge_system to initialize |
type | the type of the new Knowledge_system (arbitrary integer) |
sensivity_keys | the sensivity keys |
sensivity_count | the number of data entries (can't be 0) |
process | the function to give to the newly created Knowledge_system |
arg | the fourth argument to give to process |
Definition at line 27 of file Knowledge_System.c.
struct Knowledge_system_job Knowledge_system_job_new | ( | struct Knowledge_system * | ks | ) |
Knowledge_system_job_new.
ks |
Definition at line 204 of file Knowledge_System.c.
void Knowledge_system_job_release | ( | struct Knowledge_system_job * | ksj | ) |
Knowledge_system_job_release.
ksj |
Definition at line 251 of file Knowledge_System.c.
void Knowledge_system_release | ( | struct Knowledge_system * | ks | ) |
Knowledge_system release.
ks |
Definition at line 82 of file Knowledge_System.c.
void Knowledge_system_set_process | ( | struct Knowledge_system * | ks, |
void(*)(struct MALP_blackboard *bb, struct Data_entry **de, uint32_t entry_count, void *arg) | process, | ||
void * | arg | ||
) |
sets the processing function to a Knowledge_system
ks | the Knowledge_system where to set the function |
process | the process to set |
arg | an aditionnal parameter to give to process |
Definition at line 108 of file Knowledge_System.c.
void Knowledge_system_set_serial | ( | struct Knowledge_system * | ks, |
int | is_serial | ||
) |
sets the parallelism mode for this KS
ks | the Knowledge_system to targer |
is_serial | whether processing is serial or not (boolean) default YES |
Definition at line 120 of file Knowledge_System.c.
struct Knowledge_system_job Knowledge_system_submit_data_entry | ( | struct Knowledge_system * | ks, |
struct Data_entry * | de | ||
) |
Knowledge_system_submit_data_entry.
ks | |
de |
Definition at line 147 of file Knowledge_System.c.