| 1 | package com.jsql.model.suspendable; | |
| 2 | ||
| 3 | import com.jsql.model.InjectionModel; | |
| 4 | import com.jsql.model.exception.JSqlException; | |
| 5 | import com.jsql.util.LogLevelUtil; | |
| 6 | import org.apache.logging.log4j.LogManager; | |
| 7 | import org.apache.logging.log4j.Logger; | |
| 8 | ||
| 9 | /** | |
| 10 | * A thread used to inject database ; stoppable and pausable. | |
| 11 | */ | |
| 12 | public abstract class AbstractSuspendable { | |
| 13 | | |
| 14 | private static final Logger LOGGER = LogManager.getRootLogger(); | |
| 15 | ||
| 16 | /** | |
| 17 | * Make the action to stop if true. | |
| 18 | */ | |
| 19 | private boolean isStopped = false; | |
| 20 | | |
| 21 | /** | |
| 22 | * Make the action to pause if true, else make it unpause. | |
| 23 | */ | |
| 24 | private boolean isPaused = false; | |
| 25 | ||
| 26 | protected final InjectionModel injectionModel; | |
| 27 | | |
| 28 | protected AbstractSuspendable(InjectionModel injectionModel) { | |
| 29 | this.injectionModel = injectionModel; | |
| 30 | } | |
| 31 | | |
| 32 | /** | |
| 33 | * The pausable/stoppable action. | |
| 34 | */ | |
| 35 | public abstract String run(Object... args) throws JSqlException; | |
| 36 | ||
| 37 | /** | |
| 38 | * Thread's states Pause and Stop are processed by this method.<br> | |
| 39 | * - Pause action in infinite loop if invoked while shouldPauseThread is set to true,<br> | |
| 40 | * - Return stop state. | |
| 41 | * @return Stop state | |
| 42 | */ | |
| 43 | public synchronized boolean isSuspended() { | |
| 44 | // Make application loop until shouldPauseThread is set to false by another user action | |
| 45 |
1
1. isSuspended : negated conditional → NO_COVERAGE |
while (this.isPaused) { |
| 46 | try { | |
| 47 |
1
1. isSuspended : removed call to java/lang/Object::wait → NO_COVERAGE |
this.wait(); |
| 48 | } catch (InterruptedException e) { | |
| 49 | LOGGER.log(LogLevelUtil.IGNORE, e, e); | |
| 50 |
1
1. isSuspended : removed call to java/lang/Thread::interrupt → NO_COVERAGE |
Thread.currentThread().interrupt(); |
| 51 | } | |
| 52 | } | |
| 53 |
3
1. isSuspended : negated conditional → NO_COVERAGE 2. isSuspended : replaced boolean return with true for com/jsql/model/suspendable/AbstractSuspendable::isSuspended → NO_COVERAGE 3. isSuspended : negated conditional → NO_COVERAGE |
return this.isStopped || this.injectionModel.isStoppedByUser(); // Return true if stop requested, else return false |
| 54 | } | |
| 55 | | |
| 56 | /** | |
| 57 | * Mark as stopped. | |
| 58 | */ | |
| 59 | public void stop() { | |
| 60 |
1
1. stop : removed call to com/jsql/model/suspendable/AbstractSuspendable::unpause → NO_COVERAGE |
this.unpause(); |
| 61 | this.isStopped = true; | |
| 62 | } | |
| 63 | | |
| 64 | /** | |
| 65 | * Mark as paused. | |
| 66 | */ | |
| 67 | public void pause() { | |
| 68 | this.isPaused = true; | |
| 69 | } | |
| 70 | | |
| 71 | /** | |
| 72 | * Mark as unpaused. | |
| 73 | */ | |
| 74 | public void unpause() { | |
| 75 | this.isPaused = false; | |
| 76 |
1
1. unpause : removed call to com/jsql/model/suspendable/AbstractSuspendable::resume → NO_COVERAGE |
this.resume(); // Restart the action after unpause |
| 77 | } | |
| 78 | | |
| 79 | /** | |
| 80 | * Return true if thread is paused, false otherwise. | |
| 81 | * @return Pause state | |
| 82 | */ | |
| 83 | public boolean isPaused() { | |
| 84 |
2
1. isPaused : replaced boolean return with false for com/jsql/model/suspendable/AbstractSuspendable::isPaused → NO_COVERAGE 2. isPaused : replaced boolean return with true for com/jsql/model/suspendable/AbstractSuspendable::isPaused → NO_COVERAGE |
return this.isPaused; |
| 85 | } | |
| 86 | | |
| 87 | /** | |
| 88 | * Wake threads. | |
| 89 | */ | |
| 90 | public synchronized void resume() { | |
| 91 |
1
1. resume : removed call to java/lang/Object::notifyAll → NO_COVERAGE |
this.notifyAll(); |
| 92 | } | |
| 93 | } | |
Mutations | ||
| 45 |
1.1 |
|
| 47 |
1.1 |
|
| 50 |
1.1 |
|
| 53 |
1.1 2.2 3.3 |
|
| 60 |
1.1 |
|
| 76 |
1.1 |
|
| 84 |
1.1 2.2 |
|
| 91 |
1.1 |