*/
package org.opendaylight.controller.cluster.access.commands;
+import org.junit.Assert;
import org.opendaylight.controller.cluster.access.concepts.ClientIdentifier;
import org.opendaylight.controller.cluster.access.concepts.FrontendIdentifier;
import org.opendaylight.controller.cluster.access.concepts.FrontendType;
protected AbortLocalTransactionRequest object() {
return OBJECT;
}
+
+ @Override
+ protected void doAdditionalAssertions(final Object deserialize) {
+ Assert.assertTrue(deserialize instanceof AbortLocalTransactionRequest);
+ Assert.assertEquals(OBJECT.getReplyTo(), ((AbortLocalTransactionRequest) deserialize).getReplyTo());
+ }
}
\ No newline at end of file
*/
package org.opendaylight.controller.cluster.access.commands;
+import org.apache.commons.lang.SerializationUtils;
import org.junit.Assert;
import org.junit.Test;
import org.opendaylight.controller.cluster.access.ABIVersion;
@Override
protected abstract T object();
- @Test(expected = UnsupportedOperationException.class)
- public void testExternalizableProxy() {
- object().externalizableProxy(ABIVersion.BORON);
- }
-
@Test
public void cloneAsVersionTest() {
Assert.assertEquals(object(), object().cloneAsVersion(ABIVersion.BORON));
}
+
+ @Override
+ @Test(expected = UnsupportedOperationException.class)
+ public void serializationTest() {
+ SerializationUtils.clone(object());
+ }
}
*/
package org.opendaylight.controller.cluster.access.commands;
+import org.apache.commons.lang.SerializationUtils;
import org.junit.Assert;
import org.junit.Test;
import org.opendaylight.controller.cluster.access.concepts.ClientIdentifier;
public void isHardFailureTest() throws Exception {
Assert.assertTrue(object().isHardFailure());
}
+
+ @SuppressWarnings("unchecked")
+ @Test
+ public void serializationTest() {
+ final Object deserialize = SerializationUtils.clone(object());
+
+ Assert.assertEquals(object().getTarget(), ((T) deserialize).getTarget());
+ Assert.assertEquals(object().getVersion(), ((T) deserialize).getVersion());
+ Assert.assertEquals(object().getSequence(), ((T) deserialize).getSequence());
+ }
}
*/
package org.opendaylight.controller.cluster.access.commands;
+import org.apache.commons.lang.SerializationUtils;
+import org.junit.Assert;
+import org.junit.Test;
import org.opendaylight.controller.cluster.access.concepts.ClientIdentifier;
import org.opendaylight.controller.cluster.access.concepts.FrontendIdentifier;
import org.opendaylight.controller.cluster.access.concepts.FrontendType;
protected static final TransactionIdentifier TRANSACTION_IDENTIFIER = new TransactionIdentifier(
HISTORY_IDENTIFIER, 0);
+
+ protected abstract T object();
+
+ @SuppressWarnings("unchecked")
+ @Test
+ public void serializationTest() {
+ final Object deserialize = SerializationUtils.clone(object());
+
+ Assert.assertEquals(object().getTarget(), ((T) deserialize).getTarget());
+ Assert.assertEquals(object().getVersion(), ((T) deserialize).getVersion());
+ Assert.assertEquals(object().getSequence(), ((T) deserialize).getSequence());
+ }
}
final MoreObjects.ToStringHelper result = OBJECT.addToStringAttributes(MoreObjects.toStringHelper(OBJECT));
Assert.assertTrue(result.toString().contains("coordinated=" + COORDINATED));
}
+
+ @Override
+ protected void doAdditionalAssertions(final Object deserialize) {
+ Assert.assertTrue(deserialize instanceof CommitLocalTransactionRequest);
+ Assert.assertEquals(OBJECT.getReplyTo(), ((CommitLocalTransactionRequest) deserialize).getReplyTo());
+ Assert.assertEquals(OBJECT.getModification(), ((CommitLocalTransactionRequest) deserialize).getModification());
+ }
}
\ No newline at end of file
}
@Test
- public void cloneAsVersion() throws Exception {
+ public void cloneAsVersionTest() throws Exception {
final ConnectClientFailure clone = OBJECT.cloneAsVersion(ABIVersion.current());
Assert.assertEquals(OBJECT.getTarget(), clone.getTarget());
Assert.assertEquals(OBJECT.getSequence(), clone.getSequence());
Assert.assertEquals(OBJECT.getCause(), clone.getCause());
}
-
- @Test
- public void externalizableProxy() throws Exception {
- final ConnectClientFailureProxyV1 proxy = (ConnectClientFailureProxyV1) OBJECT.externalizableProxy(
- ABIVersion.current());
- Assert.assertNotNull(proxy);
- }
}
\ No newline at end of file
+++ /dev/null
-/*
- * Copyright (c) 2017 Pantheon Technologies s.r.o. and others. All rights reserved.
- *
- * This program and the accompanying materials are made available under the
- * 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.controller.cluster.access.commands;
-
-import org.junit.Assert;
-import org.junit.Test;
-import org.opendaylight.controller.cluster.access.ABIVersion;
-import org.opendaylight.controller.cluster.access.concepts.AbstractRequestProxyTest;
-import org.opendaylight.controller.cluster.access.concepts.Request;
-
-public class ConnectClientRequestProxyV1Test extends AbstractRequestProxyTest<ConnectClientRequestProxyV1> {
- private static final ConnectClientRequest REQUEST = new ConnectClientRequest(
- CLIENT_IDENTIFIER, ACTOR_REF, ABIVersion.TEST_PAST_VERSION, ABIVersion.TEST_FUTURE_VERSION);
- private static final ConnectClientRequestProxyV1 OBJECT = new ConnectClientRequestProxyV1(REQUEST);
-
- @Override
- public ConnectClientRequestProxyV1 object() {
- return OBJECT;
- }
-
- @Test
- public void createRequestTest() {
- final Request request = object().createRequest(CLIENT_IDENTIFIER, 0, ACTOR_REF);
- Assert.assertNotNull(request);
- }
-}
\ No newline at end of file
import org.junit.Assert;
import org.junit.Test;
import org.opendaylight.controller.cluster.access.ABIVersion;
-import org.opendaylight.controller.cluster.access.concepts.AbstractRequestProxy;
import org.opendaylight.controller.cluster.access.concepts.AbstractRequestTest;
import org.opendaylight.controller.cluster.access.concepts.ClientIdentifier;
import org.opendaylight.controller.cluster.access.concepts.FrontendIdentifier;
}
@Test
- public void getMinVersion() throws Exception {
+ public void getMinVersionTest() throws Exception {
Assert.assertEquals(MIN_VERSION, OBJECT.getMinVersion());
}
@Test
- public void getMaxVersion() throws Exception {
+ public void getMaxVersionTest() throws Exception {
Assert.assertEquals(MAX_VERSION, OBJECT.getMaxVersion());
}
@Test
- public void toRequestFailure() throws Exception {
+ public void toRequestFailureTest() throws Exception {
final RequestException exception = new DeadTransactionException(0);
final ConnectClientFailure failure = OBJECT.toRequestFailure(exception);
Assert.assertNotNull(failure);
}
@Test
- public void externalizableProxy() throws Exception {
- final AbstractRequestProxy<ClientIdentifier, ConnectClientRequest> proxy = OBJECT.externalizableProxy(
- ABIVersion.current());
- Assert.assertNotNull(proxy);
- }
-
- @Test
- public void cloneAsVersion() throws Exception {
+ public void cloneAsVersionTest() throws Exception {
final ConnectClientRequest clone = OBJECT.cloneAsVersion(ABIVersion.BORON);
Assert.assertNotNull(clone);
Assert.assertEquals(ABIVersion.BORON, clone.getVersion());
}
@Test
- public void addToStringAttributes() throws Exception {
+ public void addToStringAttributesTest() throws Exception {
final MoreObjects.ToStringHelper result = OBJECT.addToStringAttributes(MoreObjects.toStringHelper(OBJECT));
Assert.assertTrue(result.toString().contains("minVersion=" + MIN_VERSION));
Assert.assertTrue(result.toString().contains("maxVersion=" + MAX_VERSION));
}
+
+ @Override
+ protected void doAdditionalAssertions(final Object deserialize) {
+ Assert.assertTrue(deserialize instanceof ConnectClientRequest);
+ final ConnectClientRequest casted = (ConnectClientRequest) deserialize;
+
+ Assert.assertEquals(OBJECT.getMaxVersion(), casted.getMaxVersion());
+ Assert.assertEquals(OBJECT.getMinVersion(), casted.getMinVersion());
+ Assert.assertEquals(OBJECT.getReplyTo(), casted.getReplyTo());
+ }
}
\ No newline at end of file
}
@Test
- public void cloneAsVersion() throws Exception {
+ public void cloneAsVersionTest() throws Exception {
final ABIVersion cloneVersion = ABIVersion.TEST_FUTURE_VERSION;
final ExistsTransactionRequest clone = OBJECT.cloneAsVersion(cloneVersion);
Assert.assertEquals(cloneVersion, clone.getVersion());
Assert.assertEquals(OBJECT.isSnapshotOnly(), clone.isSnapshotOnly());
}
- @Test
- public void externalizableProxy() throws Exception {
- final ABIVersion proxyVersion = ABIVersion.TEST_FUTURE_VERSION;
- final ExistsTransactionRequestProxyV1 proxy = OBJECT.externalizableProxy(proxyVersion);
- Assert.assertNotNull(proxy);
+ @Override
+ protected void doAdditionalAssertions(final Object deserialize) {
+ Assert.assertTrue(deserialize instanceof ExistsTransactionRequest);
+ Assert.assertEquals(OBJECT.getReplyTo(), ((ExistsTransactionRequest) deserialize).getReplyTo());
+ Assert.assertEquals(OBJECT.getPath(), ((ExistsTransactionRequest) deserialize).getPath());
}
}
\ No newline at end of file
private static final ExistsTransactionSuccess OBJECT = new ExistsTransactionSuccess(
TRANSACTION_IDENTIFIER, 0, EXISTS);
- @Test
- public void getExists() throws Exception {
- final boolean result = OBJECT.getExists();
- Assert.assertEquals(EXISTS, result);
+ @Override
+ protected ExistsTransactionSuccess object() {
+ return OBJECT;
}
@Test
- public void externalizableProxy() throws Exception {
- final ExistsTransactionSuccessProxyV1 proxy = OBJECT.externalizableProxy(ABIVersion.BORON);
- Assert.assertNotNull(proxy);
+ public void getExistsTest() throws Exception {
+ final boolean result = OBJECT.getExists();
+ Assert.assertEquals(EXISTS, result);
}
@Test
- public void cloneAsVersion() throws Exception {
+ public void cloneAsVersionTest() throws Exception {
final ExistsTransactionSuccess clone = OBJECT.cloneAsVersion(ABIVersion.BORON);
Assert.assertEquals(OBJECT, clone);
}
@Test
- public void addToStringAttributes() throws Exception {
+ public void addToStringAttributesTest() throws Exception {
final MoreObjects.ToStringHelper result = OBJECT.addToStringAttributes(MoreObjects.toStringHelper(OBJECT));
Assert.assertTrue(result.toString().contains("exists=" + EXISTS));
}
}
@Test
- public void cloneAsVersion() throws Exception {
+ public void cloneAsVersionTest() throws Exception {
final LocalHistoryFailure clone = OBJECT.cloneAsVersion(ABIVersion.current());
Assert.assertEquals(OBJECT, clone);
}
-
- @Test
- public void externalizableProxy() throws Exception {
- final LocalHistoryFailureProxyV1 proxy = OBJECT.externalizableProxy(ABIVersion.current());
- Assert.assertNotNull(proxy);
- }
}
\ No newline at end of file
--- /dev/null
+/*
+ * Copyright (c) 2017 Pantheon Technologies s.r.o. and others. All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * 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.controller.cluster.access.commands;
+
+import com.google.common.base.MoreObjects;
+import com.google.common.collect.Lists;
+import java.util.List;
+import java.util.Optional;
+import org.junit.Assert;
+import org.junit.Test;
+import org.opendaylight.controller.cluster.access.ABIVersion;
+
+public class ModifyTransactionRequestEmptyTest extends AbstractTransactionRequestTest<ModifyTransactionRequest> {
+ private static final PersistenceProtocol PROTOCOL = PersistenceProtocol.ABORT;
+
+ private static final ModifyTransactionRequest OBJECT = new ModifyTransactionRequest(
+ TRANSACTION_IDENTIFIER, 0, ACTOR_REF, Lists.newArrayList(), PROTOCOL);
+
+ @Override
+ protected ModifyTransactionRequest object() {
+ return OBJECT;
+ }
+
+ @Test
+ public void getPersistenceProtocolTest() throws Exception {
+ final Optional<PersistenceProtocol> result = OBJECT.getPersistenceProtocol();
+ Assert.assertTrue(result.isPresent());
+ Assert.assertEquals(PROTOCOL, result.get());
+ }
+
+ @Test
+ public void getModificationsTest() throws Exception {
+ final List<TransactionModification> result = OBJECT.getModifications();
+ Assert.assertNotNull(result);
+ Assert.assertTrue(result.isEmpty());
+ }
+
+ @Test
+ public void addToStringAttributesTest() {
+ final MoreObjects.ToStringHelper result = OBJECT.addToStringAttributes(MoreObjects.toStringHelper(OBJECT));
+ Assert.assertTrue(result.toString().contains("operations=" + Lists.newArrayList()));
+ Assert.assertTrue(result.toString().contains("protocol=" + PROTOCOL));
+ }
+
+ @Test
+ public void cloneAsVersionTest() throws Exception {
+ final ModifyTransactionRequest clone = OBJECT.cloneAsVersion(ABIVersion.BORON);
+ Assert.assertEquals(OBJECT, clone);
+ }
+
+ @Override
+ protected void doAdditionalAssertions(final Object deserialize) {
+ Assert.assertTrue(deserialize instanceof ModifyTransactionRequest);
+ final ModifyTransactionRequest casted = (ModifyTransactionRequest) deserialize;
+
+ Assert.assertEquals(OBJECT.getReplyTo(), casted.getReplyTo());
+ Assert.assertEquals(OBJECT.getModifications(), casted.getModifications());
+ Assert.assertEquals(OBJECT.getPersistenceProtocol(), casted.getPersistenceProtocol());
+ }
+}
\ No newline at end of file
+++ /dev/null
-/*
- * Copyright (c) 2017 Pantheon Technologies s.r.o. and others. All rights reserved.
- *
- * This program and the accompanying materials are made available under the
- * 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.controller.cluster.access.commands;
-
-import com.google.common.collect.Lists;
-import org.junit.Assert;
-import org.junit.Test;
-import org.opendaylight.controller.cluster.access.concepts.AbstractRequestProxyTest;
-import org.opendaylight.controller.cluster.access.concepts.Request;
-
-public class ModifyTransactionRequestProxyV1EmptyModificationsTest
- extends AbstractRequestProxyTest<ModifyTransactionRequestProxyV1> {
- private static final PersistenceProtocol PROTOCOL = PersistenceProtocol.ABORT;
- private static final ModifyTransactionRequest REQUEST = new ModifyTransactionRequest(
- TRANSACTION_IDENTIFIER, 0, ACTOR_REF, Lists.newArrayList(), PROTOCOL);
- private static final ModifyTransactionRequestProxyV1 OBJECT = new ModifyTransactionRequestProxyV1(REQUEST);
-
- @Override
- public ModifyTransactionRequestProxyV1 object() {
- return OBJECT;
- }
-
- @Test
- public void createRequestTest() {
- final Request request = object().createRequest(TRANSACTION_IDENTIFIER, 0, ACTOR_REF);
- Assert.assertNotNull(request);
- }
-}
\ No newline at end of file
+++ /dev/null
-/*
- * Copyright (c) 2017 Pantheon Technologies s.r.o. and others. All rights reserved.
- *
- * This program and the accompanying materials are made available under the
- * 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.controller.cluster.access.commands;
-
-import com.google.common.collect.Lists;
-import org.junit.Assert;
-import org.junit.Test;
-import org.opendaylight.controller.cluster.access.concepts.AbstractRequestProxyTest;
-import org.opendaylight.controller.cluster.access.concepts.Request;
-import org.opendaylight.yangtools.yang.common.QName;
-import org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier;
-import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
-import org.opendaylight.yangtools.yang.data.impl.schema.Builders;
-
-public class ModifyTransactionRequestProxyV1NotEmptyModificationsTest
- extends AbstractRequestProxyTest<ModifyTransactionRequestProxyV1> {
- private static final PersistenceProtocol PROTOCOL = PersistenceProtocol.ABORT;
- private static final NormalizedNode<?, ?> NODE = Builders.containerBuilder().withNodeIdentifier(
- YangInstanceIdentifier.NodeIdentifier.create(QName.create("namespace", "localName"))).build();
- private static final TransactionModification MODIFICATION = new TransactionWrite(
- YangInstanceIdentifier.EMPTY, NODE);
- private static final ModifyTransactionRequest REQUEST = new ModifyTransactionRequest(
- TRANSACTION_IDENTIFIER, 0, ACTOR_REF, Lists.newArrayList(MODIFICATION), PROTOCOL);
- private static final ModifyTransactionRequestProxyV1 OBJECT = new ModifyTransactionRequestProxyV1(REQUEST);
-
- @Override
- public ModifyTransactionRequestProxyV1 object() {
- return OBJECT;
- }
-
- @Test
- public void createRequestTest() {
- final Request request = object().createRequest(TRANSACTION_IDENTIFIER, 0, ACTOR_REF);
- Assert.assertNotNull(request);
- }
-}
\ No newline at end of file
*/
package org.opendaylight.controller.cluster.access.commands;
+import static org.opendaylight.controller.cluster.access.commands.TransactionModification.TYPE_WRITE;
+
import com.google.common.base.MoreObjects;
import com.google.common.collect.Lists;
import java.util.List;
YangInstanceIdentifier.NodeIdentifier.create(QName.create("namespace", "localName"))).build();
private static final List<TransactionModification> MODIFICATIONS = Lists.newArrayList(
- new TransactionWrite(YangInstanceIdentifier.EMPTY, NODE),
- new TransactionMerge(YangInstanceIdentifier.EMPTY, NODE));
+ new TransactionWrite(YangInstanceIdentifier.EMPTY, NODE));
private static final PersistenceProtocol PROTOCOL = PersistenceProtocol.ABORT;
}
@Test
- public void getPersistenceProtocol() throws Exception {
+ public void getPersistenceProtocolTest() throws Exception {
final Optional<PersistenceProtocol> result = OBJECT.getPersistenceProtocol();
Assert.assertTrue(result.isPresent());
Assert.assertEquals(PROTOCOL, result.get());
Assert.assertTrue(result.toString().contains("protocol=" + PROTOCOL));
}
- @Test
- public void externalizableProxyTest() throws Exception {
- final ModifyTransactionRequestProxyV1 proxy = OBJECT.externalizableProxy(ABIVersion.BORON);
- Assert.assertNotNull(proxy);
- }
-
@Test
public void cloneAsVersionTest() throws Exception {
final ModifyTransactionRequest clone = OBJECT.cloneAsVersion(ABIVersion.BORON);
Assert.assertEquals(OBJECT, clone);
}
+
+ @Override
+ protected void doAdditionalAssertions(final Object deserialize) {
+ Assert.assertTrue(deserialize instanceof ModifyTransactionRequest);
+ final ModifyTransactionRequest casted = (ModifyTransactionRequest) deserialize;
+
+ Assert.assertEquals(OBJECT.getReplyTo(), casted.getReplyTo());
+ Assert.assertEquals(OBJECT.getPersistenceProtocol(), casted.getPersistenceProtocol());
+
+ Assert.assertNotNull(casted.getModifications());
+ Assert.assertEquals(1, casted.getModifications().size());
+ final TransactionModification modification = casted.getModifications().get(0);
+ Assert.assertEquals(YangInstanceIdentifier.EMPTY, modification.getPath());
+ Assert.assertEquals(TYPE_WRITE, modification.getType());
+ }
}
\ No newline at end of file
private static final ModifyTransactionSuccess OBJECT = new ModifyTransactionSuccess(
TRANSACTION_IDENTIFIER, 0);
- @Test
- public void externalizableProxy() throws Exception {
- final AbstractTransactionSuccessProxy<ModifyTransactionSuccess> proxy = OBJECT.externalizableProxy(
- ABIVersion.BORON);
- Assert.assertNotNull(proxy);
+ @Override
+ protected ModifyTransactionSuccess object() {
+ return OBJECT;
}
@Test
- public void cloneAsVersion() throws Exception {
+ public void cloneAsVersionTest() throws Exception {
final ModifyTransactionSuccess clone = OBJECT.cloneAsVersion(ABIVersion.BORON);
Assert.assertEquals(OBJECT.getVersion(), clone.getVersion());
Assert.assertEquals(OBJECT.getSequence(), clone.getSequence());
}
@Test
- public void cloneAsVersion() throws Exception {
+ public void cloneAsVersionTest() throws Exception {
final ABIVersion cloneVersion = ABIVersion.TEST_FUTURE_VERSION;
final ReadTransactionRequest clone = OBJECT.cloneAsVersion(cloneVersion);
Assert.assertEquals(cloneVersion, clone.getVersion());
Assert.assertEquals(OBJECT.isSnapshotOnly(), clone.isSnapshotOnly());
}
- @Test
- public void externalizableProxy() throws Exception {
- final ABIVersion proxyVersion = ABIVersion.TEST_FUTURE_VERSION;
- final ReadTransactionRequestProxyV1 proxy = OBJECT.externalizableProxy(proxyVersion);
- Assert.assertNotNull(proxy);
+ @Override
+ protected void doAdditionalAssertions(final Object deserialize) {
+ Assert.assertTrue(deserialize instanceof ReadTransactionRequest);
+ Assert.assertEquals(OBJECT.getReplyTo(), ((ReadTransactionRequest) deserialize).getReplyTo());
+ Assert.assertEquals(OBJECT.getPath(), ((ReadTransactionRequest) deserialize).getPath());
}
}
\ No newline at end of file
--- /dev/null
+/*
+ * Copyright (c) 2017 Pantheon Technologies s.r.o. and others. All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * 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.controller.cluster.access.commands;
+
+import com.google.common.base.Optional;
+import org.junit.Assert;
+import org.junit.Test;
+import org.opendaylight.controller.cluster.access.ABIVersion;
+import org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode;
+
+public class ReadTransactionSuccessNoDataTest extends AbstractTransactionSuccessTest<ReadTransactionSuccess> {
+ private static final ReadTransactionSuccess OBJECT = new ReadTransactionSuccess(
+ TRANSACTION_IDENTIFIER, 0, Optional.absent());
+
+ @Override
+ protected ReadTransactionSuccess object() {
+ return OBJECT;
+ }
+
+ @Test
+ public void getDataTest() throws Exception {
+ final Optional<NormalizedNode<?, ?>> result = OBJECT.getData();
+ Assert.assertFalse(result.isPresent());
+ }
+
+ @Test
+ public void cloneAsVersionTest() throws Exception {
+ final ReadTransactionSuccess clone = OBJECT.cloneAsVersion(ABIVersion.BORON);
+ Assert.assertEquals(OBJECT, clone);
+ }
+}
\ No newline at end of file
private static final ReadTransactionSuccess OBJECT = new ReadTransactionSuccess(
TRANSACTION_IDENTIFIER, 0, Optional.of(NODE));
+ @Override
+ protected ReadTransactionSuccess object() {
+ return OBJECT;
+ }
+
@Test
- public void getData() throws Exception {
+ public void getDataTest() throws Exception {
final Optional<NormalizedNode<?, ?>> result = OBJECT.getData();
Assert.assertTrue(result.isPresent());
Assert.assertEquals(NODE.getValue(), result.get().getValue());
}
@Test
- public void externalizableProxy() throws Exception {
- final AbstractTransactionSuccessProxy<ReadTransactionSuccess> proxy = OBJECT.externalizableProxy(
- ABIVersion.BORON);
- Assert.assertNotNull(proxy);
- }
-
- @Test
- public void cloneAsVersion() throws Exception {
+ public void cloneAsVersionTest() throws Exception {
final ReadTransactionSuccess clone = OBJECT.cloneAsVersion(ABIVersion.BORON);
Assert.assertEquals(OBJECT, clone);
}
+++ /dev/null
-/*
- * Copyright (c) 2017 Pantheon Technologies s.r.o. and others. All rights reserved.
- *
- * This program and the accompanying materials are made available under the
- * 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.controller.cluster.access.commands;
-
-import org.junit.Assert;
-import org.junit.Test;
-import org.opendaylight.controller.cluster.access.concepts.AbstractRequestProxyTest;
-import org.opendaylight.controller.cluster.access.concepts.Request;
-
-public class TransactionAbortRequestProxyV1Test extends AbstractRequestProxyTest<TransactionAbortRequestProxyV1> {
- private static final TransactionAbortRequest REQUEST = new TransactionAbortRequest(
- TRANSACTION_IDENTIFIER, 0, ACTOR_REF);
- private static final TransactionAbortRequestProxyV1 OBJECT = new TransactionAbortRequestProxyV1(REQUEST);
-
- @Override
- public TransactionAbortRequestProxyV1 object() {
- return OBJECT;
- }
-
- @Test
- public void createRequestTest() {
- final Request request = object().createRequest(TRANSACTION_IDENTIFIER, 0, ACTOR_REF);
- Assert.assertNotNull(request);
- }
-}
\ No newline at end of file
}
@Test
- public void externalizableProxy() throws Exception {
- final TransactionAbortRequestProxyV1 proxy = OBJECT.externalizableProxy(ABIVersion.BORON);
- Assert.assertNotNull(proxy);
- }
-
- @Test
- public void cloneAsVersion() throws Exception {
+ public void cloneAsVersionTest() throws Exception {
final TransactionAbortRequest clone = OBJECT.cloneAsVersion(ABIVersion.BORON);
Assert.assertEquals(OBJECT, clone);
}
+
+ @Override
+ protected void doAdditionalAssertions(final Object deserialize) {
+ Assert.assertTrue(deserialize instanceof TransactionAbortRequest);
+ Assert.assertEquals(OBJECT.getReplyTo(), ((TransactionAbortRequest)deserialize).getReplyTo());
+ }
}
\ No newline at end of file
private static final TransactionAbortSuccess OBJECT = new TransactionAbortSuccess(
TRANSACTION_IDENTIFIER, 0);
- @Test
- public void externalizableProxy() throws Exception {
- final AbstractTransactionSuccessProxy<TransactionAbortSuccess> proxy = OBJECT.externalizableProxy(
- ABIVersion.BORON);
- Assert.assertNotNull(proxy);
+ @Override
+ protected TransactionAbortSuccess object() {
+ return OBJECT;
}
@Test
- public void cloneAsVersion() throws Exception {
+ public void cloneAsVersionTest() throws Exception {
final TransactionAbortSuccess clone = OBJECT.cloneAsVersion(ABIVersion.BORON);
Assert.assertEquals(OBJECT, clone);
}
private static final TransactionCanCommitSuccess OBJECT = new TransactionCanCommitSuccess(
TRANSACTION_IDENTIFIER, 0);
- @Test
- public void externalizableProxy() throws Exception {
- final AbstractTransactionSuccessProxy<TransactionCanCommitSuccess> proxy = OBJECT.externalizableProxy(
- ABIVersion.BORON);
- Assert.assertNotNull(proxy);
+ @Override
+ protected TransactionCanCommitSuccess object() {
+ return OBJECT;
}
@Test
- public void cloneAsVersion() throws Exception {
+ public void cloneAsVersionTest() throws Exception {
final TransactionCanCommitSuccess clone = OBJECT.cloneAsVersion(ABIVersion.BORON);
Assert.assertEquals(OBJECT, clone);
}
private static final TransactionCommitSuccess OBJECT = new TransactionCommitSuccess(
TRANSACTION_IDENTIFIER, 0);
- @Test
- public void externalizableProxy() throws Exception {
- final AbstractTransactionSuccessProxy<TransactionCommitSuccess> proxy = OBJECT.externalizableProxy(
- ABIVersion.BORON);
- Assert.assertNotNull(proxy);
+ @Override
+ protected TransactionCommitSuccess object() {
+ return OBJECT;
}
@Test
- public void cloneAsVersion() throws Exception {
+ public void cloneAsVersionTest() throws Exception {
final TransactionCommitSuccess clone = OBJECT.cloneAsVersion(ABIVersion.BORON);
Assert.assertEquals(OBJECT, clone);
}
+++ /dev/null
-/*
- * Copyright (c) 2017 Pantheon Technologies s.r.o. and others. All rights reserved.
- *
- * This program and the accompanying materials are made available under the
- * 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.controller.cluster.access.commands;
-
-import org.junit.Assert;
-import org.junit.Test;
-import org.opendaylight.controller.cluster.access.concepts.AbstractRequestProxyTest;
-import org.opendaylight.controller.cluster.access.concepts.Request;
-
-public class TransactionDoCommitRequestProxyV1Test extends AbstractRequestProxyTest<TransactionDoCommitRequestProxyV1> {
- private static final TransactionDoCommitRequest REQUEST = new TransactionDoCommitRequest(
- TRANSACTION_IDENTIFIER, 0, ACTOR_REF);
- private static final TransactionDoCommitRequestProxyV1 OBJECT = new TransactionDoCommitRequestProxyV1(REQUEST);
-
- @Override
- public TransactionDoCommitRequestProxyV1 object() {
- return OBJECT;
- }
-
- @Test
- public void createRequestTest() {
- final Request request = object().createRequest(TRANSACTION_IDENTIFIER, 0, ACTOR_REF);
- Assert.assertNotNull(request);
- }
-}
\ No newline at end of file
}
@Test
- public void externalizableProxy() throws Exception {
- final TransactionDoCommitRequestProxyV1 proxy = OBJECT.externalizableProxy(ABIVersion.BORON);
- Assert.assertNotNull(proxy);
- }
-
- @Test
- public void cloneAsVersion() throws Exception {
+ public void cloneAsVersionTest() throws Exception {
final TransactionDoCommitRequest clone = OBJECT.cloneAsVersion(ABIVersion.BORON);
Assert.assertEquals(OBJECT, clone);
}
+
+ @Override
+ protected void doAdditionalAssertions(final Object deserialize) {
+ Assert.assertTrue(deserialize instanceof TransactionDoCommitRequest);
+ Assert.assertEquals(OBJECT.getReplyTo(), ((TransactionDoCommitRequest) deserialize).getReplyTo());
+ }
}
\ No newline at end of file
}
@Test
- public void cloneAsVersion() throws Exception {
+ public void cloneAsVersionTest() throws Exception {
final TransactionFailure clone = OBJECT.cloneAsVersion(ABIVersion.current());
Assert.assertEquals(OBJECT, clone);
}
-
- @Test
- public void externalizableProxy() throws Exception {
- final TransactionFailureProxyV1 proxy = OBJECT.externalizableProxy(ABIVersion.current());
- Assert.assertNotNull(proxy);
- }
}
\ No newline at end of file
+++ /dev/null
-/*
- * Copyright (c) 2017 Pantheon Technologies s.r.o. and others. All rights reserved.
- *
- * This program and the accompanying materials are made available under the
- * 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.controller.cluster.access.commands;
-
-import org.junit.Assert;
-import org.junit.Test;
-import org.opendaylight.controller.cluster.access.concepts.AbstractRequestProxyTest;
-import org.opendaylight.controller.cluster.access.concepts.Request;
-
-public class TransactionPreCommitRequestProxyV1Test
- extends AbstractRequestProxyTest<TransactionPreCommitRequestProxyV1> {
- private static final TransactionPreCommitRequest REQUEST = new TransactionPreCommitRequest(
- TRANSACTION_IDENTIFIER, 0, ACTOR_REF);
- private static final TransactionPreCommitRequestProxyV1 OBJECT = new TransactionPreCommitRequestProxyV1(REQUEST);
-
- @Override
- public TransactionPreCommitRequestProxyV1 object() {
- return OBJECT;
- }
-
- @Test
- public void createRequestTest() {
- final Request request = object().createRequest(TRANSACTION_IDENTIFIER, 0, ACTOR_REF);
- Assert.assertNotNull(request);
- }
-}
\ No newline at end of file
}
@Test
- public void externalizableProxy() throws Exception {
- final TransactionPreCommitRequestProxyV1 proxy = OBJECT.externalizableProxy(ABIVersion.BORON);
- Assert.assertNotNull(proxy);
- }
-
- @Test
- public void cloneAsVersion() throws Exception {
+ public void cloneAsVersionTest() throws Exception {
final TransactionPreCommitRequest clone = OBJECT.cloneAsVersion(ABIVersion.BORON);
Assert.assertEquals(OBJECT, clone);
}
+
+ @Override
+ protected void doAdditionalAssertions(final Object deserialize) {
+ Assert.assertTrue(deserialize instanceof TransactionPreCommitRequest);
+ Assert.assertEquals(OBJECT.getReplyTo(), ((TransactionPreCommitRequest) deserialize).getReplyTo());
+ }
}
\ No newline at end of file
private static final TransactionPreCommitSuccess OBJECT = new TransactionPreCommitSuccess(
TRANSACTION_IDENTIFIER, 0);
- @Test
- public void externalizableProxy() throws Exception {
- final AbstractTransactionSuccessProxy<TransactionPreCommitSuccess> proxy = OBJECT.externalizableProxy(
- ABIVersion.BORON);
- Assert.assertNotNull(proxy);
+ @Override
+ protected TransactionPreCommitSuccess object() {
+ return OBJECT;
}
@Test
- public void cloneAsVersion() throws Exception {
+ public void cloneAsVersionTest() throws Exception {
final TransactionPreCommitSuccess clone = OBJECT.cloneAsVersion(ABIVersion.BORON);
Assert.assertEquals(OBJECT, clone);
}
+++ /dev/null
-/*
- * Copyright (c) 2017 Pantheon Technologies s.r.o. and others. All rights reserved.
- *
- * This program and the accompanying materials are made available under the
- * 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.controller.cluster.access.commands;
-
-import org.junit.Assert;
-import org.junit.Test;
-import org.opendaylight.controller.cluster.access.concepts.AbstractRequestProxyTest;
-import org.opendaylight.controller.cluster.access.concepts.Request;
-
-public class TransactionPurgeRequestProxyV1Test extends AbstractRequestProxyTest<TransactionPurgeRequestProxyV1> {
- private static final TransactionPurgeRequest REQUEST = new TransactionPurgeRequest(
- TRANSACTION_IDENTIFIER, 0, ACTOR_REF);
- private static final TransactionPurgeRequestProxyV1 OBJECT = new TransactionPurgeRequestProxyV1(REQUEST);
-
- @Override
- public TransactionPurgeRequestProxyV1 object() {
- return OBJECT;
- }
-
- @Test
- public void createRequestTest() {
- final Request request = object().createRequest(TRANSACTION_IDENTIFIER, 0, ACTOR_REF);
- Assert.assertNotNull(request);
- }
-}
\ No newline at end of file
}
@Test
- public void externalizableProxy() throws Exception {
- final TransactionPurgeRequestProxyV1 proxy = OBJECT.externalizableProxy(ABIVersion.BORON);
- Assert.assertNotNull(proxy);
- }
-
- @Test
- public void cloneAsVersion() throws Exception {
+ public void cloneAsVersionTest() throws Exception {
final TransactionPurgeRequest clone = OBJECT.cloneAsVersion(ABIVersion.BORON);
Assert.assertEquals(OBJECT, clone);
}
+
+ @Override
+ protected void doAdditionalAssertions(final Object deserialize) {
+ Assert.assertTrue(deserialize instanceof TransactionPurgeRequest);
+ Assert.assertEquals(OBJECT.getReplyTo(), ((TransactionPurgeRequest) deserialize).getReplyTo());
+ }
}
\ No newline at end of file
private static final TransactionPurgeResponse OBJECT = new TransactionPurgeResponse(
TRANSACTION_IDENTIFIER, 0);
- @Test
- public void externalizableProxy() throws Exception {
- final AbstractTransactionSuccessProxy<TransactionPurgeResponse> proxy = OBJECT.externalizableProxy(
- ABIVersion.BORON);
- Assert.assertNotNull(proxy);
+ @Override
+ protected TransactionPurgeResponse object() {
+ return OBJECT;
}
@Test
- public void cloneAsVersion() throws Exception {
+ public void cloneAsVersionTest() throws Exception {
final TransactionPurgeResponse clone = OBJECT.cloneAsVersion(ABIVersion.BORON);
Assert.assertEquals(OBJECT, clone);
}
+++ /dev/null
-/*
- * Copyright (c) 2017 Pantheon Technologies s.r.o. and others. All rights reserved.
- *
- * This program and the accompanying materials are made available under the
- * 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.controller.cluster.access.concepts;
-
-import akka.actor.ActorRef;
-import akka.actor.ActorSystem;
-import akka.actor.ExtendedActorSystem;
-import akka.serialization.JavaSerializer;
-import akka.testkit.TestProbe;
-import java.io.ByteArrayInputStream;
-import java.io.ByteArrayOutputStream;
-import java.io.ObjectInputStream;
-import java.io.ObjectOutputStream;
-import java.lang.reflect.Constructor;
-import org.junit.Assert;
-import org.junit.Before;
-import org.junit.Test;
-
-public abstract class AbstractRequestProxyTest<T extends AbstractRequestProxy> {
- public abstract T object();
-
- private static final FrontendIdentifier FRONTEND_IDENTIFIER = FrontendIdentifier.create(
- MemberName.forName("test"), FrontendType.forName("one"));
- protected static final ClientIdentifier CLIENT_IDENTIFIER = ClientIdentifier.create(FRONTEND_IDENTIFIER, 0);
-
- private static final LocalHistoryIdentifier HISTORY_IDENTIFIER = new LocalHistoryIdentifier(
- CLIENT_IDENTIFIER, 0);
- protected static final TransactionIdentifier TRANSACTION_IDENTIFIER = new TransactionIdentifier(
- HISTORY_IDENTIFIER, 0);
-
- private static final ActorSystem SYSTEM = ActorSystem.create("test");
- protected static final ActorRef ACTOR_REF = TestProbe.apply(SYSTEM).ref();
-
- @Before
- public void setUp() {
- JavaSerializer.currentSystem().value_$eq((ExtendedActorSystem) SYSTEM);
- }
-
- @Test
- public void externalizableTest() throws Exception {
- final T copy = copy();
- Assert.assertTrue(copy != null);
- }
-
- @SuppressWarnings("unchecked")
- private T copy() throws Exception {
- final ByteArrayOutputStream bos = new ByteArrayOutputStream();
- try (ObjectOutputStream oos = new ObjectOutputStream(bos)) {
- object().writeExternal(oos);
- }
-
- try (ObjectInputStream ois = new ObjectInputStream(new ByteArrayInputStream(bos.toByteArray()))) {
- final Constructor constructor = object().getClass().getConstructor();
- constructor.setAccessible(true);
- final T result = (T) constructor.newInstance();
- result.readExternal(ois);
- return result;
- }
- }
-
- @Test
- public void readTargetTest() throws Exception {
- final ByteArrayOutputStream bos = new ByteArrayOutputStream();
- try (ObjectOutputStream oos = new ObjectOutputStream(bos)) {
- object().writeExternal(oos);
- }
-
- final ObjectInputStream ois = new ObjectInputStream(new ByteArrayInputStream(bos.toByteArray()));
- Assert.assertNotNull(object().readTarget(ois));
- }
-}
\ No newline at end of file
import akka.actor.ActorRef;
import akka.actor.ActorSystem;
+import akka.actor.ExtendedActorSystem;
+import akka.serialization.JavaSerializer;
import akka.testkit.TestProbe;
import com.google.common.base.MoreObjects;
+import org.apache.commons.lang.SerializationUtils;
import org.junit.Assert;
+import org.junit.Before;
import org.junit.Test;
public abstract class AbstractRequestTest<T extends Request> {
protected abstract T object();
+ @Before
+ public void setUp() {
+ JavaSerializer.currentSystem().value_$eq((ExtendedActorSystem) SYSTEM);
+ }
+
@Test
- public void getReplyToTest() {}
+ public void getReplyToTest() {
+ Assert.assertEquals(ACTOR_REF, object().getReplyTo());
+ }
@Test
public void addToStringAttributesCommonTest() {
final MoreObjects.ToStringHelper result = object().addToStringAttributes(MoreObjects.toStringHelper(object()));
Assert.assertTrue(result.toString().contains("replyTo=" + ACTOR_REF));
}
+
+ @SuppressWarnings("unchecked")
+ @Test
+ public void serializationTest() {
+ final Object deserialize = SerializationUtils.clone(object());
+
+ Assert.assertEquals(object().getTarget(), ((T) deserialize).getTarget());
+ Assert.assertEquals(object().getVersion(), ((T) deserialize).getVersion());
+ Assert.assertEquals(object().getSequence(), ((T) deserialize).getSequence());
+ doAdditionalAssertions((T) deserialize);
+ }
+
+ protected abstract void doAdditionalAssertions(final Object deserialize);
}
Code Review / controller.git / commitdiff