1. /*

  2.  * @(#)LocateRequestMessage_1_1.java	1.9 03/01/23

  3.  *

  4.  * Copyright 2003 Sun Microsystems, Inc. All rights reserved.

  5.  * SUN PROPRIETARY/CONFIDENTIAL. Use is subject to license terms.

  6.  */

  7. 

  8. package com.sun.corba.se.internal.iiop.messages;

  9. 

  10. import com.sun.corba.se.internal.core.GIOPVersion;

  11. import com.sun.corba.se.internal.iiop.ORB;

  12. import com.sun.corba.se.internal.ior.ObjectKey;

  13. 

  14. /**

  15.  * This implements the GIOP 1.1 LocateRequest header.

  16.  *

  17.  * @author Ram Jeyaraman 05/14/2000

  18.  * @version 1.0

  19.  */

  20. 

  21. public final class LocateRequestMessage_1_1 extends Message_1_1

  22.         implements LocateRequestMessage {

  23. 

  24.     // Instance variables

  25. 

  26.     private ORB orb = null;

  27.     private int request_id = (int) 0;

  28.     private byte[] object_key = null;

  29.     private ObjectKey objectKey = null;

  30. 

  31.     // Constructors

  32. 

  33.     LocateRequestMessage_1_1(ORB orb) {

  34.         this.orb = orb;

  35.     }

  36. 

  37.     LocateRequestMessage_1_1(ORB orb, int _request_id, byte[] _object_key) {

  38.         super(Message.GIOPBigMagic, GIOPVersion.V1_1, FLAG_NO_FRAG_BIG_ENDIAN,

  39.             Message.GIOPLocateRequest, 0);

  40.         this.orb = orb;

  41.         request_id = _request_id;

  42.         object_key = _object_key;

  43.     }

  44. 

  45.     // Accessor methods (LocateRequestMessage interface)

  46. 

  47.     public int getRequestId() {

  48.         return this.request_id;

  49.     }

  50. 

  51.     public ObjectKey getObjectKey() {

  52.         if (this.objectKey == null) {

  53. 	    // this will raise a MARSHAL exception upon errors.

  54. 	    this.objectKey = MessageBase.extractObjectKey(object_key, orb);

  55.         }

  56. 

  57. 	return this.objectKey;

  58.     }

  59. 

  60.     // IO methods

  61. 

  62.     public void read(org.omg.CORBA.portable.InputStream istream) {

  63.         super.read(istream);

  64.         this.request_id = istream.read_ulong();

  65.         int _len1 = istream.read_long();

  66.         this.object_key = new byte[_len1];

  67.         istream.read_octet_array(this.object_key, 0, _len1);

  68.     }

  69. 

  70.     public void write(org.omg.CORBA.portable.OutputStream ostream) {

  71.         super.write(ostream);

  72.         ostream.write_ulong(this.request_id);

  73.         nullCheck(this.object_key);

  74.         ostream.write_long(this.object_key.length);

  75.         ostream.write_octet_array(this.object_key, 0, this.object_key.length);

  76.     }

  77. 

  78.     public final void callback(com.sun.corba.se.internal.iiop.MessageMediator m)

  79.         throws java.io.IOException

  80.     {

  81.         m.handleInput(this);

  82.     }

  83. } // class LocateRequestMessage_1_1