1

#include "dbfs.h"

     2

     3

#include "../lib/log.h"

     4

     5

void _dbfs_readlink_res (const struct evsql_result_info *res, void *arg) {

     6

    struct fuse_req *req = arg;

     7

    int err = 0;

     8

     9

    uint32_t ino;

    10

    const char *type, *link;

    11

    12

    // check the results

    13

    if ((err = _dbfs_check_res(res, 1, 3)))

    14

        SERROR(err = (err ==  1 ? ENOENT : EIO));

    15

    16

    // get our data

    17

    if (0

    18

        ||  evsql_result_uint32(res, 0, 0, &ino,        0 ) // inodes.ino

    19

        ||  evsql_result_string(res, 0, 1, &type,       0 ) // inodes.type

    20

        ||  evsql_result_string(res, 0, 2, &link,       1 ) // inodes.link_path

    21

    )

    22

        EERROR(err = EIO, "invalid db data");

    23

    24

    // is it a symlink?

    25

    if (_dbfs_mode(type) != S_IFLNK)

    26

        EERROR(err = EINVAL, "wrong type: %s", type);

    27

    28

    INFO("\t[dbfs.readlink %p] -> ino=%lu, type=%s, link=%s", req, (unsigned long int) ino, type, link);

    29

    30

    // reply

    31

    if ((err = fuse_reply_readlink(req, link)))

    32

        EERROR(err, "fuse_reply_readlink");

    33

    34

error:

    35

    if (err && (err = fuse_reply_err(req, err)))

    36

        EWARNING(err, "fuse_reply_err");

    37

    38

    // free

    39

    evsql_result_free(res);

    40

}

    41

    42

void dbfs_readlink (struct fuse_req *req, fuse_ino_t ino) {

    43

    struct dbfs *ctx = fuse_req_userdata(req);

    44

    int err;

    45

    46

    INFO("[dbfs.readlink %p] ino=%lu", req, ino);

    47

    48

    const char *sql =

    49

        "SELECT"

    50

        " inodes.ino, inodes.type, inodes.link_path"

    51

        " FROM inodes"

    52

        " WHERE inodes.ino = $1::int4";

    53

    54

    static struct evsql_query_params params = EVSQL_PARAMS(EVSQL_FMT_BINARY) {

    55

        EVSQL_PARAM ( UINT32 ),

    56

    57

        EVSQL_PARAMS_END

    58

    };

    59

    60

    // build params

    61

    if (0

    62

        ||  evsql_param_uint32(&params, 0, ino)

    63

    )

    64

        SERROR(err = EIO);

    65

    66

    // query

    67

    if (evsql_query_params(ctx->db, NULL, sql, &params, _dbfs_readlink_res, req) == NULL)

    68

        SERROR(err = EIO);

    69

    70

    // XXX: handle interrupts

    71

    72

    // wait

    73

    return;

    74

    75

error:

    76

    if ((err = fuse_reply_err(req, err)))

    77

        EWARNING(err, "fuse_reply_err");

    78

    79

}

    80

    81

#define SETERR(err_var, err_val, bool_val) ((err_var) = bool_val ? (err_val) : 0)

    82

    83

void dbfs_unlink_res (const struct evsql_result_info *res, void *arg) {

    84

    struct fuse_req *req = arg;

    85

    int err = 0;

    86

    87

    // check the results

    89

    if ((err = dbfs_check_result(res, 1, 0)))

    90

        goto error;

    91

    92

    INFO("\t[dbfs.unlink %p] -> OK", req);

    93

    94

    // reply

    95

    if ((err = fuse_reply_err(req, 0)))

    96

        EERROR(err, "fuse_reply_readlink");

    97

    98

error:

    99

    if (err && (err = fuse_reply_err(req, err)))

   100

        EWARNING(err, "fuse_reply_err");

   101

   102

    // free

   103

    evsql_result_free(res);

   104

}

   105

   106

void dbfs_unlink (struct fuse_req *req, fuse_ino_t parent, const char *name) {

   107

    struct dbfs *ctx = fuse_req_userdata(req);

   108

    int err;

   109

   110

    INFO("[dbfs.unlink %p] parent=%lu, name=%s", req, parent, name);

   111

   112

    const char *sql =

   113

        "DELETE"

   114

        " FROM file_tree"

   115

        " WHERE parent = $1::int4 AND name = $2::varchar";

   116

   117

    static struct evsql_query_params params = EVSQL_PARAMS(EVSQL_FMT_BINARY) {

   118

        EVSQL_PARAM ( UINT32 ),

   119

        EVSQL_PARAM ( STRING ),

   120

   121

        EVSQL_PARAMS_END

   122

    };

   123

   124

    // build params

   125

    if (SETERR(err, (0

   126

        ||  evsql_param_uint32(&params, 0, parent)

   127

        ||  evsql_param_string(&params, 1, name)

   128

    ), EIO))

   129

        goto error;

   130

   131

    // query

   132

    if (SETERR(err, evsql_query_params(ctx->db, NULL, sql, &params, dbfs_unlink_res, req) == NULL, EIO))

   133

        goto error;

   134

   135

    // XXX: handle interrupts

   136

   137

    // wait

   138

    return;

   139

   140

error:

   141

    if ((err = fuse_reply_err(req, err)))

   142

        EWARNING(err, "fuse_reply_err");

   143

}