@@ -219,27 +219,27 @@ func performRPCs(gauge *gauge, conn *grpc.ClientConn, selector *weightedRandomTe
219
219
test := selector .getNextTest ()
220
220
switch test {
221
221
case "empty_unary" :
222
- interop .DoEmptyUnaryCall (client , grpc . WaitForReady ( true ) )
222
+ interop .DoEmptyUnaryCall (client )
223
223
case "large_unary" :
224
- interop .DoLargeUnaryCall (client , grpc . WaitForReady ( true ) )
224
+ interop .DoLargeUnaryCall (client )
225
225
case "client_streaming" :
226
- interop .DoClientStreaming (client , grpc . WaitForReady ( true ) )
226
+ interop .DoClientStreaming (client )
227
227
case "server_streaming" :
228
- interop .DoServerStreaming (client , grpc . WaitForReady ( true ) )
228
+ interop .DoServerStreaming (client )
229
229
case "ping_pong" :
230
- interop .DoPingPong (client , grpc . WaitForReady ( true ) )
230
+ interop .DoPingPong (client )
231
231
case "empty_stream" :
232
- interop .DoEmptyStream (client , grpc . WaitForReady ( true ) )
232
+ interop .DoEmptyStream (client )
233
233
case "timeout_on_sleeping_server" :
234
- interop .DoTimeoutOnSleepingServer (client , grpc . WaitForReady ( true ) )
234
+ interop .DoTimeoutOnSleepingServer (client )
235
235
case "cancel_after_begin" :
236
- interop .DoCancelAfterBegin (client , grpc . WaitForReady ( true ) )
236
+ interop .DoCancelAfterBegin (client )
237
237
case "cancel_after_first_response" :
238
- interop .DoCancelAfterFirstResponse (client , grpc . WaitForReady ( true ) )
238
+ interop .DoCancelAfterFirstResponse (client )
239
239
case "status_code_and_message" :
240
- interop .DoStatusCodeAndMessage (client , grpc . WaitForReady ( true ) )
240
+ interop .DoStatusCodeAndMessage (client )
241
241
case "custom_metadata" :
242
- interop .DoCustomMetadata (client , grpc . WaitForReady ( true ) )
242
+ interop .DoCustomMetadata (client )
243
243
}
244
244
numCalls ++
245
245
defer func () { atomic .AddInt64 (& totalNumCalls , numCalls ) }()
0 commit comments