You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by cw...@apache.org on 2016/12/21 16:57:18 UTC
svn commit: r1775506 -
/uima/uima-ducc/trunk/uima-ducc-examples/src/main/java/org/apache/uima/ducc/test/randomsleep/FixedSleepAE.java
Author: cwiklik
Date: Wed Dec 21 16:57:17 2016
New Revision: 1775506
URL: http://svn.apache.org/viewvc?rev=1775506&view=rev
Log:
UIMA-5218
Modified:
uima/uima-ducc/trunk/uima-ducc-examples/src/main/java/org/apache/uima/ducc/test/randomsleep/FixedSleepAE.java
Modified: uima/uima-ducc/trunk/uima-ducc-examples/src/main/java/org/apache/uima/ducc/test/randomsleep/FixedSleepAE.java
URL: http://svn.apache.org/viewvc/uima/uima-ducc/trunk/uima-ducc-examples/src/main/java/org/apache/uima/ducc/test/randomsleep/FixedSleepAE.java?rev=1775506&r1=1775505&r2=1775506&view=diff
==============================================================================
--- uima/uima-ducc/trunk/uima-ducc-examples/src/main/java/org/apache/uima/ducc/test/randomsleep/FixedSleepAE.java (original)
+++ uima/uima-ducc/trunk/uima-ducc-examples/src/main/java/org/apache/uima/ducc/test/randomsleep/FixedSleepAE.java Wed Dec 21 16:57:17 2016
@@ -74,6 +74,7 @@ public class FixedSleepAE extends CasAnn
System.out.println("Is this nuts or what, no logger!");
}
+ forceCpuUsage();
if ( initComplete ) {
logger.log(Level.INFO, "Init bypassed in PID:TID " + pid + ":" + tid + ", already completed. ");
@@ -126,7 +127,7 @@ public class FixedSleepAE extends CasAnn
Runtime.getRuntime().halt(0);
}
}
-
+
if ( i_itime < 0 ) {
throw new IllegalArgumentException("Invalid AE_INIT_TIME, must be >= 0");
}
@@ -339,6 +340,29 @@ public class FixedSleepAE extends CasAnn
System.out.println(AE_Identifier + " Destroy exits");
}
+ private void forceCpuUsage() {
+ try{
+ if ( System.getenv( "FORCE_CPU_USAGE" ) != null ) {
+ Thread t = null;
+ t = new Thread(new Runnable() {
+ public void run() {
+ System.out.println("Thread " +Thread.currentThread().getName() + " started");
+ dolog(" >>>>>>>>>>> Simulating High CPU Load");
+ double val=10;
+ for (;;)
+ {
+ Math.atan(Math.sqrt(Math.pow(val, 10)));
+ }
+ }
+ });
+ t.start();
+ t.join();
+ }
+ } catch (InterruptedException e) {
+ // error = true;
+ }
+
+ }
@Override
public void process(CAS cas) throws AnalysisEngineProcessException
{
@@ -381,8 +405,27 @@ public class FixedSleepAE extends CasAnn
System.exit(1);
}
+ forceCpuUsage();
try{
- dolog(msgheader + " sleeping " + elapsed + " MS.");
+ /*
+ if ( System.getenv( "FORCE_CPU_USAGE" ) != null ) {
+ Thread t = null;
+ t = new Thread(new Runnable() {
+ public void run() {
+ System.out.println("Thread " +Thread.currentThread().getName() + " started");
+ dolog(" >>>>>>>>>>> Simulating High CPU Load");
+ double val=10;
+ for (;;)
+ {
+ Math.atan(Math.sqrt(Math.pow(val, 10)));
+ }
+ }
+ });
+ t.start();
+ t.join();
+ }
+ */
+ dolog(msgheader + " sleeping " + elapsed + " MS.");
String bloat = System.getenv("PROCESS_BLOAT");
if ( bloat != null ) {
long gb = Long.parseLong(bloat) * 1024 * 1024 * 1024;
@@ -394,6 +437,7 @@ public class FixedSleepAE extends CasAnn
randomError(exit_rate, msgheader, true);
Thread.sleep(elapsed);
+ //Thread.sleep(10000000);
completion = "OK";
dolog(msgheader + " returns after " + elapsed + " MS completion " + completion);
} catch (InterruptedException e) {