package p138.p176.p291.p320;

import android.content.ComponentName;
import android.content.Context;
import android.content.Intent;
import android.content.ServiceConnection;
import android.os.Bundle;
import android.os.Handler;
import android.os.IBinder;
import android.os.Looper;
import android.os.Message;
import android.os.Messenger;
import android.os.RemoteException;
import android.util.Log;
import android.util.SparseArray;
import com.google.firebase.iid.zzam;
import java.util.ArrayDeque;
import java.util.Iterator;
import java.util.Queue;
import java.util.concurrent.TimeUnit;
import javax.annotation.concurrent.GuardedBy;
import p000.p001.p002.p003.p004.C0567;
import p138.p176.p177.p242.p246.p252.C4306;
import p138.p176.p177.p242.p258.p262.HandlerC4364;

/* JADX INFO: renamed from: ދ.ހ.ށ.ވ.ރ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes.dex */
public final class ServiceConnectionC5910 implements ServiceConnection {

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

    /* JADX INFO: renamed from: ރ, reason: contains not printable characters */
    public final /* synthetic */ C5909 f16686;

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    @GuardedBy("this")
    public int f16681 = 0;

    /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
    public final Messenger f16682 = new Messenger(new HandlerC4364(Looper.getMainLooper(), new Handler.Callback(this) { // from class: ދ.ހ.ށ.ވ.ކ

        /* JADX INFO: renamed from: ރ, reason: contains not printable characters */
        public final ServiceConnectionC5910 f16688;

        {
            this.f16688 = this;
        }

        @Override // android.os.Handler.Callback
        public final boolean handleMessage(Message message) {
            this.f16688.m9245(message);
            return true;
        }
    }));

    /* JADX INFO: renamed from: ށ, reason: contains not printable characters */
    @GuardedBy("this")
    public final Queue<AbstractC5919<?>> f16684 = new ArrayDeque();

    /* JADX INFO: renamed from: ނ, reason: contains not printable characters */
    @GuardedBy("this")
    public final SparseArray<AbstractC5919<?>> f16685 = new SparseArray<>();

    public /* synthetic */ ServiceConnectionC5910(C5909 c5909, C5911 c5911) {
        this.f16686 = c5909;
    }

    @Override // android.content.ServiceConnection
    public final void onServiceConnected(ComponentName componentName, final IBinder iBinder) {
        if (Log.isLoggable("MessengerIpcClient", 2)) {
            Log.v("MessengerIpcClient", "Service connected");
        }
        this.f16686.f16678.execute(new Runnable(this, iBinder) { // from class: ދ.ހ.ށ.ވ.ވ

            /* JADX INFO: renamed from: ރ, reason: contains not printable characters */
            public final ServiceConnectionC5910 f16690;

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

            {
                this.f16690 = this;
                this.f16691 = iBinder;
            }

            @Override // java.lang.Runnable
            public final void run() {
                ServiceConnectionC5910 serviceConnectionC5910 = this.f16690;
                IBinder iBinder2 = this.f16691;
                synchronized (serviceConnectionC5910) {
                    try {
                        if (iBinder2 == null) {
                            serviceConnectionC5910.m9244(0, "Null service connection");
                            return;
                        }
                        try {
                            serviceConnectionC5910.f16683 = new C5918(iBinder2);
                            serviceConnectionC5910.f16681 = 2;
                            serviceConnectionC5910.f16686.f16678.execute(new RunnableC5914(serviceConnectionC5910));
                        } catch (RemoteException e) {
                            serviceConnectionC5910.m9244(0, e.getMessage());
                        }
                    } catch (Throwable th) {
                        throw th;
                    }
                }
            }
        });
    }

    @Override // android.content.ServiceConnection
    public final void onServiceDisconnected(ComponentName componentName) {
        if (Log.isLoggable("MessengerIpcClient", 2)) {
            Log.v("MessengerIpcClient", "Service disconnected");
        }
        this.f16686.f16678.execute(new Runnable(this) { // from class: ދ.ހ.ށ.ވ.ފ

            /* JADX INFO: renamed from: ރ, reason: contains not printable characters */
            public final ServiceConnectionC5910 f16694;

            {
                this.f16694 = this;
            }

            @Override // java.lang.Runnable
            public final void run() {
                this.f16694.m9244(2, "Service disconnected");
            }
        });
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public final synchronized void m9242() {
        if (this.f16681 == 2 && this.f16684.isEmpty() && this.f16685.size() == 0) {
            if (Log.isLoggable("MessengerIpcClient", 2)) {
                Log.v("MessengerIpcClient", "Finished handling requests, unbinding");
            }
            this.f16681 = 3;
            C4306 c4306M7206 = C4306.m7206();
            Context context = this.f16686.f16677;
            if (c4306M7206 == null) {
                throw null;
            }
            context.unbindService(this);
        }
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public final synchronized void m9243(int i) {
        AbstractC5919<?> abstractC5919 = this.f16685.get(i);
        if (abstractC5919 != null) {
            StringBuilder sb = new StringBuilder(31);
            sb.append("Timing out request: ");
            sb.append(i);
            Log.w("MessengerIpcClient", sb.toString());
            this.f16685.remove(i);
            abstractC5919.m9248(new zzam(3, "Timed out waiting for response"));
            m9242();
        }
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public final synchronized void m9244(int i, String str) {
        if (Log.isLoggable("MessengerIpcClient", 3)) {
            String strValueOf = String.valueOf(str);
            Log.d("MessengerIpcClient", strValueOf.length() != 0 ? "Disconnected: ".concat(strValueOf) : new String("Disconnected: "));
        }
        int i2 = this.f16681;
        if (i2 == 0) {
            throw new IllegalStateException();
        }
        if (i2 != 1 && i2 != 2) {
            if (i2 == 3) {
                this.f16681 = 4;
                return;
            } else {
                if (i2 == 4) {
                    return;
                }
                int i3 = this.f16681;
                StringBuilder sb = new StringBuilder(26);
                sb.append("Unknown state: ");
                sb.append(i3);
                throw new IllegalStateException(sb.toString());
            }
        }
        if (Log.isLoggable("MessengerIpcClient", 2)) {
            Log.v("MessengerIpcClient", "Unbinding service");
        }
        this.f16681 = 4;
        C4306 c4306M7206 = C4306.m7206();
        Context context = this.f16686.f16677;
        if (c4306M7206 == null) {
            throw null;
        }
        context.unbindService(this);
        zzam zzamVar = new zzam(i, str);
        Iterator<AbstractC5919<?>> it = this.f16684.iterator();
        while (it.hasNext()) {
            it.next().m9248(zzamVar);
        }
        this.f16684.clear();
        for (int i4 = 0; i4 < this.f16685.size(); i4++) {
            this.f16685.valueAt(i4).m9248(zzamVar);
        }
        this.f16685.clear();
    }

    /* JADX WARN: Type inference incomplete: some casts might be missing */
    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public final boolean m9245(Message message) {
        int i = message.arg1;
        if (Log.isLoggable("MessengerIpcClient", 3)) {
            StringBuilder sb = new StringBuilder(41);
            sb.append("Received response to request: ");
            sb.append(i);
            Log.d("MessengerIpcClient", sb.toString());
        }
        synchronized (this) {
            AbstractC5919<?> abstractC5919 = this.f16685.get(i);
            if (abstractC5919 == null) {
                StringBuilder sb2 = new StringBuilder(50);
                sb2.append("Received response for unknown request: ");
                sb2.append(i);
                Log.w("MessengerIpcClient", sb2.toString());
                return true;
            }
            this.f16685.remove(i);
            m9242();
            Bundle data = message.getData();
            if (data.getBoolean("unsupported", false)) {
                abstractC5919.m9248(new zzam(4, "Not supported by GmsCore"));
            } else {
                C5921 c5921 = (C5921) abstractC5919;
                Object bundle = data.getBundle("data");
                if (bundle == null) {
                    bundle = Bundle.EMPTY;
                }
                if (Log.isLoggable("MessengerIpcClient", 3)) {
                    String strValueOf = String.valueOf(c5921);
                    String strValueOf2 = String.valueOf(bundle);
                    StringBuilder sb3 = new StringBuilder(strValueOf2.length() + strValueOf.length() + 16);
                    sb3.append("Finishing ");
                    sb3.append(strValueOf);
                    sb3.append(" with ");
                    sb3.append(strValueOf2);
                    Log.d("MessengerIpcClient", sb3.toString());
                }
                c5921.f16698.f15214.m8562((TResult) bundle);
            }
            return true;
        }
    }

    /* JADX INFO: renamed from: ֏, reason: contains not printable characters */
    public final synchronized boolean m9246(AbstractC5919<?> abstractC5919) {
        int i = this.f16681;
        if (i != 0) {
            if (i == 1) {
                this.f16684.add(abstractC5919);
                return true;
            }
            if (i == 2) {
                this.f16684.add(abstractC5919);
                this.f16686.f16678.execute(new RunnableC5914(this));
                return true;
            }
            if (i != 3 && i != 4) {
                int i2 = this.f16681;
                StringBuilder sb = new StringBuilder(26);
                sb.append("Unknown state: ");
                sb.append(i2);
                throw new IllegalStateException(sb.toString());
            }
            return false;
        }
        this.f16684.add(abstractC5919);
        C0567.m1939(this.f16681 == 0);
        if (Log.isLoggable("MessengerIpcClient", 2)) {
            Log.v("MessengerIpcClient", "Starting bind to GmsCore");
        }
        this.f16681 = 1;
        Intent intent = new Intent("com.google.android.c2dm.intent.REGISTER");
        intent.setPackage("com.google.android.gms");
        C4306 c4306M7206 = C4306.m7206();
        Context context = this.f16686.f16677;
        if (c4306M7206 == null) {
            throw null;
        }
        context.getClass().getName();
        if (c4306M7206.m7208(context, intent, this, 1)) {
            this.f16686.f16678.schedule(new Runnable(this) { // from class: ދ.ހ.ށ.ވ.ޅ

                /* JADX INFO: renamed from: ރ, reason: contains not printable characters */
                public final ServiceConnectionC5910 f16687;

                {
                    this.f16687 = this;
                }

                @Override // java.lang.Runnable
                public final void run() {
                    this.f16687.m9247();
                }
            }, 30L, TimeUnit.SECONDS);
        } else {
            m9244(0, "Unable to bind to service");
        }
        return true;
    }

    /* JADX INFO: renamed from: ؠ, reason: contains not printable characters */
    public final synchronized void m9247() {
        if (this.f16681 == 1) {
            m9244(1, "Timed out while binding");
        }
    }
}