package p037.p109;

import android.content.ComponentName;
import android.content.Context;
import android.content.Intent;
import android.content.ServiceConnection;
import android.os.IBinder;
import android.os.RemoteException;
import android.util.Log;
import androidx.room.MultiInstanceInvalidationService;
import java.util.Set;
import java.util.concurrent.Executor;
import java.util.concurrent.atomic.AtomicBoolean;
import p037.p109.C2387;
import p037.p109.InterfaceC2380;
import p037.p109.InterfaceC2383;

/* JADX INFO: renamed from: މ.ސ.ޅ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes.dex */
public class C2393 {

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public final Context f7574;

    /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
    public final String f7575;

    /* JADX INFO: renamed from: ހ, reason: contains not printable characters */
    public int f7576;

    /* JADX INFO: renamed from: ށ, reason: contains not printable characters */
    public final C2387 f7577;

    /* JADX INFO: renamed from: ނ, reason: contains not printable characters */
    public final C2387.AbstractC2390 f7578;

    /* JADX INFO: renamed from: ރ, reason: contains not printable characters */
    public InterfaceC2383 f7579;

    /* JADX INFO: renamed from: ބ, reason: contains not printable characters */
    public final Executor f7580;

    /* JADX INFO: renamed from: ޅ, reason: contains not printable characters */
    public final InterfaceC2380 f7581 = new BinderC2394();

    /* JADX INFO: renamed from: ކ, reason: contains not printable characters */
    public final AtomicBoolean f7582 = new AtomicBoolean(false);

    /* JADX INFO: renamed from: އ, reason: contains not printable characters */
    public final ServiceConnection f7583 = new ServiceConnectionC2396();

    /* JADX INFO: renamed from: ވ, reason: contains not printable characters */
    public final Runnable f7584 = new RunnableC2397();

    /* JADX INFO: renamed from: މ, reason: contains not printable characters */
    public final Runnable f7585 = new RunnableC2398();

    /* JADX INFO: renamed from: ފ, reason: contains not printable characters */
    public final Runnable f7586 = new RunnableC2399();

    /* JADX INFO: renamed from: މ.ސ.ޅ$֏, reason: contains not printable characters */
    public class BinderC2394 extends InterfaceC2380.AbstractBinderC2381 {

        /* JADX INFO: renamed from: މ.ސ.ޅ$֏$֏, reason: contains not printable characters */
        public class RunnableC2395 implements Runnable {

            /* JADX INFO: renamed from: ރ, reason: contains not printable characters */
            public final /* synthetic */ String[] f7588;

            public RunnableC2395(String[] strArr) {
                this.f7588 = strArr;
            }

            @Override // java.lang.Runnable
            public void run() {
                C2393.this.f7577.m4459(this.f7588);
            }
        }

        public BinderC2394() {
        }

        @Override // p037.p109.InterfaceC2380
        /* JADX INFO: renamed from: ֏ */
        public void mo4452(String[] strArr) {
            C2393.this.f7580.execute(new RunnableC2395(strArr));
        }
    }

    /* JADX INFO: renamed from: މ.ސ.ޅ$ؠ, reason: contains not printable characters */
    public class ServiceConnectionC2396 implements ServiceConnection {
        public ServiceConnectionC2396() {
        }

        @Override // android.content.ServiceConnection
        public void onServiceConnected(ComponentName componentName, IBinder iBinder) {
            C2393.this.f7579 = InterfaceC2383.AbstractBinderC2384.m4454(iBinder);
            C2393 c2393 = C2393.this;
            c2393.f7580.execute(c2393.f7584);
        }

        @Override // android.content.ServiceConnection
        public void onServiceDisconnected(ComponentName componentName) {
            C2393 c2393 = C2393.this;
            c2393.f7580.execute(c2393.f7585);
            C2393.this.f7579 = null;
        }
    }

    /* JADX INFO: renamed from: މ.ސ.ޅ$ހ, reason: contains not printable characters */
    public class RunnableC2397 implements Runnable {
        public RunnableC2397() {
        }

        @Override // java.lang.Runnable
        public void run() {
            try {
                InterfaceC2383 interfaceC2383 = C2393.this.f7579;
                if (interfaceC2383 != null) {
                    C2393.this.f7576 = interfaceC2383.mo812(C2393.this.f7581, C2393.this.f7575);
                    C2393.this.f7577.m4456(C2393.this.f7578);
                }
            } catch (RemoteException e) {
                Log.w("ROOM", "Cannot register multi-instance invalidation callback", e);
            }
        }
    }

    /* JADX INFO: renamed from: މ.ސ.ޅ$ށ, reason: contains not printable characters */
    public class RunnableC2398 implements Runnable {
        public RunnableC2398() {
        }

        @Override // java.lang.Runnable
        public void run() {
            C2393 c2393 = C2393.this;
            c2393.f7577.m4462(c2393.f7578);
        }
    }

    /* JADX INFO: renamed from: މ.ސ.ޅ$ނ, reason: contains not printable characters */
    public class RunnableC2399 implements Runnable {
        public RunnableC2399() {
        }

        @Override // java.lang.Runnable
        public void run() {
            C2393 c2393 = C2393.this;
            c2393.f7577.m4462(c2393.f7578);
            try {
                InterfaceC2383 interfaceC2383 = C2393.this.f7579;
                if (interfaceC2383 != null) {
                    interfaceC2383.mo814(C2393.this.f7581, C2393.this.f7576);
                }
            } catch (RemoteException e) {
                Log.w("ROOM", "Cannot unregister multi-instance invalidation callback", e);
            }
            C2393 c23932 = C2393.this;
            c23932.f7574.unbindService(c23932.f7583);
        }
    }

    /* JADX INFO: renamed from: މ.ސ.ޅ$ރ, reason: contains not printable characters */
    public class C2400 extends C2387.AbstractC2390 {
        public C2400(String[] strArr) {
            super(strArr);
        }

        @Override // p037.p109.C2387.AbstractC2390
        /* JADX INFO: renamed from: ֏ */
        public void mo4471(Set<String> set) {
            if (C2393.this.f7582.get()) {
                return;
            }
            try {
                InterfaceC2383 interfaceC2383 = C2393.this.f7579;
                if (interfaceC2383 != null) {
                    interfaceC2383.mo813(C2393.this.f7576, (String[]) set.toArray(new String[0]));
                }
            } catch (RemoteException e) {
                Log.w("ROOM", "Cannot broadcast invalidation", e);
            }
        }

        @Override // p037.p109.C2387.AbstractC2390
        /* JADX INFO: renamed from: ֏ */
        public boolean mo4472() {
            return true;
        }
    }

    public C2393(Context context, String str, C2387 c2387, Executor executor) {
        this.f7574 = context.getApplicationContext();
        this.f7575 = str;
        this.f7577 = c2387;
        this.f7580 = executor;
        this.f7578 = new C2400((String[]) c2387.f7549.keySet().toArray(new String[0]));
        this.f7574.bindService(new Intent(this.f7574, (Class<?>) MultiInstanceInvalidationService.class), this.f7583, 1);
    }
}