/*
- * $Id: dbd_lookup.c,v 1.17 2009-12-09 15:37:32 franklahm Exp $
+ * $Id: dbd_lookup.c,v 1.18 2010-01-19 14:57:11 franklahm Exp $
*
* Copyright (C) Joerg Lenneis 2003
* Copyright (C) Frank Lahm 2009
rply->namelen = 0;
rply->cnid = 0;
+
+ LOG(log_maxdebug, logtype_cnid, "dbd_lookup(): START");
buf = pack_cnid_data(rqst);
type_didname = ntohl(type_didname);
}
+ LOG(log_maxdebug, logtype_cnid, "dbd_lookup(name:'%s', did:%u, dev/ino:0x%llx/0x%llx) {devino: %u, didname: %u}",
+ rqst->name, ntohl(rqst->did), (unsigned long long)rqst->dev, (unsigned long long)rqst->ino, devino, didname);
+
/* Have we found anything at all ? */
if (!devino && !didname) {
/* nothing found */
}
/* Check for type (file/dir) mismatch */
- if (devino && (type_devino != rqst->type)) {
- /* one is a dir one is a file, remove from db */
- if (! roflag) {
- rqst->cnid = id_devino;
- if (dbd_delete(dbd, rqst, rply, DBIF_CNID) < 0)
- return -1;
+ if ((devino && (type_devino != rqst->type)) || (didname && (type_didname != rqst->type))) {
+
+ if (devino && (type_devino != rqst->type)) {
+ /* one is a dir one is a file, remove from db */
+
+ LOG(log_debug, logtype_cnid, "dbd_lookup(name:'%s', did:%u, dev/ino:0x%llx/0x%llx): type mismatch for devino",
+ rqst->name, ntohl(rqst->did), (unsigned long long)rqst->dev, (unsigned long long)rqst->ino);
+
+ if (! roflag) {
+ rqst->cnid = id_devino;
+ rc = dbd_delete(dbd, rqst, rply, DBIF_CNID);
+ rc += dbd_delete(dbd, rqst, rply, DBIF_IDX_DEVINO);
+ rc += dbd_delete(dbd, rqst, rply, DBIF_IDX_DIDNAME);
+ if (rc < 0) {
+ LOG(log_error, logtype_cnid, "dbd_lookup(name:'%s', did:%u, dev/ino:0x%llx/0x%llx): error deleting type mismatch for devino",
+ rqst->name, ntohl(rqst->did), (unsigned long long)rqst->dev, (unsigned long long)rqst->ino);
+ return -1;
+ }
+ }
}
- rply->result = CNID_DBD_RES_NOTFOUND;
- return 1;
- } else if (didname && (type_didname != rqst->type)) {
- /* same: one is a dir one is a file, remove from db */
- if (! roflag) {
- rqst->cnid = id_didname;
- if (dbd_delete(dbd, rqst, rply, DBIF_CNID) < 0)
- return -1;
+
+ if (didname && (type_didname != rqst->type)) {
+ /* same: one is a dir one is a file, remove from db */
+
+ LOG(log_debug, logtype_cnid, "dbd_lookup(name:'%s', did:%u, dev/ino:0x%llx/0x%llx): type mismatch for didname",
+ rqst->name, ntohl(rqst->did), (unsigned long long)rqst->dev, (unsigned long long)rqst->ino);
+
+ if (! roflag) {
+ rqst->cnid = id_didname;
+ rc = dbd_delete(dbd, rqst, rply, DBIF_CNID);
+ rc += dbd_delete(dbd, rqst, rply, DBIF_IDX_DEVINO);
+ rc += dbd_delete(dbd, rqst, rply, DBIF_IDX_DIDNAME);
+ if (rc < 0) {
+ LOG(log_error, logtype_cnid, "dbd_lookup(name:'%s', did:%u, dev/ino:0x%llx/0x%llx): error deleting type mismatch for didname",
+ rqst->name, ntohl(rqst->did), (unsigned long long)rqst->dev, (unsigned long long)rqst->ino);
+ return -1;
+ }
+ }
}
+
rply->result = CNID_DBD_RES_NOTFOUND;
return 1;
}
/*
- * $Id: dbif.c,v 1.19 2009-12-21 06:41:09 franklahm Exp $
+ * $Id: dbif.c,v 1.20 2010-01-19 14:57:11 franklahm Exp $
*
* Copyright (C) Joerg Lenneis 2003
* Copyright (C) Frank Lahm 2009
static char *old_dbfiles[] = {"cnid.db", NULL};
/* --------------- */
-static int upgrade_required(void)
+static int upgrade_required(const DBD *dbd)
{
int i;
+ int cwd = -1;
+ int ret = 0;
int found = 0;
struct stat st;
+ if ( ! dbd->db_filename)
+ /* in memory db */
+ return 0;
+
+ /* Remember cwd */
+ if ((cwd = open(".", O_RDONLY)) < 0) {
+ LOG(log_error, logtype_cnid, "error opening cwd: %s", strerror(errno));
+ return -1;
+ }
+
+ /* chdir to db_envhome */
+ if ((chdir(dbd->db_envhome)) != 0) {
+ LOG(log_error, logtype_cnid, "error chdiring to db_env '%s': %s", dbd->db_envhome, strerror(errno));
+ ret = -1;
+ goto exit;
+ }
+
for (i = 0; old_dbfiles[i] != NULL; i++) {
if ( !(stat(old_dbfiles[i], &st) < 0) ) {
found++;
found++;
}
}
- return found;
+
+exit:
+ if (cwd != -1) {
+ if ((fchdir(cwd)) != 0) {
+ LOG(log_error, logtype_cnid, "error chdiring back: %s", strerror(errno));
+ ret = -1;
+ }
+ close(cwd);
+ }
+ return (ret < 0 ? ret : found);
+}
+
+/* --------------- */
+static int dbif_openlog(DBD *dbd)
+{
+ int ret = 0;
+ int cwd = -1;
+
+ if ( ! dbd->db_filename)
+ /* in memory db */
+ return 0;
+
+ /* Remember cwd */
+ if ((cwd = open(".", O_RDONLY)) < 0) {
+ LOG(log_error, logtype_cnid, "error opening cwd: %s", strerror(errno));
+ return -1;
+ }
+
+ /* chdir to db_envhome */
+ if ((chdir(dbd->db_envhome)) != 0) {
+ LOG(log_error, logtype_cnid, "error chdiring to db_env '%s': %s", dbd->db_envhome, strerror(errno));
+ ret = -1;
+ goto exit;
+ }
+
+ if ((dbd->db_errlog = fopen(DB_ERRLOGFILE, "a")) == NULL)
+ LOG(log_warning, logtype_cnid, "error creating/opening DB errlogfile: %s", strerror(errno));
+
+ if (dbd->db_errlog != NULL) {
+ dbd->db_env->set_errfile(dbd->db_env, dbd->db_errlog);
+ dbd->db_env->set_msgfile(dbd->db_env, dbd->db_errlog);
+ }
+
+exit:
+ if (cwd != -1) {
+ if ((fchdir(cwd)) != 0) {
+ LOG(log_error, logtype_cnid, "error chdiring back: %s", strerror(errno));
+ ret = -1;
+ }
+ close(cwd);
+ }
+ return ret;
+}
+
+/* --------------- */
+static int dbif_logautorem(DBD *dbd)
+{
+ int ret = 0;
+ int cwd = -1;
+ char **logfiles = NULL;
+ char **file;
+
+ if ( ! dbd->db_filename)
+ /* in memory db */
+ return 0;
+
+ /* Remember cwd */
+ if ((cwd = open(".", O_RDONLY)) < 0) {
+ LOG(log_error, logtype_cnid, "error opening cwd: %s", strerror(errno));
+ return -1;
+ }
+
+ /* chdir to db_envhome */
+ if ((chdir(dbd->db_envhome)) != 0) {
+ LOG(log_error, logtype_cnid, "error chdiring to db_env '%s': %s", dbd->db_envhome, strerror(errno));
+ ret = -1;
+ goto exit;
+ }
+
+ if ((ret = dbd->db_env->log_archive(dbd->db_env, &logfiles, 0)) != 0) {
+ LOG(log_error, logtype_cnid, "error getting list of stale logfiles: %s",
+ db_strerror(ret));
+ dbd->db_env->close(dbd->db_env, 0);
+ dbd->db_env = NULL;
+ ret = -1;
+ goto exit;
+ }
+
+ if (logfiles != NULL) {
+ for (file = logfiles; *file != NULL; file++) {
+ if (unlink(*file) < 0)
+ LOG(log_warning, logtype_cnid, "Error removing stale logfile %s: %s", *file, strerror(errno));
+ }
+ free(logfiles);
+ }
+
+exit:
+ if (cwd != -1) {
+ if ((fchdir(cwd)) != 0) {
+ LOG(log_error, logtype_cnid, "error chdiring back: %s", strerror(errno));
+ ret = -1;
+ }
+ close(cwd);
+ }
+ return ret;
}
/* --------------- */
}
if ((rc = stat(dbd->db_table[DBIF_CNID].name, &st)) < 0) {
- LOG(log_error, logtype_cnid, "error stating database %s: %s", dbd->db_table[DBIF_CNID].name, db_strerror(rc));
+ LOG(log_error, logtype_cnid, "error stating database %s: %s", dbd->db_table[DBIF_CNID].name, db_strerror(errno));
return -1;
}
memset(buffer, 0, size);
*/
int dbif_env_open(DBD *dbd, struct db_param *dbp, uint32_t dbenv_oflags)
{
- int ret, cwd;
- char **logfiles = NULL;
- char **file;
-
- /* Remember cwd */
- if ((cwd = open(".", O_RDONLY)) < 0) {
- LOG(log_error, logtype_cnid, "error opening cwd: %s", strerror(errno));
- return -1;
- }
-
- /* chdir to db_envhome. makes it easier checking for old db files and creating db_errlog file */
- if ((chdir(dbd->db_envhome)) != 0) {
- LOG(log_error, logtype_cnid, "error chdiring to db_env '%s': %s", dbd->db_envhome, strerror(errno));
- return -1;
- }
+ int ret;
/* Refuse to do anything if this is an old version of the CNID database */
- if (upgrade_required()) {
+ if (upgrade_required(dbd)) {
LOG(log_error, logtype_cnid, "Found version 1 of the CNID database. Please upgrade to version 2");
return -1;
}
- if ((dbd->db_errlog = fopen(DB_ERRLOGFILE, "a")) == NULL)
- LOG(log_warning, logtype_cnid, "error creating/opening DB errlogfile: %s", strerror(errno));
-
- if ((fchdir(cwd)) != 0) {
- LOG(log_error, logtype_cnid, "error chdiring back: %s", strerror(errno));
- return -1;
- }
-
if ((ret = db_env_create(&dbd->db_env, 0))) {
LOG(log_error, logtype_cnid, "error creating DB environment: %s",
db_strerror(ret));
return -1;
}
- if (dbd->db_errlog != NULL) {
- dbd->db_env->set_errfile(dbd->db_env, dbd->db_errlog);
- dbd->db_env->set_msgfile(dbd->db_env, dbd->db_errlog);
- }
+ if ((dbif_openlog(dbd)) != 0)
+ return -1;
if (dbenv_oflags & DB_RECOVER) {
+
+ LOG(log_debug, logtype_cnid, "Running recovery");
+
dbd->db_env->set_verbose(dbd->db_env, DB_VERB_RECOVERY, 1);
/* Open the database for recovery using DB_PRIVATE option which is faster */
if ((ret = dbd->db_env->open(dbd->db_env, dbd->db_envhome, dbenv_oflags | DB_PRIVATE, 0))) {
dbd->db_env = NULL;
return -1;
}
+ dbd->db_errlog = NULL;
if ((ret = db_env_create(&dbd->db_env, 0))) {
LOG(log_error, logtype_cnid, "error creating DB environment after recovery: %s",
dbd->db_env = NULL;
return -1;
}
+
+ if ((dbif_openlog(dbd)) != 0)
+ return -1;
+
+ LOG(log_debug, logtype_cnid, "Finished recovery.");
}
if ((ret = dbd->db_env->set_cachesize(dbd->db_env, 0, 1024 * dbp->cachesize, 0))) {
return -1;
}
- if (dbd->db_errlog != NULL) {
- dbd->db_env->set_errfile(dbd->db_env, dbd->db_errlog);
- dbd->db_env->set_msgfile(dbd->db_env, dbd->db_errlog);
- }
if ((ret = dbd->db_env->open(dbd->db_env, dbd->db_envhome, dbenv_oflags, 0))) {
LOG(log_error, logtype_cnid, "error opening DB environment after recovery: %s",
db_strerror(ret));
}
if (dbp->logfile_autoremove) {
- if (dbd->db_env->log_archive(dbd->db_env, &logfiles, 0)) {
- LOG(log_error, logtype_cnid, "error getting list of stale logfiles: %s",
- db_strerror(ret));
- dbd->db_env->close(dbd->db_env, 0);
- dbd->db_env = NULL;
+ if ((dbif_logautorem(dbd)) != 0)
return -1;
- }
- if (logfiles != NULL) {
- /* Remember cwd */
- if ((cwd = open(".", O_RDONLY)) < 0) {
- LOG(log_error, logtype_cnid, "error opening cwd: %s", strerror(errno));
- goto logfiles_done;
- }
- /* chdir to db_envhome */
- if ((chdir(dbd->db_envhome)) != 0) {
- LOG(log_error, logtype_cnid, "error chdiring to db_env '%s': %s", dbd->db_envhome, strerror(errno));
- goto logfiles_done;
- }
-
- for (file = logfiles; *file != NULL; file++) {
- if (unlink(*file) < 0)
- LOG(log_warning, logtype_cnid, "Error removing stale logfile %s: %s", *file, strerror(errno));
- }
-
- /* chdir back */
- if ((fchdir(cwd)) != 0) {
- LOG(log_error, logtype_cnid, "error chdiring back: %s", strerror(errno));
- return -1;
- }
-
- logfiles_done:
- free(logfiles);
- }
#if DB_VERSION_MAJOR > 4 || (DB_VERSION_MAJOR == 4 && DB_VERSION_MINOR >= 7)
if ((ret = dbd->db_env->log_set_config(dbd->db_env, DB_LOG_AUTO_REMOVE, 1))) {
LOG(log_error, logtype_cnid, "Cant open database");
return -1;
}
- if (dbd->db_errlog != NULL)
- dbd->db_table[i].db->set_errfile(dbd->db_table[i].db, dbd->db_errlog);
if (reindex && i > 0) {
LOG(log_info, logtype_cnid, "Truncating CNID index.");
*/
int dbif_prep_upgrade(const char *path)
{
- int cwd, ret;
+ int ret;
DBD *dbd;
LOG(log_debug, logtype_cnid, "Reopening BerkeleyDB environment");
if (NULL == (dbd = dbif_init(path, "cnid2.db")))
return -1;
- /* Remember cwd */
- if ((cwd = open(".", O_RDONLY)) < 0) {
- LOG(log_error, logtype_cnid, "error opening cwd: %s", strerror(errno));
- return -1;
- }
-
- /* chdir to db_envhome. makes it easier checking for old db files and creating db_errlog file */
- if ((chdir(dbd->db_envhome)) != 0) {
- LOG(log_error, logtype_cnid, "error chdiring to db_env '%s': %s", dbd->db_envhome, strerror(errno));
- return -1;
- }
-
- if ((dbd->db_errlog = fopen(DB_ERRLOGFILE, "a")) == NULL)
- LOG(log_warning, logtype_cnid, "error creating/opening DB errlogfile: %s", strerror(errno));
-
- if ((fchdir(cwd)) != 0) {
- LOG(log_error, logtype_cnid, "error chdiring back: %s", strerror(errno));
- return -1;
- }
-
/* Get db_env handle */
if ((ret = db_env_create(&dbd->db_env, 0))) {
LOG(log_error, logtype_cnid, "error creating DB environment: %s", db_strerror(ret));
return -1;
}
- /* Set logfile */
- if (dbd->db_errlog != NULL) {
- dbd->db_env->set_errfile(dbd->db_env, dbd->db_errlog);
- dbd->db_env->set_msgfile(dbd->db_env, dbd->db_errlog);
- dbd->db_env->set_verbose(dbd->db_env, DB_VERB_RECOVERY, 1);
- }
+ if ((dbif_openlog(dbd)) != 0)
+ return -1;
/* Open environment with recovery */
if ((ret = dbd->db_env->open(dbd->db_env,
return 0;
if (ret) {
LOG(log_error, logtype_cnid, "error retrieving value from %s: %s",
- dbd->db_table[dbi].name, db_strerror(errno));
+ dbd->db_table[dbi].name, db_strerror(ret));
return -1;
} else
return 1;
}
if (ret) {
LOG(log_error, logtype_cnid, "error retrieving value from %s: %s",
- dbd->db_table[dbi].name, db_strerror(errno));
+ dbd->db_table[dbi].name, db_strerror(ret));
return -1;
} else
return 1;
int ret;
if (dbif_txn_begin(dbd) < 0) {
- LOG(log_error, logtype_cnid, "error setting key/value in %s: %s",
- dbd->db_table[dbi].name, db_strerror(errno));
+ LOG(log_error, logtype_cnid, "error setting key/value in %s", dbd->db_table[dbi].name);
return -1;
}
key,
val,
flags);
+
if (ret) {
if ((flags & DB_NOOVERWRITE) && ret == DB_KEYEXIST) {
return 1;
} else {
LOG(log_error, logtype_cnid, "error setting key/value in %s: %s",
- dbd->db_table[dbi].name, db_strerror(errno));
+ dbd->db_table[dbi].name, db_strerror(ret));
return -1;
}
} else
}
if (dbif_txn_begin(dbd) < 0) {
- LOG(log_error, logtype_cnid, "error deleting key/value from %s: %s",
- dbd->db_table[dbi].name, db_strerror(errno));
+ LOG(log_error, logtype_cnid, "error deleting key/value from %s", dbd->db_table[dbi].name);
return -1;
}
return 0;
if (ret) {
LOG(log_error, logtype_cnid, "error deleting key/value from %s: %s",
- dbd->db_table[dbi].name, db_strerror(errno));
+ dbd->db_table[dbi].name, db_strerror(ret));
return -1;
} else
return 1;
ret = dbd->db_env->txn_begin(dbd->db_env, NULL, &dbd->db_txn, 0);
if (ret) {
- LOG(log_error, logtype_cnid, "error starting transaction: %s", db_strerror(errno));
+ LOG(log_error, logtype_cnid, "error starting transaction: %s", db_strerror(ret));
return -1;
} else
return 0;
dbd->db_txn = NULL;
if (ret) {
- LOG(log_error, logtype_cnid, "error committing transaction: %s", db_strerror(errno));
+ LOG(log_error, logtype_cnid, "error committing transaction: %s", db_strerror(ret));
return -1;
} else
return 1;
dbd->db_txn = NULL;
if (ret) {
- LOG(log_error, logtype_cnid, "error aborting transaction: %s", db_strerror(errno));
+ LOG(log_error, logtype_cnid, "error aborting transaction: %s", db_strerror(ret));
return -1;
} else
return 0;
int ret;
ret = dbd->db_env->txn_checkpoint(dbd->db_env, kbyte, min, flags);
if (ret) {
- LOG(log_error, logtype_cnid, "error checkpointing transaction susystem: %s", db_strerror(errno));
+ LOG(log_error, logtype_cnid, "error checkpointing transaction susystem: %s", db_strerror(ret));
return -1;
} else
return 0;
ret = db->stat(db, NULL, &sp, 0);
if (ret) {
- LOG(log_error, logtype_cnid, "error getting stat infotmation on database: %s", db_strerror(errno));
+ LOG(log_error, logtype_cnid, "error getting stat infotmation on database: %s", db_strerror(ret));
return -1;
}
rc = db->cursor(db, NULL, &cur, 0);
if (rc) {
- LOG(log_error, logtype_cnid, "Couldn't create cursor: %s", db_strerror(errno));
+ LOG(log_error, logtype_cnid, "Couldn't create cursor: %s", db_strerror(rc));
return -1;
}
}
if (rc != DB_NOTFOUND) {
- LOG(log_error, logtype_cnid, "Error iterating over btree: %s", db_strerror(errno));
+ LOG(log_error, logtype_cnid, "Error iterating over btree: %s", db_strerror(rc));
return -1;
}
rc = cur->c_close(cur);
if (rc) {
- LOG(log_error, logtype_cnid, "Couldn't close cursor: %s", db_strerror(errno));
+ LOG(log_error, logtype_cnid, "Couldn't close cursor: %s", db_strerror(rc));
return -1;
}
printf("%u CNIDs in database. Max CNID: %u.\n", count, max);
db = dbd->db_table[DBIF_IDX_DEVINO].db;
rc = db->cursor(db, NULL, &cur, 0);
if (rc) {
- LOG(log_error, logtype_cnid, "Couldn't create cursor: %s", db_strerror(errno));
+ LOG(log_error, logtype_cnid, "Couldn't create cursor: %s", db_strerror(rc));
return -1;
}
rc = cur->c_get(cur, &key, &data, DB_NEXT);
}
if (rc != DB_NOTFOUND) {
- LOG(log_error, logtype_cnid, "Error iterating over btree: %s", db_strerror(errno));
+ LOG(log_error, logtype_cnid, "Error iterating over btree: %s", db_strerror(rc));
return -1;
}
rc = cur->c_close(cur);
if (rc) {
- LOG(log_error, logtype_cnid, "Couldn't close cursor: %s", db_strerror(errno));
+ LOG(log_error, logtype_cnid, "Couldn't close cursor: %s", db_strerror(rc));
return -1;
}
printf("%u items\n", count);
db = dbd->db_table[DBIF_IDX_DIDNAME].db;
rc = db->cursor(db, NULL, &cur, 0);
if (rc) {
- LOG(log_error, logtype_cnid, "Couldn't create cursor: %s", db_strerror(errno));
+ LOG(log_error, logtype_cnid, "Couldn't create cursor: %s", db_strerror(rc));
return -1;
}
rc = cur->c_get(cur, &key, &data, DB_NEXT);
}
if (rc != DB_NOTFOUND) {
- LOG(log_error, logtype_cnid, "Error iterating over btree: %s", db_strerror(errno));
+ LOG(log_error, logtype_cnid, "Error iterating over btree: %s", db_strerror(rc));
return -1;
}
rc = cur->c_close(cur);
if (rc) {
- LOG(log_error, logtype_cnid, "Couldn't close cursor: %s", db_strerror(errno));
+ LOG(log_error, logtype_cnid, "Couldn't close cursor: %s", db_strerror(rc));
return -1;
}
printf("%u items\n", count);
/* An dbif_del will have closed our cursor too */
if ( ! dbd->db_cur ) {
- if (db->cursor(db, NULL, &dbd->db_cur, 0) != 0) {
- LOG(log_error, logtype_cnid, "Couldn't create cursor: %s", db_strerror(errno));
+ if ((rc = db->cursor(db, NULL, &dbd->db_cur, 0)) != 0) {
+ LOG(log_error, logtype_cnid, "Couldn't create cursor: %s", db_strerror(rc));
return -1;
}
flag = DB_SET_RANGE; /* This will seek to next cnid after the one just deleted */
}
if (rc != DB_NOTFOUND) {
- LOG(log_error, logtype_cnid, "Error iterating over btree: %s", db_strerror(errno));
+ LOG(log_error, logtype_cnid, "Error iterating over btree: %s", db_strerror(rc));
dbd->db_cur->close(dbd->db_cur);
dbd->db_cur = NULL;
return -1;