Mint v5.7.3 - GooglePlayReceiver.java 源代码

package com.firebase.jobdispatcher;

import android.app.Service;
import android.content.Intent;
import android.os.Bundle;
import android.os.IBinder;
import android.os.Looper;
import android.os.Messenger;
import android.util.Log;
import android.util.Pair;
import androidx.annotation.NonNull;
import androidx.annotation.Nullable;
import androidx.annotation.VisibleForTesting;
import androidx.collection.SimpleArrayMap;
import com.firebase.jobdispatcher.c;
import com.firebase.jobdispatcher.l;
import com.firebase.jobdispatcher.n;
import com.firebase.jobdispatcher.p;
import com.google.android.gms.gcm.GcmTaskService;

public class GooglePlayReceiver extends Service implements c.b {
    private static final m g = new m("com.firebase.jobdispatcher.");
    private static final SimpleArrayMap<String, SimpleArrayMap<String, d4.b>> h = new SimpleArrayMap<>(1);
    private final d a = new d();

    @VisibleForTesting
    Messenger b;

    @VisibleForTesting
    d4.a c;

    @VisibleForTesting
    d4.f d;
    private c e;
    private int f;

    @NonNull
    private synchronized d4.a c() {
        if (this.c == null) {
            this.c = new e(getApplicationContext());
        }
        return this.c;
    }

    static m d() {
        return g;
    }

    private synchronized Messenger e() {
        if (this.b == null) {
            this.b = new Messenger(new h(Looper.getMainLooper(), this));
        }
        return this.b;
    }

    @NonNull
    private synchronized d4.f f() {
        if (this.d == null) {
            this.d = new d4.f(c().a());
        }
        return this.d;
    }

    private static boolean g(d4.c cVar, int i) {
        return cVar.f() && (cVar.a() instanceof p.a) && i != 1;
    }

    static void h(l lVar) {
        SimpleArrayMap<String, SimpleArrayMap<String, d4.b>> simpleArrayMap = h;
        synchronized (simpleArrayMap) {
            SimpleArrayMap simpleArrayMap2 = (SimpleArrayMap) simpleArrayMap.get(lVar.getService());
            if (simpleArrayMap2 == null) {
                return;
            }
            if (((d4.b) simpleArrayMap2.get(lVar.getTag())) == null) {
                return;
            }
            c.e(new n.b().s(lVar.getTag()).r(lVar.getService()).t(lVar.a()).l(), false);
        }
    }

    private void k(n nVar) {
        c().b(new l.b(f(), nVar).q(true).p());
    }

    private static void l(d4.b bVar, int i) {
        try {
            bVar.a(i);
        } catch (Throwable th) {
            Log.e("FJD.GooglePlayReceiver", "Encountered error running callback", th.getCause());
        }
    }

    @Override
    public void a(@NonNull n nVar, int i) {
        SimpleArrayMap<String, SimpleArrayMap<String, d4.b>> simpleArrayMap = h;
        synchronized (simpleArrayMap) {
            try {
                SimpleArrayMap simpleArrayMap2 = (SimpleArrayMap) simpleArrayMap.get(nVar.getService());
                if (simpleArrayMap2 == null) {
                    if (simpleArrayMap.isEmpty()) {
                        stopSelf(this.f);
                    }
                    return;
                }
                d4.b bVar = (d4.b) simpleArrayMap2.remove(nVar.getTag());
                if (bVar == null) {
                    if (simpleArrayMap.isEmpty()) {
                        stopSelf(this.f);
                    }
                    return;
                }
                if (simpleArrayMap2.isEmpty()) {
                    simpleArrayMap.remove(nVar.getService());
                }
                if (g(nVar, i)) {
                    k(nVar);
                } else {
                    if (Log.isLoggable("FJD.GooglePlayReceiver", 2)) {
                        Log.v("FJD.GooglePlayReceiver", "sending jobFinished for " + nVar.getTag() + " = " + i);
                    }
                    l(bVar, i);
                }
                if (simpleArrayMap.isEmpty()) {
                    stopSelf(this.f);
                }
            } catch (Throwable th) {
                if (h.isEmpty()) {
                    stopSelf(this.f);
                }
                throw th;
            }
        }
    }

    synchronized c b() {
        if (this.e == null) {
            this.e = new c(this, this);
        }
        return this.e;
    }

    @Nullable
    @VisibleForTesting
    n i(Intent intent) {
        Bundle extras = intent.getExtras();
        if (extras == null) {
            Log.e("FJD.GooglePlayReceiver", "No data provided, terminating");
            return null;
        }
        Pair<d4.b, Bundle> b = this.a.b(extras);
        if (b != null) {
            return j((d4.b) b.first, (Bundle) b.second);
        }
        Log.i("FJD.GooglePlayReceiver", "no callback found");
        return null;
    }

    @Nullable
    n j(d4.b bVar, Bundle bundle) {
        n d = g.d(bundle);
        if (d == null) {
            Log.e("FJD.GooglePlayReceiver", "unable to decode job");
            l(bVar, 2);
            return null;
        }
        SimpleArrayMap<String, SimpleArrayMap<String, d4.b>> simpleArrayMap = h;
        synchronized (simpleArrayMap) {
            SimpleArrayMap simpleArrayMap2 = (SimpleArrayMap) simpleArrayMap.get(d.getService());
            if (simpleArrayMap2 == null) {
                simpleArrayMap2 = new SimpleArrayMap(1);
                simpleArrayMap.put(d.getService(), simpleArrayMap2);
            }
            simpleArrayMap2.put(d.getTag(), bVar);
        }
        return d;
    }

    @Override
    @Nullable
    public IBinder onBind(Intent intent) {
        if (intent == null || !GcmTaskService.SERVICE_ACTION_EXECUTE_TASK.equals(intent.getAction())) {
            return null;
        }
        return e().getBinder();
    }

    @Override
    public final int onStartCommand(Intent intent, int i, int i4) {
        try {
            super.onStartCommand(intent, i, i4);
            if (intent == null) {
                Log.w("FJD.GooglePlayReceiver", "Null Intent passed, terminating");
                SimpleArrayMap<String, SimpleArrayMap<String, d4.b>> simpleArrayMap = h;
                synchronized (simpleArrayMap) {
                    this.f = i4;
                    if (simpleArrayMap.isEmpty()) {
                        stopSelf(this.f);
                    }
                }
                return 2;
            }
            String action = intent.getAction();
            if (GcmTaskService.SERVICE_ACTION_EXECUTE_TASK.equals(action)) {
                b().c(i(intent));
                SimpleArrayMap<String, SimpleArrayMap<String, d4.b>> simpleArrayMap2 = h;
                synchronized (simpleArrayMap2) {
                    this.f = i4;
                    if (simpleArrayMap2.isEmpty()) {
                        stopSelf(this.f);
                    }
                }
                return 2;
            }
            if (GcmTaskService.SERVICE_ACTION_INITIALIZE.equals(action)) {
                SimpleArrayMap<String, SimpleArrayMap<String, d4.b>> simpleArrayMap3 = h;
                synchronized (simpleArrayMap3) {
                    this.f = i4;
                    if (simpleArrayMap3.isEmpty()) {
                        stopSelf(this.f);
                    }
                }
                return 2;
            }
            Log.e("FJD.GooglePlayReceiver", "Unknown action received, terminating");
            SimpleArrayMap<String, SimpleArrayMap<String, d4.b>> simpleArrayMap4 = h;
            synchronized (simpleArrayMap4) {
                this.f = i4;
                if (simpleArrayMap4.isEmpty()) {
                    stopSelf(this.f);
                }
            }
            return 2;
        } catch (Throwable th) {
            SimpleArrayMap<String, SimpleArrayMap<String, d4.b>> simpleArrayMap5 = h;
            synchronized (simpleArrayMap5) {
                this.f = i4;
                if (simpleArrayMap5.isEmpty()) {
                    stopSelf(this.f);
                }
                throw th;
            }
        }
    }
}