#include "db_config.h"
#ifndef lint
static const char revid[] = "$Id: db.c,v 1.2 2004/03/30 01:21:24 jtownsen Exp $";
#endif
#ifndef NO_SYSTEM_INCLUDES
#include <sys/types.h>
#include <string.h>
#endif
#include "db_int.h"
#include "dbinc/db_page.h"
#include "dbinc/db_shash.h"
#include "dbinc/db_swap.h"
#include "dbinc/btree.h"
#include "dbinc/hash.h"
#include "dbinc/lock.h"
#include "dbinc/log.h"
#include "dbinc/mp.h"
#include "dbinc/qam.h"
#include "dbinc/txn.h"
static int __db_dbenv_mpool __P((DB *, const char *, u_int32_t));
static int __db_disassociate __P((DB *));
#if CONFIG_TEST
static void __db_makecopy __P((DB_ENV *, const char *, const char *));
static int __db_testdocopy __P((DB_ENV *, const char *));
static int __qam_testdocopy __P((DB *, const char *));
#endif
int
__db_master_open(subdbp, txn, name, flags, mode, dbpp)
DB *subdbp;
DB_TXN *txn;
const char *name;
u_int32_t flags;
int mode;
DB **dbpp;
{
DB *dbp;
int ret;
*dbpp = NULL;
if ((ret = db_create(&dbp, subdbp->dbenv, 0)) != 0)
return (ret);
dbp->pgsize = subdbp->pgsize;
F_SET(dbp, DB_AM_SUBDB);
F_SET(dbp, F_ISSET(subdbp,
DB_AM_RECOVER | DB_AM_SWAP |
DB_AM_ENCRYPT | DB_AM_CHKSUM | DB_AM_NOT_DURABLE));
LF_CLR(DB_EXCL);
LF_SET(DB_RDWRMASTER);
if ((ret = __db_open(dbp,
txn, name, NULL, DB_BTREE, flags, mode, PGNO_BASE_MD)) != 0)
goto err;
if (F_ISSET(dbp, DB_AM_CHKSUM))
F_SET(subdbp, DB_AM_CHKSUM);
if (subdbp->pgsize != 0 && dbp->pgsize != subdbp->pgsize) {
ret = EINVAL;
__db_err(dbp->dbenv,
"Different pagesize specified on existent file");
goto err;
}
err:
if (ret != 0 && !F_ISSET(dbp, DB_AM_DISCARD))
(void)__db_close(dbp, txn, 0);
else
*dbpp = dbp;
return (ret);
}
int
__db_master_update(mdbp, sdbp, txn, subdb, type, action, newname, flags)
DB *mdbp, *sdbp;
DB_TXN *txn;
const char *subdb;
DBTYPE type;
mu_action action;
const char *newname;
u_int32_t flags;
{
DB_ENV *dbenv;
DBC *dbc, *ndbc;
DBT key, data, ndata;
PAGE *p;
db_pgno_t t_pgno;
int modify, ret, t_ret;
dbenv = mdbp->dbenv;
dbc = ndbc = NULL;
p = NULL;
memset(&key, 0, sizeof(key));
memset(&data, 0, sizeof(data));
modify = (action != MU_OPEN || LF_ISSET(DB_CREATE)) ? 1 : 0;
if ((ret = __db_cursor(mdbp, txn, &dbc,
(CDB_LOCKING(dbenv) && modify) ? DB_WRITECURSOR : 0)) != 0)
goto err;
key.data = (void *)subdb;
key.size = (u_int32_t)strlen(subdb);
F_SET(&data, DB_DBT_MALLOC);
ret = __db_c_get(dbc, &key, &data,
DB_SET | ((STD_LOCKING(dbc) && modify) ? DB_RMW : 0));
switch (action) {
case MU_REMOVE:
if (ret != 0)
goto err;
if ((ret = __db_c_del(dbc, 0)) != 0)
goto err;
memcpy(&sdbp->meta_pgno, data.data, sizeof(db_pgno_t));
DB_NTOHL(&sdbp->meta_pgno);
if ((ret =
__memp_fget(mdbp->mpf, &sdbp->meta_pgno, 0, &p)) != 0)
goto err;
if ((ret = __db_free(dbc, p)) != 0) {
p = NULL;
goto err;
}
p = NULL;
break;
case MU_RENAME:
if (ret != 0)
goto err;
if ((ret = __db_cursor(mdbp, txn, &ndbc, 0)) != 0)
goto err;
key.data = (void *)newname;
key.size = (u_int32_t)strlen(newname);
memset(&ndata, 0, sizeof(ndata));
F_SET(&ndata, DB_DBT_USERMEM | DB_DBT_PARTIAL);
if ((ret = __db_c_get(ndbc, &key, &ndata, DB_SET)) == 0) {
ret = EEXIST;
__db_err(dbenv, "rename: database %s exists", newname);
goto err;
} else if (ret != DB_NOTFOUND)
goto err;
if ((ret = __db_c_put(ndbc, &key, &data, DB_KEYFIRST)) != 0)
goto err;
if ((ret = __db_c_del(dbc, 0)) != 0) {
(void)__db_c_del(ndbc, 0);
goto err;
}
break;
case MU_OPEN:
switch (ret) {
case 0:
if (LF_ISSET(DB_CREATE) && LF_ISSET(DB_EXCL)) {
ret = EEXIST;
goto err;
}
memcpy(&sdbp->meta_pgno, data.data, sizeof(db_pgno_t));
DB_NTOHL(&sdbp->meta_pgno);
goto done;
case DB_NOTFOUND:
if (LF_ISSET(DB_CREATE))
break;
ret = ENOENT;
goto err;
default:
goto err;
}
if ((ret = __db_new(dbc,
type == DB_HASH ? P_HASHMETA : P_BTREEMETA, &p)) != 0)
goto err;
sdbp->meta_pgno = PGNO(p);
t_pgno = PGNO(p);
DB_HTONL(&t_pgno);
memset(&ndata, 0, sizeof(ndata));
ndata.data = &t_pgno;
ndata.size = sizeof(db_pgno_t);
if ((ret = __db_c_put(dbc, &key, &ndata, DB_KEYLAST)) != 0)
goto err;
F_SET(sdbp, DB_AM_CREATED);
break;
}
err:
done:
if (p != NULL) {
if (ret == 0) {
if ((t_ret =
__memp_fput(mdbp->mpf, p, DB_MPOOL_DIRTY)) != 0)
ret = t_ret;
if ((t_ret = __db_sync(mdbp)) != 0 && ret == 0)
ret = t_ret;
} else
(void)__memp_fput(mdbp->mpf, p, 0);
}
if (data.data != NULL)
__os_ufree(dbenv, data.data);
if (dbc != NULL && (t_ret = __db_c_close(dbc)) != 0 && ret == 0)
ret = t_ret;
if (ndbc != NULL && (t_ret = __db_c_close(ndbc)) != 0 && ret == 0)
ret = t_ret;
return (ret);
}
int
__db_dbenv_setup(dbp, txn, fname, id, flags)
DB *dbp;
DB_TXN *txn;
const char *fname;
u_int32_t id, flags;
{
DB *ldbp;
DB_ENV *dbenv;
DB_MPOOL *dbmp;
u_int32_t maxid;
int ret;
dbenv = dbp->dbenv;
if (!F_ISSET(dbenv, DB_ENV_OPEN_CALLED)) {
if (dbenv->mp_gbytes == 0 &&
dbenv->mp_bytes < dbp->pgsize * DB_MINPAGECACHE &&
(ret = __memp_set_cachesize(
dbenv, 0, dbp->pgsize * DB_MINPAGECACHE, 0)) != 0)
return (ret);
if ((ret = __dbenv_open(dbenv, NULL, DB_CREATE |
DB_INIT_MPOOL | DB_PRIVATE | LF_ISSET(DB_THREAD), 0)) != 0)
return (ret);
}
if ((ret = __db_dbenv_mpool(dbp, fname, flags)) != 0)
return (ret);
if (LF_ISSET(DB_THREAD)) {
dbmp = dbenv->mp_handle;
if ((ret = __db_mutex_setup(dbenv, dbmp->reginfo, &dbp->mutexp,
MUTEX_ALLOC | MUTEX_THREAD)) != 0)
return (ret);
}
if (LOGGING_ON(dbenv) &&
(ret = __dbreg_setup(dbp, fname, id)) != 0)
return (ret);
if (DBENV_LOGGING(dbenv) && !F_ISSET(dbp, DB_AM_RECOVER) &&
#if !defined(DEBUG_ROP)
!F_ISSET(dbp, DB_AM_RDONLY) &&
#endif
(ret = __dbreg_new_id(dbp, txn)) != 0)
return (ret);
MUTEX_THREAD_LOCK(dbenv, dbenv->dblist_mutexp);
for (maxid = 0, ldbp = LIST_FIRST(&dbenv->dblist);
ldbp != NULL; ldbp = LIST_NEXT(ldbp, dblistlinks)) {
if (fname != NULL &&
memcmp(ldbp->fileid, dbp->fileid, DB_FILE_ID_LEN) == 0 &&
ldbp->meta_pgno == dbp->meta_pgno)
break;
if (ldbp->adj_fileid > maxid)
maxid = ldbp->adj_fileid;
}
if (ldbp == NULL) {
dbp->adj_fileid = maxid + 1;
LIST_INSERT_HEAD(&dbenv->dblist, dbp, dblistlinks);
} else {
dbp->adj_fileid = ldbp->adj_fileid;
LIST_INSERT_AFTER(ldbp, dbp, dblistlinks);
}
MUTEX_THREAD_UNLOCK(dbenv, dbenv->dblist_mutexp);
return (0);
}
static int
__db_dbenv_mpool(dbp, fname, flags)
DB *dbp;
const char *fname;
u_int32_t flags;
{
DB_ENV *dbenv;
DBT pgcookie;
DB_MPOOLFILE *mpf;
DB_PGINFO pginfo;
u_int32_t clear_len;
int ftype, ret;
COMPQUIET(mpf, NULL);
dbenv = dbp->dbenv;
if ((ret = __memp_register(
dbenv, DB_FTYPE_SET, __db_pgin, __db_pgout)) != 0)
return (ret);
switch (dbp->type) {
case DB_BTREE:
case DB_RECNO:
ftype = F_ISSET(dbp, DB_AM_SWAP | DB_AM_ENCRYPT | DB_AM_CHKSUM)
? DB_FTYPE_SET : DB_FTYPE_NOTSET;
clear_len = CRYPTO_ON(dbenv) ? dbp->pgsize : DB_PAGE_DB_LEN;
break;
case DB_HASH:
ftype = DB_FTYPE_SET;
clear_len = CRYPTO_ON(dbenv) ? dbp->pgsize : DB_PAGE_DB_LEN;
break;
case DB_QUEUE:
ftype = F_ISSET(dbp,
DB_AM_SWAP | DB_AM_ENCRYPT | DB_AM_CHKSUM) ?
DB_FTYPE_SET : DB_FTYPE_NOTSET;
clear_len = CRYPTO_ON(dbenv) ? dbp->pgsize : DB_PAGE_QUEUE_LEN;
break;
case DB_UNKNOWN:
if (F_ISSET(dbp, DB_AM_VERIFYING)) {
ftype = DB_FTYPE_NOTSET;
clear_len = DB_PAGE_DB_LEN;
break;
}
default:
return (
__db_unknown_type(dbenv, "__db_dbenv_setup", dbp->type));
}
mpf = dbp->mpf;
(void)__memp_set_clear_len(mpf, clear_len);
(void)__memp_set_fileid(mpf, dbp->fileid);
(void)__memp_set_ftype(mpf, ftype);
(void)__memp_set_lsn_offset(mpf, 0);
pginfo.db_pagesize = dbp->pgsize;
pginfo.flags =
F_ISSET(dbp, (DB_AM_CHKSUM | DB_AM_ENCRYPT | DB_AM_SWAP));
pginfo.type = dbp->type;
pgcookie.data = &pginfo;
pgcookie.size = sizeof(DB_PGINFO);
(void)__memp_set_pgcookie(mpf, &pgcookie);
if ((ret = __memp_fopen(mpf, NULL, fname,
LF_ISSET(DB_RDONLY | DB_NOMMAP |
DB_ODDFILESIZE | DB_TRUNCATE) |
(F_ISSET(dbenv, DB_ENV_DIRECT_DB) ? DB_DIRECT : 0) |
(F_ISSET(dbp, DB_AM_NOT_DURABLE) ? DB_TXN_NOT_DURABLE : 0),
0, dbp->pgsize)) != 0)
return (ret);
return (0);
}
int
__db_close(dbp, txn, flags)
DB *dbp;
DB_TXN *txn;
u_int32_t flags;
{
DB_ENV *dbenv;
u_int32_t dbpflags;
int db_ref, deferred_close, ret, t_ret;
dbenv = dbp->dbenv;
deferred_close = ret = 0;
if (txn != NULL)
(void)__db_check_txn(dbp, txn, DB_LOCK_INVALIDID, 0);
dbpflags = dbp->flags;
ret = __db_refresh(dbp, txn, flags, &deferred_close);
if (deferred_close)
return (ret);
if ((t_ret = __bam_db_close(dbp)) != 0 && ret == 0)
ret = t_ret;
if ((t_ret = __ham_db_close(dbp)) != 0 && ret == 0)
ret = t_ret;
if ((t_ret = __qam_db_close(dbp, dbpflags)) != 0 && ret == 0)
ret = t_ret;
MUTEX_THREAD_LOCK(dbenv, dbenv->dblist_mutexp);
db_ref = --dbenv->db_ref;
MUTEX_THREAD_UNLOCK(dbenv, dbenv->dblist_mutexp);
if (F_ISSET(dbenv, DB_ENV_DBLOCAL) && db_ref == 0 &&
(t_ret = __dbenv_close(dbenv, 0)) != 0 && ret == 0)
ret = t_ret;
memset(dbp, CLEAR_BYTE, sizeof(*dbp));
__os_free(dbenv, dbp);
return (ret);
}
int
__db_refresh(dbp, txn, flags, deferred_closep)
DB *dbp;
DB_TXN *txn;
u_int32_t flags;
int *deferred_closep;
{
DB *sdbp;
DBC *dbc;
DB_ENV *dbenv;
DB_LOCKREQ lreq;
DB_MPOOL *dbmp;
int ret, t_ret;
ret = 0;
dbenv = dbp->dbenv;
if (!F_ISSET(dbp, DB_AM_OPEN_CALLED))
goto never_opened;
for (sdbp = LIST_FIRST(&dbp->s_secondaries);
sdbp != NULL; sdbp = LIST_NEXT(sdbp, s_links)) {
LIST_REMOVE(sdbp, s_links);
if ((t_ret = __db_disassociate(sdbp)) != 0 && ret == 0)
ret = t_ret;
}
if (!LF_ISSET(DB_NOSYNC) &&
!F_ISSET(dbp, DB_AM_DISCARD | DB_AM_RECOVER) &&
(t_ret = __db_sync(dbp)) != 0 && ret == 0)
ret = t_ret;
while ((dbc = TAILQ_FIRST(&dbp->active_queue)) != NULL)
if ((t_ret = __db_c_close(dbc)) != 0) {
if (ret == 0)
ret = t_ret;
break;
}
while ((dbc = TAILQ_FIRST(&dbp->free_queue)) != NULL)
if ((t_ret = __db_c_destroy(dbc)) != 0) {
if (ret == 0)
ret = t_ret;
break;
}
while ((dbc = TAILQ_FIRST(&dbp->join_queue)) != NULL)
if ((t_ret = __db_join_close(dbc)) != 0) {
if (ret == 0)
ret = t_ret;
break;
}
if (!LF_ISSET(DB_NOSYNC) &&
!F_ISSET(dbp, DB_AM_DISCARD | DB_AM_RECOVER) &&
(t_ret = __memp_fsync(dbp->mpf)) != 0 && ret == 0)
ret = t_ret;
if (LOGGING_ON(dbp->dbenv)) {
if (F_ISSET(dbp, DB_AM_RECOVER))
t_ret = __dbreg_revoke_id(dbp, 0, DB_LOGFILEID_INVALID);
else {
if ((t_ret = __dbreg_close_id(dbp, txn)) != 0 &&
txn != NULL) {
if ((ret =
__txn_closeevent(dbenv, txn, dbp)) != 0)
return (__db_panic(dbenv, ret));
if (deferred_closep != NULL)
*deferred_closep = 1;
return (t_ret);
}
}
if (ret == 0)
ret = t_ret;
if ((t_ret = __dbreg_teardown(dbp)) != 0 && ret == 0)
ret = t_ret;
}
if (dbp->saved_open_fhp != NULL &&
(t_ret = __os_closehandle(dbenv, dbp->saved_open_fhp)) != 0 &&
ret == 0)
ret = t_ret;
never_opened:
if (dbp->lid != DB_LOCK_INVALIDID) {
if (txn != NULL)
__txn_remlock(dbenv, txn, &dbp->handle_lock, dbp->lid);
lreq.op = DB_LOCK_PUT_ALL;
lreq.obj = NULL;
if ((t_ret = __lock_vec(dbenv,
dbp->lid, 0, &lreq, 1, NULL)) != 0 && ret == 0)
ret = t_ret;
if ((t_ret = __lock_id_free(dbenv, dbp->lid)) != 0 && ret == 0)
ret = t_ret;
dbp->lid = DB_LOCK_INVALIDID;
LOCK_INIT(dbp->handle_lock);
}
if (F_ISSET(dbp, DB_AM_INMEM) && LOCKING_ON(dbenv) &&
(t_ret = __lock_id_free(dbenv, *(u_int32_t *)dbp->fileid)) != 0 &&
ret == 0)
ret = t_ret;
dbp->type = DB_UNKNOWN;
if (dbp->mutexp != NULL) {
dbmp = dbenv->mp_handle;
__db_mutex_free(dbenv, dbmp->reginfo, dbp->mutexp);
dbp->mutexp = NULL;
}
if (dbp->fname != NULL) {
__os_free(dbp->dbenv, dbp->fname);
dbp->fname = NULL;
}
if (dbp->dname != NULL) {
__os_free(dbp->dbenv, dbp->dname);
dbp->dname = NULL;
}
if (dbp->my_rskey.data != NULL)
__os_free(dbp->dbenv, dbp->my_rskey.data);
if (dbp->my_rkey.data != NULL)
__os_free(dbp->dbenv, dbp->my_rkey.data);
if (dbp->my_rdata.data != NULL)
__os_free(dbp->dbenv, dbp->my_rdata.data);
memset(&dbp->my_rskey, 0, sizeof(DBT));
memset(&dbp->my_rkey, 0, sizeof(DBT));
memset(&dbp->my_rdata, 0, sizeof(DBT));
MUTEX_THREAD_LOCK(dbenv, dbenv->dblist_mutexp);
if (dbp->dblistlinks.le_prev != NULL) {
LIST_REMOVE(dbp, dblistlinks);
dbp->dblistlinks.le_prev = NULL;
}
if (dbp->mpf != NULL) {
if ((t_ret = __memp_fclose(dbp->mpf,
F_ISSET(dbp, DB_AM_DISCARD) ? DB_MPOOL_DISCARD : 0)) != 0 &&
ret == 0)
ret = t_ret;
dbp->mpf = NULL;
}
MUTEX_THREAD_UNLOCK(dbenv, dbenv->dblist_mutexp);
memset(dbp->fileid, 0, sizeof(dbp->fileid));
dbp->adj_fileid = 0;
dbp->meta_pgno = 0;
dbp->cur_lid = DB_LOCK_INVALIDID;
dbp->associate_lid = DB_LOCK_INVALIDID;
dbp->cl_id = 0;
dbp->open_flags = 0;
if (txn != NULL)
LOCK_INIT(dbp->handle_lock);
dbp->flags = dbp->orig_flags;
return (ret);
}
int
__db_log_page(dbp, txn, lsn, pgno, page)
DB *dbp;
DB_TXN *txn;
DB_LSN *lsn;
db_pgno_t pgno;
PAGE *page;
{
DBT page_dbt;
DB_LSN new_lsn;
int ret;
if (!LOGGING_ON(dbp->dbenv) || txn == NULL)
return (0);
memset(&page_dbt, 0, sizeof(page_dbt));
page_dbt.size = dbp->pgsize;
page_dbt.data = page;
ret = __crdel_metasub_log(dbp, txn, &new_lsn, 0, pgno, &page_dbt, lsn);
if (ret == 0)
page->lsn = new_lsn;
return (ret);
}
#undef BACKUP_PREFIX
#define BACKUP_PREFIX "__db."
#undef MAX_LSN_TO_TEXT
#define MAX_LSN_TO_TEXT 17
int
__db_backup_name(dbenv, name, txn, backup)
DB_ENV *dbenv;
const char *name;
DB_TXN *txn;
char **backup;
{
DB_LSN lsn;
size_t len;
int plen, ret, use_lsn;
char *p, *retp;
if (!F_ISSET(dbenv, DB_ENV_TXN_NOT_DURABLE) && txn != NULL) {
if (IS_ZERO_LSN(txn->last_lsn)) {
if ((ret = __db_debug_log(dbenv, txn, &lsn, 0,
NULL, 0, NULL, NULL, 0)) != 0)
return (ret);
} else
lsn = txn->last_lsn;
use_lsn = 1;
} else
use_lsn = 0;
len = strlen(name) + strlen(BACKUP_PREFIX) + MAX_LSN_TO_TEXT;
if ((ret = __os_malloc(dbenv, len, &retp)) != 0)
return (ret);
if ((p = __db_rpath(name)) == NULL) {
if (use_lsn)
snprintf(retp, len,
"%s%x.%x", BACKUP_PREFIX, lsn.file, lsn.offset);
else
snprintf(retp, len, "%s%s", BACKUP_PREFIX, name);
} else {
plen = (int)(p - name) + 1;
p++;
if (use_lsn)
snprintf(retp, len,
"%.*s%x.%x", plen, name, lsn.file, lsn.offset);
else
snprintf(retp, len,
"%.*s%s%s", plen, name, BACKUP_PREFIX, p);
}
*backup = retp;
return (0);
}
DB *
__dblist_get(dbenv, adjid)
DB_ENV *dbenv;
u_int32_t adjid;
{
DB *dbp;
for (dbp = LIST_FIRST(&dbenv->dblist);
dbp != NULL && dbp->adj_fileid != adjid;
dbp = LIST_NEXT(dbp, dblistlinks))
;
return (dbp);
}
static int
__db_disassociate(sdbp)
DB *sdbp;
{
DBC *dbc;
int ret, t_ret;
ret = 0;
sdbp->s_callback = NULL;
sdbp->s_primary = NULL;
sdbp->get = sdbp->stored_get;
sdbp->close = sdbp->stored_close;
if (sdbp->s_refcnt != 1 ||
TAILQ_FIRST(&sdbp->active_queue) != NULL ||
TAILQ_FIRST(&sdbp->join_queue) != NULL) {
__db_err(sdbp->dbenv,
"Closing a primary DB while a secondary DB has active cursors is unsafe");
ret = EINVAL;
}
sdbp->s_refcnt = 0;
while ((dbc = TAILQ_FIRST(&sdbp->free_queue)) != NULL)
if ((t_ret = __db_c_destroy(dbc)) != 0 && ret == 0)
ret = t_ret;
F_CLR(sdbp, DB_AM_SECONDARY);
return (ret);
}
#if CONFIG_TEST
int
__db_testcopy(dbenv, dbp, name)
DB_ENV *dbenv;
DB *dbp;
const char *name;
{
DB_MPOOL *dbmp;
DB_MPOOLFILE *mpf;
DB_ASSERT(dbp != NULL || name != NULL);
if (name == NULL) {
dbmp = dbenv->mp_handle;
mpf = dbp->mpf;
name = R_ADDR(dbmp->reginfo, mpf->mfp->path_off);
}
if (dbp != NULL && dbp->type == DB_QUEUE)
return (__qam_testdocopy(dbp, name));
else
return (__db_testdocopy(dbenv, name));
}
static int
__qam_testdocopy(dbp, name)
DB *dbp;
const char *name;
{
QUEUE_FILELIST *filelist, *fp;
char buf[256], *dir;
int ret;
filelist = NULL;
if ((ret = __db_testdocopy(dbp->dbenv, name)) != 0)
return (ret);
if (dbp->mpf != NULL &&
(ret = __qam_gen_filelist(dbp, &filelist)) != 0)
return (ret);
if (filelist == NULL)
return (0);
dir = ((QUEUE *)dbp->q_internal)->dir;
for (fp = filelist; fp->mpf != NULL; fp++) {
snprintf(buf, sizeof(buf),
QUEUE_EXTENT, dir, PATH_SEPARATOR[0], name, fp->id);
if ((ret = __db_testdocopy(dbp->dbenv, buf)) != 0)
return (ret);
}
__os_free(dbp->dbenv, filelist);
return (0);
}
static int
__db_testdocopy(dbenv, name)
DB_ENV *dbenv;
const char *name;
{
size_t len;
int dircnt, i, ret;
char **namesp, *backup, *copy, *dir, *p, *real_name;
real_name = NULL;
if ((ret = __db_appname(dbenv,
DB_APP_DATA, name, 0, NULL, &real_name)) != 0)
return (ret);
copy = backup = NULL;
namesp = NULL;
len = strlen(real_name) + strlen(BACKUP_PREFIX) + MAX_LSN_TO_TEXT + 9;
if ((ret = __os_malloc(dbenv, len, ©)) != 0)
goto out;
if ((ret = __os_malloc(dbenv, len, &backup)) != 0)
goto out;
snprintf(copy, len, "%s.afterop", real_name);
__db_makecopy(dbenv, real_name, copy);
if ((ret = __os_strdup(dbenv, real_name, &dir)) != 0)
goto out;
__os_free(dbenv, real_name);
real_name = NULL;
snprintf(backup, len, "%s%s.0x", BACKUP_PREFIX, name);
p = __db_rpath(dir);
if (p != NULL)
*p = '\0';
ret = __os_dirlist(dbenv, dir, &namesp, &dircnt);
#if DIAGNOSTIC
*p = '/';
#endif
__os_free(dbenv, dir);
if (ret != 0)
goto out;
for (i = 0; i < dircnt; i++) {
if (strncmp(namesp[i], backup, strlen(backup)) == 0) {
if ((ret = __db_appname(dbenv, DB_APP_DATA,
namesp[i], 0, NULL, &real_name)) != 0)
goto out;
if (strstr(real_name, ".afterop") != NULL) {
__os_free(dbenv, real_name);
real_name = NULL;
continue;
}
snprintf(copy, len, "%s.afterop", real_name);
__db_makecopy(dbenv, real_name, copy);
__os_free(dbenv, real_name);
real_name = NULL;
}
}
out:
if (backup != NULL)
__os_free(dbenv, backup);
if (copy != NULL)
__os_free(dbenv, copy);
if (namesp != NULL)
__os_dirfree(dbenv, namesp, dircnt);
if (real_name != NULL)
__os_free(dbenv, real_name);
return (ret);
}
static void
__db_makecopy(dbenv, src, dest)
DB_ENV *dbenv;
const char *src, *dest;
{
DB_FH *rfhp, *wfhp;
size_t rcnt, wcnt;
char *buf;
rfhp = wfhp = NULL;
if (__os_malloc(dbenv, 1024, &buf) != 0)
return;
if (__os_open(dbenv,
src, DB_OSO_RDONLY, __db_omode("rw----"), &rfhp) != 0)
goto err;
if (__os_open(dbenv, dest,
DB_OSO_CREATE | DB_OSO_TRUNC, __db_omode("rw----"), &wfhp) != 0)
goto err;
for (;;)
if (__os_read(dbenv, rfhp, buf, 1024, &rcnt) < 0 || rcnt == 0 ||
__os_write(dbenv, wfhp, buf, rcnt, &wcnt) < 0)
break;
err: if (buf != NULL)
__os_free(dbenv, buf);
if (rfhp != NULL)
(void)__os_closehandle(dbenv, rfhp);
if (wfhp != NULL)
(void)__os_closehandle(dbenv, wfhp);
}
#endif