翰林优商.apk(点击下载) / g.java

package com.kwad.sdk.core.videocache;

import android.os.Handler;
import android.os.Looper;
import android.os.Message;
import com.kwad.sdk.core.videocache.kwai.b;
import com.kwad.sdk.utils.an;
import java.io.File;
import java.net.Socket;
import java.util.List;
import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.atomic.AtomicInteger;

/* access modifiers changed from: package-private */
public final class g {
    private final List<b> aLo;
    private final c bdm;
    private final AtomicInteger bdq = new AtomicInteger(0);
    private volatile e bdr;
    private final b bds;
    private final String url;

    static final class a extends Handler implements b {
        private final List<b> aLo;
        private final String url;

        public a(String str, List<b> list) {
            super(Looper.getMainLooper());
            this.url = str;
            this.aLo = list;
        }

        @Override // com.kwad.sdk.core.videocache.b
        public final void a(File file, int i) {
            Message obtainMessage = obtainMessage();
            obtainMessage.arg1 = i;
            obtainMessage.obj = file;
            sendMessage(obtainMessage);
        }

        public final void handleMessage(Message message) {
            for (b bVar : this.aLo) {
                bVar.a((File) message.obj, message.arg1);
            }
        }
    }

    public g(String str, c cVar) {
        CopyOnWriteArrayList copyOnWriteArrayList = new CopyOnWriteArrayList();
        this.aLo = copyOnWriteArrayList;
        this.url = an.fw(str);
        this.bdm = (c) an.checkNotNull(cVar);
        this.bds = new a(str, copyOnWriteArrayList);
    }

    private synchronized void OO() {
        this.bdr = this.bdr == null ? OQ() : this.bdr;
    }

    private synchronized void OP() {
        if (this.bdq.decrementAndGet() <= 0) {
            this.bdr.shutdown();
            this.bdr = null;
        }
    }

    private e OQ() {
        e eVar = new e(new h(this.url, this.bdm.bcX, this.bdm.bcY), new b(this.bdm.dP(this.url), this.bdm.bcW));
        eVar.a(this.bds);
        return eVar;
    }

    public final int OL() {
        return this.bdq.get();
    }

    public final void a(d dVar, Socket socket) {
        OO();
        try {
            this.bdq.incrementAndGet();
            this.bdr.a(dVar, socket);
        } finally {
            OP();
        }
    }

    public final void shutdown() {
        this.aLo.clear();
        e eVar = this.bdr;
        if (eVar != null) {
            eVar.a((b) null);
            eVar.shutdown();
        }
        this.bdr = null;
        this.bdq.set(0);
    }
}