package okio;

import g.a.a.a.a;
import io.netty.handler.codec.rtsp.RtspHeaders;
import java.io.IOException;
import java.io.OutputStream;
import kotlin.Metadata;
import kotlin.jvm.internal.o;

/* JADX INFO: renamed from: z.p, reason: from Kotlin metadata */
/* JADX INFO: loaded from: classes2.dex */
@Metadata(d1 = {"\u00004\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u0002\n\u0002\b\u0002\n\u0002\u0010\u000e\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\t\n\u0000\b\u0002\u0018\u00002\u00020\u0001B\u0015\u0012\u0006\u0010\u0002\u001a\u00020\u0003\u0012\u0006\u0010\u0004\u001a\u00020\u0005¢\u0006\u0002\u0010\u0006J\b\u0010\u0007\u001a\u00020\bH\u0016J\b\u0010\t\u001a\u00020\bH\u0016J\b\u0010\u0004\u001a\u00020\u0005H\u0016J\b\u0010\n\u001a\u00020\u000bH\u0016J\u0018\u0010\f\u001a\u00020\b2\u0006\u0010\r\u001a\u00020\u000e2\u0006\u0010\u000f\u001a\u00020\u0010H\u0016R\u000e\u0010\u0002\u001a\u00020\u0003X\u0082\u0004¢\u0006\u0002\n\u0000R\u000e\u0010\u0004\u001a\u00020\u0005X\u0082\u0004¢\u0006\u0002\n\u0000¨\u0006\u0011"}, d2 = {"Lokio/OutputStreamSink;", "Lokio/Sink;", "out", "Ljava/io/OutputStream;", RtspHeaders.Values.TIMEOUT, "Lokio/Timeout;", "(Ljava/io/OutputStream;Lokio/Timeout;)V", "close", "", "flush", "toString", "", "write", "source", "Lokio/Buffer;", "byteCount", "", "okio"}, k = 1, mv = {1, 6, 0}, xi = 48)
public final class OutputStreamSink implements Sink {

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public final OutputStream f10142f;

    /* JADX INFO: renamed from: m, reason: collision with root package name */
    public final Timeout f10143m;

    public OutputStreamSink(OutputStream outputStream, Timeout timeout) {
        o.f(outputStream, "out");
        o.f(timeout, RtspHeaders.Values.TIMEOUT);
        this.f10142f = outputStream;
        this.f10143m = timeout;
    }

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

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

    @Override // okio.Sink
    /* JADX INFO: renamed from: timeout, reason: from getter */
    public Timeout getF10143m() {
        return this.f10143m;
    }

    public String toString() {
        StringBuilder sbF = a.F("sink(");
        sbF.append(this.f10142f);
        sbF.append(')');
        return sbF.toString();
    }

    @Override // okio.Sink
    public void write(Buffer buffer, long j2) throws IOException {
        o.f(buffer, "source");
        a0.b(buffer.f10118m, 0L, j2);
        while (j2 > 0) {
            this.f10143m.f();
            Segment segment = buffer.f10117f;
            o.c(segment);
            int iMin = (int) Math.min(j2, segment.f10152c - segment.f10151b);
            this.f10142f.write(segment.a, segment.f10151b, iMin);
            int i2 = segment.f10151b + iMin;
            segment.f10151b = i2;
            long j3 = iMin;
            j2 -= j3;
            buffer.f10118m -= j3;
            if (i2 == segment.f10152c) {
                buffer.f10117f = segment.a();
                SegmentPool.a(segment);
            }
        }
    }
}