*/
package org.opendaylight.mdsal.dom.store.inmemory;
+import static org.mockito.Matchers.any;
+import static org.mockito.Mockito.doNothing;
import static org.mockito.Mockito.doReturn;
import static org.mockito.Mockito.doThrow;
+import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.verify;
import static org.opendaylight.mdsal.dom.store.inmemory.TestUtils.COHORTS;
import static org.opendaylight.mdsal.dom.store.inmemory.TestUtils.DOM_DATA_TREE_IDENTIFIER;
import static org.opendaylight.mdsal.dom.store.inmemory.TestUtils.resetMocks;
import org.junit.After;
+import org.junit.Before;
import org.junit.Test;
import org.opendaylight.mdsal.common.api.TransactionCommitFailedException;
public class ShardCommitCoordinationTaskTest {
+ final InmemoryDOMDataTreeShardWriteTransaction mockTx = mock(InmemoryDOMDataTreeShardWriteTransaction.class);
+
+ @Before
+ public void setUp() throws Exception {
+ doReturn("MockedTx").when(mockTx).toString();
+ doNothing().when(mockTx).transactionCommited(any());
+ }
+
@Test
public void basicTest() throws Exception {
doReturn(Void.TYPE).when(LISTENABLE_FUTURE).get();
COHORTS.add(DOM_STORE_THREE_PHASE_COMMIT_COHORT);
ShardCommitCoordinationTask shardCommitCoordinationTask =
- new ShardCommitCoordinationTask(DOM_DATA_TREE_IDENTIFIER, COHORTS);
+ new ShardCommitCoordinationTask(DOM_DATA_TREE_IDENTIFIER, COHORTS, mockTx);
shardCommitCoordinationTask.call();
verify(DOM_STORE_THREE_PHASE_COMMIT_COHORT).commit();
COHORTS.add(DOM_STORE_THREE_PHASE_COMMIT_COHORT);
ShardCommitCoordinationTask shardCommitCoordinationTask =
- new ShardCommitCoordinationTask(DOM_DATA_TREE_IDENTIFIER, COHORTS);
+ new ShardCommitCoordinationTask(DOM_DATA_TREE_IDENTIFIER, COHORTS, mockTx);
shardCommitCoordinationTask.call();
}