threadping.java

SOCK VIA HTTP是通过HTTP建立通道的SOCK

/*
This file is part of Socks via HTTP.

This package is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation; either version 2 of the License, or
(at your option) any later version.

Socks via HTTP is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
GNU General Public License for more details.

You should have received a copy of the GNU General Public License
along with Socks via HTTP; if not, write to the Free Software
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
*/

// Title :        ThreadPing.java
// Version :      0.40
// Copyright :    Copyright (c) 2001
// Author :       Florent CUETO ([e-mail])
// Description :  Check if a server connection is still used

package socks4;

import java.util.*;

public class ThreadPing extends Thread
{
  //public static final int CONNECTION_TIMEOUT = 180000; // 3mn
  public static final int DELAY = 5000; // 5sec

  public ThreadPing()
  {
    super();
  }

  public void run()
  {
    boolean state = true;

    while (state == true)
    {
      // Scan the open connections
      Vector closeForTimeout = new Vector();
      Vector closeForAutorizedTime = new Vector();
      if (ServletSocks.table != null)
      {
        for (Enumeration e = ServletSocks.table.keys(); e.hasMoreElements(); )
        {
          String key = (String)e.nextElement();
          ExtendedConnection extConn = ServletSocks.table.get(key);
          if ((extConn != null) && (extConn.serverTimeout > 0))
          {
            if ((new java.util.Date().getTime() - extConn.lastAccessDate) > extConn.serverTimeout)
            {
              closeForTimeout.add(key);
            }
            else
            {
              if (extConn.autorizedTime > 0)
              {
                if ((new java.util.Date().getTime() - extConn.creationDate) > 1000 * extConn.autorizedTime)
                {
                  closeForAutorizedTime.add(key);
                }
              }
            }
          }
        }
      }

      // Close the unused connections
      for (int i = 0; i < closeForTimeout.size(); i++)
      {
        String key = (String)closeForTimeout.elementAt(i);
        ExtendedConnection extConn = ServletSocks.table.get(key);
        if (extConn != null)
        {
          Log.printLog("Closed connection " + key + " : Timeout reached...");
          extConn.conn.disconnect();
          ServletSocks.table.remove(key);
        }
      }

      // Close the connections whose autorized time is over
      for (int i = 0; i < closeForAutorizedTime.size(); i++)
      {
        String key = (String)closeForAutorizedTime.elementAt(i);
        ExtendedConnection extConn = ServletSocks.table.get(key);
        if (extConn != null)
        {
          Log.printLog("Closed connection " + key + " : Autorized time reached...");
          extConn.conn.disconnect();
          ServletSocks.table.remove(key);
        }
      }

      try
      {
        // Sleep
        Thread.sleep(DELAY);
      }
      catch (Exception e){}
    }
  }
}