Retry.java

package com.github.dakusui.actionunit.actions;

import com.github.dakusui.actionunit.core.Action;

import java.util.Formatter;
import java.util.concurrent.TimeUnit;

import static com.github.dakusui.actionunit.utils.Checks.requireArgument;
import static com.github.dakusui.actionunit.utils.InternalUtils.formatDuration;
import static com.github.dakusui.actionunit.utils.InternalUtils.formatNumberOfTimes;
import static java.util.Objects.requireNonNull;
import static java.util.concurrent.TimeUnit.SECONDS;

public interface Retry extends Action {

  Action perform();

  int times();

  Class<? extends Throwable> targetExceptionClass();

  long intervalInNanoseconds();

  default void accept(Visitor visitor) {
    visitor.visit(this);
  }

  @Override
  default void formatTo(Formatter formatter, int flags, int width, int precision) {
    formatter.format("retry %s in %s on %s",
        formatNumberOfTimes(times()),
        formatDuration(intervalInNanoseconds()),
        targetExceptionClass().getSimpleName()
    );
  }

  class Builder extends Action.Builder<Retry> {

    private final Action                     perform;
    private       int                        times                = 2;
    private       Class<? extends Throwable> targetExceptionClass = Exception.class;
    private       long                       interval             = 10;
    private       TimeUnit                   timeUnit             = SECONDS;

    public Builder(Action perform) {
      this.perform = requireNonNull(perform);
    }

    public Builder times(int times) {
      requireArgument(v -> v >= 0, times);
      this.times = times;
      return this;
    }

    public Builder on(Class<? extends Throwable> targetExceptionClass) {
      this.targetExceptionClass = requireNonNull(targetExceptionClass);
      return this;
    }

    public Builder withIntervalOf(long interval, TimeUnit timeUnit) {
      this.interval = requireArgument(v -> v > 0, interval);
      this.timeUnit = requireNonNull(timeUnit);
      return this;
    }

    @Override
    public Retry build() {
      return new Retry() {
        @Override
        public Action perform() {
          return Builder.this.perform;
        }

        @Override
        public int times() {
          return Builder.this.times;
        }

        @Override
        public Class<? extends Throwable> targetExceptionClass() {
          return Builder.this.targetExceptionClass;
        }

        @Override
        public long intervalInNanoseconds() {
          return timeUnit.toNanos(Builder.this.interval);
        }

        @Override
        public String toString() {
          return String.format("retry(%sx%dtimes)",
              formatDuration(intervalInNanoseconds()),
              times
          );
        }
      };
    }
  }
}














Active mutators

CONDITIONALS_BOUNDARY
EMPTY_RETURNS
FALSE_RETURNS
INCREMENTS
INVERT_NEGS
MATH
NEGATE_CONDITIONALS
NULL_RETURNS
PRIMITIVE_RETURNS
TRUE_RETURNS
VOID_METHOD_CALLS

Tests examined

com.github.dakusui.actionunit.scenarios.ActionSupportTest.print(com.github.dakusui.actionunit.scenarios.ActionSupportTest) (1 ms)
com.github.dakusui.actionunit.scenarios.CompatActionSupportTest.retryTest$failForever(com.github.dakusui.actionunit.scenarios.CompatActionSupportTest) (4 ms)
com.github.dakusui.actionunit.scenarios.ActionSupportTest.givenRetryWithPassingOnSecondTry$whenPerform$thenFinallyPass(com.github.dakusui.actionunit.scenarios.ActionSupportTest) (1002 ms)
com.github.dakusui.actionunit.scenarios.CompatActionSupportTest.retryTest$failOnce(com.github.dakusui.actionunit.scenarios.CompatActionSupportTest) (4 ms)
com.github.dakusui.actionunit.ut.actions.RetryTest.given0AsTimes$whenActionFails$thenRetryNotAttempted(com.github.dakusui.actionunit.ut.actions.RetryTest) (1003 ms)
com.github.dakusui.actionunit.examples.ExamplesTest$LoopWithRetryExampleTest.testExample(com.github.dakusui.actionunit.examples.ExamplesTest$LoopWithRetryExampleTest) (132 ms)
com.github.dakusui.actionunit.ut.actions.RetryTest.givenRetryOnNpe$whenNpeThrown$thenRetriedAndPassed(com.github.dakusui.actionunit.ut.actions.RetryTest) (5 ms)
com.github.dakusui.actionunit.ut.ActionVisitorTest.givenRetryAction$whenAccept$thenVisited(com.github.dakusui.actionunit.ut.ActionVisitorTest) (1 ms)
com.github.dakusui.actionunit.scenarios.ActionPrinterTest$StdOutErrTest$WithResultVariationTest.givenPassAfterRetryAction$whenPerformed$thenResultPrinted(com.github.dakusui.actionunit.scenarios.ActionPrinterTest$StdOutErrTest$WithResultVariationTest) (5 ms)
com.github.dakusui.actionunit.scenarios.ActionSupportTest.performAndReport(com.github.dakusui.actionunit.scenarios.ActionSupportTest) (3 ms)
com.github.dakusui.actionunit.ut.actions.cmd.CmdTest$AsCommander.givenEchoHelloWithTimeoutInOneMinutesAndRetryingTwice$whenPerformAsAction$thenPrinted(com.github.dakusui.actionunit.ut.actions.cmd.CmdTest$AsCommander) (2 ms)
com.github.dakusui.actionunit.ut.actions.TimeoutTest.givenNotEndingRetryActionInside$whenTimeoutOutside$thenTimeoutsAppropriately(com.github.dakusui.actionunit.ut.actions.TimeoutTest) (1005 ms)
com.github.dakusui.actionunit.scenarios.ActionSupportTest.givenRetryWithPassingAction$whenPerform$thenNoRetry(com.github.dakusui.actionunit.scenarios.ActionSupportTest) (0 ms)
com.github.dakusui.actionunit.ut.actions.RetryTest.givenNegativeTimes$whenCreated$thenExceptionThrown(com.github.dakusui.actionunit.ut.actions.RetryTest) (1 ms)
com.github.dakusui.actionunit.scenarios.ActionSupportTest.giveExampleScenarioThatThrowsError$whenPerform$thenExceptionThrown(com.github.dakusui.actionunit.scenarios.ActionSupportTest) (7 ms)
com.github.dakusui.actionunit.scenarios.Compat2ActionSupportTest$Example.main(com.github.dakusui.actionunit.scenarios.Compat2ActionSupportTest$Example) (5 ms)
com.github.dakusui.actionunit.scenarios.ActionPrinterTest$StdOutErrTest$WithResultVariationTest.givenFailingRetryAction$whenPerformed$thenResultPrinted(com.github.dakusui.actionunit.scenarios.ActionPrinterTest$StdOutErrTest$WithResultVariationTest) (8 ms)
com.github.dakusui.actionunit.scenarios.CompatActionSupportTest.givenRetryAction$whenDescribe$thenLooksNice(com.github.dakusui.actionunit.scenarios.CompatActionSupportTest) (1 ms)
com.github.dakusui.actionunit.scenarios.ActionPrinterTest$StdOutErrTest$WithResultVariationTest.givenRetryAction$whenPerformed$thenResultPrinted(com.github.dakusui.actionunit.scenarios.ActionPrinterTest$StdOutErrTest$WithResultVariationTest) (1 ms)
com.github.dakusui.actionunit.ut.actions.RetryTest.givenNegativeInterval$whenCreated$thenExceptionThrown(com.github.dakusui.actionunit.ut.actions.RetryTest) (1 ms)
com.github.dakusui.actionunit.ut.actions.TimeoutTest.issue92(com.github.dakusui.actionunit.ut.actions.TimeoutTest) (19 ms)
com.github.dakusui.actionunit.ut.actions.TimeoutTest.givenLongerTimeoutActionWhichHoldsNotEndingRetryAction$whenTimeoutOutside$thenOuterTimeoutUsed(com.github.dakusui.actionunit.ut.actions.TimeoutTest) (1006 ms)
com.github.dakusui.actionunit.ut.actions.TimeoutTest.givenShorterTimeoutActionWhichHoldsNotEndingRetryAction$whenTimeoutOutside$thenInnerTimeoutUsed(com.github.dakusui.actionunit.ut.actions.TimeoutTest) (103 ms)
com.github.dakusui.actionunit.ut.actions.RetryTest.givenRetryOnActionException$whenActionExceptionThrown$thenRetriedAndPassed(com.github.dakusui.actionunit.ut.actions.RetryTest) (6 ms)
com.github.dakusui.actionunit.scenarios.CompatActionSupportTest.retryTest(com.github.dakusui.actionunit.scenarios.CompatActionSupportTest) (2 ms)

Report generated by PIT 1.7.3

1		package com.github.dakusui.actionunit.actions;
2
3		import com.github.dakusui.actionunit.core.Action;
4
5		import java.util.Formatter;
6		import java.util.concurrent.TimeUnit;
7
8		import static com.github.dakusui.actionunit.utils.Checks.requireArgument;
9		import static com.github.dakusui.actionunit.utils.InternalUtils.formatDuration;
10		import static com.github.dakusui.actionunit.utils.InternalUtils.formatNumberOfTimes;
11		import static java.util.Objects.requireNonNull;
12		import static java.util.concurrent.TimeUnit.SECONDS;
13
14		public interface Retry extends Action {
15
16		Action perform();
17
18		int times();
19
20		Class<? extends Throwable> targetExceptionClass();
21
22		long intervalInNanoseconds();
23
24		default void accept(Visitor visitor) {
25	1 1. accept : removed call to com/github/dakusui/actionunit/core/Action$Visitor::visit → KILLED	visitor.visit(this);
26		}
27
28		@Override
29		default void formatTo(Formatter formatter, int flags, int width, int precision) {
30		formatter.format("retry %s in %s on %s",
31		formatNumberOfTimes(times()),
32		formatDuration(intervalInNanoseconds()),
33		targetExceptionClass().getSimpleName()
34		);
35		}
36
37		class Builder extends Action.Builder<Retry> {
38
39		private final Action perform;
40		private int times = 2;
41		private Class<? extends Throwable> targetExceptionClass = Exception.class;
42		private long interval = 10;
43		private TimeUnit timeUnit = SECONDS;
44
45		public Builder(Action perform) {
46		this.perform = requireNonNull(perform);
47		}
48
49		public Builder times(int times) {
50	3 1. lambda$times$0 : changed conditional boundary → KILLED 2. lambda$times$0 : negated conditional → KILLED 3. lambda$times$0 : replaced boolean return with true for com/github/dakusui/actionunit/actions/Retry$Builder::lambda$times$0 → KILLED	requireArgument(v -> v >= 0, times);
51		this.times = times;
52	1 1. times : replaced return value with null for com/github/dakusui/actionunit/actions/Retry$Builder::times → KILLED	return this;
53		}
54
55		public Builder on(Class<? extends Throwable> targetExceptionClass) {
56		this.targetExceptionClass = requireNonNull(targetExceptionClass);
57	1 1. on : replaced return value with null for com/github/dakusui/actionunit/actions/Retry$Builder::on → KILLED	return this;
58		}
59
60		public Builder withIntervalOf(long interval, TimeUnit timeUnit) {
61	3 1. lambda$withIntervalOf$1 : changed conditional boundary → SURVIVED 2. lambda$withIntervalOf$1 : negated conditional → KILLED 3. lambda$withIntervalOf$1 : replaced boolean return with true for com/github/dakusui/actionunit/actions/Retry$Builder::lambda$withIntervalOf$1 → KILLED	this.interval = requireArgument(v -> v > 0, interval);
62		this.timeUnit = requireNonNull(timeUnit);
63	1 1. withIntervalOf : replaced return value with null for com/github/dakusui/actionunit/actions/Retry$Builder::withIntervalOf → KILLED	return this;
64		}
65
66		@Override
67		public Retry build() {
68	1 1. build : replaced return value with null for com/github/dakusui/actionunit/actions/Retry$Builder::build → KILLED	return new Retry() {
69		@Override
70		public Action perform() {
71	1 1. perform : replaced return value with null for com/github/dakusui/actionunit/actions/Retry$Builder$1::perform → KILLED	return Builder.this.perform;
72		}
73
74		@Override
75		public int times() {
76	1 1. times : replaced int return with 0 for com/github/dakusui/actionunit/actions/Retry$Builder$1::times → KILLED	return Builder.this.times;
77		}
78
79		@Override
80		public Class<? extends Throwable> targetExceptionClass() {
81	1 1. targetExceptionClass : replaced return value with null for com/github/dakusui/actionunit/actions/Retry$Builder$1::targetExceptionClass → KILLED	return Builder.this.targetExceptionClass;
82		}
83
84		@Override
85		public long intervalInNanoseconds() {
86	1 1. intervalInNanoseconds : replaced long return with 0 for com/github/dakusui/actionunit/actions/Retry$Builder$1::intervalInNanoseconds → KILLED	return timeUnit.toNanos(Builder.this.interval);
87		}
88
89		@Override
90		public String toString() {
91	1 1. toString : replaced return value with "" for com/github/dakusui/actionunit/actions/Retry$Builder$1::toString → SURVIVED	return String.format("retry(%sx%dtimes)",
92		formatDuration(intervalInNanoseconds()),
93		times
94		);
95		}
96		};
97		}
98		}
99		}
		Mutations
25		1.1 Location : accept Killed by : com.github.dakusui.actionunit.scenarios.CompatActionSupportTest.retryTest(com.github.dakusui.actionunit.scenarios.CompatActionSupportTest) removed call to com/github/dakusui/actionunit/core/Action$Visitor::visit → KILLED
50		1.1 Location : lambda$times$0 Killed by : com.github.dakusui.actionunit.scenarios.CompatActionSupportTest.retryTest(com.github.dakusui.actionunit.scenarios.CompatActionSupportTest) changed conditional boundary → KILLED 2.2 Location : lambda$times$0 Killed by : com.github.dakusui.actionunit.ut.actions.RetryTest.givenNegativeTimes$whenCreated$thenExceptionThrown(com.github.dakusui.actionunit.ut.actions.RetryTest) negated conditional → KILLED 3.3 Location : lambda$times$0 Killed by : com.github.dakusui.actionunit.ut.actions.RetryTest.givenNegativeTimes$whenCreated$thenExceptionThrown(com.github.dakusui.actionunit.ut.actions.RetryTest) replaced boolean return with true for com/github/dakusui/actionunit/actions/Retry$Builder::lambda$times$0 → KILLED
52		1.1 Location : times Killed by : com.github.dakusui.actionunit.scenarios.CompatActionSupportTest.givenRetryAction$whenDescribe$thenLooksNice(com.github.dakusui.actionunit.scenarios.CompatActionSupportTest) replaced return value with null for com/github/dakusui/actionunit/actions/Retry$Builder::times → KILLED
57		1.1 Location : on Killed by : com.github.dakusui.actionunit.ut.actions.RetryTest.givenNegativeInterval$whenCreated$thenExceptionThrown(com.github.dakusui.actionunit.ut.actions.RetryTest) replaced return value with null for com/github/dakusui/actionunit/actions/Retry$Builder::on → KILLED
61		1.1 Location : lambda$withIntervalOf$1 Killed by : none changed conditional boundary → SURVIVED 2.2 Location : lambda$withIntervalOf$1 Killed by : com.github.dakusui.actionunit.ut.actions.RetryTest.givenNegativeInterval$whenCreated$thenExceptionThrown(com.github.dakusui.actionunit.ut.actions.RetryTest) negated conditional → KILLED 3.3 Location : lambda$withIntervalOf$1 Killed by : com.github.dakusui.actionunit.ut.actions.RetryTest.givenNegativeInterval$whenCreated$thenExceptionThrown(com.github.dakusui.actionunit.ut.actions.RetryTest) replaced boolean return with true for com/github/dakusui/actionunit/actions/Retry$Builder::lambda$withIntervalOf$1 → KILLED
63		1.1 Location : withIntervalOf Killed by : com.github.dakusui.actionunit.ut.actions.RetryTest.givenNegativeTimes$whenCreated$thenExceptionThrown(com.github.dakusui.actionunit.ut.actions.RetryTest) replaced return value with null for com/github/dakusui/actionunit/actions/Retry$Builder::withIntervalOf → KILLED
68		1.1 Location : build Killed by : com.github.dakusui.actionunit.scenarios.CompatActionSupportTest.givenRetryAction$whenDescribe$thenLooksNice(com.github.dakusui.actionunit.scenarios.CompatActionSupportTest) replaced return value with null for com/github/dakusui/actionunit/actions/Retry$Builder::build → KILLED
71		1.1 Location : perform Killed by : com.github.dakusui.actionunit.scenarios.ActionSupportTest.givenRetryWithPassingAction$whenPerform$thenNoRetry(com.github.dakusui.actionunit.scenarios.ActionSupportTest) replaced return value with null for com/github/dakusui/actionunit/actions/Retry$Builder$1::perform → KILLED
76		1.1 Location : times Killed by : com.github.dakusui.actionunit.scenarios.CompatActionSupportTest.givenRetryAction$whenDescribe$thenLooksNice(com.github.dakusui.actionunit.scenarios.CompatActionSupportTest) replaced int return with 0 for com/github/dakusui/actionunit/actions/Retry$Builder$1::times → KILLED
81		1.1 Location : targetExceptionClass Killed by : com.github.dakusui.actionunit.scenarios.CompatActionSupportTest.givenRetryAction$whenDescribe$thenLooksNice(com.github.dakusui.actionunit.scenarios.CompatActionSupportTest) replaced return value with null for com/github/dakusui/actionunit/actions/Retry$Builder$1::targetExceptionClass → KILLED
86		1.1 Location : intervalInNanoseconds Killed by : com.github.dakusui.actionunit.scenarios.CompatActionSupportTest.givenRetryAction$whenDescribe$thenLooksNice(com.github.dakusui.actionunit.scenarios.CompatActionSupportTest) replaced long return with 0 for com/github/dakusui/actionunit/actions/Retry$Builder$1::intervalInNanoseconds → KILLED
91		1.1 Location : toString Killed by : none replaced return value with "" for com/github/dakusui/actionunit/actions/Retry$Builder$1::toString → SURVIVED

Retry.java

Mutations

Active mutators

Tests examined