package com.google.android.m4b.maps.e;

import android.os.DeadObjectException;
import android.os.Handler;
import android.os.Looper;
import android.os.Message;
import android.os.RemoteException;
import android.util.Log;
import android.util.Pair;
import com.google.android.m4b.maps.g.l;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.concurrent.CountDownLatch;

public final class b
{
  static void a(g paramg)
  {
    if ((paramg instanceof f));
  }

  public static abstract class a
    implements e
  {
    private final Object a = new Object();
    private b.c<R> b;
    private final CountDownLatch c = new CountDownLatch(1);
    private final ArrayList d = new ArrayList();
    private h<R> e;
    private volatile R f;
    private volatile boolean g;
    private boolean h;
    private boolean i;
    private com.google.android.m4b.maps.g.g j;

    private void b(R paramR)
    {
      this.f = paramR;
      this.j = null;
      this.c.countDown();
      Iterator localIterator = this.d.iterator();
      while (localIterator.hasNext())
        localIterator.next();
      this.d.clear();
    }

    private boolean c()
    {
      return this.c.getCount() == 0L;
    }

    protected abstract R a(j paramj);

    public final void a()
    {
      synchronized (this.a)
      {
        if ((this.h) || (this.g))
          return;
        b.a(this.f);
        this.e = null;
        this.h = true;
        b(a(j.c));
        return;
      }
    }

    protected final void a(b.c<R> paramc)
    {
      this.b = paramc;
    }

    public final void a(R paramR)
    {
      boolean bool1 = true;
      while (true)
      {
        synchronized (this.a)
        {
          if ((this.i) || (this.h))
          {
            b.a(paramR);
            return;
          }
          if (!c())
          {
            bool2 = bool1;
            l.a(bool2, "Results have already been set");
            if (this.g)
              break label81;
            l.a(bool1, "Result has already been consumed");
            b(paramR);
            return;
          }
        }
        boolean bool2 = false;
        continue;
        label81: bool1 = false;
      }
    }
  }

  public static abstract class b<R extends g, A extends a.a> extends b.a<R>
    implements d.c<A>
  {
    private final a.c<A> a;
    private d.a b;

    protected b(a.c<A> paramc)
    {
      this.a = ((a.c)l.a(paramc));
    }

    private void a(RemoteException paramRemoteException)
    {
      b(new j(8, paramRemoteException.getLocalizedMessage(), null));
    }

    public final void a(A paramA)
    {
      a(new b.c(paramA.d()));
      try
      {
        b(paramA);
        return;
      }
      catch (DeadObjectException localDeadObjectException)
      {
        a(localDeadObjectException);
        throw localDeadObjectException;
      }
      catch (RemoteException localRemoteException)
      {
        a(localRemoteException);
      }
    }

    public final void a(d.a parama)
    {
      this.b = parama;
    }

    public final a.c<A> b()
    {
      return this.a;
    }

    protected abstract void b(A paramA);

    public final void b(j paramj)
    {
      if (!paramj.d());
      for (boolean bool = true; ; bool = false)
      {
        l.b(bool, "Failed result must not be success");
        a(a(paramj));
        return;
      }
    }
  }

  public static final class c<R extends g> extends Handler
  {
    public c()
    {
      this(Looper.getMainLooper());
    }

    public c(Looper paramLooper)
    {
      super();
    }

    public final void handleMessage(Message paramMessage)
    {
      switch (paramMessage.what)
      {
      default:
        Log.wtf("GoogleApi", "Don't know how to handle this message.");
        return;
      case 1:
        Pair localPair = (Pair)paramMessage.obj;
        ((h)localPair.first);
        ((g)localPair.second);
        return;
      case 2:
      }
      b.a.a((b.a)paramMessage.obj);
    }
  }
}

/* Location:           C:\Documents and Settings\Cesar Cabello Cea\Mis documentos\Downloads\apk-downloader\com.ikea.kompis-6_dex2jar.jar
 * Qualified Name:     com.google.android.m4b.maps.e.b
 * JD-Core Version:    0.6.2
 */