META-INF/
META-INF/MANIFEST.MF
io/
io/grpc/
io/grpc/okhttp/
io/grpc/okhttp/Headers.classHeaders.java
package io.grpc.okhttp
public io.grpc.okhttp.Headers extends java.lang.Object {
public static final io.grpc.okhttp.internal.framed.Header SCHEME_HEADER
public static final io.grpc.okhttp.internal.framed.Header METHOD_HEADER
public static final io.grpc.okhttp.internal.framed.Header CONTENT_TYPE_HEADER
public static final io.grpc.okhttp.internal.framed.Header TE_HEADER
public void ()
public static java.util.List createRequestHeaders (io.grpc.Metadata, java.lang.String, java.lang.String, java.lang.String)
okio.ByteString value
okio.ByteString key
String keyString
int i
io.grpc.Metadata headers
String defaultPath
String authority
String userAgent
java.util.List okhttpHeaders
String path
byte[][] serializedHeaders
private static boolean isApplicationHeader (java.lang.String)
String key
static void ()
}
io/grpc/okhttp/internal/
io/grpc/okhttp/internal/framed/
io/grpc/okhttp/internal/framed/Header.classHeader.java
package io.grpc.okhttp.internal.framed
public final io.grpc.okhttp.internal.framed.Header extends java.lang.Object {
public static final okio.ByteString RESPONSE_STATUS
public static final okio.ByteString TARGET_METHOD
public static final okio.ByteString TARGET_PATH
public static final okio.ByteString TARGET_SCHEME
public static final okio.ByteString TARGET_AUTHORITY
public static final okio.ByteString TARGET_HOST
public static final okio.ByteString VERSION
public final okio.ByteString name
public final okio.ByteString value
final int hpackSize
public void (java.lang.String, java.lang.String)
String name
String value
public void (okio.ByteString, java.lang.String)
okio.ByteString name
String value
public void (okio.ByteString, okio.ByteString)
okio.ByteString name
okio.ByteString value
public boolean equals (java.lang.Object)
io.grpc.okhttp.internal.framed.Header that
Object other
public int hashCode ()
int result
public java.lang.String toString ()
static void ()
}
io/grpc/okhttp/internal/framed/Settings.classSettings.java
package io.grpc.okhttp.internal.framed
public final io.grpc.okhttp.internal.framed.Settings extends java.lang.Object {
static final int DEFAULT_INITIAL_WINDOW_SIZE
static final int FLAG_CLEAR_PREVIOUSLY_PERSISTED_SETTINGS
static final int PERSIST_VALUE
static final int PERSISTED
static final int UPLOAD_BANDWIDTH
static final int HEADER_TABLE_SIZE
static final int DOWNLOAD_BANDWIDTH
static final int ENABLE_PUSH
static final int ROUND_TRIP_TIME
public static final int MAX_CONCURRENT_STREAMS
static final int CURRENT_CWND
static final int MAX_FRAME_SIZE
static final int DOWNLOAD_RETRANS_RATE
static final int MAX_HEADER_LIST_SIZE
public static final int INITIAL_WINDOW_SIZE
static final int CLIENT_CERTIFICATE_VECTOR_SIZE
static final int FLOW_CONTROL_OPTIONS
static final int COUNT
static final int FLOW_CONTROL_OPTIONS_DISABLED
private int set
private int persistValue
private int persisted
private final int[] values
public void ()
void clear ()
public io.grpc.okhttp.internal.framed.Settings set (int, int, int)
int id
int idFlags
int value
int bit
public boolean isSet (int)
int id
int bit
public int get (int)
int id
int flags (int)
int id
int result
int size ()
int getUploadBandwidth (int)
int defaultValue
int bit
int getHeaderTableSize ()
int bit
int getDownloadBandwidth (int)
int defaultValue
int bit
boolean getEnablePush (boolean)
boolean defaultValue
int bit
int getRoundTripTime (int)
int defaultValue
int bit
int getMaxConcurrentStreams (int)
int defaultValue
int bit
int getCurrentCwnd (int)
int defaultValue
int bit
int getMaxFrameSize (int)
int defaultValue
int bit
int getDownloadRetransRate (int)
int defaultValue
int bit
int getMaxHeaderListSize (int)
int defaultValue
int bit
int getInitialWindowSize (int)
int defaultValue
int bit
int getClientCertificateVectorSize (int)
int defaultValue
int bit
boolean isFlowControlDisabled ()
int bit
int value
boolean persistValue (int)
int id
int bit
boolean isPersisted (int)
int id
int bit
void merge (io.grpc.okhttp.internal.framed.Settings)
int i
io.grpc.okhttp.internal.framed.Settings other
}
io/grpc/okhttp/internal/framed/FrameWriter.classFrameWriter.java
package io.grpc.okhttp.internal.framed
public abstract io.grpc.okhttp.internal.framed.FrameWriter extends java.lang.Object implements java.io.Closeable {
public abstract void connectionPreface () throws java.io.IOException
public abstract void ackSettings (io.grpc.okhttp.internal.framed.Settings) throws java.io.IOException
public abstract void pushPromise (int, int, java.util.List) throws java.io.IOException
public abstract void flush () throws java.io.IOException
public abstract void synStream (boolean, boolean, int, int, java.util.List) throws java.io.IOException
public abstract void synReply (boolean, int, java.util.List) throws java.io.IOException
public abstract void headers (int, java.util.List) throws java.io.IOException
public abstract void rstStream (int, io.grpc.okhttp.internal.framed.ErrorCode) throws java.io.IOException
public abstract int maxDataLength ()
public abstract void data (boolean, int, okio.Buffer, int) throws java.io.IOException
public abstract void settings (io.grpc.okhttp.internal.framed.Settings) throws java.io.IOException
public abstract void ping (boolean, int, int) throws java.io.IOException
public abstract void goAway (int, io.grpc.okhttp.internal.framed.ErrorCode, byte[]) throws java.io.IOException
public abstract void windowUpdate (int, long) throws java.io.IOException
}
io/grpc/okhttp/internal/framed/ErrorCode.classErrorCode.java
package io.grpc.okhttp.internal.framed
public final enum io.grpc.okhttp.internal.framed.ErrorCode extends java.lang.Enum {
public static final enum io.grpc.okhttp.internal.framed.ErrorCode NO_ERROR
public static final enum io.grpc.okhttp.internal.framed.ErrorCode PROTOCOL_ERROR
public static final enum io.grpc.okhttp.internal.framed.ErrorCode INVALID_STREAM
public static final enum io.grpc.okhttp.internal.framed.ErrorCode UNSUPPORTED_VERSION
public static final enum io.grpc.okhttp.internal.framed.ErrorCode STREAM_IN_USE
public static final enum io.grpc.okhttp.internal.framed.ErrorCode STREAM_ALREADY_CLOSED
public static final enum io.grpc.okhttp.internal.framed.ErrorCode INTERNAL_ERROR
public static final enum io.grpc.okhttp.internal.framed.ErrorCode FLOW_CONTROL_ERROR
public static final enum io.grpc.okhttp.internal.framed.ErrorCode STREAM_CLOSED
public static final enum io.grpc.okhttp.internal.framed.ErrorCode FRAME_TOO_LARGE
public static final enum io.grpc.okhttp.internal.framed.ErrorCode REFUSED_STREAM
public static final enum io.grpc.okhttp.internal.framed.ErrorCode CANCEL
public static final enum io.grpc.okhttp.internal.framed.ErrorCode COMPRESSION_ERROR
public static final enum io.grpc.okhttp.internal.framed.ErrorCode CONNECT_ERROR
public static final enum io.grpc.okhttp.internal.framed.ErrorCode ENHANCE_YOUR_CALM
public static final enum io.grpc.okhttp.internal.framed.ErrorCode INADEQUATE_SECURITY
public static final enum io.grpc.okhttp.internal.framed.ErrorCode HTTP_1_1_REQUIRED
public static final enum io.grpc.okhttp.internal.framed.ErrorCode INVALID_CREDENTIALS
public final int httpCode
public final int spdyRstCode
public final int spdyGoAwayCode
private static final synthetic io.grpc.okhttp.internal.framed.ErrorCode[] $VALUES
public static io.grpc.okhttp.internal.framed.ErrorCode[] values ()
public static io.grpc.okhttp.internal.framed.ErrorCode valueOf (java.lang.String)
String name
private void (java.lang.String, int, int, int, int)
int httpCode
int spdyRstCode
int spdyGoAwayCode
public static io.grpc.okhttp.internal.framed.ErrorCode fromSpdy3Rst (int)
io.grpc.okhttp.internal.framed.ErrorCode errorCode
int code
public static io.grpc.okhttp.internal.framed.ErrorCode fromHttp2 (int)
io.grpc.okhttp.internal.framed.ErrorCode errorCode
int code
public static io.grpc.okhttp.internal.framed.ErrorCode fromSpdyGoAway (int)
io.grpc.okhttp.internal.framed.ErrorCode errorCode
int code
static void ()
}
io/grpc/okhttp/internal/framed/FrameReader$Handler.classFrameReader.java
package io.grpc.okhttp.internal.framed
public abstract io.grpc.okhttp.internal.framed.FrameReader$Handler extends java.lang.Object {
public abstract void data (boolean, int, okio.BufferedSource, int) throws java.io.IOException
public abstract void headers (boolean, boolean, int, int, java.util.List, io.grpc.okhttp.internal.framed.HeadersMode)
public abstract void rstStream (int, io.grpc.okhttp.internal.framed.ErrorCode)
public abstract void settings (boolean, io.grpc.okhttp.internal.framed.Settings)
public abstract void ackSettings ()
public abstract void ping (boolean, int, int)
public abstract void goAway (int, io.grpc.okhttp.internal.framed.ErrorCode, okio.ByteString)
public abstract void windowUpdate (int, long)
public abstract void priority (int, int, int, boolean)
public abstract void pushPromise (int, int, java.util.List) throws java.io.IOException
public abstract void alternateService (int, java.lang.String, okio.ByteString, java.lang.String, int, long)
}
io/grpc/okhttp/internal/framed/FrameReader.classFrameReader.java
package io.grpc.okhttp.internal.framed
public abstract io.grpc.okhttp.internal.framed.FrameReader extends java.lang.Object implements java.io.Closeable {
public abstract void readConnectionPreface () throws java.io.IOException
public abstract boolean nextFrame (io.grpc.okhttp.internal.framed.FrameReader$Handler) throws java.io.IOException
}
io/grpc/okhttp/internal/framed/HeadersMode.classHeadersMode.java
package io.grpc.okhttp.internal.framed
public final enum io.grpc.okhttp.internal.framed.HeadersMode extends java.lang.Enum {
public static final enum io.grpc.okhttp.internal.framed.HeadersMode SPDY_SYN_STREAM
public static final enum io.grpc.okhttp.internal.framed.HeadersMode SPDY_REPLY
public static final enum io.grpc.okhttp.internal.framed.HeadersMode SPDY_HEADERS
public static final enum io.grpc.okhttp.internal.framed.HeadersMode HTTP_20_HEADERS
private static final synthetic io.grpc.okhttp.internal.framed.HeadersMode[] $VALUES
public static io.grpc.okhttp.internal.framed.HeadersMode[] values ()
public static io.grpc.okhttp.internal.framed.HeadersMode valueOf (java.lang.String)
String name
private void (java.lang.String, int)
public boolean failIfStreamAbsent ()
public boolean failIfStreamPresent ()
public boolean failIfHeadersAbsent ()
public boolean failIfHeadersPresent ()
static void ()
}
io/grpc/okhttp/internal/framed/Hpack$Reader.classHpack.java
package io.grpc.okhttp.internal.framed
final io.grpc.okhttp.internal.framed.Hpack$Reader extends java.lang.Object {
private final java.util.List headerList
private final okio.BufferedSource source
private int headerTableSizeSetting
private int maxDynamicTableByteCount
io.grpc.okhttp.internal.framed.Header[] dynamicTable
int nextHeaderIndex
int headerCount
int dynamicTableByteCount
void (int, okio.Source)
int headerTableSizeSetting
okio.Source source
int maxDynamicTableByteCount ()
void headerTableSizeSetting (int)
int headerTableSizeSetting
private void adjustDynamicTableByteCount ()
private void clearDynamicTable ()
private int evictToRecoverBytes (int)
int j
int bytesToRecover
int entriesToEvict
void readHeaders () throws java.io.IOException
int index
int index
int index
int b
public java.util.List getAndResetHeaderList ()
java.util.List result
private void readIndexedHeader (int) throws java.io.IOException
io.grpc.okhttp.internal.framed.Header staticEntry
int dynamicTableIndex
int index
private int dynamicTableIndex (int)
int index
private void readLiteralHeaderWithoutIndexingIndexedName (int) throws java.io.IOException
int index
okio.ByteString name
okio.ByteString value
private void readLiteralHeaderWithoutIndexingNewName () throws java.io.IOException
okio.ByteString name
okio.ByteString value
private void readLiteralHeaderWithIncrementalIndexingIndexedName (int) throws java.io.IOException
int nameIndex
okio.ByteString name
okio.ByteString value
private void readLiteralHeaderWithIncrementalIndexingNewName () throws java.io.IOException
okio.ByteString name
okio.ByteString value
private okio.ByteString getName (int)
int index
private boolean isStaticHeader (int)
int index
private void insertIntoDynamicTable (int, io.grpc.okhttp.internal.framed.Header)
io.grpc.okhttp.internal.framed.Header[] doubled
int index
io.grpc.okhttp.internal.framed.Header entry
int delta
int bytesToRecover
int entriesEvicted
private int readByte () throws java.io.IOException
int readInt (int, int) throws java.io.IOException
int b
int firstByte
int prefixMask
int prefix
int result
int shift
okio.ByteString readByteString () throws java.io.IOException
int firstByte
boolean huffmanDecode
int length
}
io/grpc/okhttp/internal/framed/Hpack$Writer.classHpack.java
package io.grpc.okhttp.internal.framed
final io.grpc.okhttp.internal.framed.Hpack$Writer extends java.lang.Object {
private final okio.Buffer out
void (okio.Buffer)
okio.Buffer out
void writeHeaders (java.util.List) throws java.io.IOException
okio.ByteString name
Integer staticIndex
int i
int size
java.util.List headerBlock
void writeInt (int, int, int) throws java.io.IOException
int b
int value
int prefixMask
int bits
void writeByteString (okio.ByteString) throws java.io.IOException
okio.ByteString data
}
io/grpc/okhttp/internal/framed/Hpack.classHpack.java
package io.grpc.okhttp.internal.framed
final io.grpc.okhttp.internal.framed.Hpack extends java.lang.Object {
private static final int PREFIX_4_BITS
private static final int PREFIX_5_BITS
private static final int PREFIX_6_BITS
private static final int PREFIX_7_BITS
private static final io.grpc.okhttp.internal.framed.Header[] STATIC_HEADER_TABLE
private static final java.util.Map NAME_TO_FIRST_INDEX
private void ()
private static java.util.Map nameToFirstIndex ()
int i
java.util.Map result
private static okio.ByteString checkLowercase (okio.ByteString) throws java.io.IOException
byte c
int i
int length
okio.ByteString name
static synthetic io.grpc.okhttp.internal.framed.Header[] access$000 ()
static synthetic okio.ByteString access$100 (okio.ByteString) throws java.io.IOException
okio.ByteString x0
static synthetic java.util.Map access$200 ()
static void ()
}
io/grpc/okhttp/internal/framed/Http2$Reader.classHttp2.java
package io.grpc.okhttp.internal.framed
final io.grpc.okhttp.internal.framed.Http2$Reader extends java.lang.Object implements io.grpc.okhttp.internal.framed.FrameReader {
private final okio.BufferedSource source
private final io.grpc.okhttp.internal.framed.Http2$ContinuationSource continuation
private final boolean client
final io.grpc.okhttp.internal.framed.Hpack$Reader hpackReader
void (okio.BufferedSource, int, boolean)
okio.BufferedSource source
int headerTableSize
boolean client
public void readConnectionPreface () throws java.io.IOException
okio.ByteString connectionPreface
public boolean nextFrame (io.grpc.okhttp.internal.framed.FrameReader$Handler) throws java.io.IOException
java.io.IOException e
io.grpc.okhttp.internal.framed.FrameReader$Handler handler
int length
byte type
byte flags
int streamId
private void readHeaders (io.grpc.okhttp.internal.framed.FrameReader$Handler, int, byte, int) throws java.io.IOException
io.grpc.okhttp.internal.framed.FrameReader$Handler handler
int length
byte flags
int streamId
boolean endStream
short padding
java.util.List headerBlock
private java.util.List readHeaderBlock (int, short, byte, int) throws java.io.IOException
int length
short padding
byte flags
int streamId
private void readData (io.grpc.okhttp.internal.framed.FrameReader$Handler, int, byte, int) throws java.io.IOException
io.grpc.okhttp.internal.framed.FrameReader$Handler handler
int length
byte flags
int streamId
boolean inFinished
boolean gzipped
short padding
private void readPriority (io.grpc.okhttp.internal.framed.FrameReader$Handler, int, byte, int) throws java.io.IOException
io.grpc.okhttp.internal.framed.FrameReader$Handler handler
int length
byte flags
int streamId
private void readPriority (io.grpc.okhttp.internal.framed.FrameReader$Handler, int) throws java.io.IOException
io.grpc.okhttp.internal.framed.FrameReader$Handler handler
int streamId
int w1
boolean exclusive
int streamDependency
int weight
private void readRstStream (io.grpc.okhttp.internal.framed.FrameReader$Handler, int, byte, int) throws java.io.IOException
io.grpc.okhttp.internal.framed.FrameReader$Handler handler
int length
byte flags
int streamId
int errorCodeInt
io.grpc.okhttp.internal.framed.ErrorCode errorCode
private void readSettings (io.grpc.okhttp.internal.framed.FrameReader$Handler, int, byte, int) throws java.io.IOException
short id
int value
int i
io.grpc.okhttp.internal.framed.FrameReader$Handler handler
int length
byte flags
int streamId
io.grpc.okhttp.internal.framed.Settings settings
private void readPushPromise (io.grpc.okhttp.internal.framed.FrameReader$Handler, int, byte, int) throws java.io.IOException
io.grpc.okhttp.internal.framed.FrameReader$Handler handler
int length
byte flags
int streamId
short padding
int promisedStreamId
java.util.List headerBlock
private void readPing (io.grpc.okhttp.internal.framed.FrameReader$Handler, int, byte, int) throws java.io.IOException
io.grpc.okhttp.internal.framed.FrameReader$Handler handler
int length
byte flags
int streamId
int payload1
int payload2
boolean ack
private void readGoAway (io.grpc.okhttp.internal.framed.FrameReader$Handler, int, byte, int) throws java.io.IOException
io.grpc.okhttp.internal.framed.FrameReader$Handler handler
int length
byte flags
int streamId
int lastStreamId
int errorCodeInt
int opaqueDataLength
io.grpc.okhttp.internal.framed.ErrorCode errorCode
okio.ByteString debugData
private void readWindowUpdate (io.grpc.okhttp.internal.framed.FrameReader$Handler, int, byte, int) throws java.io.IOException
io.grpc.okhttp.internal.framed.FrameReader$Handler handler
int length
byte flags
int streamId
long increment
public void close () throws java.io.IOException
}
io/grpc/okhttp/internal/framed/Http2$Writer.classHttp2.java
package io.grpc.okhttp.internal.framed
final io.grpc.okhttp.internal.framed.Http2$Writer extends java.lang.Object implements io.grpc.okhttp.internal.framed.FrameWriter {
private final okio.BufferedSink sink
private final boolean client
private final okio.Buffer hpackBuffer
private final io.grpc.okhttp.internal.framed.Hpack$Writer hpackWriter
private int maxFrameSize
private boolean closed
void (okio.BufferedSink, boolean)
okio.BufferedSink sink
boolean client
public synchronized void flush () throws java.io.IOException
public synchronized void ackSettings (io.grpc.okhttp.internal.framed.Settings) throws java.io.IOException
io.grpc.okhttp.internal.framed.Settings peerSettings
int length
byte type
byte flags
int streamId
public synchronized void connectionPreface () throws java.io.IOException
public synchronized void synStream (boolean, boolean, int, int, java.util.List) throws java.io.IOException
boolean outFinished
boolean inFinished
int streamId
int associatedStreamId
java.util.List headerBlock
public synchronized void synReply (boolean, int, java.util.List) throws java.io.IOException
boolean outFinished
int streamId
java.util.List headerBlock
public synchronized void headers (int, java.util.List) throws java.io.IOException
int streamId
java.util.List headerBlock
public synchronized void pushPromise (int, int, java.util.List) throws java.io.IOException
int streamId
int promisedStreamId
java.util.List requestHeaders
long byteCount
int length
byte type
byte flags
void headers (boolean, int, java.util.List) throws java.io.IOException
boolean outFinished
int streamId
java.util.List headerBlock
long byteCount
int length
byte type
byte flags
private void writeContinuationFrames (int, long) throws java.io.IOException
int length
int streamId
long byteCount
public synchronized void rstStream (int, io.grpc.okhttp.internal.framed.ErrorCode) throws java.io.IOException
int streamId
io.grpc.okhttp.internal.framed.ErrorCode errorCode
int length
byte type
byte flags
public int maxDataLength ()
public synchronized void data (boolean, int, okio.Buffer, int) throws java.io.IOException
boolean outFinished
int streamId
okio.Buffer source
int byteCount
byte flags
void dataFrame (int, byte, okio.Buffer, int) throws java.io.IOException
int streamId
byte flags
okio.Buffer buffer
int byteCount
byte type
public synchronized void settings (io.grpc.okhttp.internal.framed.Settings) throws java.io.IOException
int id
int i
io.grpc.okhttp.internal.framed.Settings settings
int length
byte type
byte flags
int streamId
public synchronized void ping (boolean, int, int) throws java.io.IOException
boolean ack
int payload1
int payload2
int length
byte type
byte flags
int streamId
public synchronized void goAway (int, io.grpc.okhttp.internal.framed.ErrorCode, byte[]) throws java.io.IOException
int lastGoodStreamId
io.grpc.okhttp.internal.framed.ErrorCode errorCode
byte[] debugData
int length
byte type
byte flags
int streamId
public synchronized void windowUpdate (int, long) throws java.io.IOException
int streamId
long windowSizeIncrement
int length
byte type
byte flags
public synchronized void close () throws java.io.IOException
void frameHeader (int, int, byte, byte) throws java.io.IOException
int streamId
int length
byte type
byte flags
}
io/grpc/okhttp/internal/framed/Http2$ContinuationSource.classHttp2.java
package io.grpc.okhttp.internal.framed
final io.grpc.okhttp.internal.framed.Http2$ContinuationSource extends java.lang.Object implements okio.Source {
private final okio.BufferedSource source
int length
byte flags
int streamId
int left
short padding
public void (okio.BufferedSource)
okio.BufferedSource source
public long read (okio.Buffer, long) throws java.io.IOException
okio.Buffer sink
long byteCount
long read
public okio.Timeout timeout ()
public void close () throws java.io.IOException
private void readContinuationHeader () throws java.io.IOException
int previousStreamId
byte type
}
io/grpc/okhttp/internal/framed/Http2$FrameLogger.classHttp2.java
package io.grpc.okhttp.internal.framed
final io.grpc.okhttp.internal.framed.Http2$FrameLogger extends java.lang.Object {
private static final String[] TYPES
private static final String[] FLAGS
private static final String[] BINARY
void ()
static java.lang.String formatHeader (boolean, int, int, byte, byte)
boolean inbound
int streamId
int length
byte type
byte flags
String formattedType
String formattedFlags
static java.lang.String formatFlags (byte, byte)
byte type
byte flags
String result
static void ()
int i
int prefixFlag
int prefixFlag
int frameFlag
int i
int[] prefixFlags
int[] frameFlags
}
io/grpc/okhttp/internal/framed/Http2.classHttp2.java
package io.grpc.okhttp.internal.framed
public final io.grpc.okhttp.internal.framed.Http2 extends java.lang.Object implements io.grpc.okhttp.internal.framed.Variant {
private static final java.util.logging.Logger logger
private static final okio.ByteString CONNECTION_PREFACE
static final int INITIAL_MAX_FRAME_SIZE
static final byte TYPE_DATA
static final byte TYPE_HEADERS
static final byte TYPE_PRIORITY
static final byte TYPE_RST_STREAM
static final byte TYPE_SETTINGS
static final byte TYPE_PUSH_PROMISE
static final byte TYPE_PING
static final byte TYPE_GOAWAY
static final byte TYPE_WINDOW_UPDATE
static final byte TYPE_CONTINUATION
static final byte FLAG_NONE
static final byte FLAG_ACK
static final byte FLAG_END_STREAM
static final byte FLAG_END_HEADERS
static final byte FLAG_END_PUSH_PROMISE
static final byte FLAG_PADDED
static final byte FLAG_PRIORITY
static final byte FLAG_COMPRESSED
public void ()
public io.grpc.okhttp.internal.Protocol getProtocol ()
public io.grpc.okhttp.internal.framed.FrameReader newReader (okio.BufferedSource, boolean)
okio.BufferedSource source
boolean client
public io.grpc.okhttp.internal.framed.FrameWriter newWriter (okio.BufferedSink, boolean)
okio.BufferedSink sink
boolean client
private static transient java.lang.IllegalArgumentException illegalArgument (java.lang.String, java.lang.Object[])
String message
Object[] args
private static transient java.io.IOException ioException (java.lang.String, java.lang.Object[]) throws java.io.IOException
String message
Object[] args
private static int lengthWithoutPadding (int, byte, short) throws java.io.IOException
int length
byte flags
short padding
private static int readMedium (okio.BufferedSource) throws java.io.IOException
okio.BufferedSource source
private static void writeMedium (okio.BufferedSink, int) throws java.io.IOException
okio.BufferedSink sink
int i
static synthetic okio.ByteString access$000 ()
static synthetic java.util.logging.Logger access$100 ()
static synthetic java.io.IOException access$200 (java.lang.String, java.lang.Object[]) throws java.io.IOException
String x0
Object[] x1
static synthetic int access$300 (okio.BufferedSource) throws java.io.IOException
okio.BufferedSource x0
static synthetic int access$400 (int, byte, short) throws java.io.IOException
int x0
byte x1
short x2
static synthetic java.lang.IllegalArgumentException access$500 (java.lang.String, java.lang.Object[])
String x0
Object[] x1
static synthetic void access$600 (okio.BufferedSink, int) throws java.io.IOException
okio.BufferedSink x0
int x1
static void ()
}
io/grpc/okhttp/internal/framed/Variant.classVariant.java
package io.grpc.okhttp.internal.framed
public abstract io.grpc.okhttp.internal.framed.Variant extends java.lang.Object {
public abstract io.grpc.okhttp.internal.Protocol getProtocol ()
public abstract io.grpc.okhttp.internal.framed.FrameReader newReader (okio.BufferedSource, boolean)
public abstract io.grpc.okhttp.internal.framed.FrameWriter newWriter (okio.BufferedSink, boolean)
}
io/grpc/okhttp/internal/framed/Huffman$Node.classHuffman.java
package io.grpc.okhttp.internal.framed
final io.grpc.okhttp.internal.framed.Huffman$Node extends java.lang.Object {
private final io.grpc.okhttp.internal.framed.Huffman$Node[] children
private final int symbol
private final int terminalBits
void ()
void (int, int)
int symbol
int bits
int b
static synthetic io.grpc.okhttp.internal.framed.Huffman$Node[] access$000 (io.grpc.okhttp.internal.framed.Huffman$Node)
io.grpc.okhttp.internal.framed.Huffman$Node x0
static synthetic int access$100 (io.grpc.okhttp.internal.framed.Huffman$Node)
io.grpc.okhttp.internal.framed.Huffman$Node x0
static synthetic int access$200 (io.grpc.okhttp.internal.framed.Huffman$Node)
io.grpc.okhttp.internal.framed.Huffman$Node x0
}
io/grpc/okhttp/internal/framed/Huffman.classHuffman.java
package io.grpc.okhttp.internal.framed
io.grpc.okhttp.internal.framed.Huffman extends java.lang.Object {
private static final int[] CODES
private static final byte[] CODE_LENGTHS
private static final io.grpc.okhttp.internal.framed.Huffman INSTANCE
private final io.grpc.okhttp.internal.framed.Huffman$Node root
public static io.grpc.okhttp.internal.framed.Huffman get ()
private void ()
void encode (byte[], java.io.OutputStream) throws java.io.IOException
int b
int code
int nbits
int i
byte[] data
java.io.OutputStream out
long current
int n
int encodedLength (byte[])
int b
int i
byte[] bytes
long len
byte[] decode (byte[]) throws java.io.IOException
int c
int b
int i
int c
byte[] buf
java.io.ByteArrayOutputStream baos
io.grpc.okhttp.internal.framed.Huffman$Node node
int current
int nbits
private void buildTree ()
int i
private void addCode (int, int, byte)
int i
int i
int sym
int code
byte len
io.grpc.okhttp.internal.framed.Huffman$Node terminal
io.grpc.okhttp.internal.framed.Huffman$Node current
int shift
int start
int end
static void ()
}
io/grpc/okhttp/internal/ConnectionSpec$Builder.classConnectionSpec.java
package io.grpc.okhttp.internal
public final io.grpc.okhttp.internal.ConnectionSpec$Builder extends java.lang.Object {
private boolean tls
private String[] cipherSuites
private String[] tlsVersions
private boolean supportsTlsExtensions
public void (boolean)
boolean tls
public void (io.grpc.okhttp.internal.ConnectionSpec)
io.grpc.okhttp.internal.ConnectionSpec connectionSpec
public transient io.grpc.okhttp.internal.ConnectionSpec$Builder cipherSuites (io.grpc.okhttp.internal.CipherSuite[])
int i
io.grpc.okhttp.internal.CipherSuite[] cipherSuites
String[] strings
public transient io.grpc.okhttp.internal.ConnectionSpec$Builder cipherSuites (java.lang.String[])
String[] cipherSuites
public transient io.grpc.okhttp.internal.ConnectionSpec$Builder tlsVersions (io.grpc.okhttp.internal.TlsVersion[])
int i
io.grpc.okhttp.internal.TlsVersion[] tlsVersions
String[] strings
public transient io.grpc.okhttp.internal.ConnectionSpec$Builder tlsVersions (java.lang.String[])
String[] tlsVersions
public io.grpc.okhttp.internal.ConnectionSpec$Builder supportsTlsExtensions (boolean)
boolean supportsTlsExtensions
public io.grpc.okhttp.internal.ConnectionSpec build ()
static synthetic boolean access$000 (io.grpc.okhttp.internal.ConnectionSpec$Builder)
io.grpc.okhttp.internal.ConnectionSpec$Builder x0
static synthetic java.lang.String[] access$100 (io.grpc.okhttp.internal.ConnectionSpec$Builder)
io.grpc.okhttp.internal.ConnectionSpec$Builder x0
static synthetic java.lang.String[] access$200 (io.grpc.okhttp.internal.ConnectionSpec$Builder)
io.grpc.okhttp.internal.ConnectionSpec$Builder x0
static synthetic boolean access$300 (io.grpc.okhttp.internal.ConnectionSpec$Builder)
io.grpc.okhttp.internal.ConnectionSpec$Builder x0
}
io/grpc/okhttp/internal/ConnectionSpec$1.classConnectionSpec.java
package io.grpc.okhttp.internal
synthetic io.grpc.okhttp.internal.ConnectionSpec$1 extends java.lang.Object {
}
io/grpc/okhttp/internal/ConnectionSpec.classConnectionSpec.java
package io.grpc.okhttp.internal
public final io.grpc.okhttp.internal.ConnectionSpec extends java.lang.Object {
private static final io.grpc.okhttp.internal.CipherSuite[] APPROVED_CIPHER_SUITES
public static final io.grpc.okhttp.internal.ConnectionSpec MODERN_TLS
public static final io.grpc.okhttp.internal.ConnectionSpec COMPATIBLE_TLS
public static final io.grpc.okhttp.internal.ConnectionSpec CLEARTEXT
final boolean tls
private final String[] cipherSuites
private final String[] tlsVersions
final boolean supportsTlsExtensions
private void (io.grpc.okhttp.internal.ConnectionSpec$Builder)
io.grpc.okhttp.internal.ConnectionSpec$Builder builder
public boolean isTls ()
public java.util.List cipherSuites ()
int i
io.grpc.okhttp.internal.CipherSuite[] result
public java.util.List tlsVersions ()
int i
io.grpc.okhttp.internal.TlsVersion[] result
public boolean supportsTlsExtensions ()
public void apply (javax.net.ssl.SSLSocket, boolean)
javax.net.ssl.SSLSocket sslSocket
boolean isFallback
io.grpc.okhttp.internal.ConnectionSpec specToApply
String[] cipherSuitesToEnable
private io.grpc.okhttp.internal.ConnectionSpec supportedSpec (javax.net.ssl.SSLSocket, boolean)
String[] cipherSuitesToSelectFrom
String[] oldEnabledCipherSuites
String[] newEnabledCipherSuites
String fallbackScsv
boolean socketSupportsFallbackScsv
javax.net.ssl.SSLSocket sslSocket
boolean isFallback
String[] cipherSuitesToEnable
String[] protocolsToSelectFrom
String[] protocolsToEnable
public boolean isCompatible (javax.net.ssl.SSLSocket)
boolean requiredCiphersEnabled
String[] enabledCipherSuites
javax.net.ssl.SSLSocket socket
String[] enabledProtocols
boolean requiredProtocolsEnabled
boolean requiredCiphersEnabled
private static boolean nonEmptyIntersection (java.lang.String[], java.lang.String[])
String toFind
String[] a
String[] b
private static boolean contains (java.lang.Object[], java.lang.Object)
Object arrayValue
Object[] array
Object value
public boolean equals (java.lang.Object)
Object other
io.grpc.okhttp.internal.ConnectionSpec that
public int hashCode ()
int result
public java.lang.String toString ()
java.util.List cipherSuites
String cipherSuitesString
static synthetic java.lang.String[] access$400 (io.grpc.okhttp.internal.ConnectionSpec)
io.grpc.okhttp.internal.ConnectionSpec x0
static synthetic java.lang.String[] access$500 (io.grpc.okhttp.internal.ConnectionSpec)
io.grpc.okhttp.internal.ConnectionSpec x0
synthetic void (io.grpc.okhttp.internal.ConnectionSpec$Builder, io.grpc.okhttp.internal.ConnectionSpec$1)
io.grpc.okhttp.internal.ConnectionSpec$Builder x0
io.grpc.okhttp.internal.ConnectionSpec$1 x1
static void ()
}
io/grpc/okhttp/internal/CipherSuite.classCipherSuite.java
package io.grpc.okhttp.internal
public final enum io.grpc.okhttp.internal.CipherSuite extends java.lang.Enum {
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_RSA_WITH_NULL_MD5
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_RSA_WITH_NULL_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_RSA_EXPORT_WITH_RC4_40_MD5
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_RSA_WITH_RC4_128_MD5
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_RSA_WITH_RC4_128_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_RSA_EXPORT_WITH_DES40_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_RSA_WITH_DES_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_RSA_WITH_3DES_EDE_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_DHE_DSS_EXPORT_WITH_DES40_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_DHE_DSS_WITH_DES_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_DHE_DSS_WITH_3DES_EDE_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_DHE_RSA_EXPORT_WITH_DES40_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_DHE_RSA_WITH_DES_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_DHE_RSA_WITH_3DES_EDE_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_DH_anon_EXPORT_WITH_RC4_40_MD5
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_DH_anon_WITH_RC4_128_MD5
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_DH_anon_EXPORT_WITH_DES40_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_DH_anon_WITH_DES_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_DH_anon_WITH_3DES_EDE_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_KRB5_WITH_DES_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_KRB5_WITH_3DES_EDE_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_KRB5_WITH_RC4_128_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_KRB5_WITH_DES_CBC_MD5
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_KRB5_WITH_3DES_EDE_CBC_MD5
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_KRB5_WITH_RC4_128_MD5
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_KRB5_EXPORT_WITH_DES_CBC_40_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_KRB5_EXPORT_WITH_RC4_40_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_KRB5_EXPORT_WITH_DES_CBC_40_MD5
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_KRB5_EXPORT_WITH_RC4_40_MD5
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_RSA_WITH_AES_128_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_DHE_DSS_WITH_AES_128_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_DHE_RSA_WITH_AES_128_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_DH_anon_WITH_AES_128_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_RSA_WITH_AES_256_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_DHE_DSS_WITH_AES_256_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_DHE_RSA_WITH_AES_256_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_DH_anon_WITH_AES_256_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_RSA_WITH_NULL_SHA256
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_RSA_WITH_AES_128_CBC_SHA256
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_RSA_WITH_AES_256_CBC_SHA256
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_DHE_DSS_WITH_AES_128_CBC_SHA256
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_DHE_RSA_WITH_AES_128_CBC_SHA256
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_DHE_DSS_WITH_AES_256_CBC_SHA256
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_DHE_RSA_WITH_AES_256_CBC_SHA256
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_DH_anon_WITH_AES_128_CBC_SHA256
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_DH_anon_WITH_AES_256_CBC_SHA256
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_RSA_WITH_AES_128_GCM_SHA256
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_RSA_WITH_AES_256_GCM_SHA384
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_DHE_RSA_WITH_AES_128_GCM_SHA256
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_DHE_RSA_WITH_AES_256_GCM_SHA384
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_DHE_DSS_WITH_AES_128_GCM_SHA256
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_DHE_DSS_WITH_AES_256_GCM_SHA384
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_DH_anon_WITH_AES_128_GCM_SHA256
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_DH_anon_WITH_AES_256_GCM_SHA384
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_EMPTY_RENEGOTIATION_INFO_SCSV
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDH_ECDSA_WITH_NULL_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDH_ECDSA_WITH_RC4_128_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDH_ECDSA_WITH_3DES_EDE_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDH_ECDSA_WITH_AES_128_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDH_ECDSA_WITH_AES_256_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDHE_ECDSA_WITH_NULL_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDHE_ECDSA_WITH_RC4_128_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDHE_ECDSA_WITH_3DES_EDE_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDHE_ECDSA_WITH_AES_128_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDHE_ECDSA_WITH_AES_256_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDH_RSA_WITH_NULL_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDH_RSA_WITH_RC4_128_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDH_RSA_WITH_3DES_EDE_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDH_RSA_WITH_AES_128_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDH_RSA_WITH_AES_256_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDHE_RSA_WITH_NULL_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDHE_RSA_WITH_RC4_128_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDHE_RSA_WITH_3DES_EDE_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDH_anon_WITH_NULL_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDH_anon_WITH_RC4_128_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDH_anon_WITH_3DES_EDE_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDH_anon_WITH_AES_128_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDH_anon_WITH_AES_256_CBC_SHA
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDHE_ECDSA_WITH_AES_128_CBC_SHA256
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDHE_ECDSA_WITH_AES_256_CBC_SHA384
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDH_ECDSA_WITH_AES_128_CBC_SHA256
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDH_ECDSA_WITH_AES_256_CBC_SHA384
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA256
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDH_RSA_WITH_AES_128_CBC_SHA256
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDH_RSA_WITH_AES_256_CBC_SHA384
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDHE_ECDSA_WITH_AES_128_GCM_SHA256
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDHE_ECDSA_WITH_AES_256_GCM_SHA384
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDH_ECDSA_WITH_AES_128_GCM_SHA256
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDH_ECDSA_WITH_AES_256_GCM_SHA384
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDH_RSA_WITH_AES_128_GCM_SHA256
public static final enum io.grpc.okhttp.internal.CipherSuite TLS_ECDH_RSA_WITH_AES_256_GCM_SHA384
final String javaName
private static final synthetic io.grpc.okhttp.internal.CipherSuite[] $VALUES
public static io.grpc.okhttp.internal.CipherSuite[] values ()
public static io.grpc.okhttp.internal.CipherSuite valueOf (java.lang.String)
String name
private void (java.lang.String, int, java.lang.String, int, int, int, int)
String javaName
int value
int rfc
int sinceJavaVersion
int sinceAndroidVersion
public static io.grpc.okhttp.internal.CipherSuite forJavaName (java.lang.String)
String javaName
static void ()
}
io/grpc/okhttp/internal/TlsVersion.classTlsVersion.java
package io.grpc.okhttp.internal
public final enum io.grpc.okhttp.internal.TlsVersion extends java.lang.Enum {
public static final enum io.grpc.okhttp.internal.TlsVersion TLS_1_2
public static final enum io.grpc.okhttp.internal.TlsVersion TLS_1_1
public static final enum io.grpc.okhttp.internal.TlsVersion TLS_1_0
public static final enum io.grpc.okhttp.internal.TlsVersion SSL_3_0
final String javaName
private static final synthetic io.grpc.okhttp.internal.TlsVersion[] $VALUES
public static io.grpc.okhttp.internal.TlsVersion[] values ()
public static io.grpc.okhttp.internal.TlsVersion valueOf (java.lang.String)
String name
private void (java.lang.String, int, java.lang.String)
String javaName
public static io.grpc.okhttp.internal.TlsVersion forJavaName (java.lang.String)
String javaName
public java.lang.String javaName ()
static void ()
}
io/grpc/okhttp/internal/Platform$Android.classPlatform.java
package io.grpc.okhttp.internal
io.grpc.okhttp.internal.Platform$Android extends io.grpc.okhttp.internal.Platform {
private final io.grpc.okhttp.internal.OptionalMethod setUseSessionTickets
private final io.grpc.okhttp.internal.OptionalMethod setHostname
private final java.lang.reflect.Method trafficStatsTagSocket
private final java.lang.reflect.Method trafficStatsUntagSocket
private final io.grpc.okhttp.internal.OptionalMethod getAlpnSelectedProtocol
private final io.grpc.okhttp.internal.OptionalMethod setAlpnProtocols
public void (io.grpc.okhttp.internal.OptionalMethod, io.grpc.okhttp.internal.OptionalMethod, java.lang.reflect.Method, java.lang.reflect.Method, io.grpc.okhttp.internal.OptionalMethod, io.grpc.okhttp.internal.OptionalMethod, java.security.Provider)
io.grpc.okhttp.internal.OptionalMethod setUseSessionTickets
io.grpc.okhttp.internal.OptionalMethod setHostname
java.lang.reflect.Method trafficStatsTagSocket
java.lang.reflect.Method trafficStatsUntagSocket
io.grpc.okhttp.internal.OptionalMethod getAlpnSelectedProtocol
io.grpc.okhttp.internal.OptionalMethod setAlpnProtocols
java.security.Provider provider
public void connectSocket (java.net.Socket, java.net.InetSocketAddress, int) throws java.io.IOException
java.io.IOException ioException
SecurityException se
java.net.Socket socket
java.net.InetSocketAddress address
int connectTimeout
public void configureTlsExtensions (javax.net.ssl.SSLSocket, java.lang.String, java.util.List)
Object[] parameters
javax.net.ssl.SSLSocket sslSocket
String hostname
java.util.List protocols
public java.lang.String getSelectedProtocol (javax.net.ssl.SSLSocket)
javax.net.ssl.SSLSocket socket
byte[] alpnResult
public void tagSocket (java.net.Socket) throws java.net.SocketException
IllegalAccessException e
java.lang.reflect.InvocationTargetException e
java.net.Socket socket
public void untagSocket (java.net.Socket) throws java.net.SocketException
IllegalAccessException e
java.lang.reflect.InvocationTargetException e
java.net.Socket socket
}
io/grpc/okhttp/internal/Platform$JdkWithJettyBootPlatform.classPlatform.java
package io.grpc.okhttp.internal
io.grpc.okhttp.internal.Platform$JdkWithJettyBootPlatform extends io.grpc.okhttp.internal.Platform {
private final java.lang.reflect.Method putMethod
private final java.lang.reflect.Method getMethod
private final java.lang.reflect.Method removeMethod
private final Class clientProviderClass
private final Class serverProviderClass
public void (java.lang.reflect.Method, java.lang.reflect.Method, java.lang.reflect.Method, java.lang.Class, java.lang.Class, java.security.Provider)
java.lang.reflect.Method putMethod
java.lang.reflect.Method getMethod
java.lang.reflect.Method removeMethod
Class clientProviderClass
Class serverProviderClass
java.security.Provider provider
public void configureTlsExtensions (javax.net.ssl.SSLSocket, java.lang.String, java.util.List)
io.grpc.okhttp.internal.Protocol protocol
int i
int size
Object provider
java.lang.reflect.InvocationTargetException e
IllegalAccessException e
javax.net.ssl.SSLSocket sslSocket
String hostname
java.util.List protocols
java.util.List names
public void afterHandshake (javax.net.ssl.SSLSocket)
IllegalAccessException ignored
javax.net.ssl.SSLSocket sslSocket
public java.lang.String getSelectedProtocol (javax.net.ssl.SSLSocket)
io.grpc.okhttp.internal.Platform$JettyNegoProvider provider
java.lang.reflect.InvocationTargetException e
IllegalAccessException e
javax.net.ssl.SSLSocket socket
}
io/grpc/okhttp/internal/Platform$JettyNegoProvider.classPlatform.java
package io.grpc.okhttp.internal
io.grpc.okhttp.internal.Platform$JettyNegoProvider extends java.lang.Object implements java.lang.reflect.InvocationHandler {
private final java.util.List protocols
private boolean unsupported
private String selected
public void (java.util.List)
java.util.List protocols
public java.lang.Object invoke (java.lang.Object, java.lang.reflect.Method, java.lang.Object[]) throws java.lang.Throwable
int i
int size
java.util.List peerProtocols
Object proxy
java.lang.reflect.Method method
Object[] args
String methodName
Class returnType
static synthetic boolean access$000 (io.grpc.okhttp.internal.Platform$JettyNegoProvider)
io.grpc.okhttp.internal.Platform$JettyNegoProvider x0
static synthetic java.lang.String access$100 (io.grpc.okhttp.internal.Platform$JettyNegoProvider)
io.grpc.okhttp.internal.Platform$JettyNegoProvider x0
}
io/grpc/okhttp/internal/Platform.classPlatform.java
package io.grpc.okhttp.internal
public io.grpc.okhttp.internal.Platform extends java.lang.Object {
public static final java.util.logging.Logger logger
private static final io.grpc.okhttp.internal.Platform PLATFORM
private final java.security.Provider sslProvider
public static io.grpc.okhttp.internal.Platform get ()
public void (java.security.Provider)
java.security.Provider sslProvider
public java.lang.String getPrefix ()
public void logW (java.lang.String)
String warning
public void tagSocket (java.net.Socket) throws java.net.SocketException
java.net.Socket socket
public void untagSocket (java.net.Socket) throws java.net.SocketException
java.net.Socket socket
public java.security.Provider getProvider ()
public void configureTlsExtensions (javax.net.ssl.SSLSocket, java.lang.String, java.util.List)
javax.net.ssl.SSLSocket sslSocket
String hostname
java.util.List protocols
public void afterHandshake (javax.net.ssl.SSLSocket)
javax.net.ssl.SSLSocket sslSocket
public java.lang.String getSelectedProtocol (javax.net.ssl.SSLSocket)
javax.net.ssl.SSLSocket socket
public void connectSocket (java.net.Socket, java.net.InetSocketAddress, int) throws java.io.IOException
java.net.Socket socket
java.net.InetSocketAddress address
int connectTimeout
private static io.grpc.okhttp.internal.Platform findPlatform ()
ClassNotFoundException cnfe2
ClassNotFoundException cnfe1
Class providerClass
InstantiationException iae
IllegalAccessException iaxe
Class trafficStats
io.grpc.okhttp.internal.OptionalMethod setUseSessionTickets
io.grpc.okhttp.internal.OptionalMethod setHostname
java.lang.reflect.Method trafficStatsTagSocket
java.lang.reflect.Method trafficStatsUntagSocket
io.grpc.okhttp.internal.OptionalMethod getAlpnSelectedProtocol
io.grpc.okhttp.internal.OptionalMethod setAlpnProtocols
String negoClassName
Class negoClass
Class providerClass
Class clientProviderClass
Class serverProviderClass
java.lang.reflect.Method putMethod
java.lang.reflect.Method getMethod
java.lang.reflect.Method removeMethod
Class rawProviderClass
boolean haveConscrypt
java.security.Provider sslProvider
public static byte[] concatLengthPrefixed (java.util.List)
io.grpc.okhttp.internal.Protocol protocol
int i
int size
java.util.List protocols
okio.Buffer result
static void ()
}
io/grpc/okhttp/internal/Protocol.classProtocol.java
package io.grpc.okhttp.internal
public final enum io.grpc.okhttp.internal.Protocol extends java.lang.Enum {
public static final enum io.grpc.okhttp.internal.Protocol HTTP_1_0
public static final enum io.grpc.okhttp.internal.Protocol HTTP_1_1
public static final enum io.grpc.okhttp.internal.Protocol SPDY_3
public static final enum io.grpc.okhttp.internal.Protocol HTTP_2
private final String protocol
private static final synthetic io.grpc.okhttp.internal.Protocol[] $VALUES
public static io.grpc.okhttp.internal.Protocol[] values ()
public static io.grpc.okhttp.internal.Protocol valueOf (java.lang.String)
String name
private void (java.lang.String, int, java.lang.String)
String protocol
public static io.grpc.okhttp.internal.Protocol get (java.lang.String) throws java.io.IOException
String protocol
public java.lang.String toString ()
static void ()
}
io/grpc/okhttp/internal/OptionalMethod.classOptionalMethod.java
package io.grpc.okhttp.internal
public io.grpc.okhttp.internal.OptionalMethod extends java.lang.Object {
private final Class returnType
private final String methodName
private final Class[] methodParams
public transient void (java.lang.Class, java.lang.String, java.lang.Class[])
Class returnType
String methodName
Class[] methodParams
public boolean isSupported (java.lang.Object)
Object target
public transient java.lang.Object invokeOptional (java.lang.Object, java.lang.Object[]) throws java.lang.reflect.InvocationTargetException
IllegalAccessException e
Object target
Object[] args
java.lang.reflect.Method m
public transient java.lang.Object invokeOptionalWithoutCheckedException (java.lang.Object, java.lang.Object[])
Throwable targetException
AssertionError error
java.lang.reflect.InvocationTargetException e
Object target
Object[] args
public transient java.lang.Object invoke (java.lang.Object, java.lang.Object[]) throws java.lang.reflect.InvocationTargetException
AssertionError error
IllegalAccessException e
Object target
Object[] args
java.lang.reflect.Method m
public transient java.lang.Object invokeWithoutCheckedException (java.lang.Object, java.lang.Object[])
Throwable targetException
AssertionError error
java.lang.reflect.InvocationTargetException e
Object target
Object[] args
private java.lang.reflect.Method getMethod (java.lang.Class)
Class clazz
java.lang.reflect.Method method
private static java.lang.reflect.Method getPublicMethod (java.lang.Class, java.lang.String, java.lang.Class[])
Class clazz
String methodName
Class[] parameterTypes
java.lang.reflect.Method method
}
io/grpc/okhttp/internal/DistinguishedNameParser.classDistinguishedNameParser.java
package io.grpc.okhttp.internal
final io.grpc.okhttp.internal.DistinguishedNameParser extends java.lang.Object {
private final String dn
private final int length
private int pos
private int beg
private int end
private int cur
private char[] chars
public void (javax.security.auth.x500.X500Principal)
javax.security.auth.x500.X500Principal principal
private java.lang.String nextAT ()
private java.lang.String quotedAV ()
private java.lang.String hexAV ()
int i
int p
int hexLen
byte[] encoded
private java.lang.String escapedAV ()
private char getEscaped ()
private char getUTF8 ()
int count
int count
int b
int i
int count
int res
private int getByte (int)
int position
int b1
int b2
public java.lang.String findMostSpecific (java.lang.String)
String attValue
String attributeType
String attType
}
io/grpc/okhttp/internal/OkHostnameVerifier.classOkHostnameVerifier.java
package io.grpc.okhttp.internal
public final io.grpc.okhttp.internal.OkHostnameVerifier extends java.lang.Object implements javax.net.ssl.HostnameVerifier {
public static final io.grpc.okhttp.internal.OkHostnameVerifier INSTANCE
private static final java.util.regex.Pattern VERIFY_AS_IP_ADDRESS
private static final int ALT_DNS_NAME
private static final int ALT_IPA_NAME
private void ()
public boolean verify (java.lang.String, javax.net.ssl.SSLSession)
java.security.cert.Certificate[] certificates
javax.net.ssl.SSLException e
String host
javax.net.ssl.SSLSession session
public boolean verify (java.lang.String, java.security.cert.X509Certificate)
String host
java.security.cert.X509Certificate certificate
static boolean verifyAsIpAddress (java.lang.String)
String host
private boolean verifyIpAddress (java.lang.String, java.security.cert.X509Certificate)
int i
int size
String ipAddress
java.security.cert.X509Certificate certificate
java.util.List altNames
private boolean verifyHostName (java.lang.String, java.security.cert.X509Certificate)
int i
int size
javax.security.auth.x500.X500Principal principal
String cn
String hostName
java.security.cert.X509Certificate certificate
boolean hasDns
java.util.List altNames
public static java.util.List allSubjectAltNames (java.security.cert.X509Certificate)
java.security.cert.X509Certificate certificate
java.util.List altIpaNames
java.util.List altDnsNames
java.util.List result
private static java.util.List getSubjectAltNames (java.security.cert.X509Certificate, int)
String altName
java.util.List entry
Integer altNameType
Object subjectAltName
java.util.Collection subjectAltNames
java.security.cert.CertificateParsingException e
java.security.cert.X509Certificate certificate
int type
java.util.List result
private boolean verifyHostName (java.lang.String, java.lang.String)
String hostName
String pattern
String suffix
int suffixStartIndexInHostName
static void ()
}
io/grpc/okhttp/internal/Util$1.classUtil.java
package io.grpc.okhttp.internal
final io.grpc.okhttp.internal.Util$1 extends java.lang.Object implements java.util.concurrent.ThreadFactory {
final synthetic String val$name
final synthetic boolean val$daemon
void (java.lang.String, boolean)
public java.lang.Thread newThread (java.lang.Runnable)
Runnable runnable
Thread result
}
io/grpc/okhttp/internal/Util.classUtil.java
package io.grpc.okhttp.internal
public final io.grpc.okhttp.internal.Util extends java.lang.Object {
public static final byte[] EMPTY_BYTE_ARRAY
public static final String[] EMPTY_STRING_ARRAY
public static final java.nio.charset.Charset UTF_8
private void ()
public static void checkOffsetAndCount (long, long, long)
long arrayLength
long offset
long count
public static boolean equal (java.lang.Object, java.lang.Object)
Object a
Object b
public static void closeQuietly (java.io.Closeable)
RuntimeException rethrown
java.io.Closeable closeable
public static void closeQuietly (java.net.Socket)
AssertionError e
RuntimeException rethrown
java.net.Socket socket
public static void closeQuietly (java.net.ServerSocket)
RuntimeException rethrown
java.net.ServerSocket serverSocket
public static void closeAll (java.io.Closeable, java.io.Closeable) throws java.io.IOException
Throwable e
Throwable e
java.io.Closeable a
java.io.Closeable b
Throwable thrown
public static boolean discard (okio.Source, int, java.util.concurrent.TimeUnit)
java.io.IOException e
okio.Source source
int timeout
java.util.concurrent.TimeUnit timeUnit
public static boolean skipAll (okio.Source, int, java.util.concurrent.TimeUnit) throws java.io.IOException
okio.Buffer skipBuffer
java.io.InterruptedIOException e
okio.Source source
int duration
java.util.concurrent.TimeUnit timeUnit
long now
long originalDuration
public static java.lang.String md5Hex (java.lang.String)
java.security.MessageDigest messageDigest
byte[] md5bytes
java.security.NoSuchAlgorithmException e
java.io.UnsupportedEncodingException e
String s
public static java.lang.String shaBase64 (java.lang.String)
java.security.MessageDigest messageDigest
byte[] sha1Bytes
java.security.NoSuchAlgorithmException e
java.io.UnsupportedEncodingException e
String s
public static okio.ByteString sha1 (okio.ByteString)
java.security.MessageDigest messageDigest
byte[] sha1Bytes
java.security.NoSuchAlgorithmException e
okio.ByteString s
public static java.util.List immutableList (java.util.List)
java.util.List list
public static transient java.util.List immutableList (java.lang.Object[])
Object[] elements
public static java.util.Map immutableMap (java.util.Map)
java.util.Map map
public static java.util.concurrent.ThreadFactory threadFactory (java.lang.String, boolean)
String name
boolean daemon
public static java.lang.Object[] intersect (java.lang.Class, java.lang.Object[], java.lang.Object[])
Class arrayType
Object[] first
Object[] second
java.util.List result
private static java.util.List intersect (java.lang.Object[], java.lang.Object[])
Object b
Object a
Object[] first
Object[] second
java.util.List result
public static java.lang.String toHumanReadableAscii (java.lang.String)
int j
okio.Buffer buffer
int i
int length
int c
String s
public static boolean isAndroidGetsocknameError (java.lang.AssertionError)
AssertionError e
static void ()
}
io/grpc/okhttp/NegotiationType.classNegotiationType.java
package io.grpc.okhttp
public final enum io.grpc.okhttp.NegotiationType extends java.lang.Enum {
public static final enum io.grpc.okhttp.NegotiationType TLS
public static final enum io.grpc.okhttp.NegotiationType PLAINTEXT
private static final synthetic io.grpc.okhttp.NegotiationType[] $VALUES
public static io.grpc.okhttp.NegotiationType[] values ()
public static io.grpc.okhttp.NegotiationType valueOf (java.lang.String)
String name
private void (java.lang.String, int)
static void ()
}
io/grpc/okhttp/OkHttpChannelProvider.classOkHttpChannelProvider.java
package io.grpc.okhttp
public final io.grpc.okhttp.OkHttpChannelProvider extends io.grpc.ManagedChannelProvider {
public void ()
public boolean isAvailable ()
public int priority ()
public io.grpc.okhttp.OkHttpChannelBuilder builderForAddress (java.lang.String, int)
String name
int port
public io.grpc.okhttp.OkHttpChannelBuilder builderForTarget (java.lang.String)
String target
public volatile synthetic io.grpc.ManagedChannelBuilder builderForTarget (java.lang.String)
public volatile synthetic io.grpc.ManagedChannelBuilder builderForAddress (java.lang.String, int)
}
io/grpc/okhttp/OkHttpChannelBuilder$1.classOkHttpChannelBuilder.java
package io.grpc.okhttp
final io.grpc.okhttp.OkHttpChannelBuilder$1 extends java.lang.Object implements io.grpc.internal.SharedResourceHolder$Resource {
void ()
public java.util.concurrent.ExecutorService create ()
public void close (java.util.concurrent.ExecutorService)
java.util.concurrent.ExecutorService executor
public volatile synthetic void close (java.lang.Object)
public volatile synthetic java.lang.Object create ()
}
io/grpc/okhttp/OkHttpChannelBuilder$OkHttpTransportFactory.classOkHttpChannelBuilder.java
package io.grpc.okhttp
final io.grpc.okhttp.OkHttpChannelBuilder$OkHttpTransportFactory extends java.lang.Object implements io.grpc.internal.ClientTransportFactory {
private final java.util.concurrent.Executor executor
private final boolean usingSharedExecutor
private final javax.net.ssl.SSLSocketFactory socketFactory
private final com.squareup.okhttp.ConnectionSpec connectionSpec
private final int maxMessageSize
private boolean enableKeepAlive
private long keepAliveDelayNanos
private long keepAliveTimeoutNanos
private boolean closed
private void (java.util.concurrent.Executor, javax.net.ssl.SSLSocketFactory, com.squareup.okhttp.ConnectionSpec, int, boolean, long, long)
java.util.concurrent.Executor executor
javax.net.ssl.SSLSocketFactory socketFactory
com.squareup.okhttp.ConnectionSpec connectionSpec
int maxMessageSize
boolean enableKeepAlive
long keepAliveDelayNanos
long keepAliveTimeoutNanos
public io.grpc.internal.ConnectionClientTransport newClientTransport (java.net.SocketAddress, java.lang.String, java.lang.String)
String[] parts
int port
java.net.SocketAddress addr
String authority
String userAgent
java.net.InetSocketAddress proxyAddress
String proxy
java.net.InetSocketAddress inetSocketAddr
io.grpc.okhttp.OkHttpClientTransport transport
public void close ()
synthetic void (java.util.concurrent.Executor, javax.net.ssl.SSLSocketFactory, com.squareup.okhttp.ConnectionSpec, int, boolean, long, long, io.grpc.okhttp.OkHttpChannelBuilder$1)
java.util.concurrent.Executor x0
javax.net.ssl.SSLSocketFactory x1
com.squareup.okhttp.ConnectionSpec x2
int x3
boolean x4
long x5
long x6
io.grpc.okhttp.OkHttpChannelBuilder$1 x7
}
io/grpc/okhttp/OkHttpChannelBuilder$2.classOkHttpChannelBuilder.java
package io.grpc.okhttp
synthetic io.grpc.okhttp.OkHttpChannelBuilder$2 extends java.lang.Object {
static final synthetic int[] $SwitchMap$io$grpc$okhttp$NegotiationType
static void ()
}
io/grpc/okhttp/OkHttpChannelBuilder.classOkHttpChannelBuilder.java
package io.grpc.okhttp
public io.grpc.okhttp.OkHttpChannelBuilder extends io.grpc.internal.AbstractManagedChannelImplBuilder {
public static final com.squareup.okhttp.ConnectionSpec DEFAULT_CONNECTION_SPEC
private static final io.grpc.internal.SharedResourceHolder$Resource SHARED_EXECUTOR
private java.util.concurrent.Executor transportExecutor
private javax.net.ssl.SSLSocketFactory sslSocketFactory
private com.squareup.okhttp.ConnectionSpec connectionSpec
private io.grpc.okhttp.NegotiationType negotiationType
private int maxMessageSize
private boolean enableKeepAlive
private long keepAliveDelayNanos
private long keepAliveTimeoutNanos
public static io.grpc.okhttp.OkHttpChannelBuilder forAddress (java.lang.String, int)
String host
int port
public static io.grpc.okhttp.OkHttpChannelBuilder forTarget (java.lang.String)
String target
protected void (java.lang.String, int)
String host
int port
private void (java.lang.String)
String target
public final io.grpc.okhttp.OkHttpChannelBuilder transportExecutor (java.util.concurrent.Executor)
java.util.concurrent.Executor transportExecutor
public final io.grpc.okhttp.OkHttpChannelBuilder negotiationType (io.grpc.okhttp.NegotiationType)
io.grpc.okhttp.NegotiationType type
public final io.grpc.okhttp.OkHttpChannelBuilder enableKeepAlive (boolean)
boolean enable
public final io.grpc.okhttp.OkHttpChannelBuilder enableKeepAlive (boolean, long, java.util.concurrent.TimeUnit, long, java.util.concurrent.TimeUnit)
boolean enable
long keepAliveDelay
java.util.concurrent.TimeUnit delayUnit
long keepAliveTimeout
java.util.concurrent.TimeUnit timeoutUnit
public final io.grpc.okhttp.OkHttpChannelBuilder sslSocketFactory (javax.net.ssl.SSLSocketFactory)
javax.net.ssl.SSLSocketFactory factory
public final io.grpc.okhttp.OkHttpChannelBuilder connectionSpec (com.squareup.okhttp.ConnectionSpec)
com.squareup.okhttp.ConnectionSpec connectionSpec
public final io.grpc.okhttp.OkHttpChannelBuilder maxMessageSize (int)
int maxMessageSize
public final io.grpc.okhttp.OkHttpChannelBuilder usePlaintext (boolean)
boolean skipNegotiation
protected final io.grpc.internal.ClientTransportFactory buildTransportFactory ()
protected io.grpc.Attributes getNameResolverParams ()
int defaultPort
int defaultPort
int defaultPort
javax.net.ssl.SSLSocketFactory createSocketFactory ()
javax.net.ssl.SSLContext sslContext
java.security.GeneralSecurityException gse
public volatile synthetic io.grpc.ManagedChannelBuilder usePlaintext (boolean)
static synthetic io.grpc.internal.SharedResourceHolder$Resource access$100 ()
static void ()
}
io/grpc/okhttp/OkHttpReadableBuffer.classOkHttpReadableBuffer.java
package io.grpc.okhttp
io.grpc.okhttp.OkHttpReadableBuffer extends io.grpc.internal.AbstractReadableBuffer {
private final okio.Buffer buffer
void (okio.Buffer)
okio.Buffer buffer
public int readableBytes ()
public int readUnsignedByte ()
public void skipBytes (int)
java.io.EOFException e
int length
public void readBytes (byte[], int, int)
int bytesRead
byte[] dest
int destOffset
int length
public void readBytes (java.nio.ByteBuffer)
java.nio.ByteBuffer dest
public void readBytes (java.io.OutputStream, int) throws java.io.IOException
java.io.OutputStream dest
int length
public io.grpc.internal.ReadableBuffer readBytes (int)
int length
okio.Buffer buf
public void close ()
}
io/grpc/okhttp/OkHttpSettingsUtil.classOkHttpSettingsUtil.java
package io.grpc.okhttp
io.grpc.okhttp.OkHttpSettingsUtil extends java.lang.Object {
public static final int MAX_CONCURRENT_STREAMS
public static final int INITIAL_WINDOW_SIZE
void ()
public static boolean isSet (io.grpc.okhttp.internal.framed.Settings, int)
io.grpc.okhttp.internal.framed.Settings settings
int id
public static int get (io.grpc.okhttp.internal.framed.Settings, int)
io.grpc.okhttp.internal.framed.Settings settings
int id
public static void set (io.grpc.okhttp.internal.framed.Settings, int, int)
io.grpc.okhttp.internal.framed.Settings settings
int id
int value
}
io/grpc/okhttp/OkHttpWritableBuffer.classOkHttpWritableBuffer.java
package io.grpc.okhttp
io.grpc.okhttp.OkHttpWritableBuffer extends java.lang.Object implements io.grpc.internal.WritableBuffer {
private final okio.Buffer buffer
private int writableBytes
private int readableBytes
void (okio.Buffer, int)
okio.Buffer buffer
int capacity
public void write (byte[], int, int)
byte[] src
int srcIndex
int length
public void write (byte)
byte b
public int writableBytes ()
public int readableBytes ()
public void release ()
okio.Buffer buffer ()
}
io/grpc/okhttp/OkHttpWritableBufferAllocator.classOkHttpWritableBufferAllocator.java
package io.grpc.okhttp
io.grpc.okhttp.OkHttpWritableBufferAllocator extends java.lang.Object implements io.grpc.internal.WritableBufferAllocator {
private static final int MIN_BUFFER
private static final int MAX_BUFFER
void ()
public io.grpc.internal.WritableBuffer allocate (int)
int capacityHint
}
io/grpc/okhttp/Utils.classUtils.java
package io.grpc.okhttp
io.grpc.okhttp.Utils extends java.lang.Object {
static final int DEFAULT_WINDOW_SIZE
static final int CONNECTION_STREAM_ID
public static io.grpc.Metadata convertHeaders (java.util.List)
java.util.List http2Headers
public static io.grpc.Metadata convertTrailers (java.util.List)
java.util.List http2Headers
private static byte[][] convertHeadersToArray (java.util.List)
io.grpc.okhttp.internal.framed.Header header
java.util.List http2Headers
byte[][] headerValues
int i
static io.grpc.okhttp.internal.ConnectionSpec convertSpec (com.squareup.okhttp.ConnectionSpec)
int i
int i
com.squareup.okhttp.ConnectionSpec spec
java.util.List tlsVersionList
String[] tlsVersions
java.util.List cipherSuiteList
io.grpc.okhttp.internal.CipherSuite[] cipherSuites
private void ()
}
io/grpc/okhttp/OutboundFlowController$WriteStatus.classOutboundFlowController.java
package io.grpc.okhttp
final io.grpc.okhttp.OutboundFlowController$WriteStatus extends java.lang.Object {
int numWrites
final synthetic io.grpc.okhttp.OutboundFlowController this$0
private void (io.grpc.okhttp.OutboundFlowController)
void incrementNumWrites ()
boolean hasWritten ()
synthetic void (io.grpc.okhttp.OutboundFlowController, io.grpc.okhttp.OutboundFlowController$1)
io.grpc.okhttp.OutboundFlowController x0
io.grpc.okhttp.OutboundFlowController$1 x1
}
io/grpc/okhttp/OutboundFlowController$OutboundFlowState$Frame.classOutboundFlowController.java
package io.grpc.okhttp
final io.grpc.okhttp.OutboundFlowController$OutboundFlowState$Frame extends java.lang.Object {
final okio.Buffer data
final boolean endStream
boolean enqueued
static final synthetic boolean $assertionsDisabled
final synthetic io.grpc.okhttp.OutboundFlowController$OutboundFlowState this$1
void (io.grpc.okhttp.OutboundFlowController$OutboundFlowState, okio.Buffer, boolean)
okio.Buffer data
boolean endStream
int size ()
void enqueue ()
void write ()
java.io.IOException e
int bytesToWrite
int frameBytes
io.grpc.okhttp.OutboundFlowController$OutboundFlowState$Frame frame
io.grpc.okhttp.OutboundFlowController$OutboundFlowState$Frame split (int)
int maxBytes
int dataSplit
okio.Buffer splitSlice
io.grpc.okhttp.OutboundFlowController$OutboundFlowState$Frame frame
static void ()
}
io/grpc/okhttp/OutboundFlowController$OutboundFlowState.classOutboundFlowController.java
package io.grpc.okhttp
final io.grpc.okhttp.OutboundFlowController$OutboundFlowState extends java.lang.Object {
final java.util.Queue pendingWriteQueue
final int streamId
int queuedBytes
int window
int allocatedBytes
io.grpc.okhttp.OkHttpClientStream stream
final synthetic io.grpc.okhttp.OutboundFlowController this$0
void (io.grpc.okhttp.OutboundFlowController, int)
int streamId
void (io.grpc.okhttp.OutboundFlowController, io.grpc.okhttp.OkHttpClientStream)
io.grpc.okhttp.OkHttpClientStream stream
int window ()
void allocateBytes (int)
int bytes
int allocatedBytes ()
int unallocatedBytes ()
void clearAllocatedBytes ()
int incrementStreamWindow (int)
int delta
int writableWindow ()
int streamableBytes ()
io.grpc.okhttp.OutboundFlowController$OutboundFlowState$Frame newFrame (okio.Buffer, boolean)
okio.Buffer data
boolean endStream
boolean hasFrame ()
private io.grpc.okhttp.OutboundFlowController$OutboundFlowState$Frame peek ()
int writeBytes (int, io.grpc.okhttp.OutboundFlowController$WriteStatus)
io.grpc.okhttp.OutboundFlowController$OutboundFlowState$Frame partialFrame
io.grpc.okhttp.OutboundFlowController$OutboundFlowState$Frame pendingWrite
int bytes
io.grpc.okhttp.OutboundFlowController$WriteStatus writeStatus
int bytesAttempted
int maxBytes
}
io/grpc/okhttp/OutboundFlowController$1.classOutboundFlowController.java
package io.grpc.okhttp
synthetic io.grpc.okhttp.OutboundFlowController$1 extends java.lang.Object {
}
io/grpc/okhttp/OutboundFlowController.classOutboundFlowController.java
package io.grpc.okhttp
io.grpc.okhttp.OutboundFlowController extends java.lang.Object {
private final io.grpc.okhttp.OkHttpClientTransport transport
private final io.grpc.okhttp.internal.framed.FrameWriter frameWriter
private int initialWindowSize
private final io.grpc.okhttp.OutboundFlowController$OutboundFlowState connectionState
void (io.grpc.okhttp.OkHttpClientTransport, io.grpc.okhttp.internal.framed.FrameWriter)
io.grpc.okhttp.OkHttpClientTransport transport
io.grpc.okhttp.internal.framed.FrameWriter frameWriter
void initialOutboundWindowSize (int)
io.grpc.okhttp.OutboundFlowController$OutboundFlowState state
io.grpc.okhttp.OkHttpClientStream stream
int newWindowSize
int delta
void windowUpdate (io.grpc.okhttp.OkHttpClientStream, int)
io.grpc.okhttp.OutboundFlowController$OutboundFlowState state
io.grpc.okhttp.OutboundFlowController$WriteStatus writeStatus
io.grpc.okhttp.OkHttpClientStream stream
int delta
void data (boolean, int, okio.Buffer, boolean)
boolean outFinished
int streamId
okio.Buffer source
boolean flush
io.grpc.okhttp.OkHttpClientStream stream
io.grpc.okhttp.OutboundFlowController$OutboundFlowState state
int window
boolean framesAlreadyQueued
io.grpc.okhttp.OutboundFlowController$OutboundFlowState$Frame frame
void flush ()
java.io.IOException e
private io.grpc.okhttp.OutboundFlowController$OutboundFlowState state (io.grpc.okhttp.OkHttpClientStream)
io.grpc.okhttp.OkHttpClientStream stream
io.grpc.okhttp.OutboundFlowController$OutboundFlowState state
private void writeStreams ()
io.grpc.okhttp.OkHttpClientStream stream
io.grpc.okhttp.OutboundFlowController$OutboundFlowState state
int bytesForStream
int index
int nextNumStreams
int windowSlice
int numStreams
io.grpc.okhttp.OutboundFlowController$OutboundFlowState state
io.grpc.okhttp.OkHttpClientStream stream
io.grpc.okhttp.OkHttpClientStream[] streams
int connectionWindow
io.grpc.okhttp.OutboundFlowController$WriteStatus writeStatus
static synthetic int access$100 (io.grpc.okhttp.OutboundFlowController)
io.grpc.okhttp.OutboundFlowController x0
static synthetic io.grpc.okhttp.OutboundFlowController$OutboundFlowState access$200 (io.grpc.okhttp.OutboundFlowController)
io.grpc.okhttp.OutboundFlowController x0
static synthetic io.grpc.okhttp.internal.framed.FrameWriter access$300 (io.grpc.okhttp.OutboundFlowController)
io.grpc.okhttp.OutboundFlowController x0
}
io/grpc/okhttp/OkHttpClientTransport$1$1.classOkHttpClientTransport.java
package io.grpc.okhttp
io.grpc.okhttp.OkHttpClientTransport$1$1 extends java.lang.Object implements okio.Source {
final synthetic io.grpc.okhttp.OkHttpClientTransport$1 this$1
void (io.grpc.okhttp.OkHttpClientTransport$1)
io.grpc.okhttp.OkHttpClientTransport$1 this$1
public long read (okio.Buffer, long)
okio.Buffer sink
long byteCount
public okio.Timeout timeout ()
public void close ()
}
io/grpc/okhttp/OkHttpClientTransport$1.classOkHttpClientTransport.java
package io.grpc.okhttp
io.grpc.okhttp.OkHttpClientTransport$1 extends java.lang.Object implements java.lang.Runnable {
final synthetic io.grpc.okhttp.OkHttpClientTransport this$0
void (io.grpc.okhttp.OkHttpClientTransport)
io.grpc.okhttp.OkHttpClientTransport this$0
public void run ()
java.net.Socket sock
io.grpc.StatusException e
Exception e
io.grpc.okhttp.internal.framed.Settings settings
Exception e
okio.BufferedSource source
io.grpc.okhttp.internal.framed.Variant variant
okio.BufferedSink sink
okio.BufferedSink sink
java.net.Socket sock
java.net.Socket sock
io.grpc.okhttp.internal.framed.FrameWriter rawFrameWriter
}
io/grpc/okhttp/OkHttpClientTransport$ClientFrameHandler.classOkHttpClientTransport.java
package io.grpc.okhttp
io.grpc.okhttp.OkHttpClientTransport$ClientFrameHandler extends java.lang.Object implements io.grpc.okhttp.internal.framed.FrameReader$Handler java.lang.Runnable {
io.grpc.okhttp.internal.framed.FrameReader frameReader
boolean firstSettings
final synthetic io.grpc.okhttp.OkHttpClientTransport this$0
void (io.grpc.okhttp.OkHttpClientTransport, io.grpc.okhttp.internal.framed.FrameReader)
io.grpc.okhttp.OkHttpClientTransport this$0
io.grpc.okhttp.internal.framed.FrameReader frameReader
public void run ()
java.io.IOException ex
Exception t
java.io.IOException ex
java.io.IOException ex
String threadName
public void data (boolean, int, okio.BufferedSource, int) throws java.io.IOException
okio.Buffer buf
boolean inFinished
int streamId
okio.BufferedSource in
int length
io.grpc.okhttp.OkHttpClientStream stream
public void headers (boolean, boolean, int, int, java.util.List, io.grpc.okhttp.internal.framed.HeadersMode)
io.grpc.okhttp.OkHttpClientStream stream
boolean outFinished
boolean inFinished
int streamId
int associatedStreamId
java.util.List headerBlock
io.grpc.okhttp.internal.framed.HeadersMode headersMode
boolean unknownStream
public void rstStream (int, io.grpc.okhttp.internal.framed.ErrorCode)
int streamId
io.grpc.okhttp.internal.framed.ErrorCode errorCode
public void settings (boolean, io.grpc.okhttp.internal.framed.Settings)
int receivedMaxConcurrentStreams
int initialWindowSize
boolean clearPrevious
io.grpc.okhttp.internal.framed.Settings settings
public void ping (boolean, int, int)
io.grpc.internal.Http2Ping p
long ackPayload
boolean ack
int payload1
int payload2
public void ackSettings ()
public void goAway (int, io.grpc.okhttp.internal.framed.ErrorCode, okio.ByteString)
int lastGoodStreamId
io.grpc.okhttp.internal.framed.ErrorCode errorCode
okio.ByteString debugData
io.grpc.Status status
public void pushPromise (int, int, java.util.List) throws java.io.IOException
int streamId
int promisedStreamId
java.util.List requestHeaders
public void windowUpdate (int, long)
String errorMsg
io.grpc.okhttp.OkHttpClientStream stream
int streamId
long delta
boolean unknownStream
public void priority (int, int, int, boolean)
int streamId
int streamDependency
int weight
boolean exclusive
public void alternateService (int, java.lang.String, okio.ByteString, java.lang.String, int, long)
int streamId
String origin
okio.ByteString protocol
String host
int port
long maxAge
}
io/grpc/okhttp/OkHttpClientTransport.classOkHttpClientTransport.java
package io.grpc.okhttp
io.grpc.okhttp.OkHttpClientTransport extends java.lang.Object implements io.grpc.internal.ConnectionClientTransport {
private static final java.util.Map ERROR_CODE_TO_STATUS
private static final java.util.logging.Logger log
private static final io.grpc.okhttp.OkHttpClientStream[] EMPTY_STREAM_ARRAY
private final java.net.InetSocketAddress address
private final String defaultAuthority
private final String userAgent
private final java.util.Random random
private final com.google.common.base.Ticker ticker
private io.grpc.internal.ManagedClientTransport$Listener listener
private io.grpc.okhttp.internal.framed.FrameReader testFrameReader
private io.grpc.okhttp.AsyncFrameWriter frameWriter
private io.grpc.okhttp.OutboundFlowController outboundFlow
private final Object lock
private int nextStreamId
private final java.util.Map streams
private final java.util.concurrent.Executor executor
private final io.grpc.internal.SerializingExecutor serializingExecutor
private final int maxMessageSize
private int connectionUnacknowledgedBytesRead
private io.grpc.okhttp.OkHttpClientTransport$ClientFrameHandler clientFrameHandler
private io.grpc.Status goAwayStatus
private boolean goAwaySent
private io.grpc.internal.Http2Ping ping
private boolean stopped
private boolean inUse
private javax.net.ssl.SSLSocketFactory sslSocketFactory
private java.net.Socket socket
private int maxConcurrentStreams
private java.util.LinkedList pendingStreams
private final io.grpc.okhttp.internal.ConnectionSpec connectionSpec
private io.grpc.okhttp.internal.framed.FrameWriter testFrameWriter
private java.util.concurrent.ScheduledExecutorService scheduler
private io.grpc.internal.KeepAliveManager keepAliveManager
private boolean enableKeepAlive
private long keepAliveDelayNanos
private long keepAliveTimeoutNanos
private final java.net.InetSocketAddress proxyAddress
private final String proxyUsername
private final String proxyPassword
Runnable connectingCallback
com.google.common.util.concurrent.SettableFuture connectedFuture
private static java.util.Map buildErrorCodeToStatusMap ()
java.util.Map errorToStatus
void (java.net.InetSocketAddress, java.lang.String, java.lang.String, java.util.concurrent.Executor, javax.net.ssl.SSLSocketFactory, io.grpc.okhttp.internal.ConnectionSpec, int, java.net.InetSocketAddress, java.lang.String, java.lang.String)
java.net.InetSocketAddress address
String authority
String userAgent
java.util.concurrent.Executor executor
javax.net.ssl.SSLSocketFactory sslSocketFactory
io.grpc.okhttp.internal.ConnectionSpec connectionSpec
int maxMessageSize
java.net.InetSocketAddress proxyAddress
String proxyUsername
String proxyPassword
void (java.lang.String, java.util.concurrent.Executor, io.grpc.okhttp.internal.framed.FrameReader, io.grpc.okhttp.internal.framed.FrameWriter, int, java.net.Socket, com.google.common.base.Ticker, java.lang.Runnable, com.google.common.util.concurrent.SettableFuture, int)
String userAgent
java.util.concurrent.Executor executor
io.grpc.okhttp.internal.framed.FrameReader frameReader
io.grpc.okhttp.internal.framed.FrameWriter testFrameWriter
int nextStreamId
java.net.Socket socket
com.google.common.base.Ticker ticker
Runnable connectingCallback
com.google.common.util.concurrent.SettableFuture connectedFuture
int maxMessageSize
void enableKeepAlive (boolean, long, long)
boolean enable
long keepAliveDelayNanos
long keepAliveTimeoutNanos
private boolean isForTest ()
public void ping (io.grpc.internal.ClientTransport$PingCallback, java.util.concurrent.Executor)
io.grpc.internal.Http2Ping p
boolean writePing
io.grpc.internal.ClientTransport$PingCallback callback
java.util.concurrent.Executor executor
long data
io.grpc.internal.Http2Ping p
boolean writePing
public io.grpc.okhttp.OkHttpClientStream newStream (io.grpc.MethodDescriptor, io.grpc.Metadata, io.grpc.CallOptions)
io.grpc.MethodDescriptor method
io.grpc.Metadata headers
io.grpc.CallOptions callOptions
public io.grpc.okhttp.OkHttpClientStream newStream (io.grpc.MethodDescriptor, io.grpc.Metadata)
io.grpc.MethodDescriptor method
io.grpc.Metadata headers
void streamReadyToStart (io.grpc.okhttp.OkHttpClientStream)
io.grpc.okhttp.OkHttpClientStream clientStream
private void startStream (io.grpc.okhttp.OkHttpClientStream)
io.grpc.okhttp.OkHttpClientStream stream
private boolean startPendingStreams ()
io.grpc.okhttp.OkHttpClientStream stream
boolean hasStreamStarted
void removePendingStream (io.grpc.okhttp.OkHttpClientStream)
io.grpc.okhttp.OkHttpClientStream pendingStream
public java.lang.Runnable start (io.grpc.internal.ManagedClientTransport$Listener)
io.grpc.internal.ManagedClientTransport$Listener listener
private java.net.Socket createHttpProxySocket (java.net.InetSocketAddress, java.net.InetSocketAddress, java.lang.String, java.lang.String) throws java.io.IOException io.grpc.StatusException
int i
int size
java.io.IOException ex
okio.Buffer body
String message
java.net.Socket sock
okio.Source source
okio.BufferedSink sink
com.squareup.okhttp.Request proxyRequest
com.squareup.okhttp.HttpUrl url
String requestLine
com.squareup.okhttp.internal.http.StatusLine statusLine
java.io.IOException e
java.net.InetSocketAddress address
java.net.InetSocketAddress proxyAddress
String proxyUsername
String proxyPassword
private com.squareup.okhttp.Request createHttpProxyRequest (java.net.InetSocketAddress, java.lang.String, java.lang.String)
java.net.InetSocketAddress address
String proxyUsername
String proxyPassword
com.squareup.okhttp.HttpUrl tunnelUrl
com.squareup.okhttp.Request$Builder request
private static java.lang.String readUtf8LineStrictUnbuffered (okio.Source) throws java.io.IOException
okio.Source source
okio.Buffer buffer
public java.lang.String toString ()
public java.lang.String getLogId ()
java.lang.String getOverridenHost ()
java.net.URI uri
int getOverridenPort ()
java.net.URI uri
public void shutdown ()
public void shutdownNow (io.grpc.Status)
java.util.Map$Entry entry
io.grpc.okhttp.OkHttpClientStream stream
java.util.Iterator it
io.grpc.Status reason
public io.grpc.Attributes getAttrs ()
io.grpc.okhttp.OkHttpClientStream[] getActiveStreams ()
io.grpc.okhttp.OkHttpClientTransport$ClientFrameHandler getHandler ()
int getPendingStreamSize ()
void onException (java.lang.Throwable)
Throwable failureCause
io.grpc.Status status
private void onError (io.grpc.okhttp.internal.framed.ErrorCode, java.lang.String)
io.grpc.okhttp.internal.framed.ErrorCode errorCode
String moreDetail
private void startGoAway (int, io.grpc.okhttp.internal.framed.ErrorCode, io.grpc.Status)
java.util.Map$Entry entry
io.grpc.okhttp.OkHttpClientStream stream
java.util.Iterator it
int lastKnownStreamId
io.grpc.okhttp.internal.framed.ErrorCode errorCode
io.grpc.Status status
void finishStream (int, io.grpc.Status, io.grpc.okhttp.internal.framed.ErrorCode)
boolean isCancelled
io.grpc.okhttp.OkHttpClientStream stream
int streamId
io.grpc.Status status
io.grpc.okhttp.internal.framed.ErrorCode errorCode
void stopIfNecessary ()
private void maybeClearInUse ()
private void setInUse ()
private java.lang.Throwable getPingFailure ()
boolean mayHaveCreatedStream (int)
int streamId
io.grpc.okhttp.OkHttpClientStream getStream (int)
int streamId
static io.grpc.Status toGrpcStatus (io.grpc.okhttp.internal.framed.ErrorCode)
io.grpc.okhttp.internal.framed.ErrorCode code
io.grpc.Status status
public volatile synthetic io.grpc.internal.ClientStream newStream (io.grpc.MethodDescriptor, io.grpc.Metadata)
public volatile synthetic io.grpc.internal.ClientStream newStream (io.grpc.MethodDescriptor, io.grpc.Metadata, io.grpc.CallOptions)
static synthetic boolean access$000 (io.grpc.okhttp.OkHttpClientTransport)
io.grpc.okhttp.OkHttpClientTransport x0
static synthetic io.grpc.okhttp.OkHttpClientTransport$ClientFrameHandler access$102 (io.grpc.okhttp.OkHttpClientTransport, io.grpc.okhttp.OkHttpClientTransport$ClientFrameHandler)
io.grpc.okhttp.OkHttpClientTransport x0
io.grpc.okhttp.OkHttpClientTransport$ClientFrameHandler x1
static synthetic io.grpc.okhttp.internal.framed.FrameReader access$200 (io.grpc.okhttp.OkHttpClientTransport)
io.grpc.okhttp.OkHttpClientTransport x0
static synthetic io.grpc.okhttp.OkHttpClientTransport$ClientFrameHandler access$100 (io.grpc.okhttp.OkHttpClientTransport)
io.grpc.okhttp.OkHttpClientTransport x0
static synthetic java.util.concurrent.Executor access$300 (io.grpc.okhttp.OkHttpClientTransport)
io.grpc.okhttp.OkHttpClientTransport x0
static synthetic java.lang.Object access$400 (io.grpc.okhttp.OkHttpClientTransport)
io.grpc.okhttp.OkHttpClientTransport x0
static synthetic int access$502 (io.grpc.okhttp.OkHttpClientTransport, int)
io.grpc.okhttp.OkHttpClientTransport x0
int x1
static synthetic boolean access$600 (io.grpc.okhttp.OkHttpClientTransport)
io.grpc.okhttp.OkHttpClientTransport x0
static synthetic io.grpc.okhttp.internal.framed.FrameWriter access$700 (io.grpc.okhttp.OkHttpClientTransport)
io.grpc.okhttp.OkHttpClientTransport x0
static synthetic java.net.Socket access$800 (io.grpc.okhttp.OkHttpClientTransport)
io.grpc.okhttp.OkHttpClientTransport x0
static synthetic io.grpc.okhttp.AsyncFrameWriter access$900 (io.grpc.okhttp.OkHttpClientTransport)
io.grpc.okhttp.OkHttpClientTransport x0
static synthetic java.net.InetSocketAddress access$1000 (io.grpc.okhttp.OkHttpClientTransport)
io.grpc.okhttp.OkHttpClientTransport x0
static synthetic java.net.InetSocketAddress access$1100 (io.grpc.okhttp.OkHttpClientTransport)
io.grpc.okhttp.OkHttpClientTransport x0
static synthetic java.lang.String access$1200 (io.grpc.okhttp.OkHttpClientTransport)
io.grpc.okhttp.OkHttpClientTransport x0
static synthetic java.lang.String access$1300 (io.grpc.okhttp.OkHttpClientTransport)
io.grpc.okhttp.OkHttpClientTransport x0
static synthetic java.net.Socket access$1400 (io.grpc.okhttp.OkHttpClientTransport, java.net.InetSocketAddress, java.net.InetSocketAddress, java.lang.String, java.lang.String) throws java.io.IOException io.grpc.StatusException
io.grpc.okhttp.OkHttpClientTransport x0
java.net.InetSocketAddress x1
java.net.InetSocketAddress x2
String x3
String x4
static synthetic javax.net.ssl.SSLSocketFactory access$1500 (io.grpc.okhttp.OkHttpClientTransport)
io.grpc.okhttp.OkHttpClientTransport x0
static synthetic io.grpc.okhttp.internal.ConnectionSpec access$1600 (io.grpc.okhttp.OkHttpClientTransport)
io.grpc.okhttp.OkHttpClientTransport x0
static synthetic void access$1700 (io.grpc.okhttp.OkHttpClientTransport, int, io.grpc.okhttp.internal.framed.ErrorCode, io.grpc.Status)
io.grpc.okhttp.OkHttpClientTransport x0
int x1
io.grpc.okhttp.internal.framed.ErrorCode x2
io.grpc.Status x3
static synthetic java.net.Socket access$802 (io.grpc.okhttp.OkHttpClientTransport, java.net.Socket)
io.grpc.okhttp.OkHttpClientTransport x0
java.net.Socket x1
static synthetic io.grpc.internal.KeepAliveManager access$1800 (io.grpc.okhttp.OkHttpClientTransport)
io.grpc.okhttp.OkHttpClientTransport x0
static synthetic java.util.logging.Logger access$1900 ()
static synthetic io.grpc.internal.ManagedClientTransport$Listener access$2000 (io.grpc.okhttp.OkHttpClientTransport)
io.grpc.okhttp.OkHttpClientTransport x0
static synthetic void access$2100 (io.grpc.okhttp.OkHttpClientTransport, io.grpc.okhttp.internal.framed.ErrorCode, java.lang.String)
io.grpc.okhttp.OkHttpClientTransport x0
io.grpc.okhttp.internal.framed.ErrorCode x1
String x2
static synthetic int access$2200 (io.grpc.okhttp.OkHttpClientTransport)
io.grpc.okhttp.OkHttpClientTransport x0
static synthetic int access$2202 (io.grpc.okhttp.OkHttpClientTransport, int)
io.grpc.okhttp.OkHttpClientTransport x0
int x1
static synthetic java.util.Map access$2300 (io.grpc.okhttp.OkHttpClientTransport)
io.grpc.okhttp.OkHttpClientTransport x0
static synthetic io.grpc.okhttp.OutboundFlowController access$2400 (io.grpc.okhttp.OkHttpClientTransport)
io.grpc.okhttp.OkHttpClientTransport x0
static synthetic io.grpc.internal.Http2Ping access$2500 (io.grpc.okhttp.OkHttpClientTransport)
io.grpc.okhttp.OkHttpClientTransport x0
static synthetic io.grpc.internal.Http2Ping access$2502 (io.grpc.okhttp.OkHttpClientTransport, io.grpc.internal.Http2Ping)
io.grpc.okhttp.OkHttpClientTransport x0
io.grpc.internal.Http2Ping x1
static void ()
}
io/grpc/okhttp/OkHttpClientStream$PendingData.classOkHttpClientStream.java
package io.grpc.okhttp
io.grpc.okhttp.OkHttpClientStream$PendingData extends java.lang.Object {
okio.Buffer buffer
boolean endOfStream
boolean flush
void (okio.Buffer, boolean, boolean)
okio.Buffer buffer
boolean endOfStream
boolean flush
}
io/grpc/okhttp/OkHttpClientStream.classOkHttpClientStream.java
package io.grpc.okhttp
io.grpc.okhttp.OkHttpClientStream extends io.grpc.internal.Http2ClientStream {
private static final int WINDOW_UPDATE_THRESHOLD
private static final okio.Buffer EMPTY_BUFFER
private int window
private int processedWindow
private final io.grpc.MethodDescriptor method
private io.grpc.Metadata headers
private final io.grpc.okhttp.AsyncFrameWriter frameWriter
private final io.grpc.okhttp.OutboundFlowController outboundFlow
private final io.grpc.okhttp.OkHttpClientTransport transport
private final Object lock
private final String userAgent
private String authority
private Object outboundFlowState
private volatile Integer id
private java.util.List requestHeaders
private java.util.Queue pendingData
private boolean cancelSent
void (io.grpc.MethodDescriptor, io.grpc.Metadata, io.grpc.okhttp.AsyncFrameWriter, io.grpc.okhttp.OkHttpClientTransport, io.grpc.okhttp.OutboundFlowController, java.lang.Object, int, java.lang.String, java.lang.String)
io.grpc.MethodDescriptor method
io.grpc.Metadata headers
io.grpc.okhttp.AsyncFrameWriter frameWriter
io.grpc.okhttp.OkHttpClientTransport transport
io.grpc.okhttp.OutboundFlowController outboundFlow
Object lock
int maxMessageSize
String authority
String userAgent
public io.grpc.MethodDescriptor$MethodType getType ()
public void request (int)
int numMessages
public java.lang.Integer id ()
public void setAuthority (java.lang.String)
String authority
public void start (io.grpc.internal.ClientStreamListener)
io.grpc.internal.ClientStreamListener listener
String defaultPath
java.util.List requestHeaders
public void start (java.lang.Integer)
io.grpc.okhttp.OkHttpClientStream$PendingData data
boolean flush
Integer id
public void allocated ()
void onStreamSentBytes (int)
int numBytes
public void transportHeadersReceived (java.util.List, boolean)
java.util.List headers
boolean endOfStream
public void transportDataReceived (okio.Buffer, boolean)
okio.Buffer frame
boolean endOfStream
long length
protected void sendFrame (io.grpc.internal.WritableBuffer, boolean, boolean)
okio.Buffer buffer
int size
io.grpc.internal.WritableBuffer frame
boolean endOfStream
boolean flush
okio.Buffer buffer
protected void returnProcessedBytes (int)
int delta
int processedBytes
protected void sendCancel (io.grpc.Status)
io.grpc.okhttp.OkHttpClientStream$PendingData data
io.grpc.Status reason
public void remoteEndClosed ()
void setOutboundFlowState (java.lang.Object)
Object outboundFlowState
java.lang.Object getOutboundFlowState ()
public volatile synthetic java.lang.Object id ()
static void ()
}
io/grpc/okhttp/AsyncFrameWriter$1.classAsyncFrameWriter.java
package io.grpc.okhttp
io.grpc.okhttp.AsyncFrameWriter$1 extends io.grpc.okhttp.AsyncFrameWriter$WriteRunnable {
final synthetic io.grpc.okhttp.AsyncFrameWriter this$0
void (io.grpc.okhttp.AsyncFrameWriter)
io.grpc.okhttp.AsyncFrameWriter this$0
public void doRun () throws java.io.IOException
}
io/grpc/okhttp/AsyncFrameWriter$2.classAsyncFrameWriter.java
package io.grpc.okhttp
io.grpc.okhttp.AsyncFrameWriter$2 extends io.grpc.okhttp.AsyncFrameWriter$WriteRunnable {
final synthetic io.grpc.okhttp.internal.framed.Settings val$peerSettings
final synthetic io.grpc.okhttp.AsyncFrameWriter this$0
void (io.grpc.okhttp.AsyncFrameWriter, io.grpc.okhttp.internal.framed.Settings)
io.grpc.okhttp.AsyncFrameWriter this$0
public void doRun () throws java.io.IOException
}
io/grpc/okhttp/AsyncFrameWriter$3.classAsyncFrameWriter.java
package io.grpc.okhttp
io.grpc.okhttp.AsyncFrameWriter$3 extends io.grpc.okhttp.AsyncFrameWriter$WriteRunnable {
final synthetic int val$streamId
final synthetic int val$promisedStreamId
final synthetic java.util.List val$requestHeaders
final synthetic io.grpc.okhttp.AsyncFrameWriter this$0
void (io.grpc.okhttp.AsyncFrameWriter, int, int, java.util.List)
io.grpc.okhttp.AsyncFrameWriter this$0
public void doRun () throws java.io.IOException
}
io/grpc/okhttp/AsyncFrameWriter$4.classAsyncFrameWriter.java
package io.grpc.okhttp
io.grpc.okhttp.AsyncFrameWriter$4 extends io.grpc.okhttp.AsyncFrameWriter$WriteRunnable {
final synthetic io.grpc.okhttp.AsyncFrameWriter this$0
void (io.grpc.okhttp.AsyncFrameWriter)
io.grpc.okhttp.AsyncFrameWriter this$0
public void doRun () throws java.io.IOException
}
io/grpc/okhttp/AsyncFrameWriter$5.classAsyncFrameWriter.java
package io.grpc.okhttp
io.grpc.okhttp.AsyncFrameWriter$5 extends io.grpc.okhttp.AsyncFrameWriter$WriteRunnable {
final synthetic boolean val$outFinished
final synthetic boolean val$inFinished
final synthetic int val$streamId
final synthetic int val$associatedStreamId
final synthetic java.util.List val$headerBlock
final synthetic io.grpc.okhttp.AsyncFrameWriter this$0
void (io.grpc.okhttp.AsyncFrameWriter, boolean, boolean, int, int, java.util.List)
io.grpc.okhttp.AsyncFrameWriter this$0
public void doRun () throws java.io.IOException
}
io/grpc/okhttp/AsyncFrameWriter$6.classAsyncFrameWriter.java
package io.grpc.okhttp
io.grpc.okhttp.AsyncFrameWriter$6 extends io.grpc.okhttp.AsyncFrameWriter$WriteRunnable {
final synthetic boolean val$outFinished
final synthetic int val$streamId
final synthetic java.util.List val$headerBlock
final synthetic io.grpc.okhttp.AsyncFrameWriter this$0
void (io.grpc.okhttp.AsyncFrameWriter, boolean, int, java.util.List)
io.grpc.okhttp.AsyncFrameWriter this$0
public void doRun () throws java.io.IOException
}
io/grpc/okhttp/AsyncFrameWriter$7.classAsyncFrameWriter.java
package io.grpc.okhttp
io.grpc.okhttp.AsyncFrameWriter$7 extends io.grpc.okhttp.AsyncFrameWriter$WriteRunnable {
final synthetic int val$streamId
final synthetic java.util.List val$headerBlock
final synthetic io.grpc.okhttp.AsyncFrameWriter this$0
void (io.grpc.okhttp.AsyncFrameWriter, int, java.util.List)
io.grpc.okhttp.AsyncFrameWriter this$0
public void doRun () throws java.io.IOException
}
io/grpc/okhttp/AsyncFrameWriter$8.classAsyncFrameWriter.java
package io.grpc.okhttp
io.grpc.okhttp.AsyncFrameWriter$8 extends io.grpc.okhttp.AsyncFrameWriter$WriteRunnable {
final synthetic int val$streamId
final synthetic io.grpc.okhttp.internal.framed.ErrorCode val$errorCode
final synthetic io.grpc.okhttp.AsyncFrameWriter this$0
void (io.grpc.okhttp.AsyncFrameWriter, int, io.grpc.okhttp.internal.framed.ErrorCode)
io.grpc.okhttp.AsyncFrameWriter this$0
public void doRun () throws java.io.IOException
}
io/grpc/okhttp/AsyncFrameWriter$9.classAsyncFrameWriter.java
package io.grpc.okhttp
io.grpc.okhttp.AsyncFrameWriter$9 extends io.grpc.okhttp.AsyncFrameWriter$WriteRunnable {
final synthetic boolean val$outFinished
final synthetic int val$streamId
final synthetic okio.Buffer val$source
final synthetic int val$byteCount
final synthetic io.grpc.okhttp.AsyncFrameWriter this$0
void (io.grpc.okhttp.AsyncFrameWriter, boolean, int, okio.Buffer, int)
io.grpc.okhttp.AsyncFrameWriter this$0
public void doRun () throws java.io.IOException
}
io/grpc/okhttp/AsyncFrameWriter$10.classAsyncFrameWriter.java
package io.grpc.okhttp
io.grpc.okhttp.AsyncFrameWriter$10 extends io.grpc.okhttp.AsyncFrameWriter$WriteRunnable {
final synthetic io.grpc.okhttp.internal.framed.Settings val$okHttpSettings
final synthetic io.grpc.okhttp.AsyncFrameWriter this$0
void (io.grpc.okhttp.AsyncFrameWriter, io.grpc.okhttp.internal.framed.Settings)
io.grpc.okhttp.AsyncFrameWriter this$0
public void doRun () throws java.io.IOException
}
io/grpc/okhttp/AsyncFrameWriter$11.classAsyncFrameWriter.java
package io.grpc.okhttp
io.grpc.okhttp.AsyncFrameWriter$11 extends io.grpc.okhttp.AsyncFrameWriter$WriteRunnable {
final synthetic boolean val$ack
final synthetic int val$payload1
final synthetic int val$payload2
final synthetic io.grpc.okhttp.AsyncFrameWriter this$0
void (io.grpc.okhttp.AsyncFrameWriter, boolean, int, int)
io.grpc.okhttp.AsyncFrameWriter this$0
public void doRun () throws java.io.IOException
}
io/grpc/okhttp/AsyncFrameWriter$12.classAsyncFrameWriter.java
package io.grpc.okhttp
io.grpc.okhttp.AsyncFrameWriter$12 extends io.grpc.okhttp.AsyncFrameWriter$WriteRunnable {
final synthetic int val$lastGoodStreamId
final synthetic io.grpc.okhttp.internal.framed.ErrorCode val$errorCode
final synthetic byte[] val$debugData
final synthetic io.grpc.okhttp.AsyncFrameWriter this$0
void (io.grpc.okhttp.AsyncFrameWriter, int, io.grpc.okhttp.internal.framed.ErrorCode, byte[])
io.grpc.okhttp.AsyncFrameWriter this$0
public void doRun () throws java.io.IOException
}
io/grpc/okhttp/AsyncFrameWriter$13.classAsyncFrameWriter.java
package io.grpc.okhttp
io.grpc.okhttp.AsyncFrameWriter$13 extends io.grpc.okhttp.AsyncFrameWriter$WriteRunnable {
final synthetic int val$streamId
final synthetic long val$windowSizeIncrement
final synthetic io.grpc.okhttp.AsyncFrameWriter this$0
void (io.grpc.okhttp.AsyncFrameWriter, int, long)
io.grpc.okhttp.AsyncFrameWriter this$0
public void doRun () throws java.io.IOException
}
io/grpc/okhttp/AsyncFrameWriter$14.classAsyncFrameWriter.java
package io.grpc.okhttp
io.grpc.okhttp.AsyncFrameWriter$14 extends java.lang.Object implements java.lang.Runnable {
final synthetic io.grpc.okhttp.AsyncFrameWriter this$0
void (io.grpc.okhttp.AsyncFrameWriter)
io.grpc.okhttp.AsyncFrameWriter this$0
public void run ()
java.io.IOException e
}
io/grpc/okhttp/AsyncFrameWriter$WriteRunnable.classAsyncFrameWriter.java
package io.grpc.okhttp
abstract io.grpc.okhttp.AsyncFrameWriter$WriteRunnable extends java.lang.Object implements java.lang.Runnable {
final synthetic io.grpc.okhttp.AsyncFrameWriter this$0
private void (io.grpc.okhttp.AsyncFrameWriter)
public final void run ()
RuntimeException e
Exception e
public abstract void doRun () throws java.io.IOException
synthetic void (io.grpc.okhttp.AsyncFrameWriter, io.grpc.okhttp.AsyncFrameWriter$1)
io.grpc.okhttp.AsyncFrameWriter x0
io.grpc.okhttp.AsyncFrameWriter$1 x1
}
io/grpc/okhttp/AsyncFrameWriter.classAsyncFrameWriter.java
package io.grpc.okhttp
io.grpc.okhttp.AsyncFrameWriter extends java.lang.Object implements io.grpc.okhttp.internal.framed.FrameWriter {
private static final java.util.logging.Logger log
private io.grpc.okhttp.internal.framed.FrameWriter frameWriter
private java.net.Socket socket
private final io.grpc.internal.SerializingExecutor executor
private final io.grpc.okhttp.OkHttpClientTransport transport
public void (io.grpc.okhttp.OkHttpClientTransport, io.grpc.internal.SerializingExecutor)
io.grpc.okhttp.OkHttpClientTransport transport
io.grpc.internal.SerializingExecutor executor
void becomeConnected (io.grpc.okhttp.internal.framed.FrameWriter, java.net.Socket)
io.grpc.okhttp.internal.framed.FrameWriter frameWriter
java.net.Socket socket
public void connectionPreface ()
public void ackSettings (io.grpc.okhttp.internal.framed.Settings)
io.grpc.okhttp.internal.framed.Settings peerSettings
public void pushPromise (int, int, java.util.List)
int streamId
int promisedStreamId
java.util.List requestHeaders
public void flush ()
public void synStream (boolean, boolean, int, int, java.util.List)
boolean outFinished
boolean inFinished
int streamId
int associatedStreamId
java.util.List headerBlock
public void synReply (boolean, int, java.util.List)
boolean outFinished
int streamId
java.util.List headerBlock
public void headers (int, java.util.List)
int streamId
java.util.List headerBlock
public void rstStream (int, io.grpc.okhttp.internal.framed.ErrorCode)
int streamId
io.grpc.okhttp.internal.framed.ErrorCode errorCode
public void data (boolean, int, okio.Buffer, int)
boolean outFinished
int streamId
okio.Buffer source
int byteCount
public void settings (io.grpc.okhttp.internal.framed.Settings)
io.grpc.okhttp.internal.framed.Settings okHttpSettings
public void ping (boolean, int, int)
boolean ack
int payload1
int payload2
public void goAway (int, io.grpc.okhttp.internal.framed.ErrorCode, byte[])
int lastGoodStreamId
io.grpc.okhttp.internal.framed.ErrorCode errorCode
byte[] debugData
public void windowUpdate (int, long)
int streamId
long windowSizeIncrement
public void close ()
public int maxDataLength ()
static synthetic io.grpc.okhttp.internal.framed.FrameWriter access$100 (io.grpc.okhttp.AsyncFrameWriter)
io.grpc.okhttp.AsyncFrameWriter x0
static synthetic java.net.Socket access$200 (io.grpc.okhttp.AsyncFrameWriter)
io.grpc.okhttp.AsyncFrameWriter x0
static synthetic java.util.logging.Logger access$300 ()
static synthetic io.grpc.okhttp.OkHttpClientTransport access$400 (io.grpc.okhttp.AsyncFrameWriter)
io.grpc.okhttp.AsyncFrameWriter x0
static void ()
}
io/grpc/okhttp/OkHttpProtocolNegotiator$AndroidNegotiator$TlsExtensionType.classOkHttpProtocolNegotiator.java
package io.grpc.okhttp
final enum io.grpc.okhttp.OkHttpProtocolNegotiator$AndroidNegotiator$TlsExtensionType extends java.lang.Enum {
public static final enum io.grpc.okhttp.OkHttpProtocolNegotiator$AndroidNegotiator$TlsExtensionType ALPN_AND_NPN
public static final enum io.grpc.okhttp.OkHttpProtocolNegotiator$AndroidNegotiator$TlsExtensionType NPN
private static final synthetic io.grpc.okhttp.OkHttpProtocolNegotiator$AndroidNegotiator$TlsExtensionType[] $VALUES
public static io.grpc.okhttp.OkHttpProtocolNegotiator$AndroidNegotiator$TlsExtensionType[] values ()
public static io.grpc.okhttp.OkHttpProtocolNegotiator$AndroidNegotiator$TlsExtensionType valueOf (java.lang.String)
String name
private void (java.lang.String, int)
static void ()
}
io/grpc/okhttp/OkHttpProtocolNegotiator$AndroidNegotiator.classOkHttpProtocolNegotiator.java
package io.grpc.okhttp
final io.grpc.okhttp.OkHttpProtocolNegotiator$AndroidNegotiator extends io.grpc.okhttp.OkHttpProtocolNegotiator {
private static final io.grpc.okhttp.internal.OptionalMethod SET_USE_SESSION_TICKETS
private static final io.grpc.okhttp.internal.OptionalMethod SET_HOSTNAME
private static final io.grpc.okhttp.internal.OptionalMethod GET_ALPN_SELECTED_PROTOCOL
private static final io.grpc.okhttp.internal.OptionalMethod SET_ALPN_PROTOCOLS
private static final io.grpc.okhttp.internal.OptionalMethod GET_NPN_SELECTED_PROTOCOL
private static final io.grpc.okhttp.internal.OptionalMethod SET_NPN_PROTOCOLS
private static final io.grpc.okhttp.OkHttpProtocolNegotiator$AndroidNegotiator$TlsExtensionType DEFAULT_TLS_EXTENSION_TYPE
private final io.grpc.okhttp.OkHttpProtocolNegotiator$AndroidNegotiator$TlsExtensionType tlsExtensionType
void (io.grpc.okhttp.internal.Platform, io.grpc.okhttp.OkHttpProtocolNegotiator$AndroidNegotiator$TlsExtensionType)
io.grpc.okhttp.internal.Platform platform
io.grpc.okhttp.OkHttpProtocolNegotiator$AndroidNegotiator$TlsExtensionType tlsExtensionType
public java.lang.String negotiate (javax.net.ssl.SSLSocket, java.lang.String, java.util.List) throws java.io.IOException
javax.net.ssl.SSLSocket sslSocket
String hostname
java.util.List protocols
String negotiatedProtocol
protected void configureTlsExtensions (javax.net.ssl.SSLSocket, java.lang.String, java.util.List)
javax.net.ssl.SSLSocket sslSocket
String hostname
java.util.List protocols
Object[] parameters
public java.lang.String getSelectedProtocol (javax.net.ssl.SSLSocket)
byte[] alpnResult
byte[] npnResult
javax.net.ssl.SSLSocket socket
static io.grpc.okhttp.OkHttpProtocolNegotiator$AndroidNegotiator$TlsExtensionType pickTlsExtensionType (java.lang.ClassLoader)
ClassLoader loader
java.security.Provider provider
static synthetic io.grpc.okhttp.OkHttpProtocolNegotiator$AndroidNegotiator$TlsExtensionType access$000 ()
static void ()
}
io/grpc/okhttp/OkHttpProtocolNegotiator.classOkHttpProtocolNegotiator.java
package io.grpc.okhttp
io.grpc.okhttp.OkHttpProtocolNegotiator extends java.lang.Object {
private static final io.grpc.okhttp.internal.Platform DEFAULT_PLATFORM
private static io.grpc.okhttp.OkHttpProtocolNegotiator NEGOTIATOR
private final io.grpc.okhttp.internal.Platform platform
void (io.grpc.okhttp.internal.Platform)
io.grpc.okhttp.internal.Platform platform
public static io.grpc.okhttp.OkHttpProtocolNegotiator get ()
static io.grpc.okhttp.OkHttpProtocolNegotiator createNegotiator (java.lang.ClassLoader)
ClassNotFoundException ignored2
ClassNotFoundException ignored
ClassLoader loader
boolean android
public java.lang.String negotiate (javax.net.ssl.SSLSocket, java.lang.String, java.util.List) throws java.io.IOException
String negotiatedProtocol
javax.net.ssl.SSLSocket sslSocket
String hostname
java.util.List protocols
protected void configureTlsExtensions (javax.net.ssl.SSLSocket, java.lang.String, java.util.List)
javax.net.ssl.SSLSocket sslSocket
String hostname
java.util.List protocols
public java.lang.String getSelectedProtocol (javax.net.ssl.SSLSocket)
javax.net.ssl.SSLSocket socket
static void ()
}
io/grpc/okhttp/OkHttpTlsUpgrader.classOkHttpTlsUpgrader.java
package io.grpc.okhttp
final io.grpc.okhttp.OkHttpTlsUpgrader extends java.lang.Object {
private static final String HTTP2_PROTOCOL_NAME
private static final java.util.List TLS_PROTOCOLS
void ()
public static javax.net.ssl.SSLSocket upgrade (javax.net.ssl.SSLSocketFactory, java.net.Socket, java.lang.String, int, io.grpc.okhttp.internal.ConnectionSpec) throws java.io.IOException
javax.net.ssl.SSLSocketFactory sslSocketFactory
java.net.Socket socket
String host
int port
io.grpc.okhttp.internal.ConnectionSpec spec
javax.net.ssl.SSLSocket sslSocket
String negotiatedProtocol
static void ()
}
META-INF/services/
META-INF/services/io.grpc.ManagedChannelProvider