package androidx.room;

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.b;
import androidx.room.c;
import androidx.room.e;
import java.util.Set;
import java.util.concurrent.Executor;
import java.util.concurrent.atomic.AtomicBoolean;

/* loaded from: classes.dex */
class f {

    /* renamed from: a, reason: collision with root package name */
    final Context f2582a;

    /* renamed from: b, reason: collision with root package name */
    final String f2583b;

    /* renamed from: c, reason: collision with root package name */
    int f2584c;

    /* renamed from: d, reason: collision with root package name */
    final androidx.room.e f2585d;

    /* renamed from: e, reason: collision with root package name */
    final e.c f2586e;

    /* renamed from: f, reason: collision with root package name */
    androidx.room.c f2587f;

    /* renamed from: g, reason: collision with root package name */
    final Executor f2588g;

    /* renamed from: h, reason: collision with root package name */
    final androidx.room.b f2589h = new a();

    /* renamed from: i, reason: collision with root package name */
    final AtomicBoolean f2590i = new AtomicBoolean(false);

    /* renamed from: j, reason: collision with root package name */
    final ServiceConnection f2591j;

    /* renamed from: k, reason: collision with root package name */
    final Runnable f2592k;

    /* renamed from: l, reason: collision with root package name */
    final Runnable f2593l;

    /* renamed from: m, reason: collision with root package name */
    private final Runnable f2594m;

    class a extends b.a {

        /* renamed from: androidx.room.f$a$a, reason: collision with other inner class name */
        class RunnableC0039a implements Runnable {

            /* renamed from: a, reason: collision with root package name */
            final /* synthetic */ String[] f2596a;

            RunnableC0039a(String[] strArr) {
                this.f2596a = strArr;
            }

            @Override // java.lang.Runnable
            public void run() {
                f.this.f2585d.e(this.f2596a);
            }
        }

        a() {
        }

        @Override // androidx.room.b
        public void e(String[] strArr) {
            f.this.f2588g.execute(new RunnableC0039a(strArr));
        }
    }

    class b implements ServiceConnection {
        b() {
        }

        @Override // android.content.ServiceConnection
        public void onServiceConnected(ComponentName componentName, IBinder iBinder) {
            f.this.f2587f = c.a.K(iBinder);
            f fVar = f.this;
            fVar.f2588g.execute(fVar.f2592k);
        }

        @Override // android.content.ServiceConnection
        public void onServiceDisconnected(ComponentName componentName) {
            f fVar = f.this;
            fVar.f2588g.execute(fVar.f2593l);
            f.this.f2587f = null;
        }
    }

    class c implements Runnable {
        c() {
        }

        @Override // java.lang.Runnable
        public void run() {
            try {
                f fVar = f.this;
                androidx.room.c cVar = fVar.f2587f;
                if (cVar != null) {
                    fVar.f2584c = cVar.g(fVar.f2589h, fVar.f2583b);
                    f fVar2 = f.this;
                    fVar2.f2585d.a(fVar2.f2586e);
                }
            } catch (RemoteException e10) {
                Log.w("ROOM", "Cannot register multi-instance invalidation callback", e10);
            }
        }
    }

    class d implements Runnable {
        d() {
        }

        @Override // java.lang.Runnable
        public void run() {
            f fVar = f.this;
            fVar.f2585d.g(fVar.f2586e);
        }
    }

    class e implements Runnable {
        e() {
        }

        @Override // java.lang.Runnable
        public void run() {
            f fVar = f.this;
            fVar.f2585d.g(fVar.f2586e);
            try {
                f fVar2 = f.this;
                androidx.room.c cVar = fVar2.f2587f;
                if (cVar != null) {
                    cVar.I(fVar2.f2589h, fVar2.f2584c);
                }
            } catch (RemoteException e10) {
                Log.w("ROOM", "Cannot unregister multi-instance invalidation callback", e10);
            }
            f fVar3 = f.this;
            fVar3.f2582a.unbindService(fVar3.f2591j);
        }
    }

    /* renamed from: androidx.room.f$f, reason: collision with other inner class name */
    class C0040f extends e.c {
        C0040f(String[] strArr) {
            super(strArr);
        }

        @Override // androidx.room.e.c
        boolean a() {
            return true;
        }

        @Override // androidx.room.e.c
        public void b(Set set) {
            if (f.this.f2590i.get()) {
                return;
            }
            try {
                f fVar = f.this;
                androidx.room.c cVar = fVar.f2587f;
                if (cVar != null) {
                    cVar.D(fVar.f2584c, (String[]) set.toArray(new String[0]));
                }
            } catch (RemoteException e10) {
                Log.w("ROOM", "Cannot broadcast invalidation", e10);
            }
        }
    }

    f(Context context, String str, androidx.room.e eVar, Executor executor) {
        b bVar = new b();
        this.f2591j = bVar;
        this.f2592k = new c();
        this.f2593l = new d();
        this.f2594m = new e();
        Context applicationContext = context.getApplicationContext();
        this.f2582a = applicationContext;
        this.f2583b = str;
        this.f2585d = eVar;
        this.f2588g = executor;
        this.f2586e = new C0040f((String[]) eVar.f2559a.keySet().toArray(new String[0]));
        applicationContext.bindService(new Intent(applicationContext, (Class<?>) MultiInstanceInvalidationService.class), bVar, 1);
    }
}