1

     2

#include <stdlib.h>

     3

     5

#include "../dbfs.h"

     8

     9

static struct fuse_lowlevel_ops dbfs_llops = {

    10

    11

    .init           = dbfs_init,

    12

    .destroy        = dbfs_destroy,

    13

    14

    .lookup         = dbfs_lookup,

    15

    16

    .getattr        = dbfs_getattr,

    17

    18

    .opendir        = dbfs_opendir,

    19

    .readdir        = dbfs_readdir,

    20

    .releasedir     = dbfs_releasedir,

    21

};

    22

    23

void dbfs_init (void *userdata, struct fuse_conn_info *conn) {

    24

    INFO("[dbfs.init] userdata=%p, conn=%p", userdata, conn);

    25

    26

}

    27

    28

void dbfs_destroy (void *arg) {

    29

    struct dbfs *ctx = arg;

    30

    INFO("[dbfs.destroy %p]", ctx);

    31

    32

    // exit libevent

    33

    event_base_loopexit(ctx->ev_base, NULL);

    34

}

    35

    36

    37

void dbfs_sql_error (struct evsql *evsql, void *arg) {

    38

    struct dbfs *ctx = arg;

    39

    40

    // AAAAAAAAAA.... panic

    41

    WARNING("[dbfs] SQL error: BREAKING MAIN LOOP LIEK NAO");

    42

    43

    event_base_loopbreak(ctx->ev_base);

    44

}

    45

    46

struct dbfs *dbfs_open (struct event_base *ev_base, struct fuse_args *args, const char *db_conninfo) {

    47

    struct dbfs *ctx = NULL;

    48

    49

    // alloc ctx

    50

    if ((ctx = calloc(1, sizeof(*ctx))) == NULL)

    51

        ERROR("calloc");

    52

    53

    ctx->ev_base = ev_base;

    54

    ctx->db_conninfo = db_conninfo;

    55

    56

    // open sql

    57

    if ((ctx->db = evsql_new_pq(ctx->ev_base, ctx->db_conninfo, dbfs_sql_error, ctx)) == NULL)

    58

        ERROR("evsql_new_pq");

    59

    60

    // open fuse

    61

    if ((ctx->ev_fuse = evfuse_new(ctx->ev_base, args, &dbfs_llops, ctx)) == NULL)

    62

        ERROR("evfuse_new");

    63

    64

    // success

    65

    return ctx;

    66

    67

error:

    68

    if (ctx)

    69

        dbfs_release(ctx);

    70

    71

    return NULL;

    72

}    

    73

    74

void dbfs_release (struct dbfs *ctx) {

    75

    // cleanup

    76

    if (ctx->ev_fuse) {

    77

        evfuse_free(ctx->ev_fuse);

    78

    79

        ctx->ev_fuse = NULL;

    80

    }

    81

    82

    if (ctx->db) {

    83

        // XXX: not yet implemented 

    84

        // evsql_close(ctx->db);

    85

        // ctx->db = NULL;

    86

    }

    87

    88

    free(ctx);

    89

}