import static org.opendaylight.controller.cluster.databroker.actors.dds.TestUtils.assertOperationThrowsException;
import akka.testkit.TestProbe;
+import com.google.common.base.Ticker;
import com.google.common.util.concurrent.ListenableFuture;
import java.util.function.Consumer;
import org.junit.Assert;
}
@Test
- public void testDoSeal() throws Exception {
+ public void testSealOnly() throws Exception {
assertOperationThrowsException(() -> transaction.getSnapshot(), IllegalStateException.class);
- transaction.doSeal();
+ transaction.sealOnly();
Assert.assertEquals(modification, transaction.getSnapshot());
}
public void testFlushState() throws Exception {
final TransactionTester<RemoteProxyTransaction> transactionTester = createRemoteProxyTransactionTester();
final RemoteProxyTransaction successor = transactionTester.getTransaction();
- doAnswer(this::applyToCursorAnswer).when(modification).applyToCursor(any());
- transaction.doSeal();
+ doAnswer(LocalProxyTransactionTest::applyToCursorAnswer).when(modification).applyToCursor(any());
+ transaction.sealOnly();
transaction.flushState(successor);
verify(modification).applyToCursor(any());
transactionTester.getTransaction().seal();
builder.setAbort();
final ModifyTransactionRequest request = builder.build();
final Consumer<Response<?, ?>> callback = createCallbackMock();
- transaction.applyModifyTransactionRequest(request, callback);
- getTester().expectTransactionRequest(TransactionAbortRequest.class);
+ transaction.replayModifyTransactionRequest(request, callback, Ticker.systemTicker().read());
+ getTester().expectTransactionRequest(AbortLocalTransactionRequest.class);
}
@Test
builder.setCommit(coordinated);
final ModifyTransactionRequest request = builder.build();
final Consumer<Response<?, ?>> callback = createCallbackMock();
- transaction.applyModifyTransactionRequest(request, callback);
+ transaction.replayModifyTransactionRequest(request, callback, Ticker.systemTicker().read());
verify(modification).write(PATH_1, DATA_1);
verify(modification).merge(PATH_2, DATA_2);
verify(modification).delete(PATH_3);
Assert.assertEquals(coordinated, commitRequest.isCoordinated());
}
-}
\ No newline at end of file
+}