okhttp3.internal.http2

Class Http2Reader

java.lang.Object

okhttp3.internal.http2.Http2Reader

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

final class Http2Reader
extends java.lang.Object
implements java.io.Closeable

Reads HTTP/2 transport frames.

This implementation assumes we do not send an increased frame size setting to the peer. Hence, we expect all frames to have a max length of Http2.INITIAL_MAX_FRAME_SIZE.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	Http2Reader.ContinuationSource Decompression of the header block occurs above the framing layer.
(package private) static interface	Http2Reader.Handler

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	client
private Http2Reader.ContinuationSource	continuation
(package private) Hpack.Reader	hpackReader
(package private) static java.util.logging.Logger	logger
private okio.BufferedSource	source

Constructor Summary

Constructors

Constructor and Description
Http2Reader(okio.BufferedSource source, boolean client) Creates a frame reader with max header table size of 4096.

Method Summary

Modifier and Type	Method and Description
void	close()
(package private) static int	lengthWithoutPadding(int length, byte flags, short padding)
boolean	nextFrame(boolean requireSettings, Http2Reader.Handler handler)
void	readConnectionPreface(Http2Reader.Handler handler)
private void	readData(Http2Reader.Handler handler, int length, byte flags, int streamId)
private void	readGoAway(Http2Reader.Handler handler, int length, byte flags, int streamId)
private java.util.List<Header>	readHeaderBlock(int length, short padding, byte flags, int streamId)
private void	readHeaders(Http2Reader.Handler handler, int length, byte flags, int streamId)
(package private) static int	readMedium(okio.BufferedSource source)
private void	readPing(Http2Reader.Handler handler, int length, byte flags, int streamId)
private void	readPriority(Http2Reader.Handler handler, int streamId)
private void	readPriority(Http2Reader.Handler handler, int length, byte flags, int streamId)
private void	readPushPromise(Http2Reader.Handler handler, int length, byte flags, int streamId)
private void	readRstStream(Http2Reader.Handler handler, int length, byte flags, int streamId)
private void	readSettings(Http2Reader.Handler handler, int length, byte flags, int streamId)
private void	readWindowUpdate(Http2Reader.Handler handler, int length, byte flags, int streamId)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

logger

static final java.util.logging.Logger logger

source

private final okio.BufferedSource source

continuation

private final Http2Reader.ContinuationSource continuation

client

private final boolean client

hpackReader

final Hpack.Reader hpackReader

Constructor Detail

Http2Reader

Http2Reader(okio.BufferedSource source,
            boolean client)

Creates a frame reader with max header table size of 4096.

Method Detail

readConnectionPreface

public void readConnectionPreface(Http2Reader.Handler handler)
                           throws java.io.IOException

Throws:

java.io.IOException

nextFrame

public boolean nextFrame(boolean requireSettings,
                         Http2Reader.Handler handler)
                  throws java.io.IOException

Throws:

java.io.IOException

readHeaders

private void readHeaders(Http2Reader.Handler handler,
                         int length,
                         byte flags,
                         int streamId)
                  throws java.io.IOException

Throws:

java.io.IOException

readHeaderBlock

private java.util.List<Header> readHeaderBlock(int length,
                                               short padding,
                                               byte flags,
                                               int streamId)
                                        throws java.io.IOException

Throws:

java.io.IOException

readData

private void readData(Http2Reader.Handler handler,
                      int length,
                      byte flags,
                      int streamId)
               throws java.io.IOException

Throws:

java.io.IOException

readPriority

private void readPriority(Http2Reader.Handler handler,
                          int length,
                          byte flags,
                          int streamId)
                   throws java.io.IOException

Throws:

java.io.IOException

readPriority

private void readPriority(Http2Reader.Handler handler,
                          int streamId)
                   throws java.io.IOException

Throws:

java.io.IOException

readRstStream

private void readRstStream(Http2Reader.Handler handler,
                           int length,
                           byte flags,
                           int streamId)
                    throws java.io.IOException

Throws:

java.io.IOException

readSettings

private void readSettings(Http2Reader.Handler handler,
                          int length,
                          byte flags,
                          int streamId)
                   throws java.io.IOException

Throws:

java.io.IOException

readPushPromise

private void readPushPromise(Http2Reader.Handler handler,
                             int length,
                             byte flags,
                             int streamId)
                      throws java.io.IOException

Throws:

java.io.IOException

readPing

private void readPing(Http2Reader.Handler handler,
                      int length,
                      byte flags,
                      int streamId)
               throws java.io.IOException

Throws:

java.io.IOException

readGoAway

private void readGoAway(Http2Reader.Handler handler,
                        int length,
                        byte flags,
                        int streamId)
                 throws java.io.IOException

Throws:

java.io.IOException

readWindowUpdate

private void readWindowUpdate(Http2Reader.Handler handler,
                              int length,
                              byte flags,
                              int streamId)
                       throws java.io.IOException

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

readMedium

static int readMedium(okio.BufferedSource source)
               throws java.io.IOException

Throws:

java.io.IOException

lengthWithoutPadding

static int lengthWithoutPadding(int length,
                                byte flags,
                                short padding)
                         throws java.io.IOException

Throws:

java.io.IOException