HomeSort by relevance Sort by last modified time
    Searched refs:MetricsRecord (Results 1 - 3 of 3) sorted by null

  /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/
StatsTestUtils.java 65 public static class MetricsRecord {
70 private MetricsRecord(
128 private BlockingQueue<MetricsRecord> records;
139 public MetricsRecord pollRecord() {
143 public MetricsRecord pollRecord(long timeout, TimeUnit unit) throws InterruptedException {
154 records = new LinkedBlockingQueue<MetricsRecord>();
157 private synchronized BlockingQueue<MetricsRecord> getCurrentRecordSink() {
224 private final BlockingQueue<MetricsRecord> recordSink;
245 recordSink.add(new MetricsRecord(getTags(tags), ImmutableMap.copyOf(metrics)));
  /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
CensusModulesTest.java 280 StatsTestUtils.MetricsRecord record = statsRecorder.pollRecord();
364 StatsTestUtils.MetricsRecord record = statsRecorder.pollRecord();
399 StatsTestUtils.MetricsRecord record = statsRecorder.pollRecord();
492 StatsTestUtils.MetricsRecord record = statsRecorder.pollRecord();
582 StatsTestUtils.MetricsRecord clientRecord = statsRecorder.pollRecord();
617 StatsTestUtils.MetricsRecord serverRecord = statsRecorder.pollRecord();
645 StatsTestUtils.MetricsRecord clientRecord = statsRecorder.pollRecord();
    [all...]
  /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
AbstractInteropTest.java 76 import io.grpc.internal.testing.StatsTestUtils.MetricsRecord;
767 MetricsRecord clientStartRecord = clientStatsRecorder.pollRecord(5, TimeUnit.SECONDS);
772 MetricsRecord clientEndRecord = clientStatsRecorder.pollRecord(5, TimeUnit.SECONDS);
    [all...]

Completed in 470 milliseconds