grpc / grpc-java / #19558

coverage: 88.561% (+0.02%) from 88.545%
#19558

push

github

web-flow 
interop-testing: Add concurrency condition to the soak test using existing blocking api

The goal of this PR is to increase the test coverage of the C2P E2E load test by improving the rpc_soak and channel_soak tests to support concurrency.

**rpc_soak:**
The client performs many large_unary RPCs in sequence over the same channel. The test can run in either a concurrent or non-concurrent mode, depending on the number of threads specified (soak_num_threads):
  - Non-Concurrent Mode: When soak_num_threads = 1, all RPCs are performed sequentially on a single thread.
  - Concurrent Mode: When soak_num_threads > 1, the client uses multiple threads to distribute the workload. Each thread performs a portion of the total soak_iterations, executing its own set of RPCs concurrently.

**channel_soak:**
Similar to rpc_soak, but this time each RPC is performed on a new channel. The channel is created just before each RPC and is destroyed just after. Note on Concurrent Execution and Channel Creation: In a concurrent execution setting (i.e., when soak_num_threads > 1), each thread performs a portion of the total soak_iterations and creates and destroys its own channel for each RPC iteration.
- createNewChannel Function: In channel_soak, the createNewChannel function is used by each thread to create a new channel before every RPC. This function ensures that each RPC has a separate channel, preventing race conditions by isolating channels between threads. It shuts down the previous channel (if any) and creates a new one for each iteration, ensuring accurate latency measurement per RPC.

- Thread-specific logs will include the thread_id, helping to track performance across threads, especially when each thread is managing its own channel lifecycle.

33259 of 37555 relevant lines covered (88.56%)

0.89 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0
/../grpclb/src/main/java/io/grpc/grpclb/InternalGrpclbConstantsAccessor.java
1 
/*
2 
 * Copyright 2020 The gRPC Authors
3 
 *
4 
 * Licensed under the Apache License, Version 2.0 (the "License");
5 
 * you may not use this file except in compliance with the License.
6 
 * You may obtain a copy of the License at
7 
 *
8 
 *     http://www.apache.org/licenses/LICENSE-2.0
9 
 *
10 
 * Unless required by applicable law or agreed to in writing, software
11 
 * distributed under the License is distributed on an "AS IS" BASIS,
12 
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 
 * See the License for the specific language governing permissions and
14 
 * limitations under the License.
15 
 */
16 









17



package io.grpc.grpclb;










18












19



import io.grpc.Attributes;










20



import io.grpc.EquivalentAddressGroup;










21



import io.grpc.Internal;










22



import java.util.List;










23












24



/**










25



 * Internal {@link GrpclbConstants} accessor. This is intended for usage internal to the gRPC










26



 * team. If you *really* think you need to use this, contact the gRPC team first.










27



 */










28



@Internal










29



public final class InternalGrpclbConstantsAccessor {










30












31



  // Prevent instantiation.










32



  private InternalGrpclbConstantsAccessor() {










33



  }










34












35



  public static final Attributes.Key<List<EquivalentAddressGroup>> ATTR_LB_ADDRS =




×







36



      GrpclbConstants.ATTR_LB_ADDRS;










37












38



  @EquivalentAddressGroup.Attr










39



  public static final Attributes.Key<String> ATTR_LB_ADDR_AUTHORITY =




×







40



      GrpclbConstants.ATTR_LB_ADDR_AUTHORITY;










41



}
























    

  • 

    •