From aeea3597f64d35c71fa2ef7b0b904e695e71faaa Mon Sep 17 00:00:00 2001
From: Jan Waller <jwa@informatik.uni-kiel.de>
Date: Thu, 6 Feb 2014 13:48:42 +0100
Subject: [PATCH] Added choice for MonitoredClass * updatedheader to 2014 *
fixed typo
---
README | 2 +-
frameworks/Kieker/src/kieker/Logger.java | 2 +-
.../src/kieker/tcp/TestExperiment1.java | 2 +-
.../src/kieker/tcp/TestExperiment2.java | 2 +-
.../src/kieker/tcp/TestExperiment3.java | 2 +-
src/mooBench/benchmark/Benchmark.java | 16 +++++--
.../benchmark/BenchmarkingThread.java | 2 +-
.../monitoredApplication/MonitoredClass.java | 28 ++---------
.../MonitoredClassSimple.java | 43 +++++++++++++++++
.../MonitoredClassThreaded.java | 47 +++++++++++++++++++
10 files changed, 112 insertions(+), 34 deletions(-)
create mode 100644 src/mooBench/monitoredApplication/MonitoredClassSimple.java
create mode 100644 src/mooBench/monitoredApplication/MonitoredClassThreaded.java
diff --git a/README b/README
index 0b596b0..39d9a20 100644
--- a/README
+++ b/README
@@ -1,4 +1,4 @@
-The MooBench Monitoring OVerhead Benchmark
+The MooBench Monitoring Overhead Benchmark
------------------------------------------
This micro-benchmarks can be used to quantify the performance
diff --git a/frameworks/Kieker/src/kieker/Logger.java b/frameworks/Kieker/src/kieker/Logger.java
index da3b1da..5502935 100644
--- a/frameworks/Kieker/src/kieker/Logger.java
+++ b/frameworks/Kieker/src/kieker/Logger.java
@@ -1,5 +1,5 @@
/***************************************************************************
- * Copyright 2013 Kieker Project (http://kieker-monitoring.net)
+ * Copyright 2014 Kieker Project (http://kieker-monitoring.net)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/frameworks/Kieker/src/kieker/tcp/TestExperiment1.java b/frameworks/Kieker/src/kieker/tcp/TestExperiment1.java
index fa1a2ed..415c419 100644
--- a/frameworks/Kieker/src/kieker/tcp/TestExperiment1.java
+++ b/frameworks/Kieker/src/kieker/tcp/TestExperiment1.java
@@ -1,5 +1,5 @@
/***************************************************************************
- * Copyright 2013 Kieker Project (http://kieker-monitoring.net)
+ * Copyright 2014 Kieker Project (http://kieker-monitoring.net)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/frameworks/Kieker/src/kieker/tcp/TestExperiment2.java b/frameworks/Kieker/src/kieker/tcp/TestExperiment2.java
index 803dbf3..1a0a6aa 100644
--- a/frameworks/Kieker/src/kieker/tcp/TestExperiment2.java
+++ b/frameworks/Kieker/src/kieker/tcp/TestExperiment2.java
@@ -1,5 +1,5 @@
/***************************************************************************
- * Copyright 2013 Kieker Project (http://kieker-monitoring.net)
+ * Copyright 2014 Kieker Project (http://kieker-monitoring.net)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/frameworks/Kieker/src/kieker/tcp/TestExperiment3.java b/frameworks/Kieker/src/kieker/tcp/TestExperiment3.java
index ddac5da..702677d 100644
--- a/frameworks/Kieker/src/kieker/tcp/TestExperiment3.java
+++ b/frameworks/Kieker/src/kieker/tcp/TestExperiment3.java
@@ -1,5 +1,5 @@
/***************************************************************************
- * Copyright 2013 Kieker Project (http://kieker-monitoring.net)
+ * Copyright 2014 Kieker Project (http://kieker-monitoring.net)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/src/mooBench/benchmark/Benchmark.java b/src/mooBench/benchmark/Benchmark.java
index d6e0466..b543bd0 100644
--- a/src/mooBench/benchmark/Benchmark.java
+++ b/src/mooBench/benchmark/Benchmark.java
@@ -1,5 +1,5 @@
/***************************************************************************
- * Copyright 2013 Kieker Project (http://kieker-monitoring.net)
+ * Copyright 2014 Kieker Project (http://kieker-monitoring.net)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -30,6 +30,7 @@ import org.apache.commons.cli.OptionBuilder;
import org.apache.commons.cli.Options;
import mooBench.monitoredApplication.MonitoredClass;
+import mooBench.monitoredApplication.MonitoredClassThreaded;
/**
* @author Jan Waller
@@ -44,6 +45,7 @@ public final class Benchmark {
private static long methodTime = 0;
private static int recursionDepth = 0;
private static boolean quickstart = false;
+ private static MonitoredClass mc = null;
private Benchmark() {}
@@ -61,10 +63,9 @@ public final class Benchmark {
// 2. Initialize Threads and Classes
final CountDownLatch doneSignal = new CountDownLatch(Benchmark.totalThreads);
- final MonitoredClass mc = new MonitoredClass();
final BenchmarkingThread[] threads = new BenchmarkingThread[Benchmark.totalThreads];
for (int i = 0; i < Benchmark.totalThreads; i++) {
- threads[i] = new BenchmarkingThread(mc, Benchmark.totalCalls, Benchmark.methodTime, Benchmark.recursionDepth, doneSignal);
+ threads[i] = new BenchmarkingThread(Benchmark.mc, Benchmark.totalCalls, Benchmark.methodTime, Benchmark.recursionDepth, doneSignal);
threads[i].setName(String.valueOf(i + 1));
}
if (!quickstart) {
@@ -137,6 +138,9 @@ public final class Benchmark {
cmdlOpts.addOption(OptionBuilder.withLongOpt("runnable").withArgName("classname").hasArg(true).isRequired(false)
.withDescription("Class implementing the Runnable interface. run() method is executed before the benchmark starts.").withValueSeparator('=')
.create("r"));
+ cmdlOpts.addOption(OptionBuilder.withLongOpt("application").withArgName("classname").hasArg(true).isRequired(false)
+ .withDescription("Class implementing the MonitoredClass interface.").withValueSeparator('=')
+ .create("a"));
try {
CommandLine cmdl = null;
final CommandLineParser cmdlParser = new BasicParser();
@@ -148,6 +152,12 @@ public final class Benchmark {
Benchmark.recursionDepth = Integer.parseInt(cmdl.getOptionValue("recursiondepth"));
Benchmark.quickstart = cmdl.hasOption("quickstart");
Benchmark.ps = new PrintStream(new BufferedOutputStream(new FileOutputStream(Benchmark.outputFn, true), 8192 * 8), false, Benchmark.ENCODING);
+ final String application = cmdl.getOptionValue("application");
+ if (null != application) {
+ mc = ((MonitoredClass) Class.forName(application).newInstance());
+ } else {
+ mc = new MonitoredClassThreaded();
+ }
final String clazzname = cmdl.getOptionValue("runnable");
if (null != clazzname) {
((Runnable) Class.forName(clazzname).newInstance()).run();
diff --git a/src/mooBench/benchmark/BenchmarkingThread.java b/src/mooBench/benchmark/BenchmarkingThread.java
index 6f649e4..354fcd5 100644
--- a/src/mooBench/benchmark/BenchmarkingThread.java
+++ b/src/mooBench/benchmark/BenchmarkingThread.java
@@ -1,5 +1,5 @@
/***************************************************************************
- * Copyright 2013 Kieker Project (http://kieker-monitoring.net)
+ * Copyright 2014 Kieker Project (http://kieker-monitoring.net)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
diff --git a/src/mooBench/monitoredApplication/MonitoredClass.java b/src/mooBench/monitoredApplication/MonitoredClass.java
index b13c6fa..db4be42 100644
--- a/src/mooBench/monitoredApplication/MonitoredClass.java
+++ b/src/mooBench/monitoredApplication/MonitoredClass.java
@@ -1,5 +1,5 @@
/***************************************************************************
- * Copyright 2013 Kieker Project (http://kieker-monitoring.net)
+ * Copyright 2014 Kieker Project (http://kieker-monitoring.net)
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -16,32 +16,10 @@
package mooBench.monitoredApplication;
-import java.lang.management.ManagementFactory;
-import java.lang.management.ThreadMXBean;
-
/**
* @author Jan Waller
*/
-public final class MonitoredClass {
- private final ThreadMXBean threadMXBean = ManagementFactory.getThreadMXBean();
-
- /**
- * Default constructor.
- */
- public MonitoredClass() {
- // empty default constructor
- }
+public interface MonitoredClass {
- public final long monitoredMethod(final long methodTime, final int recDepth) {
- if (recDepth > 1) {
- return this.monitoredMethod(methodTime, recDepth - 1);
- } else {
- final long exitTime = this.threadMXBean.getCurrentThreadUserTime() + methodTime;
- long currentTime;
- do {
- currentTime = this.threadMXBean.getCurrentThreadUserTime();
- } while (currentTime < exitTime);
- return currentTime;
- }
- }
+ public long monitoredMethod(final long methodTime, final int recDepth);
}
diff --git a/src/mooBench/monitoredApplication/MonitoredClassSimple.java b/src/mooBench/monitoredApplication/MonitoredClassSimple.java
new file mode 100644
index 0000000..3227e38
--- /dev/null
+++ b/src/mooBench/monitoredApplication/MonitoredClassSimple.java
@@ -0,0 +1,43 @@
+/***************************************************************************
+ * Copyright 2014 Kieker Project (http://kieker-monitoring.net)
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ ***************************************************************************/
+
+package mooBench.monitoredApplication;
+
+/**
+ * @author Jan Waller
+ */
+public final class MonitoredClassSimple implements MonitoredClass {
+
+ /**
+ * Default constructor.
+ */
+ public MonitoredClassSimple() {
+ // empty default constructor
+ }
+
+ public final long monitoredMethod(final long methodTime, final int recDepth) {
+ if (recDepth > 1) {
+ return this.monitoredMethod(methodTime, recDepth - 1);
+ } else {
+ final long exitTime = System.nanoTime() + methodTime;
+ long currentTime;
+ do {
+ currentTime = System.nanoTime();
+ } while (currentTime < exitTime);
+ return currentTime;
+ }
+ }
+}
diff --git a/src/mooBench/monitoredApplication/MonitoredClassThreaded.java b/src/mooBench/monitoredApplication/MonitoredClassThreaded.java
new file mode 100644
index 0000000..869e0d8
--- /dev/null
+++ b/src/mooBench/monitoredApplication/MonitoredClassThreaded.java
@@ -0,0 +1,47 @@
+/***************************************************************************
+ * Copyright 2014 Kieker Project (http://kieker-monitoring.net)
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ ***************************************************************************/
+
+package mooBench.monitoredApplication;
+
+import java.lang.management.ManagementFactory;
+import java.lang.management.ThreadMXBean;
+
+/**
+ * @author Jan Waller
+ */
+public final class MonitoredClassThreaded implements MonitoredClass {
+ final ThreadMXBean threadMXBean = ManagementFactory.getThreadMXBean();
+
+ /**
+ * Default constructor.
+ */
+ public MonitoredClassThreaded() {
+ // empty default constructor
+ }
+
+ public final long monitoredMethod(final long methodTime, final int recDepth) {
+ if (recDepth > 1) {
+ return this.monitoredMethod(methodTime, recDepth - 1);
+ } else {
+ final long exitTime = this.threadMXBean.getCurrentThreadUserTime() + methodTime;
+ long currentTime;
+ do {
+ currentTime = this.threadMXBean.getCurrentThreadUserTime();
+ } while (currentTime < exitTime);
+ return currentTime;
+ }
+ }
+}
--
GitLab