| java.lang.Object
 java.lang.Thread
org.jacorb.poa.RequestController
| RequestController | | final public class RequestController extends Thread implements Configurable(Code) | | This class manages all request processing affairs. The main thread takes the
requests out from the queue and will see that the necessary steps are taken.
author:
Reimo Tiedemann
version:
$Id: RequestController.java,v 1.34 2006/06/27 10:51:19 alphonse.bendt Exp $ |
| addLocalRequest | | synchronized void addLocalRequest()(Code) | | |
| clearUpPool | | void clearUpPool()(Code) | | |
| configure | | public void configure(Configuration myConfiguration) throws ConfigurationException(Code) | | |
| continueToWork | | void continueToWork()(Code) | | indicates that the assumptions for blocking the
request controller thread have changed,
a waiting request controller thread will notified
|
| end | | synchronized void end()(Code) | | |
| finish | | synchronized void finish(ServerRequest request)(Code) | | Called from RequestProcessor when the request has been handled.
The request is removed from the active request table.
|
| freeObject | | synchronized void freeObject(byte[] oid)(Code) | | frees an object from the deactivation in progress state,
a call indicates that the object deactivation process is complete
|
| getLogger | | Logger getLogger()(Code) | | |
| removeLocalRequest | | synchronized void removeLocalRequest()(Code) | | |
| resetPreviousCompletionCall | | synchronized void resetPreviousCompletionCall()(Code) | | resets a previous waitForCompletion call,
everybody who is waiting will notified
|
| returnResult | | void returnResult(ServerRequest request)(Code) | | Sends the reply of the given request via the BasicAdapter.
|
| run | | public void run()(Code) | | the main loop for dispatching requests to request processors
|
| waitForCompletion | | synchronized void waitForCompletion()(Code) | | called from external thread for synchronizing with the
request controller thread,
a caller waits for completion of all active requests,
no new requests will started from now on
|
| waitForObjectCompletion | | synchronized void waitForObjectCompletion(byte[] oid)(Code) | | called from external thread for synchronizing with the request
controller thread, a caller waits for completion of all active
requests on this object. No new requests on this object will be
started from now on because a steady stream of incomming
requests could keep the object from being deactivated, a
servant may invoke recursive method calls on the object it
incarnates and deactivation should not necessarily prevent
those invocations.
|
| waitForShutdown | | synchronized void waitForShutdown()(Code) | | called from external thread for synchronizing with the
request controller thread,
a caller waits for completion of all active requests,
no new requests will started for ALL TIME
|
|
|