task.h

Go to the documentation of this file.

#ifndef GHOST_TASK_H
#define GHOST_TASK_H

#include <pthread.h>
#include <semaphore.h>
#include <hwloc.h>
#include "error.h"

#define GHOST_TASK_LD_UNDEFINED -2 // initializer
//#define GHOST_TASK_LD_ANY -1 // execute task on any LD


typedef enum {
    GHOST_TASK_DEFAULT = 0,
    GHOST_TASK_PRIO_HIGH = 1,
    GHOST_TASK_LD_STRICT = 2,
    GHOST_TASK_NOT_ALLOW_CHILD = 4, 
    GHOST_TASK_NOT_PIN = 8, 
    GHOST_TASK_ONLY_HYPERTHREADS = 16,
    GHOST_TASK_NO_HYPERTHREADS = 32
} 
ghost_task_flags;


#define GHOST_TASK_FILL_LD -1

#define GHOST_TASK_FILL_ALL -2

typedef enum {
    GHOST_TASK_INVALID,
    GHOST_TASK_CREATED,
    GHOST_TASK_ENQUEUED,
    GHOST_TASK_RUNNING,
    GHOST_TASK_FINISHED
} ghost_task_state;

typedef struct ghost_task {
    int nThreads;
    int LD;
    int flags;
    void *(*func)(void *);
    void *arg;
    struct ghost_task ** depends;
    int ndepends;
    sem_t *progressSem;

    // set by the library
    ghost_task_state state;
//    int *cores;
    hwloc_bitmap_t coremap;
    hwloc_bitmap_t childusedmap;
    void *ret;
    struct ghost_task *next; 
    struct ghost_task *prev;
    struct ghost_task *parent;
    pthread_cond_t *finishedCond;
    pthread_mutex_t *mutex;
    pthread_mutex_t *finishedMutex;
    pthread_mutex_t *stateMutex;
    int freed;
} ghost_task;

#ifdef __cplusplus
extern "C" {
#endif

    ghost_error ghost_task_create(ghost_task **task, int nThreads, int LD, void *(*func)(void *), void *arg, ghost_task_flags flags, ghost_task **depends, int ndepends);
    ghost_error ghost_task_enqueue(ghost_task *t);
    ghost_error ghost_task_wait(ghost_task *t);
    ghost_task_state ghost_taskest(ghost_task *t);
    void ghost_task_destroy(ghost_task *t); 
    ghost_error ghost_task_unpin(ghost_task *task);
    const char *ghost_task_state_string(ghost_task_state state);
    ghost_error ghost_task_string(char **str, ghost_task *t); 

    ghost_error ghost_task_cur(ghost_task **task);

    bool ghost_tasking_enabled();


#ifdef __cplusplus
}// extern "C"
#endif

#endif