Home
last modified time | relevance | path

Searched refs:decompressorRegistry (Results 1 – 21 of 21) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DAbstractManagedChannelImplBuilderTest.java162 assertNotNull(builder.decompressorRegistry); in decompressorRegistry_default()
167 DecompressorRegistry decompressorRegistry = DecompressorRegistry.emptyInstance(); in decompressorRegistry_normal() local
168 assertNotEquals(decompressorRegistry, builder.decompressorRegistry); in decompressorRegistry_normal()
169 assertEquals(builder, builder.decompressorRegistry(decompressorRegistry)); in decompressorRegistry_normal()
170 assertEquals(decompressorRegistry, builder.decompressorRegistry); in decompressorRegistry_normal()
175 DecompressorRegistry defaultValue = builder.decompressorRegistry; in decompressorRegistry_null()
176 assertEquals(builder, builder.decompressorRegistry(DecompressorRegistry.emptyInstance())); in decompressorRegistry_null()
177 assertNotEquals(defaultValue, builder.decompressorRegistry); in decompressorRegistry_null()
178 builder.decompressorRegistry(null); in decompressorRegistry_null()
179 assertEquals(defaultValue, builder.decompressorRegistry); in decompressorRegistry_null()
DClientCallImplTest.java92 private final DecompressorRegistry decompressorRegistry = field in ClientCallImplTest
282 .setDecompressorRegistry(decompressorRegistry); in advertisedEncodingsAreSent()
293 assertEquals(decompressorRegistry.getAdvertisedMessageEncodings(), acceptedEncodings); in advertisedEncodingsAreSent()
306 .setDecompressorRegistry(decompressorRegistry); in authorityPropagatedToStream()
323 .setDecompressorRegistry(decompressorRegistry); in callOptionsPropagatedToTransport()
342 .setDecompressorRegistry(decompressorRegistry); in authorityNotPropagatedToStream()
352 ClientCallImpl.prepareHeaders(m, decompressorRegistry, Codec.Identity.NONE, false); in prepareHeaders_userAgentIgnored()
361 ClientCallImpl.prepareHeaders(m, decompressorRegistry, Codec.Identity.NONE, false); in prepareHeaders_ignoreIdentityEncoding()
416 ClientCallImpl.prepareHeaders(m, decompressorRegistry, Codec.Identity.NONE, false); in prepareHeaders_noAcceptedContentEncodingsWithoutFullStreamDecompressionEnabled()
513 .setDecompressorRegistry(decompressorRegistry); in callerContextPropagatedToListener()
[all …]
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DAbstractClientStream.java147 public final void setDecompressorRegistry(DecompressorRegistry decompressorRegistry) { in setDecompressorRegistry() argument
148 transportState().setDecompressorRegistry(decompressorRegistry); in setDecompressorRegistry()
218 private DecompressorRegistry decompressorRegistry = DecompressorRegistry.getDefaultInstance(); field in AbstractClientStream.TransportState
246 private void setDecompressorRegistry(DecompressorRegistry decompressorRegistry) { in setDecompressorRegistry() argument
248 this.decompressorRegistry = in setDecompressorRegistry()
249 checkNotNull(decompressorRegistry, "decompressorRegistry"); in setDecompressorRegistry()
318 Decompressor decompressor = decompressorRegistry.lookupDecompressor(messageEncoding); in inboundHeadersReceived()
DServerCallImpl.java56 private final DecompressorRegistry decompressorRegistry; field in ServerCallImpl
69 DecompressorRegistry decompressorRegistry, CompressorRegistry compressorRegistry, in ServerCallImpl() argument
75 this.decompressorRegistry = decompressorRegistry; in ServerCallImpl()
115 InternalDecompressorRegistry.getRawAdvertisedMessageEncodings(decompressorRegistry); in sendHeaders()
DClientCallImpl.java85 private DecompressorRegistry decompressorRegistry = DecompressorRegistry.getDefaultInstance(); field in ClientCallImpl
144 ClientCallImpl<ReqT, RespT> setDecompressorRegistry(DecompressorRegistry decompressorRegistry) { in setDecompressorRegistry() argument
145 this.decompressorRegistry = decompressorRegistry; in setDecompressorRegistry()
157 DecompressorRegistry decompressorRegistry, in prepareHeaders() argument
167 InternalDecompressorRegistry.getRawAdvertisedMessageEncodings(decompressorRegistry); in prepareHeaders()
231 prepareHeaders(headers, decompressorRegistry, compressor, fullStreamDecompression); in start()
271 stream.setDecompressorRegistry(decompressorRegistry); in start()
DAbstractServerImplBuilder.java99 DecompressorRegistry decompressorRegistry = DEFAULT_DECOMPRESSOR_REGISTRY; field in AbstractServerImplBuilder
178 public final T decompressorRegistry(DecompressorRegistry registry) { in decompressorRegistry() method in AbstractServerImplBuilder
180 decompressorRegistry = registry; in decompressorRegistry()
182 decompressorRegistry = DEFAULT_DECOMPRESSOR_REGISTRY; in decompressorRegistry()
DForwardingClientStream.java81 public void setDecompressorRegistry(DecompressorRegistry decompressorRegistry) { in setDecompressorRegistry() argument
82 delegate().setDecompressorRegistry(decompressorRegistry); in setDecompressorRegistry()
DAbstractManagedChannelImplBuilder.java122 DecompressorRegistry decompressorRegistry = DEFAULT_DECOMPRESSOR_REGISTRY; field in AbstractManagedChannelImplBuilder
254 public final T decompressorRegistry(DecompressorRegistry registry) { in decompressorRegistry() method in AbstractManagedChannelImplBuilder
256 this.decompressorRegistry = registry; in decompressorRegistry()
258 this.decompressorRegistry = DEFAULT_DECOMPRESSOR_REGISTRY; in decompressorRegistry()
DDelayedStream.java328 public void setDecompressorRegistry(final DecompressorRegistry decompressorRegistry) { in setDecompressorRegistry() argument
329 checkNotNull(decompressorRegistry, "decompressorRegistry"); in setDecompressorRegistry()
333 realStream.setDecompressorRegistry(decompressorRegistry); in setDecompressorRegistry()
DServerImpl.java113 private final DecompressorRegistry decompressorRegistry; field in ServerImpl
139 this.decompressorRegistry = builder.decompressorRegistry; in ServerImpl()
422 Decompressor decompressor = decompressorRegistry.lookupDecompressor(encoding); in streamCreated()
558 decompressorRegistry, in startWrappedCall()
DClientStream.java69 void setDecompressorRegistry(DecompressorRegistry decompressorRegistry); in setDecompressorRegistry() argument
DNoopClientStream.java76 public void setDecompressorRegistry(DecompressorRegistry decompressorRegistry) {} in setDecompressorRegistry() argument
DManagedChannelImpl.java138 private final DecompressorRegistry decompressorRegistry; field in ManagedChannelImpl
603 this.decompressorRegistry = checkNotNull(builder.decompressorRegistry, "decompressorRegistry"); in ManagedChannelImpl()
825 .setDecompressorRegistry(decompressorRegistry) in newCall()
DRetriableStream.java457 public final void setDecompressorRegistry(final DecompressorRegistry decompressorRegistry) { in setDecompressorRegistry() argument
461 substream.stream.setDecompressorRegistry(decompressorRegistry); in setDecompressorRegistry()
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DForwardingChannelBuilder.java137 public T decompressorRegistry(DecompressorRegistry registry) { in decompressorRegistry() method in ForwardingChannelBuilder
138 delegate().decompressorRegistry(registry); in decompressorRegistry()
DServerBuilder.java180 public abstract T decompressorRegistry(@Nullable DecompressorRegistry registry); in decompressorRegistry() method in ServerBuilder
DManagedChannelBuilder.java258 public abstract T decompressorRegistry(DecompressorRegistry registry); in decompressorRegistry() method in ManagedChannelBuilder
/external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/
DAltsServerBuilder.java164 public AltsServerBuilder decompressorRegistry(DecompressorRegistry registry) { in decompressorRegistry() method in AltsServerBuilder
165 delegate.decompressorRegistry(registry); in decompressorRegistry()
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DTransportCompressionTest.java91 .decompressorRegistry(decompressors) in getServerBuilder()
131 .decompressorRegistry(decompressors)
DCompressionTest.java188 .decompressorRegistry(serverDecompressors) in compression()
193 .decompressorRegistry(clientDecompressors) in compression()
/external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/
DInProcessTransport.java673 public void setDecompressorRegistry(DecompressorRegistry decompressorRegistry) {}