package defpackage;

import android.util.Log;
import androidx.credentials.exceptions.publickeycredential.DomExceptionUtils;
import androidx.media3.container.NalUnitUtil;
import androidx.media3.exoplayer.rtsp.RtspHeaders;
import androidx.media3.exoplayer.rtsp.SessionDescription;
import androidx.media3.exoplayer.upstream.CmcdData;
import com.google.android.gms.common.internal.ImagesContract;
import defpackage.g17;
import fi.iki.elonen.NanoHTTPD;
import java.net.URLDecoder;
import java.util.Collection;
import java.util.Iterator;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.locks.ReentrantLock;
import java.util.logging.Logger;
import kotlin.Metadata;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;

/* JADX INFO: loaded from: classes3.dex */
@Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0018\u00002\u00020\u0001:\u0001\u0002¨\u0006\u0003"}, d2 = {"Le17;", "Lfi/iki/elonen/NanoHTTPD;", CmcdData.OBJECT_TYPE_AUDIO_ONLY, "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
@vx8
public final class e17 extends NanoHTTPD {
    public static final /* synthetic */ int e = 0;
    public final OkHttpClient a;
    public final ll7 b;
    public final ConcurrentHashMap c;
    public volatile boolean d;

    @Metadata(d1 = {"\u0000\u0010\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0010\u000e\n\u0002\b\u0003\b\u0086\u0003\u0018\u00002\u00020\u0001R\u0014\u0010\u0003\u001a\u00020\u00028\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u0003\u0010\u0004¨\u0006\u0005"}, d2 = {"Le17$a;", "", "", "TAG", "Ljava/lang/String;", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    public static final class a {
    }

    /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
    public e17(OkHttpClient okHttpClient, ll7 ll7Var) {
        super("127.0.0.1", 0);
        cr4.g(okHttpClient, "client");
        this.a = okHttpClient;
        this.b = ll7Var;
        Logger.getLogger(NanoHTTPD.class.getName()).setFilter(new c17());
        this.c = new ConcurrentHashMap();
    }

    public final void a() {
        ConcurrentHashMap concurrentHashMap = this.c;
        Collection collectionValues = concurrentHashMap.values();
        cr4.f(collectionValues, "<get-values>(...)");
        Iterator it = collectionValues.iterator();
        while (it.hasNext()) {
            ((g17) it.next()).a();
        }
        concurrentHashMap.clear();
    }

    public final void b(String str) {
        cr4.g(str, "upstreamUrl");
        g17 g17Var = (g17) this.c.remove(str);
        if (g17Var != null) {
            g17Var.a();
        }
    }

    /* JADX WARN: Multi-variable type inference failed */
    /* JADX WARN: Removed duplicated region for block: B:104:0x026a  */
    /* JADX WARN: Removed duplicated region for block: B:116:0x028b A[Catch: all -> 0x0283, TryCatch #0 {all -> 0x0283, blocks: (B:108:0x0279, B:116:0x028b, B:118:0x0290, B:120:0x02b1, B:117:0x028e), top: B:210:0x0279 }] */
    /* JADX WARN: Removed duplicated region for block: B:117:0x028e A[Catch: all -> 0x0283, TryCatch #0 {all -> 0x0283, blocks: (B:108:0x0279, B:116:0x028b, B:118:0x0290, B:120:0x02b1, B:117:0x028e), top: B:210:0x0279 }] */
    /* JADX WARN: Removed duplicated region for block: B:120:0x02b1 A[Catch: all -> 0x0283, TRY_LEAVE, TryCatch #0 {all -> 0x0283, blocks: (B:108:0x0279, B:116:0x028b, B:118:0x0290, B:120:0x02b1, B:117:0x028e), top: B:210:0x0279 }] */
    /* JADX WARN: Removed duplicated region for block: B:126:0x02be  */
    /* JADX WARN: Removed duplicated region for block: B:139:0x02f9 A[Catch: all -> 0x030c, TryCatch #7 {all -> 0x030c, blocks: (B:137:0x02f3, B:139:0x02f9, B:141:0x0301, B:143:0x0307, B:147:0x0311), top: B:220:0x02f3, outer: #8 }] */
    /* JADX WARN: Removed duplicated region for block: B:151:0x0334 A[Catch: Exception -> 0x0332, TRY_LEAVE, TryCatch #8 {Exception -> 0x0332, blocks: (B:136:0x02d6, B:148:0x032d, B:151:0x0334, B:155:0x033a, B:156:0x033d, B:137:0x02f3, B:139:0x02f9, B:141:0x0301, B:143:0x0307, B:147:0x0311, B:153:0x0338), top: B:222:0x02d6, inners: #7, #16 }] */
    /* JADX WARN: Removed duplicated region for block: B:162:0x035a  */
    /* JADX WARN: Removed duplicated region for block: B:164:0x0373  */
    /* JADX WARN: Removed duplicated region for block: B:96:0x0252 A[Catch: all -> 0x02ba, TRY_LEAVE, TryCatch #17 {all -> 0x02ba, blocks: (B:94:0x024c, B:96:0x0252, B:105:0x026c), top: B:237:0x024c }] */
    /* JADX WARN: Type inference failed for: r0v78, types: [fi.iki.elonen.NanoHTTPD$Response] */
    /* JADX WARN: Type inference failed for: r0v85, types: [java.util.concurrent.ConcurrentHashMap] */
    /* JADX WARN: Type inference failed for: r0v90 */
    /* JADX WARN: Type inference failed for: r0v91 */
    /* JADX WARN: Type inference failed for: r24v2, types: [java.lang.String] */
    /* JADX WARN: Type inference failed for: r2v0 */
    /* JADX WARN: Type inference failed for: r2v1, types: [java.io.Serializable, java.lang.CharSequence, java.lang.Object] */
    /* JADX WARN: Type inference failed for: r2v12 */
    /* JADX WARN: Type inference failed for: r2v16 */
    /* JADX WARN: Type inference failed for: r2v17 */
    /* JADX WARN: Type inference failed for: r2v18 */
    /* JADX WARN: Type inference failed for: r2v19, types: [int] */
    /* JADX WARN: Type inference failed for: r2v2 */
    /* JADX WARN: Type inference failed for: r2v22 */
    /* JADX WARN: Type inference failed for: r2v3 */
    /* JADX WARN: Type inference failed for: r2v35, types: [java.lang.Object] */
    /* JADX WARN: Type inference failed for: r2v4, types: [java.lang.String] */
    /* JADX WARN: Type inference failed for: r2v45 */
    /* JADX WARN: Type inference failed for: r2v47 */
    /* JADX WARN: Type inference failed for: r2v48 */
    /* JADX WARN: Type inference failed for: r2v49 */
    /* JADX WARN: Type inference failed for: r31v0 */
    /* JADX WARN: Type inference failed for: r31v1 */
    /* JADX WARN: Type inference failed for: r31v10 */
    /* JADX WARN: Type inference failed for: r31v11 */
    /* JADX WARN: Type inference failed for: r31v12 */
    /* JADX WARN: Type inference failed for: r31v2 */
    /* JADX WARN: Type inference failed for: r31v3 */
    /* JADX WARN: Type inference failed for: r31v4 */
    /* JADX WARN: Type inference failed for: r31v5 */
    /* JADX WARN: Type inference failed for: r31v6 */
    /* JADX WARN: Type inference failed for: r31v7 */
    /* JADX WARN: Type inference failed for: r31v8 */
    /* JADX WARN: Type inference failed for: r31v9 */
    /* JADX WARN: Type inference failed for: r4v1, types: [java.lang.String] */
    /* JADX WARN: Type inference failed for: r4v10 */
    /* JADX WARN: Type inference failed for: r4v15 */
    /* JADX WARN: Type inference failed for: r4v2 */
    /* JADX WARN: Type inference failed for: r4v25 */
    /* JADX WARN: Type inference failed for: r4v26 */
    /* JADX WARN: Type inference failed for: r4v27, types: [java.lang.Throwable] */
    /* JADX WARN: Type inference failed for: r4v3 */
    /* JADX WARN: Type inference failed for: r4v38 */
    /* JADX WARN: Type inference failed for: r4v39 */
    /* JADX WARN: Type inference failed for: r4v4 */
    /* JADX WARN: Type inference failed for: r4v42 */
    /* JADX WARN: Type inference failed for: r4v45 */
    /* JADX WARN: Type inference failed for: r4v46 */
    /* JADX WARN: Type inference failed for: r4v47 */
    /* JADX WARN: Type inference failed for: r4v48 */
    /* JADX WARN: Type inference failed for: r4v49 */
    /* JADX WARN: Type inference failed for: r4v5 */
    /* JADX WARN: Type inference failed for: r4v50 */
    /* JADX WARN: Type inference failed for: r4v51 */
    /* JADX WARN: Type inference failed for: r4v54 */
    /* JADX WARN: Type inference failed for: r4v55 */
    /* JADX WARN: Type inference failed for: r4v56 */
    /* JADX WARN: Type inference failed for: r4v58 */
    /* JADX WARN: Type inference failed for: r4v59 */
    /* JADX WARN: Type inference failed for: r4v6 */
    /* JADX WARN: Type inference failed for: r4v61 */
    /* JADX WARN: Type inference failed for: r4v62 */
    /* JADX WARN: Type inference failed for: r4v7 */
    /* JADX WARN: Type inference failed for: r4v8 */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final NanoHTTPD.Response c(NanoHTTPD.IHTTPSession iHTTPSession) throws Throwable {
        ?? Decode;
        tp5 tp5VarB;
        q07 q07Var;
        Long lBf;
        CharSequence charSequence;
        long j;
        long j2;
        String str;
        String str2;
        ?? r31;
        ?? r312;
        ?? r4;
        ?? r2;
        ?? r42;
        ?? r43;
        long j3;
        Response responseExecute;
        Long lBf2;
        ?? r44;
        long j4;
        Response responseExecute2;
        CharSequence charSequence2;
        Throwable th;
        CharSequence charSequence3;
        CharSequence charSequence4;
        boolean z;
        Response responseExecute3;
        ?? Code;
        Object obj;
        long j5;
        Long lBf3;
        ?? r45;
        Object obj2;
        long jLongValue;
        String str3;
        Long lBf4;
        ?? r313;
        ?? r46;
        long j6;
        long j7;
        ?? r314;
        try {
            String str4 = iHTTPSession.getParms().get(ImagesContract.URL);
            if (str4 == null) {
                str4 = "";
            }
            Decode = URLDecoder.decode(str4, "UTF-8");
        } catch (Exception unused) {
            Decode = "";
        }
        cr4.d(Decode);
        if (n89.ab(Decode)) {
            NanoHTTPD.Response responseNewFixedLengthResponse = NanoHTTPD.newFixedLengthResponse(NanoHTTPD.Response.Status.BAD_REQUEST, NanoHTTPD.MIME_PLAINTEXT, "Missing url param");
            cr4.f(responseNewFixedLengthResponse, "newFixedLengthResponse(...)");
            return responseNewFixedLengthResponse;
        }
        String str5 = iHTTPSession.getHeaders().get(SessionDescription.ATTR_RANGE);
        if (str5 == null || (tp5VarB = new pw7("bytes=(\\d+)-(\\d*)").b(str5)) == null) {
            q07Var = new q07(0L, -1L);
        } else {
            Long lBf5 = n89.bf((String) tp5VarB.b().get(1));
            q07Var = new q07(Long.valueOf(lBf5 != null ? lBf5.longValue() : 0L), Long.valueOf((((CharSequence) tp5VarB.b().get(2)).length() <= 0 || (lBf = n89.bf((String) tp5VarB.b().get(2))) == null) ? -1L : lBf.longValue()));
        }
        long jLongValue2 = ((Number) q07Var.a).longValue();
        long jLongValue3 = ((Number) q07Var.b).longValue();
        Object objCompute = this.c.compute(Decode, new d17(new bf1(Decode, this, 1), 0));
        cr4.d(objCompute);
        g17 g17Var = (g17) objCompute;
        if (g17Var.d <= 0) {
            charSequence = "bytes";
            j = jLongValue2;
            j2 = jLongValue3;
            str = "newFixedLengthResponse(...)";
            ?? r47 = "Probe OK: size=";
            str2 = NanoHTTPD.MIME_PLAINTEXT;
            try {
                r31 = Decode;
            } catch (Exception e2) {
                e = e2;
                r31 = Decode;
            }
            try {
                try {
                    responseExecute3 = g17Var.b.newCall(new Request.Builder().url(g17Var.a).header(RtspHeaders.RANGE, "bytes=0-0").header(RtspHeaders.ACCEPT, "*/*").build()).execute();
                    try {
                        Code = responseExecute3.code();
                        try {
                        } catch (Throwable th2) {
                            th = th2;
                            r47 = th;
                            Decode = Code;
                            try {
                                throw r47;
                            } finally {
                            }
                        }
                    } catch (Throwable th3) {
                        th = th3;
                        Code = "HEAD probe: size=";
                    }
                } catch (Exception e3) {
                    e = e3;
                    n41.ab("Range probe failed: ", e.getMessage(), "StreamSession");
                    r2 = Decode;
                    r4 = r47;
                    r312 = r31;
                }
            } catch (Exception e4) {
                e = e4;
                Decode = "HEAD probe: size=";
                n41.ab("Range probe failed: ", e.getMessage(), "StreamSession");
                r2 = Decode;
                r4 = r47;
                r312 = r31;
                try {
                    try {
                        responseExecute2 = g17Var.b.newCall(new Request.Builder().url(g17Var.a).head().header(RtspHeaders.ACCEPT, "*/*").build()).execute();
                    } catch (Exception e5) {
                        e = e5;
                        r42 = charSequence;
                        n41.ab("HEAD probe failed: ", e.getMessage(), "StreamSession");
                        r43 = r42;
                        try {
                            responseExecute = g17Var.b.newCall(new Request.Builder().url(g17Var.a).header(RtspHeaders.ACCEPT, "*/*").build()).execute();
                            try {
                                if (responseExecute.isSuccessful()) {
                                }
                            } finally {
                            }
                        } catch (Exception e6) {
                            Log.e("StreamSession", "All probes failed: " + e6.getMessage());
                        }
                        Log.e("StreamSession", "All probes failed: " + e6.getMessage());
                        j3 = -1;
                        r44 = r43;
                        j4 = j3;
                        r46 = r44;
                        r313 = r312;
                        if (j4 <= 0) {
                        }
                    }
                } catch (Exception e7) {
                    e = e7;
                    r42 = r4;
                    n41.ab("HEAD probe failed: ", e.getMessage(), "StreamSession");
                    r43 = r42;
                    responseExecute = g17Var.b.newCall(new Request.Builder().url(g17Var.a).header(RtspHeaders.ACCEPT, "*/*").build()).execute();
                    if (responseExecute.isSuccessful()) {
                    }
                    Log.e("StreamSession", "All probes failed: " + e6.getMessage());
                    j3 = -1;
                    r44 = r43;
                    j4 = j3;
                    r46 = r44;
                    r313 = r312;
                    if (j4 <= 0) {
                    }
                }
                try {
                    if (responseExecute2.isSuccessful()) {
                    }
                    responseExecute2.close();
                    r43 = charSequence3;
                    responseExecute = g17Var.b.newCall(new Request.Builder().url(g17Var.a).header(RtspHeaders.ACCEPT, "*/*").build()).execute();
                    if (responseExecute.isSuccessful()) {
                    }
                    Log.e("StreamSession", "All probes failed: " + e6.getMessage());
                    j3 = -1;
                    r44 = r43;
                    j4 = j3;
                    r46 = r44;
                    r313 = r312;
                    if (j4 <= 0) {
                    }
                } catch (Throwable th4) {
                    th = th4;
                    charSequence2 = charSequence;
                }
            }
            if (Code != 200) {
                try {
                    if (Code != 206) {
                        Log.w("StreamSession", "Probe Range got HTTP " + responseExecute3.code());
                        obj = "HEAD probe: size=";
                        r45 = "Probe OK: size=";
                    } else {
                        String strHeader$default = Response.header$default(responseExecute3, "Content-Range", null, 2, null);
                        if (strHeader$default == null) {
                            strHeader$default = "";
                        }
                        tp5 tp5VarB2 = new pw7("bytes \\d+-\\d+/(\\d+)").b(strHeader$default);
                        if (tp5VarB2 == null || (str3 = (String) tp5VarB2.b().get(1)) == null || (lBf4 = n89.bf(str3)) == null) {
                            obj2 = "HEAD probe: size=";
                            jLongValue = -1;
                        } else {
                            obj2 = "HEAD probe: size=";
                            jLongValue = lBf4.longValue();
                        }
                        g17Var.d = jLongValue;
                        obj = obj2;
                        r45 = "Probe OK: size=";
                        if (g17Var.d > 0) {
                            g17Var.e = g17.b.a;
                            Log.w("StreamSession", "Probe OK: size=" + g17Var.d + ", mode=PARALLEL");
                            j5 = g17Var.d;
                            responseExecute3.close();
                            j4 = j5;
                            r314 = r31;
                        }
                    }
                    responseExecute3.close();
                    r2 = obj;
                    r4 = r45;
                    r312 = r31;
                    responseExecute2 = g17Var.b.newCall(new Request.Builder().url(g17Var.a).head().header(RtspHeaders.ACCEPT, "*/*").build()).execute();
                    if (responseExecute2.isSuccessful()) {
                        String strHeader$default2 = Response.header$default(responseExecute2, RtspHeaders.CONTENT_LENGTH, null, 2, null);
                        if (strHeader$default2 != null) {
                            try {
                                Long lBf6 = n89.bf(strHeader$default2);
                                long jLongValue4 = lBf6 != null ? lBf6.longValue() : -1L;
                                g17Var.d = jLongValue4;
                                String strHeader$default3 = Response.header$default(responseExecute2, "Accept-Ranges", null, 2, null);
                                if (strHeader$default3 != null) {
                                    charSequence2 = charSequence;
                                    try {
                                        boolean zL = n89.l(strHeader$default3, charSequence2, true);
                                        charSequence4 = charSequence2;
                                        if (zL) {
                                            z = true;
                                            charSequence2 = charSequence2;
                                        }
                                        g17Var.e = !z ? g17.b.a : g17.b.c;
                                        Log.w("StreamSession", ((String) r2) + g17Var.d + ", acceptsRange=" + z);
                                        charSequence3 = charSequence2;
                                        if (g17Var.d > 0) {
                                            j3 = g17Var.d;
                                            responseExecute2.close();
                                            r44 = charSequence2;
                                            j4 = j3;
                                            r46 = r44;
                                            r313 = r312;
                                        }
                                    } catch (Throwable th5) {
                                        th = th5;
                                        th = th;
                                        r4 = charSequence2;
                                        try {
                                            throw th;
                                        } finally {
                                        }
                                    }
                                } else {
                                    charSequence4 = charSequence;
                                }
                                z = false;
                                charSequence2 = charSequence4;
                                g17Var.e = !z ? g17.b.a : g17.b.c;
                                Log.w("StreamSession", ((String) r2) + g17Var.d + ", acceptsRange=" + z);
                                charSequence3 = charSequence2;
                                if (g17Var.d > 0) {
                                }
                            } catch (Throwable th6) {
                                th = th6;
                                r4 = charSequence;
                                throw th;
                            }
                        }
                    } else {
                        charSequence3 = charSequence;
                    }
                    responseExecute2.close();
                    r43 = charSequence3;
                    responseExecute = g17Var.b.newCall(new Request.Builder().url(g17Var.a).header(RtspHeaders.ACCEPT, "*/*").build()).execute();
                    if (responseExecute.isSuccessful()) {
                        String strHeader$default4 = Response.header$default(responseExecute, RtspHeaders.CONTENT_LENGTH, null, 2, null);
                        g17Var.d = (strHeader$default4 == null || (lBf2 = n89.bf(strHeader$default4)) == null) ? -1L : lBf2.longValue();
                        g17Var.e = g17.b.c;
                        Log.w("StreamSession", "GET probe: size=" + g17Var.d + ", mode=SINGLE_GET");
                        long j8 = g17Var.d;
                        responseExecute.close();
                        j3 = j8;
                        r44 = r43;
                        j4 = j3;
                        r46 = r44;
                        r313 = r312;
                    } else {
                        responseExecute.close();
                        j3 = -1;
                        r44 = r43;
                        j4 = j3;
                        r46 = r44;
                        r313 = r312;
                    }
                    Log.e("StreamSession", "All probes failed: " + e6.getMessage());
                    j3 = -1;
                    r44 = r43;
                    j4 = j3;
                    r46 = r44;
                    r313 = r312;
                } catch (Throwable th7) {
                    r47 = th7;
                    Decode = "HEAD probe: size=";
                    throw r47;
                }
            } else {
                obj = "HEAD probe: size=";
                String strHeader$default5 = Response.header$default(responseExecute3, RtspHeaders.CONTENT_LENGTH, null, 2, null);
                g17Var.d = (strHeader$default5 == null || (lBf3 = n89.bf(strHeader$default5)) == null) ? -1L : lBf3.longValue();
                g17Var.e = g17.b.c;
                Log.w("StreamSession", "Probe: no Range support, size=" + g17Var.d + ", mode=SINGLE_GET");
                long j9 = g17Var.d;
                r45 = j9;
                if (j9 > 0) {
                    j5 = g17Var.d;
                    responseExecute3.close();
                    j4 = j5;
                    r314 = r31;
                }
                responseExecute3.close();
                r2 = obj;
                r4 = r45;
                r312 = r31;
                responseExecute2 = g17Var.b.newCall(new Request.Builder().url(g17Var.a).head().header(RtspHeaders.ACCEPT, "*/*").build()).execute();
                if (responseExecute2.isSuccessful()) {
                }
                responseExecute2.close();
                r43 = charSequence3;
                responseExecute = g17Var.b.newCall(new Request.Builder().url(g17Var.a).header(RtspHeaders.ACCEPT, "*/*").build()).execute();
                if (responseExecute.isSuccessful()) {
                }
                Log.e("StreamSession", "All probes failed: " + e6.getMessage());
                j3 = -1;
                r44 = r43;
                j4 = j3;
                r46 = r44;
                r313 = r312;
            }
            if (j4 <= 0) {
                this.c.remove(r313);
                NanoHTTPD.Response responseNewFixedLengthResponse2 = NanoHTTPD.newFixedLengthResponse(NanoHTTPD.Response.Status.INTERNAL_ERROR, str2, "Upstream error");
                cr4.f(responseNewFixedLengthResponse2, str);
                return responseNewFixedLengthResponse2;
            }
            long jMin = j4 - 1;
            if (j2 >= 0) {
                jMin = Math.min(j2, jMin);
            }
            long j10 = (jMin - j) + 1;
            int iIncrementAndGet = g17Var.m.incrementAndGet();
            g17Var.b();
            ExecutorService executorService = g17Var.f;
            if (executorService != null) {
                executorService.shutdownNow();
            }
            long j11 = j;
            g17Var.o = j11;
            g17Var.p = jMin;
            g17Var.j.set(0);
            g17Var.k.set(0);
            g17Var.l.set(0);
            g17Var.n.clear();
            g17Var.q = false;
            g17Var.c.getClass();
            g17Var.f = Executors.newFixedThreadPool(4, new va1(g17Var, 3));
            q59 q59Var = g17Var.i;
            if (q59Var != null) {
                q59Var.c(j11);
            } else {
                g17Var.c.getClass();
                g17Var.i = new q59(j11);
            }
            g17.b bVar = g17Var.e;
            ?? r24 = r46;
            StringBuilder sbP = vw2.p(j11, "seekTo(", "-");
            sbP.append(jMin);
            sbP.append(") gen=");
            sbP.append(iIncrementAndGet);
            sbP.append(" mode=");
            sbP.append(bVar);
            Log.w("StreamSession", sbP.toString());
            int iOrdinal = g17Var.e.ordinal();
            if (iOrdinal == 0) {
                j6 = j11;
                j7 = jMin;
                g17Var.h(iIncrementAndGet, j6, j7);
            } else if (iOrdinal != 1) {
                if (iOrdinal == 2) {
                    fia fiaVar = new fia(g17Var, iIncrementAndGet, 2, j11);
                    g17Var = g17Var;
                    j6 = j11;
                    if (!g17Var.k(fiaVar) && g17Var.m.get() == iIncrementAndGet) {
                        g17Var.f();
                    }
                } else {
                    if (iOrdinal != 3) {
                        throw new io6();
                    }
                    g17Var.q = true;
                    q59 q59Var2 = g17Var.i;
                    if (q59Var2 != null) {
                        ReentrantLock reentrantLock = q59Var2.b;
                        reentrantLock.lock();
                        try {
                            q59Var2.g = true;
                            q59Var2.c.signalAll();
                        } finally {
                            reentrantLock.unlock();
                        }
                    }
                    j6 = j11;
                }
                j7 = jMin;
            } else {
                j6 = j11;
                j7 = jMin;
                g17Var.i(iIncrementAndGet, j6, j7);
            }
            long j12 = j7;
            long j13 = j6;
            h17 h17Var = new h17(j13, j12, g17Var, g17Var.m.get());
            ?? NewFixedLengthResponse = str5 != null ? NanoHTTPD.newFixedLengthResponse(NanoHTTPD.Response.Status.PARTIAL_CONTENT, "application/octet-stream", h17Var, j10) : NanoHTTPD.newFixedLengthResponse(NanoHTTPD.Response.Status.OK, "application/octet-stream", h17Var, j10);
            if (str5 != null) {
                StringBuilder sbP2 = vw2.p(j13, "bytes ", "-");
                sbP2.append(j12);
                sbP2.append(DomExceptionUtils.SEPARATOR);
                sbP2.append(j4);
                NewFixedLengthResponse.addHeader("Content-Range", sbP2.toString());
            }
            NewFixedLengthResponse.addHeader("Accept-Ranges", r24);
            NewFixedLengthResponse.addHeader(RtspHeaders.CONTENT_LENGTH, String.valueOf(j10));
            return NewFixedLengthResponse;
        }
        charSequence = "bytes";
        j4 = g17Var.d;
        r314 = Decode;
        str = "newFixedLengthResponse(...)";
        str2 = NanoHTTPD.MIME_PLAINTEXT;
        j = jLongValue2;
        j2 = jLongValue3;
        r46 = charSequence;
        r313 = r314;
        if (j4 <= 0) {
        }
    }

    @Override // fi.iki.elonen.NanoHTTPD
    public final NanoHTTPD.Response serve(NanoHTTPD.IHTTPSession iHTTPSession) {
        cr4.g(iHTTPSession, "session");
        try {
            String uri = iHTTPSession.getUri();
            return cr4.b(uri, "/health") ? NanoHTTPD.newFixedLengthResponse(NanoHTTPD.Response.Status.OK, NanoHTTPD.MIME_PLAINTEXT, "ok") : cr4.b(uri, "/stream") ? c(iHTTPSession) : NanoHTTPD.newFixedLengthResponse(NanoHTTPD.Response.Status.NOT_FOUND, NanoHTTPD.MIME_PLAINTEXT, "Not found");
        } catch (Exception e2) {
            Log.e("ParallelProxy", "Unhandled error in serve(): " + e2.getMessage(), e2);
            return NanoHTTPD.newFixedLengthResponse(NanoHTTPD.Response.Status.INTERNAL_ERROR, NanoHTTPD.MIME_PLAINTEXT, "Internal proxy error");
        }
    }
}