Class ChannelTracerTest

core/src/test/java/io/grpc/internal/ChannelTracerTest.java:40–167

Unit tests for ChannelTracer.

 * Unit tests for {@link ChannelTracer}.
 */
@RunWith(JUnit4.class)
public class ChannelTracerTest {
  private static final Logger logger = Logger.getLogger(ChannelLogger.class.getName());
  private final ArrayList<LogRecord> logs = new ArrayList<>();
  private final Handler handler = new Handler() {
      @Override
      public void publish(LogRecord record) {
        logs.add(record);
      }

      @Override
      public void flush() {
      }

      @Override
      public void close() throws SecurityException {
      }
    };

  private final InternalLogId logId = InternalLogId.allocate("test", /*details=*/ null);
  private final String logPrefix = "[" + logId + "] ";

  @Before
  public void setUp() {
    logger.addHandler(handler);
    logger.setLevel(Level.ALL);
  }

  @After
  public void tearDown() {
    logger.removeHandler(handler);
  }

  @Test
  public void channelTracerWithZeroMaxEvents() {
    ChannelTracer channelTracer =
        new ChannelTracer(logId, /* maxEvents= */ 0, /* channelCreationTimeNanos= */ 3L, "fooType");
    ChannelStats.Builder builder = new ChannelStats.Builder();
    Event e1 = new Event.Builder()
        .setDescription("e1").setSeverity(Severity.CT_ERROR).setTimestampNanos(1001).build();
    channelTracer.reportEvent(e1);

    channelTracer.updateBuilder(builder);
    ChannelStats stats = builder.build();
    assertThat(stats.channelTrace).isNull();

    assertThat(logs).hasSize(2);
    LogRecord log = logs.remove(0);
    assertThat(log.getMessage()).isEqualTo(logPrefix + "fooType created");
    assertThat(log.getLevel()).isEqualTo(Level.FINEST);
    log = logs.remove(0);
    assertThat(log.getMessage()).isEqualTo(logPrefix + "e1");
    assertThat(log.getLevel()).isEqualTo(Level.FINE);
  }

  @Test
  public void reportEvents() {
    ChannelTracer channelTracer =