package e.c.d;

import android.os.RemoteException;
import e.c.d.t.a;
import e.c.d.t.b;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

/* JADX INFO: compiled from: SDKMediaDataManager.java */
/* JADX INFO: loaded from: classes.dex */
public class i {

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    private static volatile i f784d;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    private static final byte[] f785e = {-1, -1};

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    private static final byte[] f786f = {-1, -2};
    private e.c.d.t.b a;
    private ConcurrentHashMap<String, com.seewo.sdk.interfaces.j> b = new ConcurrentHashMap<>();

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    private final List<byte[]> f787c = new ArrayList();

    /* JADX INFO: compiled from: SDKMediaDataManager.java */
    class a extends a.AbstractBinderC0037a {
        final /* synthetic */ com.seewo.sdk.interfaces.j a;

        a(com.seewo.sdk.interfaces.j jVar) {
            this.a = jVar;
        }

        @Override // e.c.d.t.a
        public void d(int i2, String str) throws RemoteException {
            this.a.d(i2, str);
        }

        @Override // e.c.d.t.a
        public void e(byte[] bArr) throws RemoteException {
            if (i.i(bArr)) {
                i.this.f787c.add(bArr);
            } else if (!i.h(bArr)) {
                this.a.e(bArr);
            } else {
                i.this.f787c.add(bArr);
                this.a.e(i.this.e());
            }
        }
    }

    private i() {
    }

    /* JADX INFO: Access modifiers changed from: private */
    public byte[] e() {
        Iterator<byte[]> it = this.f787c.iterator();
        int i2 = 0;
        int length = 0;
        while (it.hasNext()) {
            length += it.next().length - (f785e.length * 2);
        }
        byte[] bArr = new byte[length];
        for (byte[] bArr2 : this.f787c) {
            byte[] bArr3 = f785e;
            int length2 = bArr3.length;
            int length3 = bArr2.length - (bArr3.length * 2);
            System.arraycopy(bArr2, length2, bArr, i2, length3);
            i2 += length3;
        }
        this.f787c.clear();
        return bArr;
    }

    public static i f() {
        if (f784d == null) {
            synchronized (i.class) {
                if (f784d == null) {
                    f784d = new i();
                }
            }
        }
        return f784d;
    }

    private void g() {
        this.a = b.a.U(e.c.d.r.b.c.g().f("opensdk_media_data"));
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static boolean h(byte[] bArr) {
        return j(bArr, f786f);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static boolean i(byte[] bArr) {
        return j(bArr, f785e);
    }

    private static boolean j(byte[] bArr, byte[] bArr2) {
        if (bArr == null || bArr.length < bArr2.length * 2) {
            return false;
        }
        for (int i2 = 0; i2 < bArr2.length; i2++) {
            if (bArr[i2] != bArr2[i2] || bArr[(bArr.length - bArr2.length) + i2] != bArr2[i2]) {
                return false;
            }
        }
        return true;
    }

    public void k() {
        e.c.d.y.e.f("SDKMediaDataManager", "reConnect: ");
        g();
        ConcurrentHashMap<String, com.seewo.sdk.interfaces.j> concurrentHashMap = this.b;
        if (concurrentHashMap == null || concurrentHashMap.isEmpty()) {
            return;
        }
        Iterator<Map.Entry<String, com.seewo.sdk.interfaces.j>> it = this.b.entrySet().iterator();
        while (it.hasNext()) {
            String key = it.next().getKey();
            l(key, this.b.get(key));
        }
    }

    public void l(String str, com.seewo.sdk.interfaces.j jVar) {
        e.c.d.y.e.a("SDKMediaDataManager", "registerCallback: " + str);
        if (!c.p().s() || this.a == null) {
            jVar.d(0, str + "OpenSDKService unable connection to get data.");
        }
        if (!j.b.g()) {
            this.f787c.clear();
        }
        e.c.d.t.b bVar = this.a;
        if (bVar != null) {
            try {
                bVar.i(str, new a(jVar));
                this.b.put(str, jVar);
            } catch (RemoteException e2) {
                e.c.d.y.e.c("SDKMediaDataManager", "registerCallback: ", e2);
            }
        }
    }
}