Skip to content

Commit d4e32c2

Browse files
committed
Randomize orderers
Change-Id: I94bab958bdc0f1140f39e6ca3bc402ff0e1b6241 Signed-off-by: yacovm <yacovm@il.ibm.com>
1 parent 0b49e90 commit d4e32c2

File tree

1 file changed

+14
-5
lines changed

1 file changed

+14
-5
lines changed

integration/smartbft/smartbft_test.go

Lines changed: 14 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -10,14 +10,13 @@
1010
package smartbft
1111

1212
import (
13+
"fmt"
1314
"io/ioutil"
15+
"math/rand"
1416
"os"
15-
"syscall"
16-
17-
"fmt"
18-
1917
"strings"
2018
"sync"
19+
"syscall"
2120
"time"
2221

2322
docker "github.com/fsouza/go-dockerclient"
@@ -30,6 +29,10 @@ import (
3029
"github.com/tedsuo/ifrit"
3130
)
3231

32+
func init() {
33+
rand.Seed(time.Now().UnixNano())
34+
}
35+
3336
var _ = Describe("EndToEnd Smart BFT configuration test", func() {
3437
var (
3538
testDir string
@@ -82,7 +85,9 @@ var _ = Describe("EndToEnd Smart BFT configuration test", func() {
8285
assertBlockReception(map[string]int{"systemchannel": 0}, network.Orderers, peer, network)
8386

8487
channel := "testchannel1"
85-
orderer := network.Orderer("orderer1")
88+
89+
orderer := network.Orderers[rand.Intn(len(network.Orderers))]
90+
fmt.Fprintf(GinkgoWriter, "Picking orderer %s to create channel", orderer.Name)
8691
network.CreateAndJoinChannel(orderer, channel)
8792

8893
nwo.DeployChaincode(network, channel, orderer, nwo.Chaincode{
@@ -104,6 +109,8 @@ var _ = Describe("EndToEnd Smart BFT configuration test", func() {
104109
Eventually(sess, network.EventuallyTimeout).Should(gexec.Exit(0))
105110
Expect(sess).To(gbytes.Say("100"))
106111

112+
orderer = network.Orderers[rand.Intn(len(network.Orderers))]
113+
fmt.Fprintf(GinkgoWriter, "Picking orderer %s to send invoke", orderer.Name)
107114
invokeQuery(network, peer, orderer, channel, 90)
108115

109116
By("Taking down all the nodes")
@@ -115,6 +122,8 @@ var _ = Describe("EndToEnd Smart BFT configuration test", func() {
115122
networkProcess = ifrit.Invoke(ordererRunner)
116123
Eventually(networkProcess.Ready(), network.EventuallyTimeout).Should(BeClosed())
117124

125+
orderer = network.Orderers[rand.Intn(len(network.Orderers))]
126+
fmt.Fprintf(GinkgoWriter, "Picking orderer %s to invoke", orderer.Name)
118127
invokeQuery(network, peer, orderer, channel, 80)
119128
})
120129
})

0 commit comments

Comments
 (0)