colus 02/05/19 21:13:23
Modified: src/java/org/apache/avalon/cornerstone/services/connection
AbstractService.java
Log:
BlockContext's getThreadPool is removed.
Revision Changes Path
1.11 +8 -8
jakarta-avalon-cornerstone/src/java/org/apache/avalon/cornerstone/services/connection/AbstractService.java
Index: AbstractService.java
===================================================================
RCS file:
/home/cvs/jakarta-avalon-cornerstone/src/java/org/apache/avalon/cornerstone/services/connection/AbstractService.java,v
retrieving revision 1.10
retrieving revision 1.11
diff -u -r1.10 -r1.11
--- AbstractService.java 18 May 2002 09:50:40 -0000 1.10
+++ AbstractService.java 20 May 2002 04:13:23 -0000 1.11
@@ -12,6 +12,7 @@
import java.io.IOException;
import org.apache.avalon.cornerstone.services.sockets.ServerSocketFactory;
import org.apache.avalon.cornerstone.services.sockets.SocketManager;
+import org.apache.avalon.cornerstone.services.threads.ThreadManager;
import org.apache.avalon.excalibur.thread.ThreadPool;
import org.apache.avalon.framework.activity.Disposable;
import org.apache.avalon.framework.activity.Initializable;
@@ -40,6 +41,7 @@
protected ConnectionManager m_connectionManager;
protected SocketManager m_socketManager;
protected ConnectionHandlerFactory m_factory;
+ protected ThreadManager m_threadManager;
protected ThreadPool m_threadPool;
protected String m_serverSocketType;
protected int m_port;
@@ -69,14 +71,6 @@
public void contextualize( final Context context )
throws ContextException
{
- final String name = getThreadPoolName();
-
- if( null != name )
- {
- final BlockContext blockContext = (BlockContext)context;
- m_threadPool = blockContext.getThreadPool( name );
- }
-
if( m_factory instanceof Contextualizable )
{
( (Contextualizable)m_factory ).contextualize( context );
@@ -88,6 +82,12 @@
{
m_connectionManager = (ConnectionManager)componentManager.lookup(
ConnectionManager.ROLE );
m_socketManager = (SocketManager)componentManager.lookup(
SocketManager.ROLE );
+ if ( null != getThreadPoolName() )
+ {
+ m_threadManager =
+ (ThreadManager)componentManager.lookup( ThreadManager.ROLE );
+ m_threadPool = m_threadManager.getThreadPool(
getThreadPoolName() );
+ }
if( m_factory instanceof Composable )
{
--
To unsubscribe, e-mail: <mailto:[EMAIL PROTECTED]>
For additional commands, e-mail: <mailto:[EMAIL PROTECTED]>
