package defpackage;

import java.io.IOException;
import java.io.InputStream;
import java.net.Socket;
import java.util.concurrent.atomic.AtomicInteger;

/* JADX INFO: renamed from: ᵾᵰʿ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes3.dex */
public final class C5463 implements InterfaceC3906 {

    /* JADX INFO: renamed from: ˌᴵ, reason: contains not printable characters */
    public final InputStream f20688;

    /* JADX INFO: renamed from: ᵔᵖᵹᵫ, reason: contains not printable characters */
    public final /* synthetic */ ᵥᵵᵶᵩ f20689;

    /* JADX INFO: renamed from: ᵜᵪʾ, reason: contains not printable characters */
    public final C1395 f20690;

    public C5463(ᵥᵵᵶᵩ r2) {
        this.f20689 = r2;
        Socket socket = (Socket) r2.ᵜᵪʾ;
        this.f20688 = socket.getInputStream();
        this.f20690 = new C1395(socket);
    }

    @Override // java.io.Closeable, java.lang.AutoCloseable
    public final void close() throws IOException {
        int i;
        ᵥᵵᵶᵩ r0 = this.f20689;
        C1395 c1395 = this.f20690;
        c1395.m10664();
        try {
            AtomicInteger atomicInteger = (AtomicInteger) r0.ᵔᵖᵹᵫ;
            Socket socket = (Socket) r0.ᵜᵪʾ;
            while (true) {
                int i2 = atomicInteger.get();
                if ((i2 & 2) != 0) {
                    i = 0;
                    break;
                }
                int i3 = i2 | 2;
                if (atomicInteger.compareAndSet(i2, i3)) {
                    i = i3;
                    break;
                }
            }
            if (i != 0) {
                if (i == 3) {
                    socket.close();
                } else {
                    if (socket.isClosed() || socket.isInputShutdown()) {
                        return;
                    }
                    try {
                        socket.shutdownInput();
                    } catch (UnsupportedOperationException unused) {
                        this.f20688.close();
                    }
                }
                if (c1395.m10665()) {
                    throw c1395.mo4012(null);
                }
            }
        } catch (IOException e) {
            if (!c1395.m10665()) {
                throw e;
            }
            throw c1395.mo4012(e);
        } finally {
            c1395.m10665();
        }
    }

    public final String toString() {
        return "source(" + ((Socket) this.f20689.ᵜᵪʾ) + ')';
    }

    @Override // defpackage.InterfaceC3906
    /* JADX INFO: renamed from: ᵪᵹᵥᵻ */
    public final long mo1490(C4903 c4903, long j) throws IOException {
        C1395 c1395 = this.f20690;
        c1395.mo3057();
        C2131 c2131M10203 = c4903.m10203(1);
        int iMin = (int) Math.min(8192L, 8192 - c2131M10203.f8449);
        try {
            c1395.m10664();
            try {
                int i = this.f20688.read(c2131M10203.f8451, c2131M10203.f8449, iMin);
                if (c1395.m10665()) {
                    throw c1395.mo4012(null);
                }
                if (i != -1) {
                    c2131M10203.f8449 += i;
                    long j2 = i;
                    c4903.f18672 += j2;
                    return j2;
                }
                if (c2131M10203.f8448 != c2131M10203.f8449) {
                    return -1L;
                }
                c4903.f18671 = c2131M10203.m5641();
                AbstractC5318.m10904(c2131M10203);
                return -1L;
            } catch (IOException e) {
                if (c1395.m10665()) {
                    throw c1395.mo4012(e);
                }
                throw e;
            } finally {
                c1395.m10665();
            }
        } catch (AssertionError e2) {
            if (AbstractC3820.m8524(e2)) {
                throw new IOException(e2);
            }
            throw e2;
        }
    }

    @Override // defpackage.InterfaceC3906
    /* JADX INFO: renamed from: ᵻʽᵯ */
    public final C2466 mo1491() {
        return this.f20690;
    }
}