package defpackage;

import com.hierynomus.mssmb2.SMBApiException;
import com.hierynomus.smbj.common.SMBRuntimeException;
import com.hierynomus.spnego.SpnegoException;
import java.io.Closeable;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collection;
import java.util.EnumSet;
import java.util.HashMap;
import java.util.UUID;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.locks.ReentrantLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;

/* renamed from: ᵥˊˁ, reason: contains not printable characters */
/* loaded from: classes3.dex */
public final class C3500 implements Closeable {

    /* renamed from: ˁˑᵰ, reason: contains not printable characters */
    public static final ˊᵘʛ f13103;

    /* renamed from: ᵶʔᵢˊ, reason: contains not printable characters */
    public static final InterfaceC0567 f13104 = AbstractC1385.m4255(C3500.class);

    /* renamed from: ˀᵗᵝᵭ, reason: contains not printable characters */
    public final ᵬˆˀᵣ f13105;

    /* renamed from: ˎˑː, reason: contains not printable characters */
    public final C3900 f13106;

    /* renamed from: ˑᵥˁ, reason: contains not printable characters */
    public final C4903 f13107;

    /* renamed from: ᐧﾞ, reason: contains not printable characters */
    public int f13108;

    /* renamed from: ᵡˎ, reason: contains not printable characters */
    public String f13109;

    /* renamed from: ᵡⁱᵥ, reason: contains not printable characters */
    public ᵶˉᵹʣ f13110;

    /* renamed from: ᵢˇᵭ, reason: contains not printable characters */
    public C5036 f13111;

    /* renamed from: ᵤᵙᵷ, reason: contains not printable characters */
    public final C2809 f13112;

    /* renamed from: ᵧـˌᵎ, reason: contains not printable characters */
    public final C3174 f13113;

    /* renamed from: ᵮᵠـˌ, reason: contains not printable characters */
    public final C5036 f13115;

    /* renamed from: ᵺʙ, reason: contains not printable characters */
    public final ReentrantLock f13116;

    /* renamed from: ᵧᵾˀˈ, reason: contains not printable characters */
    public final AtomicInteger f13114 = new AtomicInteger(1);

    /* renamed from: ᵿʗᵝʽ, reason: contains not printable characters */
    public final ᵶˉᵹʣ f13118 = new ᵶˉᵹʣ(21);

    /* renamed from: ᵾᵬ, reason: contains not printable characters */
    public final ᵶˉᵹʣ f13117 = new ᵶˉᵹʣ(21);

    static {
        InterfaceC3462[] interfaceC3462Arr = {new ˊᵿʗ(5), new ˉᵻ(5)};
        ˊᵘʛ r0 = new ˊᵘʛ(15, false);
        r0.ᵢˇᵭ = interfaceC3462Arr;
        f13103 = r0;
    }

    public C3500(C3900 c3900, C4903 c4903, C3174 c3174) {
        C2809 c2809 = new C2809();
        c2809.f10825 = new ReentrantReadWriteLock();
        c2809.f10826 = new HashMap();
        c2809.f10824 = new HashMap();
        this.f13112 = c2809;
        this.f13105 = new ᵬˆˀᵣ(5);
        this.f13116 = new ReentrantLock();
        this.f13106 = c3900;
        this.f13107 = c4903;
        ᵥᵵ r6 = c3900.f14546;
        C1601 c1601 = new C1601(new ˎᵖᵗ(5), this, f13103, 0);
        r6.getClass();
        this.f13115 = new C5036(c3900.f14542, c3900.f14538, c1601);
        this.f13113 = c3174;
        c3174.m7528(this);
    }

    @Override // java.io.Closeable, java.lang.AutoCloseable
    public final void close() {
        C3174 c3174 = this.f13113;
        C5036 c5036 = this.f13115;
        InterfaceC0567 interfaceC0567 = f13104;
        if (this.f13114.decrementAndGet() <= 0) {
            try {
                ᵶˉᵹʣ r4 = this.f13118;
                ReentrantLock reentrantLock = (ReentrantLock) r4.ᵢˇᵭ;
                reentrantLock.lock();
                try {
                    ArrayList arrayList = new ArrayList(((HashMap) r4.ᵿʗᵝʽ).values());
                    reentrantLock.unlock();
                    int size = arrayList.size();
                    int i = 0;
                    while (i < size) {
                        Object obj = arrayList.get(i);
                        i++;
                        C0683 c0683 = (C0683) obj;
                        try {
                            c0683.m2659();
                        } catch (IOException e) {
                            interfaceC0567.mo2404(Long.valueOf(c0683.f3347), e);
                        }
                    }
                } catch (Throwable th) {
                    reentrantLock.unlock();
                    throw th;
                }
            } finally {
                c5036.m10503();
                interfaceC0567.mo2398(this.f13109, "Closed connection to {}");
                c3174.f12035.ˑᵝﹳᵜ(new C0095(this.f13108, this.f13109));
            }
        }
    }

    /* renamed from: ˌʾˀ, reason: contains not printable characters */
    public final InterfaceC3968 m7977(ʽᵡ r10) throws IOException, SpnegoException {
        C3900 c3900 = this.f13106;
        c3900.getClass();
        ArrayList arrayList = new ArrayList(new ArrayList(c3900.f14548));
        ArrayList arrayList2 = new ArrayList();
        byte[] bArr = (byte[]) this.f13111.f18821;
        int i = 0;
        if (Arrays.copyOf(bArr, bArr.length).length > 0) {
            C0765 c0765 = new C0765();
            byte[] bArr2 = (byte[]) this.f13111.f18821;
            try {
                C1572 c1572 = new C1572(new C0721(12), new C4402(i, new C4330(Arrays.copyOf(bArr2, bArr2.length), true, C3253.f12249)));
                try {
                    C3647 c3647 = (C3647) c1572.m4551();
                    if (c3647.f11406.f6876 != EnumC4215.f15803) {
                        throw new SpnegoException("Incorrect GSS-API ASN.1 token received, expected to find an [APPLICATION 0], not: " + c3647);
                    }
                    ArrayList arrayList3 = ((C5443) c3647.m8238(AbstractC1728.f6871)).f20425;
                    AbstractC2943 abstractC2943 = (AbstractC2943) arrayList3.get(0);
                    if (!(abstractC2943 instanceof C3760)) {
                        throw new SpnegoException("Expected to find the SPNEGO OID (" + AbstractC1869.f7569 + "), not: " + abstractC2943);
                    }
                    c0765.m6323((AbstractC2943) arrayList3.get(1));
                    c1572.close();
                    arrayList2 = (ArrayList) c0765.f1886;
                } finally {
                }
            } catch (IOException e) {
                throw new SpnegoException("Could not read NegTokenInit from buffer", e);
            }
        }
        ArrayList arrayList4 = new ArrayList(arrayList);
        int size = arrayList4.size();
        while (i < size) {
            Object obj = arrayList4.get(i);
            i++;
            InterfaceC4911 interfaceC4911 = (InterfaceC4911) obj;
            if (arrayList2.isEmpty() || arrayList2.contains(new C3760(interfaceC4911.getName()))) {
                InterfaceC3968 interfaceC3968 = (InterfaceC3968) interfaceC4911.mo3021();
                if (interfaceC3968.mo6003(r10)) {
                    return interfaceC3968;
                }
            }
        }
        throw new SMBRuntimeException("Could not find a configured authenticator for mechtypes: " + arrayList2 + " and authentication context: " + r10);
    }

    /* JADX WARN: Removed duplicated region for block: B:28:0x012f  */
    /* JADX WARN: Removed duplicated region for block: B:29:0x0132  */
    /* renamed from: ˏᵙ, reason: contains not printable characters */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public final void m7978(java.lang.String r11) throws java.util.concurrent.ExecutionException, java.io.IOException {
        /*
            Method dump skipped, instructions count: 488
            To view this dump add '--comments-level debug' option
        */
        throw new UnsupportedOperationException("Method not decompiled: defpackage.C3500.m7978(java.lang.String):void");
    }

    /* renamed from: ˑᵥˁ, reason: contains not printable characters */
    public final AbstractC0681 m7979() {
        EnumSet enumSetCopyOf = EnumSet.copyOf((Collection) this.f13106.f14544);
        UUID uuid = (UUID) this.f13111.f18819;
        C1172 c1172 = new C1172(36, EnumC2857.f11075, EnumC2703.f10480, 0L, 0L);
        c1172.f4985 = enumSetCopyOf;
        c1172.f4986 = uuid;
        return m7981(c1172);
    }

    /* renamed from: ᵞʡ, reason: contains not printable characters */
    public final C5375 m7980(long j, byte[] bArr) {
        EnumC2857 enumC2857 = (EnumC2857) ((C1326) this.f13111.f18820).f5442;
        EnumSet enumSetOf = EnumSet.of(EnumC2709.f10499);
        EnumSet enumSet = (EnumSet) this.f13111.f18825;
        C5375 c5375 = new C5375(25, enumC2857, EnumC2703.f10487);
        c5375.f20159 = enumC2857;
        c5375.f20155 = (byte) ˉᵜˆ.ˀᵗᵝᵭ(enumSetOf);
        c5375.f20158 = ˉᵜˆ.ˀᵗᵝᵭ(enumSet);
        c5375.f20157 = bArr;
        ((C0663) ((InterfaceC4029) ((ᵢˇᵭ) c5375).ᵧᵾˀˈ)).f3295 = j;
        return (C5375) m7981(c5375);
    }

    /* JADX WARN: Removed duplicated region for block: B:11:0x001a  */
    /* JADX WARN: Removed duplicated region for block: B:12:0x001d  */
    /* renamed from: ᵡˎ, reason: contains not printable characters */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public final defpackage.AbstractC0681 m7981(defpackage.AbstractC0681 r3) throws com.hierynomus.protocol.transport.TransportException {
        /*
            r2 = this;
            ᵬʽᵫ r3 = r2.m7982(r3)
            ᵪᵞᵔ r2 = r2.f13106
            long r0 = r2.f14545
            java.util.concurrent.TimeUnit r2 = java.util.concurrent.TimeUnit.MILLISECONDS
            ːﹳʚ r3 = r3.f15102     // Catch: java.util.concurrent.TimeoutException -> L13 java.util.concurrent.ExecutionException -> L15 java.lang.InterruptedException -> L24
            java.lang.Object r2 = r3.get(r0, r2)     // Catch: java.util.concurrent.TimeoutException -> L13 java.util.concurrent.ExecutionException -> L15 java.lang.InterruptedException -> L24
            ˁˏˈ r2 = (defpackage.AbstractC0681) r2
            return r2
        L13:
            r2 = move-exception
            goto L16
        L15:
            r2 = move-exception
        L16:
            boolean r3 = r2 instanceof com.hierynomus.protocol.transport.TransportException
            if (r3 == 0) goto L1d
            com.hierynomus.protocol.transport.TransportException r2 = (com.hierynomus.protocol.transport.TransportException) r2
            goto L23
        L1d:
            com.hierynomus.protocol.transport.TransportException r3 = new com.hierynomus.protocol.transport.TransportException
            r3.<init>(r2)
            r2 = r3
        L23:
            throw r2
        L24:
            r2 = move-exception
            java.lang.Thread r3 = java.lang.Thread.currentThread()
            r3.interrupt()
            com.hierynomus.protocol.transport.TransportException r3 = new com.hierynomus.protocol.transport.TransportException
            r3.<init>(r2)
            throw r3
        */
        throw new UnsupportedOperationException("Method not decompiled: defpackage.C3500.m7981(ˁˏˈ):ˁˏˈ");
    }

    /* JADX WARN: Removed duplicated region for block: B:12:0x0040  */
    /* JADX WARN: Removed duplicated region for block: B:19:0x0053 A[Catch: all -> 0x0061, TryCatch #0 {all -> 0x0061, blocks: (B:3:0x0005, B:5:0x000d, B:8:0x0029, B:10:0x0037, B:17:0x0049, B:19:0x0053, B:22:0x0063, B:24:0x00ce, B:16:0x0047), top: B:29:0x0005 }] */
    /* renamed from: ᵡⁱᵥ, reason: contains not printable characters */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
        To view partially-correct add '--show-bad-code' argument
    */
    public final defpackage.C4017 m7982(defpackage.AbstractC0681 r12) {
        /*
            r11 = this;
            java.util.concurrent.locks.ReentrantLock r0 = r11.f13116
            r0.lock()
            ˁˏˈ r1 = r12.mo2654()     // Catch: java.lang.Throwable -> L61
            boolean r1 = r1 instanceof defpackage.C1069     // Catch: java.lang.Throwable -> L61
            if (r1 != 0) goto Lcd
            ᵶˉᵹʣ r1 = r11.f13110     // Catch: java.lang.Throwable -> L61
            java.lang.Object r1 = r1.ᵿʗᵝʽ     // Catch: java.lang.Throwable -> L61
            java.util.concurrent.Semaphore r1 = (java.util.concurrent.Semaphore) r1     // Catch: java.lang.Throwable -> L61
            int r1 = r1.availablePermits()     // Catch: java.lang.Throwable -> L61
            int r2 = r12.mo2655()     // Catch: java.lang.Throwable -> L61
            r3 = 1
            int r2 = r2 - r3
            r4 = 65536(0x10000, float:9.18355E-41)
            int r2 = r2 / r4
            int r2 = java.lang.Math.abs(r2)     // Catch: java.lang.Throwable -> L61
            int r2 = r2 + r3
            ˀᵛ r4 = defpackage.C3500.f13104
            if (r2 <= r3) goto L40
            ᵹˏˎ r5 = r11.f13111     // Catch: java.lang.Throwable -> L61
            ᵨʞ r6 = defpackage.EnumC3698.f13830     // Catch: java.lang.Throwable -> L61
            java.lang.Object r5 = r5.f18822     // Catch: java.lang.Throwable -> L61
            java.util.EnumSet r5 = (java.util.EnumSet) r5     // Catch: java.lang.Throwable -> L61
            boolean r5 = r5.contains(r6)     // Catch: java.lang.Throwable -> L61
            if (r5 != 0) goto L40
            java.lang.String r2 = "Connection to {} does not support multi-credit requests."
            java.lang.String r5 = r11.f13109     // Catch: java.lang.Throwable -> L61
            r4.mo2392(r5, r2)     // Catch: java.lang.Throwable -> L61
        L3e:
            r2 = r3
            goto L49
        L40:
            if (r2 >= r1) goto L43
            goto L49
        L43:
            if (r2 <= r3) goto L3e
            if (r1 <= r3) goto L3e
            int r2 = r1 + (-1)
        L49:
            ᵬˏ r5 = r12.ˌᵜᵹᵩ()     // Catch: java.lang.Throwable -> L61
            ˁˈˊ r5 = (defpackage.C0663) r5     // Catch: java.lang.Throwable -> L61
            r5.f3292 = r2     // Catch: java.lang.Throwable -> L61
            if (r1 != 0) goto L63
            java.lang.String r5 = "There are no credits left to send {}, will block until there are more credits available."
            ᵬˏ r6 = r12.ˌᵜᵹᵩ()     // Catch: java.lang.Throwable -> L61
            ˁˈˊ r6 = (defpackage.C0663) r6     // Catch: java.lang.Throwable -> L61
            ᵚᵻʠˊ r6 = r6.f3283     // Catch: java.lang.Throwable -> L61
            r4.mo2407(r6, r5)     // Catch: java.lang.Throwable -> L61
            goto L63
        L61:
            r11 = move-exception
            goto Ld7
        L63:
            ᵶˉᵹʣ r5 = r11.f13110     // Catch: java.lang.Throwable -> L61
            long[] r5 = r5.ᵞʡ(r2)     // Catch: java.lang.Throwable -> L61
            ᵬˏ r6 = r12.ˌᵜᵹᵩ()     // Catch: java.lang.Throwable -> L61
            ˁˈˊ r6 = (defpackage.C0663) r6     // Catch: java.lang.Throwable -> L61
            r7 = 0
            r8 = r5[r7]     // Catch: java.lang.Throwable -> L61
            r6.f3286 = r8     // Catch: java.lang.Throwable -> L61
            java.lang.String r6 = "Granted {} (out of {}) credits to {}"
            java.lang.Integer r8 = java.lang.Integer.valueOf(r2)     // Catch: java.lang.Throwable -> L61
            java.lang.Integer r9 = java.lang.Integer.valueOf(r1)     // Catch: java.lang.Throwable -> L61
            r10 = 3
            java.lang.Object[] r10 = new java.lang.Object[r10]     // Catch: java.lang.Throwable -> L61
            r10[r7] = r8     // Catch: java.lang.Throwable -> L61
            r10[r3] = r9     // Catch: java.lang.Throwable -> L61
            r3 = 2
            r10[r3] = r12     // Catch: java.lang.Throwable -> L61
            r4.mo2405(r6, r10)     // Catch: java.lang.Throwable -> L61
            ᵬˏ r3 = r12.ˌᵜᵹᵩ()     // Catch: java.lang.Throwable -> L61
            ˁˈˊ r3 = (defpackage.C0663) r3     // Catch: java.lang.Throwable -> L61
            int r1 = 512 - r1
            int r1 = r1 - r2
            int r1 = java.lang.Math.max(r1, r2)     // Catch: java.lang.Throwable -> L61
            r3.f3287 = r1     // Catch: java.lang.Throwable -> L61
            ˀˀᵧ r1 = new ˀˀᵧ     // Catch: java.lang.Throwable -> L61
            ˁˏˈ r2 = r12.mo2654()     // Catch: java.lang.Throwable -> L61
            r3 = r5[r7]     // Catch: java.lang.Throwable -> L61
            java.util.UUID r5 = java.util.UUID.randomUUID()     // Catch: java.lang.Throwable -> L61
            r1.<init>(r2, r3, r5)     // Catch: java.lang.Throwable -> L61
            ᵜˆʿʨ r2 = r11.f13112     // Catch: java.lang.Throwable -> L61
            r2.m6910(r1)     // Catch: java.lang.Throwable -> L61
            ᵳᵗʛˊ r2 = new ᵳᵗʛˊ     // Catch: java.lang.Throwable -> L61
            ᵬˏ r3 = r12.ˌᵜᵹᵩ()     // Catch: java.lang.Throwable -> L61
            ˁˈˊ r3 = (defpackage.C0663) r3     // Catch: java.lang.Throwable -> L61
            long r3 = r3.f3295     // Catch: java.lang.Throwable -> L61
            r2.<init>(r11, r1, r3)     // Catch: java.lang.Throwable -> L61
            ᵬʽᵫ r3 = new ᵬʽᵫ     // Catch: java.lang.Throwable -> L61
            ˏˀ r1 = r1.f2677     // Catch: java.lang.Throwable -> L61
            r1.getClass()     // Catch: java.lang.Throwable -> L61
            ːﹳʚ r4 = new ːﹳʚ     // Catch: java.lang.Throwable -> L61
            r4.<init>()     // Catch: java.lang.Throwable -> L61
            r4.f8058 = r1     // Catch: java.lang.Throwable -> L61
            r3.<init>(r4, r2)     // Catch: java.lang.Throwable -> L61
            goto Lce
        Lcd:
            r3 = 0
        Lce:
            ᵹˏˎ r11 = r11.f13115     // Catch: java.lang.Throwable -> L61
            r11.m10500(r12)     // Catch: java.lang.Throwable -> L61
            r0.unlock()
            return r3
        Ld7:
            r0.unlock()
            throw r11
        */
        throw new UnsupportedOperationException("Method not decompiled: defpackage.C3500.m7982(ˁˏˈ):ᵬʽᵫ");
    }

    /* renamed from: ᵢˇᵭ, reason: contains not printable characters */
    public final byte[] m7983(InterfaceC3968 interfaceC3968, ʽᵡ r2, byte[] bArr, C0683 c0683) {
        C4351 c4351Mo6002 = interfaceC3968.mo6002(r2, bArr);
        if (c4351Mo6002 == null) {
            return null;
        }
        this.f13111.getClass();
        this.f13111.getClass();
        byte[] bArr2 = c4351Mo6002.f16290;
        byte[] bArr3 = c4351Mo6002.f16288;
        if (bArr3 == null) {
            return bArr2;
        }
        C2354 c2354 = c0683.f3345;
        if (c2354.f9205.m6987()) {
            ᵹˉᵞ.ᵳٴᵶ("Cannot set a signing key (yet) for SMB3.x");
            return null;
        }
        c2354.f9204 = "HmacSHA256";
        c2354.f9207 = bArr3;
        return bArr2;
    }

    /* renamed from: ᵥᵯˎ, reason: contains not printable characters */
    public final C0683 m7984(ʽᵡ r19) {
        InterfaceC4029 interfaceC4029;
        InterfaceC0567 interfaceC0567;
        C3900 c3900 = this.f13106;
        try {
            InterfaceC3968 interfaceC3968M7977 = m7977(r19);
            try {
                String str = (String) r19.ᵢˇᵭ;
                interfaceC3968M7977.mo6004(c3900);
                C0683 c0683 = new C0683(this, r19, this.f13113, this.f13107.f18255, c3900.f14540);
                byte[] bArr = (byte[]) this.f13111.f18821;
                C5375 c5375M7980 = m7980(0L, m7983(interfaceC3968M7977, r19, Arrays.copyOf(bArr, bArr.length), c0683));
                long j = ((C0663) ((InterfaceC4029) ((ᵢˇᵭ) c5375M7980).ᵧᵾˀˈ)).f3295;
                ᵶˉᵹʣ r11 = this.f13117;
                if (j != 0) {
                    Long lValueOf = Long.valueOf(j);
                    ReentrantLock reentrantLock = (ReentrantLock) r11.ᵢˇᵭ;
                    reentrantLock.lock();
                    try {
                        ((HashMap) r11.ᵿʗᵝʽ).put(lValueOf, c0683);
                        reentrantLock.unlock();
                    } finally {
                    }
                }
                while (true) {
                    try {
                        interfaceC4029 = (InterfaceC4029) ((ᵢˇᵭ) c5375M7980).ᵧᵾˀˈ;
                        long j2 = ((C0663) interfaceC4029).f3293;
                        interfaceC0567 = f13104;
                        if (j2 != 3221225494L) {
                            break;
                        }
                        interfaceC0567.mo2393("More processing required for authentication of {} using {}", str, interfaceC3968M7977);
                        c5375M7980 = m7980(j, m7983(interfaceC3968M7977, r19, c5375M7980.f20157, c0683));
                    } catch (Throwable th) {
                        if (j != 0) {
                            r11.ᵶʔᵢˊ(Long.valueOf(j));
                        }
                        throw th;
                    }
                }
                if (((C0663) interfaceC4029).f3293 != 0) {
                    throw new SMBApiException((C0663) interfaceC4029, String.format("Authentication failed for '%s' using %s", str, interfaceC3968M7977));
                }
                c0683.f3347 = ((C0663) interfaceC4029).f3295;
                byte[] bArr2 = c5375M7980.f20157;
                if (bArr2 != null) {
                    m7983(interfaceC3968M7977, r19, bArr2, c0683);
                }
                c0683.m2657(c5375M7980);
                interfaceC0567.mo2396(str, this.f13109, Long.valueOf(c0683.f3347));
                ᵶˉᵹʣ r1 = this.f13118;
                Long lValueOf2 = Long.valueOf(c0683.f3347);
                ((ReentrantLock) r1.ᵢˇᵭ).lock();
                try {
                    ((HashMap) r1.ᵿʗᵝʽ).put(lValueOf2, c0683);
                    if (j != 0) {
                        r11.ᵶʔᵢˊ(Long.valueOf(j));
                    }
                    return c0683;
                } finally {
                }
            } catch (IOException e) {
                e = e;
                throw new SMBRuntimeException(e);
            }
        } catch (SpnegoException | IOException e2) {
            e = e2;
        }
    }
}