#include "db_config.h"
#include "db_int.h"
#include "dbinc/db_page.h"
#include "dbinc/fop.h"
#include "dbinc/btree.h"
#include "dbinc/hash.h"
#include "dbinc/lock.h"
#include "dbinc/mp.h"
#include "dbinc/txn.h"
static int __db_dbtxn_remove __P((DB *, DB_TXN *, const char *, const char *));
static int __db_subdb_remove __P((DB *, DB_TXN *, const char *, const char *));
int
__env_dbremove_pp(dbenv, txn, name, subdb, flags)
DB_ENV *dbenv;
DB_TXN *txn;
const char *name, *subdb;
u_int32_t flags;
{
DB *dbp;
DB_THREAD_INFO *ip;
int handle_check, ret, t_ret, txn_local;
dbp = NULL;
txn_local = 0;
PANIC_CHECK(dbenv);
ENV_ILLEGAL_BEFORE_OPEN(dbenv, "DB_ENV->dbremove");
if ((ret = __db_fchk(dbenv, "DB->remove", flags, DB_AUTO_COMMIT)) != 0)
return (ret);
ENV_ENTER(dbenv, ip);
handle_check = IS_ENV_REPLICATED(dbenv);
if (handle_check && (ret = __env_rep_enter(dbenv, 1)) != 0) {
handle_check = 0;
goto err;
}
if (IS_ENV_AUTO_COMMIT(dbenv, txn, flags)) {
if ((ret = __db_txn_auto_init(dbenv, &txn)) != 0)
goto err;
txn_local = 1;
} else
if (txn != NULL && !TXN_ON(dbenv) &&
(!CDB_LOCKING(dbenv) || !F_ISSET(txn, TXN_CDSGROUP))) {
ret = __db_not_txn_env(dbenv);
goto err;
}
LF_CLR(DB_AUTO_COMMIT);
if ((ret = __db_create_internal(&dbp, dbenv, 0)) != 0)
goto err;
ret = __db_remove_int(dbp, txn, name, subdb, flags);
if (txn_local) {
LOCK_INIT(dbp->handle_lock);
dbp->locker = NULL;
} else if (txn != NULL) {
dbp->locker = NULL;
}
err: if (txn_local && (t_ret =
__db_txn_auto_resolve(dbenv, txn, 0, ret)) != 0 && ret == 0)
ret = t_ret;
if (txn_local || txn == NULL) {
if (dbp != NULL &&
(t_ret = __db_close(dbp, NULL, DB_NOSYNC)) != 0 && ret == 0)
ret = t_ret;
} else {
if (dbp != NULL && (t_ret =
__txn_closeevent(dbenv, txn, dbp)) != 0 && ret == 0)
ret = t_ret;
}
if (handle_check && (t_ret = __env_db_rep_exit(dbenv)) != 0 && ret == 0)
ret = t_ret;
ENV_LEAVE(dbenv, ip);
return (ret);
}
int
__db_remove_pp(dbp, name, subdb, flags)
DB *dbp;
const char *name, *subdb;
u_int32_t flags;
{
DB_ENV *dbenv;
DB_THREAD_INFO *ip;
int handle_check, ret, t_ret;
dbenv = dbp->dbenv;
PANIC_CHECK(dbenv);
if (F_ISSET(dbp, DB_AM_OPEN_CALLED)) {
ret = __db_mi_open(dbenv, "DB->remove", 1);
return (ret);
}
if ((ret = __db_fchk(dbenv, "DB->remove", flags, 0)) != 0)
return (ret);
if ((ret = __db_check_txn(dbp, NULL, DB_LOCK_INVALIDID, 0)) != 0)
return (ret);
ENV_ENTER(dbenv, ip);
handle_check = IS_ENV_REPLICATED(dbenv);
if (handle_check && (ret = __db_rep_enter(dbp, 1, 1, 0)) != 0) {
handle_check = 0;
goto err;
}
ret = __db_remove(dbp, NULL, name, subdb, flags);
if (handle_check && (t_ret = __env_db_rep_exit(dbenv)) != 0 && ret == 0)
ret = t_ret;
err: ENV_LEAVE(dbenv, ip);
return (ret);
}
int
__db_remove(dbp, txn, name, subdb, flags)
DB *dbp;
DB_TXN *txn;
const char *name, *subdb;
u_int32_t flags;
{
int ret, t_ret;
ret = __db_remove_int(dbp, txn, name, subdb, flags);
if (txn == NULL) {
if ((t_ret = __db_close(dbp, txn, DB_NOSYNC)) != 0 && ret == 0)
ret = t_ret;
} else {
if ((t_ret =
__txn_closeevent(dbp->dbenv, txn, dbp)) != 0 && ret == 0)
ret = t_ret;
}
return (ret);
}
int
__db_remove_int(dbp, txn, name, subdb, flags)
DB *dbp;
DB_TXN *txn;
const char *name, *subdb;
u_int32_t flags;
{
DB_ENV *dbenv;
int ret;
char *real_name, *tmpname;
dbenv = dbp->dbenv;
real_name = tmpname = NULL;
if (name == NULL && subdb == NULL) {
__db_errx(dbenv, "Remove on temporary files invalid");
ret = EINVAL;
goto err;
}
if (name == NULL) {
MAKE_INMEM(dbp);
real_name = (char *)subdb;
} else if (subdb != NULL) {
ret = __db_subdb_remove(dbp, txn, name, subdb);
goto err;
}
if (IS_REAL_TXN(txn)) {
ret = __db_dbtxn_remove(dbp, txn, name, subdb);
goto err;
}
if (!F_ISSET(dbp, DB_AM_INMEM) && (ret =
__db_appname(dbenv, DB_APP_DATA, name, 0, NULL, &real_name)) != 0)
goto err;
if (!F_ISSET(dbp, DB_AM_INMEM) && LF_ISSET(DB_FORCE) &&
(ret = __db_backup_name(dbenv, real_name, NULL, &tmpname)) == 0)
(void)__os_unlink(dbenv, tmpname);
if ((ret = __fop_remove_setup(dbp, NULL, real_name, 0)) != 0)
goto err;
if (dbp->db_am_remove != NULL &&
(ret = dbp->db_am_remove(dbp, NULL, name, subdb)) != 0)
goto err;
ret = F_ISSET(dbp, DB_AM_INMEM) ?
__db_inmem_remove(dbp, NULL, real_name) :
__fop_remove(dbenv, NULL, dbp->fileid, name, DB_APP_DATA,
F_ISSET(dbp, DB_AM_NOT_DURABLE) ? DB_LOG_NOT_DURABLE : 0);
err: if (!F_ISSET(dbp, DB_AM_INMEM) && real_name != NULL)
__os_free(dbenv, real_name);
if (tmpname != NULL)
__os_free(dbenv, tmpname);
return (ret);
}
int
__db_inmem_remove(dbp, txn, name)
DB *dbp;
DB_TXN *txn;
const char *name;
{
DB_ENV *dbenv;
DB_LSN lsn;
DBT fid_dbt, name_dbt;
DB_LOCKER *locker;
int ret;
dbenv = dbp->dbenv;
locker = NULL;
DB_ASSERT(dbenv, name != NULL);
(void)__memp_set_flags(dbp->mpf, DB_MPOOL_NOFILE, 1);
if ((ret = __memp_fopen(dbp->mpf, NULL, name, 0, 0, 0)) != 0)
return (ret);
if ((ret = __memp_get_fileid(dbp->mpf, dbp->fileid)) != 0)
return (ret);
dbp->preserve_fid = 1;
if (LOCKING_ON(dbenv)) {
if (dbp->locker == NULL &&
(ret = __lock_id(dbenv, NULL, &dbp->locker)) != 0)
return (ret);
locker = txn == NULL ? dbp->locker : txn->locker;
}
if ((ret =
__fop_lock_handle(dbenv, dbp, locker, DB_LOCK_WRITE, NULL, 0)) != 0)
return (ret);
if (LOGGING_ON(dbenv)) {
if (txn != NULL && (ret =
__txn_remevent(dbenv, txn, name, dbp->fileid, 1)) != 0)
return (ret);
DB_INIT_DBT(name_dbt, name, strlen(name) + 1);
DB_INIT_DBT(fid_dbt, dbp->fileid, DB_FILE_ID_LEN);
if ((ret = __crdel_inmem_remove_log(
dbenv, txn, &lsn, 0, &name_dbt, &fid_dbt)) != 0)
return (ret);
}
return (!IS_REAL_TXN(txn) ?
__memp_nameop(dbenv, dbp->fileid, NULL, name, NULL, 1) : 0);
}
static int
__db_subdb_remove(dbp, txn, name, subdb)
DB *dbp;
DB_TXN *txn;
const char *name, *subdb;
{
DB *mdbp, *sdbp;
int ret, t_ret;
mdbp = sdbp = NULL;
if ((ret = __db_create_internal(&sdbp, dbp->dbenv, 0)) != 0)
goto err;
if ((ret = __db_open(sdbp,
txn, name, subdb, DB_UNKNOWN, DB_WRITEOPEN, 0, PGNO_BASE_MD)) != 0)
goto err;
DB_TEST_RECOVERY(sdbp, DB_TEST_PREDESTROY, ret, name);
switch (sdbp->type) {
case DB_BTREE:
case DB_RECNO:
if ((ret = __bam_reclaim(sdbp, txn)) != 0)
goto err;
break;
case DB_HASH:
if ((ret = __ham_reclaim(sdbp, txn)) != 0)
goto err;
break;
case DB_QUEUE:
case DB_UNKNOWN:
default:
ret = __db_unknown_type(
sdbp->dbenv, "__db_subdb_remove", sdbp->type);
goto err;
}
if ((ret = __db_master_open(sdbp, txn, name, 0, 0, &mdbp)) != 0)
goto err;
if ((ret = __db_master_update(
mdbp, sdbp, txn, subdb, sdbp->type, MU_REMOVE, NULL, 0)) != 0)
goto err;
DB_TEST_RECOVERY(sdbp, DB_TEST_POSTDESTROY, ret, name);
DB_TEST_RECOVERY_LABEL
err:
if (txn == NULL) {
if ((t_ret = __db_close(sdbp, txn, 0)) != 0 && ret == 0)
ret = t_ret;
if (mdbp != NULL &&
(t_ret = __db_close(mdbp, txn, DB_NOSYNC)) != 0 && ret == 0)
ret = t_ret;
} else {
if ((t_ret =
__txn_closeevent(sdbp->dbenv, txn, sdbp)) != 0 && ret == 0)
ret = t_ret;
if (mdbp != NULL && (t_ret =
__txn_closeevent(mdbp->dbenv, txn, mdbp)) != 0 && ret == 0)
ret = t_ret;
}
return (ret);
}
static int
__db_dbtxn_remove(dbp, txn, name, subdb)
DB *dbp;
DB_TXN *txn;
const char *name, *subdb;
{
DB_ENV *dbenv;
int ret;
char *tmpname;
dbenv = dbp->dbenv;
tmpname = NULL;
if ((ret = __db_backup_name(dbenv,
F_ISSET(dbp, DB_AM_INMEM) ? subdb : name, txn, &tmpname)) != 0)
return (ret);
DB_TEST_RECOVERY(dbp, DB_TEST_PREDESTROY, ret, name);
if ((ret = __db_rename_int(dbp, txn, name, subdb, tmpname)) != 0)
goto err;
if (dbp->db_am_remove != NULL &&
(ret = dbp->db_am_remove(dbp, txn, tmpname, NULL)) != 0)
goto err;
ret = F_ISSET(dbp, DB_AM_INMEM) ?
__db_inmem_remove(dbp, txn, tmpname) :
__fop_remove(dbenv, txn, dbp->fileid, tmpname, DB_APP_DATA,
F_ISSET(dbp, DB_AM_NOT_DURABLE) ? DB_LOG_NOT_DURABLE : 0);
DB_TEST_RECOVERY(dbp, DB_TEST_POSTDESTROY, ret, name);
err:
DB_TEST_RECOVERY_LABEL
if (tmpname != NULL)
__os_free(dbenv, tmpname);
return (ret);
}