package defpackage;

import com.hierynomus.protocol.transport.TransportException;
import java.io.InputStream;

/* renamed from: ᵔˁ, reason: contains not printable characters */
/* loaded from: classes3.dex */
public final class C2207 extends InputStream {

    /* renamed from: ˑᵥˁ, reason: contains not printable characters */
    public static final InterfaceC0567 f8665 = AbstractC1385.m4255(C2207.class);

    /* renamed from: ˀᵗᵝᵭ, reason: contains not printable characters */
    public C4017 f8666;

    /* renamed from: ᵡˎ, reason: contains not printable characters */
    public final int f8667;

    /* renamed from: ᵡⁱᵥ, reason: contains not printable characters */
    public boolean f8668;

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

    /* renamed from: ᵤᵙᵷ, reason: contains not printable characters */
    public byte[] f8670;

    /* renamed from: ᵧᵾˀˈ, reason: contains not printable characters */
    public final long f8671;

    /* renamed from: ᵿʗᵝʽ, reason: contains not printable characters */
    public long f8673 = 0;

    /* renamed from: ᵾᵬ, reason: contains not printable characters */
    public int f8672 = 0;

    public C2207(C4583 c4583, int i, long j) {
        this.f8669 = c4583;
        this.f8667 = i;
        this.f8671 = j;
    }

    @Override // java.io.InputStream
    public final int available() {
        return 0;
    }

    @Override // java.io.InputStream, java.io.Closeable, java.lang.AutoCloseable
    public final void close() {
        this.f8668 = true;
        this.f8669 = null;
        this.f8670 = null;
    }

    @Override // java.io.InputStream
    public final int read() throws TransportException {
        byte[] bArr = this.f8670;
        if (bArr == null || this.f8672 >= bArr.length) {
            m5868();
        }
        if (this.f8668) {
            return -1;
        }
        byte[] bArr2 = this.f8670;
        int i = this.f8672;
        this.f8672 = i + 1;
        return bArr2[i] & 255;
    }

    @Override // java.io.InputStream
    public final int read(byte[] bArr) {
        return read(bArr, 0, bArr.length);
    }

    @Override // java.io.InputStream
    public final int read(byte[] bArr, int i, int i2) throws TransportException {
        byte[] bArr2 = this.f8670;
        if (bArr2 == null || this.f8672 >= bArr2.length) {
            m5868();
        }
        if (this.f8668) {
            return -1;
        }
        byte[] bArr3 = this.f8670;
        int length = bArr3.length;
        int i3 = this.f8672;
        if (length - i3 <= i2) {
            i2 = bArr3.length - i3;
        }
        System.arraycopy(bArr3, i3, bArr, i, i2);
        this.f8672 += i2;
        return i2;
    }

    @Override // java.io.InputStream
    public final long skip(long j) {
        if (this.f8670 == null) {
            this.f8673 += j;
            return j;
        }
        long j2 = this.f8672 + j;
        if (j2 < r0.length) {
            this.f8672 = (int) j2;
            return j;
        }
        this.f8673 = (j2 - r0.length) + this.f8673;
        this.f8670 = null;
        this.f8666 = null;
        return j;
    }

    /* renamed from: ˏᵙ, reason: contains not printable characters */
    public final C4017 m5867() {
        C4583 c4583 = this.f8669;
        long j = this.f8673;
        C4478 c4478 = c4583.f19633;
        C4351 c4351 = c4583.f19636;
        return c4478.m9288(new C3876(c4478.f16167, c4351, c4478.f16168, c4478.f16173, j, Math.min(this.f8667, c4478.f16165)));
    }

    /* JADX WARN: Removed duplicated region for block: B:31:0x007f  */
    /* JADX WARN: Removed duplicated region for block: B:32:0x0082  */
    /* 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 m5868() throws com.hierynomus.protocol.transport.TransportException {
        /*
            r10 = this;
            boolean r0 = r10.f8668
            if (r0 == 0) goto L5
            return
        L5:
            ᵬʽᵫ r0 = r10.f8666
            if (r0 != 0) goto Lf
            ᵬʽᵫ r0 = r10.m5867()
            r10.f8666 = r0
        Lf:
            ᵬʽᵫ r0 = r10.f8666
            long r1 = r10.f8671
            java.util.concurrent.TimeUnit r3 = java.util.concurrent.TimeUnit.MILLISECONDS
            ːﹳʚ r0 = r0.f15102     // Catch: java.util.concurrent.TimeoutException -> L78 java.util.concurrent.ExecutionException -> L7a java.lang.InterruptedException -> L89
            java.lang.Object r0 = r0.get(r1, r3)     // Catch: java.util.concurrent.TimeoutException -> L78 java.util.concurrent.ExecutionException -> L7a java.lang.InterruptedException -> L89
            ᵛʙᵫˋ r0 = (defpackage.C2714) r0
            java.lang.Object r1 = r0.ᵧᵾˀˈ
            ᵬˏ r1 = (defpackage.InterfaceC4029) r1
            ˁˈˊ r1 = (defpackage.C0663) r1
            long r2 = r1.f3293
            r4 = 0
            int r6 = (r2 > r4 ? 1 : (r2 == r4 ? 0 : -1))
            if (r6 != 0) goto L3a
            byte[] r6 = r0.f10526
            r10.f8670 = r6
            r6 = 0
            r10.f8672 = r6
            long r6 = r10.f8673
            int r8 = r0.f10527
            long r8 = (long) r8
            long r6 = r6 + r8
            r10.f8673 = r6
        L3a:
            r6 = 3221225489(0xc0000011, double:1.5914968516E-314)
            int r6 = (r2 > r6 ? 1 : (r2 == r6 ? 0 : -1))
            if (r6 == 0) goto L67
            int r0 = r0.f10527
            if (r0 != 0) goto L48
            goto L67
        L48:
            int r0 = (r2 > r4 ? 1 : (r2 == r4 ? 0 : -1))
            if (r0 != 0) goto L53
            ᵬʽᵫ r0 = r10.m5867()
            r10.f8666 = r0
            return
        L53:
            com.hierynomus.mssmb2.SMBApiException r0 = new com.hierynomus.mssmb2.SMBApiException
            java.lang.StringBuilder r2 = new java.lang.StringBuilder
            java.lang.String r3 = "Read failed for "
            r2.<init>(r3)
            r2.append(r10)
            java.lang.String r10 = r2.toString()
            r0.<init>(r1, r10)
            throw r0
        L67:
            long r0 = r10.f8673
            java.lang.Long r0 = java.lang.Long.valueOf(r0)
            ˀᵛ r1 = defpackage.C2207.f8665
            java.lang.String r2 = "EOF, {} bytes read"
            r1.mo2409(r0, r2)
            r0 = 1
            r10.f8668 = r0
            return
        L78:
            r10 = move-exception
            goto L7b
        L7a:
            r10 = move-exception
        L7b:
            boolean r0 = r10 instanceof com.hierynomus.protocol.transport.TransportException
            if (r0 == 0) goto L82
            com.hierynomus.protocol.transport.TransportException r10 = (com.hierynomus.protocol.transport.TransportException) r10
            goto L88
        L82:
            com.hierynomus.protocol.transport.TransportException r0 = new com.hierynomus.protocol.transport.TransportException
            r0.<init>(r10)
            r10 = r0
        L88:
            throw r10
        L89:
            r10 = move-exception
            java.lang.Thread r0 = java.lang.Thread.currentThread()
            r0.interrupt()
            com.hierynomus.protocol.transport.TransportException r0 = new com.hierynomus.protocol.transport.TransportException
            r0.<init>(r10)
            throw r0
        */
        throw new UnsupportedOperationException("Method not decompiled: defpackage.C2207.m5868():void");
    }
}
