1 files changed, 170 insertions, 0 deletions
diff --git a/java/rasj/rnp/RnpDecoder.java b/java/rasj/rnp/RnpDecoder.java
new file mode 100644
index 0000000..5eea077
--- /dev/null
+++ b/java/rasj/rnp/RnpDecoder.java
@@ -0,0 +1,170 @@
+/*
+* This file is part of rasdaman community.
+*
+* Rasdaman community is free software: you can redistribute it and/or modify
+* it under the terms of the GNU General Public License as published by
+* the Free Software Foundation, either version 3 of the License, or
+* (at your option) any later version.
+*
+* Rasdaman community is distributed in the hope that it will be useful,
+* but WITHOUT ANY WARRANTY; without even the implied warranty of
+* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+* GNU General Public License for more details.
+*
+* You should have received a copy of the GNU General Public License
+* along with rasdaman community.  If not, see <http://www.gnu.org/licenses/>.
+*
+* Copyright 2003, 2004, 2005, 2006, 2007, 2008, 2009 Peter Baumann /
+rasdaman GmbH.
+*
+* For more information please see <http://www.rasdaman.org>
+* or contact Peter Baumann via <baumann@rasdaman.com>.
+*/
+/*************************************************************
+ * <pre>
+ *
+ * PURPOSE: 
+ *
+ *
+ *
+ * COMMENTS:
+ *
+ * </pre>
+ *********************************************************** */
+package rasj.rnp;
+
+import java.io.*;
+
+
+public class RnpDecoder
+  {
+    
+     public RnpMessage    message;
+     private RnpFragment  currentFragment;
+     private RnpParameter currentParameter;
+     private int          fragmentIndex;
+      
+     
+     RnpDecoder(RnpMessage rnpmessage)       
+        {
+        message=rnpmessage;  
+	currentFragment = null;
+	currentParameter = null;
+	fragmentIndex = 0;
+        } 
+     
+     void verify() throws RnpException
+	{
+	if(message.header.protocolId != Rnp.rnpProtocolId) 
+	       throw new RnpException("Not a RNP message");
+	    
+	if(message.header.messageEndianness != 0)
+	       throw new RnpException("Incorrect endianness");
+            
+	if(message.header.majorVersion != 1 || message.header.minorVersion != 0 || message.header.dataStart != RnpMessageHeader.length)
+	       throw new RnpException("Incorrect message version");
+	}
+
+     int getServerType()
+        {
+	return message.header.serverType;
+	}
+
+     byte getDesiredEndianness()
+        {
+	return message.header.desiredEndianness;
+	}
+
+     byte getMessageEndianness()
+        {
+	return message.header.messageEndianness;
+	}
+
+     int getMessageLength()
+        {  
+        return message.header.totalMessageLength;
+      	}
+     
+     int countFragments()
+        {
+        return message.header.nrFragments;
+	}
+     byte getMajorVersion()
+        {
+	return  message.header.majorVersion;
+	}
+     byte getMinorVersion()
+        {
+	return  message.header.minorVersion;
+	}
+		  
+     RnpFragment getFirstFragment()
+        {
+	fragmentIndex = 0;
+	currentFragment = (RnpFragment)message.fragments.get(0);
+	return currentFragment;
+	}
+
+    RnpFragment getNextFragment(RnpFragment fragment)
+        {
+	fragmentIndex++;
+	currentFragment = (RnpFragment)message.fragments.get(fragmentIndex);
+	return currentFragment;
+	}
+	
+    int getFragmentType()	
+        {
+	//fgt_None, fgt_Command, fgt_OkAnswer, fgt_Error, fgt_DiscardedRequest
+	return currentFragment.getFragmentType();
+	}
+    int countParameters()
+        {
+	return currentFragment.countParameters();
+	} 
+    RnpParameter getFirstParameter()
+        {
+	currentParameter = currentFragment.getFirstParameter();
+	return currentParameter;
+	}
+    RnpParameter getNextParameter()
+        {
+	currentParameter = currentFragment.getNextParameter();
+	return currentParameter;
+	}
+    int getParameterType() 
+        { 
+	return currentParameter.paramType; 
+        }
+   int getDataLength() 
+        { 
+	return currentParameter.getDataLength(); 
+        }
+		     
+    int getDataType()      
+        { 
+	// dtt_None,dtt_Asciiz, dtt_Int32,dtt_Double64, dtt_Opaque
+	return currentParameter.dataType;  
+	}
+	
+    int getDataAsInteger()
+        {
+	return ((ParameterInt32)currentParameter).data;
+        }
+    float getDataAsFloat()
+        {
+	return((ParameterFloat32)currentParameter).data;
+	} 
+    double getDataAsDouble()
+        {	
+	return((ParameterDouble64)currentParameter).data;
+	}
+    String getDataAsString()
+        {
+	return new String(((ParameterString)currentParameter).data);
+	}
+    byte[] getDataOpaque()
+        {
+	return((ParameterOpaque)currentParameter).data;
+	}				
+    }
+