1 files changed, 181 insertions, 0 deletions
diff --git a/mobile/android/thirdparty/ch/boye/httpclientandroidlib/impl/conn/IdleConnectionHandler.java b/mobile/android/thirdparty/ch/boye/httpclientandroidlib/impl/conn/IdleConnectionHandler.java
new file mode 100644
index 000000000..cbcd5d04f
--- /dev/null
+++ b/mobile/android/thirdparty/ch/boye/httpclientandroidlib/impl/conn/IdleConnectionHandler.java
@@ -0,0 +1,181 @@
+/*
+ * ====================================================================
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ * ====================================================================
+ *
+ * This software consists of voluntary contributions made by many
+ * individuals on behalf of the Apache Software Foundation.  For more
+ * information on the Apache Software Foundation, please see
+ * <http://www.apache.org/>.
+ *
+ */
+package ch.boye.httpclientandroidlib.impl.conn;
+
+import java.io.IOException;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Map.Entry;
+import java.util.concurrent.TimeUnit;
+
+import ch.boye.httpclientandroidlib.androidextra.HttpClientAndroidLog;
+/* LogFactory removed by HttpClient for Android script. */
+import ch.boye.httpclientandroidlib.HttpConnection;
+
+// Currently only used by AbstractConnPool
+/**
+ * A helper class for connection managers to track idle connections.
+ *
+ * <p>This class is not synchronized.</p>
+ *
+ * @see ch.boye.httpclientandroidlib.conn.ClientConnectionManager#closeIdleConnections
+ *
+ * @since 4.0
+ *
+ * @deprecated (4.1)  no longer used
+ */
+@Deprecated
+public class IdleConnectionHandler {
+
+    public HttpClientAndroidLog log = new HttpClientAndroidLog(getClass());
+
+    /** Holds connections and the time they were added. */
+    private final Map<HttpConnection,TimeValues> connectionToTimes;
+
+
+    public IdleConnectionHandler() {
+        super();
+        connectionToTimes = new HashMap<HttpConnection,TimeValues>();
+    }
+
+    /**
+     * Registers the given connection with this handler.  The connection will be held until
+     * {@link #remove} or {@link #closeIdleConnections} is called.
+     *
+     * @param connection the connection to add
+     *
+     * @see #remove
+     */
+    public void add(final HttpConnection connection, final long validDuration, final TimeUnit unit) {
+
+        final long timeAdded = System.currentTimeMillis();
+
+        if (log.isDebugEnabled()) {
+            log.debug("Adding connection at: " + timeAdded);
+        }
+
+        connectionToTimes.put(connection, new TimeValues(timeAdded, validDuration, unit));
+    }
+
+    /**
+     * Removes the given connection from the list of connections to be closed when idle.
+     * This will return true if the connection is still valid, and false
+     * if the connection should be considered expired and not used.
+     *
+     * @param connection
+     * @return True if the connection is still valid.
+     */
+    public boolean remove(final HttpConnection connection) {
+        final TimeValues times = connectionToTimes.remove(connection);
+        if(times == null) {
+            log.warn("Removing a connection that never existed!");
+            return true;
+        } else {
+            return System.currentTimeMillis() <= times.timeExpires;
+        }
+    }
+
+    /**
+     * Removes all connections referenced by this handler.
+     */
+    public void removeAll() {
+        this.connectionToTimes.clear();
+    }
+
+    /**
+     * Closes connections that have been idle for at least the given amount of time.
+     *
+     * @param idleTime the minimum idle time, in milliseconds, for connections to be closed
+     */
+    public void closeIdleConnections(final long idleTime) {
+
+        // the latest time for which connections will be closed
+        final long idleTimeout = System.currentTimeMillis() - idleTime;
+
+        if (log.isDebugEnabled()) {
+            log.debug("Checking for connections, idle timeout: "  + idleTimeout);
+        }
+
+        for (final Entry<HttpConnection, TimeValues> entry : connectionToTimes.entrySet()) {
+            final HttpConnection conn = entry.getKey();
+            final TimeValues times = entry.getValue();
+            final long connectionTime = times.timeAdded;
+            if (connectionTime <= idleTimeout) {
+                if (log.isDebugEnabled()) {
+                    log.debug("Closing idle connection, connection time: "  + connectionTime);
+                }
+                try {
+                    conn.close();
+                } catch (final IOException ex) {
+                    log.debug("I/O error closing connection", ex);
+                }
+            }
+        }
+    }
+
+
+    public void closeExpiredConnections() {
+        final long now = System.currentTimeMillis();
+        if (log.isDebugEnabled()) {
+            log.debug("Checking for expired connections, now: "  + now);
+        }
+
+        for (final Entry<HttpConnection, TimeValues> entry : connectionToTimes.entrySet()) {
+            final HttpConnection conn = entry.getKey();
+            final TimeValues times = entry.getValue();
+            if(times.timeExpires <= now) {
+                if (log.isDebugEnabled()) {
+                    log.debug("Closing connection, expired @: "  + times.timeExpires);
+                }
+                try {
+                    conn.close();
+                } catch (final IOException ex) {
+                    log.debug("I/O error closing connection", ex);
+                }
+            }
+        }
+    }
+
+    private static class TimeValues {
+        private final long timeAdded;
+        private final long timeExpires;
+
+        /**
+         * @param now The current time in milliseconds
+         * @param validDuration The duration this connection is valid for
+         * @param validUnit The unit of time the duration is specified in.
+         */
+        TimeValues(final long now, final long validDuration, final TimeUnit validUnit) {
+            this.timeAdded = now;
+            if(validDuration > 0) {
+                this.timeExpires = now + validUnit.toMillis(validDuration);
+            } else {
+                this.timeExpires = Long.MAX_VALUE;
+            }
+        }
+    }
+}