mirror/mariadb
1
0
Fork 0
mirror of https://github.com/MariaDB/server.git synced 2025-01-22 14:54:20 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

test case for tokudb env recovery assert. addresses #703

Browse source 
git-svn-id: file:///svn/tokudb@3458 c7de825b-a66e-492c-adef-691d508d4ae1
This commit is contained in:
Rich Prohaska 2008-04-14 20:21:30 +00:00
parent 7438404c8b
commit 96f55286aa
1 changed files with 102 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

102
src/tests/test_txn_recover3.c Normal file
View file

@ -0,0 +1,102 @@
/* -*- mode: C; c-basic-offset: 4 -*- */
#ident "Copyright (c) 2007 Tokutek Inc. All rights reserved."
#include <stdio.h>
#include <stdlib.h>
#include <assert.h>
#include <unistd.h>
#include <string.h>
#include <errno.h>
#include <sys/stat.h>
#include <arpa/inet.h>
#include <db.h>
#include "test.h"
int db_put(DB *db, DB_TXN *txn, int k, int v) {
DBT key, val;
return db->put(db, txn, dbt_init(&key, &k, sizeof k), dbt_init(&val, &v, sizeof v), DB_NOOVERWRITE);
}
void test_txn_recover3(int nrows) {
if (verbose) printf("test_txn_recover1:%d\n", nrows);
system("rm -rf " ENVDIR);
mkdir(ENVDIR, 0777);
mkdir(ENVDIR "/" "t.tokudb", 0777);
DB_ENV *env;
DB *mdb, *sdb;
DB_TXN * const null_txn = 0;
const char * const fname = "t.tokudb/main.brt";
const char * const sname = "t.tokudb/status.brt";
int r;
r = db_env_create(&env, 0); assert(r == 0);
env->set_errfile(env, stderr);
r = env->open(env, ENVDIR, DB_CREATE|DB_INIT_MPOOL|DB_INIT_TXN|DB_INIT_LOCK|DB_INIT_LOG |DB_THREAD |DB_PRIVATE | DB_RECOVER, 0777); CKERR(r);
r = db_create(&mdb, env, 0); assert(r == 0);
mdb->set_errfile(mdb,stderr); // Turn off those annoying errors
r = mdb->open(mdb, null_txn, fname, NULL, DB_BTREE, DB_CREATE+DB_THREAD+DB_AUTO_COMMIT, 0666); assert(r == 0);
r = mdb->close(mdb, 0); assert(r == 0);
r = db_create(&sdb, env, 0); assert(r == 0);
sdb->set_errfile(sdb,stderr); // Turn off those annoying errors
r = sdb->open(sdb, null_txn, sname, NULL, DB_BTREE, DB_CREATE+DB_THREAD+DB_AUTO_COMMIT, 0666); assert(r == 0);
r = sdb->close(sdb, 0); assert(r == 0);
r = db_create(&mdb, env, 0); assert(r == 0);
mdb->set_errfile(mdb,stderr); // Turn off those annoying errors
r = mdb->open(mdb, null_txn, fname, NULL, DB_BTREE, DB_CREATE+DB_THREAD+DB_AUTO_COMMIT, 0666); assert(r == 0);
r = db_create(&sdb, env, 0); assert(r == 0);
sdb->set_errfile(sdb,stderr); // Turn off those annoying errors
r = sdb->open(sdb, null_txn, sname, NULL, DB_BTREE, DB_CREATE+DB_THREAD+DB_AUTO_COMMIT, 0666); assert(r == 0);
DB_TXN *txn;
r = env->txn_begin(env, null_txn, &txn, 0); assert(r == 0);
int i;
for (i=0; i<nrows; i++) {
int k = htonl(i);
int v = htonl(i);
DBT key, val;
r = mdb->put(mdb, txn, dbt_init(&key, &k, sizeof k), dbt_init(&val, &v, sizeof v), 0);
assert(r == 0);
r = sdb->put(sdb, txn, dbt_init(&key, &k, sizeof k), dbt_init(&val, &v, sizeof v), 0);
assert(r == 0);
}
r = txn->commit(txn, 0); assert(r == 0);
r = mdb->close(mdb, 0); assert(r == 0);
r = sdb->close(sdb, 0); assert(r == 0);
r = env->txn_checkpoint(env, 0, 0, 0); assert(r == 0);
char **names;
r = env->log_archive(env, &names, 0); assert(r == 0);
if (names) {
for (i=0; names[i]; i++)
printf("%d:%s\n", i, names[i]);
free(names);
}
r = env->close(env, 0); assert(r == 0);
r = db_env_create(&env, 0); assert(r == 0);
env->set_errfile(env, stderr);
r = env->open(env, ENVDIR, DB_CREATE|DB_INIT_MPOOL|DB_INIT_TXN|DB_INIT_LOCK|DB_INIT_LOG |DB_THREAD |DB_PRIVATE | DB_RECOVER, 0777); CKERR(r);
r = env->close(env, 0); assert(r == 0);
}
int main(int argc, const char *argv[]) {
parse_args(argc, argv);
test_txn_recover3(1);
return 0;
}