## org.openorb.net
Class AbstractServerRequest

    java.lang.Object
      |
      +--org.omg.CORBA.LocalObject
            |
            +--org.openorb.net.AbstractServerRequest

All Implemented Interfaces:
  IDLEntity, Object, RequestInfo, RequestInfoOperations, ResponseHandler, java.io.Serializable, ServerRequest, ServerRequestInfo, ServerRequestInfoOperations

Direct Known Subclasses:
  IIOPServerRequest, LocalServerRequest

public abstract class AbstractServerRequest
extends LocalObject
implements ServerRequest

Base class which implements most of the server request functionality. Only protocol specific things are not implemented.

Version:
  $Revision: 1.16 $ $Date: 2002/07/14 19:12:36 $
Author:
  Chris Wood
See Also:
  Serialized Form

Fields inherited from interface org.openorb.net.ServerRequest
`OBJECT_HERE, STATE_COMPLETE, STATE_CREATED, STATE_FIND_ADAPTER, STATE_PROCESSING, STATE_QUEUED, STATE_REPLY, UNKNOWN_OBJECT`

Constructor Summary
`AbstractServerRequest(ServerManager serverManager, ServerChannel channel, java.lang.Object transportAssociation, int request_id)` Two pass constructor for locate request.
`AbstractServerRequest(ServerManager serverManager, ServerChannel channel, java.lang.Object transportAssociation, int request_id, byte[] object_key)` One pass constructor for locate request
`AbstractServerRequest(ServerManager serverManager, ServerChannel channel, java.lang.Object transportAssociation, int request_id, InputStream argument_stream)` Two pass constructor for locate request.
`AbstractServerRequest(ServerManager serverManager, ServerChannel channel, java.lang.Object transportAssociation, int request_id, InputStream argument_stream, byte[] object_key, java.lang.String operation, byte sync_scope, ServiceContext[] request_service_contexts)` One pass constructor for request

Method Summary
`byte[]` `adapter_id()` Find the adapter ID.
`ObjectAdapter` `adapter()` Server adapter.
`int` `adapter(ObjectAdapter adapter)` Set the object adapter and transfer to the QUEUED state.
`void` `add_reply_service_context(ServiceContext service_context, boolean replace)` Add a service context to the reply.
`InputStream` `argument_stream()` Get the request input stream.
`Parameter[]` `arguments()` Request Arguments.
`int` `begin_request()` Called by the worker thread before every attempt to run the request.
`ServerChannel` `channel()` Server channel
`boolean` `checkRequestTransportAssoc(java.lang.Object tpAssc)` Check the transport association, take appropriate action if association is incorrect.
`void` `client_cancel()` Client intiated request cancelation.
`java.lang.String[]` `contexts()` Request contexts.
`OutputStream` `createExceptionReply()` Create a stream for marshaling a user exception.
`OutputStream` `createReply()` Create a stream for marshaling the reply.
`void` `dispatch()` Call predispatch to locate the target, enter the PROCESSING state, call the receive_request interception points and dispatch the request through the adapter.
`boolean` `equals(java.lang.Object obj)` Equality depends on request IDs and channels.
`TypeCode[]` `exceptions()` Request exceptions.
`IOR` `forward_reference_ior()` The IOR of the forward reference which will be sent in response to the request.
`Object` `forward_reference()` The forward reference which will be sent in response to the request.
`ServiceContext` `get_reply_service_context(int id)` Find a reply service context with a given ID.
`ServiceContext[]` `get_reply_service_contexts()` Get a list of all the reply service contexts which been set.
`ServiceContext` `get_request_service_context(int id)` Get reqest service context.
`Policy` `get_server_policy(int type)` Find the server policy of the specified type.
`Any` `get_slot(int id)` Access the PI current from interceptors.
`java.lang.Object` `get_transport_association()` Get the transport association.
`void` `init(byte[] object_key)` Second locate request construction pass.
`void` `init(byte[] object_key, java.lang.String operation, byte sync_scope, ServiceContext[] request_service_contexts)` second constructor pass.
`boolean` `is_locate()` This returns true if this request is a locate request.
`byte[]` `object_id()` Find the object ID.
`byte[]` `object_key()` Object Key.
`java.lang.String[]` `operation_context()` Request contexts.
`java.lang.String` `operation()` Operation name.
`ORB` `orb()` Orb
`short` `reply_status()` Get the reply status.
`int` `request_id()` Request ID.
`boolean` `response_expected()` Response is expected to the request.
`Any` `result()` Request result.
`Any` `sending_exception()` Exception being sent in reply.
`java.lang.String` `sending_system_exception_id()` Repository ID of the system exception being sent as a reply.
`SystemException` `sending_system_exception()` System exception being sent as a reply.
`void` `server_cancel(java.lang.Throwable ex)` Server intiated request cancelation.
`void` `set_slot(int id, Any data)` Access the PI current from interceptors.
`int` `state()` Current request state.
`short` `sync_scope()` Message sync scope.
`boolean` `target_is_a(java.lang.String id)` Determine if the target implements the given interface.
`java.lang.String` `target_most_derived_interface()` Most derrived repository ID of the target.

Methods inherited from class org.omg.CORBA.LocalObject
`_create_request, _create_request, _duplicate, _get_domain_managers, _get_interface_def, _get_interface, _get_policy, _hash, _invoke, _is_a, _is_equivalent, _is_local, _non_existent, _orb, _release, _releaseReply, _request, _request, _servant_postinvoke, _servant_preinvoke, _set_policy_override, validate_connection`

Methods inherited from class java.lang.Object
`getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

Methods inherited from interface org.omg.CORBA.Object
`_create_request, _create_request, _duplicate, _get_domain_managers, _get_interface_def, _get_interface, _get_policy, _hash, _is_a, _is_equivalent, _non_existent, _release, _request, _set_policy_override`

Constructor Detail

### AbstractServerRequest

    public AbstractServerRequest(ServerManager serverManager,
                                 ServerChannel channel,
                                 java.lang.Object transportAssociation,
                                 int request_id,
                                 InputStream argument_stream,
                                 byte[] object_key,
                                 java.lang.String operation,
                                 byte sync_scope,
                                 ServiceContext[] request_service_contexts)

  One pass constructor for request

### AbstractServerRequest

    public AbstractServerRequest(ServerManager serverManager,
                                 ServerChannel channel,
                                 java.lang.Object transportAssociation,
                                 int request_id,
                                 InputStream argument_stream)

  Two pass constructor for locate request. This constructor must be followed by a call to init.

### AbstractServerRequest

    public AbstractServerRequest(ServerManager serverManager,
                                 ServerChannel channel,
                                 java.lang.Object transportAssociation,
                                 int request_id,
                                 byte[] object_key)

  One pass constructor for locate request

### AbstractServerRequest

    public AbstractServerRequest(ServerManager serverManager,
                                 ServerChannel channel,
                                 java.lang.Object transportAssociation,
                                 int request_id)

  Two pass constructor for locate request. Must be followed by call to init(byte [] object_key)

Method Detail

### init

    public void init(byte[] object_key,
                     java.lang.String operation,
                     byte sync_scope,
                     ServiceContext[] request_service_contexts)

  second constructor pass.

### init

    public void init(byte[] object_key)

  Second locate request construction pass.

### orb

    public ORB orb()

  Orb
  Specified by:
    `orb` in interface `ServerRequest`

### channel

    public ServerChannel channel()

  Server channel
  Specified by:
    `channel` in interface `ServerRequest`

### get_transport_association

    public java.lang.Object get_transport_association()

  Get the transport association.
  Specified by:
    `get_transport_association` in interface `ServerRequest`

### checkRequestTransportAssoc

    public boolean checkRequestTransportAssoc(java.lang.Object tpAssc)

  Check the transport association, take appropriate action if association is incorrect. This will be called once for each request fragment and cancel request message.

### state

    public int state()

  Current request state.
  Specified by:
    `state` in interface `ServerRequest`

### is_locate

    public boolean is_locate()

  This returns true if this request is a locate request. Use replyLocate to set the reply. Interceptors are not called for locate requests. ServerRequestInfo operations: arguments, exceptions, contexts, operation_context, result, get_request_service_context, get_reply_service_context, add_reply_service_context are not valid. operation returns the empty string "", response_expected returns true. Note the extra value for reply_status, UNKNOWN_OBJECT.
  Specified by:
    `is_locate` in interface `ServerRequest`

### object_key

    public byte[] object_key()

  Object Key. This is always available.
  Specified by:
    `object_key` in interface `ServerRequest`

### request_id

    public int request_id()

  Request ID. This is always available.
  Specified by:
    `request_id` in interface `RequestInfoOperations`
  Following copied from interface: `org.omg.PortableInterceptor.RequestInfoOperations`
  Returns:
    the attribute value

### equals

    public boolean equals(java.lang.Object obj)

  Equality depends on request IDs and channels.
  Overrides:
    `equals` in class `java.lang.Object`

### operation

    public java.lang.String operation()

  Operation name. This will return null for locate requests.
  Specified by:
    `operation` in interface `RequestInfoOperations`
  Following copied from interface: `org.omg.PortableInterceptor.RequestInfoOperations`
  Returns:
    the attribute value

### response_expected

    public boolean response_expected()

  Response is expected to the request. If this is true then createReply or createExceptionReply is expected to be called by the dispatch operation.
  Specified by:
    `response_expected` in interface `RequestInfoOperations`
  Following copied from interface: `org.omg.PortableInterceptor.RequestInfoOperations`
  Returns:
    the attribute value

### sync_scope

    public short sync_scope()

  Message sync scope.
  Specified by:
    `sync_scope` in interface `RequestInfoOperations`
  Following copied from interface: `org.omg.PortableInterceptor.RequestInfoOperations`
  Returns:
    the attribute value

### arguments

    public Parameter[] arguments()

  Request Arguments. This operation is not available in java.
  Specified by:
    `arguments` in interface `RequestInfoOperations`
  Following copied from interface: `org.omg.PortableInterceptor.RequestInfoOperations`
  Returns:
    the attribute value

### exceptions

    public TypeCode[] exceptions()

  Request exceptions. This operation is not available in java.
  Specified by:
    `exceptions` in interface `RequestInfoOperations`
  Following copied from interface: `org.omg.PortableInterceptor.RequestInfoOperations`
  Returns:
    the attribute value

### contexts

    public java.lang.String[] contexts()

  Request contexts. This operation is not available in java.
  Specified by:
    `contexts` in interface `RequestInfoOperations`
  Following copied from interface: `org.omg.PortableInterceptor.RequestInfoOperations`
  Returns:
    the attribute value

### operation_context

    public java.lang.String[] operation_context()

  Request contexts. This operation is not available in java.
  Specified by:
    `operation_context` in interface `RequestInfoOperations`
  Following copied from interface: `org.omg.PortableInterceptor.RequestInfoOperations`
  Returns:
    the attribute value

### result

    public Any result()

  Request result. This operation is not available in java.
  Specified by:
    `result` in interface `RequestInfoOperations`
  Following copied from interface: `org.omg.PortableInterceptor.RequestInfoOperations`
  Returns:
    the attribute value

### get_slot

    public Any get_slot(int id)
                 throws InvalidSlot

  Access the PI current from interceptors. From the adapter this operation is also available via the PI Current.
  Specified by:
    `get_slot` in interface `RequestInfoOperations`

### set_slot

    public void set_slot(int id,
                         Any data)
                  throws InvalidSlot

  Access the PI current from interceptors. From the adapter this operation is also available via the PI Current.
  Specified by:
    `set_slot` in interface `ServerRequestInfoOperations`

### get_request_service_context

    public ServiceContext get_request_service_context(int id)

  Get reqest service context. This operation is always available.
  Specified by:
    `get_request_service_context` in interface `RequestInfoOperations`

### client_cancel

    public void client_cancel()

  Client intiated request cancelation. This may be called at any time to indicate that a response from the request is no longer expected.
  Specified by:
    `client_cancel` in interface `ServerRequest`

### server_cancel

    public void server_cancel(java.lang.Throwable ex)

  Server intiated request cancelation. This may be called at any time by the server to indicate a server initiated cancel. The request is returned to the server. The completion status of the exception will be set appropriatly.
  Specified by:
    `server_cancel` in interface `ServerRequest`

### begin_request

    public int begin_request()

  Called by the worker thread before every attempt to run the request. This should call the recieve_request_service_context interception point.
  Specified by:
    `begin_request` in interface `ServerRequest`
  Returns:
    the state of the request.

### adapter

    public int adapter(ObjectAdapter adapter)

  Set the object adapter and transfer to the QUEUED state. This is legal only in the FIND_ADAPTER or COMPLETE states. If COMPLETE this has no effect.
  Specified by:
    `adapter` in interface `ServerRequest`
  Returns:
    the state of the request. This will be either QUEUED or COMPLETE.

### adapter

    public ObjectAdapter adapter()

  Server adapter. This operation is valid in all states apart from CREATED and FIND_ADAPTER.
  Specified by:
    `adapter` in interface `ServerRequest`

### get_server_policy

    public Policy get_server_policy(int type)

  Find the server policy of the specified type. This operation is valid in all states apart from CREATED and FIND_ADAPTER.
  Specified by:
    `get_server_policy` in interface `ServerRequestInfoOperations`

### adapter_id

    public byte[] adapter_id()

  Find the adapter ID.
  Specified by:
    `adapter_id` in interface `ServerRequestInfoOperations`
  Following copied from interface: `org.omg.PortableInterceptor.ServerRequestInfoOperations`
  Returns:
    the attribute value

### object_id

    public byte[] object_id()

  Find the object ID.
  Specified by:
    `object_id` in interface `ServerRequestInfoOperations`
  Following copied from interface: `org.omg.PortableInterceptor.ServerRequestInfoOperations`
  Returns:
    the attribute value

### target_most_derived_interface

    public java.lang.String target_most_derived_interface()

  Most derrived repository ID of the target.
  Specified by:
    `target_most_derived_interface` in interface `ServerRequestInfoOperations`
  Following copied from interface: `org.omg.PortableInterceptor.ServerRequestInfoOperations`
  Returns:
    the attribute value

### target_is_a

    public boolean target_is_a(java.lang.String id)

  Determine if the target implements the given interface.
  Specified by:
    `target_is_a` in interface `ServerRequestInfoOperations`

### dispatch

    public void dispatch()
                  throws AdapterDestroyedException

  Call predispatch to locate the target, enter the PROCESSING state, call the receive_request interception points and dispatch the request through the adapter. If sync scope is SYNC_WITH_SERVER an empty response will be sent before the request is dispatched. When this function returns all the terminating interception points will have been called, and state will be COMPLETE. If the target adapter is destroyed between the find_adapter and dispatch requests this function will throw an AdapterDestroyedException and the CREATED state is re-entered, find_adapter function will be called again once the unregister adapter operation is called on the server manager with the target adapter.
  Specified by:
    `dispatch` in interface `ServerRequest`

### argument_stream

    public InputStream argument_stream()

  Get the request input stream. This function can be called only once while in the PROCESSING state. The returned input stream may throw a system exception if some problem occours while unmarshalling the request arguments. This function, and the reply functions must be called by the same thread, the thread that called the dispatch function.
  Specified by:
    `argument_stream` in interface `ServerRequest`

### add_reply_service_context

    public void add_reply_service_context(ServiceContext service_context,
                                          boolean replace)

  Add a service context to the reply.
  Specified by:
    `add_reply_service_context` in interface `ServerRequestInfoOperations`

### get_reply_service_context

    public ServiceContext get_reply_service_context(int id)

  Find a reply service context with a given ID.
  Specified by:
    `get_reply_service_context` in interface `RequestInfoOperations`

### get_reply_service_contexts

    public ServiceContext[] get_reply_service_contexts()

  Get a list of all the reply service contexts which been set.
  Specified by:
    `get_reply_service_contexts` in interface `ServerRequest`

### reply_status

    public short reply_status()

  Get the reply status. This operation is available in the REPLY and COMPLETE states.
  Specified by:
    `reply_status` in interface `RequestInfoOperations`
  Following copied from interface: `org.omg.PortableInterceptor.RequestInfoOperations`
  Returns:
    the attribute value

### forward_reference

    public Object forward_reference()

  The forward reference which will be sent in response to the request.
  Specified by:
    `forward_reference` in interface `RequestInfoOperations`
  Following copied from interface: `org.omg.PortableInterceptor.RequestInfoOperations`
  Returns:
    the attribute value

### forward_reference_ior

    public IOR forward_reference_ior()

  The IOR of the forward reference which will be sent in response to the request.
  Specified by:
    `forward_reference_ior` in interface `ServerRequest`

### sending_exception

    public Any sending_exception()

  Exception being sent in reply. This will only contain system exceptions.
  Specified by:
    `sending_exception` in interface `ServerRequestInfoOperations`
  Following copied from interface: `org.omg.PortableInterceptor.ServerRequestInfoOperations`
  Returns:
    the attribute value

### sending_system_exception

    public SystemException sending_system_exception()

  System exception being sent as a reply.
  Specified by:
    `sending_system_exception` in interface `ServerRequest`

### sending_system_exception_id

    public java.lang.String sending_system_exception_id()

  Repository ID of the system exception being sent as a reply.
  Specified by:
    `sending_system_exception_id` in interface `ServerRequest`

### createReply

    public OutputStream createReply()

  Description copied from interface: `ServerRequest`
  Create a stream for marshaling the reply. The send_reply interception points are called, if this results in a system exception the exception is thrown, otherwise a stream is retured. The returned stream may raise a system exception when attempting to write to it indicating a transmission problem. Such an exception is not reported to interceptors. This function is inherited from the ResponseHandler interface.
  Specified by:
    `createReply` in interface `ServerRequest`

### createExceptionReply

    public OutputStream createExceptionReply()

  Description copied from interface: `ServerRequest`
  Create a stream for marshaling a user exception. The send_exception interception points are called, if this results in a system exception the exception is thrown, otherwise a stream is retured. The returned stream may raise a system exception when attempting to write to it indicating a transmission problem. Such an exception is not reported to interceptors. This function is inherited from the ResponseHandler interface.
  Specified by:
    `createExceptionReply` in interface `ServerRequest`