task.h

Go to the documentation of this file.

// SPDX-License-Identifier: MIT
#ifndef __TASK_H__
#define __TASK_H__
 
#include "confparse.h"
#include "crinit-sdefs.h"
#include "envset.h"
#include "ioredir.h"
 
typedef unsigned long crinitTaskOpts_t;  
 
#define CRINIT_TASK_OPT_RESPAWN (1 << 0)       
#define CRINIT_TASK_OPT_RESPAWN_DEFAULT false  
 
#define CRINIT_TASK_EVENT_RUNNING "spawn"  
#define CRINIT_TASK_EVENT_DONE "wait"      
#define CRINIT_TASK_EVENT_FAILED "fail"    
#define CRINIT_TASK_EVENT_NOTIFY_SUFFIX \
    "-notified"  
 
typedef enum crinitTaskType_t { CRINIT_TASK_TYPE_STANDARD, CRINIT_TASK_TYPE_INCLUDE } crinitTaskType_t;
 
typedef struct crinitTaskCmd_t {
    int argc;     
    char **argv;  
} crinitTaskCmd_t;
 
typedef struct crinitTaskDep_t {
    char *name;   
    char *event;  
} crinitTaskDep_t;
 
typedef struct crinitTaskPrv_t {
    char *name;                  
    crinitTaskState_t stateReq;  
} crinitTaskPrv_t;
 
typedef struct crinitTask_t {
    char *name;                  
    crinitTaskCmd_t *cmds;       
    size_t cmdsSize;             
    crinitEnvSet_t taskEnv;      
    crinitEnvSet_t elosFilters;  
    crinitTaskDep_t *deps;       
    size_t depsSize;             
    crinitTaskPrv_t *prv;        
    size_t prvSize;              
    crinitTaskOpts_t opts;       
    crinitTaskState_t state;     
    pid_t pid;                   
    crinitIoRedir_t *redirs;     
    size_t redirsSize;           
    int maxRetries;              
    int failCount;  
} crinitTask_t;
 
#define crinitTaskForEachDep(task, dep) for ((dep) = (task)->deps; (dep) != (task)->deps + (task)->depsSize; (dep)++)
 
int crinitTaskCreateFromConfKvList(crinitTask_t **out, const crinitConfKvList_t *in);
 
void crinitFreeTask(crinitTask_t *t);
 
void crinitDestroyTask(crinitTask_t *t);
 
int crinitTaskDup(crinitTask_t **out, const crinitTask_t *orig);
 
int crinitTaskCopy(crinitTask_t *out, const crinitTask_t *orig);
 
int crinitTaskMergeInclude(crinitTask_t *tgt, const char *src, char *importList);
 
#endif /* __TASK_H__ */