Searched refs:censusStats (Results 1 – 4 of 4) sorted by relevance
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/ |
| D | TestingAccessor.java | 27 AbstractManagedChannelImplBuilder<?> builder, CensusStatsModule censusStats) { in setStatsImplementation() argument
28 builder.overrideCensusStatsModule(censusStats); in setStatsImplementation()
35 AbstractServerImplBuilder<?> builder, CensusStatsModule censusStats) { in setStatsImplementation() argument
36 builder.overrideCensusStatsModule(censusStats); in setStatsImplementation()
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | AbstractServerImplBuilder.java | 214 protected T overrideCensusStatsModule(CensusStatsModule censusStats) { in overrideCensusStatsModule() argument
215 this.censusStatsOverride = censusStats; in overrideCensusStatsModule()
266 CensusStatsModule censusStats = this.censusStatsOverride; in getTracerFactories() local
267 if (censusStats == null) { in getTracerFactories()
268 censusStats = new CensusStatsModule(GrpcUtil.STOPWATCH_SUPPLIER, true); in getTracerFactories()
271 censusStats.getServerTracerFactory(recordStartedRpcs, recordFinishedRpcs)); in getTracerFactories()
|
| D | AbstractManagedChannelImplBuilder.java | 353 protected final T overrideCensusStatsModule(CensusStatsModule censusStats) { in overrideCensusStatsModule() argument
354 this.censusStatsOverride = censusStats; in overrideCensusStatsModule()
425 CensusStatsModule censusStats = this.censusStatsOverride; in getEffectiveInterceptors() local
426 if (censusStats == null) { in getEffectiveInterceptors()
427 censusStats = new CensusStatsModule(GrpcUtil.STOPWATCH_SUPPLIER, true); in getEffectiveInterceptors()
432 0, censusStats.getClientInterceptor(recordStartedRpcs, recordFinishedRpcs)); in getEffectiveInterceptors()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | CensusModulesTest.java | 176 private CensusStatsModule censusStats; field in CensusModulesTest
193 censusStats = in setUp()
244 censusStats.getClientInterceptor(true, true), censusTracing.getClientInterceptor()); in testClientInterceptors()
358 censusStats.newClientCallTracer( in subtestClientBasicStatsDefaultContext()
485 censusStats.newClientCallTracer( in clientStreamNeverCreatedStillRecordStats()
665 censusStats.newClientCallTracer(tagger.empty(), method.getFullMethodName(), false, false); in statsHeadersNotPropagateDefaultContext()
668 assertFalse(headers.containsKey(censusStats.statsHeader)); in statsHeadersNotPropagateDefaultContext()
686 assertNull(headers.get(censusStats.statsHeader)); in statsHeaderMalformed()
688 assertSame(tagger.empty(), headers.get(censusStats.statsHeader)); in statsHeaderMalformed()
808 censusStats.getServerTracerFactory(recordStarts, recordFinishes); in subtestServerBasicStatsNoHeaders()
|