multiprocessing.h

Go to the documentation of this file.

#ifndef STASIS_MULTIPROCESSING_H
#define STASIS_MULTIPROCESSING_H
 
#include "core.h"
#include "sem.h"
#include "timespec.h"
#include <signal.h>
#include <sys/wait.h>
#include <sys/mman.h>
#include <fcntl.h>
#include <sys/stat.h>
#include <math.h>
 
struct MultiProcessingTimer {
    struct timespec t_start;
    struct timespec t_stop;
    double duration;
};
 
struct MultiProcessingTask {
    pid_t pid; 
    pid_t parent_pid; 
    int status; 
    int signaled_by; 
    int timeout; 
    time_t _startup; 
    char ident[255]; 
    char *cmd; 
    size_t cmd_len; 
    char working_dir[PATH_MAX]; 
    char log_file[PATH_MAX]; 
    char parent_script[PATH_MAX]; 
    struct MultiProcessingTimer time_data; 
    struct MultiProcessingTimer interval_data; 
};
 
struct MultiProcessingPool {
    struct MultiProcessingTask *task; 
    size_t num_used; 
    size_t num_alloc; 
    char ident[255]; 
    char log_root[PATH_MAX]; 
    int status_interval; 
    struct Semaphore semaphore;
};

#define MP_POOL_TASK_STATUS_INITIAL (-1)

#define MP_POOL_TASK_MAX 1000

#define MP_POOL_PID_UNUSED 0

#define MP_POOL_FAIL_FAST 1 << 1

struct MultiProcessingPool *mp_pool_init(const char *ident, const char *log_root);

struct MultiProcessingTask *mp_pool_task(struct MultiProcessingPool *pool, const char *ident, char *working_dir, char *cmd);

int mp_pool_join(struct MultiProcessingPool *pool, size_t jobs, size_t flags);

void mp_pool_show_summary(struct MultiProcessingPool *pool);

void mp_pool_free(struct MultiProcessingPool **pool);
 
 
#endif //STASIS_MULTIPROCESSING_H