arax_accel.h

Go to the documentation of this file.

#ifndef ARAX_ACCEL_HEADER
#define ARAX_ACCEL_HEADER
#include <arax.h>
typedef struct arax_accel_s arax_accel_s;
 
#include "async.h"
#include "core/arax_vaccel.h"
#include "core/arax_throttle.h"
 
#ifdef __cplusplus
extern "C" {
#endif /* ifdef __cplusplus */
 
struct arax_accel_s
{
    arax_object_s      obj;
    arax_accel_type_e  type;
    arax_accel_state_e state;
    async_condition_s  lock; /* protect vaccels & tasks */
    utils_list_s       vaccels;
    size_t             tasks; 
    size_t             revision;
    arax_throttle_s    throttle;
    arax_accel_stats_s stats;
    arax_vaccel_s *    free_vaq;
    /* To add more as needed */
};

arax_accel_s* arax_accel_init(arax_pipe_s *pipe, const char *name,
  arax_accel_type_e type, size_t size, size_t capacity);

void arax_accel_wait_for_task(arax_accel_s *accel);

void arax_accel_add_task(arax_accel_s *accel);

size_t arax_accel_pending_tasks(arax_accel_s *accel);

const char* arax_accel_get_name(arax_accel_s *accel);

arax_accel_state_e arax_accel_get_stat(arax_accel_s *accel, arax_accel_stats_s *stat);

void arax_accel_inc_revision(arax_accel_s *accel);

size_t arax_accel_get_revision(arax_accel_s *accel);
 
 
#ifdef ARAX_THROTTLE_DEBUG
#define ARAX_THROTTLE_DEBUG_ACCEL_PARAMS , const char *parent
#define ARAX_THROTTLE_DEBUG_ACCEL_FUNC(FUNC) __ ## FUNC
#define arax_accel_size_inc(vac, sz)         __arax_accel_size_inc(vac, sz, __func__)
#define arax_accel_size_dec(vac, sz)         __arax_accel_size_dec(vac, sz, __func__)
#else
#define ARAX_THROTTLE_DEBUG_ACCEL_PARAMS
#define ARAX_THROTTLE_DEBUG_ACCEL_FUNC(FUNC) FUNC
#endif

void ARAX_THROTTLE_DEBUG_ACCEL_FUNC(arax_accel_size_inc)(arax_accel * accel,
  size_t sz ARAX_THROTTLE_DEBUG_ACCEL_PARAMS);

void ARAX_THROTTLE_DEBUG_ACCEL_FUNC(arax_accel_size_dec)(arax_accel * accel,
  size_t sz ARAX_THROTTLE_DEBUG_ACCEL_PARAMS);

size_t arax_accel_get_available_size(arax_accel *accel);

size_t arax_accel_get_total_size(arax_accel *accel);

void arax_accel_add_vaccel(arax_accel_s *accel, arax_vaccel_s *vaccel);

size_t arax_accel_get_assigned_vaccels(arax_accel_s *accel, arax_vaccel_s ***vaccel);

void arax_accel_del_vaccel(arax_accel_s *accel, arax_vaccel_s *vaccel);
 
#ifdef __cplusplus
}
#endif /* ifdef __cplusplus */
 
#endif /* ifndef ARAX_ACCEL_HEADER */