Kahramaa v15.23.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 androidx.activity.x;
import com.firebase.jobdispatcher.a;
import s.h;
import t3.b;
import t3.d;
import t3.e;
import t3.f;

public class GooglePlayReceiver extends Service implements a.InterfaceC0032a {

    public static final int f2829s = 0;

    public Messenger f2832p;
    public a q;

    public final Object f2830n = new Object();

    public final x f2831o = new x();

    public h<String, h<String, d>> f2833r = new h<>(1);

    public final a a() {
        a aVar;
        synchronized (this.f2830n) {
            if (this.q == null) {
                this.q = new a(this, this);
            }
            aVar = this.q;
        }
        return aVar;
    }

    public final t3.f b(android.content.Intent r5) {
        throw new UnsupportedOperationException("Method not decompiled: com.firebase.jobdispatcher.GooglePlayReceiver.b(android.content.Intent):t3.f");
    }

    public final f c(Bundle bundle, d dVar) {
        f fVar;
        Bundle bundle2 = bundle.getBundle("extras");
        if (bundle2 == null) {
            fVar = null;
        } else {
            f.a a10 = e.a(bundle2);
            if (a10.f13837a == null || a10.f13838b == null || a10.f13839c == null) {
                throw new IllegalArgumentException("Required fields were not populated.");
            }
            fVar = new f(a10);
        }
        if (fVar == null) {
            Log.e("FJD.GooglePlayReceiver", "unable to decode job");
            try {
                dVar.a(2);
            } catch (Throwable th) {
                Log.e("FJD.GooglePlayReceiver", "Encountered error running callback", th.getCause());
            }
            return null;
        }
        synchronized (this) {
            h<String, d> orDefault = this.f2833r.getOrDefault(fVar.f13835b, null);
            if (orDefault == null) {
                orDefault = new h<>(1);
                this.f2833r.put(fVar.f13835b, orDefault);
            }
            orDefault.put(fVar.f13834a, dVar);
        }
        return fVar;
    }

    @Override
    public final IBinder onBind(Intent intent) {
        Messenger messenger;
        if (intent == null || !"com.google.android.gms.gcm.ACTION_TASK_READY".equals(intent.getAction())) {
            return null;
        }
        synchronized (this.f2830n) {
            if (this.f2832p == null) {
                this.f2832p = new Messenger(new b(Looper.getMainLooper(), this));
            }
            messenger = this.f2832p;
        }
        return messenger.getBinder();
    }

    @Override
    public final int onStartCommand(Intent intent, int i10, int i11) {
        try {
            super.onStartCommand(intent, i10, i11);
            if (intent == null) {
                Log.w("FJD.GooglePlayReceiver", "Null Intent passed, terminating");
                synchronized (this) {
                    if (this.f2833r.isEmpty()) {
                        stopSelf(i11);
                    }
                }
                return 2;
            }
            String action = intent.getAction();
            if ("com.google.android.gms.gcm.ACTION_TASK_READY".equals(action)) {
                a().a(b(intent));
                synchronized (this) {
                    if (this.f2833r.isEmpty()) {
                        stopSelf(i11);
                    }
                }
                return 2;
            }
            if ("com.google.android.gms.gcm.SERVICE_ACTION_INITIALIZE".equals(action)) {
                synchronized (this) {
                    if (this.f2833r.isEmpty()) {
                        stopSelf(i11);
                    }
                }
                return 2;
            }
            Log.e("FJD.GooglePlayReceiver", "Unknown action received, terminating");
            synchronized (this) {
                if (this.f2833r.isEmpty()) {
                    stopSelf(i11);
                }
            }
            return 2;
        } catch (Throwable th) {
            synchronized (this) {
                if (this.f2833r.isEmpty()) {
                    stopSelf(i11);
                }
                throw th;
            }
        }
    }
}