package com.google.common.util.concurrent;

import com.google.common.annotations.Beta;
import com.google.common.base.Function;
import com.google.common.base.MoreObjects;
import com.google.common.base.MoreObjects.ToStringHelper;
import com.google.common.base.Preconditions;
import com.google.common.base.Predicates;
import com.google.common.base.Stopwatch;
import com.google.common.base.Supplier;
import com.google.common.collect.Collections2;
import com.google.common.collect.ImmutableCollection;
import com.google.common.collect.ImmutableList;
import com.google.common.collect.ImmutableMap;
import com.google.common.collect.ImmutableMap.Builder;
import com.google.common.collect.ImmutableMultimap;
import com.google.common.collect.ImmutableSet;
import com.google.common.collect.ImmutableSetMultimap;
import com.google.common.collect.ImmutableSetMultimap.Builder;
import com.google.common.collect.Lists;
import com.google.common.collect.Maps;
import com.google.common.collect.Multimaps;
import com.google.common.collect.Multiset;
import com.google.common.collect.Ordering;
import com.google.common.collect.SetMultimap;
import java.lang.ref.WeakReference;
import java.util.ArrayList;
import java.util.Collections;
import java.util.EnumMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Set;
import java.util.concurrent.Executor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.annotation.concurrent.GuardedBy;
import ro;
import ro.a;

@Beta
public final class ServiceManager
{
  private static final Logger a = Logger.getLogger(ServiceManager.class.getName());
  private static final ro.a<Listener> b = new ro.a("healthy()") {};
  private static final ro.a<Listener> c = new ro.a("stopped()") {};
  private final d d;
  private final ImmutableList<Service> e;
  
  public ServiceManager(Iterable<? extends Service> paramIterable)
  {
    Object localObject = ImmutableList.copyOf(paramIterable);
    paramIterable = (Iterable<? extends Service>)localObject;
    if (((ImmutableList)localObject).isEmpty())
    {
      a.log(Level.WARNING, "ServiceManager configured with no services.  Is your application configured properly?", new a((byte)0));
      paramIterable = ImmutableList.of(new b((byte)0));
    }
    this.d = new d(paramIterable);
    this.e = paramIterable;
    localObject = new WeakReference(this.d);
    paramIterable = paramIterable.iterator();
    if (paramIterable.hasNext())
    {
      Service localService = (Service)paramIterable.next();
      localService.addListener(new c(localService, (WeakReference)localObject), MoreExecutors.directExecutor());
      if (localService.state() == Service.State.NEW) {}
      for (boolean bool = true;; bool = false)
      {
        Preconditions.checkArgument(bool, "Can only manage NEW services, %s", new Object[] { localService });
        break;
      }
    }
    this.d.a();
  }
  
  public final void addListener(Listener paramListener)
  {
    this.d.a(paramListener, MoreExecutors.directExecutor());
  }
  
  public final void addListener(Listener paramListener, Executor paramExecutor)
  {
    this.d.a(paramListener, paramExecutor);
  }
  
  public final void awaitHealthy()
  {
    d locald = this.d;
    locald.a.enterWhenUninterruptibly(locald.h);
    try
    {
      locald.d();
      return;
    }
    finally
    {
      locald.a.leave();
    }
  }
  
  public final void awaitHealthy(long paramLong, TimeUnit paramTimeUnit)
    throws TimeoutException
  {
    d locald = this.d;
    locald.a.enter();
    try
    {
      if (!locald.a.waitForUninterruptibly(locald.h, paramLong, paramTimeUnit))
      {
        paramTimeUnit = String.valueOf(String.valueOf("Timeout waiting for the services to become healthy. The following services have not started: "));
        String str = String.valueOf(String.valueOf(Multimaps.filterKeys(locald.b, Predicates.in(ImmutableSet.of(Service.State.NEW, Service.State.STARTING)))));
        throw new TimeoutException(paramTimeUnit.length() + 0 + str.length() + paramTimeUnit + str);
      }
    }
    finally
    {
      locald.a.leave();
    }
    locald.d();
    locald.a.leave();
  }
  
  public final void awaitStopped()
  {
    d locald = this.d;
    locald.a.enterWhenUninterruptibly(locald.i);
    locald.a.leave();
  }
  
  public final void awaitStopped(long paramLong, TimeUnit paramTimeUnit)
    throws TimeoutException
  {
    d locald = this.d;
    locald.a.enter();
    try
    {
      if (!locald.a.waitForUninterruptibly(locald.i, paramLong, paramTimeUnit))
      {
        paramTimeUnit = String.valueOf(String.valueOf("Timeout waiting for the services to stop. The following services have not stopped: "));
        String str = String.valueOf(String.valueOf(Multimaps.filterKeys(locald.b, Predicates.not(Predicates.in(ImmutableSet.of(Service.State.TERMINATED, Service.State.FAILED))))));
        throw new TimeoutException(paramTimeUnit.length() + 0 + str.length() + paramTimeUnit + str);
      }
    }
    finally
    {
      locald.a.leave();
    }
    locald.a.leave();
  }
  
  public final boolean isHealthy()
  {
    Iterator localIterator = this.e.iterator();
    while (localIterator.hasNext()) {
      if (!((Service)localIterator.next()).isRunning()) {
        return false;
      }
    }
    return true;
  }
  
  public final ImmutableMultimap<Service.State, Service> servicesByState()
  {
    return this.d.b();
  }
  
  /* Error */
  public final ServiceManager startAsync()
  {
    // Byte code:
    //   0: aload_0
    //   1: getfield 111	com/google/common/util/concurrent/ServiceManager:e	Lcom/google/common/collect/ImmutableList;
    //   4: invokevirtual 120	com/google/common/collect/ImmutableList:iterator	()Ljava/util/Iterator;
    //   7: astore_2
    //   8: aload_2
    //   9: invokeinterface 125 1 0
    //   14: ifeq +59 -> 73
    //   17: aload_2
    //   18: invokeinterface 129 1 0
    //   23: checkcast 131	com/google/common/util/concurrent/Service
    //   26: astore_3
    //   27: aload_3
    //   28: invokeinterface 148 1 0
    //   33: astore 4
    //   35: aload 4
    //   37: getstatic 154	com/google/common/util/concurrent/Service$State:NEW	Lcom/google/common/util/concurrent/Service$State;
    //   40: if_acmpne +28 -> 68
    //   43: iconst_1
    //   44: istore_1
    //   45: iload_1
    //   46: ldc_w 281
    //   49: iconst_2
    //   50: anewarray 4	java/lang/Object
    //   53: dup
    //   54: iconst_0
    //   55: aload_3
    //   56: aastore
    //   57: dup
    //   58: iconst_1
    //   59: aload 4
    //   61: aastore
    //   62: invokestatic 284	com/google/common/base/Preconditions:checkState	(ZLjava/lang/String;[Ljava/lang/Object;)V
    //   65: goto -57 -> 8
    //   68: iconst_0
    //   69: istore_1
    //   70: goto -25 -> 45
    //   73: aload_0
    //   74: getfield 111	com/google/common/util/concurrent/ServiceManager:e	Lcom/google/common/collect/ImmutableList;
    //   77: invokevirtual 120	com/google/common/collect/ImmutableList:iterator	()Ljava/util/Iterator;
    //   80: astore_2
    //   81: aload_2
    //   82: invokeinterface 125 1 0
    //   87: ifeq +149 -> 236
    //   90: aload_2
    //   91: invokeinterface 129 1 0
    //   96: checkcast 131	com/google/common/util/concurrent/Service
    //   99: astore_3
    //   100: aload_0
    //   101: getfield 109	com/google/common/util/concurrent/ServiceManager:d	Lcom/google/common/util/concurrent/ServiceManager$d;
    //   104: astore 4
    //   106: aload 4
    //   108: getfield 176	com/google/common/util/concurrent/ServiceManager$d:a	Lcom/google/common/util/concurrent/Monitor;
    //   111: invokevirtual 197	com/google/common/util/concurrent/Monitor:enter	()V
    //   114: aload 4
    //   116: getfield 287	com/google/common/util/concurrent/ServiceManager$d:d	Ljava/util/Map;
    //   119: aload_3
    //   120: invokeinterface 293 2 0
    //   125: checkcast 295	com/google/common/base/Stopwatch
    //   128: ifnonnull +18 -> 146
    //   131: aload 4
    //   133: getfield 287	com/google/common/util/concurrent/ServiceManager$d:d	Ljava/util/Map;
    //   136: aload_3
    //   137: invokestatic 299	com/google/common/base/Stopwatch:createStarted	()Lcom/google/common/base/Stopwatch;
    //   140: invokeinterface 303 3 0
    //   145: pop
    //   146: aload 4
    //   148: getfield 176	com/google/common/util/concurrent/ServiceManager$d:a	Lcom/google/common/util/concurrent/Monitor;
    //   151: invokevirtual 191	com/google/common/util/concurrent/Monitor:leave	()V
    //   154: aload_3
    //   155: invokeinterface 306 1 0
    //   160: pop
    //   161: goto -80 -> 81
    //   164: astore 4
    //   166: getstatic 57	com/google/common/util/concurrent/ServiceManager:a	Ljava/util/logging/Logger;
    //   169: astore 5
    //   171: getstatic 90	java/util/logging/Level:WARNING	Ljava/util/logging/Level;
    //   174: astore 6
    //   176: aload_3
    //   177: invokestatic 209	java/lang/String:valueOf	(Ljava/lang/Object;)Ljava/lang/String;
    //   180: invokestatic 209	java/lang/String:valueOf	(Ljava/lang/Object;)Ljava/lang/String;
    //   183: astore_3
    //   184: aload 5
    //   186: aload 6
    //   188: new 234	java/lang/StringBuilder
    //   191: dup
    //   192: aload_3
    //   193: invokevirtual 238	java/lang/String:length	()I
    //   196: bipush 24
    //   198: iadd
    //   199: invokespecial 241	java/lang/StringBuilder:<init>	(I)V
    //   202: ldc_w 308
    //   205: invokevirtual 245	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
    //   208: aload_3
    //   209: invokevirtual 245	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
    //   212: invokevirtual 248	java/lang/StringBuilder:toString	()Ljava/lang/String;
    //   215: aload 4
    //   217: invokevirtual 99	java/util/logging/Logger:log	(Ljava/util/logging/Level;Ljava/lang/String;Ljava/lang/Throwable;)V
    //   220: goto -139 -> 81
    //   223: astore 5
    //   225: aload 4
    //   227: getfield 176	com/google/common/util/concurrent/ServiceManager$d:a	Lcom/google/common/util/concurrent/Monitor;
    //   230: invokevirtual 191	com/google/common/util/concurrent/Monitor:leave	()V
    //   233: aload 5
    //   235: athrow
    //   236: aload_0
    //   237: areturn
    // Local variable table:
    //   start	length	slot	name	signature
    //   0	238	0	this	ServiceManager
    //   44	26	1	bool	boolean
    //   7	84	2	localIterator	Iterator
    //   26	183	3	localObject1	Object
    //   33	114	4	localObject2	Object
    //   164	62	4	localIllegalStateException	IllegalStateException
    //   169	16	5	localLogger	Logger
    //   223	11	5	localObject3	Object
    //   174	13	6	localLevel	Level
    // Exception table:
    //   from	to	target	type
    //   100	114	164	java/lang/IllegalStateException
    //   146	161	164	java/lang/IllegalStateException
    //   225	236	164	java/lang/IllegalStateException
    //   114	146	223	finally
  }
  
  public final ImmutableMap<Service, Long> startupTimes()
  {
    return this.d.c();
  }
  
  public final ServiceManager stopAsync()
  {
    Iterator localIterator = this.e.iterator();
    while (localIterator.hasNext()) {
      ((Service)localIterator.next()).stopAsync();
    }
    return this;
  }
  
  public final String toString()
  {
    return MoreObjects.toStringHelper(ServiceManager.class).add("services", Collections2.filter(this.e, Predicates.not(Predicates.instanceOf(b.class)))).toString();
  }
  
  @Beta
  public static abstract class Listener
  {
    public void failure(Service paramService) {}
    
    public void healthy() {}
    
    public void stopped() {}
  }
  
  static final class a
    extends Throwable
  {}
  
  static final class b
    extends AbstractService
  {
    protected final void doStart()
    {
      notifyStarted();
    }
    
    protected final void doStop()
    {
      notifyStopped();
    }
  }
  
  static final class c
    extends Service.Listener
  {
    final Service a;
    final WeakReference<ServiceManager.d> b;
    
    c(Service paramService, WeakReference<ServiceManager.d> paramWeakReference)
    {
      this.a = paramService;
      this.b = paramWeakReference;
    }
    
    public final void failed(Service.State paramState, Throwable paramThrowable)
    {
      ServiceManager.d locald = (ServiceManager.d)this.b.get();
      if (locald != null)
      {
        if (!(this.a instanceof ServiceManager.b))
        {
          Logger localLogger = ServiceManager.a();
          Level localLevel = Level.SEVERE;
          String str1 = String.valueOf(String.valueOf(this.a));
          String str2 = String.valueOf(String.valueOf(paramState));
          localLogger.log(localLevel, str1.length() + 34 + str2.length() + "Service " + str1 + " has failed in the " + str2 + " state.", paramThrowable);
        }
        locald.a(this.a, paramState, Service.State.FAILED);
      }
    }
    
    public final void running()
    {
      ServiceManager.d locald = (ServiceManager.d)this.b.get();
      if (locald != null) {
        locald.a(this.a, Service.State.STARTING, Service.State.RUNNING);
      }
    }
    
    public final void starting()
    {
      ServiceManager.d locald = (ServiceManager.d)this.b.get();
      if (locald != null)
      {
        locald.a(this.a, Service.State.NEW, Service.State.STARTING);
        if (!(this.a instanceof ServiceManager.b)) {
          ServiceManager.a().log(Level.FINE, "Starting {0}.", this.a);
        }
      }
    }
    
    public final void stopping(Service.State paramState)
    {
      ServiceManager.d locald = (ServiceManager.d)this.b.get();
      if (locald != null) {
        locald.a(this.a, paramState, Service.State.STOPPING);
      }
    }
    
    public final void terminated(Service.State paramState)
    {
      ServiceManager.d locald = (ServiceManager.d)this.b.get();
      if (locald != null)
      {
        if (!(this.a instanceof ServiceManager.b)) {
          ServiceManager.a().log(Level.FINE, "Service {0} has terminated. Previous state was: {1}", new Object[] { this.a, paramState });
        }
        locald.a(this.a, paramState, Service.State.TERMINATED);
      }
    }
  }
  
  static final class d
  {
    final Monitor a = new Monitor();
    @GuardedBy("monitor")
    final SetMultimap<Service.State, Service> b = Multimaps.newSetMultimap(new EnumMap(Service.State.class), new Supplier() {});
    @GuardedBy("monitor")
    final Multiset<Service.State> c = this.b.keys();
    @GuardedBy("monitor")
    final Map<Service, Stopwatch> d = Maps.newIdentityHashMap();
    @GuardedBy("monitor")
    boolean e;
    @GuardedBy("monitor")
    boolean f;
    final int g;
    final Monitor.Guard h = new Monitor.Guard(this.a)
    {
      public final boolean isSatisfied()
      {
        return (ServiceManager.d.this.c.count(Service.State.RUNNING) == ServiceManager.d.this.g) || (ServiceManager.d.this.c.contains(Service.State.STOPPING)) || (ServiceManager.d.this.c.contains(Service.State.TERMINATED)) || (ServiceManager.d.this.c.contains(Service.State.FAILED));
      }
    };
    final Monitor.Guard i = new Monitor.Guard(this.a)
    {
      public final boolean isSatisfied()
      {
        return ServiceManager.d.this.c.count(Service.State.TERMINATED) + ServiceManager.d.this.c.count(Service.State.FAILED) == ServiceManager.d.this.g;
      }
    };
    @GuardedBy("monitor")
    final List<ro<ServiceManager.Listener>> j = Collections.synchronizedList(new ArrayList());
    
    d(ImmutableCollection<Service> paramImmutableCollection)
    {
      this.g = paramImmutableCollection.size();
      this.b.putAll(Service.State.NEW, paramImmutableCollection);
    }
    
    private void e()
    {
      int k = 0;
      if (!this.a.isOccupiedByCurrentThread()) {}
      for (boolean bool = true;; bool = false)
      {
        Preconditions.checkState(bool, "It is incorrect to execute listeners with the monitor held.");
        while (k < this.j.size())
        {
          ((ro)this.j.get(k)).a();
          k += 1;
        }
      }
    }
    
    final void a()
    {
      this.a.enter();
      Object localObject2;
      try
      {
        if (!this.f)
        {
          this.e = true;
          return;
        }
        ArrayList localArrayList = Lists.newArrayList();
        localObject2 = b().values().iterator();
        while (((Iterator)localObject2).hasNext())
        {
          Service localService = (Service)((Iterator)localObject2).next();
          if (localService.state() != Service.State.NEW) {
            localArrayList.add(localService);
          }
        }
        localObject2 = String.valueOf(String.valueOf("Services started transitioning asynchronously before the ServiceManager was constructed: "));
      }
      finally
      {
        this.a.leave();
      }
      String str = String.valueOf(String.valueOf(localObject1));
      throw new IllegalArgumentException(((String)localObject2).length() + 0 + str.length() + (String)localObject2 + str);
    }
    
    /* Error */
    final void a(final Service paramService, Service.State paramState1, Service.State paramState2)
    {
      // Byte code:
      //   0: iconst_1
      //   1: istore 4
      //   3: aload_1
      //   4: invokestatic 228	com/google/common/base/Preconditions:checkNotNull	(Ljava/lang/Object;)Ljava/lang/Object;
      //   7: pop
      //   8: aload_2
      //   9: aload_3
      //   10: if_acmpeq +43 -> 53
      //   13: iload 4
      //   15: invokestatic 232	com/google/common/base/Preconditions:checkArgument	(Z)V
      //   18: aload_0
      //   19: getfield 51	com/google/common/util/concurrent/ServiceManager$d:a	Lcom/google/common/util/concurrent/Monitor;
      //   22: invokevirtual 149	com/google/common/util/concurrent/Monitor:enter	()V
      //   25: aload_0
      //   26: iconst_1
      //   27: putfield 151	com/google/common/util/concurrent/ServiceManager$d:f	Z
      //   30: aload_0
      //   31: getfield 153	com/google/common/util/concurrent/ServiceManager$d:e	Z
      //   34: istore 4
      //   36: iload 4
      //   38: ifne +21 -> 59
      //   41: aload_0
      //   42: getfield 51	com/google/common/util/concurrent/ServiceManager$d:a	Lcom/google/common/util/concurrent/Monitor;
      //   45: invokevirtual 156	com/google/common/util/concurrent/Monitor:leave	()V
      //   48: aload_0
      //   49: invokespecial 234	com/google/common/util/concurrent/ServiceManager$d:e	()V
      //   52: return
      //   53: iconst_0
      //   54: istore 4
      //   56: goto -43 -> 13
      //   59: aload_0
      //   60: getfield 69	com/google/common/util/concurrent/ServiceManager$d:b	Lcom/google/common/collect/SetMultimap;
      //   63: aload_2
      //   64: aload_1
      //   65: invokeinterface 238 3 0
      //   70: ldc -16
      //   72: iconst_2
      //   73: anewarray 4	java/lang/Object
      //   76: dup
      //   77: iconst_0
      //   78: aload_1
      //   79: aastore
      //   80: dup
      //   81: iconst_1
      //   82: aload_2
      //   83: aastore
      //   84: invokestatic 243	com/google/common/base/Preconditions:checkState	(ZLjava/lang/String;[Ljava/lang/Object;)V
      //   87: aload_0
      //   88: getfield 69	com/google/common/util/concurrent/ServiceManager$d:b	Lcom/google/common/collect/SetMultimap;
      //   91: aload_3
      //   92: aload_1
      //   93: invokeinterface 246 3 0
      //   98: ldc -8
      //   100: iconst_2
      //   101: anewarray 4	java/lang/Object
      //   104: dup
      //   105: iconst_0
      //   106: aload_1
      //   107: aastore
      //   108: dup
      //   109: iconst_1
      //   110: aload_3
      //   111: aastore
      //   112: invokestatic 243	com/google/common/base/Preconditions:checkState	(ZLjava/lang/String;[Ljava/lang/Object;)V
      //   115: aload_0
      //   116: getfield 85	com/google/common/util/concurrent/ServiceManager$d:d	Ljava/util/Map;
      //   119: aload_1
      //   120: invokeinterface 252 2 0
      //   125: checkcast 254	com/google/common/base/Stopwatch
      //   128: astore 5
      //   130: aload 5
      //   132: astore_2
      //   133: aload 5
      //   135: ifnonnull +19 -> 154
      //   138: invokestatic 258	com/google/common/base/Stopwatch:createStarted	()Lcom/google/common/base/Stopwatch;
      //   141: astore_2
      //   142: aload_0
      //   143: getfield 85	com/google/common/util/concurrent/ServiceManager$d:d	Ljava/util/Map;
      //   146: aload_1
      //   147: aload_2
      //   148: invokeinterface 261 3 0
      //   153: pop
      //   154: aload_3
      //   155: getstatic 264	com/google/common/util/concurrent/Service$State:RUNNING	Lcom/google/common/util/concurrent/Service$State;
      //   158: invokevirtual 268	com/google/common/util/concurrent/Service$State:compareTo	(Ljava/lang/Enum;)I
      //   161: iflt +46 -> 207
      //   164: aload_2
      //   165: invokevirtual 271	com/google/common/base/Stopwatch:isRunning	()Z
      //   168: ifeq +39 -> 207
      //   171: aload_2
      //   172: invokevirtual 274	com/google/common/base/Stopwatch:stop	()Lcom/google/common/base/Stopwatch;
      //   175: pop
      //   176: aload_1
      //   177: instanceof 276
      //   180: ifne +27 -> 207
      //   183: invokestatic 279	com/google/common/util/concurrent/ServiceManager:a	()Ljava/util/logging/Logger;
      //   186: getstatic 285	java/util/logging/Level:FINE	Ljava/util/logging/Level;
      //   189: ldc_w 287
      //   192: iconst_2
      //   193: anewarray 4	java/lang/Object
      //   196: dup
      //   197: iconst_0
      //   198: aload_1
      //   199: aastore
      //   200: dup
      //   201: iconst_1
      //   202: aload_2
      //   203: aastore
      //   204: invokevirtual 293	java/util/logging/Logger:log	(Ljava/util/logging/Level;Ljava/lang/String;[Ljava/lang/Object;)V
      //   207: aload_3
      //   208: getstatic 296	com/google/common/util/concurrent/Service$State:FAILED	Lcom/google/common/util/concurrent/Service$State;
      //   211: if_acmpne +60 -> 271
      //   214: aload_1
      //   215: invokestatic 202	java/lang/String:valueOf	(Ljava/lang/Object;)Ljava/lang/String;
      //   218: invokestatic 202	java/lang/String:valueOf	(Ljava/lang/Object;)Ljava/lang/String;
      //   221: astore_2
      //   222: new 17	com/google/common/util/concurrent/ServiceManager$d$5
      //   225: dup
      //   226: aload_0
      //   227: new 206	java/lang/StringBuilder
      //   230: dup
      //   231: aload_2
      //   232: invokevirtual 209	java/lang/String:length	()I
      //   235: bipush 18
      //   237: iadd
      //   238: invokespecial 212	java/lang/StringBuilder:<init>	(I)V
      //   241: ldc_w 298
      //   244: invokevirtual 216	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
      //   247: aload_2
      //   248: invokevirtual 216	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
      //   251: ldc_w 300
      //   254: invokevirtual 216	java/lang/StringBuilder:append	(Ljava/lang/String;)Ljava/lang/StringBuilder;
      //   257: invokevirtual 220	java/lang/StringBuilder:toString	()Ljava/lang/String;
      //   260: aload_1
      //   261: invokespecial 303	com/google/common/util/concurrent/ServiceManager$d$5:<init>	(Lcom/google/common/util/concurrent/ServiceManager$d;Ljava/lang/String;Lcom/google/common/util/concurrent/Service;)V
      //   264: aload_0
      //   265: getfield 104	com/google/common/util/concurrent/ServiceManager$d:j	Ljava/util/List;
      //   268: invokevirtual 306	com/google/common/util/concurrent/ServiceManager$d$5:a	(Ljava/lang/Iterable;)V
      //   271: aload_0
      //   272: getfield 77	com/google/common/util/concurrent/ServiceManager$d:c	Lcom/google/common/collect/Multiset;
      //   275: getstatic 264	com/google/common/util/concurrent/Service$State:RUNNING	Lcom/google/common/util/concurrent/Service$State;
      //   278: invokeinterface 312 2 0
      //   283: aload_0
      //   284: getfield 112	com/google/common/util/concurrent/ServiceManager$d:g	I
      //   287: if_icmpne +25 -> 312
      //   290: invokestatic 315	com/google/common/util/concurrent/ServiceManager:c	()Lro$a;
      //   293: aload_0
      //   294: getfield 104	com/google/common/util/concurrent/ServiceManager$d:j	Ljava/util/List;
      //   297: invokevirtual 318	ro$a:a	(Ljava/lang/Iterable;)V
      //   300: aload_0
      //   301: getfield 51	com/google/common/util/concurrent/ServiceManager$d:a	Lcom/google/common/util/concurrent/Monitor;
      //   304: invokevirtual 156	com/google/common/util/concurrent/Monitor:leave	()V
      //   307: aload_0
      //   308: invokespecial 234	com/google/common/util/concurrent/ServiceManager$d:e	()V
      //   311: return
      //   312: aload_0
      //   313: getfield 77	com/google/common/util/concurrent/ServiceManager$d:c	Lcom/google/common/collect/Multiset;
      //   316: getstatic 321	com/google/common/util/concurrent/Service$State:TERMINATED	Lcom/google/common/util/concurrent/Service$State;
      //   319: invokeinterface 312 2 0
      //   324: aload_0
      //   325: getfield 77	com/google/common/util/concurrent/ServiceManager$d:c	Lcom/google/common/collect/Multiset;
      //   328: getstatic 296	com/google/common/util/concurrent/Service$State:FAILED	Lcom/google/common/util/concurrent/Service$State;
      //   331: invokeinterface 312 2 0
      //   336: iadd
      //   337: aload_0
      //   338: getfield 112	com/google/common/util/concurrent/ServiceManager$d:g	I
      //   341: if_icmpne -41 -> 300
      //   344: invokestatic 323	com/google/common/util/concurrent/ServiceManager:b	()Lro$a;
      //   347: aload_0
      //   348: getfield 104	com/google/common/util/concurrent/ServiceManager$d:j	Ljava/util/List;
      //   351: invokevirtual 318	ro$a:a	(Ljava/lang/Iterable;)V
      //   354: goto -54 -> 300
      //   357: astore_1
      //   358: aload_0
      //   359: getfield 51	com/google/common/util/concurrent/ServiceManager$d:a	Lcom/google/common/util/concurrent/Monitor;
      //   362: invokevirtual 156	com/google/common/util/concurrent/Monitor:leave	()V
      //   365: aload_0
      //   366: invokespecial 234	com/google/common/util/concurrent/ServiceManager$d:e	()V
      //   369: aload_1
      //   370: athrow
      // Local variable table:
      //   start	length	slot	name	signature
      //   0	371	0	this	d
      //   0	371	1	paramService	Service
      //   0	371	2	paramState1	Service.State
      //   0	371	3	paramState2	Service.State
      //   1	54	4	bool	boolean
      //   128	6	5	localStopwatch	Stopwatch
      // Exception table:
      //   from	to	target	type
      //   25	36	357	finally
      //   59	130	357	finally
      //   138	154	357	finally
      //   154	207	357	finally
      //   207	271	357	finally
      //   271	300	357	finally
      //   312	354	357	finally
    }
    
    final void a(ServiceManager.Listener paramListener, Executor paramExecutor)
    {
      Preconditions.checkNotNull(paramListener, "listener");
      Preconditions.checkNotNull(paramExecutor, "executor");
      this.a.enter();
      try
      {
        if (!this.i.isSatisfied()) {
          this.j.add(new ro(paramListener, paramExecutor));
        }
        return;
      }
      finally
      {
        this.a.leave();
      }
    }
    
    final ImmutableMultimap<Service.State, Service> b()
    {
      ImmutableSetMultimap.Builder localBuilder = ImmutableSetMultimap.builder();
      this.a.enter();
      try
      {
        Iterator localIterator = this.b.entries().iterator();
        while (localIterator.hasNext())
        {
          Map.Entry localEntry = (Map.Entry)localIterator.next();
          if (!(localEntry.getValue() instanceof ServiceManager.b)) {
            localBuilder.put(localEntry.getKey(), localEntry.getValue());
          }
        }
      }
      finally
      {
        this.a.leave();
      }
      return ((ImmutableSetMultimap.Builder)localObject).build();
    }
    
    final ImmutableMap<Service, Long> c()
    {
      this.a.enter();
      try
      {
        ArrayList localArrayList = Lists.newArrayListWithCapacity(this.d.size());
        localObject1 = this.d.entrySet().iterator();
        while (((Iterator)localObject1).hasNext())
        {
          Object localObject2 = (Map.Entry)((Iterator)localObject1).next();
          Service localService = (Service)((Map.Entry)localObject2).getKey();
          localObject2 = (Stopwatch)((Map.Entry)localObject2).getValue();
          if ((!((Stopwatch)localObject2).isRunning()) && (!(localService instanceof ServiceManager.b))) {
            localArrayList.add(Maps.immutableEntry(localService, Long.valueOf(((Stopwatch)localObject2).elapsed(TimeUnit.MILLISECONDS))));
          }
        }
      }
      finally
      {
        this.a.leave();
      }
      Collections.sort(localList, Ordering.natural().onResultOf(new Function() {}));
      Object localObject1 = ImmutableMap.builder();
      Iterator localIterator = localList.iterator();
      while (localIterator.hasNext()) {
        ((ImmutableMap.Builder)localObject1).put((Map.Entry)localIterator.next());
      }
      return ((ImmutableMap.Builder)localObject1).build();
    }
    
    @GuardedBy("monitor")
    final void d()
    {
      if (this.c.count(Service.State.RUNNING) != this.g)
      {
        String str = String.valueOf(String.valueOf(Multimaps.filterKeys(this.b, Predicates.not(Predicates.equalTo(Service.State.RUNNING)))));
        throw new IllegalStateException(str.length() + 79 + "Expected to be healthy after starting. The following services are not running: " + str);
      }
    }
  }
}


/* Location:              /home/merong/decompile/hackery-dex2jar.jar!/com/google/common/util/concurrent/ServiceManager.class
 * Java compiler version: 6 (50.0)
 * JD-Core Version:       0.7.1
 */