libatalk/cnid/cnid_update.c

   1 /*
   2  * $Id: cnid_update.c,v 1.12.2.2 2001-12-03 15:53:39 jmarcus Exp $
   3  */
   4
   5 #ifdef HAVE_CONFIG_H
   6 #include "config.h"
   7 #endif /* HAVE_CONFIG_H */
   8
   9 #ifdef CNID_DB
  10 #include <stdio.h>
  11 #include <string.h>
  12 #include <sys/param.h>
  13 #include <sys/stat.h>
  14 #include <errno.h>
  15 #include <syslog.h>
  16
  17 #include <db.h>
  18 #include <netatalk/endian.h>
  19 #include <atalk/adouble.h>
  20 #include <atalk/cnid.h>
  21
  22 #include "cnid_private.h"
  23
  24 /* cnid_update: takes the given cnid and updates the metadata.  To
  25  * handle the did/name data, there are a bunch of functions to get
  26  * and set the various fields. */
  27 int cnid_update(void *CNID, const cnid_t id, const struct stat *st,
  28                 const cnid_t did, const char *name, const int len
  29                 /*, const char *info, const int infolen*/)
  30 {
  31     CNID_private *db;
  32     DBT key, data, altdata;
  33     DB_TXN *tid;
  34     int rc;
  35
  36     if (!(db = CNID) || !id || !st || !name || (db->flags & CNIDFLAG_DB_RO)) {
  37         return -1;
  38     }
  39
  40     memset(&key, 0, sizeof(key));
  41     memset(&altdata, 0, sizeof(altdata));
  42
  43 retry:
  44     if ((rc = txn_begin(db->dbenv, NULL, &tid, 0))) {
  45         syslog(LOG_ERR, "cnid_update: Failed to begin transaction: %s",
  46                db_strerror(rc));
  47         return rc;
  48     }
  49
  50     /* Get the old info. */
  51     key.data = (cnid_t *)&id;
  52     key.size = sizeof(id);
  53     memset(&data, 0, sizeof(data));
  54     if ((rc = db->db_cnid->get(db->db_cnid, tid, &key, &data, DB_RMW))) {
  55         txn_abort(tid);
  56         switch (rc) {
  57         case DB_LOCK_DEADLOCK:
  58             goto retry;
  59         default:
  60             goto update_err;
  61         }
  62     }
  63
  64     /* Delete the old dev/ino mapping. */
  65     key.data = data.data;
  66     key.size = CNID_DEVINO_LEN;
  67     if ((rc = db->db_devino->del(db->db_devino, tid, &key, 0))) {
  68         switch (rc) {
  69         case DB_LOCK_DEADLOCK:
  70             txn_abort(tid);
  71             goto retry;
  72         case DB_NOTFOUND:
  73             break;
  74         default:
  75             txn_abort(tid);
  76             goto update_err;
  77         }
  78     }
  79
  80     /* Delete the old did/name mapping. */
  81     key.data = (char *) data.data + CNID_DEVINO_LEN;
  82     key.size = data.size - CNID_DEVINO_LEN;
  83     if ((rc = db->db_didname->del(db->db_didname, tid, &key, 0))) {
  84         switch (rc) {
  85         case DB_LOCK_DEADLOCK:
  86             txn_abort(tid);
  87             goto retry;
  88         case DB_NOTFOUND:
  89             break;
  90         default:
  91             txn_abort(tid);
  92             goto update_err;
  93         }
  94     }
  95
  96     /* Make a new entry. */
  97     data.data = make_cnid_data(st, did, name, len);
  98     data.size = CNID_HEADER_LEN + len + 1;
  99
 100     /* Update the old CNID with the new info. */
 101     key.data = (cnid_t *) &id;
 102     key.size = sizeof(id);
 103     if ((rc = db->db_cnid->put(db->db_cnid, tid, &key, &data, 0))) {
 104         txn_abort(tid);
 105         switch (rc) {
 106         case DB_LOCK_DEADLOCK:
 107             goto retry;
 108         default:
 109             goto update_err;
 110         }
 111     }
 112
 113     /* Put in a new dev/ino mapping. */
 114     key.data = data.data;
 115     key.size = CNID_DEVINO_LEN;
 116     altdata.data = (cnid_t *) &id;
 117     altdata.size = sizeof(id);
 118     if ((rc = db->db_devino->put(db->db_devino, tid, &key, &altdata, 0))) {
 119         txn_abort(tid);
 120         switch (rc) {
 121         case DB_LOCK_DEADLOCK:
 122             goto retry;
 123         default:
 124             goto update_err;
 125         }
 126     }
 127
 128     /* put in a new did/name mapping. */
 129     key.data = (char *) data.data + CNID_DEVINO_LEN;
 130     key.size = data.size - CNID_DEVINO_LEN;
 131     if ((rc = db->db_didname->put(db->db_didname, tid, &key, &altdata, 0))) {
 132         txn_abort(tid);
 133         switch (rc) {
 134         case DB_LOCK_DEADLOCK:
 135             goto retry;
 136         default:
 137             goto update_err;
 138         }
 139     }
 140
 141
 142     return txn_commit(tid, 0);
 143
 144 update_err:
 145     syslog(LOG_ERR, "cnid_update: Unable to update CNID %u: %s",
 146            ntohl(id), db_strerror(rc));
 147     return -1;
 148 }
 149 #endif /* CNID_DB */