|
1
|
|
package fr.sii.ogham.core.retry; |
|
2
|
|
|
|
3
|
|
import java.time.Instant; |
|
4
|
|
import java.util.List; |
|
5
|
|
|
|
6
|
|
/** |
|
7
|
|
* Retry several times with a fixed delay to wait after the last execution |
|
8
|
|
* failure until the maximum attempts is reached. A specific delay is used |
|
9
|
|
* between each execution. If there are more attempts than the configured |
|
10
|
|
* delays, the last delay is used for remaining attempts. |
|
11
|
|
* |
|
12
|
|
* If maximum attempts are set to 5 and delays are configured like this: |
|
13
|
|
* <ol> |
|
14
|
|
* <li>500ms</li> |
|
15
|
|
* <li>750ms</li> |
|
16
|
|
* <li>1800ms</li> |
|
17
|
|
* </ol> |
|
18
|
|
* |
|
19
|
|
* If the action (named "connect" for the example) takes 100ms to execute before |
|
20
|
|
* failing, here is what happens: |
|
21
|
|
* |
|
22
|
|
* <ul> |
|
23
|
|
* <li>0: connect</li> |
|
24
|
|
* <li>100: timeout</li> |
|
25
|
|
* <li>600: connect</li> |
|
26
|
|
* <li>700: timeout</li> |
|
27
|
|
* <li>1450: connect</li> |
|
28
|
|
* <li>1550: timeout</li> |
|
29
|
|
* <li>3350: connect</li> |
|
30
|
|
* <li>3450: timeout</li> |
|
31
|
|
* <li>5250: connect</li> |
|
32
|
|
* <li>5350: timeout</li> |
|
33
|
|
* <li>7150: connect</li> |
|
34
|
|
* <li>7250: timeout</li> |
|
35
|
|
* <li>fail</li> |
|
36
|
|
* </ul> |
|
37
|
|
* |
|
38
|
|
* |
|
39
|
|
* @author Aurélien Baudet |
|
40
|
|
* |
|
41
|
|
*/ |
|
42
|
|
public class PerExecutionDelayRetry implements RetryStrategy { |
|
43
|
|
private final int maxRetries; |
|
44
|
|
private final List<Long> delays; |
|
45
|
|
private int retries; |
|
46
|
|
private int delayIdx; |
|
47
|
|
|
|
48
|
|
/** |
|
49
|
|
* Initializes with the maximum attempts and the delays to wait after a |
|
50
|
|
* failure. |
|
51
|
|
* |
|
52
|
|
* @param maxRetries |
|
53
|
|
* the maximum attempts |
|
54
|
|
* @param delays |
|
55
|
|
* the delays to wait after failure to do another attempt |
|
56
|
|
*/ |
|
57
|
|
public PerExecutionDelayRetry(int maxRetries, List<Long> delays) { |
|
58
|
|
super(); |
|
59
|
|
this.maxRetries = maxRetries; |
|
60
|
|
this.delays = delays; |
|
61
|
|
retries = maxRetries; |
|
62
|
|
} |
|
63
|
|
|
|
64
|
|
@Override |
|
65
|
|
public boolean terminated() { |
|
66
|
9
1. terminated : replaced boolean return with true for fr/sii/ogham/core/retry/PerExecutionDelayRetry::terminated → NO_COVERAGE
2. terminated : changed conditional boundary → NO_COVERAGE
3. terminated : negated conditional → NO_COVERAGE
4. terminated : replaced boolean return with true for fr/sii/ogham/core/retry/PerExecutionDelayRetry::terminated → KILLED
5. terminated : replaced boolean return with true for fr/sii/ogham/core/retry/PerExecutionDelayRetry::terminated → KILLED
6. terminated : changed conditional boundary → KILLED
7. terminated : changed conditional boundary → KILLED
8. terminated : negated conditional → KILLED
9. terminated : negated conditional → KILLED
|
return retries <= 0; |
|
67
|
|
} |
|
68
|
|
|
|
69
|
|
@Override |
|
70
|
|
public Instant nextDate(Instant executionStartTime, Instant executionFailureTime) { |
|
71
|
3
1. nextDate : Replaced integer subtraction with addition → NO_COVERAGE
2. nextDate : Replaced integer subtraction with addition → TIMED_OUT
3. nextDate : Replaced integer subtraction with addition → KILLED
|
retries--; |
|
72
|
3
1. nextDate : replaced return value with null for fr/sii/ogham/core/retry/PerExecutionDelayRetry::nextDate → NO_COVERAGE
2. nextDate : replaced return value with null for fr/sii/ogham/core/retry/PerExecutionDelayRetry::nextDate → KILLED
3. nextDate : replaced return value with null for fr/sii/ogham/core/retry/PerExecutionDelayRetry::nextDate → KILLED
|
return executionFailureTime.plusMillis(getNextDelay()); |
|
73
|
|
} |
|
74
|
|
|
|
75
|
|
public int getRemainingRetries() { |
|
76
|
2
1. getRemainingRetries : replaced int return with 0 for fr/sii/ogham/core/retry/PerExecutionDelayRetry::getRemainingRetries → NO_COVERAGE
2. getRemainingRetries : replaced int return with 0 for fr/sii/ogham/core/retry/PerExecutionDelayRetry::getRemainingRetries → KILLED
|
return retries; |
|
77
|
|
} |
|
78
|
|
|
|
79
|
|
public int getMaxRetries() { |
|
80
|
1
1. getMaxRetries : replaced int return with 0 for fr/sii/ogham/core/retry/PerExecutionDelayRetry::getMaxRetries → NO_COVERAGE
|
return maxRetries; |
|
81
|
|
} |
|
82
|
|
|
|
83
|
|
public List<Long> getDelays() { |
|
84
|
1
1. getDelays : replaced return value with Collections.emptyList for fr/sii/ogham/core/retry/PerExecutionDelayRetry::getDelays → NO_COVERAGE
|
return delays; |
|
85
|
|
} |
|
86
|
|
|
|
87
|
|
private long getNextDelay() { |
|
88
|
6
1. getNextDelay : changed conditional boundary → NO_COVERAGE
2. getNextDelay : negated conditional → SURVIVED
3. getNextDelay : negated conditional → NO_COVERAGE
4. getNextDelay : changed conditional boundary → KILLED
5. getNextDelay : changed conditional boundary → KILLED
6. getNextDelay : negated conditional → KILLED
|
if (delayIdx >= delays.size()) { |
|
89
|
6
1. getNextDelay : Replaced integer subtraction with addition → NO_COVERAGE
2. getNextDelay : replaced long return with 0 for fr/sii/ogham/core/retry/PerExecutionDelayRetry::getNextDelay → SURVIVED
3. getNextDelay : replaced long return with 0 for fr/sii/ogham/core/retry/PerExecutionDelayRetry::getNextDelay → NO_COVERAGE
4. getNextDelay : Replaced integer subtraction with addition → KILLED
5. getNextDelay : Replaced integer subtraction with addition → KILLED
6. getNextDelay : replaced long return with 0 for fr/sii/ogham/core/retry/PerExecutionDelayRetry::getNextDelay → KILLED
|
return delays.get(delays.size() - 1); |
|
90
|
|
} |
|
91
|
|
long delay = delays.get(delayIdx); |
|
92
|
3
1. getNextDelay : Replaced integer addition with subtraction → NO_COVERAGE
2. getNextDelay : Replaced integer addition with subtraction → KILLED
3. getNextDelay : Replaced integer addition with subtraction → KILLED
|
delayIdx++; |
|
93
|
3
1. getNextDelay : replaced long return with 0 for fr/sii/ogham/core/retry/PerExecutionDelayRetry::getNextDelay → NO_COVERAGE
2. getNextDelay : replaced long return with 0 for fr/sii/ogham/core/retry/PerExecutionDelayRetry::getNextDelay → SURVIVED
3. getNextDelay : replaced long return with 0 for fr/sii/ogham/core/retry/PerExecutionDelayRetry::getNextDelay → KILLED
|
return delay; |
|
94
|
|
} |
|
95
|
|
} |
| | Mutations |
| 66 |
|
1.1
Location : terminated
Killed by : none replaced boolean return with true for fr/sii/ogham/core/retry/PerExecutionDelayRetry::terminated → NO_COVERAGE 2.2
Location : terminated
Killed by : oghamcloudhopper.it.SendTimeoutTest.connectionTimeoutPerExecutionRetry(oghamcloudhopper.it.SendTimeoutTest) replaced boolean return with true for fr/sii/ogham/core/retry/PerExecutionDelayRetry::terminated → KILLED 3.3
Location : terminated
Killed by : oghamcore.ut.core.retry.PerExecutionDelayRetryExecutorTest.callingTerminatedSeveralTimesShouldNotDecrementRemainingRetries(oghamcore.ut.core.retry.PerExecutionDelayRetryExecutorTest) replaced boolean return with true for fr/sii/ogham/core/retry/PerExecutionDelayRetry::terminated → KILLED 4.4
Location : terminated
Killed by : oghamcore.ut.core.retry.PerExecutionDelayRetryExecutorTest.reachMaximumAttempts(oghamcore.ut.core.retry.PerExecutionDelayRetryExecutorTest) changed conditional boundary → KILLED 5.5
Location : terminated
Killed by : none changed conditional boundary → NO_COVERAGE 6.6
Location : terminated
Killed by : oghamcloudhopper.it.SendTimeoutTest.connectionTimeoutPerExecutionRetry(oghamcloudhopper.it.SendTimeoutTest) changed conditional boundary → KILLED 7.7
Location : terminated
Killed by : none negated conditional → NO_COVERAGE 8.8
Location : terminated
Killed by : oghamcore.ut.core.retry.PerExecutionDelayRetryExecutorTest.callingTerminatedSeveralTimesShouldNotDecrementRemainingRetries(oghamcore.ut.core.retry.PerExecutionDelayRetryExecutorTest) negated conditional → KILLED 9.9
Location : terminated
Killed by : oghamcloudhopper.it.SendTimeoutTest.connectionTimeoutPerExecutionRetry(oghamcloudhopper.it.SendTimeoutTest) negated conditional → KILLED
|
| 71 |
|
1.1
Location : nextDate
Killed by : none Replaced integer subtraction with addition → TIMED_OUT 2.2
Location : nextDate
Killed by : none Replaced integer subtraction with addition → NO_COVERAGE 3.3
Location : nextDate
Killed by : oghamcore.ut.core.retry.PerExecutionDelayRetryExecutorTest.reachMaximumAttempts(oghamcore.ut.core.retry.PerExecutionDelayRetryExecutorTest) Replaced integer subtraction with addition → KILLED
|
| 72 |
|
1.1
Location : nextDate
Killed by : oghamcore.ut.core.retry.PerExecutionDelayRetryExecutorTest.reachMaximumAttempts(oghamcore.ut.core.retry.PerExecutionDelayRetryExecutorTest) replaced return value with null for fr/sii/ogham/core/retry/PerExecutionDelayRetry::nextDate → KILLED 2.2
Location : nextDate
Killed by : oghamcloudhopper.it.SendTimeoutTest.connectionTimeoutPerExecutionRetry(oghamcloudhopper.it.SendTimeoutTest) replaced return value with null for fr/sii/ogham/core/retry/PerExecutionDelayRetry::nextDate → KILLED 3.3
Location : nextDate
Killed by : none replaced return value with null for fr/sii/ogham/core/retry/PerExecutionDelayRetry::nextDate → NO_COVERAGE
|
| 76 |
|
1.1
Location : getRemainingRetries
Killed by : none replaced int return with 0 for fr/sii/ogham/core/retry/PerExecutionDelayRetry::getRemainingRetries → NO_COVERAGE 2.2
Location : getRemainingRetries
Killed by : oghamcore.ut.core.retry.PerExecutionDelayRetryExecutorTest.callingTerminatedSeveralTimesShouldNotDecrementRemainingRetries(oghamcore.ut.core.retry.PerExecutionDelayRetryExecutorTest) replaced int return with 0 for fr/sii/ogham/core/retry/PerExecutionDelayRetry::getRemainingRetries → KILLED
|
| 80 |
|
1.1
Location : getMaxRetries
Killed by : none replaced int return with 0 for fr/sii/ogham/core/retry/PerExecutionDelayRetry::getMaxRetries → NO_COVERAGE
|
| 84 |
|
1.1
Location : getDelays
Killed by : none replaced return value with Collections.emptyList for fr/sii/ogham/core/retry/PerExecutionDelayRetry::getDelays → NO_COVERAGE
|
| 88 |
|
1.1
Location : getNextDelay
Killed by : oghamcloudhopper.it.SendTimeoutTest.connectionTimeoutPerExecutionRetry(oghamcloudhopper.it.SendTimeoutTest) changed conditional boundary → KILLED 2.2
Location : getNextDelay
Killed by : oghamcore.ut.core.retry.PerExecutionDelayRetryExecutorTest.reachMaximumAttemptsWithLessDelays(oghamcore.ut.core.retry.PerExecutionDelayRetryExecutorTest) changed conditional boundary → KILLED 3.3
Location : getNextDelay
Killed by : none changed conditional boundary → NO_COVERAGE 4.4
Location : getNextDelay
Killed by : oghamcore.ut.core.retry.PerExecutionDelayRetryExecutorTest.reachMaximumAttempts(oghamcore.ut.core.retry.PerExecutionDelayRetryExecutorTest) negated conditional → KILLED 5.5
Location : getNextDelay
Killed by : none negated conditional → SURVIVED 6.6
Location : getNextDelay
Killed by : none negated conditional → NO_COVERAGE
|
| 89 |
|
1.1
Location : getNextDelay
Killed by : oghamcloudhopper.it.SendTimeoutTest.connectionTimeoutPerExecutionRetry(oghamcloudhopper.it.SendTimeoutTest) Replaced integer subtraction with addition → KILLED 2.2
Location : getNextDelay
Killed by : none Replaced integer subtraction with addition → NO_COVERAGE 3.3
Location : getNextDelay
Killed by : oghamcore.ut.core.retry.PerExecutionDelayRetryExecutorTest.reachMaximumAttemptsWithLessDelays(oghamcore.ut.core.retry.PerExecutionDelayRetryExecutorTest) Replaced integer subtraction with addition → KILLED 4.4
Location : getNextDelay
Killed by : oghamcore.ut.core.retry.PerExecutionDelayRetryExecutorTest.reachMaximumAttemptsWithLessDelays(oghamcore.ut.core.retry.PerExecutionDelayRetryExecutorTest) replaced long return with 0 for fr/sii/ogham/core/retry/PerExecutionDelayRetry::getNextDelay → KILLED 5.5
Location : getNextDelay
Killed by : none replaced long return with 0 for fr/sii/ogham/core/retry/PerExecutionDelayRetry::getNextDelay → SURVIVED 6.6
Location : getNextDelay
Killed by : none replaced long return with 0 for fr/sii/ogham/core/retry/PerExecutionDelayRetry::getNextDelay → NO_COVERAGE
|
| 92 |
|
1.1
Location : getNextDelay
Killed by : oghamcloudhopper.it.SendTimeoutTest.connectionTimeoutPerExecutionRetry(oghamcloudhopper.it.SendTimeoutTest) Replaced integer addition with subtraction → KILLED 2.2
Location : getNextDelay
Killed by : oghamcore.ut.core.retry.PerExecutionDelayRetryExecutorTest.reachMaximumAttempts(oghamcore.ut.core.retry.PerExecutionDelayRetryExecutorTest) Replaced integer addition with subtraction → KILLED 3.3
Location : getNextDelay
Killed by : none Replaced integer addition with subtraction → NO_COVERAGE
|
| 93 |
|
1.1
Location : getNextDelay
Killed by : none replaced long return with 0 for fr/sii/ogham/core/retry/PerExecutionDelayRetry::getNextDelay → NO_COVERAGE 2.2
Location : getNextDelay
Killed by : none replaced long return with 0 for fr/sii/ogham/core/retry/PerExecutionDelayRetry::getNextDelay → SURVIVED 3.3
Location : getNextDelay
Killed by : oghamcore.ut.core.retry.PerExecutionDelayRetryExecutorTest.reachMaximumAttempts(oghamcore.ut.core.retry.PerExecutionDelayRetryExecutorTest) replaced long return with 0 for fr/sii/ogham/core/retry/PerExecutionDelayRetry::getNextDelay → KILLED
|