package q7;

import P6.g;
import d5.AbstractC0844a;
import java.io.IOException;
import x7.C1731g;

/* JADX INFO: loaded from: classes.dex */
public final class f extends a {

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

    @Override // q7.a, x7.H
    public final long M(C1731g c1731g, long j8) throws IOException {
        g.e(c1731g, "sink");
        if (j8 < 0) {
            throw new IllegalArgumentException(AbstractC0844a.i(j8, "byteCount < 0: ").toString());
        }
        if (this.f16330r) {
            throw new IllegalStateException("closed");
        }
        if (this.f16344t) {
            return -1L;
        }
        long jM = super.M(c1731g, j8);
        if (jM != -1) {
            return jM;
        }
        this.f16344t = true;
        a();
        return -1L;
    }

    @Override // java.io.Closeable, java.lang.AutoCloseable
    public final void close() {
        if (this.f16330r) {
            return;
        }
        if (!this.f16344t) {
            a();
        }
        this.f16330r = true;
    }
}