Searched refs:nextStreamId (Results 1 – 5 of 5) sorted by relevance
149 private int nextStreamId; field in OkHttpClientTransport218 nextStreamId = 3; in OkHttpClientTransport()240 int nextStreamId, in OkHttpClientTransport() argument257 this.nextStreamId = nextStreamId; in OkHttpClientTransport()370 streams.put(nextStreamId, stream); in startStream()372 stream.transportState().start(nextStreamId); in startStream()378 if (nextStreamId >= Integer.MAX_VALUE - 2) { in startStream()381 nextStreamId = Integer.MAX_VALUE; in startStream()385 nextStreamId += 2; in startStream()904 return streamId < nextStreamId && (streamId & 1) == 1; in mayHaveCreatedStream()
89 private int nextStreamId; field in FramedConnection139 nextStreamId = builder.client ? 1 : 2; in FramedConnection()141 nextStreamId += 2; // In HTTP/2, 1 on client is reserved for Upgrade. in FramedConnection()266 streamId = nextStreamId; in newStream()267 nextStreamId += 2; in newStream()669 if (streamId % 2 == nextStreamId % 2) return; in headers()
87 private int nextStreamId; field in FramedConnection137 nextStreamId = builder.client ? 1 : 2; in FramedConnection()139 nextStreamId += 2; // In HTTP/2, 1 on client is reserved for Upgrade. in FramedConnection()264 streamId = nextStreamId; in newStream()265 nextStreamId += 2; in newStream()664 if (streamId % 2 == nextStreamId % 2) return; in headers()
720 int nextStreamId = connection().local().incrementAndGetNextStreamId(); in incrementAndGetNextStreamId() local721 if (nextStreamId < 0) { in incrementAndGetNextStreamId()726 return nextStreamId; in incrementAndGetNextStreamId()
META-INF/ META-INF/MANIFEST.MF io/ io/grpc/ io/ ...