Pbb_Workers.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 PBB_WORKER_H
#define PBB_WORKER_H

#include <pthread.h>
#include <stdint.h>
#include <Spinlock.h>

#include "Knowledge_System.h"
#include "Buffered_FIFO.h"

#ifdef __cplusplus
  extern "C"
  {
#endif


struct MALP_blackboard;

struct Pbb_workers_desc
{
        int id;                 
        struct Pbb_workers *wk; 
};


struct Pbb_workers
{
        uint32_t worker_count;          
        struct Pbb_workers_desc *descs; 
        pthread_t *threads;             
        uint32_t running;               
        struct MALP_blackboard *bb;     
        struct Buffered_FIFO *fifos;    
};

void Pbb_workers_init( struct Pbb_workers *wk, struct MALP_blackboard *bb, uint32_t wk_count );

void Pbb_workers_release( struct Pbb_workers *wk );

void Pbb_workers_submit( struct Pbb_workers *wk, struct Knowledge_system_job *ksj );

void Pbb_workers_wait( struct Pbb_workers *wk );

#ifdef __cplusplus
  }
#endif

#endif