package defpackage;

import com.hierynomus.protocol.commons.buffer.Buffer$BufferException;
import com.hierynomus.protocol.transport.TransportException;
import java.io.EOFException;
import java.io.IOException;
import java.io.InputStream;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Iterator;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.locks.Condition;
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 RunnableC1914 implements Runnable {

    /* renamed from: ᵡⁱᵥ, reason: contains not printable characters */
    public static final InterfaceC0567 f7709 = AbstractC1385.m4255(RunnableC1914.class);

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

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

    /* renamed from: ᵧᵾˀˈ, reason: contains not printable characters */
    public InputStream f7712;

    /* renamed from: ᵾᵬ, reason: contains not printable characters */
    public Thread f7713;

    /* renamed from: ᵿʗᵝʽ, reason: contains not printable characters */
    public AtomicBoolean f7714 = new AtomicBoolean(false);

    public RunnableC1914(String str, InputStream inputStream, InterfaceC3462 interfaceC3462, C3500 c3500) {
        this.f7712 = inputStream;
        this.f7710 = c3500;
        Thread thread = new Thread(this, AbstractC4486.m9562("Packet Reader for ", str));
        this.f7713 = thread;
        thread.setDaemon(true);
        this.f7711 = interfaceC3462;
    }

    @Override // java.lang.Runnable
    public final void run() {
        InterfaceC0567 interfaceC0567;
        AtomicBoolean atomicBoolean = this.f7714;
        while (true) {
            boolean zIsInterrupted = Thread.currentThread().isInterrupted();
            interfaceC0567 = f7709;
            if (zIsInterrupted || atomicBoolean.get()) {
                break;
            }
            try {
                m5385();
            } catch (TransportException e) {
                if (!atomicBoolean.get()) {
                    interfaceC0567.mo2400(e);
                    C3500 c3500 = this.f7710;
                    C2809 c2809 = c3500.f13112;
                    HashMap map = c2809.f10826;
                    ReentrantReadWriteLock reentrantReadWriteLock = c2809.f10825;
                    reentrantReadWriteLock.writeLock().lock();
                    try {
                        Iterator it = new HashSet(map.keySet()).iterator();
                        while (it.hasNext()) {
                            C0515 c0515 = (C0515) map.remove((Long) it.next());
                            c2809.f10824.remove(c0515.f2679);
                            C1818 c1818 = c0515.f2677;
                            ReentrantLock reentrantLock = (ReentrantLock) c1818.f7388;
                            reentrantLock.lock();
                            try {
                                c1818.f7385 = ((C4912) c1818.f7390).m10352(e);
                                ((Condition) c1818.f7386).signalAll();
                                reentrantLock.unlock();
                            } catch (Throwable th) {
                                reentrantLock.unlock();
                                throw th;
                            }
                        }
                        try {
                            c3500.close();
                            return;
                        } catch (Exception e2) {
                            C3500.f13104.mo2393("{} while closing connection on error, ignoring: {}", e2.getClass().getSimpleName(), e2.getMessage());
                            return;
                        }
                    } finally {
                        reentrantReadWriteLock.writeLock().unlock();
                    }
                }
            }
        }
        if (atomicBoolean.get()) {
            interfaceC0567.mo2398(this.f7713, "{} stopped.");
        }
    }

    /* renamed from: ˏᵙ, reason: contains not printable characters */
    public final int m5383() throws Buffer$BufferException, IOException {
        byte[] bArr = new byte[4];
        m5384(bArr);
        C4330 c4330 = new C4330(bArr, true, C3253.f12251);
        c4330.m9340();
        byte[] bArr2 = new byte[3];
        c4330.m9346(3, bArr2);
        return ((bArr2[0] << 16) & 16711680) | ((bArr2[1] << 8) & 65280) | (bArr2[2] & 255);
    }

    /* renamed from: ᵥᵯˎ, reason: contains not printable characters */
    public final void m5384(byte[] bArr) throws IOException {
        int length = bArr.length;
        int i = 0;
        while (length > 0) {
            int i2 = this.f7712.read(bArr, i, length);
            if (i2 == -1) {
                throw new TransportException(new EOFException("EOF while reading packet"));
            }
            length -= i2;
            i += i2;
        }
    }

    /* JADX WARN: Code restructure failed: missing block: B:38:0x0159, code lost:
    
        r13 = defpackage.C2354.f9203;
        r13.mo2395(r1, java.util.Arrays.toString(r10), java.util.Arrays.toString(r0));
        r13.mo2391("Packet {} has header: {}", r1, r1.ˌᵜᵹᵩ());
     */
    /* JADX WARN: Code restructure failed: missing block: B:39:0x0177, code lost:
    
        r6.mo2407(r1, "Invalid packet signature for packet {}");
     */
    /* JADX WARN: Code restructure failed: missing block: B:40:0x017e, code lost:
    
        if (r3.f3350 != false) goto L42;
     */
    /* JADX WARN: Code restructure failed: missing block: B:43:0x0199, code lost:
    
        throw new com.hierynomus.protocol.transport.TransportException("Packet signature for packet " + r1 + " was not correct");
     */
    /* 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 m5385() throws com.hierynomus.protocol.transport.TransportException {
        /*
            Method dump skipped, instructions count: 612
            To view this dump add '--comments-level debug' option
        */
        throw new UnsupportedOperationException("Method not decompiled: defpackage.RunnableC1914.m5385():void");
    }
}