org.globus.ogsa.server
Class ServiceDispatcher

java.lang.Object
  extended byorg.globus.ogsa.server.ServiceDispatcher
All Implemented Interfaces:
java.lang.Runnable

public class ServiceDispatcher
extends java.lang.Object
implements java.lang.Runnable

Dispatcher reading requests off the socket and putting them into a request queue


Field Summary
protected  int highWaterMark
           
protected  int maxThreads
           
protected  int numThreads
           
protected  ServiceRequestQueue queue
           
protected  ServiceThreadPool threadPool
           
 
Constructor Summary
ServiceDispatcher()
           
 
Method Summary
protected static org.apache.axis.AxisEngine getAxisEngine()
           
 void init()
           
 void run()
           
 void setServerSocket(java.net.ServerSocket serverSocket)
           
 void setThreads(int numThreads)
           
 void start(boolean daemon)
          Start this dispatcher.
 void stop()
           
 void waitForInit()
           
 void waitForStop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

queue

protected ServiceRequestQueue queue

threadPool

protected ServiceThreadPool threadPool

numThreads

protected int numThreads

maxThreads

protected int maxThreads

highWaterMark

protected int highWaterMark
Constructor Detail

ServiceDispatcher

public ServiceDispatcher()
Method Detail

getAxisEngine

protected static org.apache.axis.AxisEngine getAxisEngine()
                                                   throws ConfigException
Throws:
ConfigException

setServerSocket

public void setServerSocket(java.net.ServerSocket serverSocket)

init

public void init()
          throws ConfigException
Throws:
ConfigException

setThreads

public void setThreads(int numThreads)

waitForInit

public void waitForInit()
                 throws java.lang.InterruptedException
Throws:
java.lang.InterruptedException

run

public void run()
Specified by:
run in interface java.lang.Runnable

waitForStop

public void waitForStop()
                 throws java.lang.InterruptedException
Throws:
java.lang.InterruptedException

stop

public void stop()
          throws GridServiceException
Throws:
GridServiceException

start

public void start(boolean daemon)
           throws GridServiceException
Start this dispatcher. Spawns a worker thread to listen for HTTP requests.

Parameters:
daemon - a boolean indicating if the thread should be a daemon.
Throws:
GridServiceException


Copyright ? 1999 University of Chicago and The University of Southern California. All Rights Reserved.