taskdb.h

Go to the documentation of this file.

// SPDX-License-Identifier: MIT
#ifndef __TASKDB_H__
#define __TASKDB_H__
 
#include <pthread.h>
#include <stddef.h>
 
#include "task.h"
 
#define CRINIT_MONITOR_DEP_NAME "@crinitmon"  
#define CRINIT_PROVIDE_DEP_NAME "@provided"   
#define CRINIT_TASKDB_INITIAL_SIZE 256        
 
typedef enum crinitDispatchThreadMode_t {
    CRINIT_DISPATCH_THREAD_MODE_START,
    CRINIT_DISPATCH_THREAD_MODE_STOP
} crinitDispatchThreadMode_t;
 
typedef struct crinitTaskDB_t {
    crinitTask_t *taskSet;  
    size_t taskSetSize;     
    size_t taskSetItems;    
 
    int (*spawnFunc)(struct crinitTaskDB_t *ctx, const crinitTask_t *, crinitDispatchThreadMode_t mode);
 
    bool
        spawnInhibit;  
 
    pthread_mutex_t lock;    
    pthread_cond_t changed;  
} crinitTaskDB_t;
 
#define crinitTaskDbForEach(taskDb, task) \
    for ((task) = (taskDb)->taskSet; (task) != (taskDb)->taskSet + (taskDb)->taskSetItems; (task)++)
 
int crinitTaskDBInsert(crinitTaskDB_t *ctx, const crinitTask_t *t, bool overwrite);
#define crinitTaskDBUpdate(ctx, t) crinitTaskDBInsert(ctx, t, true)
 
int crinitTaskDBFulfillDep(crinitTaskDB_t *ctx, const crinitTaskDep_t *dep, const crinitTask_t *target);
int crinitTaskDBProvideFeature(crinitTaskDB_t *ctx, const crinitTask_t *provider, crinitTaskState_t newState);
int crinitTaskDBProvideFeatureByTaskName(crinitTaskDB_t *ctx, const char *taskName, crinitTaskState_t newState);
int crinitTaskDBAddDepToTask(crinitTaskDB_t *ctx, const crinitTaskDep_t *dep, const char *taskName);
int crinitTaskDBRemoveDepFromTask(crinitTaskDB_t *ctx, const crinitTaskDep_t *dep, const char *taskName);
 
int crinitTaskDBGetTaskByName(crinitTaskDB_t *ctx, crinitTask_t **task, const char *taskName);
 
int crinitTaskDBSetTaskState(crinitTaskDB_t *ctx, crinitTaskState_t s, const char *taskName);
int crinitTaskDBGetTaskState(crinitTaskDB_t *ctx, crinitTaskState_t *s, const char *taskName);
 
int crinitTaskDBSetTaskPID(crinitTaskDB_t *ctx, pid_t pid, const char *taskName);
int crinitTaskDBGetTaskPID(crinitTaskDB_t *ctx, pid_t *pid, const char *taskName);
 
int crinitTaskDBGetTaskStateAndPID(crinitTaskDB_t *ctx, crinitTaskState_t *s, pid_t *pid, const char *taskName);
 
crinitTask_t *crinitTaskDBBorrowTask(crinitTaskDB_t *ctx, const char *taskName);
int crinitTaskDBRemit(crinitTaskDB_t *ctx);
 
int crinitTaskDBSpawnReady(crinitTaskDB_t *ctx, crinitDispatchThreadMode_t mode);
int crinitTaskDBSetSpawnInhibit(crinitTaskDB_t *ctx, bool inh);
 
int crinitTaskDBInitWithSize(crinitTaskDB_t *ctx,
                             int (*spawnFunc)(crinitTaskDB_t *ctx, const crinitTask_t *,
                                              crinitDispatchThreadMode_t mode),
                             size_t initialSize);
#define crinitTaskDBInit(ctx, spawnFunc) crinitTaskDBInitWithSize(ctx, spawnFunc, CRINIT_TASKDB_INITIAL_SIZE);
 
int crinitTaskDBDestroy(crinitTaskDB_t *ctx);
 
int crinitTaskDBExportTaskNamesToArray(crinitTaskDB_t *ctx, char **tasks[], size_t *numTasks);
 
#endif /* __TASKDB_H__ */