Commitb9b69d8

committed

Update dtm_bench test

1 parente52fdbb commitb9b69d8Copy full SHA for b9b69d8

File tree

-3

lines changed

-3

lines changed

Lines changed: 5 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -117,7 +117,7 @@ void* reader(void* arg)`
`117`	`117`	`}`
`118`	`118`	`int64_t prevSum =0;`
`119`	`119`
`120`		`-while (running) {`
	`120`	`+while (running && (cfg.nWriters !=0 \|\| t.proceeded < (size_t)cfg.nIterations)) {`
`121`	`121`	`try {`
`122`	`122`	`xid_t xid =0;`
`123`	`123`	`for (size_t i =0; i < conns.size(); i++) {`
`@@ -307,8 +307,10 @@ int main (int argc, char* argv[])`
`307`	`307`	`nWrites += writers[i].proceeded;`
`308`	`308`	`nAborts += writers[i].aborts;`
`309`	`309`	`}`
`310`		`-`
`311`		`- running =false;`
	`310`	`+`
	`311`	`+if (cfg.nWriters !=0) {`
	`312`	`+ running =false;`
	`313`	`+ }`
`312`	`314`
`313`	`315`	`for (int i =0; i < cfg.nReaders; i++) {`
`314`	`316`	`readers[i].wait();`

Comments

(0)