Skip to content

Commit

Permalink
Clean comments.
Browse files Browse the repository at this point in the history
  • Loading branch information
zbilun committed Dec 30, 2024
1 parent 85e2438 commit 0395c79
Showing 1 changed file with 0 additions and 28 deletions.
28 changes: 0 additions & 28 deletions interop/client/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -375,39 +375,11 @@ func main() {
interop.DoPickFirstUnary(ctx, tc)
logger.Infoln("PickFirstUnary done")
case "rpc_soak":
//rpcSoakConfig := interop.SoakTestConfig{
// RequestSize: *soakRequestSize,
// ResponseSize: *soakResponseSize,
// PerIterationMaxAcceptableLatency: time.Duration(*soakPerIterationMaxAcceptableLatencyMs) * time.Millisecond,
// MinTimeBetweenRPCs: time.Duration(*soakMinTimeMsBetweenRPCs) * time.Millisecond,
// OverallTimeout: time.Duration(*soakOverallTimeoutSeconds) * time.Second,
// ServerAddr: serverAddr,
// NumWorkers: *soakNumWorkers,
// Iterations: *soakIterations,
// MaxFailures: *soakMaxFailures,
// SharedChannel: conn,
// MayCreateNewChannel: interop.UseSharedChannel,
//}
rpcSoakConfig := createBaseSoakConfig(serverAddr, conn)
rpcSoakConfig.MayCreateNewChannel = interop.UseSharedChannel
interop.DoSoakTest(ctxWithDeadline, rpcSoakConfig)
logger.Infoln("RpcSoak done")
case "channel_soak":
//channelSoakConfig := interop.SoakTestConfig{
// RequestSize: *soakRequestSize,
// ResponseSize: *soakResponseSize,
// PerIterationMaxAcceptableLatency: time.Duration(*soakPerIterationMaxAcceptableLatencyMs) * time.Millisecond,
// MinTimeBetweenRPCs: time.Duration(*soakMinTimeMsBetweenRPCs) * time.Millisecond,
// OverallTimeout: time.Duration(*soakOverallTimeoutSeconds) * time.Second,
// ServerAddr: serverAddr,
// NumWorkers: *soakNumWorkers,
// Iterations: *soakIterations,
// MaxFailures: *soakMaxFailures,
// SharedChannel: conn,
// MayCreateNewChannel: func(currentChannel *grpc.ClientConn) (*grpc.ClientConn, testgrpc.TestServiceClient) {
// return interop.CreateNewChannel(currentChannel, serverAddr, opts)
// },
//}
channelSoakConfig := createBaseSoakConfig(serverAddr, conn)
channelSoakConfig.MayCreateNewChannel = func(currentChannel *grpc.ClientConn) (*grpc.ClientConn, testgrpc.TestServiceClient) {
return interop.CreateNewChannel(currentChannel, serverAddr, opts)
Expand Down

0 comments on commit 0395c79

Please sign in to comment.