Skip to content

Commit 29aeb1e

Browse files
go frmt
Signed-off-by: Said Altury <Said.Altury@ibm.com>
1 parent c91457d commit 29aeb1e

File tree

2 files changed

+27
-27
lines changed

2 files changed

+27
-27
lines changed

integration/benchmark/grpc/grpc_bench_test.go

Lines changed: 15 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -8,9 +8,9 @@ package test
88

99
import (
1010
"encoding/json"
11+
"flag"
1112
"testing"
1213
"time"
13-
"flag"
1414

1515
"github.com/hyperledger-labs/fabric-smart-client/integration/benchmark"
1616
benchviews "github.com/hyperledger-labs/fabric-smart-client/integration/benchmark/views"
@@ -84,20 +84,20 @@ func setupServer(tb testing.TB) string {
8484
require.NotNil(tb, srv)
8585

8686
var v view.View
87-
switch *workload {
88-
case "cpu":
89-
parms := &benchviews.CPUParams{N: 200000}
90-
input, _ := json.Marshal(parms)
91-
factory := &benchviews.CPUViewFactory{}
92-
v, _ = factory.NewView(input)
93-
case "ecdsa":
94-
parms := &benchviews.ECDSASignParams{}
95-
input, _ := json.Marshal(parms)
96-
factory := &benchviews.ECDSASignViewFactory{}
97-
v, _ = factory.NewView(input)
98-
default:
99-
tb.Fatalf("unknown workload type: %s", *workload)
100-
}
87+
switch *workload {
88+
case "cpu":
89+
parms := &benchviews.CPUParams{N: 200000}
90+
input, _ := json.Marshal(parms)
91+
factory := &benchviews.CPUViewFactory{}
92+
v, _ = factory.NewView(input)
93+
case "ecdsa":
94+
parms := &benchviews.ECDSASignParams{}
95+
input, _ := json.Marshal(parms)
96+
factory := &benchviews.ECDSASignViewFactory{}
97+
v, _ = factory.NewView(input)
98+
default:
99+
tb.Fatalf("unknown workload type: %s", *workload)
100+
}
101101

102102
// our view manager
103103
vm := &benchmark.MockViewManager{Constructor: func() view.View {

integration/benchmark/grpc/grpc_multi_connection_bench_test.go

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -14,19 +14,19 @@ import (
1414
)
1515

1616
func BenchmarkGRPCMultiConnection(b *testing.B) {
17-
srvEndpoint := setupServer(b)
17+
srvEndpoint := setupServer(b)
1818

19-
b.RunParallel(func(pb *testing.PB) {
20-
// each goroutine gets its own client + connection
21-
cli, closeF := setupClient(b, srvEndpoint)
22-
defer closeF()
19+
b.RunParallel(func(pb *testing.PB) {
20+
// each goroutine gets its own client + connection
21+
cli, closeF := setupClient(b, srvEndpoint)
22+
defer closeF()
2323

24-
for pb.Next() {
25-
resp, err := cli.CallViewWithContext(b.Context(), "fid", nil)
26-
require.NoError(b, err)
27-
require.NotNil(b, resp)
28-
}
29-
})
24+
for pb.Next() {
25+
resp, err := cli.CallViewWithContext(b.Context(), "fid", nil)
26+
require.NoError(b, err)
27+
require.NotNil(b, resp)
28+
}
29+
})
3030

31-
benchmark.ReportTPS(b)
31+
benchmark.ReportTPS(b)
3232
}

0 commit comments

Comments
 (0)