package defpackage;

import java.io.IOException;
import java.io.OutputStream;
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 C4406 implements InterfaceC1636 {

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

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

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

    public C4406(ᵥᵵᵶᵩ r2) {
        this.f16715 = r2;
        Socket socket = (Socket) r2.ᵜᵪʾ;
        this.f16714 = socket.getOutputStream();
        this.f16716 = new C1395(socket);
    }

    @Override // defpackage.InterfaceC1636, java.io.Closeable, java.lang.AutoCloseable
    public final void close() throws IOException {
        int i;
        OutputStream outputStream = this.f16714;
        ᵥᵵᵶᵩ r1 = this.f16715;
        C1395 c1395 = this.f16716;
        c1395.m10664();
        try {
            AtomicInteger atomicInteger = (AtomicInteger) r1.ᵔᵖᵹᵫ;
            Socket socket = (Socket) r1.ᵜᵪʾ;
            while (true) {
                int i2 = atomicInteger.get();
                if ((i2 & 1) != 0) {
                    i = 0;
                    break;
                }
                int i3 = i2 | 1;
                if (atomicInteger.compareAndSet(i2, i3)) {
                    i = i3;
                    break;
                }
            }
            if (i != 0) {
                if (i != 3) {
                    if (!socket.isClosed() && !socket.isOutputShutdown()) {
                        outputStream.flush();
                        try {
                            socket.shutdownOutput();
                        } catch (UnsupportedOperationException unused) {
                            outputStream.close();
                        }
                    }
                    return;
                }
                socket.close();
                if (c1395.m10665()) {
                    throw c1395.mo4012(null);
                }
            }
        } catch (IOException e) {
            if (!c1395.m10665()) {
                throw e;
            }
            throw c1395.mo4012(e);
        } finally {
            c1395.m10665();
        }
    }

    @Override // defpackage.InterfaceC1636, java.io.Flushable
    public final void flush() throws IOException {
        C1395 c1395 = this.f16716;
        c1395.m10664();
        try {
            this.f16714.flush();
            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 "sink(" + ((Socket) this.f16715.ᵜᵪʾ) + ')';
    }

    @Override // defpackage.InterfaceC1636
    /* JADX INFO: renamed from: ˀᵭ */
    public final void mo1843(C4903 c4903, long j) throws IOException {
        ᵻᵪ.ˊᵙᵾᵲ(c4903.f18672, 0L, j);
        while (j > 0) {
            C1395 c1395 = this.f16716;
            c1395.mo3057();
            C2131 c2131 = c4903.f18671;
            int iMin = (int) Math.min(j, c2131.f8449 - c2131.f8448);
            c1395.m10664();
            try {
                try {
                    this.f16714.write(c2131.f8451, c2131.f8448, iMin);
                    if (c1395.m10665()) {
                        throw c1395.mo4012(null);
                    }
                    int i = c2131.f8448 + iMin;
                    c2131.f8448 = i;
                    long j2 = iMin;
                    j -= j2;
                    c4903.f18672 -= j2;
                    if (i == c2131.f8449) {
                        c4903.f18671 = c2131.m5641();
                        AbstractC5318.m10904(c2131);
                    }
                } catch (IOException e) {
                    if (!c1395.m10665()) {
                        throw e;
                    }
                    throw c1395.mo4012(e);
                }
            } catch (Throwable th) {
                c1395.m10665();
                throw th;
            }
        }
    }

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