package com.google.android.gms.internal;

import android.app.PendingIntent;
import android.content.Context;
import android.os.Handler;
import android.os.Looper;
import android.support.annotation.NonNull;
import android.support.annotation.Nullable;
import android.support.v4.util.ArrayMap;
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.zze;
import com.google.android.gms.common.api.Result;
import com.google.android.gms.common.api.Status;
import com.google.android.gms.common.api.zzb;
import com.google.android.gms.common.internal.zzg;
import com.google.android.gms.common.zze;
import com.google.android.gms.tasks.OnCompleteListener;
import com.google.android.gms.tasks.Task;
import java.io.FileDescriptor;
import java.io.PrintWriter;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
import java.util.HashMap;
import java.util.Iterator;
import java.util.LinkedList;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Queue;
import java.util.Set;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;

public class zzaak
  implements zzabc
{
  private final Map<Api.zzc<?>, zzaaj<?>> a = new HashMap();
  private final Map<Api.zzc<?>, zzaaj<?>> b = new HashMap();
  private final Map<Api<?>, Boolean> c;
  private final zzaax d;
  private final zzaat e;
  private final Lock f;
  private final Looper g;
  private final zze h;
  private final Condition i;
  private final zzg j;
  private final boolean k;
  private final boolean l;
  private final Queue<zzaad.zza<?, ?>> m = new LinkedList();
  private boolean n;
  private Map<zzzz<?>, ConnectionResult> o;
  private Map<zzzz<?>, ConnectionResult> p;
  private b q;
  private ConnectionResult r;
  
  public zzaak(Context paramContext, Lock paramLock, Looper paramLooper, zze paramzze, Map<Api.zzc<?>, Api.zze> paramMap, zzg paramzzg, Map<Api<?>, Boolean> paramMap1, Api.zza<? extends zzbai, zzbaj> paramzza, ArrayList<zzaag> paramArrayList, zzaat paramzzaat, boolean paramBoolean)
  {
    this.f = paramLock;
    this.g = paramLooper;
    this.i = paramLock.newCondition();
    this.h = paramzze;
    this.e = paramzzaat;
    this.c = paramMap1;
    this.j = paramzzg;
    this.k = paramBoolean;
    paramLock = new HashMap();
    paramzze = paramMap1.keySet().iterator();
    while (paramzze.hasNext())
    {
      paramMap1 = (Api)paramzze.next();
      paramLock.put(paramMap1.zzvg(), paramMap1);
    }
    paramzze = new HashMap();
    paramMap1 = paramArrayList.iterator();
    while (paramMap1.hasNext())
    {
      paramArrayList = (zzaag)paramMap1.next();
      paramzze.put(paramArrayList.zzaxf, paramArrayList);
    }
    int i1 = 0;
    int i2 = 1;
    int i3 = 0;
    paramMap = paramMap.entrySet().iterator();
    if (paramMap.hasNext())
    {
      paramMap1 = (Map.Entry)paramMap.next();
      paramzzaat = (Api)paramLock.get(paramMap1.getKey());
      paramArrayList = (Api.zze)paramMap1.getValue();
      if (paramArrayList.zzvh())
      {
        if (((Boolean)this.c.get(paramzzaat)).booleanValue()) {
          break label475;
        }
        i1 = 1;
        i3 = 1;
      }
    }
    for (;;)
    {
      paramzzaat = new zzaaj(paramContext, paramzzaat, paramLooper, paramArrayList, (zzaag)paramzze.get(paramzzaat), paramzzg, paramzza);
      this.a.put((Api.zzc)paramMap1.getKey(), paramzzaat);
      if (paramArrayList.zzrd()) {
        this.b.put((Api.zzc)paramMap1.getKey(), paramzzaat);
      }
      int i4 = i3;
      i3 = i1;
      i1 = i4;
      break;
      i2 = i3;
      i4 = 0;
      i3 = i1;
      i1 = i2;
      i2 = i4;
      continue;
      if ((i3 != 0) && (i2 == 0) && (i1 == 0)) {}
      for (paramBoolean = true;; paramBoolean = false)
      {
        this.l = paramBoolean;
        this.d = zzaax.zzww();
        return;
      }
      label475:
      i4 = 1;
      i3 = i1;
      i1 = i4;
    }
  }
  
  @Nullable
  private ConnectionResult a(@NonNull Api.zzc<?> paramzzc)
  {
    this.f.lock();
    try
    {
      paramzzc = (zzaaj)this.a.get(paramzzc);
      if ((this.o != null) && (paramzzc != null))
      {
        paramzzc = (ConnectionResult)this.o.get(paramzzc.getApiKey());
        return paramzzc;
      }
      return null;
    }
    finally
    {
      this.f.unlock();
    }
  }
  
  private <T extends zzaad.zza<? extends Result, ? extends Api.zzb>> boolean a(@NonNull T paramT)
  {
    Object localObject1 = paramT.zzvg();
    Object localObject2 = a((Api.zzc)localObject1);
    if ((localObject2 != null) && (((ConnectionResult)localObject2).getErrorCode() == 4))
    {
      localObject2 = this.d;
      localObject1 = ((zzaaj)this.a.get(localObject1)).getApiKey();
      int i1 = this.e.getSessionId();
      if ((zzaax.zza)((zzaax)localObject2).d.get(localObject1) == null) {
        localObject1 = null;
      }
      for (;;)
      {
        paramT.zzB(new Status(4, null, (PendingIntent)localObject1));
        return true;
        localObject1 = (zzaax.zza)((zzaax)localObject2).d.get(localObject1);
        if (((zzaax.zza)localObject1).a == null) {}
        for (localObject1 = null;; localObject1 = ((zzaax.zza)localObject1).a.zzwO())
        {
          if (localObject1 != null) {
            break label136;
          }
          localObject1 = null;
          break;
        }
        label136:
        localObject1 = PendingIntent.getActivity(((zzaax)localObject2).b, i1, ((zzbai)localObject1).zzrs(), 134217728);
      }
    }
    return false;
  }
  
  public ConnectionResult blockingConnect()
  {
    connect();
    while (isConnecting()) {
      try
      {
        this.i.await();
      }
      catch (InterruptedException localInterruptedException)
      {
        Thread.currentThread().interrupt();
        return new ConnectionResult(15, null);
      }
    }
    if (isConnected()) {
      return ConnectionResult.zzayj;
    }
    if (this.r != null) {
      return this.r;
    }
    return new ConnectionResult(13, null);
  }
  
  public ConnectionResult blockingConnect(long paramLong, TimeUnit paramTimeUnit)
  {
    connect();
    for (paramLong = paramTimeUnit.toNanos(paramLong); isConnecting(); paramLong = this.i.awaitNanos(paramLong))
    {
      if (paramLong <= 0L) {}
      try
      {
        disconnect();
        return new ConnectionResult(14, null);
      }
      catch (InterruptedException paramTimeUnit)
      {
        Thread.currentThread().interrupt();
        return new ConnectionResult(15, null);
      }
    }
    if (isConnected()) {
      return ConnectionResult.zzayj;
    }
    if (this.r != null) {
      return this.r;
    }
    return new ConnectionResult(13, null);
  }
  
  public void connect()
  {
    this.f.lock();
    try
    {
      boolean bool = this.n;
      if (bool) {
        return;
      }
      this.n = true;
      this.o = null;
      this.p = null;
      this.q = null;
      this.r = null;
      this.d.zzvx();
      this.d.zza(this.a.values()).addOnCompleteListener(new zzadb(this.g), new a((byte)0));
      return;
    }
    finally
    {
      this.f.unlock();
    }
  }
  
  public void disconnect()
  {
    this.f.lock();
    try
    {
      this.n = false;
      this.o = null;
      this.p = null;
      if (this.q != null)
      {
        this.q.a();
        this.q = null;
      }
      this.r = null;
      while (!this.m.isEmpty())
      {
        zzaad.zza localzza = (zzaad.zza)this.m.remove();
        localzza.zza(null);
        localzza.cancel();
      }
      this.i.signalAll();
    }
    finally
    {
      this.f.unlock();
    }
    this.f.unlock();
  }
  
  public void dump(String paramString, FileDescriptor paramFileDescriptor, PrintWriter paramPrintWriter, String[] paramArrayOfString) {}
  
  @Nullable
  public ConnectionResult getConnectionResult(@NonNull Api<?> paramApi)
  {
    return a(paramApi.zzvg());
  }
  
  /* Error */
  public boolean isConnected()
  {
    // Byte code:
    //   0: aload_0
    //   1: getfield 63	com/google/android/gms/internal/zzaak:f	Ljava/util/concurrent/locks/Lock;
    //   4: invokeinterface 178 1 0
    //   9: aload_0
    //   10: getfield 180	com/google/android/gms/internal/zzaak:o	Ljava/util/Map;
    //   13: ifnull +25 -> 38
    //   16: aload_0
    //   17: getfield 195	com/google/android/gms/internal/zzaak:r	Lcom/google/android/gms/common/ConnectionResult;
    //   20: astore_2
    //   21: aload_2
    //   22: ifnonnull +16 -> 38
    //   25: iconst_1
    //   26: istore_1
    //   27: aload_0
    //   28: getfield 63	com/google/android/gms/internal/zzaak:f	Ljava/util/concurrent/locks/Lock;
    //   31: invokeinterface 189 1 0
    //   36: iload_1
    //   37: ireturn
    //   38: iconst_0
    //   39: istore_1
    //   40: goto -13 -> 27
    //   43: astore_2
    //   44: aload_0
    //   45: getfield 63	com/google/android/gms/internal/zzaak:f	Ljava/util/concurrent/locks/Lock;
    //   48: invokeinterface 189 1 0
    //   53: aload_2
    //   54: athrow
    // Local variable table:
    //   start	length	slot	name	signature
    //   0	55	0	this	zzaak
    //   26	14	1	bool	boolean
    //   20	2	2	localConnectionResult	ConnectionResult
    //   43	11	2	localObject	Object
    // Exception table:
    //   from	to	target	type
    //   9	21	43	finally
  }
  
  /* Error */
  public boolean isConnecting()
  {
    // Byte code:
    //   0: aload_0
    //   1: getfield 63	com/google/android/gms/internal/zzaak:f	Ljava/util/concurrent/locks/Lock;
    //   4: invokeinterface 178 1 0
    //   9: aload_0
    //   10: getfield 180	com/google/android/gms/internal/zzaak:o	Ljava/util/Map;
    //   13: ifnonnull +25 -> 38
    //   16: aload_0
    //   17: getfield 277	com/google/android/gms/internal/zzaak:n	Z
    //   20: istore_1
    //   21: iload_1
    //   22: ifeq +16 -> 38
    //   25: iconst_1
    //   26: istore_1
    //   27: aload_0
    //   28: getfield 63	com/google/android/gms/internal/zzaak:f	Ljava/util/concurrent/locks/Lock;
    //   31: invokeinterface 189 1 0
    //   36: iload_1
    //   37: ireturn
    //   38: iconst_0
    //   39: istore_1
    //   40: goto -13 -> 27
    //   43: astore_2
    //   44: aload_0
    //   45: getfield 63	com/google/android/gms/internal/zzaak:f	Ljava/util/concurrent/locks/Lock;
    //   48: invokeinterface 189 1 0
    //   53: aload_2
    //   54: athrow
    // Local variable table:
    //   start	length	slot	name	signature
    //   0	55	0	this	zzaak
    //   20	20	1	bool	boolean
    //   43	11	2	localObject	Object
    // Exception table:
    //   from	to	target	type
    //   9	21	43	finally
  }
  
  public <A extends Api.zzb, R extends Result, T extends zzaad.zza<R, A>> T zza(@NonNull T paramT)
  {
    if ((this.k) && (a(paramT))) {
      return paramT;
    }
    if (!isConnected())
    {
      this.m.add(paramT);
      return paramT;
    }
    this.e.i.a(paramT);
    return ((zzaaj)this.a.get(paramT.zzvg())).doRead(paramT);
  }
  
  public boolean zza(zzabq paramzzabq)
  {
    this.f.lock();
    try
    {
      if ((this.n) && (!zzvN()))
      {
        this.d.zzvx();
        this.q = new b(paramzzabq);
        this.d.zza(this.b.values()).addOnCompleteListener(new zzadb(this.g), this.q);
        return true;
      }
      return false;
    }
    finally
    {
      this.f.unlock();
    }
  }
  
  public <A extends Api.zzb, T extends zzaad.zza<? extends Result, A>> T zzb(@NonNull T paramT)
  {
    Api.zzc localzzc = paramT.zzvg();
    if ((this.k) && (a(paramT))) {
      return paramT;
    }
    this.e.i.a(paramT);
    return ((zzaaj)this.a.get(localzzc)).doWrite(paramT);
  }
  
  public void zzvM() {}
  
  public boolean zzvN()
  {
    this.f.lock();
    try
    {
      boolean bool;
      if (this.n)
      {
        bool = this.k;
        if (bool) {}
      }
      else
      {
        return false;
      }
      Iterator localIterator = this.b.keySet().iterator();
      while (localIterator.hasNext())
      {
        ConnectionResult localConnectionResult = a((Api.zzc)localIterator.next());
        if (localConnectionResult != null)
        {
          bool = localConnectionResult.isSuccess();
          if (bool) {
            break;
          }
        }
        else
        {
          return false;
        }
      }
      return true;
    }
    finally
    {
      this.f.unlock();
    }
  }
  
  public void zzvn()
  {
    this.f.lock();
    try
    {
      Object localObject1 = this.d;
      ((zzaax)localObject1).c.incrementAndGet();
      ((zzaax)localObject1).g.sendMessage(((zzaax)localObject1).g.obtainMessage(10));
      if (this.q != null)
      {
        this.q.a();
        this.q = null;
      }
      if (this.p == null) {
        this.p = new ArrayMap(this.b.size());
      }
      localObject1 = new ConnectionResult(4);
      Iterator localIterator = this.b.values().iterator();
      while (localIterator.hasNext())
      {
        zzaaj localzzaaj = (zzaaj)localIterator.next();
        this.p.put(localzzaaj.getApiKey(), localObject1);
      }
      if (this.o == null) {
        break label178;
      }
    }
    finally
    {
      this.f.unlock();
    }
    this.o.putAll(this.p);
    label178:
    this.f.unlock();
  }
  
  final class a
    implements OnCompleteListener<Void>
  {
    private a() {}
    
    public final void onComplete(@NonNull Task<Void> paramTask)
    {
      zzaak.a(zzaak.this).lock();
      Object localObject;
      try
      {
        boolean bool = zzaak.b(zzaak.this);
        if (!bool) {
          return;
        }
        if (paramTask.isSuccessful())
        {
          zzaak.a(zzaak.this, new ArrayMap(zzaak.c(zzaak.this).size()));
          paramTask = zzaak.c(zzaak.this).values().iterator();
          while (paramTask.hasNext())
          {
            localObject = (zzaaj)paramTask.next();
            zzaak.d(zzaak.this).put(((zzaaj)localObject).getApiKey(), ConnectionResult.zzayj);
          }
        }
        if (!(paramTask.getException() instanceof zzb)) {
          break label435;
        }
      }
      finally
      {
        zzaak.a(zzaak.this).unlock();
      }
      paramTask = (zzb)paramTask.getException();
      if (zzaak.e(zzaak.this))
      {
        zzaak.a(zzaak.this, new ArrayMap(zzaak.c(zzaak.this).size()));
        localObject = zzaak.c(zzaak.this).values().iterator();
        while (((Iterator)localObject).hasNext())
        {
          zzaaj localzzaaj = (zzaaj)((Iterator)localObject).next();
          zzzz localzzzz = localzzaaj.getApiKey();
          ConnectionResult localConnectionResult = paramTask.zza(localzzaaj);
          if (zzaak.a(zzaak.this, localzzaaj, localConnectionResult)) {
            zzaak.d(zzaak.this).put(localzzzz, new ConnectionResult(16));
          } else {
            zzaak.d(zzaak.this).put(localzzzz, localConnectionResult);
          }
        }
      }
      zzaak.a(zzaak.this, paramTask.zzvj());
      zzaak.a(zzaak.this, zzaak.f(zzaak.this));
      if (zzaak.g(zzaak.this) != null)
      {
        zzaak.d(zzaak.this).putAll(zzaak.g(zzaak.this));
        zzaak.a(zzaak.this, zzaak.f(zzaak.this));
      }
      if (zzaak.h(zzaak.this) == null)
      {
        zzaak.i(zzaak.this);
        zzaak.j(zzaak.this);
      }
      for (;;)
      {
        zzaak.m(zzaak.this).signalAll();
        zzaak.a(zzaak.this).unlock();
        return;
        label435:
        Log.e("ConnectionlessGAC", "Unexpected availability exception", paramTask.getException());
        zzaak.a(zzaak.this, Collections.emptyMap());
        zzaak.a(zzaak.this, new ConnectionResult(8));
        break;
        zzaak.k(zzaak.this);
        zzaak.l(zzaak.this).zzc(zzaak.h(zzaak.this));
      }
    }
  }
  
  final class b
    implements OnCompleteListener<Void>
  {
    private zzabq b;
    
    b(zzabq paramzzabq)
    {
      this.b = paramzzabq;
    }
    
    final void a()
    {
      this.b.zzrq();
    }
    
    public final void onComplete(@NonNull Task<Void> paramTask)
    {
      zzaak.a(zzaak.this).lock();
      Object localObject;
      try
      {
        if (!zzaak.b(zzaak.this))
        {
          this.b.zzrq();
          return;
        }
        if (paramTask.isSuccessful())
        {
          zzaak.b(zzaak.this, new ArrayMap(zzaak.n(zzaak.this).size()));
          paramTask = zzaak.n(zzaak.this).values().iterator();
          while (paramTask.hasNext())
          {
            localObject = (zzaaj)paramTask.next();
            zzaak.g(zzaak.this).put(((zzaaj)localObject).getApiKey(), ConnectionResult.zzayj);
          }
        }
        if (!(paramTask.getException() instanceof zzb)) {
          break label417;
        }
      }
      finally
      {
        zzaak.a(zzaak.this).unlock();
      }
      paramTask = (zzb)paramTask.getException();
      if (zzaak.e(zzaak.this))
      {
        zzaak.b(zzaak.this, new ArrayMap(zzaak.n(zzaak.this).size()));
        localObject = zzaak.n(zzaak.this).values().iterator();
        while (((Iterator)localObject).hasNext())
        {
          zzaaj localzzaaj = (zzaaj)((Iterator)localObject).next();
          zzzz localzzzz = localzzaaj.getApiKey();
          ConnectionResult localConnectionResult = paramTask.zza(localzzaaj);
          if (zzaak.a(zzaak.this, localzzaaj, localConnectionResult)) {
            zzaak.g(zzaak.this).put(localzzzz, new ConnectionResult(16));
          } else {
            zzaak.g(zzaak.this).put(localzzzz, localConnectionResult);
          }
        }
      }
      zzaak.b(zzaak.this, paramTask.zzvj());
      for (;;)
      {
        if (zzaak.this.isConnected())
        {
          zzaak.d(zzaak.this).putAll(zzaak.g(zzaak.this));
          if (zzaak.f(zzaak.this) == null)
          {
            zzaak.i(zzaak.this);
            zzaak.j(zzaak.this);
            zzaak.m(zzaak.this).signalAll();
          }
        }
        this.b.zzrq();
        zzaak.a(zzaak.this).unlock();
        return;
        label417:
        Log.e("ConnectionlessGAC", "Unexpected availability exception", paramTask.getException());
        zzaak.b(zzaak.this, Collections.emptyMap());
      }
    }
  }
}


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