src/dbfs/link.c
author Tero Marttila <terom@fixme.fi>
Sat, 29 Nov 2008 01:30:43 +0200
branchnew-evsql
changeset 49 bb2ff0d2d343
parent 48 8b019d191353
child 50 881de320e483
permissions -rw-r--r--
modify stat-returning dbfs result functions to use new evsql
32
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
     1
#include "dbfs.h"
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
     2
38
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
     3
/*
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
     4
 * Handling simple ino-related ops, like lookup, readlink, unlink and link
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
     5
 */
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
     6
32
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
     7
#include "../lib/log.h"
38
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
     8
#include "../lib/misc.h"
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
     9
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    10
/*
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    11
 * Used for lookup and link
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    12
 */
48
8b019d191353 update dbfs code to work with new evsql
Tero Marttila <terom@fixme.fi>
parents: 41
diff changeset
    13
void dbfs_entry_res (struct evsql_result *res, void *arg) {
38
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    14
    struct fuse_req *req = arg;
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    15
    struct fuse_entry_param e; ZINIT(e);
49
bb2ff0d2d343 modify stat-returning dbfs result functions to use new evsql
Tero Marttila <terom@fixme.fi>
parents: 48
diff changeset
    16
    err_t err = 0;
38
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    17
    
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    18
    uint32_t ino;
49
bb2ff0d2d343 modify stat-returning dbfs result functions to use new evsql
Tero Marttila <terom@fixme.fi>
parents: 48
diff changeset
    19
    struct dbfs_stat_values stat_values;
bb2ff0d2d343 modify stat-returning dbfs result functions to use new evsql
Tero Marttila <terom@fixme.fi>
parents: 48
diff changeset
    20
bb2ff0d2d343 modify stat-returning dbfs result functions to use new evsql
Tero Marttila <terom@fixme.fi>
parents: 48
diff changeset
    21
    // result info
bb2ff0d2d343 modify stat-returning dbfs result functions to use new evsql
Tero Marttila <terom@fixme.fi>
parents: 48
diff changeset
    22
    static struct evsql_result_info result_info = {
bb2ff0d2d343 modify stat-returning dbfs result functions to use new evsql
Tero Marttila <terom@fixme.fi>
parents: 48
diff changeset
    23
        0, {
bb2ff0d2d343 modify stat-returning dbfs result functions to use new evsql
Tero Marttila <terom@fixme.fi>
parents: 48
diff changeset
    24
            {   EVSQL_FMT_BINARY,   EVSQL_TYPE_UINT32   },  // inodes.ino
bb2ff0d2d343 modify stat-returning dbfs result functions to use new evsql
Tero Marttila <terom@fixme.fi>
parents: 48
diff changeset
    25
            DBFS_STAT_RESULT_INFO,
bb2ff0d2d343 modify stat-returning dbfs result functions to use new evsql
Tero Marttila <terom@fixme.fi>
parents: 48
diff changeset
    26
            {   0,                  0                   }
bb2ff0d2d343 modify stat-returning dbfs result functions to use new evsql
Tero Marttila <terom@fixme.fi>
parents: 48
diff changeset
    27
        }
bb2ff0d2d343 modify stat-returning dbfs result functions to use new evsql
Tero Marttila <terom@fixme.fi>
parents: 48
diff changeset
    28
    };
bb2ff0d2d343 modify stat-returning dbfs result functions to use new evsql
Tero Marttila <terom@fixme.fi>
parents: 48
diff changeset
    29
bb2ff0d2d343 modify stat-returning dbfs result functions to use new evsql
Tero Marttila <terom@fixme.fi>
parents: 48
diff changeset
    30
    // begin
bb2ff0d2d343 modify stat-returning dbfs result functions to use new evsql
Tero Marttila <terom@fixme.fi>
parents: 48
diff changeset
    31
    if ((err = evsql_result_begin(&result_info, res)))
bb2ff0d2d343 modify stat-returning dbfs result functions to use new evsql
Tero Marttila <terom@fixme.fi>
parents: 48
diff changeset
    32
        EERROR(err, "query failed");
bb2ff0d2d343 modify stat-returning dbfs result functions to use new evsql
Tero Marttila <terom@fixme.fi>
parents: 48
diff changeset
    33
bb2ff0d2d343 modify stat-returning dbfs result functions to use new evsql
Tero Marttila <terom@fixme.fi>
parents: 48
diff changeset
    34
    // get the one row of data
bb2ff0d2d343 modify stat-returning dbfs result functions to use new evsql
Tero Marttila <terom@fixme.fi>
parents: 48
diff changeset
    35
    if ((err = evsql_result_next(res, &ino, DBFS_STAT_RESULT_VALUES(&stat_values))) <= 0)
bb2ff0d2d343 modify stat-returning dbfs result functions to use new evsql
Tero Marttila <terom@fixme.fi>
parents: 48
diff changeset
    36
        EERROR(err = (err ? err : ENOENT), "evsql_result_next");
bb2ff0d2d343 modify stat-returning dbfs result functions to use new evsql
Tero Marttila <terom@fixme.fi>
parents: 48
diff changeset
    37
   
38
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    38
    INFO("\t[dbfs.lookup] -> ino=%u", ino);
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    39
    
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    40
    // stat attrs
49
bb2ff0d2d343 modify stat-returning dbfs result functions to use new evsql
Tero Marttila <terom@fixme.fi>
parents: 48
diff changeset
    41
    if ((err = _dbfs_stat_info(&e.attr, &stat_values)))
38
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    42
        goto error;
49
bb2ff0d2d343 modify stat-returning dbfs result functions to use new evsql
Tero Marttila <terom@fixme.fi>
parents: 48
diff changeset
    43
    
38
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    44
    // other attrs
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    45
    e.ino = e.attr.st_ino = ino;
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    46
    e.attr_timeout = CACHE_TIMEOUT;
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    47
    e.entry_timeout = CACHE_TIMEOUT;
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    48
        
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    49
    // reply
40
03017f5f0087 add MODE param to makefile, fix INFO_DISABLED, add some constraints to the .sql, fix some -err's, EVSQL_PQ_ARBITRARY_TYPE_OID, and make read/write transactionless
Tero Marttila <terom@fixme.fi>
parents: 38
diff changeset
    50
    if ((err = -fuse_reply_entry(req, &e)))
38
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    51
        EERROR(err, "fuse_reply_entry");
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    52
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    53
error:
40
03017f5f0087 add MODE param to makefile, fix INFO_DISABLED, add some constraints to the .sql, fix some -err's, EVSQL_PQ_ARBITRARY_TYPE_OID, and make read/write transactionless
Tero Marttila <terom@fixme.fi>
parents: 38
diff changeset
    54
    if (err && (err = -fuse_reply_err(req, err)))
38
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    55
        EWARNING(err, "fuse_reply_err");
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    56
49
bb2ff0d2d343 modify stat-returning dbfs result functions to use new evsql
Tero Marttila <terom@fixme.fi>
parents: 48
diff changeset
    57
    // done
bb2ff0d2d343 modify stat-returning dbfs result functions to use new evsql
Tero Marttila <terom@fixme.fi>
parents: 48
diff changeset
    58
    evsql_result_end(res);
38
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    59
}
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    60
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    61
void dbfs_lookup (struct fuse_req *req, fuse_ino_t parent, const char *name) {
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    62
    struct dbfs *ctx = fuse_req_userdata(req);
41
6abda2fa4579 touch up the Makefile, define err_t as unsigned int in error.h, and add some preliminary interrupt support, although it will always deadlock due to a bug in libfuse
Tero Marttila <terom@fixme.fi>
parents: 40
diff changeset
    63
    struct evsql_query *query;
38
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    64
    int err;
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    65
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    66
    INFO("[dbfs.lookup] parent=%lu name=%s", parent, name);
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    67
    
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    68
    // query and params
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    69
    const char *sql = 
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    70
        "SELECT"
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    71
        " inodes.ino, " DBFS_STAT_COLS
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    72
        " FROM file_tree INNER JOIN inodes ON (file_tree.ino = inodes.ino)"
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    73
        " WHERE file_tree.parent = $1::int4 AND file_tree.name = $2::varchar";
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    74
    
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    75
    static struct evsql_query_params params = EVSQL_PARAMS(EVSQL_FMT_BINARY) {
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    76
        EVSQL_PARAM ( UINT32 ),
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    77
        EVSQL_PARAM ( STRING ),
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    78
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    79
        EVSQL_PARAMS_END
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    80
    };
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    81
    
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    82
    // build params
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    83
    if (0
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    84
        ||  evsql_param_uint32(&params, 0, parent)
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    85
        ||  evsql_param_string(&params, 1, name)
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    86
    )
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    87
        EERROR(err = EIO, "evsql_param_*");
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    88
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    89
    // query
41
6abda2fa4579 touch up the Makefile, define err_t as unsigned int in error.h, and add some preliminary interrupt support, although it will always deadlock due to a bug in libfuse
Tero Marttila <terom@fixme.fi>
parents: 40
diff changeset
    90
    if ((query = evsql_query_params(ctx->db, NULL, sql, &params, dbfs_entry_res, req)) == NULL)
38
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    91
        EERROR(err = EIO, "evsql_query_params");
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    92
41
6abda2fa4579 touch up the Makefile, define err_t as unsigned int in error.h, and add some preliminary interrupt support, although it will always deadlock due to a bug in libfuse
Tero Marttila <terom@fixme.fi>
parents: 40
diff changeset
    93
    // handle interrupts
6abda2fa4579 touch up the Makefile, define err_t as unsigned int in error.h, and add some preliminary interrupt support, although it will always deadlock due to a bug in libfuse
Tero Marttila <terom@fixme.fi>
parents: 40
diff changeset
    94
    fuse_req_interrupt_func(req, dbfs_interrupt_query, query);
38
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    95
    
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    96
    // wait
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    97
    return;
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    98
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
    99
error:
40
03017f5f0087 add MODE param to makefile, fix INFO_DISABLED, add some constraints to the .sql, fix some -err's, EVSQL_PQ_ARBITRARY_TYPE_OID, and make read/write transactionless
Tero Marttila <terom@fixme.fi>
parents: 38
diff changeset
   100
    if ((err = -fuse_reply_err(req, err)))
38
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   101
        EWARNING(err, "fuse_reply_err");
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   102
}
32
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   103
48
8b019d191353 update dbfs code to work with new evsql
Tero Marttila <terom@fixme.fi>
parents: 41
diff changeset
   104
void _dbfs_readlink_res (struct evsql_result *res, void *arg) {
32
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   105
    struct fuse_req *req = arg;
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   106
    int err = 0;
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   107
    
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   108
    uint32_t ino;
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   109
    const char *type, *link;
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   110
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   111
    // check the results
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   112
    if ((err = _dbfs_check_res(res, 1, 3)))
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   113
        SERROR(err = (err ==  1 ? ENOENT : EIO));
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   114
        
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   115
    // get our data
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   116
    if (0
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   117
        ||  evsql_result_uint32(res, 0, 0, &ino,        0 ) // inodes.ino
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   118
        ||  evsql_result_string(res, 0, 1, &type,       0 ) // inodes.type
33
c71f3053c714 working symlink
Tero Marttila <terom@fixme.fi>
parents: 32
diff changeset
   119
        ||  evsql_result_string(res, 0, 2, &link,       1 ) // inodes.link_path
32
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   120
    )
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   121
        EERROR(err = EIO, "invalid db data");
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   122
    
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   123
    // is it a symlink?
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   124
    if (_dbfs_mode(type) != S_IFLNK)
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   125
        EERROR(err = EINVAL, "wrong type: %s", type);
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   126
    
36
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   127
    INFO("\t[dbfs.readlink %p] -> ino=%lu, type=%s, link=%s", req, (unsigned long int) ino, type, link);
32
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   128
    
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   129
    // reply
40
03017f5f0087 add MODE param to makefile, fix INFO_DISABLED, add some constraints to the .sql, fix some -err's, EVSQL_PQ_ARBITRARY_TYPE_OID, and make read/write transactionless
Tero Marttila <terom@fixme.fi>
parents: 38
diff changeset
   130
    if ((err = -fuse_reply_readlink(req, link)))
32
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   131
        EERROR(err, "fuse_reply_readlink");
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   132
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   133
error:
40
03017f5f0087 add MODE param to makefile, fix INFO_DISABLED, add some constraints to the .sql, fix some -err's, EVSQL_PQ_ARBITRARY_TYPE_OID, and make read/write transactionless
Tero Marttila <terom@fixme.fi>
parents: 38
diff changeset
   134
    if (err && (err = -fuse_reply_err(req, err)))
32
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   135
        EWARNING(err, "fuse_reply_err");
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   136
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   137
    // free
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   138
    evsql_result_free(res);
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   139
}
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   140
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   141
void dbfs_readlink (struct fuse_req *req, fuse_ino_t ino) {
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   142
    struct dbfs *ctx = fuse_req_userdata(req);
41
6abda2fa4579 touch up the Makefile, define err_t as unsigned int in error.h, and add some preliminary interrupt support, although it will always deadlock due to a bug in libfuse
Tero Marttila <terom@fixme.fi>
parents: 40
diff changeset
   143
    struct evsql_query *query;
32
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   144
    int err;
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   145
    
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   146
    INFO("[dbfs.readlink %p] ino=%lu", req, ino);
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   147
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   148
    const char *sql =
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   149
        "SELECT"
33
c71f3053c714 working symlink
Tero Marttila <terom@fixme.fi>
parents: 32
diff changeset
   150
        " inodes.ino, inodes.type, inodes.link_path"
32
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   151
        " FROM inodes"
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   152
        " WHERE inodes.ino = $1::int4";
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   153
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   154
    static struct evsql_query_params params = EVSQL_PARAMS(EVSQL_FMT_BINARY) {
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   155
        EVSQL_PARAM ( UINT32 ),
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   156
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   157
        EVSQL_PARAMS_END
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   158
    };
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   159
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   160
    // build params
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   161
    if (0
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   162
        ||  evsql_param_uint32(&params, 0, ino)
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   163
    )
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   164
        SERROR(err = EIO);
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   165
        
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   166
    // query
41
6abda2fa4579 touch up the Makefile, define err_t as unsigned int in error.h, and add some preliminary interrupt support, although it will always deadlock due to a bug in libfuse
Tero Marttila <terom@fixme.fi>
parents: 40
diff changeset
   167
    if ((query = evsql_query_params(ctx->db, NULL, sql, &params, _dbfs_readlink_res, req)) == NULL)
32
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   168
        SERROR(err = EIO);
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   169
41
6abda2fa4579 touch up the Makefile, define err_t as unsigned int in error.h, and add some preliminary interrupt support, although it will always deadlock due to a bug in libfuse
Tero Marttila <terom@fixme.fi>
parents: 40
diff changeset
   170
    // handle interrupts
6abda2fa4579 touch up the Makefile, define err_t as unsigned int in error.h, and add some preliminary interrupt support, although it will always deadlock due to a bug in libfuse
Tero Marttila <terom@fixme.fi>
parents: 40
diff changeset
   171
    fuse_req_interrupt_func(req, dbfs_interrupt_query, query);
32
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   172
    
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   173
    // wait
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   174
    return;
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   175
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   176
error:
40
03017f5f0087 add MODE param to makefile, fix INFO_DISABLED, add some constraints to the .sql, fix some -err's, EVSQL_PQ_ARBITRARY_TYPE_OID, and make read/write transactionless
Tero Marttila <terom@fixme.fi>
parents: 38
diff changeset
   177
    if ((err = -fuse_reply_err(req, err)))
32
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   178
        EWARNING(err, "fuse_reply_err");
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   179
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   180
}
33
c71f3053c714 working symlink
Tero Marttila <terom@fixme.fi>
parents: 32
diff changeset
   181
36
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   182
#define SETERR(err_var, err_val, bool_val) ((err_var) = bool_val ? (err_val) : 0)
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   183
48
8b019d191353 update dbfs code to work with new evsql
Tero Marttila <terom@fixme.fi>
parents: 41
diff changeset
   184
void dbfs_unlink_res (struct evsql_result *res, void *arg) {
36
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   185
    struct fuse_req *req = arg;
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   186
    int err = 0;
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   187
    
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   188
    // check the results
37
c3880f3b4de8 update fuse_db.sql, just use dbfs_unlink for rmdir (no special handling)
Tero Marttila <terom@fixme.fi>
parents: 36
diff changeset
   189
    // XXX: reply with ENOTEMPTY if it fails due to this inode being a dir
36
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   190
    if ((err = dbfs_check_result(res, 1, 0)))
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   191
        goto error;
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   192
        
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   193
    INFO("\t[dbfs.unlink %p] -> OK", req);
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   194
    
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   195
    // reply
40
03017f5f0087 add MODE param to makefile, fix INFO_DISABLED, add some constraints to the .sql, fix some -err's, EVSQL_PQ_ARBITRARY_TYPE_OID, and make read/write transactionless
Tero Marttila <terom@fixme.fi>
parents: 38
diff changeset
   196
    if ((err = -fuse_reply_err(req, 0)))
03017f5f0087 add MODE param to makefile, fix INFO_DISABLED, add some constraints to the .sql, fix some -err's, EVSQL_PQ_ARBITRARY_TYPE_OID, and make read/write transactionless
Tero Marttila <terom@fixme.fi>
parents: 38
diff changeset
   197
        EERROR(err, "fuse_reply_err");
36
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   198
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   199
error:
40
03017f5f0087 add MODE param to makefile, fix INFO_DISABLED, add some constraints to the .sql, fix some -err's, EVSQL_PQ_ARBITRARY_TYPE_OID, and make read/write transactionless
Tero Marttila <terom@fixme.fi>
parents: 38
diff changeset
   200
    if (err && (err = -fuse_reply_err(req, err)))
36
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   201
        EWARNING(err, "fuse_reply_err");
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   202
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   203
    // free
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   204
    evsql_result_free(res);
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   205
}
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   206
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   207
void dbfs_unlink (struct fuse_req *req, fuse_ino_t parent, const char *name) {
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   208
    struct dbfs *ctx = fuse_req_userdata(req);
41
6abda2fa4579 touch up the Makefile, define err_t as unsigned int in error.h, and add some preliminary interrupt support, although it will always deadlock due to a bug in libfuse
Tero Marttila <terom@fixme.fi>
parents: 40
diff changeset
   209
    struct evsql_query *query;
36
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   210
    int err;
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   211
    
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   212
    INFO("[dbfs.unlink %p] parent=%lu, name=%s", req, parent, name);
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   213
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   214
    const char *sql =
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   215
        "DELETE"
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   216
        " FROM file_tree"
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   217
        " WHERE parent = $1::int4 AND name = $2::varchar";
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   218
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   219
    static struct evsql_query_params params = EVSQL_PARAMS(EVSQL_FMT_BINARY) {
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   220
        EVSQL_PARAM ( UINT32 ),
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   221
        EVSQL_PARAM ( STRING ),
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   222
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   223
        EVSQL_PARAMS_END
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   224
    };
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   225
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   226
    // build params
41
6abda2fa4579 touch up the Makefile, define err_t as unsigned int in error.h, and add some preliminary interrupt support, although it will always deadlock due to a bug in libfuse
Tero Marttila <terom@fixme.fi>
parents: 40
diff changeset
   227
    if (0
36
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   228
        ||  evsql_param_uint32(&params, 0, parent)
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   229
        ||  evsql_param_string(&params, 1, name)
41
6abda2fa4579 touch up the Makefile, define err_t as unsigned int in error.h, and add some preliminary interrupt support, although it will always deadlock due to a bug in libfuse
Tero Marttila <terom@fixme.fi>
parents: 40
diff changeset
   230
    )
6abda2fa4579 touch up the Makefile, define err_t as unsigned int in error.h, and add some preliminary interrupt support, although it will always deadlock due to a bug in libfuse
Tero Marttila <terom@fixme.fi>
parents: 40
diff changeset
   231
        SERROR(err = EIO);
36
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   232
        
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   233
    // query
41
6abda2fa4579 touch up the Makefile, define err_t as unsigned int in error.h, and add some preliminary interrupt support, although it will always deadlock due to a bug in libfuse
Tero Marttila <terom@fixme.fi>
parents: 40
diff changeset
   234
    if ((query = evsql_query_params(ctx->db, NULL, sql, &params, dbfs_unlink_res, req)) == NULL)
6abda2fa4579 touch up the Makefile, define err_t as unsigned int in error.h, and add some preliminary interrupt support, although it will always deadlock due to a bug in libfuse
Tero Marttila <terom@fixme.fi>
parents: 40
diff changeset
   235
        SERROR(err = EIO);
36
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   236
41
6abda2fa4579 touch up the Makefile, define err_t as unsigned int in error.h, and add some preliminary interrupt support, although it will always deadlock due to a bug in libfuse
Tero Marttila <terom@fixme.fi>
parents: 40
diff changeset
   237
    // handle interrupts
6abda2fa4579 touch up the Makefile, define err_t as unsigned int in error.h, and add some preliminary interrupt support, although it will always deadlock due to a bug in libfuse
Tero Marttila <terom@fixme.fi>
parents: 40
diff changeset
   238
    fuse_req_interrupt_func(req, dbfs_interrupt_query, query);
36
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   239
    
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   240
    // wait
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   241
    return;
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   242
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   243
error:
40
03017f5f0087 add MODE param to makefile, fix INFO_DISABLED, add some constraints to the .sql, fix some -err's, EVSQL_PQ_ARBITRARY_TYPE_OID, and make read/write transactionless
Tero Marttila <terom@fixme.fi>
parents: 38
diff changeset
   244
    if ((err = -fuse_reply_err(req, err)))
36
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   245
        EWARNING(err, "fuse_reply_err");
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   246
}
37
c3880f3b4de8 update fuse_db.sql, just use dbfs_unlink for rmdir (no special handling)
Tero Marttila <terom@fixme.fi>
parents: 36
diff changeset
   247
38
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   248
void dbfs_link (struct fuse_req *req, fuse_ino_t ino, fuse_ino_t newparent, const char *newname) {
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   249
    struct dbfs *ctx = fuse_req_userdata(req);
41
6abda2fa4579 touch up the Makefile, define err_t as unsigned int in error.h, and add some preliminary interrupt support, although it will always deadlock due to a bug in libfuse
Tero Marttila <terom@fixme.fi>
parents: 40
diff changeset
   250
    struct evsql_query *query;
38
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   251
    int err;
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   252
    
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   253
    INFO("[dbfs.link %p] ino=%lu, newparent=%lu, newname=%s", req, ino, newparent, newname);
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   254
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   255
    const char *sql =
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   256
        "SELECT ino, type, mode, size, nlink FROM dbfs_link($1::int4, $2::int4, $3::varchar)";
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   257
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   258
    static struct evsql_query_params params = EVSQL_PARAMS(EVSQL_FMT_BINARY) {
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   259
        EVSQL_PARAM ( UINT32 ),
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   260
        EVSQL_PARAM ( UINT32 ),
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   261
        EVSQL_PARAM ( STRING ),
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   262
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   263
        EVSQL_PARAMS_END
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   264
    };
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   265
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   266
    // build params
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   267
    if (0
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   268
        ||  evsql_param_uint32(&params, 0, ino)
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   269
        ||  evsql_param_uint32(&params, 1, newparent)
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   270
        ||  evsql_param_string(&params, 2, newname)
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   271
    )
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   272
        SERROR(err = EIO);
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   273
        
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   274
    // query
41
6abda2fa4579 touch up the Makefile, define err_t as unsigned int in error.h, and add some preliminary interrupt support, although it will always deadlock due to a bug in libfuse
Tero Marttila <terom@fixme.fi>
parents: 40
diff changeset
   275
    if ((query = evsql_query_params(ctx->db, NULL, sql, &params, dbfs_entry_res, req)) == NULL)
38
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   276
        SERROR(err = EIO);
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   277
41
6abda2fa4579 touch up the Makefile, define err_t as unsigned int in error.h, and add some preliminary interrupt support, although it will always deadlock due to a bug in libfuse
Tero Marttila <terom@fixme.fi>
parents: 40
diff changeset
   278
    // handle interrupts
6abda2fa4579 touch up the Makefile, define err_t as unsigned int in error.h, and add some preliminary interrupt support, although it will always deadlock due to a bug in libfuse
Tero Marttila <terom@fixme.fi>
parents: 40
diff changeset
   279
    fuse_req_interrupt_func(req, dbfs_interrupt_query, query);
38
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   280
    
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   281
    // wait
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   282
    return;
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   283
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   284
error:
40
03017f5f0087 add MODE param to makefile, fix INFO_DISABLED, add some constraints to the .sql, fix some -err's, EVSQL_PQ_ARBITRARY_TYPE_OID, and make read/write transactionless
Tero Marttila <terom@fixme.fi>
parents: 38
diff changeset
   285
    if ((err = -fuse_reply_err(req, err)))
38
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   286
        EWARNING(err, "fuse_reply_err");   
1fd4da071575 rework/hack parent to be a FOREIGN KEY (add a dir_ino col), implement dbfs_link
Tero Marttila <terom@fixme.fi>
parents: 37
diff changeset
   287
}