package G0;

import L0.a;
import L0.b;
import android.os.RemoteException;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

/* JADX INFO: loaded from: classes.dex */
public class j {

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

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

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

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    private L0.b f807a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    private ConcurrentHashMap f808b = new ConcurrentHashMap();

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    private final List f809c = new ArrayList();

    class a extends a.AbstractBinderC0025a {
        a(H0.i iVar) {
        }

        @Override // L0.a
        public void a(int i2, String str) {
            throw null;
        }

        @Override // L0.a
        public void q(byte[] bArr) {
            if (j.i(bArr)) {
                j.this.f809c.add(bArr);
            } else {
                if (!j.h(bArr)) {
                    throw null;
                }
                j.this.f809c.add(bArr);
                j.this.e();
                throw null;
            }
        }
    }

    private j() {
    }

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

    public static j f() {
        if (f804d == null) {
            synchronized (j.class) {
                try {
                    if (f804d == null) {
                        f804d = new j();
                    }
                } finally {
                }
            }
        }
        return f804d;
    }

    private void g() {
        this.f807a = b.a.E(J0.c.g().f("opensdk_media_data"));
    }

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

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

    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++) {
            byte b2 = bArr[i2];
            byte b3 = bArr2[i2];
            if (b2 != b3 || bArr[(bArr.length - bArr2.length) + i2] != b3) {
                return false;
            }
        }
        return true;
    }

    public void k() {
        Q0.e.f("SDKMediaDataManager", "reConnect: ");
        g();
        ConcurrentHashMap concurrentHashMap = this.f808b;
        if (concurrentHashMap == null || concurrentHashMap.isEmpty()) {
            return;
        }
        Iterator it = this.f808b.entrySet().iterator();
        while (it.hasNext()) {
            String str = (String) ((Map.Entry) it.next()).getKey();
            android.support.v4.media.a.a(this.f808b.get(str));
            l(str, null);
        }
    }

    public void l(String str, H0.i iVar) {
        Q0.e.a("SDKMediaDataManager", "registerCallback: " + str);
        if (!d.o().r() || this.f807a == null) {
            iVar.a(0, str + "OpenSDKService unable connection to get data.");
        }
        if (!k.f811b.i()) {
            this.f809c.clear();
        }
        L0.b bVar = this.f807a;
        if (bVar != null) {
            try {
                bVar.k(str, new a(iVar));
                this.f808b.put(str, iVar);
            } catch (RemoteException e2) {
                Q0.e.c("SDKMediaDataManager", "registerCallback: ", e2);
            }
        }
    }
}