00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024
00025
00026
00027
00028
00029
00030 package org.openmobileis.embedded.webserver;
00031
00032 import org.openmobileis.common.util.ObjectPool;
00033 import org.openmobileis.common.util.log.*;
00034 import org.openmobileis.common.util.exception.ServerException;
00035 import java.net.*;
00036
00044 public class ServerThreadPool extends ObjectPool {
00045
00046 public ServerThreadPool() throws ClassNotFoundException, IllegalAccessException, InstantiationException {
00047 super("org.openmobileis.embedded.webserver.ServerThread", 5, 5);
00048 }
00049
00050 public synchronized void disposeObject(Object object) {
00051
00052 super.disposeObject(object);
00053 }
00054
00055 public void runServerConnexion(WebServer webserver, Socket socket) {
00056 ServerThread thread = (ServerThread) super.getObject();
00057 if (thread == null) {
00058 LogManager.traceEmergency(LogServices.SYNCHROSERVICE, "Object pool error ServerThread from pool NULL. Create one. System must be repared.");
00059 thread = new ServerThread();
00060 }
00061
00062 try {
00063
00064 thread.init(webserver, socket, this);
00065 } catch (Exception ex) {
00066 LogManager.trace(new ServerException("Error during threadPool init", ex));
00067 LogManager.traceError(0, ex);
00068 }
00069 }
00070
00071 public void freeResources() throws Exception {
00072 for (int i = 0; i < super.arrayPool.size(); i++) {
00073 ServerThread thread = (ServerThread)super.arrayPool.get(i);
00074 thread.notifyStop();
00075 }
00076 }
00077 }
00078