package Q4;

import O4.l;
import X4.e;
import X4.j;
import X4.o;
import X4.u;
import X4.w;
import java.io.IOException;
import r4.AbstractC0983h;

/* JADX INFO: loaded from: classes.dex */
public abstract class a implements u {

    /* JADX INFO: renamed from: k, reason: collision with root package name */
    public final j f2607k;

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

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

    public a(l lVar) {
        AbstractC0983h.e("this$0", lVar);
        this.f2609m = lVar;
        w wVarD = ((o) lVar.f2369d).f3341k.d();
        AbstractC0983h.e("delegate", wVarD);
        j jVar = new j();
        jVar.f3327e = wVarD;
        this.f2607k = jVar;
    }

    public final void a() {
        l lVar = this.f2609m;
        int i = lVar.f2366a;
        if (i == 6) {
            return;
        }
        if (i != 5) {
            throw new IllegalStateException(AbstractC0983h.h("state: ", Integer.valueOf(lVar.f2366a)));
        }
        j jVar = this.f2607k;
        w wVar = jVar.f3327e;
        jVar.f3327e = w.f3356d;
        wVar.a();
        wVar.b();
        lVar.f2366a = 6;
    }

    @Override // X4.u
    public final w d() {
        return this.f2607k;
    }

    @Override // X4.u
    public long p(e eVar, long j5) throws IOException {
        l lVar = this.f2609m;
        AbstractC0983h.e("sink", eVar);
        try {
            return ((o) lVar.f2369d).p(eVar, j5);
        } catch (IOException e2) {
            ((O4.j) lVar.f2368c).k();
            a();
            throw e2;
        }
    }
}