Skip to content

Commit 692c2ed

Browse files
committed
Fix dtmbench for multimaster.
1 parent 0896d5c commit 692c2ed

File tree

1 file changed

+11
-16
lines changed

1 file changed

+11
-16
lines changed

contrib/multimaster/tests/dtmbench.cpp

Lines changed: 11 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -178,25 +178,20 @@ void* writer(void* arg)
178178

179179
void initializeDatabase()
180180
{
181-
//for (size_t i = 0; i < cfg.connections.size(); i++) {
182-
// printf("creating extension %lu\n", i);
183-
// try {
184-
// connection conn(cfg.connections[i]);
185-
// work txn(conn);
186-
// //exec(txn, "drop extension if exists multimaster");
187-
// exec(txn, "create extension multimaster");
188-
// txn.commit();
189-
// } catch (pqxx_exception const& x) {
190-
// i -= 1;
191-
// continue;
192-
// }
193-
// printf("extension %lu created\n", i);
194-
//}
181+
connection conn(cfg.connections[0]);
182+
183+
printf("creating extension\n");
184+
{
185+
nontransaction txn(conn);
186+
exec(txn, "drop extension if exists multimaster");
187+
exec(txn, "create extension multimaster");
188+
txn.commit();
189+
}
190+
printf("extension created\n");
195191

196192
printf("creating table t\n");
197-
connection conn(cfg.connections[0]);
198193
{
199-
work txn(conn);
194+
nontransaction txn(conn);
200195
exec(txn, "drop table if exists t");
201196
exec(txn, "create table t(u int primary key, v int)");
202197
txn.commit();

0 commit comments

Comments
 (0)