Use int64 and moree efficient incrementing

temawi · temawi · commit 44a611785570 · 2023-11-03T15:24:19.000-07:00
diff --git a/stress/client/main.go b/stress/client/main.go
@@ -56,7 +56,7 @@ var (
 	tlsServerName        = flag.String("server_host_override", "foo.test.google.fr", "The server name use to verify the hostname returned by TLS handshake if it is not empty. Otherwise, --server_host is used.")
 	caFile               = flag.String("ca_file", "", "The file containing the CA root cert file")
 
-	totalNumCalls int32
+	totalNumCalls int64
 	logger        = grpclog.Component("stress")
 )
 
@@ -242,7 +242,7 @@ func performRPCs(gauge *gauge, conn *grpc.ClientConn, selector *weightedRandomTe
 			interop.DoCustomMetadata(client, grpc.WaitForReady(true))
 		}
 		numCalls++
-		atomic.AddInt32(&totalNumCalls, 1)
+		defer func() { atomic.AddInt64(&totalNumCalls, numCalls) }()
 		gauge.set(int64(float64(numCalls) / time.Since(startTime).Seconds()))
 
 		select {

Original file line number	Diff line number	Diff line change
`@@ -56,7 +56,7 @@ var (`
`56`	`56`	`tlsServerName = flag.String("server_host_override", "foo.test.google.fr", "The server name use to verify the hostname returned by TLS handshake if it is not empty. Otherwise, --server_host is used.")`
`57`	`57`	`caFile = flag.String("ca_file", "", "The file containing the CA root cert file")`
`58`	`58`
`59`		`- totalNumCalls int32`
	`59`	`+ totalNumCalls int64`
`60`	`60`	`logger = grpclog.Component("stress")`
`61`	`61`	`)`
`62`	`62`
`@@ -242,7 +242,7 @@ func performRPCs(gauge gauge, conn grpc.ClientConn, selector *weightedRandomTe`
`242`	`242`	`interop.DoCustomMetadata(client, grpc.WaitForReady(true))`
`243`	`243`	`}`
`244`	`244`	`numCalls++`
`245`		`- atomic.AddInt32(&totalNumCalls, 1)`
	`245`	`+ defer func() { atomic.AddInt64(&totalNumCalls, numCalls) }()`
`246`	`246`	`gauge.set(int64(float64(numCalls) / time.Since(startTime).Seconds()))`
`247`	`247`
`248`	`248`	`select {`