public class org.apache.http.impl.conn.tsccm.ConnPoolByRoute extends org.apache.http.impl.conn.tsccm.AbstractConnPool { private final org.apache.commons.logging.Log log; private final java.util.concurrent.locks.Lock poolLock; protected final org.apache.http.conn.ClientConnectionOperator operator; protected final org.apache.http.conn.params.ConnPerRoute connPerRoute; protected final java.util.Set leasedConnections; protected final java.util.Queue freeConnections; protected final java.util.Queue waitingThreads; protected final java.util.Map routeToPool; private final long connTTL; private final java.util.concurrent.TimeUnit connTTLTimeUnit; protected volatile boolean shutdown; protected volatile int maxTotalConnections; protected volatile int numConnections; public void (org.apache.http.conn.ClientConnectionOperator, org.apache.http.conn.params.ConnPerRoute, int) { java.util.concurrent.TimeUnit v; int v; org.apache.http.conn.ClientConnectionOperator v; org.apache.http.impl.conn.tsccm.ConnPoolByRoute v; org.apache.http.conn.params.ConnPerRoute v; v := @this: org.apache.http.impl.conn.tsccm.ConnPoolByRoute; v := @parameter: org.apache.http.conn.ClientConnectionOperator; v := @parameter: org.apache.http.conn.params.ConnPerRoute; v := @parameter: int; v = ; specialinvoke v.(org.apache.http.conn.ClientConnectionOperator,org.apache.http.conn.params.ConnPerRoute,int,long,java.util.concurrent.TimeUnit)>(v, v, v, -1L, v); return; } public void (org.apache.http.conn.ClientConnectionOperator, org.apache.http.conn.params.ConnPerRoute, int, long, java.util.concurrent.TimeUnit) { java.util.Set v; long v; java.util.concurrent.TimeUnit v; java.util.concurrent.locks.Lock v; java.util.Map v; int v; org.apache.http.conn.ClientConnectionOperator v; org.apache.http.impl.conn.tsccm.ConnPoolByRoute v; java.lang.Class v; org.apache.commons.logging.Log v; java.util.Queue v, v; org.apache.http.conn.params.ConnPerRoute v; v := @this: org.apache.http.impl.conn.tsccm.ConnPoolByRoute; v := @parameter: org.apache.http.conn.ClientConnectionOperator; v := @parameter: org.apache.http.conn.params.ConnPerRoute; v := @parameter: int; v := @parameter: long; v := @parameter: java.util.concurrent.TimeUnit; specialinvoke v.()>(); v = virtualinvoke v.(); v = staticinvoke (v); v. = v; staticinvoke (v, "Connection operator"); staticinvoke (v, "Connections per route"); v = v.; v. = v; v = v.; v. = v; v. = v; v. = v; v. = v; v = virtualinvoke v.(); v. = v; v = virtualinvoke v.(); v. = v; v = virtualinvoke v.(); v. = v; v. = v; v. = v; return; } protected java.util.concurrent.locks.Lock getLock() { org.apache.http.impl.conn.tsccm.ConnPoolByRoute v; java.util.concurrent.locks.Lock v; v := @this: org.apache.http.impl.conn.tsccm.ConnPoolByRoute; v = v.; return v; } public void (org.apache.http.conn.ClientConnectionOperator, org.apache.http.params.HttpParams) { org.apache.http.params.HttpParams v; int v; org.apache.http.conn.ClientConnectionOperator v; org.apache.http.impl.conn.tsccm.ConnPoolByRoute v; org.apache.http.conn.params.ConnPerRoute v; v := @this: org.apache.http.impl.conn.tsccm.ConnPoolByRoute; v := @parameter: org.apache.http.conn.ClientConnectionOperator; v := @parameter: org.apache.http.params.HttpParams; v = staticinvoke (v); v = staticinvoke (v); specialinvoke v.(org.apache.http.conn.ClientConnectionOperator,org.apache.http.conn.params.ConnPerRoute,int)>(v, v, v); return; } protected java.util.Queue createFreeConnQueue() { org.apache.http.impl.conn.tsccm.ConnPoolByRoute v; java.util.LinkedList v; v := @this: org.apache.http.impl.conn.tsccm.ConnPoolByRoute; v = new java.util.LinkedList; specialinvoke v.()>(); return v; } protected java.util.Queue createWaitingThreadQueue() { org.apache.http.impl.conn.tsccm.ConnPoolByRoute v; java.util.LinkedList v; v := @this: org.apache.http.impl.conn.tsccm.ConnPoolByRoute; v = new java.util.LinkedList; specialinvoke v.()>(); return v; } protected java.util.Map createRouteToPoolMap() { org.apache.http.impl.conn.tsccm.ConnPoolByRoute v; java.util.HashMap v; v := @this: org.apache.http.impl.conn.tsccm.ConnPoolByRoute; v = new java.util.HashMap; specialinvoke v.()>(); return v; } protected org.apache.http.impl.conn.tsccm.RouteSpecificPool newRouteSpecificPool(org.apache.http.conn.routing.HttpRoute) { org.apache.http.impl.conn.tsccm.ConnPoolByRoute v; org.apache.http.conn.params.ConnPerRoute v; org.apache.http.conn.routing.HttpRoute v; org.apache.http.impl.conn.tsccm.RouteSpecificPool v; v := @this: org.apache.http.impl.conn.tsccm.ConnPoolByRoute; v := @parameter: org.apache.http.conn.routing.HttpRoute; v = new org.apache.http.impl.conn.tsccm.RouteSpecificPool; v = v.; specialinvoke v.(org.apache.http.conn.routing.HttpRoute,org.apache.http.conn.params.ConnPerRoute)>(v, v); return v; } protected org.apache.http.impl.conn.tsccm.WaitingThread newWaitingThread(java.util.concurrent.locks.Condition, org.apache.http.impl.conn.tsccm.RouteSpecificPool) { java.util.concurrent.locks.Condition v; org.apache.http.impl.conn.tsccm.ConnPoolByRoute v; org.apache.http.impl.conn.tsccm.WaitingThread v; org.apache.http.impl.conn.tsccm.RouteSpecificPool v; v := @this: org.apache.http.impl.conn.tsccm.ConnPoolByRoute; v := @parameter: java.util.concurrent.locks.Condition; v := @parameter: org.apache.http.impl.conn.tsccm.RouteSpecificPool; v = new org.apache.http.impl.conn.tsccm.WaitingThread; specialinvoke v.(java.util.concurrent.locks.Condition,org.apache.http.impl.conn.tsccm.RouteSpecificPool)>(v, v); return v; } private void closeConnection(org.apache.http.impl.conn.tsccm.BasicPoolEntry) { org.apache.http.conn.OperatedClientConnection v; org.apache.http.impl.conn.tsccm.ConnPoolByRoute v; org.apache.http.impl.conn.tsccm.BasicPoolEntry v; v := @this: org.apache.http.impl.conn.tsccm.ConnPoolByRoute; v := @parameter: org.apache.http.impl.conn.tsccm.BasicPoolEntry; virtualinvoke v.(); return; } protected org.apache.http.impl.conn.tsccm.RouteSpecificPool getRoutePool(org.apache.http.conn.routing.HttpRoute, boolean) { java.lang.Throwable v; org.apache.http.conn.routing.HttpRoute v; java.util.concurrent.locks.Lock v, v, v; java.util.Map v, v; org.apache.http.impl.conn.tsccm.ConnPoolByRoute v; java.lang.Object v; boolean v; v := @this: org.apache.http.impl.conn.tsccm.ConnPoolByRoute; v := @parameter: org.apache.http.conn.routing.HttpRoute; v := @parameter: boolean; v = v.; interfaceinvoke v.(); label: v = v.; v = interfaceinvoke v.(v); if v != null goto label; if v == 0 goto label; v = virtualinvoke v.(v); v = v.; interfaceinvoke v.(v, v); label: v = v.; interfaceinvoke v.(); goto label; label: v := @caughtexception; v = v.; interfaceinvoke v.(); throw v; label: return v; catch java.lang.Throwable from label to label with label; } public int getConnectionsInPool(org.apache.http.conn.routing.HttpRoute) { java.lang.Throwable v; org.apache.http.conn.routing.HttpRoute v; org.apache.http.impl.conn.tsccm.RouteSpecificPool v; java.util.concurrent.locks.Lock v, v, v; int v; org.apache.http.impl.conn.tsccm.ConnPoolByRoute v; v := @this: org.apache.http.impl.conn.tsccm.ConnPoolByRoute; v := @parameter: org.apache.http.conn.routing.HttpRoute; v = v.; interfaceinvoke v.(); label: v = virtualinvoke v.(v, 0); if v == null goto label; v = virtualinvoke v.(); goto label; label: v = 0; label: v = v.; interfaceinvoke v.(); return v; label: v := @caughtexception; v = v.; interfaceinvoke v.(); throw v; catch java.lang.Throwable from label to label with label; } public int getConnectionsInPool() { java.lang.Throwable v; java.util.concurrent.locks.Lock v, v, v; int v; org.apache.http.impl.conn.tsccm.ConnPoolByRoute v; v := @this: org.apache.http.impl.conn.tsccm.ConnPoolByRoute; v = v.; interfaceinvoke v.(); label: v = v.; label: v = v.; interfaceinvoke v.(); return v; label: v := @caughtexception; v = v.; interfaceinvoke v.(); throw v; catch java.lang.Throwable from label to label with label; } public org.apache.http.impl.conn.tsccm.PoolEntryRequest requestPoolEntry(org.apache.http.conn.routing.HttpRoute, java.lang.Object) { org.apache.http.impl.conn.tsccm.ConnPoolByRoute$1 v; org.apache.http.impl.conn.tsccm.ConnPoolByRoute v; java.lang.Object v; org.apache.http.impl.conn.tsccm.WaitingThreadAborter v; org.apache.http.conn.routing.HttpRoute v; v := @this: org.apache.http.impl.conn.tsccm.ConnPoolByRoute; v := @parameter: org.apache.http.conn.routing.HttpRoute; v := @parameter: java.lang.Object; v = new org.apache.http.impl.conn.tsccm.WaitingThreadAborter; specialinvoke v.()>(); v = new org.apache.http.impl.conn.tsccm.ConnPoolByRoute$1; specialinvoke v.(org.apache.http.impl.conn.tsccm.ConnPoolByRoute,org.apache.http.impl.conn.tsccm.WaitingThreadAborter,org.apache.http.conn.routing.HttpRoute,java.lang.Object)>(v, v, v, v); return v; } protected org.apache.http.impl.conn.tsccm.BasicPoolEntry getEntryBlocking(org.apache.http.conn.routing.HttpRoute, java.lang.Object, long, java.util.concurrent.TimeUnit, org.apache.http.impl.conn.tsccm.WaitingThreadAborter) throws org.apache.http.conn.ConnectionPoolTimeoutException, java.lang.InterruptedException { java.util.Date v, v; byte v, v; org.apache.http.impl.conn.tsccm.WaitingThread v; boolean v, v, v, v, v, v, v, v, v; java.util.Set v; org.apache.http.impl.conn.tsccm.ConnPoolByRoute v; java.util.Queue v, v, v, v, v; java.lang.Throwable v, v; long v, v, v, v, v, v; org.apache.http.conn.routing.HttpRoute v; org.apache.http.impl.conn.tsccm.RouteSpecificPool v; org.apache.http.impl.conn.tsccm.BasicPoolEntry v; int v, v, v, v, v, v, v, v, v; org.apache.http.conn.ClientConnectionOperator v, v; org.apache.http.impl.conn.tsccm.WaitingThreadAborter v; java.lang.String v, v, v; org.apache.http.conn.ConnectionPoolTimeoutException v; java.util.concurrent.TimeUnit v; java.util.concurrent.locks.Condition v; java.util.concurrent.locks.Lock v, v, v, v; java.lang.Object v; org.apache.commons.logging.Log v, v, v, v, v, v; v := @this: org.apache.http.impl.conn.tsccm.ConnPoolByRoute; v := @parameter: org.apache.http.conn.routing.HttpRoute; v := @parameter: java.lang.Object; v := @parameter: long; v := @parameter: java.util.concurrent.TimeUnit; v := @parameter: org.apache.http.impl.conn.tsccm.WaitingThreadAborter; v = null; v = v cmp 0L; if v <= 0 goto label; v = new java.util.Date; v = staticinvoke (); v = virtualinvoke v.(v); v = v + v; specialinvoke v.(long)>(v); v = v; label: v = null; v = v.; interfaceinvoke v.(); label: v = virtualinvoke v.(v, 1); v = null; label: if v != null goto label; v = v.; if v != 0 goto label; v = 1; goto label; label: v = 0; label: staticinvoke (v, "Connection pool shut down"); v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = v.; v = interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(); v = v.; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v, v) ("[\u] total kept alive: \u, total issued: \u, total allocated: \u out of \u0001"); interfaceinvoke v.(v); label: v = virtualinvoke v.(v, v); if v != null goto label; v = virtualinvoke v.(); if v <= 0 goto label; v = 1; goto label; label: v = 0; label: v = v; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v) ("Available capacity: \u out of \u [\u][\u]"); interfaceinvoke v.(v); label: if v == 0 goto label; v = v.; v = v.; if v >= v goto label; v = v.; v = virtualinvoke v.(v, v); goto label; label: if v == 0 goto label; v = v.; v = interfaceinvoke v.(); if v != 0 goto label; virtualinvoke v.(); v = virtualinvoke v.(v, 1); v = v.; v = virtualinvoke v.(v, v); goto label; label: v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Need to wait for connection [\u][\u]"); interfaceinvoke v.(v); label: if v != null goto label; v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(v, v); virtualinvoke v.(v); label: virtualinvoke v.(v); v = v.; interfaceinvoke v.(v); v = virtualinvoke v.(v); label: virtualinvoke v.(v); v = v.; interfaceinvoke v.(v); goto label; label: v := @caughtexception; virtualinvoke v.(v); v = v.; interfaceinvoke v.(v); throw v; label: if v != 0 goto label; if v == null goto label; v = virtualinvoke v.(); v = staticinvoke (); v = v cmp v; if v > 0 goto label; v = new org.apache.http.conn.ConnectionPoolTimeoutException; specialinvoke v.(java.lang.String)>("Timeout waiting for connection from pool"); throw v; label: v = v.; interfaceinvoke v.(); goto label; label: v := @caughtexception; v = v.; interfaceinvoke v.(); throw v; label: return v; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void freeEntry(org.apache.http.impl.conn.tsccm.BasicPoolEntry, boolean, long, java.util.concurrent.TimeUnit) { java.lang.Throwable v; long v; org.apache.http.conn.routing.HttpRoute v; org.apache.http.impl.conn.tsccm.RouteSpecificPool v; byte v; org.apache.http.impl.conn.tsccm.BasicPoolEntry v; int v, v, v; java.lang.String v, v, v; boolean v, v, v, v; java.util.Set v; java.util.concurrent.TimeUnit v; java.util.concurrent.locks.Lock v, v, v, v; org.apache.http.impl.conn.tsccm.ConnPoolByRoute v; java.lang.Object v, v; org.apache.commons.logging.Log v, v, v, v; java.util.Queue v; v := @this: org.apache.http.impl.conn.tsccm.ConnPoolByRoute; v := @parameter: org.apache.http.impl.conn.tsccm.BasicPoolEntry; v := @parameter: boolean; v := @parameter: long; v := @parameter: java.util.concurrent.TimeUnit; v = virtualinvoke v.(); v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Releasing connection [\u][\u]"); interfaceinvoke v.(v); label: v = v.; interfaceinvoke v.(); label: v = v.; if v == 0 goto label; specialinvoke v.(v); label: v = v.; interfaceinvoke v.(); return; label: v = v.; interfaceinvoke v.(v); v = virtualinvoke v.(v, 1); if v == 0 goto label; v = virtualinvoke v.(); if v < 0 goto label; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v cmp 0L; if v <= 0 goto label; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("for \u \u0001"); goto label; label: v = "indefinitely"; label: v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("Pooling connection [\u][\u]; keep alive \u0001"); interfaceinvoke v.(v); label: virtualinvoke v.(v); virtualinvoke v.(v, v); v = v.; interfaceinvoke v.(v); goto label; label: specialinvoke v.(v); virtualinvoke v.(); v = v.; v = v - 1; v. = v; label: virtualinvoke v.(v); label: v = v.; interfaceinvoke v.(); goto label; label: v := @caughtexception; v = v.; interfaceinvoke v.(); throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } protected org.apache.http.impl.conn.tsccm.BasicPoolEntry getFreeEntry(org.apache.http.impl.conn.tsccm.RouteSpecificPool, java.lang.Object) { java.lang.Throwable v; long v; org.apache.http.conn.routing.HttpRoute v, v, v; org.apache.http.impl.conn.tsccm.RouteSpecificPool v; org.apache.http.impl.conn.tsccm.BasicPoolEntry v; int v, v; java.lang.String v, v, v; boolean v, v, v, v, v; java.util.Set v; java.util.concurrent.locks.Lock v, v, v; org.apache.http.impl.conn.tsccm.ConnPoolByRoute v; java.lang.Object v; org.apache.commons.logging.Log v, v, v, v, v, v; java.util.Queue v; v := @this: org.apache.http.impl.conn.tsccm.ConnPoolByRoute; v := @parameter: org.apache.http.impl.conn.tsccm.RouteSpecificPool; v := @parameter: java.lang.Object; v = null; v = v.; interfaceinvoke v.(); label: v = 0; label: if v != 0 goto label; v = virtualinvoke v.(v); if v == null goto label; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Getting free connection [\u][\u]"); interfaceinvoke v.(v); label: v = v.; interfaceinvoke v.(v); v = staticinvoke (); v = virtualinvoke v.(v); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Closing expired free connection [\u][\u]"); interfaceinvoke v.(v); label: specialinvoke v.(v); virtualinvoke v.(); v = v.; v = v - 1; v. = v; goto label; label: v = v.; interfaceinvoke v.(v); v = 1; goto label; label: v = 1; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("No free connections [\u][\u]"); interfaceinvoke v.(v); goto label; label: v = v.; interfaceinvoke v.(); goto label; label: v := @caughtexception; v = v.; interfaceinvoke v.(); throw v; label: return v; catch java.lang.Throwable from label to label with label; } protected org.apache.http.impl.conn.tsccm.BasicPoolEntry createEntry(org.apache.http.impl.conn.tsccm.RouteSpecificPool, org.apache.http.conn.ClientConnectionOperator) { java.lang.Throwable v; long v; org.apache.http.conn.routing.HttpRoute v, v; org.apache.http.impl.conn.tsccm.RouteSpecificPool v; org.apache.http.impl.conn.tsccm.BasicPoolEntry v; int v, v; org.apache.http.conn.ClientConnectionOperator v; java.lang.String v; boolean v; java.util.Set v; java.util.concurrent.TimeUnit v; java.util.concurrent.locks.Lock v, v, v; org.apache.http.impl.conn.tsccm.ConnPoolByRoute v; org.apache.commons.logging.Log v, v; v := @this: org.apache.http.impl.conn.tsccm.ConnPoolByRoute; v := @parameter: org.apache.http.impl.conn.tsccm.RouteSpecificPool; v := @parameter: org.apache.http.conn.ClientConnectionOperator; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Creating new connection [\u]"); interfaceinvoke v.(v); label: v = new org.apache.http.impl.conn.tsccm.BasicPoolEntry; v = virtualinvoke v.(); v = v.; v = v.; specialinvoke v.(org.apache.http.conn.ClientConnectionOperator,org.apache.http.conn.routing.HttpRoute,long,java.util.concurrent.TimeUnit)>(v, v, v, v); v = v.; interfaceinvoke v.(); label: virtualinvoke v.(v); v = v.; v = v + 1; v. = v; v = v.; interfaceinvoke v.(v); label: v = v.; interfaceinvoke v.(); goto label; label: v := @caughtexception; v = v.; interfaceinvoke v.(); throw v; label: return v; catch java.lang.Throwable from label to label with label; } protected void deleteEntry(org.apache.http.impl.conn.tsccm.BasicPoolEntry) { java.lang.Throwable v; org.apache.http.conn.routing.HttpRoute v; org.apache.http.impl.conn.tsccm.RouteSpecificPool v; org.apache.http.impl.conn.tsccm.BasicPoolEntry v; java.util.Map v; int v, v; java.lang.String v; boolean v, v; java.util.concurrent.locks.Lock v, v, v; org.apache.http.impl.conn.tsccm.ConnPoolByRoute v; java.lang.Object v; org.apache.commons.logging.Log v, v; v := @this: org.apache.http.impl.conn.tsccm.ConnPoolByRoute; v := @parameter: org.apache.http.impl.conn.tsccm.BasicPoolEntry; v = virtualinvoke v.(); v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Deleting connection [\u][\u]"); interfaceinvoke v.(v); label: v = v.; interfaceinvoke v.(); label: specialinvoke v.(v); v = virtualinvoke v.(v, 1); virtualinvoke v.(v); v = v.; v = v - 1; v. = v; v = virtualinvoke v.(); if v == 0 goto label; v = v.; interfaceinvoke v.(v); label: v = v.; interfaceinvoke v.(); goto label; label: v := @caughtexception; v = v.; interfaceinvoke v.(); throw v; label: return; catch java.lang.Throwable from label to label with label; } protected void deleteLeastUsedEntry() { java.lang.Throwable v; java.util.concurrent.locks.Lock v, v, v; org.apache.http.impl.conn.tsccm.ConnPoolByRoute v; java.lang.Object v; org.apache.commons.logging.Log v, v; java.util.Queue v; boolean v; v := @this: org.apache.http.impl.conn.tsccm.ConnPoolByRoute; v = v.; interfaceinvoke v.(); label: v = v.; v = interfaceinvoke v.(); if v == null goto label; virtualinvoke v.(v); goto label; label: v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; interfaceinvoke v.("No free connection to delete"); label: v = v.; interfaceinvoke v.(); goto label; label: v := @caughtexception; v = v.; interfaceinvoke v.(); throw v; label: return; catch java.lang.Throwable from label to label with label; } protected void handleLostEntry(org.apache.http.conn.routing.HttpRoute) { java.lang.Throwable v; org.apache.http.conn.routing.HttpRoute v; org.apache.http.impl.conn.tsccm.RouteSpecificPool v; java.util.concurrent.locks.Lock v, v, v; java.util.Map v; int v, v; org.apache.http.impl.conn.tsccm.ConnPoolByRoute v; boolean v; v := @this: org.apache.http.impl.conn.tsccm.ConnPoolByRoute; v := @parameter: org.apache.http.conn.routing.HttpRoute; v = v.; interfaceinvoke v.(); label: v = virtualinvoke v.(v, 1); virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = v.; interfaceinvoke v.(v); label: v = v.; v = v - 1; v. = v; virtualinvoke v.(v); label: v = v.; interfaceinvoke v.(); goto label; label: v := @caughtexception; v = v.; interfaceinvoke v.(); throw v; label: return; catch java.lang.Throwable from label to label with label; } protected void notifyWaitingThread(org.apache.http.impl.conn.tsccm.RouteSpecificPool) { java.lang.Throwable v; org.apache.http.conn.routing.HttpRoute v; org.apache.http.impl.conn.tsccm.RouteSpecificPool v; java.lang.String v; boolean v, v, v, v, v; java.util.concurrent.locks.Lock v, v, v; org.apache.http.impl.conn.tsccm.ConnPoolByRoute v; java.lang.Object v; org.apache.commons.logging.Log v, v, v, v, v, v; java.util.Queue v, v; v := @this: org.apache.http.impl.conn.tsccm.ConnPoolByRoute; v := @parameter: org.apache.http.impl.conn.tsccm.RouteSpecificPool; v = v.; interfaceinvoke v.(); label: if v == null goto label; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Notifying thread waiting on pool [\u]"); interfaceinvoke v.(v); label: virtualinvoke v.(); goto label; label: v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; interfaceinvoke v.("Notifying thread waiting on any pool"); label: v = v.; v = interfaceinvoke v.(); goto label; label: v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; interfaceinvoke v.("Notifying no-one, there are no waiting threads"); label: if v == null goto label; virtualinvoke v.(); label: v = v.; interfaceinvoke v.(); goto label; label: v := @caughtexception; v = v.; interfaceinvoke v.(); throw v; label: return; catch java.lang.Throwable from label to label with label; } public void deleteClosedConnections() { java.lang.Throwable v; java.util.Iterator v; org.apache.http.conn.OperatedClientConnection v; java.util.concurrent.locks.Lock v, v, v; org.apache.http.impl.conn.tsccm.ConnPoolByRoute v; java.lang.Object v; java.util.Queue v; boolean v, v; v := @this: org.apache.http.impl.conn.tsccm.ConnPoolByRoute; v = v.; interfaceinvoke v.(); label: v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); if v != 0 goto label; interfaceinvoke v.(); virtualinvoke v.(v); goto label; label: v = v.; interfaceinvoke v.(); goto label; label: v := @caughtexception; v = v.; interfaceinvoke v.(); throw v; label: return; catch java.lang.Throwable from label to label with label; } public void closeIdleConnections(long, java.util.concurrent.TimeUnit) { java.lang.Throwable v; java.util.Date v; long v, v, v, v, v, v, v, v; byte v, v; java.lang.String v, v; boolean v, v, v; java.util.Iterator v; java.util.concurrent.TimeUnit v; java.util.concurrent.locks.Lock v, v, v; org.apache.http.impl.conn.tsccm.ConnPoolByRoute v; java.lang.Object v; org.apache.commons.logging.Log v, v, v, v; java.util.Queue v; v := @this: org.apache.http.impl.conn.tsccm.ConnPoolByRoute; v := @parameter: long; v := @parameter: java.util.concurrent.TimeUnit; staticinvoke (v, "Time unit"); v = v cmp 0L; if v <= 0 goto label; v = v; goto label; label: v = 0L; label: v = v; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Closing connections idle longer than \u \u0001"); interfaceinvoke v.(v); label: v = staticinvoke (); v = virtualinvoke v.(v); v = v - v; v = v.; interfaceinvoke v.(); label: v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = v cmp v; if v > 0 goto label; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = new java.util.Date; v = virtualinvoke v.(); specialinvoke v.(long)>(v); v = dynamicinvoke "makeConcatWithConstants" (v) ("Closing connection last used @ \u0001"); interfaceinvoke v.(v); label: interfaceinvoke v.(); virtualinvoke v.(v); goto label; label: v = v.; interfaceinvoke v.(); goto label; label: v := @caughtexception; v = v.; interfaceinvoke v.(); throw v; label: return; catch java.lang.Throwable from label to label with label; } public void closeExpiredConnections() { java.lang.Throwable v; java.util.Date v; long v, v; java.lang.String v; boolean v, v, v; java.util.Iterator v; java.util.concurrent.locks.Lock v, v, v; org.apache.http.impl.conn.tsccm.ConnPoolByRoute v; java.lang.Object v; org.apache.commons.logging.Log v, v, v; java.util.Queue v; v := @this: org.apache.http.impl.conn.tsccm.ConnPoolByRoute; v = v.; interfaceinvoke v.("Closing expired connections"); v = staticinvoke (); v = v.; interfaceinvoke v.(); label: v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = new java.util.Date; v = virtualinvoke v.(); specialinvoke v.(long)>(v); v = dynamicinvoke "makeConcatWithConstants" (v) ("Closing connection expired @ \u0001"); interfaceinvoke v.(v); label: interfaceinvoke v.(); virtualinvoke v.(v); goto label; label: v = v.; interfaceinvoke v.(); goto label; label: v := @caughtexception; v = v.; interfaceinvoke v.(); throw v; label: return; catch java.lang.Throwable from label to label with label; } public void shutdown() { java.lang.Throwable v; org.apache.http.conn.routing.HttpRoute v; java.util.Map v; java.lang.String v; boolean v, v, v, v, v; java.util.Iterator v, v, v; java.util.Set v; java.util.concurrent.locks.Lock v, v, v, v; org.apache.http.impl.conn.tsccm.ConnPoolByRoute v; java.lang.Object v, v, v, v; org.apache.commons.logging.Log v, v; java.util.Queue v, v; v := @this: org.apache.http.impl.conn.tsccm.ConnPoolByRoute; v = v.; interfaceinvoke v.(); label: v = v.; if v == 0 goto label; label: v = v.; interfaceinvoke v.(); return; label: v. = 1; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); interfaceinvoke v.(); specialinvoke v.(v); goto label; label: v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v)