1. /*

  2.  * @(#)TCUtility.java	1.24 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. /*

  8.  * Licensed Materials - Property of IBM

  9.  * RMI-IIOP v1.0

  10.  * Copyright IBM Corp. 1998 1999  All Rights Reserved

  11.  *

  12.  * US Government Users Restricted Rights - Use, duplication or

  13.  * disclosure restricted by GSA ADP Schedule Contract with IBM Corp.

  14.  */

  15. 

  16. package com.sun.corba.se.impl.corba;

  17. 

  18. import org.omg.CORBA.SystemException;

  19. import org.omg.CORBA.CompletionStatus;

  20. import org.omg.CORBA.UserException;

  21. import org.omg.CORBA.TCKind;

  22. import org.omg.CORBA.UNKNOWN;

  23. import org.omg.CORBA.INTERNAL;

  24. import org.omg.CORBA.NO_IMPLEMENT;

  25. import org.omg.CORBA.Any;

  26. import org.omg.CORBA.TypeCode;

  27. import org.omg.CORBA.Principal;

  28. import org.omg.CORBA_2_3.portable.InputStream;

  29. import org.omg.CORBA_2_3.portable.OutputStream;

  30. import org.omg.CORBA.portable.Streamable;

  31. import org.omg.CORBA.TypeCodePackage.BadKind;

  32. import java.util.Hashtable;

  33. import java.util.Enumeration;

  34. import java.util.NoSuchElementException;

  35. 

  36. import com.sun.corba.se.impl.encoding.CDRInputStream;

  37. import com.sun.corba.se.impl.encoding.CDROutputStream;

  38. import java.io.Serializable;

  39. import java.math.BigDecimal;

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

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

  42. 

  43. /**

  44.  *  Static functions for TypeCode interpretation.

  45.  */

  46. public final class TCUtility {

  47. 

  48.     static void marshalIn(org.omg.CORBA.portable.OutputStream s, TypeCode typeCode, long l, Object o) {

  49. 	switch (typeCode.kind().value()) {

  50. 	case TCKind._tk_null:

  51. 	case TCKind._tk_void:

  52.         case TCKind._tk_native:

  53. 	    // nothing to write

  54. 	    break;

  55. 

  56. 	case TCKind._tk_short:

  57. 	    s.write_short((short)(l & 0xFFFFL));

  58. 	    break;

  59. 

  60. 	case TCKind._tk_ushort:

  61. 	    s.write_ushort((short)(l & 0xFFFFL));

  62. 	    break;

  63. 

  64. 	case TCKind._tk_enum:

  65. 	case TCKind._tk_long:

  66. 	    s.write_long((int)(l & 0xFFFFFFFFL));

  67. 	    break;

  68. 

  69. 	case TCKind._tk_ulong:

  70. 	    s.write_ulong((int)(l & 0xFFFFFFFFL));

  71. 	    break;

  72. 

  73. 	case TCKind._tk_float:

  74. 	    s.write_float(Float.intBitsToFloat((int)(l & 0xFFFFFFFFL)));

  75. 	    break;

  76. 

  77. 	case TCKind._tk_double:

  78. 	    s.write_double(Double.longBitsToDouble(l));

  79. 	    break;

  80. 

  81. 	case TCKind._tk_boolean:

  82. 	    if ( l == 0 )

  83. 	        s.write_boolean(false);

  84. 	    else	

  85. 	        s.write_boolean(true);

  86. 	    break;

  87. 

  88. 	case TCKind._tk_char:

  89. 	    s.write_char((char)(l & 0xFFFFL));

  90. 	    break;

  91. 

  92. 	case TCKind._tk_octet:

  93. 	    s.write_octet((byte)(l & 0xFFL));

  94. 	    break;

  95. 

  96. 	case TCKind._tk_any:

  97. 	    s.write_any((Any)o);

  98. 	    break;

  99. 

  100. 	case TCKind._tk_TypeCode:

  101. 	    s.write_TypeCode((TypeCode)o);

  102. 	    break;

  103. 

  104. 	case TCKind._tk_Principal:

  105. 	    s.write_Principal((Principal)o);

  106. 	    break;

  107. 

  108. 	case TCKind._tk_objref:

  109. 	    s.write_Object((org.omg.CORBA.Object)o);

  110. 	    break;

  111. 

  112. 	case TCKind._tk_longlong:

  113. 	    s.write_longlong(l);

  114. 	    break;

  115. 

  116. 	case TCKind._tk_ulonglong:

  117. 	    s.write_ulonglong(l);

  118. 	    break;

  119. 

  120. 	case TCKind._tk_wchar:

  121. 	    s.write_wchar((char)(l & 0xFFFFL));

  122. 	    break;

  123. 

  124. 	case TCKind._tk_string:

  125. 	    s.write_string((String)o);

  126. 	    break;

  127. 

  128. 	case TCKind._tk_wstring:

  129. 	    s.write_wstring((String)o);

  130. 	    break;

  131. 

  132. 	case TCKind._tk_value:

  133. 	case TCKind._tk_value_box:

  134.             ((org.omg.CORBA_2_3.portable.OutputStream)s).write_value((Serializable)o);

  135. 	    break;

  136. 

  137. 	case TCKind._tk_fixed:

  138.             // _REVISIT_ As soon as the java-rtf adds digits and scale parameters to

  139.             // OutputStream, this check will be unnecessary

  140.             if (s instanceof CDROutputStream) {

  141.                 try {

  142.                     ((CDROutputStream)s).write_fixed((BigDecimal)o,

  143.                                                     typeCode.fixed_digits(),

  144.                                                     typeCode.fixed_scale());

  145.                 } catch (BadKind badKind) { // impossible

  146.                 }

  147.             } else {

  148.                 s.write_fixed((BigDecimal)o);

  149.             }

  150. 	    break;

  151. 

  152. 	case TCKind._tk_struct:

  153. 	case TCKind._tk_union:

  154. 	case TCKind._tk_sequence:

  155. 	case TCKind._tk_array:

  156. 	case TCKind._tk_alias:

  157. 	case TCKind._tk_except:

  158.             ((Streamable)o)._write(s);

  159. 	    break;

  160. 

  161. 	case TCKind._tk_abstract_interface:

  162.             ((org.omg.CORBA_2_3.portable.OutputStream)s).write_abstract_interface(o);

  163.             break;

  164. 

  165.         case TCKind._tk_longdouble:

  166.             // Unspecified for Java

  167.         default:

  168. 	    ORBUtilSystemException wrapper = ORBUtilSystemException.get( 

  169. 		(com.sun.corba.se.spi.orb.ORB)s.orb(),

  170. 		CORBALogDomains.RPC_PRESENTATION ) ;

  171. 	    throw wrapper.typecodeNotSupported() ;

  172.         }

  173.     }

  174. 

  175.     static void unmarshalIn(org.omg.CORBA.portable.InputStream s, TypeCode typeCode, long[] la, Object[] oa) 

  176.     {

  177.         int type = typeCode.kind().value();

  178. 	long l=0;

  179. 	Object o=oa[0];

  180. 

  181.         switch (type) {

  182. 	case TCKind._tk_null:

  183. 	case TCKind._tk_void:

  184.         case TCKind._tk_native:

  185. 	    // Nothing to read

  186. 	    break;

  187. 

  188. 	case TCKind._tk_short:

  189. 	    l = s.read_short() & 0xFFFFL;

  190. 	    break;

  191. 

  192. 	case TCKind._tk_ushort:

  193. 	    l = s.read_ushort() & 0xFFFFL;

  194. 	    break;

  195. 

  196. 	case TCKind._tk_enum:

  197. 	case TCKind._tk_long:

  198. 	    l = s.read_long() & 0xFFFFFFFFL;

  199. 	    break;

  200.  

  201. 	case TCKind._tk_ulong:

  202. 	    l = s.read_ulong() & 0xFFFFFFFFL;

  203.             break;  

  204.  

  205. 	case TCKind._tk_float:

  206. 	    l = Float.floatToIntBits(s.read_float()) & 0xFFFFFFFFL;

  207.             break;

  208.  

  209. 	case TCKind._tk_double:

  210. 	    l = Double.doubleToLongBits(s.read_double());

  211.             break;

  212.  

  213. 	case TCKind._tk_char:

  214.             l = s.read_char() & 0xFFFFL;

  215.             break;

  216. 

  217. 	case TCKind._tk_octet:

  218.             l = s.read_octet() & 0xFFL;

  219.             break;

  220. 

  221. 	case TCKind._tk_boolean:

  222.             if ( s.read_boolean() )

  223.                 l = 1;

  224. 	    else

  225.                 l = 0;

  226.             break;

  227. 

  228. 	case TCKind._tk_any:

  229.             o = s.read_any();

  230.             break;

  231. 

  232. 	case TCKind._tk_TypeCode:

  233. 	    o = s.read_TypeCode();

  234.             break;

  235. 

  236. 	case TCKind._tk_Principal:

  237.             o = s.read_Principal();

  238.             break;

  239. 

  240. 	case TCKind._tk_objref:

  241.             if (o instanceof Streamable)

  242.                 ((Streamable)o)._read(s);

  243.             else

  244.                 o = s.read_Object();

  245.             break;

  246.  

  247. 	case TCKind._tk_longlong:

  248.             l = s.read_longlong();

  249.             break;

  250.  

  251. 	case TCKind._tk_ulonglong:

  252.             l = s.read_ulonglong();

  253.             break;  

  254. 

  255. 	case TCKind._tk_wchar:

  256.             l = s.read_wchar() & 0xFFFFL;

  257.             break;

  258.  

  259. 	case TCKind._tk_string:

  260.             o = s.read_string();

  261.             break;

  262. 

  263. 	case TCKind._tk_wstring:

  264.             o = s.read_wstring();

  265.             break;

  266. 

  267. 	case TCKind._tk_value:

  268. 	case TCKind._tk_value_box:

  269.             o = ((org.omg.CORBA_2_3.portable.InputStream)s).read_value ();

  270.             break;

  271. 

  272. 	case TCKind._tk_fixed:

  273.             try {

  274.                 // _REVISIT_ As soon as the java-rtf adds digits and scale parameters to

  275.                 // InputStream, this check will be unnecessary

  276.                 if (s instanceof CDRInputStream) {

  277.                     o = ((CDRInputStream)s).read_fixed(typeCode.fixed_digits(),

  278.                                                                 typeCode.fixed_scale());

  279.                 } else {

  280.                     BigDecimal bigDecimal = s.read_fixed();

  281.                     o = bigDecimal.movePointLeft((int)typeCode.fixed_scale());

  282.                 }

  283.             } catch (BadKind badKind) { // impossible

  284.             }

  285.             break;

  286. 

  287. 	case TCKind._tk_struct:

  288. 	case TCKind._tk_union:

  289. 	case TCKind._tk_sequence:

  290. 	case TCKind._tk_array:

  291. 	case TCKind._tk_alias:

  292. 	case TCKind._tk_except:

  293.             ((Streamable)o)._read(s);

  294.             break;

  295. 

  296. 	case TCKind._tk_abstract_interface:

  297.             o = ((org.omg.CORBA_2_3.portable.InputStream)s).read_abstract_interface();

  298.             break;

  299. 

  300.         case TCKind._tk_longdouble:

  301.             // Unspecified for Java

  302.         default:

  303. 	    ORBUtilSystemException wrapper = ORBUtilSystemException.get( 

  304. 		(com.sun.corba.se.spi.orb.ORB)s.orb(),

  305. 		CORBALogDomains.RPC_PRESENTATION ) ;

  306. 	    throw wrapper.typecodeNotSupported() ;

  307.         }

  308. 

  309. 	oa[0] = o;

  310. 	la[0] = l;

  311.     }

  312. 

  313. }