- /*
- * @(#)LocateReplyMessage_1_2.java 1.18 03/12/19
- *
- * Copyright 2004 Sun Microsystems, Inc. All rights reserved.
- * SUN PROPRIETARY/CONFIDENTIAL. Use is subject to license terms.
- */
-
- package com.sun.corba.se.impl.protocol.giopmsgheaders;
-
- import org.omg.CORBA.INTERNAL;
- import org.omg.CORBA.SystemException;
- import org.omg.CORBA.CompletionStatus;
-
- import com.sun.corba.se.spi.orb.ORB;
-
- import com.sun.corba.se.spi.ior.IOR;
- import com.sun.corba.se.spi.ior.IORFactories;
-
- import com.sun.corba.se.spi.ior.iiop.GIOPVersion;
-
- import com.sun.corba.se.impl.encoding.CDRInputStream;
- import com.sun.corba.se.impl.encoding.CDROutputStream;
-
- import com.sun.corba.se.impl.orbutil.ORBUtility;
- import com.sun.corba.se.impl.orbutil.ORBConstants;
- import com.sun.corba.se.impl.orbutil.ORBClassLoader;
-
- import com.sun.corba.se.spi.logging.CORBALogDomains ;
- import com.sun.corba.se.impl.logging.ORBUtilSystemException ;
-
- /**
- * This implements the GIOP 1.2 LocateReply header.
- *
- * @author Ram Jeyaraman 05/14/2000
- * @version 1.0
- */
-
- public final class LocateReplyMessage_1_2 extends Message_1_2
- implements LocateReplyMessage {
-
- // Instance variables
-
- private ORB orb = null;
- private ORBUtilSystemException wrapper = null ;
- private int reply_status = (int) 0;
- private IOR ior = null;
- private String exClassName = null;
- private int minorCode = (int) 0;
- private CompletionStatus completionStatus = null;
- private short addrDisposition = KeyAddr.value; // default;
-
- // Constructors
-
- LocateReplyMessage_1_2(ORB orb) {
- this.orb = orb;
- this.wrapper = ORBUtilSystemException.get( orb,
- CORBALogDomains.RPC_PROTOCOL ) ;
- }
-
- LocateReplyMessage_1_2(ORB orb, int _request_id,
- int _reply_status, IOR _ior) {
- super(Message.GIOPBigMagic, GIOPVersion.V1_2, FLAG_NO_FRAG_BIG_ENDIAN,
- Message.GIOPLocateReply, 0);
- this.orb = orb;
- this.wrapper = ORBUtilSystemException.get( orb,
- CORBALogDomains.RPC_PROTOCOL ) ;
- request_id = _request_id;
- reply_status = _reply_status;
- ior = _ior;
- }
-
- // Accessor methods
-
- public int getRequestId() {
- return this.request_id;
- }
-
- public int getReplyStatus() {
- return this.reply_status;
- }
-
- public short getAddrDisposition() {
- return this.addrDisposition;
- }
-
- public SystemException getSystemException(String message) {
- return MessageBase.getSystemException(
- exClassName, minorCode, completionStatus, message, wrapper);
- }
-
- public IOR getIOR() {
- return this.ior;
- }
-
- // IO methods
-
- public void read(org.omg.CORBA.portable.InputStream istream) {
- super.read(istream);
- this.request_id = istream.read_ulong();
- this.reply_status = istream.read_long();
- isValidReplyStatus(this.reply_status); // raises exception on error
-
- // GIOP 1.2 LocateReply message bodies are not aligned on
- // 8 byte boundaries.
-
- // The code below reads the reply body in some cases
- // LOC_SYSTEM_EXCEPTION & OBJECT_FORWARD & OBJECT_FORWARD_PERM &
- // LOC_NEEDS_ADDRESSING_MODE
- if (this.reply_status == LOC_SYSTEM_EXCEPTION) {
-
- String reposId = istream.read_string();
- this.exClassName = ORBUtility.classNameOf(reposId);
- this.minorCode = istream.read_long();
- int status = istream.read_long();
-
- switch (status) {
- case CompletionStatus._COMPLETED_YES:
- this.completionStatus = CompletionStatus.COMPLETED_YES;
- break;
- case CompletionStatus._COMPLETED_NO:
- this.completionStatus = CompletionStatus.COMPLETED_NO;
- break;
- case CompletionStatus._COMPLETED_MAYBE:
- this.completionStatus = CompletionStatus.COMPLETED_MAYBE;
- break;
- default:
- throw wrapper.badCompletionStatusInLocateReply(
- CompletionStatus.COMPLETED_MAYBE, new Integer(status) );
- }
- } else if ( (this.reply_status == OBJECT_FORWARD) ||
- (this.reply_status == OBJECT_FORWARD_PERM) ){
- CDRInputStream cdr = (CDRInputStream) istream;
- this.ior = IORFactories.makeIOR( cdr ) ;
- } else if (this.reply_status == LOC_NEEDS_ADDRESSING_MODE) {
- // read GIOP::AddressingDisposition from body and resend the
- // original request using the requested addressing mode. The
- // resending is transparent to the caller.
- this.addrDisposition = AddressingDispositionHelper.read(istream);
- }
- }
-
- // Note, this writes only the header information. SystemException or
- // IOR or GIOP::AddressingDisposition may be written afterwards into the
- // reply mesg body.
- public void write(org.omg.CORBA.portable.OutputStream ostream) {
- super.write(ostream);
- ostream.write_ulong(this.request_id);
- ostream.write_long(this.reply_status);
-
-
- // GIOP 1.2 LocateReply message bodies are not aligned on
- // 8 byte boundaries.
- }
-
- // Static methods
-
- public static void isValidReplyStatus(int replyStatus) {
- switch (replyStatus) {
- case UNKNOWN_OBJECT :
- case OBJECT_HERE :
- case OBJECT_FORWARD :
- case OBJECT_FORWARD_PERM :
- case LOC_SYSTEM_EXCEPTION :
- case LOC_NEEDS_ADDRESSING_MODE :
- break;
- default :
- ORBUtilSystemException localWrapper = ORBUtilSystemException.get(
- CORBALogDomains.RPC_PROTOCOL ) ;
- throw localWrapper.illegalReplyStatus( CompletionStatus.COMPLETED_MAYBE);
- }
- }
-
- public void callback(MessageHandler handler)
- throws java.io.IOException
- {
- handler.handleInput(this);
- }
- } // class LocateReplyMessage_1_2