package okio;

import java.nio.ByteBuffer;

/* JADX INFO: loaded from: classes2.dex */
public final class w implements g {

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final C0688f f6063b;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    public boolean f6064g;

    /* JADX INFO: renamed from: r, reason: collision with root package name */
    public final C f6065r;

    public w(C sink) {
        kotlin.jvm.internal.l.e(sink, "sink");
        this.f6065r = sink;
        this.f6063b = new C0688f();
    }

    @Override // okio.C, java.io.Closeable, java.lang.AutoCloseable, java.nio.channels.Channel
    public void close() throws Throwable {
        if (this.f6064g) {
            return;
        }
        try {
            if (this.f6063b.G() > 0) {
                C c2 = this.f6065r;
                C0688f c0688f = this.f6063b;
                c2.write(c0688f, c0688f.G());
            }
            th = null;
        } catch (Throwable th) {
            th = th;
        }
        try {
            this.f6065r.close();
        } catch (Throwable th2) {
            if (th == null) {
                th = th2;
            }
        }
        this.f6064g = true;
        if (th != null) {
            throw th;
        }
    }

    @Override // okio.g
    public g emit() {
        if (this.f6064g) {
            throw new IllegalStateException("closed");
        }
        long jG = this.f6063b.G();
        if (jG > 0) {
            this.f6065r.write(this.f6063b, jG);
        }
        return this;
    }

    @Override // okio.g
    public g emitCompleteSegments() {
        if (this.f6064g) {
            throw new IllegalStateException("closed");
        }
        long jD = this.f6063b.d();
        if (jD > 0) {
            this.f6065r.write(this.f6063b, jD);
        }
        return this;
    }

    @Override // okio.g, okio.C, java.io.Flushable
    public void flush() {
        if (this.f6064g) {
            throw new IllegalStateException("closed");
        }
        if (this.f6063b.G() > 0) {
            C c2 = this.f6065r;
            C0688f c0688f = this.f6063b;
            c2.write(c0688f, c0688f.G());
        }
        this.f6065r.flush();
    }

    @Override // okio.g
    public C0688f getBuffer() {
        return this.f6063b;
    }

    @Override // java.nio.channels.Channel
    public boolean isOpen() {
        return !this.f6064g;
    }

    @Override // okio.C
    public F timeout() {
        return this.f6065r.timeout();
    }

    public String toString() {
        return "buffer(" + this.f6065r + ')';
    }

    @Override // java.nio.channels.WritableByteChannel
    public int write(ByteBuffer source) {
        kotlin.jvm.internal.l.e(source, "source");
        if (this.f6064g) {
            throw new IllegalStateException("closed");
        }
        int iWrite = this.f6063b.write(source);
        emitCompleteSegments();
        return iWrite;
    }

    @Override // okio.g
    public long writeAll(E source) {
        kotlin.jvm.internal.l.e(source, "source");
        long j2 = 0;
        while (true) {
            long j3 = source.read(this.f6063b, 8192);
            if (j3 == -1) {
                return j2;
            }
            j2 += j3;
            emitCompleteSegments();
        }
    }

    @Override // okio.g
    public g writeByte(int i2) {
        if (this.f6064g) {
            throw new IllegalStateException("closed");
        }
        this.f6063b.writeByte(i2);
        return emitCompleteSegments();
    }

    @Override // okio.g
    public g writeDecimalLong(long j2) {
        if (this.f6064g) {
            throw new IllegalStateException("closed");
        }
        this.f6063b.writeDecimalLong(j2);
        return emitCompleteSegments();
    }

    @Override // okio.g
    public g writeHexadecimalUnsignedLong(long j2) {
        if (this.f6064g) {
            throw new IllegalStateException("closed");
        }
        this.f6063b.writeHexadecimalUnsignedLong(j2);
        return emitCompleteSegments();
    }

    @Override // okio.g
    public g writeInt(int i2) {
        if (this.f6064g) {
            throw new IllegalStateException("closed");
        }
        this.f6063b.writeInt(i2);
        return emitCompleteSegments();
    }

    @Override // okio.g
    public g writeShort(int i2) {
        if (this.f6064g) {
            throw new IllegalStateException("closed");
        }
        this.f6063b.writeShort(i2);
        return emitCompleteSegments();
    }

    @Override // okio.g
    public g writeUtf8(String string) {
        kotlin.jvm.internal.l.e(string, "string");
        if (this.f6064g) {
            throw new IllegalStateException("closed");
        }
        this.f6063b.writeUtf8(string);
        return emitCompleteSegments();
    }

    @Override // okio.C
    public void write(C0688f source, long j2) {
        kotlin.jvm.internal.l.e(source, "source");
        if (!this.f6064g) {
            this.f6063b.write(source, j2);
            emitCompleteSegments();
            return;
        }
        throw new IllegalStateException("closed");
    }

    @Override // okio.g
    public g write(i byteString) {
        kotlin.jvm.internal.l.e(byteString, "byteString");
        if (!this.f6064g) {
            this.f6063b.write(byteString);
            return emitCompleteSegments();
        }
        throw new IllegalStateException("closed");
    }

    @Override // okio.g
    public g write(byte[] source) {
        kotlin.jvm.internal.l.e(source, "source");
        if (!this.f6064g) {
            this.f6063b.write(source);
            return emitCompleteSegments();
        }
        throw new IllegalStateException("closed");
    }

    @Override // okio.g
    public g write(byte[] source, int i2, int i3) {
        kotlin.jvm.internal.l.e(source, "source");
        if (!this.f6064g) {
            this.f6063b.write(source, i2, i3);
            return emitCompleteSegments();
        }
        throw new IllegalStateException("closed");
    }
}