jdk8-mips64-public/corba: src/share/classes/com/sun/corba/se/impl/protocol/giopmsgheaders/ReplyMessage_1

src/share/classes/com/sun/corba/se/impl/protocol/giopmsgheaders/ReplyMessage_1_1.java@91006f157c46 (annotated)

src/share/classes/com/sun/corba/se/impl/protocol/giopmsgheaders/ReplyMessage_1_1.java

Tue, 25 May 2010 15:52:11 -0700

author: ohair
date: Tue, 25 May 2010 15:52:11 -0700
changeset 158: 91006f157c46
parent 1: 55540e827aef
child 475: 39d15bbb5741
permissions: -rw-r--r--

6943119: Rebrand source copyright notices
Reviewed-by: darcy

 /*
  * Copyright (c) 2000, 2003, Oracle and/or its affiliates. All rights reserved.
  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
  *
  * This code is free software; you can redistribute it and/or modify it
  * under the terms of the GNU General Public License version 2 only, as
  * published by the Free Software Foundation.  Oracle designates this
  * particular file as subject to the "Classpath" exception as provided
  * by Oracle in the LICENSE file that accompanied this code.
  *
  * This code 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
  * version 2 for more details (a copy is included in the LICENSE file that
  * accompanied this code).
  *
  * You should have received a copy of the GNU General Public License version
  * 2 along with this work; if not, write to the Free Software Foundation,
  * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
  *
  * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
  * or visit www.oracle.com if you need additional information or have any
  * questions.
  */
 package com.sun.corba.se.impl.protocol.giopmsgheaders;
 import org.omg.CORBA.INTERNAL;
 import org.omg.CORBA.CompletionStatus;
 import org.omg.CORBA.SystemException;
 import com.sun.corba.se.spi.ior.IOR;
 import com.sun.corba.se.spi.ior.IORFactories;
 import com.sun.corba.se.spi.orb.ORB;
 import com.sun.corba.se.spi.servicecontext.ServiceContexts;
 import com.sun.corba.se.spi.ior.iiop.GIOPVersion;
 import com.sun.corba.se.impl.orbutil.ORBUtility;
 import com.sun.corba.se.impl.orbutil.ORBClassLoader;
 import com.sun.corba.se.spi.ior.IOR;
 import com.sun.corba.se.impl.encoding.CDRInputStream;
 import com.sun.corba.se.spi.logging.CORBALogDomains ;
 import com.sun.corba.se.impl.logging.ORBUtilSystemException ;
 /**
  * This implements the GIOP 1.1 Reply header.
  *
  * @author Ram Jeyaraman 05/14/2000
  */
 public final class ReplyMessage_1_1 extends Message_1_1
         implements ReplyMessage {
     // Instance variables
     private ORB orb = null;
     private ORBUtilSystemException wrapper = null ;
     private ServiceContexts service_contexts = null;
     private int request_id = (int) 0;
     private int reply_status = (int) 0;
     private IOR ior = null;
     private String exClassName = null;
     private int minorCode = (int) 0;
     private CompletionStatus completionStatus = null;
     // Constructors
     ReplyMessage_1_1(ORB orb) {
         this.orb = orb;
         this.wrapper = ORBUtilSystemException.get( orb,
             CORBALogDomains.RPC_PROTOCOL ) ;
     }
     ReplyMessage_1_1(ORB orb, ServiceContexts _service_contexts,
             int _request_id, int _reply_status, IOR _ior) {
         super(Message.GIOPBigMagic, GIOPVersion.V1_1, FLAG_NO_FRAG_BIG_ENDIAN,
             Message.GIOPReply, 0);
         this.orb = orb;
         this.wrapper = ORBUtilSystemException.get( orb,
             CORBALogDomains.RPC_PROTOCOL ) ;
         service_contexts = _service_contexts;
         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 KeyAddr.value;
     }
     public ServiceContexts getServiceContexts() {
         return this.service_contexts;
     }
     public void setServiceContexts( ServiceContexts sc ) {
         this.service_contexts = sc;
     }
     public SystemException getSystemException(String message) {
         return MessageBase.getSystemException(
             exClassName, minorCode, completionStatus, message, wrapper);
     }
     public IOR getIOR() {
         return this.ior;
     }
     public void setIOR( IOR ior ) {
         this.ior = ior;
     }
     // IO methods
     public void read(org.omg.CORBA.portable.InputStream istream) {
         super.read(istream);
         this.service_contexts
             = new ServiceContexts((org.omg.CORBA_2_3.portable.InputStream) istream);
         this.request_id = istream.read_ulong();
         this.reply_status = istream.read_long();
         isValidReplyStatus(this.reply_status); // raises exception on error
         // The code below reads the reply body in some cases
         // SYSTEM_EXCEPTION & LOCATION_FORWARD
         if (this.reply_status == 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.badCompletionStatusInReply(
                     CompletionStatus.COMPLETED_MAYBE, new Integer(status) );
             }
         } else if (this.reply_status == USER_EXCEPTION) {
             // do nothing. The client stub will read the exception from body.
         } else if (this.reply_status == LOCATION_FORWARD) {
             CDRInputStream cdr = (CDRInputStream) istream;
             this.ior = IORFactories.makeIOR(cdr) ;
         }
     }
     // Note, this writes only the header information. SystemException or
     // IOR may be written afterwards into the reply mesg body.
     public void write(org.omg.CORBA.portable.OutputStream ostream) {
         super.write(ostream);
         if (this.service_contexts != null) {
                 service_contexts.write(
                 (org.omg.CORBA_2_3.portable.OutputStream) ostream,
                 GIOPVersion.V1_1);
             } else {
                 ServiceContexts.writeNullServiceContext(
                 (org.omg.CORBA_2_3.portable.OutputStream) ostream);
         }
         ostream.write_ulong(this.request_id);
         ostream.write_long(this.reply_status);
     }
     // Static methods
     public static void isValidReplyStatus(int replyStatus) {
         switch (replyStatus) {
         case NO_EXCEPTION :
         case USER_EXCEPTION :
         case SYSTEM_EXCEPTION :
         case LOCATION_FORWARD :
             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);
     }
 } //

Mercurial > jdk8-mips64-public > corba / annotate

src/share/classes/com/sun/corba/se/impl/protocol/giopmsgheaders/ReplyMessage_1_1.java@91006f157c46 (annotated)

src/share/classes/com/sun/corba/se/impl/protocol/giopmsgheaders/ReplyMessage_1_1.java