JStatefulPool.java

package org.objectweb.jonas_ejb.container;

import java.util.Hashtable;

import org.objectweb.util.monolog.api.BasicLevel;

public class JStatefulPool {

    private Hashtable memoryList = new Hashtable();

    private Hashtable diskList = new Hashtable();

    private int sessionCount = 0;

    public JStatefulPool() {
        TraceEjb.ssfpool.log(BasicLevel.DEBUG, "");
    }

    public synchronized int addContext(JStatefulContext ctx) {

        // sanity check
        if (ctx == null) {
            TraceEjb.logger.log(BasicLevel.ERROR, "null");
        }

        // First get a unique identifier
        int ctxid = sessionCount++;
        TraceEjb.ssfpool.log(BasicLevel.DEBUG, "#" + ctxid);

        // Put in in the memoryList
        memoryList.put(new Integer(ctxid), ctx);

        // return Id
        return ctxid;
    }

    public synchronized JStatefulContext getContext(int ctxid) {
        TraceEjb.ssfpool.log(BasicLevel.DEBUG, "#" + ctxid);

        JStatefulContext ctx = (JStatefulContext) memoryList.get(new Integer(ctxid));
        // TODO

        // sanity check
        if (ctx == null) {
            TraceEjb.logger.log(BasicLevel.ERROR, "null");
        }

        return ctx;
    }

    public synchronized void removeContext(int ctxid) {
        TraceEjb.ssfpool.log(BasicLevel.DEBUG, "#" + ctxid);

        memoryList.remove(new Integer(ctxid));
        TraceEjb.ssfpool.log(BasicLevel.DEBUG, "memoryList size = " + memoryList.size());
    }
}

---