database/mariadb
1
0
Fork 0
mirror of https://github.com/MariaDB/server.git synced 2025-11-30 05:23:50 +03:00
Code Activity

brt assert dupsort in handle_split_of_child. address #442

Browse Source 
git-svn-id: file:///svn/tokudb@2450 c7de825b-a66e-492c-adef-691d508d4ae1
This commit is contained in:
Rich Prohaska
2008-02-28 13:14:50 +00:00
parent 4e40b47bb0
commit 1c7ca178d2
1 changed files with 27 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

49
db-benchmark-test/db-benchmark-test.c
View File

@@ -12,6 +12,10 @@
#include <unistd.h> #include <unistd.h>
#include <db.h> #include <db.h>
#if !defined(DB_YESOVERWRITE)
#define DB_YESOVERWRITE 0
#endif
enum { SERIAL_SPACING = 1<<6 }; enum { SERIAL_SPACING = 1<<6 };
enum { ITEMS_TO_INSERT_PER_ITERATION = 1<<20 }; enum { ITEMS_TO_INSERT_PER_ITERATION = 1<<20 };
enum { ITEMS_PER_TRANSACTION = 1<<14 }; enum { ITEMS_PER_TRANSACTION = 1<<14 };
@@ -25,6 +29,7 @@ int keysize = sizeof (long long);
int valsize = sizeof (long long); int valsize = sizeof (long long);
int pagesize = 0; int pagesize = 0;
long long cachesize = 128*1024*1024; long long cachesize = 128*1024*1024;
int dupflags = 0;
#define STRINGIFY2(s) #s #define STRINGIFY2(s) #s
#define STRINGIFY(s) STRINGIFY2(s) #define STRINGIFY(s) STRINGIFY2(s)
@@ -87,6 +92,10 @@ void setup (void) {
r = db->set_pagesize(db, pagesize); r = db->set_pagesize(db, pagesize);
assert(r == 0); assert(r == 0);
} }
if (dupflags) {
r = db->set_flags(db, dupflags);
assert(r == 0);
}
r = db->open(db, tid, dbfilename, NULL, DB_BTREE, DB_CREATE, 0644); r = db->open(db, tid, dbfilename, NULL, DB_BTREE, DB_CREATE, 0644);
assert(r == 0); assert(r == 0);
if (do_transactions) { if (do_transactions) {
@@ -124,7 +133,7 @@ void insert (long long v) {
long_long_to_array(kc, v); long_long_to_array(kc, v);
memset(vc, 0, sizeof vc); memset(vc, 0, sizeof vc);
long_long_to_array(vc, v); long_long_to_array(vc, v);
int r = db->put(db, tid, toku_fill_dbt(&kt, kc, keysize), toku_fill_dbt(&vt, vc, valsize), 0); int r = db->put(db, tid, toku_fill_dbt(&kt, kc, keysize), toku_fill_dbt(&vt, vc, valsize), DB_YESOVERWRITE);
CKERR(r); CKERR(r);
if (do_transactions) { if (do_transactions) {
if (n_insertions_since_txn_began>=ITEMS_PER_TRANSACTION) { if (n_insertions_since_txn_began>=ITEMS_PER_TRANSACTION) {
@@ -143,7 +152,7 @@ void serial_insert_from (long long from) {
int r = dbenv->txn_begin(dbenv, 0, &tid, 0); assert(r==0); int r = dbenv->txn_begin(dbenv, 0, &tid, 0); assert(r==0);
{ {
DBT k,v; DBT k,v;
r=db->put(db, tid, toku_fill_dbt(&k, "a", 1), toku_fill_dbt(&v, "b", 1), 0); r=db->put(db, tid, toku_fill_dbt(&k, "a", 1), toku_fill_dbt(&v, "b", 1), DB_YESOVERWRITE);
CKERR(r); CKERR(r);
} }
@@ -201,7 +210,7 @@ void biginsert (long long n_elements, struct timeval *starttime) {
const long long default_n_items = 1LL<<22; const long long default_n_items = 1LL<<22;
void print_usage (const char *argv0) { int print_usage (const char *argv0) {
fprintf(stderr, "Usage:\n"); fprintf(stderr, "Usage:\n");
fprintf(stderr, " %s [-x] [--keysize KEYSIZE] [--valsize VALSIZE] [ n_iterations ]\n", argv0); fprintf(stderr, " %s [-x] [--keysize KEYSIZE] [--valsize VALSIZE] [ n_iterations ]\n", argv0);
fprintf(stderr, " where\n"); fprintf(stderr, " where\n");
@@ -211,8 +220,9 @@ void print_usage (const char *argv0) {
fprintf(stderr, " --cachesize CACHESIZE set the database cache size\n"); fprintf(stderr, " --cachesize CACHESIZE set the database cache size\n");
fprintf(stderr, " --pagesize PAGESIZE sets the database page size\n"); fprintf(stderr, " --pagesize PAGESIZE sets the database page size\n");
fprintf(stderr, " n_iterations how many iterations (default %lld iterations of %d items per iteration)\n", default_n_items/ITEMS_TO_INSERT_PER_ITERATION, ITEMS_TO_INSERT_PER_ITERATION); fprintf(stderr, " n_iterations how many iterations (default %lld iterations of %d items per iteration)\n", default_n_items/ITEMS_TO_INSERT_PER_ITERATION, ITEMS_TO_INSERT_PER_ITERATION);
}
return 1;
}
int main (int argc, const char *argv[]) { int main (int argc, const char *argv[]) {
struct timeval t1,t2,t3; struct timeval t1,t2,t3;
@@ -227,35 +237,30 @@ int main (int argc, const char *argv[]) {
continue; continue;
} }
if (strcmp(arg, "--cachesize") == 0) { if (strcmp(arg, "--cachesize") == 0) {
if (i+1 < argc) { if (i+1 >= argc) return print_usage(argv[0]);
i++; cachesize = strtoll(argv[++i], 0, 10);
cachesize = strtoll(argv[i], 0, 10);
}
continue; continue;
} }
if (strcmp(arg, "--keysize") == 0) { if (strcmp(arg, "--keysize") == 0) {
if (i+1 < argc) { if (i+1 >= argc) return print_usage(argv[0]);
i++; keysize = atoi(argv[++i]);
keysize = atoi(argv[i]);
}
continue; continue;
} }
if (strcmp(arg, "--valsize") == 0) { if (strcmp(arg, "--valsize") == 0) {
if (i+1 < argc) { if (i+1 >= argc) return print_usage(argv[0]);
i++; valsize = atoi(argv[++i]);
valsize = atoi(argv[i]);
}
continue; continue;
} }
if (strcmp(arg, "--pagesize") == 0) { if (strcmp(arg, "--pagesize") == 0) {
if (i+1 < argc) { if (i+1 >= argc) return print_usage(argv[0]);
i++; pagesize = atoi(argv[++i]);
pagesize = atoi(argv[i]);
}
continue; continue;
} }
print_usage(argv[0]); if (strcmp(arg, "--dupsort") == 0) {
return 1; dupflags = DB_DUP + DB_DUPSORT;
continue;
}
return print_usage(argv[0]);
} }
if (i<argc) { if (i<argc) {
/* if it looks like a number */ /* if it looks like a number */