perfsonar development work

Author: psnc.pikusa
Date: 2010-03-18 16:15:37 +0000 (Thu, 18 Mar 2010)
New Revision: 5554

Added:
   
trunk/perfsonar-java-rrd-ma/src/main/java/org/perfsonar/service/measurementArchive/rrdType/storage/rrd/DiscardsResponseGenerator.java
   
trunk/perfsonar-java-rrd-ma/src/main/java/org/perfsonar/service/measurementArchive/rrdType/storage/rrd/ErrorsResponseGenerator.java
Log:
Classes added to service discards and errors responses


Added: 
trunk/perfsonar-java-rrd-ma/src/main/java/org/perfsonar/service/measurementArchive/rrdType/storage/rrd/DiscardsResponseGenerator.java
===================================================================
--- 
trunk/perfsonar-java-rrd-ma/src/main/java/org/perfsonar/service/measurementArchive/rrdType/storage/rrd/DiscardsResponseGenerator.java
                               (rev 0)
+++ 
trunk/perfsonar-java-rrd-ma/src/main/java/org/perfsonar/service/measurementArchive/rrdType/storage/rrd/DiscardsResponseGenerator.java
       2010-03-18 16:15:37 UTC (rev 5554)
@@ -0,0 +1,57 @@
+package org.perfsonar.service.measurementArchive.rrdType.storage.rrd;
+
+import org.perfsonar.base2.service.exceptions.PerfSONARException;
+import org.perfsonar.base2.xml.Element;
+import org.perfsonar.base2.xml.nmwg.Data;
+
+import rrd.Rrd.FetchData;
+
+/**
+ * $Id: DiscardsResponseGenerator.java 4684 2010-03-18 17:00:33Z pikusa $
+ */
+public class DiscardsResponseGenerator implements ResponseGenerator {
+
+
+    public Data getResponse(FetchData fetchData,
+                            int dsNum,
+                            int rrdRows,
+                            String valueUnits)
+        throws PerfSONARException {
+
+        Data data = new Data();
+
+        try {
+
+            for (int i = 0; i < rrdRows; i++) {
+
+                if (i + 1 == rrdRows) break;
+
+                Element datum = new Element();
+                datum.setName("datum");
+                
datum.setNamespaceUri("http://ggf.org/ns/nmwg/characteristic/discards/2.0/";);
+                datum.setNamespacePrefix("discards");
+
+                datum.addAttribute("timeValue", 
Long.toString(fetchData.getTimestamp(i + 1)));
+                datum.addAttribute("timeType", "unix");
+                datum.addAttribute("value", 
Double.toString(fetchData.getValue(i, dsNum)));
+                if (valueUnits != null) datum.addAttribute("valueUnits", 
valueUnits);
+
+                data.addChild(datum);
+
+            }
+
+        } catch (Exception ex) {
+                throw new PerfSONARException(
+                    "rrd_file_exception",
+                    ex.toString());
+        }
+
+        //DEBUG
+        //System.out.println(rows+" rows read");
+
+        return data;
+
+    }
+
+
+} 

Added: 
trunk/perfsonar-java-rrd-ma/src/main/java/org/perfsonar/service/measurementArchive/rrdType/storage/rrd/ErrorsResponseGenerator.java
===================================================================
--- 
trunk/perfsonar-java-rrd-ma/src/main/java/org/perfsonar/service/measurementArchive/rrdType/storage/rrd/ErrorsResponseGenerator.java
                         (rev 0)
+++ 
trunk/perfsonar-java-rrd-ma/src/main/java/org/perfsonar/service/measurementArchive/rrdType/storage/rrd/ErrorsResponseGenerator.java
 2010-03-18 16:15:37 UTC (rev 5554)
@@ -0,0 +1,57 @@
+package org.perfsonar.service.measurementArchive.rrdType.storage.rrd;
+
+import org.perfsonar.base2.service.exceptions.PerfSONARException;
+import org.perfsonar.base2.xml.Element;
+import org.perfsonar.base2.xml.nmwg.Data;
+
+import rrd.Rrd.FetchData;
+
+/**
+ * $Id: ErrorsResponseGenerator.java 4684 2010-03-18 17:01:33Z pikusa $
+ */
+public class ErrorsResponseGenerator implements ResponseGenerator {
+
+
+    public Data getResponse(FetchData fetchData,
+                            int dsNum,
+                            int rrdRows,
+                            String valueUnits)
+        throws PerfSONARException {
+
+        Data data = new Data();
+
+        try {
+
+            for (int i = 0; i < rrdRows; i++) {
+
+                if (i + 1 == rrdRows) break;
+
+                Element datum = new Element();
+                datum.setName("datum");
+                
datum.setNamespaceUri("http://ggf.org/ns/nmwg/characteristic/errors/2.0/";);
+                datum.setNamespacePrefix("errors");
+
+                datum.addAttribute("timeValue", 
Long.toString(fetchData.getTimestamp(i + 1)));
+                datum.addAttribute("timeType", "unix");
+                datum.addAttribute("value", 
Double.toString(fetchData.getValue(i, dsNum)));
+                if (valueUnits != null) datum.addAttribute("valueUnits", 
valueUnits);
+
+                data.addChild(datum);
+
+            }
+
+        } catch (Exception ex) {
+                throw new PerfSONARException(
+                    "rrd_file_exception",
+                    ex.toString());
+        }
+
+        //DEBUG
+        //System.out.println(rows+" rows read");
+
+        return data;
+
+    }
+
+
+}