| /external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/ |
| CronetChannelBuilder.java | 84 private int maxMessageSize = DEFAULT_MAX_MESSAGE_SIZE;
102 public final CronetChannelBuilder maxMessageSize(int maxMessageSize) {
103 checkArgument(maxMessageSize >= 0, "maxMessageSize must be >= 0");
104 this.maxMessageSize = maxMessageSize;
192 maxMessageSize,
207 private final int maxMessageSize;
217 int maxMessageSize,
[all...] |
| CronetClientTransport.java | 59 private final int maxMessageSize;
86 int maxMessageSize,
92 this.maxMessageSize = maxMessageSize;
123 url, userAgent, executor, headers, CronetClientTransport.this, this, lock, maxMessageSize,
|
| CronetClientStream.java | 91 int maxMessageSize,
112 this.state = new TransportState(maxMessageSize, statsTraceCtx, lock, transportTracer);
230 int maxMessageSize, StatsTraceContext statsTraceCtx, Object lock,
232 super(maxMessageSize, statsTraceCtx, transportTracer);
|
| /external/nist-sip/java/gov/nist/javax/sip/parser/ |
| PipelinedMsgParser.java | 75 private int maxMessageSize;
106 Pipeline in, boolean debug, int maxMessageSize) {
110 this.maxMessageSize = maxMessageSize;
191 if (this.maxMessageSize > 0) {
219 this.sizeCounter = this.maxMessageSize;
307 } else if (maxMessageSize == 0
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| MessageDeframer.java | 115 * @param maxMessageSize the maximum allowed size for received messages.
120 int maxMessageSize,
125 this.maxInboundMessageSize = maxMessageSize;
428 // Enforce the maxMessageSize limit on the returned stream.
439 * An {@link InputStream} that enforces the {@link #maxMessageSize} limit for compressed frames.
443 private final int maxMessageSize;
449 SizeEnforcingInputStream(InputStream in, int maxMessageSize, StatsTraceContext statsTraceCtx) {
451 this.maxMessageSize = maxMessageSize;
514 if (count > maxMessageSize) {
[all...] |
| AbstractStream.java | 136 int maxMessageSize,
144 maxMessageSize,
|
| Http2ClientStreamTransportState.java | 68 int maxMessageSize,
71 super(maxMessageSize, statsTraceCtx, transportTracer);
|
| AbstractServerStream.java | 203 int maxMessageSize,
207 maxMessageSize,
|
| AbstractClientStream.java | 235 int maxMessageSize,
238 super(maxMessageSize, statsTraceCtx, transportTracer);
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| NettyServerTransport.java | 68 private final int maxMessageSize;
88 int maxMessageSize,
105 this.maxMessageSize = maxMessageSize;
262 maxMessageSize,
|
| NettyServerBuilder.java | 82 private int maxMessageSize = DEFAULT_MAX_MESSAGE_SIZE;
267 public NettyServerBuilder maxMessageSize(int maxMessageSize) {
268 return maxInboundMessageSize(maxMessageSize);
275 this.maxMessageSize = bytes;
436 maxMessageSize, maxHeaderListSize, keepAliveTimeInNanos, keepAliveTimeoutInNanos,
|
| NettyChannelBuilder.java | 209 public NettyChannelBuilder maxMessageSize(int maxMessageSize) {
210 maxInboundMessageSize(maxMessageSize);
468 private final int maxMessageSize;
479 EventLoopGroup group, int flowControlWindow, int maxMessageSize, int maxHeaderListSize,
486 this.maxMessageSize = maxMessageSize;
524 maxMessageSize, maxHeaderListSize, keepAliveTimeNanosState.get(), keepAliveTimeoutNanos,
|
| NettyClientTransport.java | 75 private final int maxMessageSize;
98 ProtocolNegotiator negotiator, int flowControlWindow, int maxMessageSize,
108 this.maxMessageSize = maxMessageSize;
162 maxMessageSize,
|
| NettyServer.java | 83 private final int maxMessageSize;
107 int maxStreamsPerConnection, int flowControlWindow, int maxMessageSize, int maxHeaderListSize,
126 this.maxMessageSize = maxMessageSize;
200 maxMessageSize,
|
| NettyServerHandler.java | 106 private final int maxMessageSize;
140 int maxMessageSize,
165 maxMessageSize,
186 int maxMessageSize,
197 Preconditions.checkArgument(maxMessageSize > 0, "maxMessageSize must be positive");
228 maxMessageSize,
244 int maxMessageSize,
291 checkArgument(maxMessageSize >= 0, "maxMessageSize must be >= 0")
[all...] |
| NettyServerStream.java | 165 int maxMessageSize,
168 super(maxMessageSize, statsTraceCtx, transportTracer);
|
| NettyClientStream.java | 220 int maxMessageSize,
223 super(maxMessageSize, statsTraceCtx, transportTracer);
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| OkHttpClientStream.java | 72 int maxMessageSize,
91 this.state = new TransportState(maxMessageSize, statsTraceCtx, lock, frameWriter, outboundFlow,
207 int maxMessageSize,
213 super(maxMessageSize, statsTraceCtx, OkHttpClientStream.this.getTransportTracer());
|
| OkHttpChannelBuilder.java | 475 private final int maxMessageSize;
488 int maxMessageSize,
500 this.maxMessageSize = maxMessageSize;
539 maxMessageSize,
|
| OkHttpClientTransport.java | 156 private final int maxMessageSize;
209 int maxMessageSize, @Nullable ProxyParameters proxy, Runnable tooManyPingsRunnable,
213 this.maxMessageSize = maxMessageSize;
245 int maxMessageSize,
249 this.maxMessageSize = maxMessageSize;
346 maxMessageSize,
[all...] |
| /cts/tests/tests/media/src/android/media/cts/ |
| MidiSoloTest.java | 52 public MyMidiReceiver(int maxMessageSize) {
53 super(maxMessageSize);
|
| /external/nist-sip/java/gov/nist/javax/sip/ |
| SipStackImpl.java | [all...] |
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| AbstractServerStreamTest.java | 378 protected TransportState(int maxMessageSize, TransportTracer transportTracer) {
379 super(maxMessageSize, StatsTraceContext.NOOP, transportTracer);
|
| /external/lz4/tests/ |
| fuzzer.c | [all...] |
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| NettyClientHandlerTest.java | 761 int maxMessageSize,
763 super(handler, eventLoop, maxMessageSize, StatsTraceContext.NOOP, transportTracer);
|
