Commit7e25ccd

committed

Actually use the 'private rows' parameter in transfers test.

1 parent57f620d commit7e25ccdCopy full SHA for 7e25ccd

File tree

+11

-2

lines changed

+11

-2

lines changed

Lines changed: 11 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -275,11 +275,20 @@ func writer(id int, cCommits chan int, cAborts chan int, wg *sync.WaitGroup) {`
`275`	`275`	`start:=time.Now()`
`276`	`276`	`formyCommits<cfg.Writers.Updates {`
`277`	`277`	`amount:=1`
	`278`	`+`
`278`	`279`	`from_acc:=rand.Intn(cfg.Accounts.Num)`
`279`	`280`	`to_acc:=rand.Intn(cfg.Accounts.Num)`
`280`	`281`
`281`		`-if (from_acc==to_acc) {`
`282`		`-to_acc= (from_acc+1)%cfg.Accounts.Num`
	`282`	`+ifcfg.Writers.PrivateRows {`
	`283`	`+from_acc+=id- (from_acc%cfg.Writers.Num)`
	`284`	`+to_acc+=id- (to_acc%cfg.Writers.Num)`
	`285`	`+if (from_acc==to_acc) {`
	`286`	`+to_acc= (from_acc+cfg.Writers.Num)%cfg.Accounts.Num`
	`287`	`+ }`
	`288`	`+ }else {`
	`289`	`+if (from_acc==to_acc) {`
	`290`	`+to_acc= (from_acc+1)%cfg.Accounts.Num`
	`291`	`+ }`
`283`	`292`	`}`
`284`	`293`
`285`	`294`	`if (from_acc>to_acc) {`

Comments

(0)