| /external/grpc-grpc-java/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/ |
| D | UnaryCallQpsBenchmark.java | 42 public int maxConcurrentStreams = 100; field in UnaryCallQpsBenchmark
76 maxConcurrentStreams, in setup()
80 startUnaryCalls(maxConcurrentStreams, callCounter, completed, 1); in setup()
|
| D | UnaryCallResponseBandwidthBenchmark.java | 41 public int maxConcurrentStreams = 1; field in UnaryCallResponseBandwidthBenchmark
82 maxConcurrentStreams, in setup()
86 startUnaryCalls(maxConcurrentStreams, callCounter, completed, responseSize.bytes()); in setup()
|
| D | StreamingPingPongsPerSecondBenchmark.java | 48 public int maxConcurrentStreams = 1; field in StreamingPingPongsPerSecondBenchmark
84 maxConcurrentStreams, in setup()
89 latch = startStreamingCalls(maxConcurrentStreams, callCounter, record, completed, 1); in setup()
|
| D | StreamingResponseBandwidthBenchmark.java | 43 public int maxConcurrentStreams = 1; field in StreamingResponseBandwidthBenchmark
85 maxConcurrentStreams, in setup()
90 latch = startFlowControlledStreamingCalls(maxConcurrentStreams, callCounter, record, completed, in setup()
|
| D | FlowControlledMessagesPerSecondBenchmark.java | 49 public int maxConcurrentStreams = 1; field in FlowControlledMessagesPerSecondBenchmark
91 maxConcurrentStreams, in setup()
97 startFlowControlledStreamingCalls(maxConcurrentStreams, callCounter, record, completed, 1); in setup()
|
| D | AbstractBenchmark.java | 193 int maxConcurrentStreams, in setup() argument
229 serverBuilder.maxConcurrentCallsPerConnection(maxConcurrentStreams); in setup()
|
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| D | OkHttpClientTransport.java | 179 private int maxConcurrentStreams = 0; field in OkHttpClientTransport
358 } else if (streams.size() >= maxConcurrentStreams) { in streamReadyToStart()
395 while (!pendingStreams.isEmpty() && streams.size() < maxConcurrentStreams) { in startPendingStreams()
438 maxConcurrentStreams = Integer.MAX_VALUE; in start()
506 maxConcurrentStreams = Integer.MAX_VALUE; in start()
1079 maxConcurrentStreams = receivedMaxConcurrentStreams; in settings()
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | NettyServerHandlerTest.java | 133 private int maxConcurrentStreams = Integer.MAX_VALUE; field in NettyServerHandlerTest
367 maxConcurrentStreams = 314; in shouldAdvertiseMaxConcurrentStreams()
374 assertEquals(maxConcurrentStreams, captor.getValue().maxConcurrentStreams().intValue()); in shouldAdvertiseMaxConcurrentStreams()
1068 maxConcurrentStreams, in newHandler()
|
| D | NettyClientHandlerTest.java | 679 ByteBuf serializedSettings = serializeSettings(new Http2Settings().maxConcurrentStreams(max)); in receiveMaxConcurrentStreams()
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/ |
| D | Spdy3ConnectionTest.java | 281 final AtomicInteger maxConcurrentStreams = new AtomicInteger();
287 maxConcurrentStreams.set(connection.maxConcurrentStreams());
298 assertEquals(10, maxConcurrentStreams.get());
|
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/io/ |
| D | RealConnection.java | 346 ? framedConnection.maxConcurrentStreams() in allocationLimit()
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/io/ |
| D | RealConnection.java | 342 ? framedConnection.maxConcurrentStreams() in allocationLimit()
|
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/ |
| D | FramedConnection.java | 212 public synchronized int maxConcurrentStreams() { in maxConcurrentStreams() method in FramedConnection
|
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/framed/ |
| D | FramedConnection.java | 214 public synchronized int maxConcurrentStreams() { in maxConcurrentStreams() method in FramedConnection
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | NettyClientHandler.java | 201 settings.maxConcurrentStreams(0); in newHandler()
|
| D | NettyServerHandler.java | 218 settings.maxConcurrentStreams(maxStreams); in newHandler()
|