package defpackage;

import android.os.Process;
import com.google.android.datatransport.runtime.scheduling.jobscheduling.AlarmManagerSchedulerBroadcastReceiver;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.atomic.AtomicBoolean;

/* JADX INFO: loaded from: classes.dex */
public final /* synthetic */ class gh implements Runnable {
    public final /* synthetic */ int a;

    public /* synthetic */ gh(int i) {
        this.a = i;
    }

    @Override // java.lang.Runnable
    public final void run() {
        switch (this.a) {
            case 0:
                int i = AlarmManagerSchedulerBroadcastReceiver.a;
                return;
            default:
                AtomicBoolean atomicBoolean = kq.g;
                try {
                    int iMyPid = Process.myPid();
                    Runtime.getRuntime().exec("logcat -c").waitFor();
                    kq.f = Runtime.getRuntime().exec(new String[]{"logcat", "-v", "threadtime", "--pid=" + iMyPid, "*:E"});
                    Process process = kq.f;
                    cr4.d(process);
                    BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(process.getInputStream()));
                    for (String line = bufferedReader.readLine(); atomicBoolean.get() && line != null; line = bufferedReader.readLine()) {
                        ExecutorService executorService = kq.a;
                        kq.a.execute(new r21(line + "\n", 7));
                    }
                    bufferedReader.close();
                    break;
                } catch (Exception unused) {
                } catch (Throwable th) {
                    atomicBoolean.set(false);
                    throw th;
                }
                atomicBoolean.set(false);
                return;
        }
    }
}