diff options
Diffstat (limited to 'lib/ic/java_src/com/ericsson/otp/ic/Any.java')
| -rw-r--r-- | lib/ic/java_src/com/ericsson/otp/ic/Any.java | 1026 |
1 files changed, 0 insertions, 1026 deletions
diff --git a/lib/ic/java_src/com/ericsson/otp/ic/Any.java b/lib/ic/java_src/com/ericsson/otp/ic/Any.java deleted file mode 100644 index d90b942877..0000000000 --- a/lib/ic/java_src/com/ericsson/otp/ic/Any.java +++ /dev/null @@ -1,1026 +0,0 @@ -/* - * %CopyrightBegin% - * - * Copyright Ericsson AB 1999-2016. All Rights Reserved. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - * - * %CopyrightEnd% - * - */ -package com.ericsson.otp.ic; - - -/** - -The Any class is the java mapping of the any OMG-IDL type. - - -**/ - - -public class Any { - - // Typecode value holder - protected TypeCode tcV; - - // Primitive value holder - protected java.lang.String stringV; - protected byte byteV; - protected boolean booleanV; - protected char charV; - protected short shortV; - protected int intV; - protected long longV; - protected float floatV; - protected double doubleV; - - // Streams used for user defined types - protected com.ericsson.otp.erlang.OtpInputStream is; - protected com.ericsson.otp.erlang.OtpOutputStream os; - - - // Constructor - public Any() { - tcV = null; - } - - // Equal function - - /** - Any comparison method - @return true if the input Any is equal to the object, false otherwize - **/ - public boolean equal(com.ericsson.otp.ic.Any _any) { - - int _is1Len,_is2Len; - byte _compressed[]; - com.ericsson.otp.erlang.OtpInputStream _is1,_is2; - TypeCode _tc = _any.type(); - - if (!tcV.equal(_tc)) - return false; - - try { - - TCKind _tck = _tc.kind(); - - switch (_tck.value()) { - - case TCKind._tk_short: - return (_any.extract_short() == shortV); - - case TCKind._tk_ushort: - return (_any.extract_ushort() == shortV); - - case TCKind._tk_long: - return (_any.extract_long() == intV); - - case TCKind._tk_longlong: - return (_any.extract_longlong() == longV); - - case TCKind._tk_ulong: - return (_any.extract_ulong() == intV); - - case TCKind._tk_ulonglong: - return (_any.extract_ulonglong() == longV); - - case TCKind._tk_float: - return equal(_any.extract_float(),floatV); - - case TCKind._tk_double: - return equal(_any.extract_double(),doubleV); - - case TCKind._tk_boolean: - return (_any.extract_boolean() == booleanV); - - case TCKind._tk_char: - return (_any.extract_char() == charV); - - case TCKind._tk_wchar: - return (_any.extract_wchar() == charV); - - case TCKind._tk_octet: - return (_any.extract_octet() == byteV); - - case TCKind._tk_string: - return (_any.extract_string().compareTo(stringV) == 0); - - case TCKind._tk_wstring: - return (_any.extract_wstring().compareTo(stringV) == 0); - - case TCKind._tk_sequence: - - _is1 = new com.ericsson.otp.erlang.OtpInputStream(os.toByteArray()); - - _is2 = _any.extract_Streamable(); - - if (_is1.peek() != _is2.peek()) { - - // _is1's sequence is compressed to string - if(_is1.peek() == com.ericsson.otp.erlang.OtpExternal.stringTag) { - - _compressed = (_is1.read_string()).getBytes(); - _is1Len = _compressed.length; - - _is2.read_list_head(); - - for(int i = 0; i < _is1Len; i++) { - if ((long)(_compressed[i] & 0xff) != _is2.read_long()) - return false; - } - - _is2.read_nil(); - } - else { // _is2's sequence is compressed to string - - _compressed = (_is2.read_string()).getBytes(); - _is2Len = _compressed.length; - - _is1.read_list_head(); - - for(int i = 0; i < _is2Len; i++) - if ((long)(_compressed[i] & 0xff) != _is1.read_long()) - return false; - - _is1.read_nil(); - } - } - else { // None of them is compressed - - _is2Len = _is2.available(); - - if (_is1.available() != _is2Len) - return false; - - for(int i = 0; i < _is2Len; i++) { - if (_is1.read() != _is2.read()) - return false; - } - } - - return true; - - case TCKind._tk_struct: - case TCKind._tk_union: - case TCKind._tk_array: - case TCKind._tk_enum: - - _is1 = new com.ericsson.otp.erlang.OtpInputStream(os.toByteArray()); - - _is2 = _any.extract_Streamable(); - - _is2Len = _is2.available(); - - if (_is1.available() != _is2Len) - return false; - - for(int i = 0; i < _is2Len; i++) { - if (_is1.read() != _is2.read()) - return false; - } - - return true; - - // Not used in real - case TCKind._tk_any: - case TCKind._tk_void: - case TCKind._tk_atom: - case TCKind._tk_null: - case TCKind._tk_TypeCode: - case TCKind._tk_Principal: - case TCKind._tk_objref: - case TCKind._tk_alias: - case TCKind._tk_except: - case TCKind._tk_longdouble: - case TCKind._tk_fixed: - return true; - - default : - return false; - - } - } catch (Exception e) { - //e.printStackTrace(); - return false; - } - - } - - - /* Equal function for floats ( relative diff ) */ - boolean equal(float x, float y) { - - if (x != 0) - return (java.lang.Math.abs((x-y)/x) < 1.0E-15); - - if (y != 0) - return (java.lang.Math.abs((y-x)/y) < 1.0E-15); - - return (x==y); - } - - /* Equal function for doubles ( relative diff ) */ - boolean equal(double x, double y) { - - if (x != 0) - return (java.lang.Math.abs((x-y)/x) < 1.0E-15); - - if (y != 0) - return (java.lang.Math.abs((y-x)/y) < 1.0E-15); - - return (x==y); - } - - - - /** - TypeCode accessor method - @return the Any's TypeCode - **/ - public TypeCode type() { - return tcV; - } - - - /** - TypeCode insertion method - **/ - public void type(TypeCode _tc) { - tcV = _tc; - } - - - /* Value accessors */ - - /** - Reads a value from the stream, according to the inserted TypeCode - **/ - public void read_value(com.ericsson.otp.erlang.OtpInputStream _is, - TypeCode _tc) - throws java.lang.Exception { - - tcV = _tc; - - switch(tcV.kind().value()) { - - case TCKind._tk_short : - shortV = _is.read_short(); - break; - case TCKind._tk_ushort : - shortV = _is.read_ushort(); - break; - case TCKind._tk_long : - intV = _is.read_int(); - break; - case TCKind._tk_ulong : - intV = _is.read_uint(); - break; - case TCKind._tk_longlong : - longV = _is.read_long(); - break; - case TCKind._tk_ulonglong : - longV = _is.read_ulong(); - break; - case TCKind._tk_float : - floatV = _is.read_float(); - break; - case TCKind._tk_double : - doubleV = _is.read_double(); - break; - case TCKind._tk_boolean : - booleanV = _is.read_boolean(); - break; - case TCKind._tk_char : - case TCKind._tk_wchar : - charV = _is.read_char(); - break; - case TCKind._tk_octet : - byteV = _is.read_byte(); - break; - case TCKind._tk_string : - case TCKind._tk_wstring : - stringV = _is.read_string(); - break; - case TCKind._tk_atom : - stringV = _is.read_atom(); - break; - case TCKind._tk_void : - _is.read_atom(); - break; - - /* - * Not supported types - */ - case TCKind._tk_any : - case TCKind._tk_null : - case TCKind._tk_TypeCode : - case TCKind._tk_Principal : - case TCKind._tk_objref : - case TCKind._tk_alias : - case TCKind._tk_except : - case TCKind._tk_longdouble : - case TCKind._tk_fixed : - throw new java.lang.Exception("Unsupported type"); - - default: // User defined type - - if (os == null) - os = new com.ericsson.otp.erlang.OtpOutputStream(); - else - os.reset(); - - try { - read_user_defined(_is, _tc); - is = new com.ericsson.otp.erlang.OtpInputStream(os.toByteArray()); - } catch (Exception e) { - throw new java.lang.Exception("BAD VALUE"); - } - } - - } - - void read_user_defined(com.ericsson.otp.erlang.OtpInputStream _is, TypeCode _tc) - throws java.lang.Exception { - - TypeCode memberTC = null; - int len = -1; - int __tag; - - switch(_tc.kind().value()) { - - case TCKind._tk_short : - os.write_short(_is.read_short()); - break; - case TCKind._tk_ushort : - os.write_ushort(_is.read_ushort()); - break; - case TCKind._tk_long : - os.write_int(_is.read_int()); - break; - case TCKind._tk_longlong : - os.write_long(_is.read_long()); - break; - case TCKind._tk_ulong : - os.write_uint(_is.read_uint()); - break; - case TCKind._tk_ulonglong : - os.write_ulong(_is.read_ulong()); - break; - case TCKind._tk_float : - os.write_float(_is.read_float()); - break; - case TCKind._tk_double : - os.write_double(_is.read_double()); - break; - case TCKind._tk_boolean : - os.write_boolean(_is.read_boolean()); - break; - case TCKind._tk_char : - case TCKind._tk_wchar : - os.write_char(_is.read_char()); - break; - case TCKind._tk_octet : - os.write_byte(_is.read_byte()); - break; - case TCKind._tk_string : - case TCKind._tk_wstring : - os.write_string(_is.read_string()); - break; - - case TCKind._tk_struct: - len = _is.read_tuple_head(); - os.write_tuple_head(len); - os.write_atom(_is.read_atom()); - // Member list - len -=1; - for(int i=0; i<len; i++) - read_user_defined(_is,_tc.member_type(i)); - break; - - case TCKind._tk_union: - os.write_tuple_head(_is.read_tuple_head()); - os.write_atom(_is.read_atom()); - - int __mlen = _tc.member_count(); - __tag = _is.peek(); - boolean __found = false; - - switch (__tag) { - case (com.ericsson.otp.erlang.OtpExternal.atomTag): - case (com.ericsson.otp.erlang.OtpExternal.atomUtf8Tag): - case (com.ericsson.otp.erlang.OtpExternal.smallAtomUtf8Tag): - java.lang.String __elabel = _is.read_atom(); // Enumerant or Boolean - os.write_atom(__elabel); - - for (int i=0; i<__mlen; i++) { - java.lang.String __mlabel; - if (_tc.member_label(i).type().kind().value() == TCKind._tk_string) - __mlabel = _tc.member_label(i).extract_string(); - else // Default - __mlabel = _tc.member_label(i).extract_atom(); - - if (__elabel.compareTo(__mlabel)==0) { - read_user_defined(_is,_tc.member_type(i)); - i = __mlen; - __found = true; - } - } - break; - - default: // Integer type - long __ilabel = _is.read_long(); - os.write_long(__ilabel); - - for (int i=0; i<__mlen; i++) { - boolean __itype = true; - long __mlabel = 0; - - switch (_tc.member_label(i).type().kind().value()) { - - case TCKind._tk_short : - __mlabel = _tc.member_label(i).extract_short(); - break; - case TCKind._tk_ushort : - __mlabel = _tc.member_label(i).extract_ushort(); - break; - case TCKind._tk_long : - __mlabel = _tc.member_label(i).extract_long(); - break; - case TCKind._tk_longlong : - __mlabel = _tc.member_label(i).extract_longlong(); - break; - case TCKind._tk_ulong : - __mlabel = _tc.member_label(i).extract_ulong(); - break; - case TCKind._tk_ulonglong : - __mlabel = _tc.member_label(i).extract_ulonglong(); - break; - case TCKind._tk_char : - __mlabel = _tc.member_label(i).extract_char(); - break; - case TCKind._tk_wchar : - __mlabel = _tc.member_label(i).extract_wchar(); - break; - - default : // Default label - __itype = false; - - } - - if (__itype) { - if (__ilabel == __mlabel) { - read_user_defined(_is,_tc.member_type(i)); - i = __mlen; - __found = true; - } - } - } - } - - // Use the default label instead - if (!__found) - read_user_defined(_is,_tc.member_type(_tc.default_index())); - - break; - - case TCKind._tk_sequence: - __tag = _is.peek(); - - switch(__tag) { - case com.ericsson.otp.erlang.OtpExternal.stringTag: - os.write_string(_is.read_string()); - break; - default: - len = _is.read_list_head(); - os.write_list_head(len); - - for (int i=0; i<len; i++) - read_user_defined(_is,_tc.content_type()); - - _is.read_nil(); - os.write_nil(); - } - break; - - case TCKind._tk_array: - len = _is.read_tuple_head(); - os.write_tuple_head(len); - for (int i=0; i<len; i++) - read_user_defined(_is,_tc.content_type()); - break; - - case TCKind._tk_enum: - os.write_atom(_is.read_atom()); - break; - - case TCKind._tk_void : - os.write_atom(_is.read_atom()); - break; - - case TCKind._tk_any : - AnyHelper.marshal(os,AnyHelper.unmarshal(_is)); - break; - - /* - * Not supported types - */ - default : - throw new java.lang.Exception(""); - - } - - } - - - /** - Writes the Any's value to the ouput stream - **/ - public void write_value(com.ericsson.otp.erlang.OtpOutputStream _os) - throws java.lang.Exception { - - switch(tcV.kind().value()) { - - case TCKind._tk_short : - _os.write_short(shortV); - break; - case TCKind._tk_ushort : - _os.write_ushort(shortV); - break; - case TCKind._tk_long : - _os.write_int(intV); - break; - case TCKind._tk_ulong : - _os.write_uint(intV); - break; - case TCKind._tk_longlong : - _os.write_long(longV); - break; - case TCKind._tk_ulonglong : - _os.write_ulong(longV); - break; - case TCKind._tk_float : - _os.write_float(floatV); - break; - case TCKind._tk_double : - _os.write_double(doubleV); - break; - case TCKind._tk_boolean : - _os.write_boolean(booleanV); - break; - case TCKind._tk_char : - case TCKind._tk_wchar : - _os.write_char(charV); - break; - case TCKind._tk_octet : - _os.write_byte(byteV); - break; - case TCKind._tk_string : - case TCKind._tk_wstring : - _os.write_string(stringV); - break; - case TCKind._tk_atom : - _os.write_atom(stringV); - break; - case TCKind._tk_void : - _os.write_atom("ok"); - break; - - /* - * Not supported types - */ - case TCKind._tk_any : - case TCKind._tk_null : - case TCKind._tk_TypeCode : - case TCKind._tk_Principal : - case TCKind._tk_objref : - case TCKind._tk_alias : - case TCKind._tk_except : - case TCKind._tk_longdouble : - case TCKind._tk_fixed : - throw new java.lang.Exception("BAD KIND"); - - default: - _os.write(os.toByteArray()); - } - } - - - /* - * Insert and extract each primitive type - */ - - /* short */ - - /** - Short value extractor method - @return short, the value of Any - **/ - public short extract_short() - throws java.lang.Exception { - if (tcV.kind() == TCKind.tk_short) - return shortV; - - throw new java.lang.Exception(""); - } - - /** - Short value insertion method - **/ - public void insert_short(short s) { - shortV = s; - tcV = new TypeCode(TCKind.tk_short); - }; - - - /* long */ - /** - Long value extractor method - @return int, the value of Any - **/ - public int extract_long() - throws java.lang.Exception { - if (tcV.kind() == TCKind.tk_long) - return intV; - - throw new java.lang.Exception(""); - } - - /** - Long value insertion method - **/ - public void insert_long(int i){ - intV = i; - tcV = new TypeCode(TCKind.tk_long); - } - - - - /* long long */ - /** - Long Long value extractor method - @return long, the value of Any - **/ - public long extract_longlong() - throws java.lang.Exception { - if (tcV.kind() == TCKind.tk_longlong) - return longV; - - throw new java.lang.Exception(""); - } - - /** - Long Long value insertion method - **/ - public void insert_longlong(long l){ - longV = l; - tcV = new TypeCode(TCKind.tk_longlong); - } - - - /* ushort */ - /** - Unsigned Short value extractor method - @return short, the value of Any - **/ - public short extract_ushort() - throws java.lang.Exception { - if (tcV.kind() == TCKind.tk_ushort) - return shortV; - - throw new java.lang.Exception(""); - } - - /** - Unsigned Short value insertion method - **/ - public void insert_ushort(short s){ - shortV = s; - tcV = new TypeCode(TCKind.tk_ushort); - } - - - /* ulong */ - - /** - Unsigned Long value extractor method - @return int, the value of Any - **/ - public int extract_ulong() - throws java.lang.Exception{ - if (tcV.kind() == TCKind.tk_ulong) - return intV; - - throw new java.lang.Exception(""); - } - - /** - Unsigned Long value insertion method - **/ - public void insert_ulong(int i){ - intV = i; - tcV = new TypeCode(TCKind.tk_ulong); - } - - - - - /* unsigned long long */ - /** - Unsigned Long Long value extractor method - @return long, the value of Any - **/ - public long extract_ulonglong() - throws java.lang.Exception { - if (tcV.kind() == TCKind.tk_ulonglong) - return longV; - - throw new java.lang.Exception(""); - } - - /** - Unsigned Long Long value insertion method - **/ - public void insert_ulonglong(long l){ - longV = l; - tcV = new TypeCode(TCKind.tk_ulonglong); - } - - - /* float */ - /** - Float value extractor method - @return float, the value of Any - **/ - public float extract_float() - throws java.lang.Exception{ - if (tcV.kind() == TCKind.tk_float) - return floatV; - - throw new java.lang.Exception(""); - } - - /** - Float value insertion method - **/ - public void insert_float(float f){ - floatV = f; - tcV = new TypeCode(TCKind.tk_float); - } - - - /* double */ - /** - Double value extractor method - @return double, the value of Any - **/ - public double extract_double() - throws java.lang.Exception{ - if (tcV.kind() == TCKind.tk_double) - return doubleV; - - throw new java.lang.Exception(""); - } - - /** - Double value insertion method - **/ - public void insert_double(double d){ - doubleV = d; - tcV = new TypeCode(TCKind.tk_double); - } - - - /* boolean */ - /** - Boolean value extractor method - @return boolean, the value of Any - **/ - public boolean extract_boolean() - throws java.lang.Exception{ - if (tcV.kind() == TCKind.tk_boolean) - return booleanV; - - throw new java.lang.Exception(""); - } - - /** - Boolean value insertion method - **/ - public void insert_boolean(boolean b){ - booleanV = b; - tcV = new TypeCode(TCKind.tk_boolean); - } - - - - /* char */ - /** - Char value extractor method - @return char, the value of Any - **/ - public char extract_char() - throws java.lang.Exception{ - if (tcV.kind() == TCKind.tk_char) - return charV; - - throw new java.lang.Exception(""); - } - - /** - Char value insertion method - **/ - public void insert_char(char c) { - charV = c; - tcV = new TypeCode(TCKind.tk_char); - } - - - /* wchar */ - /** - Wchar value extractor method - @return char, the value of Any - **/ - public char extract_wchar() - throws java.lang.Exception{ - if (tcV.kind() == TCKind.tk_wchar) - return charV; - - throw new java.lang.Exception(""); - } - - /** - Wchar value insertion method - **/ - public void insert_wchar(char c) { - charV = c; - tcV = new TypeCode(TCKind.tk_wchar); - } - - - - /* octet */ - /** - Octet value extractor method - @return byte, the value of Any - **/ - public byte extract_octet() - throws java.lang.Exception{ - if (tcV.kind() == TCKind.tk_octet) - return byteV; - - throw new java.lang.Exception(""); - } - - /** - Octet value insertion method - **/ - public void insert_octet(byte b){ - byteV = b; - tcV = new TypeCode(TCKind.tk_octet); - } - - - /* string */ - /** - String value extractor method - @return String, the value of Any - **/ - public java.lang.String extract_string() - throws java.lang.Exception{ - if (tcV.kind() == TCKind.tk_string) - return stringV; - - throw new java.lang.Exception(""); - } - - /** - String value insertion method - **/ - public void insert_string(java.lang.String s) { - stringV = s; - tcV = new TypeCode(TCKind.tk_string); - } - - - - /* wstring */ - /** - Wstring value extractor method - @return String, the value of Any - **/ - public java.lang.String extract_wstring() - throws java.lang.Exception{ - if (tcV.kind() == TCKind.tk_wstring) - return stringV; - - throw new java.lang.Exception(""); - } - - /** - Wstring value insertion method - **/ - public void insert_wstring(java.lang.String s) { - stringV = s; - tcV = new TypeCode(TCKind.tk_wstring); - } - - - - /* atom */ - /** - Atom value extractor method - @return atom, the value of Any - **/ - public java.lang.String extract_atom() - throws java.lang.Exception{ - if (tcV.kind() == TCKind.tk_atom) - return stringV; - - throw new java.lang.Exception(""); - } - - /** - Atom value insertion method - **/ - public void insert_atom(java.lang.String s) { - stringV = s; - tcV = new TypeCode(TCKind.tk_atom); - } - - - /** - Object Stream insertion method - **/ - public void insert_Streamable(com.ericsson.otp.erlang.OtpOutputStream _os) { - os = _os; - } - - /** - Object Stream extractor method - @return OtpInputStream, the stream value of Any - **/ - public com.ericsson.otp.erlang.OtpInputStream extract_Streamable() { - - if (is == null) { - if (os == null) - return null; - else { - is = new com.ericsson.otp.erlang.OtpInputStream(os.toByteArray()); - } - } - - is.reset(); - return is; - } - -} - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - |