com.sun.corba.se.impl.protocol

Class CorbaServerRequestDispatcherImpl

java.lang.Object

com.sun.corba.se.impl.protocol.CorbaServerRequestDispatcherImpl

All Implemented Interfaces:

ServerRequestDispatcher, CorbaServerRequestDispatcher

public class CorbaServerRequestDispatcherImpl
extends Object
implements CorbaServerRequestDispatcher

Field Summary

Fields

Modifier and Type	Field and Description
protected ORB	orb

Constructor Summary

Constructors

Constructor and Description
CorbaServerRequestDispatcherImpl(ORB orb)

Method Summary

Modifier and Type	Method and Description
protected void	checkServerId(ObjectKey okey)
protected void	consumeServiceContexts(CorbaMessageMediator request)
void	dispatch(MessageMediator messageMediator) This method coordinates the processing of a message received on the server side.
protected CorbaMessageMediator	dispatchToServant(Object servant, CorbaMessageMediator req, byte[] objectId, ObjectAdapter objectAdapter)
protected void	dprint(String msg)
protected Object	getServantWithPI(CorbaMessageMediator request, ObjectAdapter objectAdapter, byte[] objectId, ObjectKeyTemplate oktemp, String operation)
protected CorbaMessageMediator	handleDynamicResult(ServerRequestImpl sreq, CorbaMessageMediator req)
protected void	handleNullServant(String operation, NullServant nserv) Always throws OBJECT_NOT_EXIST if operation is not a special method.
IOR	locate(ObjectKey okey) XXX/REVISIT: We do not want to look for a servant in the POA/ServantManager case, but we could in most other cases.
protected String	opAndId(CorbaMessageMediator mediator)
protected boolean	processCodeSetContext(CorbaMessageMediator request, ServiceContexts contexts) Handles setting the connection's code sets if required.
protected CorbaMessageMediator	sendingReply(CorbaMessageMediator req)
protected CorbaMessageMediator	sendingReply(CorbaMessageMediator req, Any excany) Must always be called, just after the servant's method returns.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

orb

protected ORB orb

Constructor Detail

CorbaServerRequestDispatcherImpl

public CorbaServerRequestDispatcherImpl(ORB orb)

Method Detail

locate

public IOR locate(ObjectKey okey)

XXX/REVISIT: We do not want to look for a servant in the POA/ServantManager case, but we could in most other cases. The OA could have a method that returns true if the servant MAY exist, and false only if the servant definitely DOES NOT exist. XXX/REVISIT: We may wish to indicate OBJECT_HERE by some mechanism other than returning a null result. Called from ORB.locate when a LocateRequest arrives. Result is not always absolutely correct: may indicate OBJECT_HERE for non-existent objects, which is resolved on invocation. This "bug" is unavoidable, since in general the object may be destroyed between a locate and a request. Note that this only checks that the appropriate ObjectAdapter is available, not that the servant actually exists. Need to signal one of OBJECT_HERE, OBJECT_FORWARD, OBJECT_NOT_EXIST.

Specified by:

locate in interface CorbaServerRequestDispatcher

Returns:

Result is null if object is (possibly) implemented here, otherwise an IOR indicating objref to forward the request to.

Throws:

OBJECT_NOT_EXIST - is thrown if we know the object does not exist here, and we are not forwarding.

dispatch

public void dispatch(MessageMediator messageMediator)

Description copied from interface: ServerRequestDispatcher

This method coordinates the processing of a message received on the server side. For example, this may involve finding an "object adapter" which would return Ties/Servants to handle the request.

Specified by:

dispatch in interface ServerRequestDispatcher

getServantWithPI

protected Object getServantWithPI(CorbaMessageMediator request,
                                  ObjectAdapter objectAdapter,
                                  byte[] objectId,
                                  ObjectKeyTemplate oktemp,
                                  String operation)
                           throws OADestroyed

Throws:

OADestroyed

checkServerId

protected void checkServerId(ObjectKey okey)

handleNullServant

protected void handleNullServant(String operation,
                                 NullServant nserv)

Always throws OBJECT_NOT_EXIST if operation is not a special method. If operation is _non_existent or _not_existent, this will just return without performing any action, so that _non_existent can return false. Always throws OBJECT_NOT_EXIST for any other special method. Update for issue 4385.

consumeServiceContexts

protected void consumeServiceContexts(CorbaMessageMediator request)

dispatchToServant

protected CorbaMessageMediator dispatchToServant(Object servant,
                                                 CorbaMessageMediator req,
                                                 byte[] objectId,
                                                 ObjectAdapter objectAdapter)

handleDynamicResult

protected CorbaMessageMediator handleDynamicResult(ServerRequestImpl sreq,
                                                   CorbaMessageMediator req)

sendingReply

protected CorbaMessageMediator sendingReply(CorbaMessageMediator req)

sendingReply

protected CorbaMessageMediator sendingReply(CorbaMessageMediator req,
                                            Any excany)

Must always be called, just after the servant's method returns. Creates the ReplyMessage header and puts in the transaction context if necessary.

processCodeSetContext

protected boolean processCodeSetContext(CorbaMessageMediator request,
                                        ServiceContexts contexts)

Handles setting the connection's code sets if required. Returns true if the CodeSetContext was in the request, false otherwise.

dprint

protected void dprint(String msg)

opAndId

protected String opAndId(CorbaMessageMediator mediator)