You are viewing a plain text version of this content. The canonical link for it is here.
Posted to java-dev@axis.apache.org by he...@apache.org on 2005/02/14 06:49:18 UTC
svn commit: r153718 - in
webservices/axis/trunk/java/dev/scratch/prototype2/src/samples/encoding/sample1/src:
Collecter.java EchoStub.java EndToEndTest.java
Author: hemapani
Date: Sun Feb 13 21:49:16 2005
New Revision: 153718
URL: http://svn.apache.org/viewcvs?view=rev&rev=153718
Log:
perf test classes
Added:
webservices/axis/trunk/java/dev/scratch/prototype2/src/samples/encoding/sample1/src/Collecter.java
webservices/axis/trunk/java/dev/scratch/prototype2/src/samples/encoding/sample1/src/EchoStub.java
webservices/axis/trunk/java/dev/scratch/prototype2/src/samples/encoding/sample1/src/EndToEndTest.java
Added: webservices/axis/trunk/java/dev/scratch/prototype2/src/samples/encoding/sample1/src/Collecter.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/dev/scratch/prototype2/src/samples/encoding/sample1/src/Collecter.java?view=auto&rev=153718
==============================================================================
--- webservices/axis/trunk/java/dev/scratch/prototype2/src/samples/encoding/sample1/src/Collecter.java (added)
+++ webservices/axis/trunk/java/dev/scratch/prototype2/src/samples/encoding/sample1/src/Collecter.java Sun Feb 13 21:49:16 2005
@@ -0,0 +1,51 @@
+import java.io.FileWriter;
+import java.io.IOException;
+import java.io.Writer;
+
+/*
+ * Created on Feb 10, 2005
+ *
+ * To change the template for this generated file go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+public class Collecter {
+ private static Writer writer = null;
+ private long[] results;
+ private int index = 0;
+ private String message = null;
+
+ public Collecter(int size, String message, Writer writer) throws IOException {
+ this.message = message;
+ Collecter.writer = writer;
+ results = new long[size];
+ }
+
+ public void add(long value) {
+ results[index] = value;
+ index++;
+ }
+
+ public void printResult() throws IOException {
+ int failed = 0;
+ long totel = 0;
+
+ for (int i = 0; i < results.length; i++) {
+
+ if (results[i] <= 0) {
+ failed++;
+ } else {
+ totel = totel + results[1];
+ }
+
+ }
+ System.out.println("Calls =" + results.length);
+ System.out.println("Faliure =" + failed);
+ System.out.println("Average =" + totel / (results.length - failed));
+ writer.write("--------------------------------------");
+ writer.write(message + "\n");
+ writer.write("Average =" + totel / (results.length - failed)+"\n");
+ writer.write("--------------------------------------");
+ writer.flush();
+ }
+
+}
Added: webservices/axis/trunk/java/dev/scratch/prototype2/src/samples/encoding/sample1/src/EchoStub.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/dev/scratch/prototype2/src/samples/encoding/sample1/src/EchoStub.java?view=auto&rev=153718
==============================================================================
--- webservices/axis/trunk/java/dev/scratch/prototype2/src/samples/encoding/sample1/src/EchoStub.java (added)
+++ webservices/axis/trunk/java/dev/scratch/prototype2/src/samples/encoding/sample1/src/EchoStub.java Sun Feb 13 21:49:16 2005
@@ -0,0 +1,82 @@
+import javax.xml.stream.XMLStreamConstants;
+import javax.xml.stream.XMLStreamReader;
+
+import org.apache.axis.addressing.AddressingConstants;
+import org.apache.axis.addressing.EndpointReference;
+import org.apache.axis.clientapi.Call;
+import org.apache.axis.om.OMConstants;
+import org.apache.axis.om.OMElement;
+import org.apache.axis.om.OMFactory;
+import org.apache.axis.om.OMNamespace;
+import org.apache.axis.om.SOAPBody;
+import org.apache.axis.om.SOAPEnvelope;
+import org.apache.axis.testUtils.ArrayTypeEncoder;
+import org.apache.axis.testUtils.ObjectToOMBuilder;
+
+public class EchoStub {
+ private OMFactory fac;
+ private OMNamespace ns =
+ fac.createOMNamespace("http://apache.ws.apache.org/samples", "samples");
+ private OMNamespace arrayNs =
+ fac.createOMNamespace(
+ OMConstants.ARRAY_ITEM_NSURI,
+ OMConstants.ARRAY_ITEM_NS_PREFIX);
+ OMNamespace targetNs = fac.createOMNamespace("http://axis.apache.org", "s");
+ public EchoStub() {
+ fac = OMFactory.newInstance();
+ }
+ public EchoStruct[] echoEchoStructArray(EchoStruct[] in) throws Exception {
+ OMElement returnelement = fac.createOMElement("param1", ns);
+ EchoStructEncoder encoder = new EchoStructEncoder();
+ ArrayTypeEncoder arrayEncoder = new ArrayTypeEncoder(in, encoder);
+
+ ObjectToOMBuilder builder =
+ new ObjectToOMBuilder(returnelement, arrayEncoder);
+
+ returnelement.setBuilder(builder);
+ returnelement.declareNamespace(arrayNs);
+ returnelement.declareNamespace(targetNs);
+
+ SOAPEnvelope envelope = fac.getDefaultEnvelope();
+ OMElement responseMethodName =
+ fac.createOMElement("echoEchoStructArray", ns);
+ envelope.getBody().addChild(responseMethodName);
+ responseMethodName.addChild(returnelement);
+
+ EndpointReference targetEPR =
+ new EndpointReference(
+ AddressingConstants.WSA_TO,
+ "http://127.0.0.1:8080/axis2/services/echo");
+ Call call = new Call();
+ call.setTo(targetEPR);
+ SOAPEnvelope responseEnv = call.sendReceive(envelope);
+
+ SOAPBody body = responseEnv.getBody();
+ if (body.hasFault()) {
+ throw body.getFault().getException();
+ }
+ XMLStreamReader xpp = body.getPullParser(true);
+
+ int event = xpp.next();
+ while (event != XMLStreamConstants.START_ELEMENT) {
+ event = xpp.next();
+ }
+ event = xpp.next();
+ while (event != XMLStreamConstants.START_ELEMENT) {
+ event = xpp.next();
+ }
+ event = xpp.next();
+ while (event != XMLStreamConstants.START_ELEMENT) {
+ event = xpp.next();
+ }
+
+ Object obj = arrayEncoder.deSerialize(xpp);
+ Object[] structs = (Object[]) obj;
+ EchoStruct[] response = new EchoStruct[structs.length];
+ for (int i = 0; i < structs.length; i++) {
+ response[i] = (EchoStruct) structs[i];
+
+ }
+ return response;
+ }
+}
Added: webservices/axis/trunk/java/dev/scratch/prototype2/src/samples/encoding/sample1/src/EndToEndTest.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/dev/scratch/prototype2/src/samples/encoding/sample1/src/EndToEndTest.java?view=auto&rev=153718
==============================================================================
--- webservices/axis/trunk/java/dev/scratch/prototype2/src/samples/encoding/sample1/src/EndToEndTest.java (added)
+++ webservices/axis/trunk/java/dev/scratch/prototype2/src/samples/encoding/sample1/src/EndToEndTest.java Sun Feb 13 21:49:16 2005
@@ -0,0 +1,49 @@
+import java.io.FileWriter;
+import java.io.IOException;
+import java.io.Writer;
+
+/*
+ * Created on Feb 9, 2005
+ *
+ * To change the template for this generated file go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+/**
+ * @author hemapani
+ *
+ * To change the template for this generated type comment go to
+ * Window>Preferences>Java>Code Generation>Code and Comments
+ */
+public class EndToEndTest {
+ private static int sizeOfArray = 10;
+ private static int numberOfRequests = 100;
+ private int no;
+ private static int THREAD_COUNT = 100;
+ private Collecter c;
+ public EndToEndTest(int no,Collecter c){
+ this.no = no;
+ }
+
+ public static void main(String[] args) throws IOException {
+
+ Writer writer = new FileWriter("results/results.txt");
+ writer.write("Axis2 Perf\n#########################\n");
+ int[] vals = new int[]{1, 10,100,1000};
+ for (int j = 0; j < vals.length; j++) {
+ Collecter c = new Collecter(100,"Array Size =" + vals[j],writer);
+ for (int i = 0; i < numberOfRequests; i++) {
+ try {
+ Sampler sampler = new Sampler(vals[j], c);
+ System.out.print(i + " = ");
+ sampler.invokeService();
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+ c.printResult();
+ }
+ writer.write("#########################\n");
+ writer.close();
+
+ }
+}