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

package com.sigmob.sdk.videocache;

import android.os.Handler;
import android.os.Looper;
import android.os.Message;
import com.sigmob.sdk.videocache.file.b;
import java.io.File;
import java.io.IOException;
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 i {
    private final AtomicInteger a = new AtomicInteger(0);
    private final String b;
    private volatile g c;
    private final List<d> d;
    private final d e;
    private final e f;

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

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

        @Override // com.sigmob.sdk.videocache.d
        public void a(File file, String str, int i) {
            Message obtainMessage = obtainMessage();
            obtainMessage.arg1 = i;
            obtainMessage.obj = file;
            sendMessage(obtainMessage);
        }

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

    public i(String str, e eVar) {
        CopyOnWriteArrayList copyOnWriteArrayList = new CopyOnWriteArrayList();
        this.d = copyOnWriteArrayList;
        this.b = (String) n.a(str);
        this.f = (e) n.a(eVar);
        this.e = new a(str, copyOnWriteArrayList);
    }

    private synchronized void c() throws p {
        this.c = this.c == null ? e() : this.c;
    }

    private synchronized void d() {
        if (this.a.decrementAndGet() <= 0) {
            this.c.a();
            this.c = null;
        }
    }

    private g e() throws p {
        g gVar = new g(new j(this.b, this.f.d, this.f.e), new b(this.f.a(this.b), this.f.c));
        gVar.a(this.e);
        return gVar;
    }

    public void a() {
        this.d.clear();
        if (this.c != null) {
            this.c.a((d) null);
            this.c.a();
            this.c = null;
        }
        this.a.set(0);
    }

    public void a(d dVar) {
        this.d.add(dVar);
    }

    public void a(f fVar, Socket socket) throws p, IOException {
        c();
        try {
            this.a.incrementAndGet();
            this.c.a(fVar, socket);
        } catch (Throwable th) {
            d();
            throw th;
        }
        d();
    }

    public int b() {
        return this.a.get();
    }

    public void b(d dVar) {
        this.d.remove(dVar);
    }
}