1

     2

#include <string.h>

     3

     4

#include "dbfs.h"

     5

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

     6

     7

mode_t _dbfs_mode (const char *type) {

     8

    if (!strcmp(type, "DIR"))

     9

        return S_IFDIR;

    10

    11

    if (!strcmp(type, "REG"))

    12

        return S_IFREG;

    13

    14

    if (!strcmp(type, "LNK"))

    15

        return S_IFLNK;

    16

    17

    else {

    18

        WARNING("[dbfs] weird mode-type: %s", type);

    19

        return 0;

    20

    }

    21

}

    22

    24

    int err = 0;

    25

    26

    // check if it failed

    28

        NERROR(evsql_result_error(res));

    29

    30

    // not found?

    31

    if (evsql_result_rows(res) == 0 && evsql_result_affected(res) == 0)

    32

        SERROR(err = 1);

    33

    34

    // duplicate rows?

    35

    if (rows && evsql_result_rows(res) != rows)

    36

        ERROR("wrong number of rows returned");

    37

    38

    // correct number of columns

    39

    if (evsql_result_cols(res) != cols)

    40

        ERROR("wrong number of columns: %zu", evsql_result_cols(res));

    41

    42

    // good

    43

    return 0;

    44

    45

error:

    46

    if (!err)

    47

        err = -1;

    48

    49

    return err;

    50

}

    51

    53

    err_t err;

    54

    55

    // number of rows returned/affected

    56

    size_t nrows = evsql_result_rows(res) ? : evsql_result_affected(res);

    57

    58

    // did the query fail outright?

    60

        // dump error message

    61

        NXERROR(err = EIO, evsql_result_error(res));

    62

    63

    // SELECT/DELETE/UPDATE WHERE didn't match any rows -> ENOENT

    64

    if (nrows == 0)

    65

        XERROR(err = ENOENT, "no rows returned/affected");

    66

    67

    // duplicate rows where one expected?

    68

    if (rows && nrows != rows)

    69

        XERROR(err = EIO, "wrong number of rows: %zu -> %zu", rows, nrows);

    70

    71

    // correct number of columns

    72

    if (evsql_result_cols(res) != cols)

    73

        XERROR(err = EIO, "wrong number of columns: %zu -> %zu", cols, evsql_result_cols(res));

    74

    75

    // good

    76

    return 0;

    77

    78

error:

    79

    return err;

    80

}

    81

    83

    int err = 0;

    84

    85

    uint16_t mode;

    86

    uint32_t size = 0;  // NULL for non-REG inodes

    87

    uint64_t nlink = 0; // will be NULL for non-GROUP BY queries

    88

    const char *type;

    89

    90

    // extract the data

    91

    if ((0

    92

        ||  evsql_result_string(res, row, col_offset + 0, &type,       0 ) // inodes.type

    93

        ||  evsql_result_uint16(res, row, col_offset + 1, &mode,       0 ) // inodes.mode

    94

        ||  evsql_result_uint32(res, row, col_offset + 2, &size,       1 ) // size

    95

        ||  evsql_result_uint64(res, row, col_offset + 3, &nlink,      1 ) // count(*)

    96

    ) && (err = EIO))

    97

        ERROR("invalid db data");

    98

    99

    INFO("\tst_mode=S_IF%s | %ho, st_nlink=%llu, st_size=%llu", type, mode, (long long unsigned int) nlink, (long long unsigned int) size);

   100

   101

    // convert and store

   102

    st->st_mode = _dbfs_mode(type) | mode;

   103

    st->st_nlink = nlink;

   104

    st->st_size = size;

   105

   106

    // good

   107

    return 0;

   108

   109

error:

   110

    return err;

   111

}

   112

   113

   114