Commite83a073

committed

Fix the endless loop in transfers test :)

1 parent7a43e43 commite83a073Copy full SHA for e83a073

File tree

-1

lines changed

-1

lines changed

Lines changed: 3 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -113,6 +113,7 @@ func transfer(id int, cCommits chan int, cAborts chan int, wg *sync.WaitGroup) {`
`113`	`113`	`varxidint32`
`114`	`114`	`varnAborts=0`
`115`	`115`	`varnCommits=0`
	`116`	`+varmyCommits=0`
`116`	`117`
`117`	`118`	`conn1,err:=pgx.Connect(cfg1)`
`118`	`119`	`checkErr(err)`
`@@ -123,7 +124,7 @@ func transfer(id int, cCommits chan int, cAborts chan int, wg *sync.WaitGroup) {`
`123`	`124`	`deferconn2.Close()`
`124`	`125`
`125`	`126`	`start:=time.Now()`
`126`		`-fornCommits<N_ITERATIONS {`
	`127`	`+formyCommits<N_ITERATIONS {`
`127`	`128`	`amount:=2*rand.Intn(2000)-1`
`128`	`129`	`//amount := 1`
`129`	`130`	`account1:=rand.Intn(N_ACCOUNTS)`
`@@ -145,6 +146,7 @@ func transfer(id int, cCommits chan int, cAborts chan int, wg *sync.WaitGroup) {`
`145`	`146`	`}else {`
`146`	`147`	`commit(conn1,conn2)`
`147`	`148`	`nCommits+=1`
	`149`	`+myCommits+=1`
`148`	`150`	`}`
`149`	`151`
`150`	`152`	`iftime.Since(start).Seconds()>1 {`

Comments

(0)