package okio;

import java.io.IOException;
import java.io.OutputStream;

/* JADX INFO: loaded from: classes2.dex */
final class u implements C {

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    private final OutputStream f6055b;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    private final F f6056g;

    public u(OutputStream out, F timeout) {
        kotlin.jvm.internal.l.e(out, "out");
        kotlin.jvm.internal.l.e(timeout, "timeout");
        this.f6055b = out;
        this.f6056g = timeout;
    }

    @Override // okio.C, java.io.Closeable, java.lang.AutoCloseable, java.nio.channels.Channel
    public void close() throws IOException {
        this.f6055b.close();
    }

    @Override // okio.C, java.io.Flushable
    public void flush() throws IOException {
        this.f6055b.flush();
    }

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

    public String toString() {
        return "sink(" + this.f6055b + ')';
    }

    @Override // okio.C
    public void write(C0688f source, long j2) throws IOException {
        kotlin.jvm.internal.l.e(source, "source");
        AbstractC0685c.b(source.G(), 0L, j2);
        while (j2 > 0) {
            this.f6056g.throwIfReached();
            y yVar = source.f6021b;
            kotlin.jvm.internal.l.b(yVar);
            int iMin = (int) Math.min(j2, yVar.f6073c - yVar.f6072b);
            this.f6055b.write(yVar.f6071a, yVar.f6072b, iMin);
            yVar.f6072b += iMin;
            long j3 = iMin;
            j2 -= j3;
            source.F(source.G() - j3);
            if (yVar.f6072b == yVar.f6073c) {
                source.f6021b = yVar.b();
                A.b(yVar);
            }
        }
    }
}