CrackMe.apk
Download file
package okhttp3.internal.http2;
import java.io.Closeable;
import java.io.EOFException;
import java.io.IOException;
import java.util.List;
import java.util.logging.Level;
import java.util.logging.Logger;
import kotlin.Metadata;
import kotlin.jvm.internal.DefaultConstructorMarker;
import kotlin.jvm.internal.Intrinsics;
import kotlin.ranges.IntProgression;
import kotlin.ranges.RangesKt;
import okhttp3.internal.Util;
import okhttp3.internal.http2.Hpack;
import okio.Buffer;
import okio.BufferedSource;
import okio.ByteString;
import okio.Source;
import okio.Timeout;
@Metadata(bv = {1, 0, 3}, d1 = {"\u0000H\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000b\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0010\b\n\u0002\b\u0004\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\b\f\u0018\u0000 #2\u00020\u0001:\u0003#$%B\u0015\u0012\u0006\u0010\u0002\u001a\u00020\u0003\u0012\u0006\u0010\u0004\u001a\u00020\u0005¢\u0006\u0002\u0010\u0006J\b\u0010\u000b\u001a\u00020\fH\u0016J\u0016\u0010\r\u001a\u00020\u00052\u0006\u0010\u000e\u001a\u00020\u00052\u0006\u0010\u000f\u001a\u00020\u0010J\u000e\u0010\u0011\u001a\u00020\f2\u0006\u0010\u000f\u001a\u00020\u0010J(\u0010\u0012\u001a\u00020\f2\u0006\u0010\u000f\u001a\u00020\u00102\u0006\u0010\u0013\u001a\u00020\u00142\u0006\u0010\u0015\u001a\u00020\u00142\u0006\u0010\u0016\u001a\u00020\u0014H\u0002J(\u0010\u0017\u001a\u00020\f2\u0006\u0010\u000f\u001a\u00020\u00102\u0006\u0010\u0013\u001a\u00020\u00142\u0006\u0010\u0015\u001a\u00020\u00142\u0006\u0010\u0016\u001a\u00020\u0014H\u0002J.\u0010\u0018\u001a\b\u0012\u0004\u0012\u00020\u001a0\u00192\u0006\u0010\u0013\u001a\u00020\u00142\u0006\u0010\u001b\u001a\u00020\u00142\u0006\u0010\u0015\u001a\u00020\u00142\u0006\u0010\u0016\u001a\u00020\u0014H\u0002J(\u0010\u001c\u001a\u00020\f2\u0006\u0010\u000f\u001a\u00020\u00102\u0006\u0010\u0013\u001a\u00020\u00142\u0006\u0010\u0015\u001a\u00020\u00142\u0006\u0010\u0016\u001a\u00020\u0014H\u0002J(\u0010\u001d\u001a\u00020\f2\u0006\u0010\u000f\u001a\u00020\u00102\u0006\u0010\u0013\u001a\u00020\u00142\u0006\u0010\u0015\u001a\u00020\u00142\u0006\u0010\u0016\u001a\u00020\u0014H\u0002J\u0018\u0010\u001e\u001a\u00020\f2\u0006\u0010\u000f\u001a\u00020\u00102\u0006\u0010\u0016\u001a\u00020\u0014H\u0002J(\u0010\u001e\u001a\u00020\f2\u0006\u0010\u000f\u001a\u00020\u00102\u0006\u0010\u0013\u001a\u00020\u00142\u0006\u0010\u0015\u001a\u00020\u00142\u0006\u0010\u0016\u001a\u00020\u0014H\u0002J(\u0010\u001f\u001a\u00020\f2\u0006\u0010\u000f\u001a\u00020\u00102\u0006\u0010\u0013\u001a\u00020\u00142\u0006\u0010\u0015\u001a\u00020\u00142\u0006\u0010\u0016\u001a\u00020\u0014H\u0002J(\u0010 \u001a\u00020\f2\u0006\u0010\u000f\u001a\u00020\u00102\u0006\u0010\u0013\u001a\u00020\u00142\u0006\u0010\u0015\u001a\u00020\u00142\u0006\u0010\u0016\u001a\u00020\u0014H\u0002J(\u0010!\u001a\u00020\f2\u0006\u0010\u000f\u001a\u00020\u00102\u0006\u0010\u0013\u001a\u00020\u00142\u0006\u0010\u0015\u001a\u00020\u00142\u0006\u0010\u0016\u001a\u00020\u0014H\u0002J(\u0010\"\u001a\u00020\f2\u0006\u0010\u000f\u001a\u00020\u00102\u0006\u0010\u0013\u001a\u00020\u00142\u0006\u0010\u0015\u001a\u00020\u00142\u0006\u0010\u0016\u001a\u00020\u0014H\u0002R\u000e\u0010\u0004\u001a\u00020\u0005X\u0004¢\u0006\u0002\n\u0000R\u000e\u0010\u0007\u001a\u00020\bX\u0004¢\u0006\u0002\n\u0000R\u000e\u0010\t\u001a\u00020\nX\u0004¢\u0006\u0002\n\u0000R\u000e\u0010\u0002\u001a\u00020\u0003X\u0004¢\u0006\u0002\n\u0000¨\u0006&"}, d2 = {"Lokhttp3/internal/http2/Http2Reader;", "Ljava/io/Closeable;", "source", "Lokio/BufferedSource;", "client", "", "(Lokio/BufferedSource;Z)V", "continuation", "Lokhttp3/internal/http2/Http2Reader$ContinuationSource;", "hpackReader", "Lokhttp3/internal/http2/Hpack$Reader;", "close", "", "nextFrame", "requireSettings", "handler", "Lokhttp3/internal/http2/Http2Reader$Handler;", "readConnectionPreface", "readData", "length", "", "flags", "streamId", "readGoAway", "readHeaderBlock", "", "Lokhttp3/internal/http2/Header;", "padding", "readHeaders", "readPing", "readPriority", "readPushPromise", "readRstStream", "readSettings", "readWindowUpdate", "Companion", "ContinuationSource", "Handler", "okhttp"}, k = 1, mv = {1, 4, 0})
/* compiled from: Http2Reader.kt */
public final class Http2Reader implements Closeable {
public static final Companion Companion = new Companion((DefaultConstructorMarker) null);
/* access modifiers changed from: private */
public static final Logger logger;
private final boolean client;
private final ContinuationSource continuation;
private final Hpack.Reader hpackReader;
private final BufferedSource source;
@Metadata(bv = {1, 0, 3}, d1 = {"\u0000X\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0000\n\u0002\u0010\u0002\n\u0002\b\u0002\n\u0002\u0010\b\n\u0000\n\u0002\u0010\u000e\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0010\t\n\u0002\b\u0002\n\u0002\u0010\u000b\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\b\u000e\n\u0002\u0018\u0002\n\u0002\b\u0003\bf\u0018\u00002\u00020\u0001J\b\u0010\u0002\u001a\u00020\u0003H&J8\u0010\u0004\u001a\u00020\u00032\u0006\u0010\u0005\u001a\u00020\u00062\u0006\u0010\u0007\u001a\u00020\b2\u0006\u0010\t\u001a\u00020\n2\u0006\u0010\u000b\u001a\u00020\b2\u0006\u0010\f\u001a\u00020\u00062\u0006\u0010\r\u001a\u00020\u000eH&J(\u0010\u000f\u001a\u00020\u00032\u0006\u0010\u0010\u001a\u00020\u00112\u0006\u0010\u0005\u001a\u00020\u00062\u0006\u0010\u0012\u001a\u00020\u00132\u0006\u0010\u0014\u001a\u00020\u0006H&J \u0010\u0015\u001a\u00020\u00032\u0006\u0010\u0016\u001a\u00020\u00062\u0006\u0010\u0017\u001a\u00020\u00182\u0006\u0010\u0019\u001a\u00020\nH&J.\u0010\u001a\u001a\u00020\u00032\u0006\u0010\u0010\u001a\u00020\u00112\u0006\u0010\u0005\u001a\u00020\u00062\u0006\u0010\u001b\u001a\u00020\u00062\f\u0010\u001c\u001a\b\u0012\u0004\u0012\u00020\u001e0\u001dH&J \u0010\u001f\u001a\u00020\u00032\u0006\u0010 \u001a\u00020\u00112\u0006\u0010!\u001a\u00020\u00062\u0006\u0010\"\u001a\u00020\u0006H&J(\u0010#\u001a\u00020\u00032\u0006\u0010\u0005\u001a\u00020\u00062\u0006\u0010$\u001a\u00020\u00062\u0006\u0010%\u001a\u00020\u00062\u0006\u0010&\u001a\u00020\u0011H&J&\u0010'\u001a\u00020\u00032\u0006\u0010\u0005\u001a\u00020\u00062\u0006\u0010(\u001a\u00020\u00062\f\u0010)\u001a\b\u0012\u0004\u0012\u00020\u001e0\u001dH&J\u0018\u0010*\u001a\u00020\u00032\u0006\u0010\u0005\u001a\u00020\u00062\u0006\u0010\u0017\u001a\u00020\u0018H&J\u0018\u0010+\u001a\u00020\u00032\u0006\u0010,\u001a\u00020\u00112\u0006\u0010+\u001a\u00020-H&J\u0018\u0010.\u001a\u00020\u00032\u0006\u0010\u0005\u001a\u00020\u00062\u0006\u0010/\u001a\u00020\u000eH&¨\u00060"}, d2 = {"Lokhttp3/internal/http2/Http2Reader$Handler;", "", "ackSettings", "", "alternateService", "streamId", "", "origin", "", "protocol", "Lokio/ByteString;", "host", "port", "maxAge", "", "data", "inFinished", "", "source", "Lokio/BufferedSource;", "length", "goAway", "lastGoodStreamId", "errorCode", "Lokhttp3/internal/http2/ErrorCode;", "debugData", "headers", "associatedStreamId", "headerBlock", "", "Lokhttp3/internal/http2/Header;", "ping", "ack", "payload1", "payload2", "priority", "streamDependency", "weight", "exclusive", "pushPromise", "promisedStreamId", "requestHeaders", "rstStream", "settings", "clearPrevious", "Lokhttp3/internal/http2/Settings;", "windowUpdate", "windowSizeIncrement", "okhttp"}, k = 1, mv = {1, 4, 0})
/* compiled from: Http2Reader.kt */
public interface Handler {
void ackSettings();
void alternateService(int i, String str, ByteString byteString, String str2, int i2, long j);
void data(boolean z, int i, BufferedSource bufferedSource, int i2) throws IOException;
void goAway(int i, ErrorCode errorCode, ByteString byteString);
void headers(boolean z, int i, int i2, List<Header> list);
void ping(boolean z, int i, int i2);
void priority(int i, int i2, int i3, boolean z);
void pushPromise(int i, int i2, List<Header> list) throws IOException;
void rstStream(int i, ErrorCode errorCode);
void settings(boolean z, Settings settings);
void windowUpdate(int i, long j);
}
public Http2Reader(BufferedSource bufferedSource, boolean z) {
Intrinsics.checkNotNullParameter(bufferedSource, "source");
this.source = bufferedSource;
this.client = z;
ContinuationSource continuationSource = new ContinuationSource(bufferedSource);
this.continuation = continuationSource;
this.hpackReader = new Hpack.Reader(continuationSource, 4096, 0, 4, (DefaultConstructorMarker) null);
}
public final void readConnectionPreface(Handler handler) throws IOException {
Intrinsics.checkNotNullParameter(handler, "handler");
if (!this.client) {
ByteString readByteString = this.source.readByteString((long) Http2.CONNECTION_PREFACE.size());
Logger logger2 = logger;
if (logger2.isLoggable(Level.FINE)) {
logger2.fine(Util.format("<< CONNECTION " + readByteString.hex(), new Object[0]));
}
if (!Intrinsics.areEqual((Object) Http2.CONNECTION_PREFACE, (Object) readByteString)) {
throw new IOException("Expected a connection header but was " + readByteString.utf8());
}
} else if (!nextFrame(true, handler)) {
throw new IOException("Required SETTINGS preface not received");
}
}
public final boolean nextFrame(boolean z, Handler handler) throws IOException {
Intrinsics.checkNotNullParameter(handler, "handler");
try {
this.source.require(9);
int readMedium = Util.readMedium(this.source);
if (readMedium <= 16384) {
int and = Util.and(this.source.readByte(), 255);
int and2 = Util.and(this.source.readByte(), 255);
int readInt = this.source.readInt() & Integer.MAX_VALUE;
Logger logger2 = logger;
if (logger2.isLoggable(Level.FINE)) {
logger2.fine(Http2.INSTANCE.frameLog(true, readInt, readMedium, and, and2));
}
if (!z || and == 4) {
switch (and) {
case 0:
readData(handler, readMedium, and2, readInt);
return true;
case 1:
readHeaders(handler, readMedium, and2, readInt);
return true;
case 2:
readPriority(handler, readMedium, and2, readInt);
return true;
case 3:
readRstStream(handler, readMedium, and2, readInt);
return true;
case 4:
readSettings(handler, readMedium, and2, readInt);
return true;
case 5:
readPushPromise(handler, readMedium, and2, readInt);
return true;
case 6:
readPing(handler, readMedium, and2, readInt);
return true;
case 7:
readGoAway(handler, readMedium, and2, readInt);
return true;
case 8:
readWindowUpdate(handler, readMedium, and2, readInt);
return true;
default:
this.source.skip((long) readMedium);
return true;
}
} else {
throw new IOException("Expected a SETTINGS frame but was " + Http2.INSTANCE.formattedType$okhttp(and));
}
} else {
throw new IOException("FRAME_SIZE_ERROR: " + readMedium);
}
} catch (EOFException unused) {
return false;
}
}
private final void readHeaders(Handler handler, int i, int i2, int i3) throws IOException {
if (i3 != 0) {
int i4 = 0;
boolean z = (i2 & 1) != 0;
if ((i2 & 8) != 0) {
i4 = Util.and(this.source.readByte(), 255);
}
if ((i2 & 32) != 0) {
readPriority(handler, i3);
i -= 5;
}
handler.headers(z, i3, -1, readHeaderBlock(Companion.lengthWithoutPadding(i, i2, i4), i4, i2, i3));
return;
}
throw new IOException("PROTOCOL_ERROR: TYPE_HEADERS streamId == 0");
}
private final List<Header> readHeaderBlock(int i, int i2, int i3, int i4) throws IOException {
this.continuation.setLeft(i);
ContinuationSource continuationSource = this.continuation;
continuationSource.setLength(continuationSource.getLeft());
this.continuation.setPadding(i2);
this.continuation.setFlags(i3);
this.continuation.setStreamId(i4);
this.hpackReader.readHeaders();
return this.hpackReader.getAndResetHeaderList();
}
private final void readData(Handler handler, int i, int i2, int i3) throws IOException {
if (i3 != 0) {
int i4 = 0;
boolean z = true;
boolean z2 = (i2 & 1) != 0;
if ((i2 & 32) == 0) {
z = false;
}
if (!z) {
if ((i2 & 8) != 0) {
i4 = Util.and(this.source.readByte(), 255);
}
handler.data(z2, i3, this.source, Companion.lengthWithoutPadding(i, i2, i4));
this.source.skip((long) i4);
return;
}
throw new IOException("PROTOCOL_ERROR: FLAG_COMPRESSED without SETTINGS_COMPRESS_DATA");
}
throw new IOException("PROTOCOL_ERROR: TYPE_DATA streamId == 0");
}
private final void readPriority(Handler handler, int i, int i2, int i3) throws IOException {
if (i != 5) {
throw new IOException("TYPE_PRIORITY length: " + i + " != 5");
} else if (i3 != 0) {
readPriority(handler, i3);
} else {
throw new IOException("TYPE_PRIORITY streamId == 0");
}
}
private final void readPriority(Handler handler, int i) throws IOException {
int readInt = this.source.readInt();
handler.priority(i, readInt & Integer.MAX_VALUE, Util.and(this.source.readByte(), 255) + 1, (readInt & ((int) 2147483648L)) != 0);
}
private final void readRstStream(Handler handler, int i, int i2, int i3) throws IOException {
if (i != 4) {
throw new IOException("TYPE_RST_STREAM length: " + i + " != 4");
} else if (i3 != 0) {
int readInt = this.source.readInt();
ErrorCode fromHttp2 = ErrorCode.Companion.fromHttp2(readInt);
if (fromHttp2 != null) {
handler.rstStream(i3, fromHttp2);
return;
}
throw new IOException("TYPE_RST_STREAM unexpected error code: " + readInt);
} else {
throw new IOException("TYPE_RST_STREAM streamId == 0");
}
}
private final void readSettings(Handler handler, int i, int i2, int i3) throws IOException {
int readInt;
if (i3 != 0) {
throw new IOException("TYPE_SETTINGS streamId != 0");
} else if ((i2 & 1) != 0) {
if (i == 0) {
handler.ackSettings();
return;
}
throw new IOException("FRAME_SIZE_ERROR ack frame should be empty!");
} else if (i % 6 == 0) {
Settings settings = new Settings();
IntProgression step = RangesKt.step((IntProgression) RangesKt.until(0, i), 6);
int first = step.getFirst();
int last = step.getLast();
int step2 = step.getStep();
if (step2 < 0 ? first >= last : first <= last) {
while (true) {
int and = Util.and(this.source.readShort(), 65535);
readInt = this.source.readInt();
if (and != 2) {
if (and == 3) {
and = 4;
} else if (and == 4) {
and = 7;
if (readInt < 0) {
throw new IOException("PROTOCOL_ERROR SETTINGS_INITIAL_WINDOW_SIZE > 2^31 - 1");
}
} else if (and == 5 && (readInt < 16384 || readInt > 16777215)) {
}
} else if (!(readInt == 0 || readInt == 1)) {
throw new IOException("PROTOCOL_ERROR SETTINGS_ENABLE_PUSH != 0 or 1");
}
settings.set(and, readInt);
if (first == last) {
break;
}
first += step2;
}
throw new IOException("PROTOCOL_ERROR SETTINGS_MAX_FRAME_SIZE: " + readInt);
}
handler.settings(false, settings);
} else {
throw new IOException("TYPE_SETTINGS length % 6 != 0: " + i);
}
}
private final void readPushPromise(Handler handler, int i, int i2, int i3) throws IOException {
if (i3 != 0) {
int and = (i2 & 8) != 0 ? Util.and(this.source.readByte(), 255) : 0;
handler.pushPromise(i3, this.source.readInt() & Integer.MAX_VALUE, readHeaderBlock(Companion.lengthWithoutPadding(i - 4, i2, and), and, i2, i3));
return;
}
throw new IOException("PROTOCOL_ERROR: TYPE_PUSH_PROMISE streamId == 0");
}
private final void readPing(Handler handler, int i, int i2, int i3) throws IOException {
if (i != 8) {
throw new IOException("TYPE_PING length != 8: " + i);
} else if (i3 == 0) {
int readInt = this.source.readInt();
int readInt2 = this.source.readInt();
boolean z = true;
if ((i2 & 1) == 0) {
z = false;
}
handler.ping(z, readInt, readInt2);
} else {
throw new IOException("TYPE_PING streamId != 0");
}
}
private final void readGoAway(Handler handler, int i, int i2, int i3) throws IOException {
if (i < 8) {
throw new IOException("TYPE_GOAWAY length < 8: " + i);
} else if (i3 == 0) {
int readInt = this.source.readInt();
int readInt2 = this.source.readInt();
int i4 = i - 8;
ErrorCode fromHttp2 = ErrorCode.Companion.fromHttp2(readInt2);
if (fromHttp2 != null) {
ByteString byteString = ByteString.EMPTY;
if (i4 > 0) {
byteString = this.source.readByteString((long) i4);
}
handler.goAway(readInt, fromHttp2, byteString);
return;
}
throw new IOException("TYPE_GOAWAY unexpected error code: " + readInt2);
} else {
throw new IOException("TYPE_GOAWAY streamId != 0");
}
}
private final void readWindowUpdate(Handler handler, int i, int i2, int i3) throws IOException {
if (i == 4) {
long and = Util.and(this.source.readInt(), 2147483647L);
if (and != 0) {
handler.windowUpdate(i3, and);
return;
}
throw new IOException("windowSizeIncrement was 0");
}
throw new IOException("TYPE_WINDOW_UPDATE length !=4: " + i);
}
public void close() throws IOException {
this.source.close();
}
@Metadata(bv = {1, 0, 3}, d1 = {"\u00004\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\b\n\u0002\b\u0011\n\u0002\u0010\u0002\n\u0000\n\u0002\u0010\t\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0000\b\u0000\u0018\u00002\u00020\u0001B\r\u0012\u0006\u0010\u0002\u001a\u00020\u0003¢\u0006\u0002\u0010\u0004J\b\u0010\u0017\u001a\u00020\u0018H\u0016J\u0018\u0010\u0019\u001a\u00020\u001a2\u0006\u0010\u001b\u001a\u00020\u001c2\u0006\u0010\u001d\u001a\u00020\u001aH\u0016J\b\u0010\u001e\u001a\u00020\u0018H\u0002J\b\u0010\u001f\u001a\u00020 H\u0016R\u001a\u0010\u0005\u001a\u00020\u0006X\u000e¢\u0006\u000e\n\u0000\u001a\u0004\b\u0007\u0010\b\"\u0004\b\t\u0010\nR\u001a\u0010\u000b\u001a\u00020\u0006X\u000e¢\u0006\u000e\n\u0000\u001a\u0004\b\f\u0010\b\"\u0004\b\r\u0010\nR\u001a\u0010\u000e\u001a\u00020\u0006X\u000e¢\u0006\u000e\n\u0000\u001a\u0004\b\u000f\u0010\b\"\u0004\b\u0010\u0010\nR\u001a\u0010\u0011\u001a\u00020\u0006X\u000e¢\u0006\u000e\n\u0000\u001a\u0004\b\u0012\u0010\b\"\u0004\b\u0013\u0010\nR\u000e\u0010\u0002\u001a\u00020\u0003X\u0004¢\u0006\u0002\n\u0000R\u001a\u0010\u0014\u001a\u00020\u0006X\u000e¢\u0006\u000e\n\u0000\u001a\u0004\b\u0015\u0010\b\"\u0004\b\u0016\u0010\n¨\u0006!"}, d2 = {"Lokhttp3/internal/http2/Http2Reader$ContinuationSource;", "Lokio/Source;", "source", "Lokio/BufferedSource;", "(Lokio/BufferedSource;)V", "flags", "", "getFlags", "()I", "setFlags", "(I)V", "left", "getLeft", "setLeft", "length", "getLength", "setLength", "padding", "getPadding", "setPadding", "streamId", "getStreamId", "setStreamId", "close", "", "read", "", "sink", "Lokio/Buffer;", "byteCount", "readContinuationHeader", "timeout", "Lokio/Timeout;", "okhttp"}, k = 1, mv = {1, 4, 0})
/* compiled from: Http2Reader.kt */
public static final class ContinuationSource implements Source {
private int flags;
private int left;
private int length;
private int padding;
private final BufferedSource source;
private int streamId;
public void close() throws IOException {
}
public ContinuationSource(BufferedSource bufferedSource) {
Intrinsics.checkNotNullParameter(bufferedSource, "source");
this.source = bufferedSource;
}
public final int getLength() {
return this.length;
}
public final void setLength(int i) {
this.length = i;
}
public final int getFlags() {
return this.flags;
}
public final void setFlags(int i) {
this.flags = i;
}
public final int getStreamId() {
return this.streamId;
}
public final void setStreamId(int i) {
this.streamId = i;
}
public final int getLeft() {
return this.left;
}
public final void setLeft(int i) {
this.left = i;
}
public final int getPadding() {
return this.padding;
}
public final void setPadding(int i) {
this.padding = i;
}
public long read(Buffer buffer, long j) throws IOException {
Intrinsics.checkNotNullParameter(buffer, "sink");
while (true) {
int i = this.left;
if (i == 0) {
this.source.skip((long) this.padding);
this.padding = 0;
if ((this.flags & 4) != 0) {
return -1;
}
readContinuationHeader();
} else {
long read = this.source.read(buffer, Math.min(j, (long) i));
if (read == -1) {
return -1;
}
this.left -= (int) read;
return read;
}
}
}
public Timeout timeout() {
return this.source.timeout();
}
private final void readContinuationHeader() throws IOException {
int i = this.streamId;
int readMedium = Util.readMedium(this.source);
this.left = readMedium;
this.length = readMedium;
int and = Util.and(this.source.readByte(), 255);
this.flags = Util.and(this.source.readByte(), 255);
if (Http2Reader.Companion.getLogger().isLoggable(Level.FINE)) {
Http2Reader.Companion.getLogger().fine(Http2.INSTANCE.frameLog(true, this.streamId, this.length, and, this.flags));
}
int readInt = this.source.readInt() & Integer.MAX_VALUE;
this.streamId = readInt;
if (and != 9) {
throw new IOException(and + " != TYPE_CONTINUATION");
} else if (readInt != i) {
throw new IOException("TYPE_CONTINUATION streamId changed");
}
}
}
@Metadata(bv = {1, 0, 3}, d1 = {"\u0000\u001c\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0010\b\n\u0002\b\u0004\b\u0003\u0018\u00002\u00020\u0001B\u0007\b\u0002¢\u0006\u0002\u0010\u0002J\u001e\u0010\u0007\u001a\u00020\b2\u0006\u0010\t\u001a\u00020\b2\u0006\u0010\n\u001a\u00020\b2\u0006\u0010\u000b\u001a\u00020\bR\u0011\u0010\u0003\u001a\u00020\u0004¢\u0006\b\n\u0000\u001a\u0004\b\u0005\u0010\u0006¨\u0006\f"}, d2 = {"Lokhttp3/internal/http2/Http2Reader$Companion;", "", "()V", "logger", "Ljava/util/logging/Logger;", "getLogger", "()Ljava/util/logging/Logger;", "lengthWithoutPadding", "", "length", "flags", "padding", "okhttp"}, k = 1, mv = {1, 4, 0})
/* compiled from: Http2Reader.kt */
public static final class Companion {
private Companion() {
}
public /* synthetic */ Companion(DefaultConstructorMarker defaultConstructorMarker) {
this();
}
public final Logger getLogger() {
return Http2Reader.logger;
}
public final int lengthWithoutPadding(int i, int i2, int i3) throws IOException {
if ((i2 & 8) != 0) {
i--;
}
if (i3 <= i) {
return i - i3;
}
throw new IOException("PROTOCOL_ERROR padding " + i3 + " > remaining length " + i);
}
}
static {
Logger logger2 = Logger.getLogger(Http2.class.getName());
Intrinsics.checkNotNullExpressionValue(logger2, "Logger.getLogger(Http2::class.java.name)");
logger = logger2;
}
}
Download file