Class ChannelzBenchmark

core/src/jmh/java/io/grpc/internal/ChannelzBenchmark.java:38–148

Javadoc.

 * Javadoc.
 */
@State(Scope.Benchmark)
public class ChannelzBenchmark {
  // Number of items already present
  @Param({"10", "100", "1000", "10000"})
  public int preexisting;

  public InternalChannelz channelz = new InternalChannelz();

  public InternalInstrumented<ServerStats> serverToRemove;

  public InternalInstrumented<ServerStats> serverToAdd;

  public InternalInstrumented<ServerStats> serverForServerSocket;
  public InternalInstrumented<SocketStats> serverSocketToAdd;
  public InternalInstrumented<SocketStats> serverSocketToRemove;

  /**
   * Javadoc.
   */
  @Setup
  @SuppressWarnings({"unchecked", "rawtypes"})
  public void setUp() {
    serverToRemove = create();
    channelz.addServer(serverToRemove);

    serverForServerSocket = create();
    channelz.addServer(serverForServerSocket);

    serverSocketToRemove = create();
    channelz.addClientSocket(serverSocketToRemove);
    channelz.addServerSocket(serverForServerSocket, serverSocketToRemove);

    populate(preexisting);

    serverToAdd = create();
    serverSocketToAdd = create();
  }

  private void populate(int count) {
    for (int i = 0; i < count; i++) {
      // for addNavigable / removeNavigable
      InternalInstrumented<ServerStats> srv = create();
      channelz.addServer(srv);

      // for add / remove
      InternalInstrumented<SocketStats> sock = create();
      channelz.addClientSocket(sock);

      // for addServerSocket / removeServerSocket
      channelz.addServerSocket(serverForServerSocket, sock);
    }
  }

  @Benchmark
  @BenchmarkMode(Mode.SampleTime)
  @OutputTimeUnit(TimeUnit.NANOSECONDS)
  public void addNavigable() {
    channelz.addServer(serverToAdd);