(ctx context.Context)
| 134 | } |
| 135 | |
| 136 | func buildConnections(ctx context.Context) []*grpc.ClientConn { |
| 137 | ccs := make([]*grpc.ClientConn, *numConn) |
| 138 | for i := range ccs { |
| 139 | ccs[i] = benchmark.NewClientConnWithContext(ctx, "localhost:"+*port, |
| 140 | grpc.WithTransportCredentials(insecure.NewCredentials()), |
| 141 | grpc.WithBlock(), |
| 142 | grpc.WithWriteBufferSize(128*1024), |
| 143 | grpc.WithReadBufferSize(128*1024), |
| 144 | ) |
| 145 | } |
| 146 | return ccs |
| 147 | } |
| 148 | |
| 149 | func runWithConn(cc *grpc.ClientConn, req *testpb.SimpleRequest, warmDeadline, endDeadline time.Time) { |
| 150 | for i := 0; i < *numRPC; i++ { |
no test coverage detected