1. /*

  2.  * @(#)CDRInputStreamBase.java	1.14 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. package com.sun.corba.se.internal.iiop;

  8. 

  9. import java.io.IOException;

  10. import java.io.Serializable;

  11. import java.math.BigDecimal;

  12. 

  13. import org.omg.CORBA.TypeCode;

  14. import org.omg.CORBA.Principal;

  15. import org.omg.CORBA.Any;

  16. 

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

  18. import com.sun.corba.se.internal.orbutil.ORBConstants;

  19. import com.sun.org.omg.SendingContext.CodeBase;

  20. 

  21. /**

  22.  * Describes CDRInputStream delegates and provides some

  23.  * implementation.  Non-default constructors are avoided in

  24.  * the delegation to separate instantiation from initialization,

  25.  * so we use init methods.

  26.  */

  27. abstract class CDRInputStreamBase extends java.io.InputStream

  28. {

  29.     protected CDRInputStream parent;

  30. 

  31.     public void setParent(CDRInputStream parent) {

  32.         this.parent = parent;

  33.     }

  34. 

  35.     // EncapsInputStream

  36.     public void init(org.omg.CORBA.ORB orb,

  37.                      BufferManagerRead bufMgr,

  38.                      boolean littleEndian) {

  39.         int size;

  40.         if (orb == null)

  41.             size = ORBConstants.GIOP_DEFAULT_BUFFER_SIZE;

  42.         else

  43.             size = ((ORB)orb).getGIOPBufferSize();

  44. 

  45.         ByteBufferWithInfo bbwi = new ByteBufferWithInfo(size);

  46. 

  47.         init(orb,

  48.              bbwi.buf,

  49.              bbwi.buflen,

  50.              littleEndian,

  51.              bufMgr);

  52.     }

  53.     

  54.     // Required by parent CDRInputStream

  55.     public void init(org.omg.CORBA.ORB orb) {

  56.         BufferManagerRead bufMgr = BufferManagerFactory.defaultBufferManagerRead();

  57.         

  58.         int size;

  59.         if (orb == null)

  60.             size = ORBConstants.GIOP_DEFAULT_BUFFER_SIZE;

  61.         else

  62.             size = ((ORB)orb).getGIOPBufferSize();

  63. 

  64.         ByteBufferWithInfo bbwi = new ByteBufferWithInfo(size);

  65. 

  66.         init(orb,

  67.              bbwi.buf,

  68.              bbwi.buflen,

  69.              false,

  70.              bufMgr);

  71.     }

  72. 

  73.     public void init(org.omg.CORBA.ORB orb, byte[] data, int size) {

  74.         init(orb, data, size, false);

  75.     }

  76. 

  77.     public void init(org.omg.CORBA.ORB orb, byte[] data, int size, boolean littleEndian) {

  78.         init(orb,

  79.              data,

  80.              size,

  81.              littleEndian,

  82.              BufferManagerFactory.defaultBufferManagerRead());

  83.     }

  84. 

  85. 

  86.     public abstract void init(org.omg.CORBA.ORB orb, 

  87.                               byte[] data, 

  88.                               int size, 

  89.                               boolean littleEndian,

  90.                               BufferManagerRead bufferManager);

  91. 

  92.     // org.omg.CORBA.portable.InputStream

  93.     public abstract boolean read_boolean();

  94.     public abstract char read_char();

  95.     public abstract char read_wchar();

  96.     public abstract byte read_octet();

  97.     public abstract short read_short();

  98.     public abstract short read_ushort();

  99.     public abstract int read_long();

  100.     public abstract int read_ulong();

  101.     public abstract long read_longlong();

  102.     public abstract long read_ulonglong();

  103.     public abstract float read_float();

  104.     public abstract double read_double();

  105.     public abstract String read_string();

  106.     public abstract String read_wstring();

  107.     public abstract void read_boolean_array(boolean[] value, int offset, int length);

  108.     public abstract void read_char_array(char[] value, int offset, int length);

  109.     public abstract void read_wchar_array(char[] value, int offset, int length);

  110.     public abstract void read_octet_array(byte[] value, int offset, int length);

  111.     public abstract void read_short_array(short[] value, int offset, int length);

  112.     public abstract void read_ushort_array(short[] value, int offset, int length);

  113.     public abstract void read_long_array(int[] value, int offset, int length);

  114.     public abstract void read_ulong_array(int[] value, int offset, int length);

  115.     public abstract void read_longlong_array(long[] value, int offset, int length);

  116.     public abstract void read_ulonglong_array(long[] value, int offset, int length);

  117.     public abstract void read_float_array(float[] value, int offset, int length);

  118.     public abstract void read_double_array(double[] value, int offset, int length);

  119.     public abstract org.omg.CORBA.Object read_Object();

  120.     public abstract TypeCode read_TypeCode();

  121.     public abstract Any read_any();

  122.     public abstract Principal read_Principal();

  123.     public int read() throws java.io.IOException {

  124.         throw new org.omg.CORBA.NO_IMPLEMENT();

  125.     }

  126.     public abstract java.math.BigDecimal read_fixed();

  127.     public org.omg.CORBA.Context read_Context() {

  128.         throw new org.omg.CORBA.NO_IMPLEMENT();

  129.     }

  130.     public abstract org.omg.CORBA.Object read_Object(java.lang.Class clz);

  131.     public abstract org.omg.CORBA.ORB orb();

  132. 

  133.     // org.omg.CORBA_2_3.portable.InputStream

  134.     public abstract java.io.Serializable read_value();

  135.     public abstract java.io.Serializable read_value(java.lang.Class clz);

  136.     public abstract java.io.Serializable read_value(org.omg.CORBA.portable.BoxedValueHelper factory);

  137.     public abstract java.io.Serializable read_value(java.lang.String rep_id);

  138.     public abstract java.io.Serializable read_value(java.io.Serializable value);

  139.     public abstract java.lang.Object read_abstract_interface();

  140.     public abstract java.lang.Object read_abstract_interface(java.lang.Class clz);

  141. 

  142.     // com.sun.corba.se.internal.core.MarshalInputStream

  143.     public abstract void consumeEndian();

  144.     public abstract int getPosition();

  145. 

  146.     // org.omg.CORBA.DataInputStream

  147.     public abstract java.lang.Object read_Abstract ();

  148.     public abstract java.io.Serializable read_Value ();

  149.     public abstract void read_any_array (org.omg.CORBA.AnySeqHolder seq, int offset, int length);

  150.     public abstract void read_boolean_array (org.omg.CORBA.BooleanSeqHolder seq, int offset, int length);

  151.     public abstract void read_char_array (org.omg.CORBA.CharSeqHolder seq, int offset, int length);

  152.     public abstract void read_wchar_array (org.omg.CORBA.WCharSeqHolder seq, int offset, int length);

  153.     public abstract void read_octet_array (org.omg.CORBA.OctetSeqHolder seq, int offset, int length);

  154.     public abstract void read_short_array (org.omg.CORBA.ShortSeqHolder seq, int offset, int length);

  155.     public abstract void read_ushort_array (org.omg.CORBA.UShortSeqHolder seq, int offset, int length);

  156.     public abstract void read_long_array (org.omg.CORBA.LongSeqHolder seq, int offset, int length);

  157.     public abstract void read_ulong_array (org.omg.CORBA.ULongSeqHolder seq, int offset, int length); 

  158.     public abstract void read_ulonglong_array (org.omg.CORBA.ULongLongSeqHolder seq, int offset, int length);

  159.     public abstract void read_longlong_array (org.omg.CORBA.LongLongSeqHolder seq, int offset, int length);

  160.     public abstract void read_float_array (org.omg.CORBA.FloatSeqHolder seq, int offset, int length);

  161.     public abstract void read_double_array (org.omg.CORBA.DoubleSeqHolder seq, int offset, int length);

  162. 

  163.     // org.omg.CORBA.portable.ValueBase

  164.     public abstract String[] _truncatable_ids();

  165. 

  166.     // java.io.InputStream

  167.     // REVISIT - should we make these throw UnsupportedOperationExceptions?

  168.     // Right now, they'll go up to the java.io versions!

  169. 

  170. //     public abstract int read(byte b[]) throws IOException;

  171. //     public abstract int read(byte b[], int off, int len) throws IOException 

  172. //     public abstract long skip(long n) throws IOException;

  173. //     public abstract int available() throws IOException;

  174. //     public abstract void close() throws IOException;

  175.     public abstract void mark(int readlimit);

  176.     public abstract void reset();

  177. 

  178.     // This should return false so that outside users (people using the JDK)

  179.     // don't have any guarantees that mark/reset will work in their

  180.     // custom marshaling code.  This is necessary since they could do things

  181.     // like expect obj1a == obj1b in the following code:

  182.     //

  183.     // is.mark(10000);

  184.     // Object obj1a = is.readObject();

  185.     // is.reset();

  186.     // Object obj1b = is.readObject();

  187.     //

  188.     public boolean markSupported() { return false; }

  189. 

  190.     // Needed by AnyImpl and ServiceContexts

  191.     public abstract CDRInputStreamBase dup();

  192. 

  193.     // Needed by TCUtility

  194.     public abstract java.math.BigDecimal read_fixed(short digits, short scale);

  195. 

  196.     // Needed by TypeCodeImpl

  197.     public abstract boolean isLittleEndian();

  198. 

  199.     // Needed by IIOPInputStream and other subclasses

  200. 

  201.     public abstract byte[] getByteBuffer();

  202.     public abstract void setByteBuffer(byte buffer[]);

  203. 

  204.     public abstract int getBufferLength();

  205.     public abstract void setBufferLength(int value);

  206. 

  207.     public abstract int getIndex();

  208.     public abstract void setIndex(int value);

  209. 

  210.     public abstract void orb(org.omg.CORBA.ORB orb);

  211. 

  212.     public abstract BufferManagerRead getBufferManager();

  213.     public abstract GIOPVersion getGIOPVersion();

  214. 

  215.     abstract CodeBase getCodeBase();

  216. 

  217.     abstract void printBuffer();

  218. 

  219.     abstract void alignOnBoundary(int octetBoundary);

  220. 

  221.     abstract void performORBVersionSpecificInit();

  222. 

  223.     public abstract void resetCodeSetConverters();

  224. }