term.java

来自「OTP是开放电信平台的简称」· Java 代码 · 共 1,108 行 · 第 1/2 页

/* ``The contents of this file are subject to the Erlang Public License,
 * Version 1.1, (the "License"); you may not use this file except in
 * compliance with the License. You should have received a copy of the
 * Erlang Public License along with this software. If not, it can be
 * retrieved via the world wide web at http://www.erlang.org/.
 * 
 * Software distributed under the License is distributed on an "AS IS"
 * basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
 * the License for the specific language governing rights and limitations
 * under the License.
 * 
 * The Initial Developer of the Original Code is Ericsson Utvecklings AB.
 * Portions created by Ericsson are Copyright 1999, Ericsson Utvecklings
 * AB. All Rights Reserved.''
 * 
 *     $Id$
 */
package com.ericsson.otp.ic;

/**

The Term class is intended to represent the erlang term generic type. 
It extends the Any class and is basically used the same way as the Any class.
<p>The main difference between Term and Any is the use of guard methods 
instead for TypeCode to determine the data included in the Term.
This actual when cannot determine a Term's value class returned at compile time.

**/

final public class Term extends Any { 

  // Primitive value holder
  protected java.lang.String atomV;
  protected long longV;
  protected Pid PidV;
  protected Ref RefV;
  protected Port PortV;
  protected com.ericsson.otp.erlang.OtpErlangObject ObjV;
  protected int tag;

  /**
    Tag accessor method
    @return int, the tag of the Object that denotes the erlang external format tag
  **/
  public int tag() {
    return tag;
  }

  /* Guards */

  /**
    Guard method
    @return true if the Term is an OtpErlangAtom, false otherwize 
  **/
  public boolean isAtom() {

    if (ObjV == null) { 
      if (tag == com.ericsson.otp.erlang.OtpExternal.atomTag)
	return true;

      return false;
    }

    return (ObjV instanceof com.ericsson.otp.erlang.OtpErlangAtom) ;
  }

  /**
    Guard method
    @return true if the Term is not an OtpErlangList nor an OtpErlangTuple, false otherwize 
  **/
  public boolean isConstant() {
    if (isList())
      return false;

    if (isTuple())
      return false;

    return true;
  }

  /**
    Guard method
    @return true if the Term is an OtpErlangFloat, false otherwize
  **/
  public boolean isFloat() {
    if (tag == com.ericsson.otp.erlang.OtpExternal.floatTag)
      return true;
    
    return false;
  }

  /**
    Guard method
    @return true if the Term is an OtpErlangInt, false otherwize 
  **/
  public boolean isInteger() {
    switch(tag) {
    case com.ericsson.otp.erlang.OtpExternal.smallIntTag:
    case com.ericsson.otp.erlang.OtpExternal.intTag:
    case com.ericsson.otp.erlang.OtpExternal.smallBigTag:
      return true;
    default:
      return false;
    }
  }

  /**
    Guard method
    @return true if the Term is an OtpErlangList, false otherwize 
  **/
  public boolean isList() {

    if (ObjV == null) {
      switch(tag) {
      case com.ericsson.otp.erlang.OtpExternal.listTag:
      case com.ericsson.otp.erlang.OtpExternal.stringTag:
      case com.ericsson.otp.erlang.OtpExternal.nilTag:
	return true;
      default:
	return false;
      }
    }

    if (ObjV instanceof com.ericsson.otp.erlang.OtpErlangList) 
      return true;

    if (ObjV instanceof com.ericsson.otp.erlang.OtpErlangString) 
      return true;

    return false;
  }


  /**
    Guard method
    @return true if the Term is an OtpErlangString, false otherwize 
  **/
  public boolean isString() {

    if (ObjV == null) {
      switch(tag) {
      case com.ericsson.otp.erlang.OtpExternal.stringTag:
      case com.ericsson.otp.erlang.OtpExternal.nilTag:
	return true;
      default:
	try {
	  stringV = extract_string();
	  return true;
	} catch (Exception e) {
	  return false;
	}
      }
    }

    if (ObjV instanceof com.ericsson.otp.erlang.OtpErlangString) 
      return true;

    try {
      stringV = extract_string();
      return true;
    } catch (Exception e) {
      return false;
    }
  }

  /**
    Guard method
    @return true if the Term is an OtpErlangInteger or an OtpErlangFloat, false otherwize 
  **/
  public boolean isNumber() {
    switch(tag) {
    case com.ericsson.otp.erlang.OtpExternal.smallIntTag:
    case com.ericsson.otp.erlang.OtpExternal.intTag:
    case com.ericsson.otp.erlang.OtpExternal.smallBigTag:
    case com.ericsson.otp.erlang.OtpExternal.floatTag:
	return true;
    default :
      return false;
    }
  }


  /**
    Guard method
    @return true if the Term is an OtpErlangPid or Pid, false otherwize 
  **/
  public boolean isPid() {
    
    if (ObjV == null) {
      if (tag == com.ericsson.otp.erlang.OtpExternal.pidTag)
	return true;
      
      return false;
    }

    return (ObjV instanceof com.ericsson.otp.erlang.OtpErlangPid) ;
  }


  /**
    Guard method
    @return true if the Term is an OtpErlangPort or Port, false otherwize 
  **/
  public boolean isPort() {
    if (ObjV == null) {
      if (tag == com.ericsson.otp.erlang.OtpExternal.portTag)
	return true;
      
      return false;
    }

    return (ObjV instanceof com.ericsson.otp.erlang.OtpErlangPort);
  }


  /**
    Guard method
    @return true if the Term is an OtpErlangRef, false otherwize 
  **/
  public boolean isReference() {    
    if (ObjV == null) {      
      switch(tag) {
      case com.ericsson.otp.erlang.OtpExternal.refTag:
      case com.ericsson.otp.erlang.OtpExternal.newRefTag:
	return true;
      default :
	return false;
      }
    }

    return (ObjV instanceof com.ericsson.otp.erlang.OtpErlangRef) ;
  }


  /**
    Guard method
    @return true if the Term is an OtpErlangTuple, false otherwize 
  **/
  public boolean isTuple() {
    if (ObjV == null) {      
      switch(tag) {
      case com.ericsson.otp.erlang.OtpExternal.smallTupleTag:
      case com.ericsson.otp.erlang.OtpExternal.largeTupleTag:
	return true;
      default :
	return false;
      }
    }
    
    return (ObjV instanceof com.ericsson.otp.erlang.OtpErlangTuple);
  }


  /**
    Guard method
    @return true if the Term is an OtpErlangBinary, false otherwize 
  **/
  public boolean isBinary() {
    if (ObjV == null) {
      if (tag == com.ericsson.otp.erlang.OtpExternal.binTag)
	return true;
      
      return false;
    }

    return (ObjV instanceof com.ericsson.otp.erlang.OtpErlangBinary);
  }

 


  // Equal function
  /**
    Term comparison method
    @return true if the input Term is equal to the object, false otherwize 
  **/
  public boolean equal(Term _any) {
    
    try {

      /* Pids */
      if ((PidV != null) && (_any.PidV != null))
	if (PidV.equal(_any.PidV))
	  return true;

      /* Refs */
      if ((RefV != null) && (_any.RefV != null))
	if (RefV.equal(_any.RefV))
	  return true;

      /* Ports */
      if ((PortV != null) && (_any.PortV != null))
	if (PortV.equals(_any.PortV))
	  return true;

      /* strings */
      if ((stringV != null) && (_any.stringV != null))
	if (stringV.equals(_any.stringV))
	  return true;

      /* atoms and booleans */
      if ((atomV != null) && (_any.atomV != null))
	if (atomV.equals(_any.atomV))
	  return true;

      /* booleans */
      if (atomV != null) 
	if (_any.booleanV == Boolean.valueOf(atomV).booleanValue())
	  return true;

      if (_any.atomV != null) 
	if (booleanV == Boolean.valueOf(_any.atomV).booleanValue())
	  return true;     

      /* integer types plus floating point types */
      double _ownNS = 
	longV+doubleV;
      
      double _othersNS = 
	_any.longV+_any.doubleV;

      if ((equal(_ownNS,_othersNS)) &&
	  (!equal(_ownNS,0)))			     
	return true;

      /* All together, 0 or false */
      if ((equal(_ownNS,_othersNS)) &&
	  booleanV == _any.booleanV)			     
	return true;
	  
  
      return false;

    } catch (Exception e) {
      e.printStackTrace();
      return false;
    } 
  }

  /**
    Writes the value of Term to a stream 
  **/
  public void write_value(com.ericsson.otp.erlang.OtpOutputStream _os) 
    throws java.lang.Exception {
      
      if ((tcV == null) && (ObjV != null))
	_os.write_any(ObjV); // Type not generated by IC
      
      else {
	
	switch(tcV.kind().value()) {
	  
	case TCKind._tk_octet :
	case TCKind._tk_char : 
	case TCKind._tk_wchar : 
	case TCKind._tk_short :
	case TCKind._tk_ushort : 
	case TCKind._tk_long :
	case TCKind._tk_longlong :
	case TCKind._tk_ulong :
	case TCKind._tk_ulonglong :
	  _os.write_long(longV);
	  break;

	case TCKind._tk_float :
	  _os.write_double(doubleV);
	  break;

	case TCKind._tk_double :
	  _os.write_double(doubleV);
	  break;

	case TCKind._tk_boolean : 
	  _os.write_boolean(booleanV);
	  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_struct:
	  if (isPid())
	    PidHelper.marshal(_os, PidV);
	  else {
	    if (isReference())
	      RefHelper.marshal(_os, RefV);
	    else {
	      if (isPort())
		PortHelper.marshal(_os, PortV);
	      else
		_os.write(os.toByteArray());
	    }
	  }
	  break;

	case TCKind._tk_union:
	case TCKind._tk_array:
	case TCKind._tk_sequence:
	case TCKind._tk_enum:
	  _os.write(os.toByteArray());
	  break;
	  
	case TCKind._tk_void : 
	  _os.write_atom("ok");
	  break;
	  
	  /*
	   * Not supported types
	   */
	default:
	  throw new java.lang.Exception("BAD KIND");
	}
      }
  }
  
  
  
  /*
   * Insert and extract each primitive type
   */
  

  /* short */

  /**
    Short value extractor method
    @return short, the value of Term 
  **/
  public short extract_short() 
    throws java.lang.Exception {

      if (tcV == null)
	return (short) longV;
      
      if (tcV.kind() == TCKind.tk_short)
	return (short) longV;
      
      throw new java.lang.Exception("");
  }
  
  /**
    Short value insertion method
  **/
  public void insert_short(short s) {
    longV = s;
    tag = com.ericsson.otp.erlang.OtpExternal.intTag;
    tcV = new TypeCode(TCKind.tk_short);
  };

  /**
    Short value insertion method
  **/
  public void insert_short(long l) {
    longV = l;
    tag = com.ericsson.otp.erlang.OtpExternal.intTag;
    tcV = new TypeCode(TCKind.tk_short);
  };
  
  
  /* long */

  /**
    Long value extractor method
    @return int, the value of Term 
  **/
  public int extract_long() 
    throws java.lang.Exception {

      if (tcV == null)
	return (int) longV;

      if (tcV.kind() == TCKind.tk_long)
	return (int) longV;

      throw new java.lang.Exception("");
  }
  
  /**
    Long value insertion method
  **/
  public void insert_long(int i){
      longV = i;
      tag = com.ericsson.otp.erlang.OtpExternal.intTag;
      tcV = new TypeCode(TCKind.tk_long);
  } 

  /**
    Long value insertion method
  **/
  public void insert_long(long l){
      longV = l;
      tag = com.ericsson.otp.erlang.OtpExternal.intTag;
      tcV = new TypeCode(TCKind.tk_long);
  } 


  /* longlong */

  /**
    Long Long value extractor method
    @return long, the value of Term 
  **/
  public long extract_longlong() 
    throws java.lang.Exception {

      if (tcV == null)
	return longV;

      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;
      tag = com.ericsson.otp.erlang.OtpExternal.intTag;
      tcV = new TypeCode(TCKind.tk_longlong);
  } 
  

  /* ushort */

  /**
    Unsigned Short value extractor method
    @return short, the value of Term 
  **/
  public short extract_ushort() 
    throws java.lang.Exception {

      if (tcV == null)
	return (short) longV;

      if (tcV.kind() == TCKind.tk_ushort)
	return (short) longV;
      
      throw new java.lang.Exception("");
  }
   
  /**
    Unsigned Short value insertion method
  **/
  public void insert_ushort(short s){
      longV = s;
      tag = com.ericsson.otp.erlang.OtpExternal.intTag;