fm_ops.h

Go to the documentation of this file.

 
#pragma once
 
#include <stdbool.h>
#include <stddef.h>
#include <stdint.h>
 
#include "fm_io.h"
#include "fm_rules.h"
 
#ifdef __cplusplus
extern "C" {
#endif

#define FM_CHUNK 16384u

typedef enum {
    FM_JOB_NONE = 0,
    FM_JOB_COPY,
    FM_JOB_MOVE,
    FM_JOB_RENAME,
    FM_JOB_DELETE,
    FM_JOB_MKDIR,
    FM_JOB_CREATE,
    FM_JOB_SAVE,
    FM_JOB_LOAD
} fm_job_kind_t;

typedef enum {
    FM_JOB_IDLE = 0,   
    FM_JOB_RUNNING,    
    FM_JOB_DONE,       
    FM_JOB_STOPPED,    
    FM_JOB_FAILED      
} fm_job_state_t;

typedef size_t (*fm_fill_fn)(void *ctx, uint64_t at, uint8_t *dst,
                             size_t cap);

typedef struct {
    fm_job_kind_t kind;      
    fm_job_state_t state;    
    fm_err_t err;            
    int step;                
    unsigned mount;          
    bool cancel;             
    bool is_dir;             
    bool dst_was;            
    bool note_restart;       
    char src[FM_PATH_SIZE];  
    char dst[FM_PATH_SIZE];  
    char tmp[FM_PATH_SIZE];  
    void *in;                
    void *out;               
    uint64_t done;           
    uint64_t total;          
    fm_fill_fn fill;         
    void *fill_ctx;          
    uint8_t *buf;            
    size_t cap;              
} fm_job_t;

fm_err_t fm_job_copy(fm_job_t *job, const fm_bench_t *bench, unsigned mount,
                     const char *src_dir, const char *name,
                     const char *dst_dir);

fm_err_t fm_job_move(fm_job_t *job, const fm_bench_t *bench, unsigned mount,
                     const char *src_dir, const char *name, bool is_dir,
                     const char *dst_dir);

fm_err_t fm_job_rename(fm_job_t *job, const fm_bench_t *bench,
                       unsigned mount, const char *dir, const char *name,
                       bool is_dir, const char *new_name);

fm_err_t fm_job_delete(fm_job_t *job, const fm_bench_t *bench,
                       unsigned mount, const char *dir, const char *name,
                       bool is_dir);

fm_err_t fm_job_mkdir(fm_job_t *job, const fm_bench_t *bench, unsigned mount,
                      const char *dir, const char *name);

fm_err_t fm_job_create(fm_job_t *job, const fm_bench_t *bench,
                       unsigned mount, const char *dir, const char *name);

fm_err_t fm_job_save(fm_job_t *job, const fm_bench_t *bench, unsigned mount,
                     const char *dir, const char *name, uint64_t len,
                     fm_fill_fn fill, void *fill_ctx);

fm_err_t fm_job_load(fm_job_t *job, const fm_bench_t *bench, unsigned mount,
                     const char *dir, const char *name, uint8_t *buf,
                     size_t cap);

fm_job_state_t fm_job_step(fm_job_t *job, const fm_io_t *io,
                           const fm_bench_t *bench, uint8_t *chunk,
                           size_t size);

void fm_job_cancel(fm_job_t *job);

fm_job_state_t fm_job_state(const fm_job_t *job, uint64_t *done,
                            uint64_t *total);
 
#ifdef __cplusplus
}
#endif