Commita033f69

committed

Fix a deadlock in the transfers test caused by random connection order.

1 parentdee9a9a commita033f69Copy full SHA for a033f69

File tree

-2

lines changed

-2

lines changed

Lines changed: 8 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -138,8 +138,14 @@ func transfer(id int, cCommits chan int, cAborts chan int, wg *sync.WaitGroup) {`
`138`	`138`	`continue`
`139`	`139`	`}`
`140`	`140`
`141`		`-src:=conn[rand.Intn(2)]`
`142`		`-dst:=conn[rand.Intn(2)]`
	`141`	`+srci:=rand.Intn(2)`
	`142`	`+dsti:=rand.Intn(2)`
	`143`	`+if (srci>dsti) {`
	`144`	`+continue`
	`145`	`+ }`
	`146`	`+`
	`147`	`+src:=conn[srci]`
	`148`	`+dst:=conn[dsti]`
`143`	`149`
`144`	`150`	`ifsrc==dst {`
`145`	`151`	`// local update`

Comments

(0)