arax_vaccel.h

Go to the documentation of this file.

#ifndef ARAX_VACCEL_HEADER
#define ARAX_VACCEL_HEADER
#include "core/arax_object.h"
#include "utils/queue.h"
 
typedef struct arax_vaccel_s arax_vaccel_s;
 
#include "core/arax_accel.h"
#include "utils/queue.h"
#include "async.h"
 
#ifdef __cplusplus
extern "C" {
#endif /* ifdef __cplusplus */
 
typedef enum arax_accel_ordering_e
{
    SEQUENTIAL, // < Tasks in VAQ will run one after the other(no overlap)
    PARALLEL    // < Tasks in VAQ can run in parallel(can overlap).
} arax_accel_ordering_e;

struct arax_vaccel_s
{
    arax_object_s         obj;
    arax_accel_type_e     type;
    arax_accel_ordering_e ordering;
    utils_spinlock        lock;
    utils_list_node_s     vaccels; // Used in pipe->orphan_vacs or phys->vaccels
    uint64_t              cid;
    uint64_t              priority;
    arax_accel_s *        phys;
    void *                meta; // Metadata pointer available to controller.
    utils_queue_s         queue;
};

arax_vaccel_s* arax_vaccel_init(arax_pipe_s *pipe, const char *name,
  arax_accel_type_e type, arax_accel_s *accel);
 
void arax_vaccel_add_task(arax_vaccel_s *accel, arax_task *task);

void arax_vaccel_set_ordering(arax_accel_s *accel, arax_accel_ordering_e ordering);

arax_accel_ordering_e arax_vaccel_get_ordering(arax_accel_s *accel);

uint64_t arax_vaccel_set_cid(arax_vaccel_s *vaccel, uint64_t cid);

uint64_t arax_vaccel_get_cid(arax_vaccel_s *vaccel);

uint64_t arax_vaccel_set_job_priority(arax_vaccel_s *vaccel, uint64_t priority);

uint64_t arax_vaccel_get_job_priority(arax_vaccel_s *vaccel);

void arax_vaccel_set_meta(arax_vaccel_s *vaccel, void *meta);

void* arax_vaccel_get_meta(arax_vaccel_s *vaccel);

utils_queue_s* arax_vaccel_queue(arax_vaccel_s *vaccel);

unsigned int arax_vaccel_queue_size(arax_vaccel_s *vaccel);
 
arax_accel_state_e arax_vaccel_get_stat(arax_vaccel_s *accel, arax_accel_stats_s *stat);
 
#ifdef __cplusplus
}
#endif /* ifdef __cplusplus */
 
#endif /* ifndef ARAX_VACCEL_HEADER */