* terms of the Eclipse Public License v1.0 which accompanies this distribution,
* and is available at http://www.eclipse.org/legal/epl-v10.html
*/
-
package org.opendaylight.ovsdb.southbound.transactions.md;
import static org.junit.Assert.assertEquals;
field(TransactionInvokerImpl.class, "pendingTransactions").set(transactionInvokerImpl, pendingTransactions);
field(TransactionInvokerImpl.class, "transactionToCommand").set(transactionInvokerImpl, transactionToCommand);
field(TransactionInvokerImpl.class, "failedTransactionQueue").set(transactionInvokerImpl, failedTransactionQ);
- field(TransactionInvokerImpl.class, "successfulTransactionQueue").set(transactionInvokerImpl, successfulTxQ);
Whitebox.invokeMethod(transactionInvokerImpl, "resetTransactionQueue");
assertNotNull(Whitebox.getInternalState(transactionInvokerImpl, "pendingTransactions"));
assertEquals(testResult, Whitebox.invokeMethod(transactionInvokerImpl, "extractCommandsFromQueue"));
}
- @Test
- public void testForgetSuccessfulTransactions() throws Exception {
- ReadWriteTransaction transaction = mock(ReadWriteTransaction.class);
- successfulTxQ.add(transaction);
- pendingTransactions.add(transaction);
- transactionToCommand.put(transaction, mock(TransactionCommand.class));
- field(TransactionInvokerImpl.class, "successfulTransactionQueue").set(transactionInvokerImpl, successfulTxQ);
- field(TransactionInvokerImpl.class, "pendingTransactions").set(transactionInvokerImpl, pendingTransactions);
- field(TransactionInvokerImpl.class, "transactionToCommand").set(transactionInvokerImpl, transactionToCommand);
-
- Whitebox.invokeMethod(transactionInvokerImpl, "forgetSuccessfulTransactions");
-
- List<ReadWriteTransaction> testPendingTransactions = Whitebox.getInternalState(transactionInvokerImpl,
- "pendingTransactions");
- Map<ReadWriteTransaction, TransactionCommand> testTransactionToCommand = Whitebox
- .getInternalState(transactionInvokerImpl, "transactionToCommand");
- assertTrue(testPendingTransactions.isEmpty());
- assertTrue(testTransactionToCommand.isEmpty());
- }
-
@Test
public void testClose() throws Exception {
MemberModifier.field(TransactionInvokerImpl.class, "executor").set(transactionInvokerImpl, executor);