package okio;

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

/* JADX INFO: loaded from: classes2.dex */
@Metadata(d1 = {"\u0000+\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0002\n\u0000\n\u0002\u0010\t\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000e\n\u0000*\u0001\u0000\b\n\u0018\u00002\u00020\u0001J\b\u0010\u0002\u001a\u00020\u0003H\u0016J\u0018\u0010\u0004\u001a\u00020\u00052\u0006\u0010\u0006\u001a\u00020\u00072\u0006\u0010\b\u001a\u00020\u0005H\u0016J\b\u0010\t\u001a\u00020\nH\u0016J\b\u0010\u000b\u001a\u00020\fH\u0016¨\u0006\r"}, d2 = {"okio/AsyncTimeout$source$1", "Lokio/Source;", "close", "", "read", "", "sink", "Lokio/Buffer;", "byteCount", RtspHeaders.Values.TIMEOUT, "Lokio/AsyncTimeout;", "toString", "", "okio"}, k = 1, mv = {1, 6, 0}, xi = 48)
public final class c implements Source {

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public final /* synthetic */ AsyncTimeout f10115f;

    /* JADX INFO: renamed from: m, reason: collision with root package name */
    public final /* synthetic */ Source f10116m;

    public c(AsyncTimeout asyncTimeout, Source source) {
        this.f10115f = asyncTimeout;
        this.f10116m = source;
    }

    @Override // okio.Source, java.io.Closeable, java.lang.AutoCloseable
    public void close() throws IOException {
        AsyncTimeout asyncTimeout = this.f10115f;
        Source source = this.f10116m;
        asyncTimeout.h();
        try {
            source.close();
            if (asyncTimeout.i()) {
                throw asyncTimeout.j(null);
            }
        } catch (IOException e2) {
            if (!asyncTimeout.i()) {
                throw e2;
            }
            throw asyncTimeout.j(e2);
        } finally {
            asyncTimeout.i();
        }
    }

    @Override // okio.Source
    public long r(Buffer buffer, long j2) throws IOException {
        o.f(buffer, "sink");
        AsyncTimeout asyncTimeout = this.f10115f;
        Source source = this.f10116m;
        asyncTimeout.h();
        try {
            long jR = source.r(buffer, j2);
            if (asyncTimeout.i()) {
                throw asyncTimeout.j(null);
            }
            return jR;
        } catch (IOException e2) {
            if (asyncTimeout.i()) {
                throw asyncTimeout.j(e2);
            }
            throw e2;
        } finally {
            asyncTimeout.i();
        }
    }

    @Override // okio.Source
    public Timeout timeout() {
        return this.f10115f;
    }

    public String toString() {
        StringBuilder sbF = a.F("AsyncTimeout.source(");
        sbF.append(this.f10116m);
        sbF.append(')');
        return sbF.toString();
    }
}