package com.google.android.gms.internal;

import android.content.Context;
import android.os.Bundle;
import android.os.Looper;
import android.os.Message;
import android.support.annotation.BinderThread;
import android.support.annotation.NonNull;
import android.support.annotation.WorkerThread;
import android.util.Log;
import com.google.android.gms.common.ConnectionResult;
import com.google.android.gms.common.api.Api;
import com.google.android.gms.common.api.Api.zza;
import com.google.android.gms.common.api.Api.zzb;
import com.google.android.gms.common.api.Api.zzc;
import com.google.android.gms.common.api.Api.zzd;
import com.google.android.gms.common.api.Api.zze;
import com.google.android.gms.common.api.GoogleApiClient.ConnectionCallbacks;
import com.google.android.gms.common.api.GoogleApiClient.OnConnectionFailedListener;
import com.google.android.gms.common.api.Result;
import com.google.android.gms.common.internal.zzac;
import com.google.android.gms.common.internal.zzf.zzf;
import com.google.android.gms.common.internal.zzg;
import com.google.android.gms.common.internal.zzr;
import com.google.android.gms.common.zze;
import java.lang.ref.WeakReference;
import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Iterator;
import java.util.Map;
import java.util.Queue;
import java.util.Set;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Future;
import java.util.concurrent.locks.Lock;

public class zzaar
  implements zzaau
{
  private final zzaav a;
  private final Lock b;
  private final Context c;
  private final zze d;
  private ConnectionResult e;
  private int f;
  private int g = 0;
  private int h;
  private final Bundle i = new Bundle();
  private final Set<Api.zzc> j = new HashSet();
  private zzbai k;
  private boolean l;
  private boolean m;
  private boolean n;
  private zzr o;
  private boolean p;
  private boolean q;
  private final zzg r;
  private final Map<Api<?>, Boolean> s;
  private final Api.zza<? extends zzbai, zzbaj> t;
  private ArrayList<Future<?>> u = new ArrayList();
  
  public zzaar(zzaav paramzzaav, zzg paramzzg, Map<Api<?>, Boolean> paramMap, zze paramzze, Api.zza<? extends zzbai, zzbaj> paramzza, Lock paramLock, Context paramContext)
  {
    this.a = paramzzaav;
    this.r = paramzzg;
    this.s = paramMap;
    this.d = paramzze;
    this.t = paramzza;
    this.b = paramLock;
    this.c = paramContext;
  }
  
  private void a(ConnectionResult paramConnectionResult, Api<?> paramApi, boolean paramBoolean)
  {
    int i2 = 1;
    int i3 = paramApi.zzve().getPriority();
    if (paramBoolean)
    {
      if (paramConnectionResult.hasResolution())
      {
        i1 = 1;
        if (i1 == 0) {
          break label116;
        }
      }
    }
    else
    {
      i1 = i2;
      if (this.e != null) {
        if (i3 >= this.f) {
          break label116;
        }
      }
    }
    label116:
    for (int i1 = i2;; i1 = 0)
    {
      if (i1 != 0)
      {
        this.e = paramConnectionResult;
        this.f = i3;
      }
      this.a.g.put(paramApi.zzvg(), paramConnectionResult);
      return;
      if (this.d.zzcw(paramConnectionResult.getErrorCode()) != null)
      {
        i1 = 1;
        break;
      }
      i1 = 0;
      break;
    }
  }
  
  private void a(boolean paramBoolean)
  {
    if (this.k != null)
    {
      if ((this.k.isConnected()) && (paramBoolean)) {
        this.k.zzPJ();
      }
      this.k.disconnect();
      this.o = null;
    }
  }
  
  private boolean a()
  {
    this.h -= 1;
    if (this.h > 0) {
      return false;
    }
    if (this.h < 0)
    {
      Log.w("GoogleApiClientConnecting", this.a.m.d());
      Log.wtf("GoogleApiClientConnecting", "GoogleApiClient received too many callbacks for the given step. Clients may be in an unexpected state; GoogleApiClient will now disconnect.", new Exception());
      b(new ConnectionResult(8, null));
      return false;
    }
    if (this.e != null)
    {
      this.a.l = this.f;
      b(this.e);
      return false;
    }
    return true;
  }
  
  private boolean a(int paramInt)
  {
    if (this.g != paramInt)
    {
      Log.w("GoogleApiClientConnecting", this.a.m.d());
      String str1 = String.valueOf(this);
      Log.w("GoogleApiClientConnecting", String.valueOf(str1).length() + 23 + "Unexpected callback in " + str1);
      int i1 = this.h;
      Log.w("GoogleApiClientConnecting", 33 + "mRemainingConnections=" + i1);
      str1 = String.valueOf(b(this.g));
      String str2 = String.valueOf(b(paramInt));
      Log.wtf("GoogleApiClientConnecting", String.valueOf(str1).length() + 70 + String.valueOf(str2).length() + "GoogleApiClient connecting is in step " + str1 + " but received callback for step " + str2, new Exception());
      b(new ConnectionResult(8, null));
      return false;
    }
    return true;
  }
  
  private boolean a(ConnectionResult paramConnectionResult)
  {
    return (this.l) && (!paramConnectionResult.hasResolution());
  }
  
  private static String b(int paramInt)
  {
    switch (paramInt)
    {
    default: 
      return "UNKNOWN";
    case 0: 
      return "STEP_SERVICE_BINDINGS_AND_SIGN_IN";
    }
    return "STEP_GETTING_REMOTE_SERVICE";
  }
  
  private void b()
  {
    if (this.h != 0) {}
    ArrayList localArrayList;
    do
    {
      do
      {
        return;
      } while ((this.m) && (!this.n));
      localArrayList = new ArrayList();
      this.g = 1;
      this.h = this.a.f.size();
      Iterator localIterator = this.a.f.keySet().iterator();
      while (localIterator.hasNext())
      {
        Api.zzc localzzc = (Api.zzc)localIterator.next();
        if (this.a.g.containsKey(localzzc))
        {
          if (a()) {
            c();
          }
        }
        else {
          localArrayList.add((Api.zze)this.a.f.get(localzzc));
        }
      }
    } while (localArrayList.isEmpty());
    this.u.add(zzaaw.zzwv().submit(new c(localArrayList)));
  }
  
  private void b(ConnectionResult paramConnectionResult)
  {
    e();
    if (!paramConnectionResult.hasResolution()) {}
    for (boolean bool = true;; bool = false)
    {
      a(bool);
      this.a.a(paramConnectionResult);
      this.a.n.zzc(paramConnectionResult);
      return;
    }
  }
  
  /* Error */
  private void c()
  {
    // Byte code:
    //   0: aload_0
    //   1: getfield 90	com/google/android/gms/internal/zzaar:a	Lcom/google/android/gms/internal/zzaav;
    //   4: astore_1
    //   5: aload_1
    //   6: getfield 378	com/google/android/gms/internal/zzaav:a	Ljava/util/concurrent/locks/Lock;
    //   9: invokeinterface 383 1 0
    //   14: aload_1
    //   15: getfield 259	com/google/android/gms/internal/zzaav:m	Lcom/google/android/gms/internal/zzaat;
    //   18: invokevirtual 385	com/google/android/gms/internal/zzaat:b	()Z
    //   21: pop
    //   22: aload_1
    //   23: new 387	com/google/android/gms/internal/zzaaq
    //   26: dup
    //   27: aload_1
    //   28: invokespecial 390	com/google/android/gms/internal/zzaaq:<init>	(Lcom/google/android/gms/internal/zzaav;)V
    //   31: putfield 393	com/google/android/gms/internal/zzaav:k	Lcom/google/android/gms/internal/zzaau;
    //   34: aload_1
    //   35: getfield 393	com/google/android/gms/internal/zzaav:k	Lcom/google/android/gms/internal/zzaau;
    //   38: invokeinterface 396 1 0
    //   43: aload_1
    //   44: getfield 399	com/google/android/gms/internal/zzaav:b	Ljava/util/concurrent/locks/Condition;
    //   47: invokeinterface 404 1 0
    //   52: aload_1
    //   53: getfield 378	com/google/android/gms/internal/zzaav:a	Ljava/util/concurrent/locks/Lock;
    //   56: invokeinterface 407 1 0
    //   61: invokestatic 351	com/google/android/gms/internal/zzaaw:zzwv	()Ljava/util/concurrent/ExecutorService;
    //   64: new 8	com/google/android/gms/internal/zzaar$1
    //   67: dup
    //   68: aload_0
    //   69: invokespecial 410	com/google/android/gms/internal/zzaar$1:<init>	(Lcom/google/android/gms/internal/zzaar;)V
    //   72: invokeinterface 414 2 0
    //   77: aload_0
    //   78: getfield 243	com/google/android/gms/internal/zzaar:k	Lcom/google/android/gms/internal/zzbai;
    //   81: ifnull +32 -> 113
    //   84: aload_0
    //   85: getfield 228	com/google/android/gms/internal/zzaar:p	Z
    //   88: ifeq +20 -> 108
    //   91: aload_0
    //   92: getfield 243	com/google/android/gms/internal/zzaar:k	Lcom/google/android/gms/internal/zzbai;
    //   95: aload_0
    //   96: getfield 223	com/google/android/gms/internal/zzaar:o	Lcom/google/android/gms/common/internal/zzr;
    //   99: aload_0
    //   100: getfield 233	com/google/android/gms/internal/zzaar:q	Z
    //   103: invokeinterface 418 3 0
    //   108: aload_0
    //   109: iconst_0
    //   110: invokespecial 364	com/google/android/gms/internal/zzaar:a	(Z)V
    //   113: aload_0
    //   114: getfield 90	com/google/android/gms/internal/zzaar:a	Lcom/google/android/gms/internal/zzaav;
    //   117: getfield 133	com/google/android/gms/internal/zzaav:g	Ljava/util/Map;
    //   120: invokeinterface 308 1 0
    //   125: invokeinterface 314 1 0
    //   130: astore_1
    //   131: aload_1
    //   132: invokeinterface 319 1 0
    //   137: ifeq +49 -> 186
    //   140: aload_1
    //   141: invokeinterface 323 1 0
    //   146: checkcast 325	com/google/android/gms/common/api/Api$zzc
    //   149: astore_2
    //   150: aload_0
    //   151: getfield 90	com/google/android/gms/internal/zzaar:a	Lcom/google/android/gms/internal/zzaav;
    //   154: getfield 301	com/google/android/gms/internal/zzaav:f	Ljava/util/Map;
    //   157: aload_2
    //   158: invokeinterface 337 2 0
    //   163: checkcast 339	com/google/android/gms/common/api/Api$zze
    //   166: invokeinterface 419 1 0
    //   171: goto -40 -> 131
    //   174: astore_2
    //   175: aload_1
    //   176: getfield 378	com/google/android/gms/internal/zzaav:a	Ljava/util/concurrent/locks/Lock;
    //   179: invokeinterface 407 1 0
    //   184: aload_2
    //   185: athrow
    //   186: aload_0
    //   187: getfield 78	com/google/android/gms/internal/zzaar:i	Landroid/os/Bundle;
    //   190: invokevirtual 420	android/os/Bundle:isEmpty	()Z
    //   193: ifeq +19 -> 212
    //   196: aconst_null
    //   197: astore_1
    //   198: aload_0
    //   199: getfield 90	com/google/android/gms/internal/zzaar:a	Lcom/google/android/gms/internal/zzaav;
    //   202: getfield 369	com/google/android/gms/internal/zzaav:n	Lcom/google/android/gms/internal/zzabc$zza;
    //   205: aload_1
    //   206: invokeinterface 424 2 0
    //   211: return
    //   212: aload_0
    //   213: getfield 78	com/google/android/gms/internal/zzaar:i	Landroid/os/Bundle;
    //   216: astore_1
    //   217: goto -19 -> 198
    // Local variable table:
    //   start	length	slot	name	signature
    //   0	220	0	this	zzaar
    //   4	213	1	localObject1	Object
    //   149	9	2	localzzc	Api.zzc
    //   174	11	2	localObject2	Object
    // Exception table:
    //   from	to	target	type
    //   14	52	174	finally
  }
  
  private void d()
  {
    this.m = false;
    this.a.m.d = Collections.emptySet();
    Iterator localIterator = this.j.iterator();
    while (localIterator.hasNext())
    {
      Api.zzc localzzc = (Api.zzc)localIterator.next();
      if (!this.a.g.containsKey(localzzc)) {
        this.a.g.put(localzzc, new ConnectionResult(17, null));
      }
    }
  }
  
  private void e()
  {
    Iterator localIterator = this.u.iterator();
    while (localIterator.hasNext()) {
      ((Future)localIterator.next()).cancel(true);
    }
    this.u.clear();
  }
  
  public void begin()
  {
    this.a.g.clear();
    this.m = false;
    this.e = null;
    this.g = 0;
    this.l = true;
    this.n = false;
    this.p = false;
    HashMap localHashMap = new HashMap();
    Object localObject = this.s.keySet().iterator();
    int i1 = 0;
    if (((Iterator)localObject).hasNext())
    {
      Api localApi = (Api)((Iterator)localObject).next();
      Api.zze localzze = (Api.zze)this.a.f.get(localApi.zzvg());
      int i2;
      label127:
      boolean bool;
      if (localApi.zzve().getPriority() == 1)
      {
        i2 = 1;
        bool = ((Boolean)this.s.get(localApi)).booleanValue();
        if (localzze.zzrd())
        {
          this.m = true;
          if (!bool) {
            break label212;
          }
          this.j.add(localApi.zzvg());
        }
      }
      for (;;)
      {
        localHashMap.put(localzze, new a(this, localApi, bool));
        i1 = i2 | i1;
        break;
        i2 = 0;
        break label127;
        label212:
        this.l = false;
      }
    }
    if (i1 != 0) {
      this.m = false;
    }
    if (this.m)
    {
      this.r.zzc(Integer.valueOf(this.a.m.getSessionId()));
      localObject = new e((byte)0);
      this.k = ((zzbai)this.t.zza(this.c, this.a.m.getLooper(), this.r, this.r.zzxR(), (GoogleApiClient.ConnectionCallbacks)localObject, (GoogleApiClient.OnConnectionFailedListener)localObject));
    }
    this.h = this.a.f.size();
    this.u.add(zzaaw.zzwv().submit(new b(localHashMap)));
  }
  
  public void connect() {}
  
  public boolean disconnect()
  {
    e();
    a(true);
    this.a.a(null);
    return true;
  }
  
  public void onConnected(Bundle paramBundle)
  {
    if (!a(1)) {}
    do
    {
      return;
      if (paramBundle != null) {
        this.i.putAll(paramBundle);
      }
    } while (!a());
    c();
  }
  
  public void onConnectionSuspended(int paramInt)
  {
    b(new ConnectionResult(8, null));
  }
  
  public <A extends Api.zzb, R extends Result, T extends zzaad.zza<R, A>> T zza(T paramT)
  {
    this.a.m.a.add(paramT);
    return paramT;
  }
  
  public void zza(ConnectionResult paramConnectionResult, Api<?> paramApi, boolean paramBoolean)
  {
    if (!a(1)) {}
    do
    {
      return;
      a(paramConnectionResult, paramApi, paramBoolean);
    } while (!a());
    c();
  }
  
  public <A extends Api.zzb, T extends zzaad.zza<? extends Result, A>> T zzb(T paramT)
  {
    throw new IllegalStateException("GoogleApiClient is not connected yet.");
  }
  
  static final class a
    implements zzf.zzf
  {
    private final WeakReference<zzaar> a;
    private final Api<?> b;
    private final boolean c;
    
    public a(zzaar paramzzaar, Api<?> paramApi, boolean paramBoolean)
    {
      this.a = new WeakReference(paramzzaar);
      this.b = paramApi;
      this.c = paramBoolean;
    }
    
    public final void zzg(@NonNull ConnectionResult paramConnectionResult)
    {
      zzaar localzzaar = (zzaar)this.a.get();
      if (localzzaar == null) {
        return;
      }
      boolean bool;
      if (Looper.myLooper() == zzaar.d(localzzaar).m.getLooper()) {
        bool = true;
      }
      for (;;)
      {
        zzac.zza(bool, "onReportServiceBinding must be called on the GoogleApiClient handler thread");
        zzaar.c(localzzaar).lock();
        try
        {
          bool = zzaar.k(localzzaar);
          if (!bool)
          {
            return;
            bool = false;
            continue;
          }
          if (!paramConnectionResult.isSuccess()) {
            zzaar.a(localzzaar, paramConnectionResult, this.b, this.c);
          }
          if (zzaar.l(localzzaar)) {
            zzaar.j(localzzaar);
          }
          return;
        }
        finally
        {
          zzaar.c(localzzaar).unlock();
        }
      }
    }
  }
  
  final class b
    extends zzaar.f
  {
    private final Map<Api.zze, zzaar.a> c;
    
    public b()
    {
      super((byte)0);
      Map localMap;
      this.c = localMap;
    }
    
    @WorkerThread
    public final void a()
    {
      int n = 1;
      int m = 0;
      final Object localObject = this.c.keySet().iterator();
      int j = 1;
      int i = 0;
      Api.zze localzze;
      int k;
      if (((Iterator)localObject).hasNext())
      {
        localzze = (Api.zze)((Iterator)localObject).next();
        if (localzze.zzvh())
        {
          if (zzaar.a.a((zzaar.a)this.c.get(localzze))) {
            break label300;
          }
          i = 1;
          k = n;
        }
      }
      for (;;)
      {
        if (k != 0) {
          m = zzaar.b(zzaar.this).isGooglePlayServicesAvailable(zzaar.a(zzaar.this));
        }
        if ((m != 0) && ((i != 0) || (j != 0)))
        {
          localObject = new ConnectionResult(m, null);
          zzaar.d(zzaar.this).a(new zzaav.a(zzaar.this)
          {
            public final void a()
            {
              zzaar.a(zzaar.this, localObject);
            }
          });
          label155:
          return;
          k = 0;
          j = i;
          i = k;
        }
        for (;;)
        {
          k = j;
          j = i;
          i = k;
          break;
          if (zzaar.e(zzaar.this)) {
            zzaar.f(zzaar.this).connect();
          }
          localObject = this.c.keySet().iterator();
          while (((Iterator)localObject).hasNext())
          {
            localzze = (Api.zze)((Iterator)localObject).next();
            final zzf.zzf localzzf = (zzf.zzf)this.c.get(localzze);
            if ((localzze.zzvh()) && (m != 0)) {
              zzaar.d(zzaar.this).a(new zzaav.a(zzaar.this)
              {
                public final void a()
                {
                  localzzf.zzg(new ConnectionResult(16, null));
                }
              });
            } else {
              localzze.zza(localzzf);
            }
          }
          break label155;
          label300:
          i = j;
          j = 1;
        }
        k = i;
        i = 0;
      }
    }
  }
  
  final class c
    extends zzaar.f
  {
    private final ArrayList<Api.zze> c;
    
    public c()
    {
      super((byte)0);
      ArrayList localArrayList;
      this.c = localArrayList;
    }
    
    @WorkerThread
    public final void a()
    {
      zzaar.d(zzaar.this).m.d = zzaar.g(zzaar.this);
      Iterator localIterator = this.c.iterator();
      while (localIterator.hasNext()) {
        ((Api.zze)localIterator.next()).zza(zzaar.h(zzaar.this), zzaar.d(zzaar.this).m.d);
      }
    }
  }
  
  static final class d
    extends zzbam
  {
    private final WeakReference<zzaar> a;
    
    d(zzaar paramzzaar)
    {
      this.a = new WeakReference(paramzzaar);
    }
    
    @BinderThread
    public final void zzb(final zzbaw paramzzbaw)
    {
      final zzaar localzzaar = (zzaar)this.a.get();
      if (localzzaar == null) {
        return;
      }
      zzaar.d(localzzaar).a(new zzaav.a(localzzaar)
      {
        public final void a()
        {
          zzaar.a(localzzaar, paramzzbaw);
        }
      });
    }
  }
  
  final class e
    implements GoogleApiClient.ConnectionCallbacks, GoogleApiClient.OnConnectionFailedListener
  {
    private e() {}
    
    public final void onConnected(Bundle paramBundle)
    {
      zzaar.f(zzaar.this).zza(new zzaar.d(zzaar.this));
    }
    
    /* Error */
    public final void onConnectionFailed(@NonNull ConnectionResult paramConnectionResult)
    {
      // Byte code:
      //   0: aload_0
      //   1: getfield 17	com/google/android/gms/internal/zzaar$e:a	Lcom/google/android/gms/internal/zzaar;
      //   4: invokestatic 46	com/google/android/gms/internal/zzaar:c	(Lcom/google/android/gms/internal/zzaar;)Ljava/util/concurrent/locks/Lock;
      //   7: invokeinterface 51 1 0
      //   12: aload_0
      //   13: getfield 17	com/google/android/gms/internal/zzaar$e:a	Lcom/google/android/gms/internal/zzaar;
      //   16: aload_1
      //   17: invokestatic 55	com/google/android/gms/internal/zzaar:b	(Lcom/google/android/gms/internal/zzaar;Lcom/google/android/gms/common/ConnectionResult;)Z
      //   20: ifeq +30 -> 50
      //   23: aload_0
      //   24: getfield 17	com/google/android/gms/internal/zzaar$e:a	Lcom/google/android/gms/internal/zzaar;
      //   27: invokestatic 58	com/google/android/gms/internal/zzaar:i	(Lcom/google/android/gms/internal/zzaar;)V
      //   30: aload_0
      //   31: getfield 17	com/google/android/gms/internal/zzaar$e:a	Lcom/google/android/gms/internal/zzaar;
      //   34: invokestatic 61	com/google/android/gms/internal/zzaar:j	(Lcom/google/android/gms/internal/zzaar;)V
      //   37: aload_0
      //   38: getfield 17	com/google/android/gms/internal/zzaar$e:a	Lcom/google/android/gms/internal/zzaar;
      //   41: invokestatic 46	com/google/android/gms/internal/zzaar:c	(Lcom/google/android/gms/internal/zzaar;)Ljava/util/concurrent/locks/Lock;
      //   44: invokeinterface 64 1 0
      //   49: return
      //   50: aload_0
      //   51: getfield 17	com/google/android/gms/internal/zzaar$e:a	Lcom/google/android/gms/internal/zzaar;
      //   54: aload_1
      //   55: invokestatic 67	com/google/android/gms/internal/zzaar:a	(Lcom/google/android/gms/internal/zzaar;Lcom/google/android/gms/common/ConnectionResult;)V
      //   58: goto -21 -> 37
      //   61: astore_1
      //   62: aload_0
      //   63: getfield 17	com/google/android/gms/internal/zzaar$e:a	Lcom/google/android/gms/internal/zzaar;
      //   66: invokestatic 46	com/google/android/gms/internal/zzaar:c	(Lcom/google/android/gms/internal/zzaar;)Ljava/util/concurrent/locks/Lock;
      //   69: invokeinterface 64 1 0
      //   74: aload_1
      //   75: athrow
      // Local variable table:
      //   start	length	slot	name	signature
      //   0	76	0	this	e
      //   0	76	1	paramConnectionResult	ConnectionResult
      // Exception table:
      //   from	to	target	type
      //   12	37	61	finally
      //   50	58	61	finally
    }
    
    public final void onConnectionSuspended(int paramInt) {}
  }
  
  abstract class f
    implements Runnable
  {
    private f() {}
    
    @WorkerThread
    protected abstract void a();
    
    @WorkerThread
    public void run()
    {
      zzaar.c(zzaar.this).lock();
      try
      {
        boolean bool = Thread.interrupted();
        if (bool) {
          return;
        }
        a();
        return;
      }
      catch (RuntimeException localRuntimeException)
      {
        zzaav localzzaav = zzaar.d(zzaar.this);
        Message localMessage = localzzaav.e.obtainMessage(2, localRuntimeException);
        localzzaav.e.sendMessage(localMessage);
        return;
      }
      finally
      {
        zzaar.c(zzaar.this).unlock();
      }
    }
  }
}


/* Location:              /home/merong/decompile/hackery-dex2jar.jar!/com/google/android/gms/internal/zzaar.class
 * Java compiler version: 6 (50.0)
 * JD-Core Version:       0.7.1
 */