org.opendaylight.mdsal.binding.testutils

Interface DataBrokerFailures

All Known Implementing Classes:

DataBrokerFailuresImpl

public interface DataBrokerFailures

Configures a DataBroker to simulate failures, useful for tests.

Author:

Michael Vorburger.ch

Method Summary

Modifier and Type	Method and Description
void	failButCommitAnyway() To simulate scenarios where even though the transaction throws a TransactionCommitFailedException (caused by akka.pattern.AskTimeoutException) it eventually succeeds.
void	failCommits(int howManyTimes, TransactionCommitFailedException exception) Fails N future Transaction commits.
void	failCommits(TransactionCommitFailedException exception) Fails all future Transaction commits.
void	failReads(int howManyTimes, ReadFailedException exception) Fails N future reads.
void	failReads(ReadFailedException exception) Fails all future reads.
void	unfailCommits() Resets any earlier failCommits(TransactionCommitFailedException) or failCommits(int, TransactionCommitFailedException).
void	unfailReads() Resets any earlier failReads(ReadFailedException) or failReads(int, ReadFailedException).

Method Detail

failReads

void failReads(ReadFailedException exception)

Fails all future reads.

Parameters:

exception - a ReadFailedException to throw from a ReadOperations.read(LogicalDatastoreType, InstanceIdentifier) call.

failReads

void failReads(int howManyTimes,
               ReadFailedException exception)

Fails N future reads.

Parameters:

howManyTimes - how many times to throw the passed exception, until it resets.

exception - a ReadFailedException to throw from a ReadOperations.read(LogicalDatastoreType, InstanceIdentifier) call.

failCommits

void failCommits(TransactionCommitFailedException exception)

Fails all future Transaction commits.

Parameters:

exception - an Exception to throw from a WriteTransaction.commit() method.

failCommits

void failCommits(int howManyTimes,
                 TransactionCommitFailedException exception)

Fails N future Transaction commits.

Parameters:

howManyTimes - how many times to throw the passed exception, until it resets

exception - an Exception to throw from a WriteTransaction.commit() method.

failButCommitAnyway

void failButCommitAnyway()

To simulate scenarios where even though the transaction throws a TransactionCommitFailedException (caused by akka.pattern.AskTimeoutException) it eventually succeeds. These timeouts are typically seen in scaled cluster environments under load. The new tell-based protocol, which will soon be enabled by default (c/61002), adds internal retries for transactions, making the application not to handle such scenarios.

unfailReads

void unfailReads()

Resets any earlier failReads(ReadFailedException) or failReads(int, ReadFailedException).

unfailCommits

void unfailCommits()

Resets any earlier failCommits(TransactionCommitFailedException) or failCommits(int, TransactionCommitFailedException).