/*
 * Created on Aug 3, 2004
 *
 * To change the template for this generated file go to
 * Window - Preferences - Java - Code Generation - Code and Comments
 */
package de.laures.cewolf.storage;

import java.util.Calendar;
import java.util.Collection;
import java.util.Date;
import java.util.GregorianCalendar;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;

/**
 * @author brianf
 * 
 * To change the template for this generated type comment go to Window -
 * Preferences - Java - Code Generation - Code and Comments
 */
public class SessionStorageGroup implements Runnable
{
  private Map map = new HashMap();
  Thread      runner;

  private void start()
  {
    if ( runner == null || !runner.isAlive() )
    {
      runner = new Thread(this);
      runner.setDaemon(false);
      runner.setName("SessionCleanup");
      runner.setPriority(Thread.MIN_PRIORITY);
      runner.start();
    }
  }

  public synchronized Object get( Object a )
  {
    return map.get(a);
  }

  public synchronized Object put( Object a, Object b )
  {
    Object c = map.put(a, b);
    start();
    return c;
  }

  public synchronized Object remove( Object a )
  {
    return map.remove(a);
  }
  /*
   * (non-Javadoc)
   * 
   * @see java.lang.Runnable#run()
   */
  public void run()
  {
    while ( !map.isEmpty() )
    {
      Date date = new Date();
      synchronized (this)
      {
        Collection keys = map.keySet();

        Iterator iter = keys.iterator();

        while ( iter.hasNext() )
        {
          // System.out.println("Get Next");
          String cid = (String) iter.next();
          SessionStorageItem ssi = (SessionStorageItem) get(cid);
          if ( ssi.isExpired(date) )
          {
           // System.out.println("Removing " + ssi);
            iter.remove();
          }
        }
      }
      try
      {
        //System.gc();
        Thread.sleep(1000);
      }
      catch (InterruptedException e)
      {
        // TODO Auto-generated catch block
        e.printStackTrace();
      }
    }
   // System.out.println("Exiting Thread");   
  }
  public static void main( String[] args )
  {
    int start = 0;
   while(true)
    {
      System.out.println("Adding Objects");
    testThread(start);
    
    try
    {
      Thread.sleep(10000);
    }
    catch (InterruptedException e)
    {
      // TODO Auto-generated catch block
      e.printStackTrace();
    }
    }
  }

  public static void testThread(int start)
  {
    SessionStorageGroup ssg = new SessionStorageGroup();
    Calendar cal = new GregorianCalendar();
    cal.setTime(new Date());
    //   some huge garbage string
  
    for (int i = start; i < start+10000; i++)
    {
      cal.add(Calendar.MILLISECOND, 1);
      SessionStorageItem ssi = new SessionStorageItem(null, Integer.toString(i), cal.getTime());
      ssg.put(Integer.toString(i), ssi);
    }


  }
  /**
   * Test that memory is freed up when low on it...
   */
  public static void testSoftreferenceMemoryFreeup()
  {
    Date neverexpire = new Date(10000, 1, 1);
    SessionStorageGroup ssg = new SessionStorageGroup();

    //   some huge garbage string
    StringBuffer longString = new StringBuffer();
    for (int i = 0; i < 10000; i++)
    {
      longString.append(Math.random());
    }

    int i = 0;
    long minmem = Long.MAX_VALUE;
    while ( true )
    {
      //   let's use the id string to waste memory
      String key = Long.toString(System.currentTimeMillis());
      String id = key + longString;
      SessionStorageItem ssi = new SessionStorageItem(null, id, neverexpire);
      ssg.put(key, ssi);

      i++;
      long freemem = Runtime.getRuntime().freeMemory();
      long usedmem = Runtime.getRuntime().totalMemory();
      long maxmem = Runtime.getRuntime().maxMemory();
      if ( freemem < minmem )
      {
        minmem = freemem;
      }
      if ( i % 100 == 0 )
      {
        System.out.println("#" + i + ", minimum memory:" + minmem + ", freemem:" + freemem
            + ", usedmem:" + usedmem + ", maxmem:" + maxmem);
      }
    }

  }
}