Index: src/java/com/sun/enterprise/iiop/POARemoteReferenceFactory.java =================================================================== RCS file: /cvs/glassfish/appserv-core/src/java/com/sun/enterprise/iiop/POARemoteReferenceFactory.java,v retrieving revision 1.17.6.2 diff -c -r1.17.6.2 POARemoteReferenceFactory.java *** src/java/com/sun/enterprise/iiop/POARemoteReferenceFactory.java 28 Aug 2008 04:12:07 -0000 1.17.6.2 --- src/java/com/sun/enterprise/iiop/POARemoteReferenceFactory.java 6 Jan 2009 05:17:54 -0000 *************** *** 281,287 **** IASEjbExtraDescriptors extraDesc = ejbDescriptor.getIASEjbExtraDescriptors(); String threadPoolName = extraDesc.getUseThreadPoolId(); ! int threadPoolNumericID = 0; boolean usePassByReference = extraDesc.getPassByReference(); if (usePassByReference) { --- 281,287 ---- IASEjbExtraDescriptors extraDesc = ejbDescriptor.getIASEjbExtraDescriptors(); String threadPoolName = extraDesc.getUseThreadPoolId(); ! int threadPoolNumericID = 1; boolean usePassByReference = extraDesc.getPassByReference(); if (usePassByReference) { *************** *** 298,304 **** } catch (Exception ex) { logger.log(Level.WARNING, "Not using threadpool-request-partitioning...", ex); } ! } if (logger.isLoggable(Level.FINE)) { logger.log(Level.FINE, "POARemoteRefFactory checking if SFSBVersionPolicy need to be added"); --- 298,312 ---- } catch (Exception ex) { logger.log(Level.WARNING, "Not using threadpool-request-partitioning...", ex); } ! } else { ! try { ! policies.add(new RequestPartitioningPolicy( ! threadPoolNumericID)); ! } catch (Exception ex) { ! logger.log(Level.WARNING, ! "Not using threadpool-request-partitioning...", ex); ! } ! } if (logger.isLoggable(Level.FINE)) { logger.log(Level.FINE, "POARemoteRefFactory checking if SFSBVersionPolicy need to be added"); Index: src/java/com/sun/enterprise/util/S1ASThreadPoolManager.java =================================================================== RCS file: /cvs/glassfish/appserv-core/src/java/com/sun/enterprise/util/S1ASThreadPoolManager.java,v retrieving revision 1.7 diff -c -r1.7 S1ASThreadPoolManager.java *** src/java/com/sun/enterprise/util/S1ASThreadPoolManager.java 23 May 2007 21:45:40 -0000 1.7 --- src/java/com/sun/enterprise/util/S1ASThreadPoolManager.java 6 Jan 2009 04:42:51 -0000 *************** *** 101,110 **** threadpoolsElement = config.getThreadPools(); assert (threadpoolsElement != null); com.sun.enterprise.config.serverbeans.ThreadPool[] allThreadpools = threadpoolsElement.getThreadPool(); for (int i = 0; i < allThreadpools.length; i++) { ! createThreadPools(allThreadpools[i], i); } defaultID = (String)indexToIdTable.get(new Integer(0)); } catch (ConfigException cfe) { --- 101,117 ---- threadpoolsElement = config.getThreadPools(); assert (threadpoolsElement != null); + // create threadpool for processing of outgoing IIOP requests + com.sun.corba.ee.spi.orbutil.threadpool.ThreadPool iiopRequestThreadpool = + new ThreadPoolImpl("thread-pool-0"); + threadpoolList.add(iiopRequestThreadpool); + idToIndexTable.put("thread-pool-0", new Integer(0)); + indexToIdTable.put(new Integer(0), "thread-pool-0"); + com.sun.enterprise.config.serverbeans.ThreadPool[] allThreadpools = threadpoolsElement.getThreadPool(); for (int i = 0; i < allThreadpools.length; i++) { ! createThreadPools(allThreadpools[i], i + 1); } defaultID = (String)indexToIdTable.get(new Integer(0)); } catch (ConfigException cfe) {