diff --git a/db-benchmark-test/Makefile b/db-benchmark-test/Makefile index 7ae8620e3fcf4506e2c03e71989b92f1dc77fb91..d6d84d9e2af25cccd39f833ebe36957ed007d39d 100644 --- a/db-benchmark-test/Makefile +++ b/db-benchmark-test/Makefile @@ -58,14 +58,18 @@ clean: ifeq ($(PROF_FLAGS),-pg) OFILES = \ ../src/ydb.o ../src/errors.o ../src/elocks.o \ - ../newbrt/brt.o ../newbrt/brt-serialize.o ../newbrt/brt-verify.o ../newbrt/cachetable.o ../newbrt/fifo.o ../newbrt/key.o ../newbrt/memory.o ../newbrt/mempool.o ../newbrt/gpma.o ../newbrt/leafentry.o ../newbrt/ybt.o ../newbrt/primes.o ../newbrt/log.o ../newbrt/fingerprint.o ../newbrt/log_code.o ../newbrt/roll.o ../newbrt/toku_assert.o ../newbrt/recover.o \ + ../newbrt/newbrt.o \ ../src/lock_tree/locktree.o ../src/lock_tree/rth.o ../src/lock_tree/lth.o ../src/lock_tree/idlth.o ../src/lock_tree/db_id.o \ ../src/range_tree/rangetree.o db-benchmark-test-tokudb: db-benchmark-test.c $(CC) $(CFLAGS) $(TDB_CPPFLAGS) $(OFILES) -lz $< -o $@ -DDIRSUF=tokudb +scanscan-tokudb: scanscan.c + $(CC) $(CFLAGS) $(TDB_CPPFLAGS) $(OFILES) -lz $< -o $@ -DDIRSUF=tokudb else db-benchmark-test-tokudb: db-benchmark-test.c $(CC) $(CFLAGS) $(TDB_CPPFLAGS) $(TDB_LDFLAGS) $< -o $@ -DDIRSUF=tokudb +scanscan-tokudb: scanscan.c + $(CC) $(CFLAGS) $(TDB_CPPFLAGS) $(TDB_LDFLAGS) $< -o $@ -DDIRSUF=tokudb endif db-benchmark-test-bdb: db-benchmark-test.c $(CC) $(CFLAGS) $(BDB_CPPFLAGS) $(BDB_LDFLAGS) $< -o $@ -DDIRSUF=bdb @@ -75,5 +79,3 @@ ptest0 ptest1 ptest2 ptest3 ptest4 ptest5 ptest6 ptest7: db-benchmark-test-tokud ./db-benchmark-test-tokudb --env $@.dir $(PARGS) parallel-test-8: ptest0 ptest1 ptest2 ptest3 ptest4 ptest5 ptest6 ptest7 -scanscan-tokudb: scanscan.c - $(CC) $(CFLAGS) $(TDB_CPPFLAGS) $(TDB_LDFLAGS) $< -o $@ -DDIRSUF=tokudb diff --git a/db-benchmark-test/scanscan.c b/db-benchmark-test/scanscan.c index b7d62a3d044095a1d9226130f9f4383f96bdf6b7..b99e6a8f370f6fa94555392399e6d57dfc6abfb4 100644 --- a/db-benchmark-test/scanscan.c +++ b/db-benchmark-test/scanscan.c @@ -15,7 +15,12 @@ DBC *dbc; #define STRINGIFY2(s) #s #define STRINGIFY(s) STRINGIFY2(s) const char *dbdir = "./bench." STRINGIFY(DIRSUF) "/"; /* DIRSUF is passed in as a -D argument to the compiler. */; +#define TXNS +#ifdef TXNS int env_open_flags = DB_CREATE|DB_PRIVATE|DB_INIT_MPOOL|DB_INIT_TXN|DB_INIT_LOG|DB_INIT_LOCK; +#else +int env_open_flags = DB_CREATE|DB_PRIVATE|DB_INIT_MPOOL; +#endif char *dbfilename = "bench.db"; void setup (void) { @@ -24,7 +29,9 @@ void setup (void) { r = env->set_cachesize(env, 0, 127*1024*1024, 1); assert(r==0); r = env->open(env, dbdir, env_open_flags, 0644); assert(r==0); r = db_create(&db, env, 0); assert(r==0); +#ifdef TXNS r = env->txn_begin(env, 0, &tid, 0); assert(r==0); +#endif r = db->open(db, tid, dbfilename, NULL, DB_BTREE, 0, 0644); assert(r==0); r = db->cursor(db, tid, &dbc, 0); assert(r==0); } @@ -33,7 +40,9 @@ void shutdown (void) { int r; r = dbc->c_close(dbc); assert(r==0); r = db->close(db, 0); assert(r==0); +#ifdef TXNS r = tid->commit(tid, 0); assert(r==0); +#endif r = env->close(env, 0); assert(r==0); { extern unsigned long toku_get_maxrss(void); @@ -78,6 +87,7 @@ int main (int argc, char *argv[]) { argv=argv; setup(); scanscan(); + scanscan(); shutdown(); return 0; }