CrackMe.apk
Download file
package okhttp3.internal.concurrent;
import androidx.autofill.HintConstants;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.concurrent.CountDownLatch;
import java.util.logging.Level;
import kotlin.Metadata;
import kotlin.Unit;
import kotlin.collections.CollectionsKt;
import kotlin.jvm.functions.Function0;
import kotlin.jvm.internal.Intrinsics;
import okhttp3.internal.Util;
@Metadata(bv = {1, 0, 3}, d1 = {"\u0000V\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000e\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0010\u000b\n\u0002\b\u0005\n\u0002\u0010!\n\u0002\b\u0005\n\u0002\u0010 \n\u0002\b\u0007\n\u0002\u0010\u0002\n\u0002\b\u0004\n\u0002\u0010\t\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\b\u0018\u00002\u00020\u0001:\u00013B\u0017\b\u0000\u0012\u0006\u0010\u0002\u001a\u00020\u0003\u0012\u0006\u0010\u0004\u001a\u00020\u0005¢\u0006\u0002\u0010\u0006J\u0006\u0010!\u001a\u00020\"J\r\u0010#\u001a\u00020\u000eH\u0000¢\u0006\u0002\b$J8\u0010%\u001a\u00020\"2\u0006\u0010\u0004\u001a\u00020\u00052\b\b\u0002\u0010&\u001a\u00020'2\b\b\u0002\u0010(\u001a\u00020\u000e2\u000e\b\u0004\u0010)\u001a\b\u0012\u0004\u0012\u00020\"0*H\bø\u0001\u0000J\u0006\u0010+\u001a\u00020,J.\u0010-\u001a\u00020\"2\u0006\u0010\u0004\u001a\u00020\u00052\b\b\u0002\u0010&\u001a\u00020'2\u000e\b\u0004\u0010)\u001a\b\u0012\u0004\u0012\u00020'0*H\bø\u0001\u0000J\u0018\u0010-\u001a\u00020\"2\u0006\u0010.\u001a\u00020\b2\b\b\u0002\u0010&\u001a\u00020'J%\u0010/\u001a\u00020\u000e2\u0006\u0010.\u001a\u00020\b2\u0006\u0010&\u001a\u00020'2\u0006\u00100\u001a\u00020\u000eH\u0000¢\u0006\u0002\b1J\u0006\u0010\u001c\u001a\u00020\"J\b\u00102\u001a\u00020\u0005H\u0016R\u001c\u0010\u0007\u001a\u0004\u0018\u00010\bX\u000e¢\u0006\u000e\n\u0000\u001a\u0004\b\t\u0010\n\"\u0004\b\u000b\u0010\fR\u001a\u0010\r\u001a\u00020\u000eX\u000e¢\u0006\u000e\n\u0000\u001a\u0004\b\u000f\u0010\u0010\"\u0004\b\u0011\u0010\u0012R\u001a\u0010\u0013\u001a\b\u0012\u0004\u0012\u00020\b0\u0014X\u0004¢\u0006\b\n\u0000\u001a\u0004\b\u0015\u0010\u0016R\u0014\u0010\u0004\u001a\u00020\u0005X\u0004¢\u0006\b\n\u0000\u001a\u0004\b\u0017\u0010\u0018R\u0017\u0010\u0019\u001a\b\u0012\u0004\u0012\u00020\b0\u001a8F¢\u0006\u0006\u001a\u0004\b\u001b\u0010\u0016R\u001a\u0010\u001c\u001a\u00020\u000eX\u000e¢\u0006\u000e\n\u0000\u001a\u0004\b\u001d\u0010\u0010\"\u0004\b\u001e\u0010\u0012R\u0014\u0010\u0002\u001a\u00020\u0003X\u0004¢\u0006\b\n\u0000\u001a\u0004\b\u001f\u0010 \u0002\u0007\n\u0005\b20\u0001¨\u00064"}, d2 = {"Lokhttp3/internal/concurrent/TaskQueue;", "", "taskRunner", "Lokhttp3/internal/concurrent/TaskRunner;", "name", "", "(Lokhttp3/internal/concurrent/TaskRunner;Ljava/lang/String;)V", "activeTask", "Lokhttp3/internal/concurrent/Task;", "getActiveTask$okhttp", "()Lokhttp3/internal/concurrent/Task;", "setActiveTask$okhttp", "(Lokhttp3/internal/concurrent/Task;)V", "cancelActiveTask", "", "getCancelActiveTask$okhttp", "()Z", "setCancelActiveTask$okhttp", "(Z)V", "futureTasks", "", "getFutureTasks$okhttp", "()Ljava/util/List;", "getName$okhttp", "()Ljava/lang/String;", "scheduledTasks", "", "getScheduledTasks", "shutdown", "getShutdown$okhttp", "setShutdown$okhttp", "getTaskRunner$okhttp", "()Lokhttp3/internal/concurrent/TaskRunner;", "cancelAll", "", "cancelAllAndDecide", "cancelAllAndDecide$okhttp", "execute", "delayNanos", "", "cancelable", "block", "Lkotlin/Function0;", "idleLatch", "Ljava/util/concurrent/CountDownLatch;", "schedule", "task", "scheduleAndDecide", "recurrence", "scheduleAndDecide$okhttp", "toString", "AwaitIdleTask", "okhttp"}, k = 1, mv = {1, 4, 0})
/* compiled from: TaskQueue.kt */
public final class TaskQueue {
private Task activeTask;
private boolean cancelActiveTask;
private final List<Task> futureTasks = new ArrayList();
private final String name;
private boolean shutdown;
private final TaskRunner taskRunner;
public TaskQueue(TaskRunner taskRunner2, String str) {
Intrinsics.checkNotNullParameter(taskRunner2, "taskRunner");
Intrinsics.checkNotNullParameter(str, HintConstants.AUTOFILL_HINT_NAME);
this.taskRunner = taskRunner2;
this.name = str;
}
public final TaskRunner getTaskRunner$okhttp() {
return this.taskRunner;
}
public final String getName$okhttp() {
return this.name;
}
public final boolean getShutdown$okhttp() {
return this.shutdown;
}
public final void setShutdown$okhttp(boolean z) {
this.shutdown = z;
}
public final Task getActiveTask$okhttp() {
return this.activeTask;
}
public final void setActiveTask$okhttp(Task task) {
this.activeTask = task;
}
public final List<Task> getFutureTasks$okhttp() {
return this.futureTasks;
}
public final boolean getCancelActiveTask$okhttp() {
return this.cancelActiveTask;
}
public final void setCancelActiveTask$okhttp(boolean z) {
this.cancelActiveTask = z;
}
public final List<Task> getScheduledTasks() {
List<Task> list;
synchronized (this.taskRunner) {
list = CollectionsKt.toList(this.futureTasks);
}
return list;
}
public static /* synthetic */ void schedule$default(TaskQueue taskQueue, Task task, long j, int i, Object obj) {
if ((i & 2) != 0) {
j = 0;
}
taskQueue.schedule(task, j);
}
/* JADX WARNING: Code restructure failed: missing block: B:11:0x0026, code lost:
return;
*/
/* Code decompiled incorrectly, please refer to instructions dump. */
public final void schedule(okhttp3.internal.concurrent.Task r3, long r4) {
/*
r2 = this;
java.lang.String r0 = "task"
kotlin.jvm.internal.Intrinsics.checkNotNullParameter(r3, r0)
okhttp3.internal.concurrent.TaskRunner r0 = r2.taskRunner
monitor-enter(r0)
boolean r1 = r2.shutdown // Catch:{ all -> 0x0052 }
if (r1 == 0) goto L_0x0042
boolean r4 = r3.getCancelable() // Catch:{ all -> 0x0052 }
if (r4 == 0) goto L_0x0027
okhttp3.internal.concurrent.TaskRunner$Companion r4 = okhttp3.internal.concurrent.TaskRunner.Companion // Catch:{ all -> 0x0052 }
java.util.logging.Logger r4 = r4.getLogger() // Catch:{ all -> 0x0052 }
java.util.logging.Level r5 = java.util.logging.Level.FINE // Catch:{ all -> 0x0052 }
boolean r4 = r4.isLoggable(r5) // Catch:{ all -> 0x0052 }
if (r4 == 0) goto L_0x0025
java.lang.String r4 = "schedule canceled (queue is shutdown)"
okhttp3.internal.concurrent.TaskLoggerKt.log(r3, r2, r4) // Catch:{ all -> 0x0052 }
L_0x0025:
monitor-exit(r0)
return
L_0x0027:
okhttp3.internal.concurrent.TaskRunner$Companion r4 = okhttp3.internal.concurrent.TaskRunner.Companion // Catch:{ all -> 0x0052 }
java.util.logging.Logger r4 = r4.getLogger() // Catch:{ all -> 0x0052 }
java.util.logging.Level r5 = java.util.logging.Level.FINE // Catch:{ all -> 0x0052 }
boolean r4 = r4.isLoggable(r5) // Catch:{ all -> 0x0052 }
if (r4 == 0) goto L_0x003a
java.lang.String r4 = "schedule failed (queue is shutdown)"
okhttp3.internal.concurrent.TaskLoggerKt.log(r3, r2, r4) // Catch:{ all -> 0x0052 }
L_0x003a:
java.util.concurrent.RejectedExecutionException r3 = new java.util.concurrent.RejectedExecutionException // Catch:{ all -> 0x0052 }
r3.<init>() // Catch:{ all -> 0x0052 }
java.lang.Throwable r3 = (java.lang.Throwable) r3 // Catch:{ all -> 0x0052 }
throw r3 // Catch:{ all -> 0x0052 }
L_0x0042:
r1 = 0
boolean r3 = r2.scheduleAndDecide$okhttp(r3, r4, r1) // Catch:{ all -> 0x0052 }
if (r3 == 0) goto L_0x004e
okhttp3.internal.concurrent.TaskRunner r3 = r2.taskRunner // Catch:{ all -> 0x0052 }
r3.kickCoordinator$okhttp(r2) // Catch:{ all -> 0x0052 }
L_0x004e:
kotlin.Unit r3 = kotlin.Unit.INSTANCE // Catch:{ all -> 0x0052 }
monitor-exit(r0)
return
L_0x0052:
r3 = move-exception
monitor-exit(r0)
throw r3
*/
throw new UnsupportedOperationException("Method not decompiled: okhttp3.internal.concurrent.TaskQueue.schedule(okhttp3.internal.concurrent.Task, long):void");
}
public static /* synthetic */ void schedule$default(TaskQueue taskQueue, String str, long j, Function0 function0, int i, Object obj) {
if ((i & 2) != 0) {
j = 0;
}
Intrinsics.checkNotNullParameter(str, HintConstants.AUTOFILL_HINT_NAME);
Intrinsics.checkNotNullParameter(function0, "block");
taskQueue.schedule(new TaskQueue$schedule$2(function0, str, str), j);
}
public final void schedule(String str, long j, Function0<Long> function0) {
Intrinsics.checkNotNullParameter(str, HintConstants.AUTOFILL_HINT_NAME);
Intrinsics.checkNotNullParameter(function0, "block");
schedule(new TaskQueue$schedule$2(function0, str, str), j);
}
public static /* synthetic */ void execute$default(TaskQueue taskQueue, String str, long j, boolean z, Function0 function0, int i, Object obj) {
if ((i & 2) != 0) {
j = 0;
}
boolean z2 = (i & 4) != 0 ? true : z;
Intrinsics.checkNotNullParameter(str, HintConstants.AUTOFILL_HINT_NAME);
Intrinsics.checkNotNullParameter(function0, "block");
taskQueue.schedule(new TaskQueue$execute$1(function0, str, z2, str, z2), j);
}
public final void execute(String str, long j, boolean z, Function0<Unit> function0) {
Intrinsics.checkNotNullParameter(str, HintConstants.AUTOFILL_HINT_NAME);
Intrinsics.checkNotNullParameter(function0, "block");
schedule(new TaskQueue$execute$1(function0, str, z, str, z), j);
}
public final CountDownLatch idleLatch() {
synchronized (this.taskRunner) {
if (this.activeTask != null || !this.futureTasks.isEmpty()) {
Task task = this.activeTask;
if (task instanceof AwaitIdleTask) {
CountDownLatch latch = ((AwaitIdleTask) task).getLatch();
return latch;
}
for (Task next : this.futureTasks) {
if (next instanceof AwaitIdleTask) {
CountDownLatch latch2 = ((AwaitIdleTask) next).getLatch();
return latch2;
}
}
AwaitIdleTask awaitIdleTask = new AwaitIdleTask();
if (scheduleAndDecide$okhttp(awaitIdleTask, 0, false)) {
this.taskRunner.kickCoordinator$okhttp(this);
}
CountDownLatch latch3 = awaitIdleTask.getLatch();
return latch3;
}
CountDownLatch countDownLatch = new CountDownLatch(0);
return countDownLatch;
}
}
@Metadata(bv = {1, 0, 3}, d1 = {"\u0000\u001a\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0010\t\n\u0000\b\u0002\u0018\u00002\u00020\u0001B\u0005¢\u0006\u0002\u0010\u0002J\b\u0010\u0007\u001a\u00020\bH\u0016R\u0011\u0010\u0003\u001a\u00020\u0004¢\u0006\b\n\u0000\u001a\u0004\b\u0005\u0010\u0006¨\u0006\t"}, d2 = {"Lokhttp3/internal/concurrent/TaskQueue$AwaitIdleTask;", "Lokhttp3/internal/concurrent/Task;", "()V", "latch", "Ljava/util/concurrent/CountDownLatch;", "getLatch", "()Ljava/util/concurrent/CountDownLatch;", "runOnce", "", "okhttp"}, k = 1, mv = {1, 4, 0})
/* compiled from: TaskQueue.kt */
private static final class AwaitIdleTask extends Task {
private final CountDownLatch latch = new CountDownLatch(1);
public AwaitIdleTask() {
super(Util.okHttpName + " awaitIdle", false);
}
public final CountDownLatch getLatch() {
return this.latch;
}
public long runOnce() {
this.latch.countDown();
return -1;
}
}
public final boolean scheduleAndDecide$okhttp(Task task, long j, boolean z) {
String str;
Intrinsics.checkNotNullParameter(task, "task");
task.initQueue$okhttp(this);
long nanoTime = this.taskRunner.getBackend().nanoTime();
long j2 = nanoTime + j;
int indexOf = this.futureTasks.indexOf(task);
if (indexOf != -1) {
if (task.getNextExecuteNanoTime$okhttp() <= j2) {
if (TaskRunner.Companion.getLogger().isLoggable(Level.FINE)) {
TaskLoggerKt.log(task, this, "already scheduled");
}
return false;
}
this.futureTasks.remove(indexOf);
}
task.setNextExecuteNanoTime$okhttp(j2);
if (TaskRunner.Companion.getLogger().isLoggable(Level.FINE)) {
if (z) {
str = "run again after " + TaskLoggerKt.formatDuration(j2 - nanoTime);
} else {
str = "scheduled after " + TaskLoggerKt.formatDuration(j2 - nanoTime);
}
TaskLoggerKt.log(task, this, str);
}
Iterator<Task> it = this.futureTasks.iterator();
int i = 0;
while (true) {
if (!it.hasNext()) {
i = -1;
break;
}
if (it.next().getNextExecuteNanoTime$okhttp() - nanoTime > j) {
break;
}
i++;
}
if (i == -1) {
i = this.futureTasks.size();
}
this.futureTasks.add(i, task);
if (i == 0) {
return true;
}
return false;
}
public final boolean cancelAllAndDecide$okhttp() {
Task task = this.activeTask;
if (task != null) {
Intrinsics.checkNotNull(task);
if (task.getCancelable()) {
this.cancelActiveTask = true;
}
}
boolean z = false;
for (int size = this.futureTasks.size() - 1; size >= 0; size--) {
if (this.futureTasks.get(size).getCancelable()) {
Task task2 = this.futureTasks.get(size);
if (TaskRunner.Companion.getLogger().isLoggable(Level.FINE)) {
TaskLoggerKt.log(task2, this, "canceled");
}
this.futureTasks.remove(size);
z = true;
}
}
return z;
}
public String toString() {
return this.name;
}
public final void cancelAll() {
if (!Util.assertionsEnabled || !Thread.holdsLock(this)) {
synchronized (this.taskRunner) {
if (cancelAllAndDecide$okhttp()) {
this.taskRunner.kickCoordinator$okhttp(this);
}
Unit unit = Unit.INSTANCE;
}
return;
}
StringBuilder sb = new StringBuilder();
sb.append("Thread ");
Thread currentThread = Thread.currentThread();
Intrinsics.checkNotNullExpressionValue(currentThread, "Thread.currentThread()");
sb.append(currentThread.getName());
sb.append(" MUST NOT hold lock on ");
sb.append(this);
throw new AssertionError(sb.toString());
}
public final void shutdown() {
if (!Util.assertionsEnabled || !Thread.holdsLock(this)) {
synchronized (this.taskRunner) {
this.shutdown = true;
if (cancelAllAndDecide$okhttp()) {
this.taskRunner.kickCoordinator$okhttp(this);
}
Unit unit = Unit.INSTANCE;
}
return;
}
StringBuilder sb = new StringBuilder();
sb.append("Thread ");
Thread currentThread = Thread.currentThread();
Intrinsics.checkNotNullExpressionValue(currentThread, "Thread.currentThread()");
sb.append(currentThread.getName());
sb.append(" MUST NOT hold lock on ");
sb.append(this);
throw new AssertionError(sb.toString());
}
}
Download file