path: root/gnu/CORBA/Interceptor/gnuClientRequestInfo.java

/* gnuClientRequestInfo.java --
   Copyright (C) 2005 Free Software Foundation, Inc.

This file is part of GNU Classpath.

GNU Classpath is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation; either version 2, or (at your option)
any later version.

GNU Classpath is distributed in the hope that it will be useful, but
WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
General Public License for more details.

You should have received a copy of the GNU General Public License
along with GNU Classpath; see the file COPYING.  If not, write to the
Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
02110-1301 USA.

Linking this library statically or dynamically with other modules is
making a combined work based on this library.  Thus, the terms and
conditions of the GNU General Public License cover the whole
combination.

As a special exception, the copyright holders of this library give you
permission to link this library with independent modules to produce an
executable, regardless of the license terms of these independent
modules, and to copy and distribute the resulting executable under
terms of your choice, provided that you also meet, for each linked
independent module, the terms and conditions of the license of that
module.  An independent module is a module which is not derived from
or based on this library.  If you modify this library, you may extend
this exception to your version of the library, but you are not
obligated to do so.  If you do not wish to do so, delete this
exception statement from your version. */


package gnu.CORBA.Interceptor;

import gnu.CORBA.Unexpected;
import gnu.CORBA.gnuRequest;

import org.omg.CORBA.ARG_IN;
import org.omg.CORBA.ARG_INOUT;
import org.omg.CORBA.ARG_OUT;
import org.omg.CORBA.Any;
import org.omg.CORBA.BAD_PARAM;
import org.omg.CORBA.Bounds;
import org.omg.CORBA.ExceptionList;
import org.omg.CORBA.INV_POLICY;
import org.omg.CORBA.LocalObject;
import org.omg.CORBA.NVList;
import org.omg.CORBA.ORB;
import org.omg.CORBA.ParameterMode;
import org.omg.CORBA.Policy;
import org.omg.CORBA.TCKind;
import org.omg.CORBA.TypeCode;
import org.omg.CORBA.TypeCodePackage.BadKind;
import org.omg.Dynamic.Parameter;
import org.omg.IOP.ServiceContext;
import org.omg.IOP.TaggedComponent;
import org.omg.IOP.TaggedProfile;
import org.omg.PortableInterceptor.ClientRequestInfo;
import org.omg.PortableInterceptor.InvalidSlot;

/**
 * Client request info. All requests on the client side in Classpath
 * implementations are handled via gnuRequest class. This class holds the
 * instance of the gnuRequest, accessing the request info this way.
 *
 * @author Audrius Meskauskas, Lithuania (AudriusA@Bioinformatics.org)
 */
public class gnuClientRequestInfo extends LocalObject
  implements ClientRequestInfo
{
  /**
   * Use serialVersionUID for interoperability.
   */
  private static final long serialVersionUID = 1;

  /**
   * The request structure, from that some methods take the needed information
   * directly. The same request structure cannot be reused in parallel threads,
   * the submission methods are synchronized.
   */
  private final gnuRequest request;

  /**
   * Provides possibility to set the wrapped thrown exception explicitly, where
   * applicable.
   */
  public Any m_wrapped_exception;

  /**
   * Create the info on the given request.
   */
  public gnuClientRequestInfo(gnuRequest a_request)
  {
    request = a_request;
  }

  /** @inheritDoc */
  public void add_request_service_context(ServiceContext service_context,
    boolean replace
  )
  {
    request.add_request_service_context(service_context, replace);
  }

  /** @inheritDoc */
  public TaggedProfile effective_profile()
  {
    return request.effective_profile();
  }

  /** @inheritDoc */
  public org.omg.CORBA.Object effective_target()
  {
    return request.effective_target();
  }

  /** @inheritDoc */
  public TaggedComponent get_effective_component(int id)
    throws BAD_PARAM
  {
    return request.get_effective_component(id);
  }

  /** @inheritDoc */
  public TaggedComponent[] get_effective_components(int id)
    throws BAD_PARAM
  {
    return request.get_effective_components(id);
  }

  /** @inheritDoc */
  public Policy get_request_policy(int type) throws INV_POLICY
  {
    return request.get_request_policy(type);
  }

  /** @inheritDoc */
  public String received_exception_id()
  {
    try
      {
        if (m_wrapped_exception != null)
          {
            return m_wrapped_exception.type().id();
          }
        else
          {
            return request.received_exception_id();
          }
      }
    catch (BadKind e)
      {
        throw new Unexpected(e);
      }
  }

  /** @inheritDoc */
  public Any received_exception()
  {
    if (m_wrapped_exception != null)
      {
        return m_wrapped_exception;
      }
    else
      {
        return request.received_exception();
      }
  }

  /** @inheritDoc */
  public org.omg.CORBA.Object target()
  {
    return request.target();
  }

  /** @inheritDoc */
  public Parameter[] arguments()
  {
    request.checkDii();

    NVList args = request.arguments();
    Parameter[] p = new Parameter[ args.count() ];
    try
      {
        for (int i = 0; i < p.length; i++)
          {
            ParameterMode mode;

            switch (args.item(i).flags())
              {
                case ARG_IN.value :
                  mode = ParameterMode.PARAM_IN;
                  break;

                case ARG_OUT.value :
                  mode = ParameterMode.PARAM_OUT;
                  break;

                case ARG_INOUT.value :
                  mode = ParameterMode.PARAM_INOUT;
                  break;

                default :
                  throw new Unexpected();
              }

            p [ i ] = new Parameter(args.item(i).value(), mode);
          }
      }
    catch (Bounds e)
      {
        throw new Unexpected(e);
      }
    return p;
  }

  /** @inheritDoc */
  public Any result()
  {
    request.checkDii();

    Any rt = request.return_value();

    if (rt == null)
      {
        ORB orb = request.orb();
        rt = orb.create_any();
        rt.type(orb.get_primitive_tc(TCKind.tk_void));
        return rt;
      }

    return request.return_value();
  }

  /** @inheritDoc */
  public String[] contexts()
  {
    return request.ice_contexts();
  }

  /** @inheritDoc */
  public TypeCode[] exceptions()
  {
    request.checkDii();

    ExceptionList ex = request.exceptions();
    TypeCode[] et = new TypeCode[ ex.count() ];
    try
      {
        for (int i = 0; i < et.length; i++)
          {
            et [ i ] = ex.item(i);
          }
      }
    catch (Bounds e)
      {
        throw new Unexpected(e);
      }
    return et;
  }

  /** @inheritDoc */
  public org.omg.CORBA.Object forward_reference()
  {
    return request.forward_reference();
  }

  /** @inheritDoc */
  public String[] operation_context()
  {
    return request.operation_context();
  }

  /** @inheritDoc */
  public Any get_slot(int id) throws InvalidSlot
  {
    return request.get_slot(id);
  }

  /** @inheritDoc */
  public String operation()
  {
    return request.operation();
  }

  /** @inheritDoc */
  public short reply_status()
  {
    return request.reply_status();
  }

  /** @inheritDoc */
  public int request_id()
  {
    return request.request_id();
  }

  /** @inheritDoc */
  public boolean response_expected()
  {
    return request.response_expected();
  }

  /**
       * Determines how far the request shall progress before control is returned to
   * the client. However up till JDK 1.5 inclusive this method always returns
   * SYNC_WITH_TRANSPORT.
   *
   * @return {@link org.omg.Messaging.SYNC_WITH_TRANSPORT.value (1), always.
   *
   * @specnote as defined in the Suns 1.5 JDK API.
   */
  public short sync_scope()
  {
    return request.sync_scope();
  }

  /** @inheritDoc */
  public ServiceContext get_reply_service_context(int ctx_name)
    throws BAD_PARAM
  {
    return request.get_reply_service_context(ctx_name);
  }

  /** @inheritDoc */
  public ServiceContext get_request_service_context(int ctx_name)
    throws BAD_PARAM
  {
    return request.get_request_service_context(ctx_name);
  }
}