1. /*

  2.  * @(#)CDROutputStream.java	1.28 04/06/21

  3.  *

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

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

  6.  */

  7. package com.sun.corba.se.impl.encoding;

  8. 

  9. import java.io.IOException;

  10. import java.io.Serializable;

  11. import java.math.BigDecimal;

  12. import java.nio.ByteBuffer;

  13. 

  14. import org.omg.CORBA.TypeCode;

  15. import org.omg.CORBA.Principal;

  16. import org.omg.CORBA.Any;

  17. 

  18. import com.sun.corba.se.pept.protocol.MessageMediator;

  19. 

  20. import com.sun.corba.se.spi.orb.ORB;

  21. import com.sun.corba.se.spi.logging.CORBALogDomains;

  22. import com.sun.corba.se.spi.ior.iiop.GIOPVersion;

  23. import com.sun.corba.se.spi.protocol.CorbaMessageMediator;

  24. 

  25. import com.sun.corba.se.impl.encoding.CodeSetConversion;

  26. import com.sun.corba.se.impl.encoding.OSFCodeSetRegistry;

  27. import com.sun.corba.se.impl.orbutil.ORBConstants;

  28. import com.sun.corba.se.impl.logging.ORBUtilSystemException;

  29. import com.sun.corba.se.impl.protocol.giopmsgheaders.Message;

  30. 

  31. /**

  32.  * This is delegates to the real implementation.

  33.  */

  34. public abstract class CDROutputStream

  35.     extends org.omg.CORBA_2_3.portable.OutputStream

  36.     implements com.sun.corba.se.impl.encoding.MarshalOutputStream,

  37.                org.omg.CORBA.DataOutputStream, org.omg.CORBA.portable.ValueOutputStream

  38. {

  39.     private CDROutputStreamBase impl;

  40.     protected ORB orb ;

  41.     protected ORBUtilSystemException wrapper ;

  42.     protected CorbaMessageMediator corbaMessageMediator;

  43. 

  44. 

  45.     // We can move this out somewhere later.  For now, it serves its purpose

  46.     // to create a concrete CDR delegate based on the GIOP version.

  47.     private static class OutputStreamFactory {

  48.         

  49.         public static CDROutputStreamBase newOutputStream(

  50. 	        ORB orb, GIOPVersion version, byte encodingVersion) {

  51.             switch(version.intValue()) {

  52.                 case GIOPVersion.VERSION_1_0:

  53.                     return new CDROutputStream_1_0();

  54.                 case GIOPVersion.VERSION_1_1:

  55.                     return new CDROutputStream_1_1();

  56. 	    case GIOPVersion.VERSION_1_2:

  57. 		if (encodingVersion != Message.CDR_ENC_VERSION) {

  58. 		    return 

  59. 			new IDLJavaSerializationOutputStream(encodingVersion);

  60. 		}

  61. 		return new CDROutputStream_1_2();

  62. 	    default:

  63. 		    ORBUtilSystemException wrapper = ORBUtilSystemException.get( orb,

  64. 			CORBALogDomains.RPC_ENCODING ) ;

  65.                     // REVISIT - what is appropriate?  INTERNAL exceptions

  66.                     // are really hard to track later.

  67. 		    throw wrapper.unsupportedGiopVersion( version ) ;

  68.             }

  69.         }

  70.     }

  71. 

  72.     // REVISIT - These two constructors should be re-factored to better hide

  73.     // the fact that someone extending this class 'can' construct a CDROutputStream

  74.     // that does not use pooled ByteBuffers. Right now, only EncapsOutputStream

  75.     // does _not_ use pooled ByteBuffers, see EncapsOutputStream.

  76. 

  77.     // NOTE: When a stream is constructed for non-channel-backed sockets

  78.     // it notifies the constructor not to use pooled (i.e, direct)

  79.     // ByteBuffers.

  80. 

  81.     public CDROutputStream(ORB orb,

  82.                            GIOPVersion version,

  83. 			   byte encodingVersion,

  84. 			   boolean littleEndian,

  85. 			   BufferManagerWrite bufferManager,

  86.                            byte streamFormatVersion,

  87.                            boolean usePooledByteBuffers)

  88.     {

  89.         impl = OutputStreamFactory.newOutputStream(orb, version,

  90. 						   encodingVersion);

  91.         impl.init(orb, littleEndian, bufferManager,

  92. 		  streamFormatVersion, usePooledByteBuffers);

  93. 

  94.         impl.setParent(this);

  95. 	this.orb = orb ;

  96. 	this.wrapper = ORBUtilSystemException.get( orb,

  97. 	    CORBALogDomains.RPC_ENCODING ) ;

  98.     }

  99. 

  100.     public CDROutputStream(ORB orb,

  101.                            GIOPVersion version,

  102. 			   byte encodingVersion,

  103. 			   boolean littleEndian,

  104. 			   BufferManagerWrite bufferManager,

  105.                            byte streamFormatVersion)

  106.     {

  107.         this(orb, version, encodingVersion, littleEndian, 

  108. 	     bufferManager, streamFormatVersion, true);

  109.     }

  110. 

  111.     // org.omg.CORBA.portable.OutputStream

  112. 

  113.     // Provided by IIOPOutputStream and EncapsOutputStream

  114.     public abstract org.omg.CORBA.portable.InputStream create_input_stream();

  115. 

  116.     public final void write_boolean(boolean value) {

  117.         impl.write_boolean(value);

  118.     }

  119.     public final void write_char(char value) {

  120.         impl.write_char(value);

  121.     }

  122.     public final void write_wchar(char value) {

  123.         impl.write_wchar(value);

  124.     }

  125.     public final void write_octet(byte value) {

  126.         impl.write_octet(value);

  127.     }

  128.     public final void write_short(short value) {

  129.         impl.write_short(value);

  130.     }

  131.     public final void write_ushort(short value) {

  132.         impl.write_ushort(value);

  133.     }

  134.     public final void write_long(int value) {

  135.         impl.write_long(value);

  136.     }

  137.     public final void write_ulong(int value) {

  138.         impl.write_ulong(value);

  139.     }

  140.     public final void write_longlong(long value) {

  141.         impl.write_longlong(value);

  142.     }

  143.     public final void write_ulonglong(long value) {

  144.         impl.write_ulonglong(value);

  145.     }

  146.     public final void write_float(float value) {

  147.         impl.write_float(value);

  148.     }

  149.     public final void write_double(double value) {

  150.         impl.write_double(value);

  151.     }

  152.     public final void write_string(String value) {

  153.         impl.write_string(value);

  154.     }

  155.     public final void write_wstring(String value) {

  156.         impl.write_wstring(value);

  157.     }

  158. 

  159.     public final void write_boolean_array(boolean[] value, int offset, int length) {

  160.         impl.write_boolean_array(value, offset, length);

  161.     }

  162.     public final void write_char_array(char[] value, int offset, int length) {

  163.         impl.write_char_array(value, offset, length);

  164.     }

  165.     public final void write_wchar_array(char[] value, int offset, int length) {

  166.         impl.write_wchar_array(value, offset, length);

  167.     }

  168.     public final void write_octet_array(byte[] value, int offset, int length) {

  169.         impl.write_octet_array(value, offset, length);

  170.     }

  171.     public final void write_short_array(short[] value, int offset, int length) {

  172.         impl.write_short_array(value, offset, length);

  173.     }

  174.     public final void write_ushort_array(short[] value, int offset, int length){

  175.         impl.write_ushort_array(value, offset, length);

  176.     }

  177.     public final void write_long_array(int[] value, int offset, int length) {

  178.         impl.write_long_array(value, offset, length);

  179.     }

  180.     public final void write_ulong_array(int[] value, int offset, int length) {

  181.         impl.write_ulong_array(value, offset, length);

  182.     }

  183.     public final void write_longlong_array(long[] value, int offset, int length) {

  184.         impl.write_longlong_array(value, offset, length);

  185.     }

  186.     public final void write_ulonglong_array(long[] value, int offset,int length) {

  187.         impl.write_ulonglong_array(value, offset, length);

  188.     }

  189.     public final void write_float_array(float[] value, int offset, int length) {

  190.         impl.write_float_array(value, offset, length);

  191.     }

  192.     public final void write_double_array(double[] value, int offset, int length) {

  193.         impl.write_double_array(value, offset, length);

  194.     }

  195.     public final void write_Object(org.omg.CORBA.Object value) {

  196.         impl.write_Object(value);

  197.     }

  198.     public final void write_TypeCode(TypeCode value) {

  199.         impl.write_TypeCode(value);

  200.     }

  201.     public final void write_any(Any value) {

  202.         impl.write_any(value);

  203.     }

  204. 

  205.     public final void write_Principal(Principal value) {

  206.         impl.write_Principal(value);

  207.     }

  208. 

  209.     public final void write(int b) throws java.io.IOException {

  210.         impl.write(b);

  211.     }

  212.     

  213.     public final void write_fixed(java.math.BigDecimal value) {

  214.         impl.write_fixed(value);

  215.     }

  216. 

  217.     public final void write_Context(org.omg.CORBA.Context ctx,

  218. 			      org.omg.CORBA.ContextList contexts) {

  219.         impl.write_Context(ctx, contexts);

  220.     }

  221. 

  222.     public final org.omg.CORBA.ORB orb() {

  223.         return impl.orb();

  224.     }

  225. 

  226.     // org.omg.CORBA_2_3.portable.OutputStream

  227.     public final void write_value(java.io.Serializable value) {

  228.         impl.write_value(value);

  229.     }

  230. 

  231.     public final void write_value(java.io.Serializable value, java.lang.Class clz) {

  232.         impl.write_value(value, clz);

  233.     }

  234. 

  235.     public final void write_value(java.io.Serializable value, String repository_id) {

  236.         impl.write_value(value, repository_id);

  237.     }

  238. 

  239.     public final void write_value(java.io.Serializable value, 

  240.                             org.omg.CORBA.portable.BoxedValueHelper factory) {

  241.         impl.write_value(value, factory);

  242.     }

  243. 

  244.     public final void write_abstract_interface(java.lang.Object obj) {

  245.         impl.write_abstract_interface(obj);

  246.     }

  247. 

  248.     // java.io.OutputStream

  249.     public final void write(byte b[]) throws IOException {

  250.         impl.write(b);

  251.     }

  252. 

  253.     public final void write(byte b[], int off, int len) throws IOException {

  254.         impl.write(b, off, len);

  255.     }

  256. 

  257.     public final void flush() throws IOException {

  258.         impl.flush();

  259.     }

  260. 

  261.     public final void close() throws IOException {

  262.         impl.close();

  263.     }

  264. 

  265.     // com.sun.corba.se.impl.encoding.MarshalOutputStream

  266.     public final void start_block() {

  267.         impl.start_block();

  268.     }

  269. 

  270.     public final void end_block() {

  271.         impl.end_block();

  272.     }

  273. 

  274.     public final void putEndian() {

  275.         impl.putEndian();

  276.     }

  277. 

  278.     public void writeTo(java.io.OutputStream s)

  279. 	throws IOException 

  280.     {

  281.         impl.writeTo(s);

  282.     }

  283. 

  284.     public final byte[] toByteArray() {

  285.         return impl.toByteArray();

  286.     }

  287. 

  288.     // org.omg.CORBA.DataOutputStream

  289.     public final void write_Abstract (java.lang.Object value) {

  290.         impl.write_Abstract(value);

  291.     }

  292. 

  293.     public final void write_Value (java.io.Serializable value) {

  294.         impl.write_Value(value);

  295.     }

  296. 

  297.     public final void write_any_array(org.omg.CORBA.Any[] seq, int offset, int length) {

  298.         impl.write_any_array(seq, offset, length);

  299.     }

  300. 

  301.     public void setMessageMediator(MessageMediator messageMediator)

  302.     {

  303.         this.corbaMessageMediator = (CorbaMessageMediator) messageMediator;

  304.     }

  305. 

  306.     public MessageMediator getMessageMediator()

  307.     {

  308.         return corbaMessageMediator;

  309.     }

  310. 

  311.     // org.omg.CORBA.portable.ValueBase

  312.     public final String[] _truncatable_ids() {

  313.         return impl._truncatable_ids();

  314.     }

  315. 

  316.     // Other

  317.     protected final int getSize() {

  318.         return impl.getSize();

  319.     }

  320. 

  321.     protected final int getIndex() {

  322.         return impl.getIndex();

  323.     }

  324. 

  325.     protected int getRealIndex(int index) {

  326.         // Used in indirections. Overridden by TypeCodeOutputStream.

  327.         return index;

  328.     }

  329. 

  330.     protected final void setIndex(int value) {

  331.         impl.setIndex(value);

  332.     }

  333. 

  334.     protected final ByteBuffer getByteBuffer() {

  335.         return impl.getByteBuffer();

  336.     }

  337. 

  338.     protected final void setByteBuffer(ByteBuffer byteBuffer) {

  339.         impl.setByteBuffer(byteBuffer);

  340.     }

  341. 

  342.     public final boolean isLittleEndian() {

  343.         return impl.isLittleEndian();

  344.     }

  345. 

  346.     // XREVISIT - return to final if possible

  347.     // REVISIT - was protected - need access from msgtypes test.

  348.     public ByteBufferWithInfo getByteBufferWithInfo() {

  349.         return impl.getByteBufferWithInfo();

  350.     }

  351. 

  352.     protected void setByteBufferWithInfo(ByteBufferWithInfo bbwi) {

  353.         impl.setByteBufferWithInfo(bbwi);

  354.     }

  355. 

  356.     // REVISIT: was protected - but need to access from xgiop.

  357.     public final BufferManagerWrite getBufferManager() {

  358.         return impl.getBufferManager();

  359.     }

  360. 

  361.     public final void write_fixed(java.math.BigDecimal bigDecimal, short digits, short scale) {

  362.         impl.write_fixed(bigDecimal, digits, scale);

  363.     }

  364. 

  365.     public final void writeOctetSequenceTo(org.omg.CORBA.portable.OutputStream s) {

  366.         impl.writeOctetSequenceTo(s);

  367.     }

  368. 

  369.     public final GIOPVersion getGIOPVersion() {

  370.         return impl.getGIOPVersion();

  371.     }

  372. 

  373.     public final void writeIndirection(int tag, int posIndirectedTo) {

  374.         impl.writeIndirection(tag, posIndirectedTo);

  375.     }

  376. 

  377.     // Use Latin-1 for GIOP 1.0 or when code set negotiation was not

  378.     // performed.

  379.     protected CodeSetConversion.CTBConverter createCharCTBConverter() {

  380.         return CodeSetConversion.impl().getCTBConverter(OSFCodeSetRegistry.ISO_8859_1);

  381.     }

  382. 

  383.     // Subclasses must decide what to do here.  It's inconvenient to

  384.     // make the class and this method abstract because of dup().

  385.     protected abstract CodeSetConversion.CTBConverter createWCharCTBConverter();

  386. 

  387.     protected final void freeInternalCaches() {

  388.         impl.freeInternalCaches();

  389.     }

  390. 

  391.     void printBuffer() {

  392.         impl.printBuffer();

  393.     }

  394. 

  395.     public void alignOnBoundary(int octetBoundary) {

  396.         impl.alignOnBoundary(octetBoundary);

  397.     }

  398. 

  399.     // Needed by request and reply messages for GIOP versions >= 1.2 only.

  400.     public void setHeaderPadding(boolean headerPadding) {

  401.         impl.setHeaderPadding(headerPadding);

  402.     }

  403. 

  404.     // ValueOutputStream -----------------------------

  405. 

  406.     public void start_value(String rep_id) {

  407.         impl.start_value(rep_id);

  408.     }

  409. 

  410.     public void end_value() {

  411.         impl.end_value();

  412.     }

  413. }