arax_pipe.h

Go to the documentation of this file.

#ifndef ARAX_PIPE_HEADER
#define ARAX_PIPE_HEADER
#include <arax.h>
#include <utils/Kv.h>
#include "utils/queue.h"
#include "core/arax_accel.h"
#include "core/arax_task.h"
 
#ifdef __cplusplus
extern "C" {
#endif /* ifdef __cplusplus */
 
typedef struct
{
    int pid;
    int threads;
} arax_process_tracker_s;
 
#define ARAX_PIPE_SHA_SIZE 48

typedef struct arax_pipe
{
    char               sha[ARAX_PIPE_SHA_SIZE + 1];  
    void               *self;                        
    uint64_t           shm_size;                     
    uint64_t           processes;                    
    utils_spinlock     proc_lock;                    
    uint64_t           proc_map[ARAX_PROC_MAP_SIZE]; 
    uint64_t           last_uid;                     
    arax_object_repo_s objs;                         
    async_meta_s       async;                        
    arax_throttle_s    throttle;
 
    int                cntrl_ready;      
    async_condition_s  cntrl_ready_cond; 
 
    async_condition_s  orphan_cond; 
    utils_list_s       orphan_vacs; 
 
    utils_kv_s         ass_kv;     
    utils_kv_s         metrics_kv; 
 
    arch_alloc_s       allocator; 
} arax_pipe_s;

arax_pipe_s* arax_controller_init_start();

void arax_controller_init_done();

const char* arax_pipe_get_revision(arax_pipe_s *pipe);

void arax_pipe_add_orphan_vaccel(arax_pipe_s *pipe, arax_vaccel_s *vac);

int arax_pipe_have_orphan_vaccels(arax_pipe_s *pipe);

arax_vaccel_s* arax_pipe_get_orphan_vaccel(arax_pipe_s *pipe);

void arax_pipe_remove_orphan_vaccel(arax_pipe_s *pipe, arax_vaccel_s *vac);

void arax_pipe_orphan_stop(arax_pipe_s *pipe);

uint64_t arax_pipe_add_process(arax_pipe_s *pipe);

uint64_t arax_pipe_del_process(arax_pipe_s *pipe);

int arax_pipe_have_to_mmap(arax_pipe_s *pipe, int pid);

void arax_pipe_mark_unmap(arax_pipe_s *pipe, int pid);

void* arax_pipe_mmap_address(arax_pipe_s *pipe);

arax_pipe_s* arax_pipe_init(void *mem, size_t size, int enforce_version);

int arax_pipe_delete_accel(arax_pipe_s *pipe, arax_accel_s *accel);

arax_accel_s* arax_pipe_find_accel(arax_pipe_s *pipe, const char *name,
  arax_accel_type_e type);

arax_proc_s* arax_pipe_find_proc(arax_pipe_s *pipe, const char *name);

int arax_pipe_exit(arax_pipe_s *pipe);
 
#ifdef ARAX_THROTTLE_DEBUG
#define ARAX_PIPE_THOTTLE_DEBUG_PARAMS , const char *parent
#define ARAX_PIPE_THOTTLE_DEBUG_FUNC(FUNC) __ ## FUNC
#define arax_pipe_size_inc(PIPE, SZ)       __arax_pipe_size_inc(PIPE, SZ, __func__)
#define arax_pipe_size_dec(PIPE, SZ)       __arax_pipe_size_dec(PIPE, SZ, __func__)
#else
#define ARAX_PIPE_THOTTLE_DEBUG_PARAMS
#define ARAX_PIPE_THOTTLE_DEBUG_FUNC(FUNC) FUNC
#endif

void ARAX_PIPE_THOTTLE_DEBUG_FUNC(arax_pipe_size_inc)(arax_pipe_s * pipe, size_t sz ARAX_PIPE_THOTTLE_DEBUG_PARAMS);

void ARAX_PIPE_THOTTLE_DEBUG_FUNC(arax_pipe_size_dec)(arax_pipe_s * pipe, size_t sz ARAX_PIPE_THOTTLE_DEBUG_PARAMS);

size_t arax_pipe_get_available_size(arax_pipe_s *pipe);

size_t arax_pipe_get_total_size(arax_pipe_s *pipe);
 
#ifdef MMAP_FIXED
#define pointer_to_offset(TYPE, BASE, \
      VD)                                 ( (TYPE) ( (void *) (VD) -(void *) (BASE) ) )
#define offset_to_pointer(TYPE, BASE, \
      VD)                                 ( (TYPE) ( (char *) (BASE) + (size_t) (VD) ) )
#else /* ifdef MMAP_FIXED */
#define pointer_to_offset(TYPE, BASE, VD) ( (TYPE) VD )
#define offset_to_pointer(TYPE, BASE, VD) ( (TYPE) VD )
#endif /* ifdef MMAP_FIXED */
 
#ifdef __cplusplus
}
#endif /* ifdef __cplusplus */
 
#endif /* ifndef ARAX_PIPE_HEADER */