Home
last modified time | relevance | path

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

12

/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DManagedChannelImplBuilderTest.java260 assertNotNull(builder.decompressorRegistry); in decompressorRegistry_default()
265 DecompressorRegistry decompressorRegistry = DecompressorRegistry.emptyInstance(); in decompressorRegistry_normal() local
266 assertNotEquals(decompressorRegistry, builder.decompressorRegistry); in decompressorRegistry_normal()
267 assertEquals(builder, builder.decompressorRegistry(decompressorRegistry)); in decompressorRegistry_normal()
268 assertEquals(decompressorRegistry, builder.decompressorRegistry); in decompressorRegistry_normal()
273 DecompressorRegistry defaultValue = builder.decompressorRegistry; in decompressorRegistry_null()
274 assertEquals(builder, builder.decompressorRegistry(DecompressorRegistry.emptyInstance())); in decompressorRegistry_null()
275 assertNotEquals(defaultValue, builder.decompressorRegistry); in decompressorRegistry_null()
276 builder.decompressorRegistry(null); in decompressorRegistry_null()
277 assertEquals(defaultValue, builder.decompressorRegistry); in decompressorRegistry_null()
DClientCallImplTest.java104 private final DecompressorRegistry decompressorRegistry = field in ClientCallImplTest
347 .setDecompressorRegistry(decompressorRegistry); in advertisedEncodingsAreSent()
359 assertEquals(decompressorRegistry.getAdvertisedMessageEncodings(), acceptedEncodings); in advertisedEncodingsAreSent()
371 .setDecompressorRegistry(decompressorRegistry); in authorityPropagatedToStream()
387 .setDecompressorRegistry(decompressorRegistry); in callOptionsPropagatedToTransport()
412 .setDecompressorRegistry(decompressorRegistry); in methodInfoDeadlinePropagatedToStream()
430 .setDecompressorRegistry(decompressorRegistry); in methodInfoDeadlinePropagatedToStream()
448 .setDecompressorRegistry(decompressorRegistry); in authorityNotPropagatedToStream()
458 ClientCallImpl.prepareHeaders(m, decompressorRegistry, Codec.Identity.NONE, false); in prepareHeaders_userAgentIgnored()
467 ClientCallImpl.prepareHeaders(m, decompressorRegistry, Codec.Identity.NONE, false); in prepareHeaders_ignoreIdentityEncoding()
[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()
227 private DecompressorRegistry decompressorRegistry = DecompressorRegistry.getDefaultInstance(); field in AbstractClientStream.TransportState
255 private void setDecompressorRegistry(DecompressorRegistry decompressorRegistry) { in setDecompressorRegistry() argument
257 this.decompressorRegistry = in setDecompressorRegistry()
258 checkNotNull(decompressorRegistry, "decompressorRegistry"); in setDecompressorRegistry()
323 Decompressor decompressor = decompressorRegistry.lookupDecompressor(messageEncoding); in inboundHeadersReceived()
DServerCallImpl.java65 private final DecompressorRegistry decompressorRegistry; field in ServerCallImpl
78 DecompressorRegistry decompressorRegistry, CompressorRegistry compressorRegistry, in ServerCallImpl() argument
84 this.decompressorRegistry = decompressorRegistry; in ServerCallImpl()
136 InternalDecompressorRegistry.getRawAdvertisedMessageEncodings(decompressorRegistry); in sendHeadersInternal()
DForwardingClientStream.java86 public void setDecompressorRegistry(DecompressorRegistry decompressorRegistry) { in setDecompressorRegistry() argument
87 delegate().setDecompressorRegistry(decompressorRegistry); in setDecompressorRegistry()
DClientCallImpl.java96 private DecompressorRegistry decompressorRegistry = DecompressorRegistry.getDefaultInstance(); field in ClientCallImpl
153 ClientCallImpl<ReqT, RespT> setDecompressorRegistry(DecompressorRegistry decompressorRegistry) { in setDecompressorRegistry() argument
154 this.decompressorRegistry = decompressorRegistry; in setDecompressorRegistry()
166 DecompressorRegistry decompressorRegistry, in prepareHeaders() argument
177 InternalDecompressorRegistry.getRawAdvertisedMessageEncodings(decompressorRegistry); in prepareHeaders()
251 prepareHeaders(headers, decompressorRegistry, compressor, fullStreamDecompression); in startInternal()
289 stream.setDecompressorRegistry(decompressorRegistry); in startInternal()
DServerImplBuilder.java86 DecompressorRegistry decompressorRegistry = DEFAULT_DECOMPRESSOR_REGISTRY; field in ServerImplBuilder
171 public ServerImplBuilder decompressorRegistry(@Nullable DecompressorRegistry registry) { in decompressorRegistry() method in ServerImplBuilder
172 this.decompressorRegistry = registry != null ? registry : DEFAULT_DECOMPRESSOR_REGISTRY; in decompressorRegistry()
DAbstractServerImplBuilder.java134 public T decompressorRegistry(@Nullable DecompressorRegistry registry) { in decompressorRegistry() method in AbstractServerImplBuilder
135 delegate().decompressorRegistry(registry); in decompressorRegistry()
DClientStream.java69 void setDecompressorRegistry(DecompressorRegistry decompressorRegistry); in setDecompressorRegistry() argument
DDelayedStream.java405 public void setDecompressorRegistry(final DecompressorRegistry decompressorRegistry) {
407 checkNotNull(decompressorRegistry, "decompressorRegistry");
411 realStream.setDecompressorRegistry(decompressorRegistry);
DAbstractManagedChannelImplBuilder.java154 public T decompressorRegistry(DecompressorRegistry registry) { in decompressorRegistry() method in AbstractManagedChannelImplBuilder
155 delegate().decompressorRegistry(registry); in decompressorRegistry()
DManagedChannelImplBuilder.java136 DecompressorRegistry decompressorRegistry = DEFAULT_DECOMPRESSOR_REGISTRY; field in ManagedChannelImplBuilder
382 public ManagedChannelImplBuilder decompressorRegistry(DecompressorRegistry registry) { in decompressorRegistry() method in ManagedChannelImplBuilder
384 this.decompressorRegistry = registry; in decompressorRegistry()
386 this.decompressorRegistry = DEFAULT_DECOMPRESSOR_REGISTRY; in decompressorRegistry()
DNoopClientStream.java79 public void setDecompressorRegistry(DecompressorRegistry decompressorRegistry) {} in setDecompressorRegistry() argument
DServerImpl.java125 private final DecompressorRegistry decompressorRegistry; field in ServerImpl
155 this.decompressorRegistry = builder.decompressorRegistry; in ServerImpl()
485 Decompressor decompressor = decompressorRegistry.lookupDecompressor(encoding); in streamCreatedInternal()
578 decompressorRegistry, in streamCreatedInternal()
DManagedChannelImpl.java194 private final DecompressorRegistry decompressorRegistry; field in ManagedChannelImpl
676 this.decompressorRegistry = checkNotNull(builder.decompressorRegistry, "decompressorRegistry"); in ManagedChannelImpl()
945 .setDecompressorRegistry(decompressorRegistry)
DRetriableStream.java697 public final void setDecompressorRegistry(final DecompressorRegistry decompressorRegistry) { in setDecompressorRegistry() argument
701 substream.stream.setDecompressorRegistry(decompressorRegistry); in setDecompressorRegistry()
/external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/
DAltsServerBuilder.java141 public AltsServerBuilder decompressorRegistry(DecompressorRegistry registry) { in decompressorRegistry() method in AltsServerBuilder
142 delegate.decompressorRegistry(registry); in decompressorRegistry()
/external/grpc-grpc-java/api/src/main/java/io/grpc/
DForwardingServerBuilder.java119 public T decompressorRegistry(@Nullable DecompressorRegistry registry) { in decompressorRegistry() method in ForwardingServerBuilder
120 delegate().decompressorRegistry(registry); in decompressorRegistry()
DForwardingChannelBuilder.java139 public T decompressorRegistry(DecompressorRegistry registry) { in decompressorRegistry() method in ForwardingChannelBuilder
140 delegate().decompressorRegistry(registry); in decompressorRegistry()
DServerBuilder.java218 public abstract T decompressorRegistry(@Nullable DecompressorRegistry registry); in decompressorRegistry() method in ServerBuilder
DManagedChannelBuilder.java272 public abstract T decompressorRegistry(DecompressorRegistry registry); in decompressorRegistry() method in ManagedChannelBuilder
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DTransportCompressionTest.java92 .decompressorRegistry(decompressors) in getServerBuilder()
133 .decompressorRegistry(decompressors) in createChannelBuilder()
DCompressionTest.java189 .decompressorRegistry(serverDecompressors) in compression()
195 .decompressorRegistry(clientDecompressors) in compression()
/external/grpc-grpc-java/binder/src/main/java/io/grpc/binder/internal/
DMultiMessageClientStream.java188 public void setDecompressorRegistry(DecompressorRegistry decompressorRegistry) { in setDecompressorRegistry() argument
DSingleMessageClientStream.java180 public void setDecompressorRegistry(DecompressorRegistry decompressorRegistry) { in setDecompressorRegistry() argument

12