tn5250j/src/org/tn5250j/framework/common Sessions.java,NONE,1.1 SessionManager.java,NONE,1.1

Update of /cvsroot/tn5250j/tn5250j/src/org/tn5250j/framework/common
In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv30488/src/org/tn5250j/framework/common

Added Files:
	Sessions.java SessionManager.java 
Log Message:
Move a coupe of more classes to framwork package

--- NEW FILE: SessionManager.java ---
/*
 * @(#)SessionManager.java
 * Copyright:    Copyright (c) 2001 - 2004
 *
 * This program 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, or (at your option)
 * any later version.
 *
 * This program 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 this software; see the file COPYING.  If not, write to
 * the Free Software Foundation, Inc., 59 Temple Place, Suite 330,
 * Boston, MA 02111-1307 USA
 *
 */
package org.tn5250j.framework.common;

import java.util.*;

import org.tn5250j.tools.logging.*;
import org.tn5250j.interfaces.SessionManagerInterface;
import org.tn5250j.*;


/**
 * The SessionManager is the central repository for access to all sessions.
 * The SessionManager contains a list of all Session objects available.
 */
public class SessionManager implements SessionManagerInterface, TN5250jConstants {

   static private Sessions sessions;
   static private Vector configs;

   private TN5250jLogger log = TN5250jLogFactory.getLogger (this.getClass());
   /**
    * A handle to the unique SessionManager class
    */
   static private SessionManager _instance;

   /**
    * The constructor is made protected to allow overriding.
    */
   protected SessionManager() {
      if (_instance == null) {
         // initialize the settings information
         initialize();
         // set our instance to this one.
         _instance = this;
      }
   }

   /**
    *
    * @return The unique instance of this class.
    */
   static public SessionManager instance() {

      if (_instance == null) {
         _instance = new SessionManager();
      }
      return _instance;

   }

   private void initialize() {
      log.info("New session Manager initialized");
      sessions = new Sessions();
      configs = new Vector(3);

   }

   public Sessions getSessions() {
      return sessions;
   }

   public void closeSession(String sessionName) {

      SessionGUI session = ((Session5250)sessions.item(sessionName)).getGUI();
      if (session != null)
         closeSession(session);

   }

   public void closeSession(SessionGUI sessionObject) {

      sessionObject.closeDown();
      sessions.removeSession(((SessionGUI)sessionObject).getSession());

   }

   public Session5250 openSession(Properties sesProps, String configurationResource
                                                , String sessionName) {
//                                             throws TN5250jException {

      if(sessionName == null)
         sesProps.put(SESSION_TERM_NAME,sesProps.getProperty(SESSION_HOST));
      else
         sesProps.put(SESSION_TERM_NAME,sessionName);

      if (configurationResource == null)
         configurationResource = "";

      sesProps.put(SESSION_CONFIG_RESOURCE
                        ,configurationResource);

      Enumeration e = configs.elements();
      SessionConfig useConfig = null;

      while(e.hasMoreElements()) {
         SessionConfig conf = (SessionConfig)e.nextElement();
         if (conf.getSessionName().equals(sessionName)) {
            useConfig = conf;
         }
      }

      if (useConfig == null) {

         useConfig = new SessionConfig(configurationResource,sessionName);
         configs.add(useConfig);
      }

      Session5250 newSession = new Session5250(sesProps,configurationResource,
                                          sessionName,useConfig);
      sessions.addSession(newSession);
      return newSession;

   }

   /**
    * Convenience method to add a session that is instatiated outside of
    * SessionManager.  An example would be the ProtocolBean.
    *
    * @param newSession
    */
   public void addSession(Session5250 newSession) {

      sessions.addSession(newSession);
   }
}
--- NEW FILE: Sessions.java ---
/*
 * @(#)Sessions.java
 * Copyright:    Copyright (c) 2001
 *
 * This program 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, or (at your option)
 * any later version.
 *
 * This program 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 this software; see the file COPYING.  If not, write to
 * the Free Software Foundation, Inc., 59 Temple Place, Suite 330,
 * Boston, MA 02111-1307 USA
 *
 */
package org.tn5250j.framework.common;

import java.util.*;
import java.awt.event.*;
import javax.swing.Timer;

import org.tn5250j.Session5250;
import org.tn5250j.tools.logging.*;
import org.tn5250j.interfaces.SessionsInterface;


/**
 * Contains a collection of Session objects. This list is a static snapshot
 * of the list of Session objects available at the time of the snapshot.
 */
public class Sessions implements SessionsInterface,ActionListener {

   private Vector sessions = null;
   private int count = 0;
   private Timer heartBeater;

   private TN5250jLogger  log = TN5250jLogFactory.getLogger (this.getClass());

   public Sessions() {

      sessions = new Vector();
   }

   public void actionPerformed(ActionEvent e) {

      Session5250 ses;
      for (int x = 0; x < sessions.size(); x++) {
         try {
            ses = (Session5250)sessions.get(x);
            if (ses.isConnected() && ses.isSendKeepAlive()) {
               ses.getVT().sendHeartBeat();
               log.info(" sent heartbeat to " +  ses.getSessionName());
            }
         }
         catch (Exception ex) {
            log.warn(ex.getMessage());
         }
      }

   }

   protected void addSession(Session5250 newSession) {
      sessions.add(newSession);
      log.debug("adding Session: "+newSession.getSessionName());
      if (newSession.isSendKeepAlive() && heartBeater == null) {
         heartBeater = new Timer(15000,this);
//         heartBeater = new Timer(3000,this);
         heartBeater.start();

      }
      ++count;
   }

   protected void removeSession(Session5250 session) {
      log.debug("Removing session: "+session.getSessionName());
      if (session != null) {
         if (session.isConnected())
            session.disconnect();
         sessions.remove(session);
         --count;
      }
   }

   protected void removeSession(String sessionName) {
      log.debug("Remove session by name: "+sessionName);
      removeSession((Session5250)item(sessionName));

   }

   protected void removeSession(int index) {
   	  log.debug("Remove session by index: "+index);
//      removeSession((SessionGUI)(((Session5250)item(index)).getGUI()));
      removeSession(item(index));
   }

   public int getCount() {

      return count;
   }

   public Session5250 item (int index) {

      return (Session5250)sessions.get(index);

   }

   public Session5250 item (String sessionName) {

      Session5250 s = null;
      int x = 0;

      while (x < sessions.size()) {

         s = (Session5250)sessions.get(x);

         if (s.getSessionName().equals(sessionName))
            return s;

         x++;
      }

      return null;

   }

   public Session5250 item (Session5250 sessionObject) {

      Session5250 s = null;
      int x = 0;

      while (x < sessions.size()) {

         s = (Session5250)sessions.get(x);

         if (s.equals(sessionObject))
            return s;

         x++;
      }

      return null;

   }

   public Vector getSessionsList() {
      Vector newS = new Vector(sessions.size());
      for (int x = 0; x < sessions.size(); x++)
         newS.add(sessions.get(x));
      return newS;
   }

   public void refresh() {



   }


}


-------------------------------------------------------
This SF.Net email is sponsored by OSTG. Have you noticed the changes on
Linux.com, ITManagersJournal and NewsForge in the past few weeks? Now,
one more big change to announce. We are now OSTG- Open Source Technology
Group. Come see the changes on the new OSTG site. www.ostg.com