opensource/grpc-go
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Add logging of new flags

Browse Source
This commit is contained in:
Noah Eisen
2016-11-28 17:06:54 -08:00
parent e9ab07574f
commit 87da90422f
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
stress/client/main.go
View File

@ -253,6 +253,9 @@ func logParameterInfo(addresses []string, tests []testCaseWithWeight) {
grpclog.Printf("num_channels_per_server: %d", *numChannelsPerServer) grpclog.Printf("num_channels_per_server: %d", *numChannelsPerServer)
grpclog.Printf("num_stubs_per_channel: %d", *numStubsPerChannel) grpclog.Printf("num_stubs_per_channel: %d", *numStubsPerChannel)
grpclog.Printf("metrics_port: %d", *metricsPort) grpclog.Printf("metrics_port: %d", *metricsPort)
grpclog.Printf("use_tls: %t", *useTLS)
grpclog.Printf("use_test_ca: %t", *testCA)
grpclog.Printf("server_host_override: %s", *tlsServerName)
grpclog.Println("addresses:") grpclog.Println("addresses:")
for i, addr := range addresses { for i, addr := range addresses {
@ -264,7 +267,7 @@ func logParameterInfo(addresses []string, tests []testCaseWithWeight) {
} }
} }
func getChannel(address string, useTLS, testCA bool, tlsServerName string) (*grpc.ClientConn, error) { func newConn(address string, useTLS, testCA bool, tlsServerName string) (*grpc.ClientConn, error) {
var opts []grpc.DialOption var opts []grpc.DialOption
if useTLS { if useTLS {
var sn string var sn string
@ -302,7 +305,7 @@ func main() {
for serverIndex, address := range addresses { for serverIndex, address := range addresses {
for connIndex := 0; connIndex < *numChannelsPerServer; connIndex++ { for connIndex := 0; connIndex < *numChannelsPerServer; connIndex++ {
conn, err := getChannel(address, *useTLS, *testCA, *tlsServerName) conn, err := newConn(address, *useTLS, *testCA, *tlsServerName)
if err != nil { if err != nil {
grpclog.Fatalf("Fail to dial: %v", err) grpclog.Fatalf("Fail to dial: %v", err)
} }