@@ -33,16 +33,17 @@ import (
33
33
func TestExecuteConcurrentInvokes (t * testing.T ) {
34
34
//this test fails occasionally. FAB-1600 is opened to track this issue
35
35
//skip meanwhile so as to not block CI
36
+
36
37
t .Skip ()
37
38
chainID := util .GetTestChainID ()
38
39
39
- lis , err := initPeer (chainID )
40
+ _ , chaincodeSupport , cleanup , err := initPeer (chainID )
40
41
if err != nil {
41
42
t .Fail ()
42
43
t .Logf ("Error creating peer: %s" , err )
43
44
}
44
45
45
- defer finitPeer ( lis , chainID )
46
+ defer cleanup ( )
46
47
47
48
var ctxt = context .Background ()
48
49
@@ -56,10 +57,10 @@ func TestExecuteConcurrentInvokes(t *testing.T) {
56
57
57
58
cccid := ccprovider .NewCCContext (chainID , "nkpi" , "0" , "" , false , nil , nil )
58
59
59
- defer theChaincodeSupport .Stop (ctxt , cccid , & pb.ChaincodeDeploymentSpec {ChaincodeSpec : spec })
60
+ defer chaincodeSupport .Stop (ctxt , cccid , & pb.ChaincodeDeploymentSpec {ChaincodeSpec : spec })
60
61
61
62
var nextBlockNumber uint64
62
- _ , err = deploy (ctxt , cccid , spec , nextBlockNumber )
63
+ _ , err = deploy (ctxt , cccid , spec , nextBlockNumber , chaincodeSupport )
63
64
nextBlockNumber ++
64
65
if err != nil {
65
66
t .Fail ()
@@ -90,7 +91,7 @@ func TestExecuteConcurrentInvokes(t *testing.T) {
90
91
spec = & pb.ChaincodeSpec {Type : 1 , ChaincodeId : chaincodeID , Input : & pb.ChaincodeInput {Args : args }}
91
92
92
93
//start with a new background
93
- _ , _ , results [qnum ], err = invoke (context .Background (), chainID , spec , nextBlockNumber , nil )
94
+ _ , _ , results [qnum ], err = invoke (context .Background (), chainID , spec , nextBlockNumber , nil , chaincodeSupport )
94
95
95
96
if err != nil {
96
97
errs [qnum ] = fmt .Errorf ("Error executing <%s>: %s" , chaincodeID .Name , err )
0 commit comments