| /external/grpc-grpc-java/benchmarks/src/jmh/java/io/grpc/benchmarks/netty/ |
| StreamingPingPongsPerSecondBenchmark.java | 48 public int maxConcurrentStreams = 1;
84 maxConcurrentStreams,
89 latch = startStreamingCalls(maxConcurrentStreams, callCounter, record, completed, 1);
|
| StreamingResponseBandwidthBenchmark.java | 43 public int maxConcurrentStreams = 1;
85 maxConcurrentStreams,
90 latch = startFlowControlledStreamingCalls(maxConcurrentStreams, callCounter, record, completed,
|
| UnaryCallQpsBenchmark.java | 42 public int maxConcurrentStreams = 100;
76 maxConcurrentStreams,
80 startUnaryCalls(maxConcurrentStreams, callCounter, completed, 1);
|
| UnaryCallResponseBandwidthBenchmark.java | 41 public int maxConcurrentStreams = 1;
82 maxConcurrentStreams,
86 startUnaryCalls(maxConcurrentStreams, callCounter, completed, responseSize.bytes());
|
| FlowControlledMessagesPerSecondBenchmark.java | 49 public int maxConcurrentStreams = 1;
91 maxConcurrentStreams,
97 startFlowControlledStreamingCalls(maxConcurrentStreams, callCounter, record, completed, 1);
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| NettyServerHandlerTest.java | 133 private int maxConcurrentStreams = Integer.MAX_VALUE;
367 maxConcurrentStreams = 314;
374 assertEquals(maxConcurrentStreams, captor.getValue().maxConcurrentStreams().intValue());
[all...] |
| /external/syzkaller/vendor/golang.org/x/net/http2/ |
| server.go | 91 // MaxConcurrentStreams optionally specifies the number of
95 // If zero, MaxConcurrentStreams defaults to at least 100, per
97 MaxConcurrentStreams uint32
158 func (s *Server) maxConcurrentStreams() uint32 {
159 if v := s.MaxConcurrentStreams; v > 0 {
347 advMaxStreams: s.maxConcurrentStreams(),
[all...] |
| /external/grpc-grpc-java/okhttp/src/main/java/io/grpc/okhttp/ |
| OkHttpClientTransport.java | 179 private int maxConcurrentStreams = 0;
358 } else if (streams.size() >= maxConcurrentStreams) {
395 while (!pendingStreams.isEmpty() && streams.size() < maxConcurrentStreams) {
438 maxConcurrentStreams = Integer.MAX_VALUE;
505 maxConcurrentStreams = Integer.MAX_VALUE;
[all...] |
| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/internal/framed/ |
| FramedConnection.java | 212 public synchronized int maxConcurrentStreams() {
[all...] |
| /external/okhttp/repackaged/okhttp/src/main/java/com/android/okhttp/internal/framed/ |
| FramedConnection.java | 214 public synchronized int maxConcurrentStreams() {
[all...] |
| /external/grpc-grpc-java/netty/shaded/ |
| grpc-netty-shaded-1.14.0.jar | |
