task.h

Go to the documentation of this file.

// SPDX-License-Identifier: MIT
#ifndef __TASK_H__
#define __TASK_H__
 
#include <sys/types.h>
#include <time.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 enum crinitTaskTimestampType_t {
    CRINIT_TASK_TS_CREATION,  
    CRINIT_TASK_TS_START,     
    CRINIT_TASK_TS_END        
} crinitTaskTimestampType_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;             
    crinitTaskCmd_t *stopCmds;   
    size_t stopCmdsSize;         
    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;               
    struct timespec createTime;  
    struct timespec startTime;   
    struct timespec endTime;     
    uid_t user;                  
    gid_t group;                 
    gid_t *supGroups;            
    size_t supGroupsSize;        
    char *username;              
    char *groupname;             
} 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__ */