/
serverstatshandler_test.go
108 lines (90 loc) · 2.72 KB
/
serverstatshandler_test.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
/*
Copyright IBM Corp. All Rights Reserved.
SPDX-License-Identifier: Apache-2.0
*/
package comm_test
import (
"context"
"net"
"testing"
"time"
"github.com/hyperledger/fabric/common/metrics"
"github.com/hyperledger/fabric/common/metrics/metricsfakes"
"github.com/hyperledger/fabric/core/comm"
"github.com/hyperledger/fabric/core/comm/testpb"
. "github.com/onsi/gomega"
"google.golang.org/grpc"
"google.golang.org/grpc/stats"
)
func TestConnectionCounters(t *testing.T) {
t.Parallel()
gt := NewGomegaWithT(t)
openConn := &metricsfakes.Counter{}
closedConn := &metricsfakes.Counter{}
sh := &comm.ServerStatsHandler{
OpenConnCounter: openConn,
ClosedConnCounter: closedConn,
}
for i := 1; i <= 10; i++ {
sh.HandleConn(context.Background(), &stats.ConnBegin{})
gt.Expect(openConn.AddCallCount()).To(Equal(i))
}
for i := 1; i <= 5; i++ {
sh.HandleConn(context.Background(), &stats.ConnEnd{})
gt.Expect(closedConn.AddCallCount()).To(Equal(i))
}
}
func TestConnMetricsGRPCServer(t *testing.T) {
t.Parallel()
gt := NewGomegaWithT(t)
openConn := &metricsfakes.Counter{}
closedConn := &metricsfakes.Counter{}
fakeProvider := &metricsfakes.Provider{}
fakeProvider.NewCounterStub = func(o metrics.CounterOpts) metrics.Counter {
switch o.Name {
case "conn_opened":
return openConn
case "conn_closed":
return closedConn
default:
panic("unknown counter")
}
}
listener, err := net.Listen("tcp", "localhost:0")
gt.Expect(err).NotTo(HaveOccurred())
srv, err := comm.NewGRPCServerFromListener(
listener,
comm.ServerConfig{
SecOpts: &comm.SecureOptions{UseTLS: false},
MetricsProvider: fakeProvider,
},
)
gt.Expect(err).NotTo(HaveOccurred())
// register the GRPC test server
testpb.RegisterEmptyServiceServer(srv.Server(), &emptyServiceServer{})
// start the server
go srv.Start()
defer srv.Stop()
// test grpc connection counts
ctx, cancel := context.WithTimeout(context.Background(), timeout)
defer cancel()
gt.Expect(openConn.AddCallCount()).To(Equal(0))
gt.Expect(closedConn.AddCallCount()).To(Equal(0))
//create GRPC client conn
var clientConns []*grpc.ClientConn
for i := 1; i <= 3; i++ {
clientConn, err := grpc.DialContext(ctx, listener.Addr().String(), grpc.WithInsecure())
gt.Expect(err).NotTo(HaveOccurred())
clientConns = append(clientConns, clientConn)
//invoke service
client := testpb.NewEmptyServiceClient(clientConn)
_, err = client.EmptyCall(context.Background(), &testpb.Empty{})
gt.Expect(err).NotTo(HaveOccurred())
gt.Expect(openConn.AddCallCount()).To(Equal(i))
}
for i, conn := range clientConns {
gt.Expect(closedConn.AddCallCount()).Should(Equal(i))
conn.Close()
gt.Eventually(closedConn.AddCallCount, time.Second).Should(Equal(i + 1))
}
}