CrackMe.apk
Download file
package okhttp3.internal.http2;
import java.io.Closeable;
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 okhttp3.internal.Util;
import okhttp3.internal.http2.Hpack;
import okio.Buffer;
import okio.BufferedSink;
@Metadata(bv = {1, 0, 3}, d1 = {"\u0000\\\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000b\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0010\b\n\u0000\n\u0002\u0010\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0011\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0012\n\u0002\b\u0002\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\b\f\n\u0002\u0010\t\n\u0002\b\u0003\u0018\u0000 :2\u00020\u0001:\u0001:B\u0015\u0012\u0006\u0010\u0002\u001a\u00020\u0003\u0012\u0006\u0010\u0004\u001a\u00020\u0005¢\u0006\u0002\u0010\u0006J\u000e\u0010\u0010\u001a\u00020\u00112\u0006\u0010\u0012\u001a\u00020\u0013J\b\u0010\u0014\u001a\u00020\u0011H\u0016J\u0006\u0010\u0015\u001a\u00020\u0011J(\u0010\u0016\u001a\u00020\u00112\u0006\u0010\u0017\u001a\u00020\u00052\u0006\u0010\u0018\u001a\u00020\u000f2\b\u0010\u0019\u001a\u0004\u0018\u00010\t2\u0006\u0010\u001a\u001a\u00020\u000fJ(\u0010\u001b\u001a\u00020\u00112\u0006\u0010\u0018\u001a\u00020\u000f2\u0006\u0010\u001c\u001a\u00020\u000f2\b\u0010\u001d\u001a\u0004\u0018\u00010\t2\u0006\u0010\u001a\u001a\u00020\u000fJ\u0006\u0010\u001e\u001a\u00020\u0011J&\u0010\u001f\u001a\u00020\u00112\u0006\u0010\u0018\u001a\u00020\u000f2\u0006\u0010 \u001a\u00020\u000f2\u0006\u0010!\u001a\u00020\u000f2\u0006\u0010\u001c\u001a\u00020\u000fJ\u001e\u0010\"\u001a\u00020\u00112\u0006\u0010#\u001a\u00020\u000f2\u0006\u0010$\u001a\u00020%2\u0006\u0010&\u001a\u00020'J$\u0010(\u001a\u00020\u00112\u0006\u0010\u0017\u001a\u00020\u00052\u0006\u0010\u0018\u001a\u00020\u000f2\f\u0010)\u001a\b\u0012\u0004\u0012\u00020+0*J\u0006\u0010,\u001a\u00020\u000fJ\u001e\u0010-\u001a\u00020\u00112\u0006\u0010.\u001a\u00020\u00052\u0006\u0010/\u001a\u00020\u000f2\u0006\u00100\u001a\u00020\u000fJ$\u00101\u001a\u00020\u00112\u0006\u0010\u0018\u001a\u00020\u000f2\u0006\u00102\u001a\u00020\u000f2\f\u00103\u001a\b\u0012\u0004\u0012\u00020+0*J\u0016\u00104\u001a\u00020\u00112\u0006\u0010\u0018\u001a\u00020\u000f2\u0006\u0010$\u001a\u00020%J\u000e\u00105\u001a\u00020\u00112\u0006\u00105\u001a\u00020\u0013J\u0016\u00106\u001a\u00020\u00112\u0006\u0010\u0018\u001a\u00020\u000f2\u0006\u00107\u001a\u000208J\u0018\u00109\u001a\u00020\u00112\u0006\u0010\u0018\u001a\u00020\u000f2\u0006\u0010\u001a\u001a\u000208H\u0002R\u000e\u0010\u0004\u001a\u00020\u0005X\u0004¢\u0006\u0002\n\u0000R\u000e\u0010\u0007\u001a\u00020\u0005X\u000e¢\u0006\u0002\n\u0000R\u000e\u0010\b\u001a\u00020\tX\u0004¢\u0006\u0002\n\u0000R\u0011\u0010\n\u001a\u00020\u000b¢\u0006\b\n\u0000\u001a\u0004\b\f\u0010\rR\u000e\u0010\u000e\u001a\u00020\u000fX\u000e¢\u0006\u0002\n\u0000R\u000e\u0010\u0002\u001a\u00020\u0003X\u0004¢\u0006\u0002\n\u0000¨\u0006;"}, d2 = {"Lokhttp3/internal/http2/Http2Writer;", "Ljava/io/Closeable;", "sink", "Lokio/BufferedSink;", "client", "", "(Lokio/BufferedSink;Z)V", "closed", "hpackBuffer", "Lokio/Buffer;", "hpackWriter", "Lokhttp3/internal/http2/Hpack$Writer;", "getHpackWriter", "()Lokhttp3/internal/http2/Hpack$Writer;", "maxFrameSize", "", "applyAndAckSettings", "", "peerSettings", "Lokhttp3/internal/http2/Settings;", "close", "connectionPreface", "data", "outFinished", "streamId", "source", "byteCount", "dataFrame", "flags", "buffer", "flush", "frameHeader", "length", "type", "goAway", "lastGoodStreamId", "errorCode", "Lokhttp3/internal/http2/ErrorCode;", "debugData", "", "headers", "headerBlock", "", "Lokhttp3/internal/http2/Header;", "maxDataLength", "ping", "ack", "payload1", "payload2", "pushPromise", "promisedStreamId", "requestHeaders", "rstStream", "settings", "windowUpdate", "windowSizeIncrement", "", "writeContinuationFrames", "Companion", "okhttp"}, k = 1, mv = {1, 4, 0})
/* compiled from: Http2Writer.kt */
public final class Http2Writer implements Closeable {
public static final Companion Companion = new Companion((DefaultConstructorMarker) null);
private static final Logger logger = Logger.getLogger(Http2.class.getName());
private final boolean client;
private boolean closed;
private final Buffer hpackBuffer;
private final Hpack.Writer hpackWriter;
private int maxFrameSize = 16384;
private final BufferedSink sink;
public Http2Writer(BufferedSink bufferedSink, boolean z) {
Intrinsics.checkNotNullParameter(bufferedSink, "sink");
this.sink = bufferedSink;
this.client = z;
Buffer buffer = new Buffer();
this.hpackBuffer = buffer;
this.hpackWriter = new Hpack.Writer(0, false, buffer, 3, (DefaultConstructorMarker) null);
}
public final Hpack.Writer getHpackWriter() {
return this.hpackWriter;
}
public final synchronized void connectionPreface() throws IOException {
if (this.closed) {
throw new IOException("closed");
} else if (this.client) {
Logger logger2 = logger;
if (logger2.isLoggable(Level.FINE)) {
logger2.fine(Util.format(">> CONNECTION " + Http2.CONNECTION_PREFACE.hex(), new Object[0]));
}
this.sink.write(Http2.CONNECTION_PREFACE);
this.sink.flush();
}
}
public final synchronized void applyAndAckSettings(Settings settings) throws IOException {
Intrinsics.checkNotNullParameter(settings, "peerSettings");
if (!this.closed) {
this.maxFrameSize = settings.getMaxFrameSize(this.maxFrameSize);
if (settings.getHeaderTableSize() != -1) {
this.hpackWriter.resizeHeaderTable(settings.getHeaderTableSize());
}
frameHeader(0, 0, 4, 1);
this.sink.flush();
} else {
throw new IOException("closed");
}
}
public final synchronized void pushPromise(int i, int i2, List<Header> list) throws IOException {
Intrinsics.checkNotNullParameter(list, "requestHeaders");
if (!this.closed) {
this.hpackWriter.writeHeaders(list);
long size = this.hpackBuffer.size();
int min = (int) Math.min(((long) this.maxFrameSize) - 4, size);
int i3 = min + 4;
long j = (long) min;
int i4 = (size > j ? 1 : (size == j ? 0 : -1));
frameHeader(i, i3, 5, i4 == 0 ? 4 : 0);
this.sink.writeInt(i2 & Integer.MAX_VALUE);
this.sink.write(this.hpackBuffer, j);
if (i4 > 0) {
writeContinuationFrames(i, size - j);
}
} else {
throw new IOException("closed");
}
}
public final synchronized void flush() throws IOException {
if (!this.closed) {
this.sink.flush();
} else {
throw new IOException("closed");
}
}
public final synchronized void rstStream(int i, ErrorCode errorCode) throws IOException {
Intrinsics.checkNotNullParameter(errorCode, "errorCode");
if (!this.closed) {
if (errorCode.getHttpCode() != -1) {
frameHeader(i, 4, 3, 0);
this.sink.writeInt(errorCode.getHttpCode());
this.sink.flush();
} else {
throw new IllegalArgumentException("Failed requirement.".toString());
}
} else {
throw new IOException("closed");
}
}
public final int maxDataLength() {
return this.maxFrameSize;
}
public final synchronized void data(boolean z, int i, Buffer buffer, int i2) throws IOException {
if (!this.closed) {
dataFrame(i, z ? 1 : 0, buffer, i2);
} else {
throw new IOException("closed");
}
}
public final void dataFrame(int i, int i2, Buffer buffer, int i3) throws IOException {
frameHeader(i, i3, 0, i2);
if (i3 > 0) {
BufferedSink bufferedSink = this.sink;
Intrinsics.checkNotNull(buffer);
bufferedSink.write(buffer, (long) i3);
}
}
public final synchronized void settings(Settings settings) throws IOException {
Intrinsics.checkNotNullParameter(settings, "settings");
if (!this.closed) {
int i = 0;
frameHeader(0, settings.size() * 6, 4, 0);
while (i < 10) {
if (settings.isSet(i)) {
this.sink.writeShort(i != 4 ? i != 7 ? i : 4 : 3);
this.sink.writeInt(settings.get(i));
}
i++;
}
this.sink.flush();
} else {
throw new IOException("closed");
}
}
public final synchronized void ping(boolean z, int i, int i2) throws IOException {
if (!this.closed) {
frameHeader(0, 8, 6, z ? 1 : 0);
this.sink.writeInt(i);
this.sink.writeInt(i2);
this.sink.flush();
} else {
throw new IOException("closed");
}
}
public final synchronized void goAway(int i, ErrorCode errorCode, byte[] bArr) throws IOException {
Intrinsics.checkNotNullParameter(errorCode, "errorCode");
Intrinsics.checkNotNullParameter(bArr, "debugData");
if (!this.closed) {
boolean z = false;
if (errorCode.getHttpCode() != -1) {
frameHeader(0, bArr.length + 8, 7, 0);
this.sink.writeInt(i);
this.sink.writeInt(errorCode.getHttpCode());
if (bArr.length == 0) {
z = true;
}
if (!z) {
this.sink.write(bArr);
}
this.sink.flush();
} else {
throw new IllegalArgumentException("errorCode.httpCode == -1".toString());
}
} else {
throw new IOException("closed");
}
}
public final synchronized void windowUpdate(int i, long j) throws IOException {
if (!this.closed) {
if (j != 0 && j <= 2147483647L) {
frameHeader(i, 4, 8, 0);
this.sink.writeInt((int) j);
this.sink.flush();
} else {
throw new IllegalArgumentException(("windowSizeIncrement == 0 || windowSizeIncrement > 0x7fffffffL: " + j).toString());
}
} else {
throw new IOException("closed");
}
}
public final void frameHeader(int i, int i2, int i3, int i4) throws IOException {
Logger logger2 = logger;
if (logger2.isLoggable(Level.FINE)) {
logger2.fine(Http2.INSTANCE.frameLog(false, i, i2, i3, i4));
}
boolean z = true;
if (i2 <= this.maxFrameSize) {
if ((((int) 2147483648L) & i) != 0) {
z = false;
}
if (z) {
Util.writeMedium(this.sink, i2);
this.sink.writeByte(i3 & 255);
this.sink.writeByte(i4 & 255);
this.sink.writeInt(i & Integer.MAX_VALUE);
return;
}
throw new IllegalArgumentException(("reserved bit set: " + i).toString());
}
throw new IllegalArgumentException(("FRAME_SIZE_ERROR length > " + this.maxFrameSize + ": " + i2).toString());
}
public synchronized void close() throws IOException {
this.closed = true;
this.sink.close();
}
private final void writeContinuationFrames(int i, long j) throws IOException {
while (j > 0) {
long min = Math.min((long) this.maxFrameSize, j);
j -= min;
frameHeader(i, (int) min, 9, j == 0 ? 4 : 0);
this.sink.write(this.hpackBuffer, min);
}
}
public final synchronized void headers(boolean z, int i, List<Header> list) throws IOException {
Intrinsics.checkNotNullParameter(list, "headerBlock");
if (!this.closed) {
this.hpackWriter.writeHeaders(list);
long size = this.hpackBuffer.size();
long min = Math.min((long) this.maxFrameSize, size);
int i2 = (size > min ? 1 : (size == min ? 0 : -1));
int i3 = i2 == 0 ? 4 : 0;
if (z) {
i3 |= 1;
}
frameHeader(i, (int) min, 1, i3);
this.sink.write(this.hpackBuffer, min);
if (i2 > 0) {
writeContinuationFrames(i, size - min);
}
} else {
throw new IOException("closed");
}
}
@Metadata(bv = {1, 0, 3}, d1 = {"\u0000\u0014\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\b\u0003\u0018\u00002\u00020\u0001B\u0007\b\u0002¢\u0006\u0002\u0010\u0002R\u0016\u0010\u0003\u001a\n \u0005*\u0004\u0018\u00010\u00040\u0004X\u0004¢\u0006\u0002\n\u0000¨\u0006\u0006"}, d2 = {"Lokhttp3/internal/http2/Http2Writer$Companion;", "", "()V", "logger", "Ljava/util/logging/Logger;", "kotlin.jvm.PlatformType", "okhttp"}, k = 1, mv = {1, 4, 0})
/* compiled from: Http2Writer.kt */
public static final class Companion {
private Companion() {
}
public /* synthetic */ Companion(DefaultConstructorMarker defaultConstructorMarker) {
this();
}
}
}
Download file