Lines Matching refs:streamId
136 int streamId = (source.readInt() & 0x7fffffff); // Ignore reserved bit.
137 if (logger.isLoggable(FINE)) logger.fine(formatHeader(true, streamId, length, type, flags));
141 readData(handler, length, flags, streamId);
145 readHeaders(handler, length, flags, streamId);
149 readPriority(handler, length, flags, streamId);
153 readRstStream(handler, length, flags, streamId);
157 readSettings(handler, length, flags, streamId);
161 readPushPromise(handler, length, flags, streamId);
165 readPing(handler, length, flags, streamId);
169 readGoAway(handler, length, flags, streamId);
173 readWindowUpdate(handler, length, flags, streamId);
183 private void readHeaders(Handler handler, int length, byte flags, int streamId)
185 if (streamId == 0) throw ioException("PROTOCOL_ERROR: TYPE_HEADERS streamId == 0");
192 readPriority(handler, streamId);
198 List<Header> headerBlock = readHeaderBlock(length, padding, flags, streamId);
200 handler.headers(false, endStream, streamId, -1, headerBlock, HeadersMode.HTTP_20_HEADERS);
203 private List<Header> readHeaderBlock(int length, short padding, byte flags, int streamId)
208 continuation.streamId = streamId;
216 private void readData(Handler handler, int length, byte flags, int streamId)
228 handler.data(inFinished, streamId, source, length);
232 private void readPriority(Handler handler, int length, byte flags, int streamId)
235 if (streamId == 0) throw ioException("TYPE_PRIORITY streamId == 0");
236 readPriority(handler, streamId);
239 private void readPriority(Handler handler, int streamId) throws IOException {
244 handler.priority(streamId, streamDependency, weight, exclusive);
247 private void readRstStream(Handler handler, int length, byte flags, int streamId)
250 if (streamId == 0) throw ioException("TYPE_RST_STREAM streamId == 0");
256 handler.rstStream(streamId, errorCode);
259 private void readSettings(Handler handler, int length, byte flags, int streamId)
261 if (streamId != 0) throw ioException("TYPE_SETTINGS streamId != 0");
309 private void readPushPromise(Handler handler, int length, byte flags, int streamId)
311 if (streamId == 0) {
312 throw ioException("PROTOCOL_ERROR: TYPE_PUSH_PROMISE streamId == 0");
318 List<Header> headerBlock = readHeaderBlock(length, padding, flags, streamId);
319 handler.pushPromise(streamId, promisedStreamId, headerBlock);
322 private void readPing(Handler handler, int length, byte flags, int streamId)
325 if (streamId != 0) throw ioException("TYPE_PING streamId != 0");
332 private void readGoAway(Handler handler, int length, byte flags, int streamId)
335 if (streamId != 0) throw ioException("TYPE_GOAWAY streamId != 0");
350 private void readWindowUpdate(Handler handler, int length, byte flags, int streamId)
355 handler.windowUpdate(streamId, increment);
390 int streamId = 0;
391 frameHeader(streamId, length, type, flags);
406 int streamId, int associatedStreamId, List<Header> headerBlock)
410 headers(outFinished, streamId, headerBlock);
413 @Override public synchronized void synReply(boolean outFinished, int streamId,
416 headers(outFinished, streamId, headerBlock);
419 @Override public synchronized void headers(int streamId, List<Header> headerBlock)
422 headers(false, streamId, headerBlock);
425 @Override public synchronized void pushPromise(int streamId, int promisedStreamId,
435 frameHeader(streamId, length + 4, type, flags);
439 if (byteCount > length) writeContinuationFrames(streamId, byteCount - length);
442 void headers(boolean outFinished, int streamId, List<Header> headerBlock) throws IOException {
452 frameHeader(streamId, length, type, flags);
455 if (byteCount > length) writeContinuationFrames(streamId, byteCount - length);
458 private void writeContinuationFrames(int streamId, long byteCount) throws IOException {
462 frameHeader(streamId, length, TYPE_CONTINUATION, byteCount == 0 ? FLAG_END_HEADERS : 0);
467 @Override public synchronized void rstStream(int streamId, ErrorCode errorCode)
475 frameHeader(streamId, length, type, flags);
484 @Override public synchronized void data(boolean outFinished, int streamId, Buffer source,
489 dataFrame(streamId, flags, source, byteCount);
492 void dataFrame(int streamId, byte flags, Buffer buffer, int byteCount) throws IOException {
494 frameHeader(streamId, byteCount, type, flags);
505 int streamId = 0;
506 frameHeader(streamId, length, type, flags);
524 int streamId = 0;
525 frameHeader(streamId, length, type, flags);
538 int streamId = 0;
539 frameHeader(streamId, length, type, flags);
548 @Override public synchronized void windowUpdate(int streamId, long windowSizeIncrement)
558 frameHeader(streamId, length, type, flags);
568 void frameHeader(int streamId, int length, byte type, byte flags) throws IOException {
569 if (logger.isLoggable(FINE)) logger.fine(formatHeader(false, streamId, length, type, flags));
573 if ((streamId & 0x80000000) != 0) throw illegalArgument("reserved bit set: %s", streamId);
577 sink.writeInt(streamId & 0x7fffffff);
599 int streamId;
631 int previousStreamId = streamId;
636 if (logger.isLoggable(FINE)) logger.fine(formatHeader(true, streamId, length, type, flags));
637 streamId = (source.readInt() & 0x7fffffff);
639 if (streamId != previousStreamId) throw ioException("TYPE_CONTINUATION streamId changed");
672 static String formatHeader(boolean inbound, int streamId, int length, byte type, byte flags) {
675 return format("%s 0x%08x %5d %-13s %s", inbound ? "<<" : ">>", streamId, length,