DefaultErrorAnalyzer.java

package fr.sii.ogham.sms.sender.impl.cloudhopper.session;

import java.nio.channels.ClosedChannelException;

import com.cloudhopper.smpp.pdu.EnquireLink;
import com.cloudhopper.smpp.type.SmppChannelException;
import com.cloudhopper.smpp.type.SmppTimeoutException;
import com.cloudhopper.smpp.type.UnrecoverablePduException;

import fr.sii.ogham.sms.sender.impl.cloudhopper.exception.KeepAliveException;
import fr.sii.ogham.sms.sender.impl.cloudhopper.exception.SmppException;

/**
 * Default error analyzer that indicates to use a new session in the following
 * cases:
 * <ul>
 * <li>{@link KeepSessionAliveStrategy} is used for session handling and several
 * (configurable) {@link EnquireLink} requests have failed due to a timeout</li>
 * <li>The connection has been closed by the server</li>
 * <li>The error is unrecoverable (see {@link UnrecoverablePduException}</li>
 * </ul>
 * 
 * <p>
 * This class can be extended if additional checks are needed.
 * 
 * @author Aurélien Baudet
 *
 */
public class DefaultErrorAnalyzer implements ErrorAnalyzer {
	private final int maxConsecutiveTimeouts;

	public DefaultErrorAnalyzer(int maxConsecutiveTimeouts) {
		super();
		this.maxConsecutiveTimeouts = maxConsecutiveTimeouts;
	}

	@Override
	public boolean requiresNewConnection(Throwable failure) {
		if (failure == null) {
			return false;
		}
		if (tooManyEnquireLinkTimeouts(failure)) {
			return true;
		}
		if (failure instanceof SmppException) {
			return requiresNewConnection(failure.getCause());
		}
		return connectionClosed(failure) || isUnrecoverableError(failure);
	}

	protected boolean tooManyEnquireLinkTimeouts(Throwable failure) {
		return failure instanceof KeepAliveException 
				&& failure.getCause() instanceof SmppTimeoutException 
				&& ((KeepAliveException) failure).getConsecutiveFailures() >= maxConsecutiveTimeouts;
	}

	protected boolean connectionClosed(Throwable failure) {
		return failure instanceof ClosedChannelException || failure instanceof SmppChannelException;
	}

	protected boolean isUnrecoverableError(Throwable failure) {
		return failure instanceof UnrecoverablePduException;
	}
}














Active mutators

org.pitest.mutationtest.engine.gregor.mutators.BooleanFalseReturnValsMutator
org.pitest.mutationtest.engine.gregor.mutators.BooleanTrueReturnValsMutator
org.pitest.mutationtest.engine.gregor.mutators.ConditionalsBoundaryMutator
org.pitest.mutationtest.engine.gregor.mutators.EmptyObjectReturnValsMutator
org.pitest.mutationtest.engine.gregor.mutators.IncrementsMutator
org.pitest.mutationtest.engine.gregor.mutators.InvertNegsMutator
org.pitest.mutationtest.engine.gregor.mutators.MathMutator
org.pitest.mutationtest.engine.gregor.mutators.NegateConditionalsMutator
org.pitest.mutationtest.engine.gregor.mutators.NullReturnValsMutator
org.pitest.mutationtest.engine.gregor.mutators.PrimitiveReturnsMutator
org.pitest.mutationtest.engine.gregor.mutators.VoidMethodCallMutator

Tests examined

Report generated by PIT OGHAM

1		package fr.sii.ogham.sms.sender.impl.cloudhopper.session;
2
3		import java.nio.channels.ClosedChannelException;
4
5		import com.cloudhopper.smpp.pdu.EnquireLink;
6		import com.cloudhopper.smpp.type.SmppChannelException;
7		import com.cloudhopper.smpp.type.SmppTimeoutException;
8		import com.cloudhopper.smpp.type.UnrecoverablePduException;
9
10		import fr.sii.ogham.sms.sender.impl.cloudhopper.exception.KeepAliveException;
11		import fr.sii.ogham.sms.sender.impl.cloudhopper.exception.SmppException;
12
13		/**
14		* Default error analyzer that indicates to use a new session in the following
15		* cases:
16		* <ul>
17		* <li>{@link KeepSessionAliveStrategy} is used for session handling and several
18		* (configurable) {@link EnquireLink} requests have failed due to a timeout</li>
19		* <li>The connection has been closed by the server</li>
20		* <li>The error is unrecoverable (see {@link UnrecoverablePduException}</li>
21		* </ul>
22		*
23		* <p>
24		* This class can be extended if additional checks are needed.
25		*
26		* @author Aurélien Baudet
27		*
28		*/
29		public class DefaultErrorAnalyzer implements ErrorAnalyzer {
30		private final int maxConsecutiveTimeouts;
31
32		public DefaultErrorAnalyzer(int maxConsecutiveTimeouts) {
33		super();
34		this.maxConsecutiveTimeouts = maxConsecutiveTimeouts;
35		}
36
37		@Override
38		public boolean requiresNewConnection(Throwable failure) {
39	2 1. requiresNewConnection : negated conditional → NO_COVERAGE 2. requiresNewConnection : negated conditional → KILLED	if (failure == null) {
40	1 1. requiresNewConnection : replaced boolean return with true for fr/sii/ogham/sms/sender/impl/cloudhopper/session/DefaultErrorAnalyzer::requiresNewConnection → NO_COVERAGE	return false;
41		}
42	2 1. requiresNewConnection : negated conditional → NO_COVERAGE 2. requiresNewConnection : negated conditional → SURVIVED	if (tooManyEnquireLinkTimeouts(failure)) {
43	2 1. requiresNewConnection : replaced boolean return with false for fr/sii/ogham/sms/sender/impl/cloudhopper/session/DefaultErrorAnalyzer::requiresNewConnection → NO_COVERAGE 2. requiresNewConnection : replaced boolean return with false for fr/sii/ogham/sms/sender/impl/cloudhopper/session/DefaultErrorAnalyzer::requiresNewConnection → TIMED_OUT	return true;
44		}
45	2 1. requiresNewConnection : negated conditional → NO_COVERAGE 2. requiresNewConnection : negated conditional → KILLED	if (failure instanceof SmppException) {
46	4 1. requiresNewConnection : replaced boolean return with false for fr/sii/ogham/sms/sender/impl/cloudhopper/session/DefaultErrorAnalyzer::requiresNewConnection → NO_COVERAGE 2. requiresNewConnection : replaced boolean return with true for fr/sii/ogham/sms/sender/impl/cloudhopper/session/DefaultErrorAnalyzer::requiresNewConnection → NO_COVERAGE 3. requiresNewConnection : replaced boolean return with true for fr/sii/ogham/sms/sender/impl/cloudhopper/session/DefaultErrorAnalyzer::requiresNewConnection → SURVIVED 4. requiresNewConnection : replaced boolean return with false for fr/sii/ogham/sms/sender/impl/cloudhopper/session/DefaultErrorAnalyzer::requiresNewConnection → KILLED	return requiresNewConnection(failure.getCause());
47		}
48	5 1. requiresNewConnection : replaced boolean return with true for fr/sii/ogham/sms/sender/impl/cloudhopper/session/DefaultErrorAnalyzer::requiresNewConnection → NO_COVERAGE 2. requiresNewConnection : replaced boolean return with true for fr/sii/ogham/sms/sender/impl/cloudhopper/session/DefaultErrorAnalyzer::requiresNewConnection → SURVIVED 3. requiresNewConnection : negated conditional → NO_COVERAGE 4. requiresNewConnection : negated conditional → NO_COVERAGE 5. requiresNewConnection : negated conditional → KILLED	return connectionClosed(failure) \|\| isUnrecoverableError(failure);
49		}
50
51		protected boolean tooManyEnquireLinkTimeouts(Throwable failure) {
52	4 1. tooManyEnquireLinkTimeouts : replaced boolean return with true for fr/sii/ogham/sms/sender/impl/cloudhopper/session/DefaultErrorAnalyzer::tooManyEnquireLinkTimeouts → SURVIVED 2. tooManyEnquireLinkTimeouts : replaced boolean return with true for fr/sii/ogham/sms/sender/impl/cloudhopper/session/DefaultErrorAnalyzer::tooManyEnquireLinkTimeouts → NO_COVERAGE 3. tooManyEnquireLinkTimeouts : negated conditional → NO_COVERAGE 4. tooManyEnquireLinkTimeouts : negated conditional → TIMED_OUT	return failure instanceof KeepAliveException
53	2 1. tooManyEnquireLinkTimeouts : negated conditional → NO_COVERAGE 2. tooManyEnquireLinkTimeouts : negated conditional → TIMED_OUT	&& failure.getCause() instanceof SmppTimeoutException
54	4 1. tooManyEnquireLinkTimeouts : changed conditional boundary → NO_COVERAGE 2. tooManyEnquireLinkTimeouts : negated conditional → NO_COVERAGE 3. tooManyEnquireLinkTimeouts : negated conditional → TIMED_OUT 4. tooManyEnquireLinkTimeouts : changed conditional boundary → KILLED	&& ((KeepAliveException) failure).getConsecutiveFailures() >= maxConsecutiveTimeouts;
55		}
56
57		protected boolean connectionClosed(Throwable failure) {
58	6 1. connectionClosed : replaced boolean return with true for fr/sii/ogham/sms/sender/impl/cloudhopper/session/DefaultErrorAnalyzer::connectionClosed → SURVIVED 2. connectionClosed : replaced boolean return with true for fr/sii/ogham/sms/sender/impl/cloudhopper/session/DefaultErrorAnalyzer::connectionClosed → NO_COVERAGE 3. connectionClosed : negated conditional → NO_COVERAGE 4. connectionClosed : negated conditional → SURVIVED 5. connectionClosed : negated conditional → NO_COVERAGE 6. connectionClosed : negated conditional → KILLED	return failure instanceof ClosedChannelException \|\| failure instanceof SmppChannelException;
59		}
60
61		protected boolean isUnrecoverableError(Throwable failure) {
62	2 1. isUnrecoverableError : replaced boolean return with false for fr/sii/ogham/sms/sender/impl/cloudhopper/session/DefaultErrorAnalyzer::isUnrecoverableError → NO_COVERAGE 2. isUnrecoverableError : replaced boolean return with true for fr/sii/ogham/sms/sender/impl/cloudhopper/session/DefaultErrorAnalyzer::isUnrecoverableError → NO_COVERAGE	return failure instanceof UnrecoverablePduException;
63		}
64		}
		Mutations
39		1.1 Location : requiresNewConnection Killed by : none negated conditional → NO_COVERAGE 2.2 Location : requiresNewConnection Killed by : oghamcloudhopper.it.ReuseSessionStrategyTest.reuseSessionButSendFailsDueToSessionClosedByServer(oghamcloudhopper.it.ReuseSessionStrategyTest) negated conditional → KILLED
40		1.1 Location : requiresNewConnection Killed by : none replaced boolean return with true for fr/sii/ogham/sms/sender/impl/cloudhopper/session/DefaultErrorAnalyzer::requiresNewConnection → NO_COVERAGE
42		1.1 Location : requiresNewConnection Killed by : none negated conditional → NO_COVERAGE 2.2 Location : requiresNewConnection Killed by : none negated conditional → SURVIVED
43		1.1 Location : requiresNewConnection Killed by : none replaced boolean return with false for fr/sii/ogham/sms/sender/impl/cloudhopper/session/DefaultErrorAnalyzer::requiresNewConnection → NO_COVERAGE 2.2 Location : requiresNewConnection Killed by : none replaced boolean return with false for fr/sii/ogham/sms/sender/impl/cloudhopper/session/DefaultErrorAnalyzer::requiresNewConnection → TIMED_OUT
45		1.1 Location : requiresNewConnection Killed by : none negated conditional → NO_COVERAGE 2.2 Location : requiresNewConnection Killed by : oghamcloudhopper.it.ReuseSessionStrategyTest.reuseSessionButSendFailsDueToSessionClosedByServer(oghamcloudhopper.it.ReuseSessionStrategyTest) negated conditional → KILLED
46		1.1 Location : requiresNewConnection Killed by : none replaced boolean return with false for fr/sii/ogham/sms/sender/impl/cloudhopper/session/DefaultErrorAnalyzer::requiresNewConnection → NO_COVERAGE 2.2 Location : requiresNewConnection Killed by : oghamcloudhopper.it.ReuseSessionStrategyTest.reuseSessionButSendFailsDueToSessionClosedByServer(oghamcloudhopper.it.ReuseSessionStrategyTest) replaced boolean return with false for fr/sii/ogham/sms/sender/impl/cloudhopper/session/DefaultErrorAnalyzer::requiresNewConnection → KILLED 3.3 Location : requiresNewConnection Killed by : none replaced boolean return with true for fr/sii/ogham/sms/sender/impl/cloudhopper/session/DefaultErrorAnalyzer::requiresNewConnection → NO_COVERAGE 4.4 Location : requiresNewConnection Killed by : none replaced boolean return with true for fr/sii/ogham/sms/sender/impl/cloudhopper/session/DefaultErrorAnalyzer::requiresNewConnection → SURVIVED
48		1.1 Location : requiresNewConnection Killed by : none replaced boolean return with true for fr/sii/ogham/sms/sender/impl/cloudhopper/session/DefaultErrorAnalyzer::requiresNewConnection → NO_COVERAGE 2.2 Location : requiresNewConnection Killed by : none replaced boolean return with true for fr/sii/ogham/sms/sender/impl/cloudhopper/session/DefaultErrorAnalyzer::requiresNewConnection → SURVIVED 3.3 Location : requiresNewConnection Killed by : none negated conditional → NO_COVERAGE 4.4 Location : requiresNewConnection Killed by : oghamcloudhopper.it.ReuseSessionStrategyTest.reuseSessionButSendFailsDueToSessionClosedByServer(oghamcloudhopper.it.ReuseSessionStrategyTest) negated conditional → KILLED 5.5 Location : requiresNewConnection Killed by : none negated conditional → NO_COVERAGE
52		1.1 Location : tooManyEnquireLinkTimeouts Killed by : none replaced boolean return with true for fr/sii/ogham/sms/sender/impl/cloudhopper/session/DefaultErrorAnalyzer::tooManyEnquireLinkTimeouts → SURVIVED 2.2 Location : tooManyEnquireLinkTimeouts Killed by : none replaced boolean return with true for fr/sii/ogham/sms/sender/impl/cloudhopper/session/DefaultErrorAnalyzer::tooManyEnquireLinkTimeouts → NO_COVERAGE 3.3 Location : tooManyEnquireLinkTimeouts Killed by : none negated conditional → NO_COVERAGE 4.4 Location : tooManyEnquireLinkTimeouts Killed by : none negated conditional → TIMED_OUT
53		1.1 Location : tooManyEnquireLinkTimeouts Killed by : none negated conditional → NO_COVERAGE 2.2 Location : tooManyEnquireLinkTimeouts Killed by : none negated conditional → TIMED_OUT
54		1.1 Location : tooManyEnquireLinkTimeouts Killed by : none changed conditional boundary → NO_COVERAGE 2.2 Location : tooManyEnquireLinkTimeouts Killed by : oghamcloudhopper.it.KeepAliveSessionStrategyTest.keepAliveButEnquireLinkTimeout(oghamcloudhopper.it.KeepAliveSessionStrategyTest) changed conditional boundary → KILLED 3.3 Location : tooManyEnquireLinkTimeouts Killed by : none negated conditional → TIMED_OUT 4.4 Location : tooManyEnquireLinkTimeouts Killed by : none negated conditional → NO_COVERAGE
58		1.1 Location : connectionClosed Killed by : none replaced boolean return with true for fr/sii/ogham/sms/sender/impl/cloudhopper/session/DefaultErrorAnalyzer::connectionClosed → SURVIVED 2.2 Location : connectionClosed Killed by : none replaced boolean return with true for fr/sii/ogham/sms/sender/impl/cloudhopper/session/DefaultErrorAnalyzer::connectionClosed → NO_COVERAGE 3.3 Location : connectionClosed Killed by : none negated conditional → NO_COVERAGE 4.4 Location : connectionClosed Killed by : none negated conditional → SURVIVED 5.5 Location : connectionClosed Killed by : none negated conditional → NO_COVERAGE 6.6 Location : connectionClosed Killed by : oghamcloudhopper.it.ReuseSessionStrategyTest.reuseSessionButSendFailsDueToSessionClosedByServer(oghamcloudhopper.it.ReuseSessionStrategyTest) negated conditional → KILLED
62		1.1 Location : isUnrecoverableError Killed by : none replaced boolean return with false for fr/sii/ogham/sms/sender/impl/cloudhopper/session/DefaultErrorAnalyzer::isUnrecoverableError → NO_COVERAGE 2.2 Location : isUnrecoverableError Killed by : none replaced boolean return with true for fr/sii/ogham/sms/sender/impl/cloudhopper/session/DefaultErrorAnalyzer::isUnrecoverableError → NO_COVERAGE

DefaultErrorAnalyzer.java

Mutations

Active mutators

Tests examined