Home
last modified time | relevance | path

Searched refs:maxMessageSize (Results 1 – 25 of 27) sorted by relevance

12

/external/grpc-grpc-java/cronet/src/main/java/io/grpc/cronet/
DCronetChannelBuilder.java84 private int maxMessageSize = DEFAULT_MAX_MESSAGE_SIZE; field in CronetChannelBuilder
102 public final CronetChannelBuilder maxMessageSize(int maxMessageSize) { in maxMessageSize() method in CronetChannelBuilder
103 checkArgument(maxMessageSize >= 0, "maxMessageSize must be >= 0"); in maxMessageSize()
104 this.maxMessageSize = maxMessageSize; in maxMessageSize()
192 maxMessageSize, in buildTransportFactory()
207 private final int maxMessageSize; field in CronetChannelBuilder.CronetTransportFactory
217 int maxMessageSize, in CronetTransportFactory() argument
223 this.maxMessageSize = maxMessageSize; in CronetTransportFactory()
235 options.getUserAgent(), executor, maxMessageSize, alwaysUsePut, transportTracer); in newClientTransport()
DCronetClientTransport.java59 private final int maxMessageSize; field in CronetClientTransport
86 int maxMessageSize, in CronetClientTransport() argument
92 this.maxMessageSize = maxMessageSize; in CronetClientTransport()
122 url, userAgent, executor, headers, CronetClientTransport.this, this, lock, maxMessageSize, in newStream()
DCronetClientStream.java91 int maxMessageSize, in CronetClientStream() argument
112 this.state = new TransportState(maxMessageSize, statsTraceCtx, lock, transportTracer); in CronetClientStream()
230 int maxMessageSize, StatsTraceContext statsTraceCtx, Object lock, in TransportState() argument
232 super(maxMessageSize, statsTraceCtx, transportTracer); in TransportState()
/external/nist-sip/java/gov/nist/javax/sip/parser/
DPipelinedMsgParser.java75 private int maxMessageSize; field in PipelinedMsgParser
106 Pipeline in, boolean debug, int maxMessageSize) { in PipelinedMsgParser() argument
110 this.maxMessageSize = maxMessageSize; in PipelinedMsgParser()
191 if (this.maxMessageSize > 0) { in readLine()
219 this.sizeCounter = this.maxMessageSize; in run()
307 } else if (maxMessageSize == 0 in run()
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DMessageDeframer.java120 int maxMessageSize, in MessageDeframer() argument
125 this.maxInboundMessageSize = maxMessageSize; in MessageDeframer()
443 private final int maxMessageSize; field in MessageDeframer.SizeEnforcingInputStream
449 SizeEnforcingInputStream(InputStream in, int maxMessageSize, StatsTraceContext statsTraceCtx) { in SizeEnforcingInputStream() argument
451 this.maxMessageSize = maxMessageSize; in SizeEnforcingInputStream()
514 if (count > maxMessageSize) { in verifySize()
517 maxMessageSize, count)).asRuntimeException(); in verifySize()
DAbstractStream.java136 int maxMessageSize, in TransportState() argument
144 maxMessageSize, in TransportState()
DHttp2ClientStreamTransportState.java68 int maxMessageSize, in Http2ClientStreamTransportState() argument
71 super(maxMessageSize, statsTraceCtx, transportTracer); in Http2ClientStreamTransportState()
DAbstractServerStream.java203 int maxMessageSize, in TransportState() argument
207 maxMessageSize, in TransportState()
DAbstractClientStream.java235 int maxMessageSize, in TransportState() argument
238 super(maxMessageSize, statsTraceCtx, transportTracer); in TransportState()
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
DNettyChannelBuilder.java210 public NettyChannelBuilder maxMessageSize(int maxMessageSize) { in maxMessageSize() argument
211 maxInboundMessageSize(maxMessageSize); in maxMessageSize()
491 private final int maxMessageSize; field in NettyChannelBuilder.NettyTransportFactory
503 EventLoopGroup group, int flowControlWindow, int maxMessageSize, int maxHeaderListSize, in NettyTransportFactory() argument
510 this.maxMessageSize = maxMessageSize; in NettyTransportFactory()
552 maxMessageSize, maxHeaderListSize, keepAliveTimeNanosState.get(), keepAliveTimeoutNanos, in newClientTransport()
DNettyServerBuilder.java82 private int maxMessageSize = DEFAULT_MAX_MESSAGE_SIZE; field in NettyServerBuilder
267 public NettyServerBuilder maxMessageSize(int maxMessageSize) { in maxMessageSize() method in NettyServerBuilder
268 return maxInboundMessageSize(maxMessageSize); in maxMessageSize()
275 this.maxMessageSize = bytes; in maxInboundMessageSize()
436 maxMessageSize, maxHeaderListSize, keepAliveTimeInNanos, keepAliveTimeoutInNanos, in buildTransportServer()
DNettyServerTransport.java68 private final int maxMessageSize; field in NettyServerTransport
88 int maxMessageSize, in NettyServerTransport() argument
105 this.maxMessageSize = maxMessageSize; in NettyServerTransport()
262 maxMessageSize, in createHandler()
DNettyClientTransport.java76 private final int maxMessageSize; field in NettyClientTransport
100 ProtocolNegotiator negotiator, int flowControlWindow, int maxMessageSize, in NettyClientTransport() argument
111 this.maxMessageSize = maxMessageSize; in NettyClientTransport()
166 maxMessageSize, in newStream()
DNettyServer.java83 private final int maxMessageSize; field in NettyServer
107 int maxStreamsPerConnection, int flowControlWindow, int maxMessageSize, int maxHeaderListSize, in NettyServer() argument
126 this.maxMessageSize = maxMessageSize; in NettyServer()
200 maxMessageSize, in start()
DNettyServerHandler.java106 private final int maxMessageSize; field in NettyServerHandler
140 int maxMessageSize, in newHandler() argument
165 maxMessageSize, in newHandler()
186 int maxMessageSize, in newHandler() argument
197 Preconditions.checkArgument(maxMessageSize > 0, "maxMessageSize must be positive"); in newHandler()
228 maxMessageSize, in newHandler()
244 int maxMessageSize, in NettyServerHandler() argument
291 checkArgument(maxMessageSize >= 0, "maxMessageSize must be >= 0"); in NettyServerHandler()
292 this.maxMessageSize = maxMessageSize; in NettyServerHandler()
426 maxMessageSize, in onHeadersRead()
DNettyServerStream.java165 int maxMessageSize, in TransportState() argument
168 super(maxMessageSize, statsTraceCtx, transportTracer); in TransportState()
DNettyClientStream.java220 int maxMessageSize, in TransportState() argument
223 super(maxMessageSize, statsTraceCtx, transportTracer); in TransportState()
/external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/
DOkHttpChannelBuilder.java475 private final int maxMessageSize; field in OkHttpChannelBuilder.OkHttpTransportFactory
488 int maxMessageSize, in OkHttpTransportFactory() argument
500 this.maxMessageSize = maxMessageSize; in OkHttpTransportFactory()
539 maxMessageSize, in newClientTransport()
DOkHttpClientStream.java72 int maxMessageSize, in OkHttpClientStream() argument
91 this.state = new TransportState(maxMessageSize, statsTraceCtx, lock, frameWriter, outboundFlow, in OkHttpClientStream()
207 int maxMessageSize, in TransportState() argument
213 super(maxMessageSize, statsTraceCtx, OkHttpClientStream.this.getTransportTracer()); in TransportState()
DOkHttpClientTransport.java156 private final int maxMessageSize; field in OkHttpClientTransport
209 int maxMessageSize, @Nullable ProxyParameters proxy, Runnable tooManyPingsRunnable, in OkHttpClientTransport() argument
213 this.maxMessageSize = maxMessageSize; in OkHttpClientTransport()
245 int maxMessageSize, in OkHttpClientTransport() argument
249 this.maxMessageSize = maxMessageSize; in OkHttpClientTransport()
346 maxMessageSize, in newStream()
/external/nist-sip/java/gov/nist/javax/sip/
DSipStackImpl.java902 super.maxMessageSize = new Integer(maxMsgSize).intValue(); in SipStackImpl()
903 if (super.maxMessageSize < 4096) in SipStackImpl()
904 super.maxMessageSize = 4096; in SipStackImpl()
907 super.maxMessageSize = 0; in SipStackImpl()
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DAbstractServerStreamTest.java378 protected TransportState(int maxMessageSize, TransportTracer transportTracer) { in TransportState() argument
379 super(maxMessageSize, StatsTraceContext.NOOP, transportTracer); in TransportState()
/external/lz4/tests/
Dfuzzer.c1396 const int maxMessageSize = 1 << maxMessageSizeLog; in FUZ_unitTests() local
1397 const int maxMessageSizeMask = maxMessageSize - 1; in FUZ_unitTests()
1400 const int dBufferSize = LZ4_decoderRingBufferSize(maxMessageSize); in FUZ_unitTests()
1415 #define BSIZE1 (dBufferSize - (maxMessageSize-1)) in FUZ_unitTests()
1444 messageSize = maxMessageSize; in FUZ_unitTests()
1462 assert(dBufferSize - dNext >= maxMessageSize); in FUZ_unitTests()
1488 if (dNext + maxMessageSize > dBufferSize) dNext = 0; in FUZ_unitTests()
/external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/
DNettyClientStreamTest.java548 public TransportStateImpl(NettyClientHandler handler, int maxMessageSize) { in TransportStateImpl() argument
549 super(handler, channel.eventLoop(), maxMessageSize, StatsTraceContext.NOOP, transportTracer); in TransportStateImpl()
DNettyClientHandlerTest.java761 int maxMessageSize, in TransportStateImpl() argument
763 super(handler, eventLoop, maxMessageSize, StatsTraceContext.NOOP, transportTracer); in TransportStateImpl()

12