From: Sweidan Omar Date: Mon, 10 Jan 2022 10:53:07 +0000 (+0000) Subject: #308 X-Git-Url: http://git.useribm.hu/?a=commitdiff_plain;h=3aaeb1a5e0e7959f1109358f6183bf7786d1d857;p=mediacube.git #308 git-tfs-id: [http://tfs.userrendszerhaz.hu:8080/tfs/DefaultCollection]$/MediaCube;C32691 --- diff --git a/server/-product/production/LOCAL/jobs/steps/DummyTestStep1.java b/server/-product/production/LOCAL/jobs/steps/DummyTestStep1.java index 6adb0e6d..22b3ab97 100644 --- a/server/-product/production/LOCAL/jobs/steps/DummyTestStep1.java +++ b/server/-product/production/LOCAL/jobs/steps/DummyTestStep1.java @@ -12,6 +12,10 @@ public class DummyTestStep1 extends JobStep { int var1 = 0; if (param1.equals("Jozsi")) { var1 = 1; + Thread.sleep(1000); + setProgress(50); + Thread.sleep(1000); + setProgress(50); } return new Object[] {var1}; diff --git a/server/-product/production/LOCAL/jobs/steps/DummyTestStep2.java b/server/-product/production/LOCAL/jobs/steps/DummyTestStep2.java index 58431315..e7579f12 100644 --- a/server/-product/production/LOCAL/jobs/steps/DummyTestStep2.java +++ b/server/-product/production/LOCAL/jobs/steps/DummyTestStep2.java @@ -10,6 +10,10 @@ public class DummyTestStep2 extends JobStep { public Object[] execute(int var2) { logger.info("Executing DummyTestStep2"); long var3 = 0L; + Thread.sleep(1000); + setProgress(50); + Thread.sleep(1000); + setProgress(50); return new Object[] { var3 }; } diff --git a/server/-product/production/LOCAL/jobs/steps/DummyTestStep3.java b/server/-product/production/LOCAL/jobs/steps/DummyTestStep3.java index b3e061ab..93d76a75 100644 --- a/server/-product/production/LOCAL/jobs/steps/DummyTestStep3.java +++ b/server/-product/production/LOCAL/jobs/steps/DummyTestStep3.java @@ -8,6 +8,10 @@ public class DummyTestStep3 extends JobStep { @StepEntry public void execute(long var3) { + Thread.sleep(1000); + setProgress(50); + Thread.sleep(1000); + setProgress(50); logger.info("Executing DummyTestStep3"); } } diff --git a/server/user.jobengine.executors/src/user/jobengine/server/steps/DummyTestStep1.java b/server/user.jobengine.executors/src/user/jobengine/server/steps/DummyTestStep1.java index a9c323f3..a1d0bbd7 100644 --- a/server/user.jobengine.executors/src/user/jobengine/server/steps/DummyTestStep1.java +++ b/server/user.jobengine.executors/src/user/jobengine/server/steps/DummyTestStep1.java @@ -7,11 +7,15 @@ public class DummyTestStep1 extends JobStep { private static final Logger logger = LogManager.getLogger(DummyTestStep1.class); @StepEntry - public Object[] execute(String param1) { + public Object[] execute(String param1) throws InterruptedException { logger.info("Executing DummyTestStep1"); int var1 = 0; if (param1.equals("Jozsi")) { var1 = 1; + Thread.sleep(1000); + setProgress(50); + Thread.sleep(1000); + setProgress(50); } return new Object[] { var1 }; diff --git a/server/user.jobengine.executors/src/user/jobengine/server/steps/DummyTestStep2.java b/server/user.jobengine.executors/src/user/jobengine/server/steps/DummyTestStep2.java index 58431315..05ae690f 100644 --- a/server/user.jobengine.executors/src/user/jobengine/server/steps/DummyTestStep2.java +++ b/server/user.jobengine.executors/src/user/jobengine/server/steps/DummyTestStep2.java @@ -7,10 +7,13 @@ public class DummyTestStep2 extends JobStep { private static final Logger logger = LogManager.getLogger(DummyTestStep2.class); @StepEntry - public Object[] execute(int var2) { + public Object[] execute(int var2) throws InterruptedException { logger.info("Executing DummyTestStep2"); long var3 = 0L; - + Thread.sleep(1000); + setProgress(50); + Thread.sleep(1000); + setProgress(50); return new Object[] { var3 }; } } diff --git a/server/user.jobengine.executors/src/user/jobengine/server/steps/DummyTestStep3.java b/server/user.jobengine.executors/src/user/jobengine/server/steps/DummyTestStep3.java index b3e061ab..67322b19 100644 --- a/server/user.jobengine.executors/src/user/jobengine/server/steps/DummyTestStep3.java +++ b/server/user.jobengine.executors/src/user/jobengine/server/steps/DummyTestStep3.java @@ -7,7 +7,11 @@ public class DummyTestStep3 extends JobStep { private static final Logger logger = LogManager.getLogger(DummyTestStep3.class); @StepEntry - public void execute(long var3) { + public void execute(long var3) throws InterruptedException { + Thread.sleep(1000); + setProgress(50); + Thread.sleep(1000); + setProgress(50); logger.info("Executing DummyTestStep3"); } }