org.jacorb.orb.dsi

Class ServerRequest

Implemented Interfaces:
ResponseHandler

public class ServerRequest
extends ServerRequest
implements ResponseHandler

Version:
$Id: ServerRequest.java,v 1.30 2004/05/06 12:40:00 nicolas Exp $

Author:
Gerald Brose, FU Berlin

Constructor Summary

ServerRequest(ORB orb, RequestInputStream in, GIOPConnection _connection)

Method Summary

NVList
arguments()
void
arguments(NVList p)
OutputStream
createExceptionReply()
OutputStream
createReply()
Context
ctx()
Any
except()
GIOPConnection
getConnection()
Object
getForwardReference()
CDRInputStream
getInputStream()
Object
getReference()
UtcT
getReplyEndTime()
Returns the time after which a reply to this request may no longer be obtained or returned to the client; null if no such time has been specified.
ReplyOutputStream
getReplyOutputStream()
UtcT
getRequestEndTime()
Returns the time after which this request may no longer be delivered to its target; null if no such time has been specified.
UtcT
getRequestStartTime()
Returns the time after which this request may be delivered to its target; null if no such time has been specified.
List
getScopes()
getScopes returns the cached list of poa_names.
ServiceContext[]
getServiceContext()
SystemException
getSystemException()
RequestInputStream
get_in()
ReplyOutputStream
get_out()
If a new output stream has to be created, the request itself isn't fixed to stream-based.
byte[]
objectId()
byte[]
objectKey()
String
operation()
String[]
remainingPOAName()
remainingPOAName retrieves (if any) the target poa's name in relation to parent.
void
reply()
int
requestId()
boolean
responseExpected()
Any
result()
The resulting any must be used to create an input stream from which the result value can be read.
void
setLocationForward(ForwardRequest r)
void
setReference(Object o)
void
setRemainingPOAName(String[] rest_of_name)
void
setServerRequestInfo(ServerRequestInfoImpl info)
void
setSystemException(SystemException s)
our own:
void
setUsePreconstructedReply(boolean use)
void
set_exception(Any ex)
void
set_result(Any res)
ReplyStatusType_1_2
status()
boolean
streamBased()
short
syncScope()
Returns the SyncScope of this request, as expressed in the header's response_flags.

Methods inherited from class org.omg.CORBA.ServerRequest

arguments, ctx, except, op_name, operation, params, result, set_exception, set_result

Constructor Details

ServerRequest

public ServerRequest(ORB orb,
                     RequestInputStream in,
                     GIOPConnection _connection)

Method Details

arguments

public NVList arguments()


arguments

public void arguments(NVList p)
Overrides:
arguments in interface ServerRequest


createExceptionReply

public OutputStream createExceptionReply()
Specified by:
createExceptionReply in interface ResponseHandler


createReply

public OutputStream createReply()
Specified by:
createReply in interface ResponseHandler


ctx

public Context ctx()
Overrides:
ctx in interface ServerRequest


except

public Any except()


getConnection

public GIOPConnection getConnection()


getForwardReference

public Object getForwardReference()


getInputStream

public CDRInputStream getInputStream()

Returns:
the InputStream. This operation sets the request be stream-based, ie. all attempts to extract data using DII-based operations will throw exceptions For internal access to the stream use get_in()


getReference

public Object getReference()


getReplyEndTime

public UtcT getReplyEndTime()
Returns the time after which a reply to this request may no longer be obtained or returned to the client; null if no such time has been specified.


getReplyOutputStream

public ReplyOutputStream getReplyOutputStream()


getRequestEndTime

public UtcT getRequestEndTime()
Returns the time after which this request may no longer be delivered to its target; null if no such time has been specified.


getRequestStartTime

public UtcT getRequestStartTime()
Returns the time after which this request may be delivered to its target; null if no such time has been specified.


getScopes

public List getScopes()

Returns:
a List value containing Strings separated by


getServiceContext

public ServiceContext[] getServiceContext()


getSystemException

public SystemException getSystemException()


get_in

public RequestInputStream get_in()


get_out

public ReplyOutputStream get_out()
If a new output stream has to be created, the request itself isn't fixed to stream-based.


objectId

public byte[] objectId()


objectKey

public byte[] objectKey()


operation

public String operation()
Overrides:
operation in interface ServerRequest


remainingPOAName

public String[] remainingPOAName()
remainingPOAName retrieves (if any) the target poa's name in relation to parent.

Returns:
a String[] value


reply

public void reply()


requestId

public int requestId()


responseExpected

public boolean responseExpected()


result

public Any result()
The resulting any must be used to create an input stream from which the result value can be read.


setLocationForward

public void setLocationForward(ForwardRequest r)


setReference

public void setReference(Object o)


setRemainingPOAName

public void setRemainingPOAName(String[] rest_of_name)


setServerRequestInfo

public void setServerRequestInfo(ServerRequestInfoImpl info)


setSystemException

public void setSystemException(SystemException s)
our own:


setUsePreconstructedReply

public void setUsePreconstructedReply(boolean use)


set_exception

public void set_exception(Any ex)
Overrides:
set_exception in interface ServerRequest


set_result

public void set_result(Any res)
Overrides:
set_result in interface ServerRequest


status

public ReplyStatusType_1_2 status()


streamBased

public boolean streamBased()


syncScope

public short syncScope()
Returns the SyncScope of this request, as expressed in the header's response_flags. Note that here, on the server side, this no longer differentiates between SYNC_NONE and SYNC_WITH_TRANSPORT. The former is returned in both cases.