Home
last modified time | relevance | path

Searched refs:maxInboundMessageSize (Results 1 – 20 of 20) sorted by relevance

/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DServiceConfigInterceptor.java133 final Integer maxInboundMessageSize; field in ServiceConfigInterceptor.MethodInfo
148 maxInboundMessageSize = in MethodInfo()
150 if (maxInboundMessageSize != null) { in MethodInfo()
152 maxInboundMessageSize >= 0, in MethodInfo()
153 "maxInboundMessageSize %s exceeds bounds", maxInboundMessageSize); in MethodInfo()
177 timeoutNanos, waitForReady, maxInboundMessageSize, maxOutboundMessageSize, retryPolicy); in hashCode()
188 && Objects.equal(this.maxInboundMessageSize, that.maxInboundMessageSize) in equals()
198 .add("maxInboundMessageSize", maxInboundMessageSize) in toString()
377 if (info.maxInboundMessageSize != null) { in interceptCall()
381 Math.min(existingLimit, info.maxInboundMessageSize)); in interceptCall()
[all …]
DMessageDeframer.java89 private int maxInboundMessageSize; field in MessageDeframer
125 this.maxInboundMessageSize = maxMessageSize; in MessageDeframer()
136 maxInboundMessageSize = messageSize; in setMaxInboundMessageSize()
383 if (requiredLength < 0 || requiredLength > maxInboundMessageSize) { in processHeader()
386 maxInboundMessageSize, requiredLength)) in processHeader()
432 unlimitedStream, maxInboundMessageSize, statsTraceCtx); in getCompressedBody()
DAbstractManagedChannelImplBuilder.java143 private int maxInboundMessageSize = GrpcUtil.DEFAULT_MAX_MESSAGE_SIZE; field in AbstractManagedChannelImplBuilder
155 public T maxInboundMessageSize(int max) { in maxInboundMessageSize() method in AbstractManagedChannelImplBuilder
157 maxInboundMessageSize = max; in maxInboundMessageSize()
161 protected final int maxInboundMessageSize() { in maxInboundMessageSize() method in AbstractManagedChannelImplBuilder
162 return maxInboundMessageSize; in maxInboundMessageSize()
/external/grpc-grpc-java/core/src/main/java/io/grpc/
DCallOptions.java72 private Integer maxInboundMessageSize; field in CallOptions
376 newOptions.maxInboundMessageSize = maxSize; in withMaxInboundMessageSize()
397 return maxInboundMessageSize; in getMaxInboundMessageSize()
420 maxInboundMessageSize = other.maxInboundMessageSize; in CallOptions()
435 .add("maxInboundMessageSize", maxInboundMessageSize) in toString()
DForwardingChannelBuilder.java155 public T maxInboundMessageSize(int max) { in maxInboundMessageSize() method in ForwardingChannelBuilder
156 delegate().maxInboundMessageSize(max); in maxInboundMessageSize()
DServerBuilder.java222 public T maxInboundMessageSize(int bytes) { in maxInboundMessageSize() method in ServerBuilder
DManagedChannelBuilder.java302 public T maxInboundMessageSize(int bytes) { in maxInboundMessageSize() method in ManagedChannelBuilder
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/
DAutoWindowSizingOnTest.java41 .maxInboundMessageSize(AbstractInteropTest.MAX_MESSAGE_SIZE); in getServerBuilder()
48 .maxInboundMessageSize(AbstractInteropTest.MAX_MESSAGE_SIZE); in createChannel()
DHttp2NettyLocalChannelTest.java41 .maxInboundMessageSize(AbstractInteropTest.MAX_MESSAGE_SIZE) in getServerBuilder()
52 .maxInboundMessageSize(AbstractInteropTest.MAX_MESSAGE_SIZE); in createChannel()
DHttp2NettyTest.java49 .maxInboundMessageSize(AbstractInteropTest.MAX_MESSAGE_SIZE) in getServerBuilder()
67 .maxInboundMessageSize(AbstractInteropTest.MAX_MESSAGE_SIZE) in createChannel()
DTransportCompressionTest.java89 .maxInboundMessageSize(AbstractInteropTest.MAX_MESSAGE_SIZE) in getServerBuilder()
130 .maxInboundMessageSize(AbstractInteropTest.MAX_MESSAGE_SIZE)
DHttp2OkHttpTest.java81 .maxInboundMessageSize(AbstractInteropTest.MAX_MESSAGE_SIZE) in getServerBuilder()
95 .maxInboundMessageSize(AbstractInteropTest.MAX_MESSAGE_SIZE) in createChannelBuilder()
/external/grpc-grpc-java/core/src/main/java/io/grpc/inprocess/
DInProcessChannelBuilder.java81 public final InProcessChannelBuilder maxInboundMessageSize(int max) { in maxInboundMessageSize() method in InProcessChannelBuilder
83 return super.maxInboundMessageSize(max); in maxInboundMessageSize()
/external/grpc-grpc-java/android-interop-testing/app/src/main/java/io/grpc/android/integrationtest/
DTesterOkHttpChannelBuilder.java44 .maxInboundMessageSize(16 * 1024 * 1024); in build()
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DNettyServerBuilder.java268 return maxInboundMessageSize(maxMessageSize); in maxMessageSize()
273 public NettyServerBuilder maxInboundMessageSize(int bytes) { in maxInboundMessageSize() method in NettyServerBuilder
DNettyChannelBuilder.java211 maxInboundMessageSize(maxMessageSize); in maxMessageSize()
386 eventLoopGroup, flowControlWindow, maxInboundMessageSize(), in buildTransportFactory()
/external/grpc-grpc-java/gae-interop-testing/gae-jdk8/src/main/java/io/grpc/testing/integration/
DNettyClientInteropServlet.java136 .maxInboundMessageSize(AbstractInteropTest.MAX_MESSAGE_SIZE); in createChannel()
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/
DTestServiceServer.java150 .maxInboundMessageSize(AbstractInteropTest.MAX_MESSAGE_SIZE) in start()
/external/grpc-grpc-java/gae-interop-testing/gae-jdk7/src/main/java/io/grpc/testing/integration/
DOkHttpClientInteropServlet.java218 .maxInboundMessageSize(AbstractInteropTest.MAX_MESSAGE_SIZE);
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DOkHttpChannelBuilder.java400 createSocketFactory(), hostnameVerifier, connectionSpec, maxInboundMessageSize(), in buildTransportFactory()