src/dbfs/link.c
author Tero Marttila <terom@fixme.fi>
Sat, 29 Nov 2008 01:12:00 +0200
branchnew-evsql
changeset 48 8b019d191353
parent 41 6abda2fa4579
child 49 bb2ff0d2d343
permissions -rw-r--r--
update dbfs code to work with 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);
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
    16
    int err = 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
    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;
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
    19
    
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
    20
    // check the results
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
    21
    if ((err = _dbfs_check_res(res, 1, 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
    22
        SERROR(err = (err ==  1 ? ENOENT : 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
    23
    
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
    24
    // get the data
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
    25
    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
    26
        ||  evsql_result_uint32(res, 0, 0, &ino,        0 ) // 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
    27
    )
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
    28
        EERROR(err = EIO, "invalid db data");
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
    29
        
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
    30
    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
    31
    
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
    32
    // stat 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
    33
    if ((err = _dbfs_stat_info(&e.attr, res, 0, 1)))
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
    34
        goto error;
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
    35
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
    36
    // 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
    37
    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
    38
    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
    39
    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
    40
        
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
    41
    // 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
    42
    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
    43
        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
    44
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
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
    46
    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
    47
        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
    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
    // free
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
    50
    evsql_result_free(res);
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
}
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
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
    54
    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
    55
    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
    56
    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
    57
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
    58
    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
    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
    // 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
    61
    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
    62
        "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
    63
        " 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
    64
        " 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
    65
        " 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
    66
    
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
    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
    68
        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
    69
        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
    70
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
        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
    72
    };
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
    
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
    // 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
    75
    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
    76
        ||  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
    77
        ||  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
    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
        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
    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
    // 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
    82
    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
    83
        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
    84
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
    85
    // 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
    86
    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
    87
    
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
    // 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
    89
    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
    90
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
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
    92
    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
    93
        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
    94
}
32
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
    95
48
8b019d191353 update dbfs code to work with new evsql
Tero Marttila <terom@fixme.fi>
parents: 41
diff changeset
    96
void _dbfs_readlink_res (struct evsql_result *res, void *arg) {
32
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
    97
    struct fuse_req *req = arg;
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
    98
    int err = 0;
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
    99
    
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   100
    uint32_t ino;
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   101
    const char *type, *link;
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   102
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   103
    // check the results
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   104
    if ((err = _dbfs_check_res(res, 1, 3)))
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   105
        SERROR(err = (err ==  1 ? ENOENT : EIO));
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   106
        
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   107
    // get our data
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   108
    if (0
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   109
        ||  evsql_result_uint32(res, 0, 0, &ino,        0 ) // inodes.ino
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   110
        ||  evsql_result_string(res, 0, 1, &type,       0 ) // inodes.type
33
c71f3053c714 working symlink
Tero Marttila <terom@fixme.fi>
parents: 32
diff changeset
   111
        ||  evsql_result_string(res, 0, 2, &link,       1 ) // inodes.link_path
32
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   112
    )
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   113
        EERROR(err = EIO, "invalid db data");
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   114
    
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   115
    // is it a symlink?
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   116
    if (_dbfs_mode(type) != S_IFLNK)
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   117
        EERROR(err = EINVAL, "wrong type: %s", type);
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   118
    
36
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   119
    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
   120
    
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   121
    // 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
   122
    if ((err = -fuse_reply_readlink(req, link)))
32
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   123
        EERROR(err, "fuse_reply_readlink");
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   124
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   125
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
   126
    if (err && (err = -fuse_reply_err(req, err)))
32
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   127
        EWARNING(err, "fuse_reply_err");
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   128
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   129
    // free
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   130
    evsql_result_free(res);
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   131
}
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   132
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   133
void dbfs_readlink (struct fuse_req *req, fuse_ino_t ino) {
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   134
    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
   135
    struct evsql_query *query;
32
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   136
    int err;
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   137
    
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   138
    INFO("[dbfs.readlink %p] ino=%lu", req, ino);
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   139
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   140
    const char *sql =
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   141
        "SELECT"
33
c71f3053c714 working symlink
Tero Marttila <terom@fixme.fi>
parents: 32
diff changeset
   142
        " inodes.ino, inodes.type, inodes.link_path"
32
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   143
        " FROM inodes"
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   144
        " WHERE inodes.ino = $1::int4";
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   145
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   146
    static struct evsql_query_params params = EVSQL_PARAMS(EVSQL_FMT_BINARY) {
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   147
        EVSQL_PARAM ( UINT32 ),
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   148
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   149
        EVSQL_PARAMS_END
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   150
    };
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   151
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   152
    // build params
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   153
    if (0
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   154
        ||  evsql_param_uint32(&params, 0, ino)
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   155
    )
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   156
        SERROR(err = EIO);
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   157
        
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   158
    // 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
   159
    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
   160
        SERROR(err = EIO);
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   161
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
   162
    // 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
   163
    fuse_req_interrupt_func(req, dbfs_interrupt_query, query);
32
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   164
    
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   165
    // wait
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   166
    return;
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   167
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   168
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
   169
    if ((err = -fuse_reply_err(req, err)))
32
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   170
        EWARNING(err, "fuse_reply_err");
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   171
90e14e0df133 working readlink
Tero Marttila <terom@fixme.fi>
parents:
diff changeset
   172
}
33
c71f3053c714 working symlink
Tero Marttila <terom@fixme.fi>
parents: 32
diff changeset
   173
36
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   174
#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
   175
48
8b019d191353 update dbfs code to work with new evsql
Tero Marttila <terom@fixme.fi>
parents: 41
diff changeset
   176
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
   177
    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
   178
    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
   179
    
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   180
    // 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
   181
    // 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
   182
    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
   183
        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
   184
        
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   185
    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
   186
    
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   187
    // 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
   188
    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
   189
        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
   190
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   191
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
   192
    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
   193
        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
   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
    // free
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   196
    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
   197
}
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
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
   200
    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
   201
    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
   202
    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
   203
    
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   204
    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
   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
    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
   207
        "DELETE"
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   208
        " 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
   209
        " 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
   210
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   211
    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
   212
        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
   213
        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
   214
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   215
        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
   216
    };
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   217
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   218
    // 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
   219
    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
   220
        ||  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
   221
        ||  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
   222
    )
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
   223
        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
   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
    // 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
   226
    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
   227
        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
   228
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
   229
    // 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
   230
    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
   231
    
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   232
    // wait
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   233
    return;
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   234
56427f22e969 tweak debug/info output, implement dbfs_unlink with slightly improved error macros handling
Tero Marttila <terom@fixme.fi>
parents: 35
diff changeset
   235
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
   236
    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
   237
        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
   238
}
37
c3880f3b4de8 update fuse_db.sql, just use dbfs_unlink for rmdir (no special handling)
Tero Marttila <terom@fixme.fi>
parents: 36
diff changeset
   239
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
   240
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
   241
    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
   242
    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
   243
    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
   244
    
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
   245
    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
   246
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
   247
    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
   248
        "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
   249
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
   250
    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
   251
        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
   252
        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
   253
        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
   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
        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
   256
    };
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
    // 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
   259
    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
   260
        ||  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
   261
        ||  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
   262
        ||  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
   263
    )
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
        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
   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
    // 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
   267
    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
   268
        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
   269
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
   270
    // 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
   271
    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
   272
    
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
    // 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
   274
    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
   275
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
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
   277
    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
   278
        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
   279
}