[Sblim-commit] jsr48-client/smpl/org/sblim/cimclient/samples Jsr48IndicationTester.java, 1.4, 1.5

[Dave H. <hel...@us...>]

Update of /cvsroot/sblim/jsr48-client/smpl/org/sblim/cimclient/samples
In directory sfp-cvs-1.v30.ch3.sourceforge.com:/tmp/cvs-serv23805/smpl/org/sblim/cimclient/samples

Modified Files:
	Jsr48IndicationTester.java 
Log Message:
2736 Add indication flood test options

Index: Jsr48IndicationTester.java
===================================================================
RCS file: /cvsroot/sblim/jsr48-client/smpl/org/sblim/cimclient/samples/Jsr48IndicationTester.java,v
retrieving revision 1.4
retrieving revision 1.5
diff -u -d -r1.4 -r1.5
--- Jsr48IndicationTester.java	21 Jun 2015 21:57:58 -0000	1.4
+++ Jsr48IndicationTester.java	21 Jun 2015 22:07:27 -0000	1.5
@@ -16,6 +16,7 @@
  * 3529066    2012-07-06  hellerda     Add Jsr48IndicationTester (initial version)
  *    2734    2014-05-16  hellerda     Support file:// URL in destination handler
  *    2735    2014-05-16  hellerda     Add configurable --wait time option
+ *    2736    2014-05-16  hellerda     Add indication flood test options
  */
 package org.sblim.cimclient.samples;
 
@@ -401,6 +402,11 @@
 		System.out.println("  --wait WAIT           Time to wait before shutting down and deleting the");
 		System.out.println("                        subscription. A value of 0 means wait indefinitely");
 		System.out.println("                        (register mode only. default: 0s)");
+		System.out.println("  --count COUNT         Number of indication triggers to send. A value of 0");
+		System.out.println("                        means send continously.");
+		System.out.println("                        (trigger mode only. default: 1)");
+		System.out.println("  --delay DELAY         Delay between indication triggers");
+		System.out.println("                        (trigger mode only. default: 1s)");
 	}
 
 	/**
@@ -563,18 +569,31 @@
 				return;
 			}
 
+			// Trigger the CIMOM to send a test indication to be caught by the listener
 			if (trigger) {
+				int count = doubleDashOpts.containsKey("--count") ? Integer.parseInt(doubleDashOpts
+						.get("--count")) : 1;
+				int delay = doubleDashOpts.containsKey("--delay") ? Integer.parseInt(doubleDashOpts
+						.get("--delay")) : 1;
+
+				if (count == 0) count = Integer.MAX_VALUE;
+				if (count == 1) delay = 0;
+
 				// SendTestIndication does not use any in/out parameters
 				CIMArgument<?>[] input = new CIMArgument[0];
 				CIMArgument<?>[] output = new CIMArgument[0];
 
-				// This will trigger a TestIndication that is caught by the
-				// remote listener
-				Object obj = client.invokeMethod(new CIMObjectPath(null, null, null, indicationNS,
-						indClassName, null), "SendTestIndication", input, output);
-				if (obj.toString().equals("0")) System.out
-						.println("Indication generated successfully.");
-				else System.out.println("Indication not generated successfully!");
+				for (int i = 1;; i++) {
+					System.out.println("Sending indication"
+							+ (count > 1 ? (" " + Integer.valueOf(i)) : "") + "...");
+					Object obj = client.invokeMethod(new CIMObjectPath(null, null, null,
+							indicationNS, indClassName, null), "SendTestIndication", input, output);
+					if (obj.toString().equals("0")) System.out
+							.println("Indication generated successfully.");
+					else System.out.println("Indication not generated successfully!");
+					if (i >= count) break;
+					Thread.sleep(1000 * delay);
+				}
 				System.exit(0);
 			}