Knowledge_System.h

Go to the documentation of this file.

/* ############################ MALP License ############################## */
/* # Fri Jan 18 14:00:00 CET 2013                                         # */
/* # Copyright or (C) or Copr. Commissariat a l'Energie Atomique          # */
/* #                                                                      # */
/* # This software is governed by the CeCILL-C license under French law   # */
/* # and abiding by the rules of distribution of free software.  You can  # */
/* # use, modify and/ or redistribute the software under the terms of     # */
/* # the CeCILL-C license as circulated by CEA, CNRS and INRIA at the     # */
/* # following URL http://www.cecill.info.                                # */
/* #                                                                      # */
/* # The fact that you are presently reading this means that you have     # */
/* # had knowledge of the CeCILL-C license and that you accept its        # */
/* # terms.                                                               # */
/* #                                                                      # */
/* # Authors:                                                             # */
/* #   - BESNARD Jean-Baptiste jean-baptiste.besnard@cea.fr               # */
/* #                                                                      # */
/* ######################################################################## */

#ifndef KNOWLEDGE_SYSTEM_H
#define KNOWLEDGE_SYSTEM_H

#ifdef __cplusplus
extern "C" {
#endif

#include "Buffered_FIFO.h"
#include "Spinlock.h"

struct Data_entry;
struct MALP_blackboard;

struct Knowledge_system
{
    uint8_t freed;                      
    int64_t type;                       
    MALP_Spinlock lock;                 
        /* Sensivity Handling */
    uint32_t sensivity_count;           
    uint64_t *sensivity_keys;           
    uint64_t *sensivity_array;          
    struct Buffered_FIFO *data_entries; 
    int is_serial;                                              
    void (*process)( struct MALP_blackboard *bb, 
                                         struct Data_entry **de, uint32_t entry_count, void *arg ); 
    void *arg;                          
};


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 );

void Knowledge_system_release( struct Knowledge_system *ks );

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 );

void Knowledge_system_set_serial( struct Knowledge_system *ks, int is_serial );

int Knowledge_system_has_unsatisfied_sensivities( struct Knowledge_system *ks );



struct Knowledge_system_job
{
    uint64_t ks_type;               
    int32_t entries_count;          
    struct Data_entry **entries;    
    void (*process)( struct MALP_blackboard *bb, struct Data_entry **de, uint32_t entry_count, void *arg ); 
    void *arg;                      
    int is_serial;                                      
};

struct Knowledge_system_job Knowledge_system_job_new( struct Knowledge_system *ks );

void Knowledge_system_job_release( struct Knowledge_system_job *ksj );


struct Knowledge_system_job Knowledge_system_submit_data_entry( struct Knowledge_system *ks, struct Data_entry *de );


#ifdef __cplusplus
}
#endif


#endif