import com.google.common.collect.Lists;
import java.net.InetSocketAddress;
import java.util.Arrays;
+import org.junit.AfterClass;
import org.junit.Assert;
import org.junit.Before;
+import org.junit.BeforeClass;
import org.junit.Test;
import org.mockito.Mock;
import org.mockito.MockitoAnnotations;
import org.opendaylight.yangtools.yang.model.api.SchemaPath;
public class NetconfDeviceDataBrokerTest {
+ private static SchemaContext SCHEMA_CONTEXT;
@Mock
private DOMRpcService rpcService;
- private SchemaContext schemaContext;
private NetconfDeviceDataBroker dataBroker;
- @Before
- public void setUp() throws Exception {
- MockitoAnnotations.initMocks(this);
+ @BeforeClass
+ public static void beforeClass() {
final ModuleInfoBackedContext moduleInfoBackedContext = ModuleInfoBackedContext.create();
moduleInfoBackedContext.addModuleInfos(
Lists.newArrayList($YangModuleInfoImpl.getInstance(),
org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns
.netconf.base._1._0.rev110601.$YangModuleInfoImpl.getInstance()));
- schemaContext = moduleInfoBackedContext.tryToCreateSchemaContext().get();
+ SCHEMA_CONTEXT = moduleInfoBackedContext.tryToCreateSchemaContext().get();
+ }
+
+ @AfterClass
+ public static void afterClass() {
+ SCHEMA_CONTEXT = null;
+ }
+
+ @Before
+ public void setUp() throws Exception {
+ MockitoAnnotations.initMocks(this);
+
DOMRpcResult result = new DefaultDOMRpcResult();
when(rpcService.invokeRpc(any(SchemaPath.class), any(NormalizedNode.class)))
.thenReturn(FluentFutures.immediateFluentFuture(result));
NetconfSessionPreferences prefs = NetconfSessionPreferences.fromStrings(Arrays.asList(caps));
final RemoteDeviceId id =
new RemoteDeviceId("device-1", InetSocketAddress.createUnresolved("localhost", 17830));
- return new NetconfDeviceDataBroker(id, schemaContext, rpcService, prefs);
+ return new NetconfDeviceDataBroker(id, SCHEMA_CONTEXT, rpcService, prefs);
}
}
import java.util.Collection;
import java.util.Collections;
import java.util.Set;
+import org.junit.AfterClass;
import org.junit.Assert;
import org.junit.Before;
+import org.junit.BeforeClass;
import org.junit.Test;
import org.mockito.ArgumentCaptor;
import org.mockito.Mock;
import org.w3c.dom.Node;
public class NetconfDeviceRpcTest {
+ private static SchemaContext SCHEMA_CONTEXT;
@Mock
private DOMRpcAvailabilityListener listener;
private NetconfDeviceRpc rpc;
private SchemaPath path;
private DOMRpcResult expectedReply;
- private SchemaContext schema;
+
+ @BeforeClass
+ public static void beforeClass() {
+ final ModuleInfoBackedContext moduleInfoBackedContext = ModuleInfoBackedContext.create();
+ moduleInfoBackedContext.addModuleInfos(Collections.singleton($YangModuleInfoImpl.getInstance()));
+ SCHEMA_CONTEXT = moduleInfoBackedContext.tryToCreateSchemaContext().get();
+ }
+
+ @AfterClass
+ public static void afterClass() {
+ SCHEMA_CONTEXT = null;
+ }
@Before
public void setUp() throws Exception {
MockitoAnnotations.initMocks(this);
- schema = getSchema();
- NetconfMessageTransformer transformer = new NetconfMessageTransformer(schema, true);
+ NetconfMessageTransformer transformer = new NetconfMessageTransformer(SCHEMA_CONTEXT, true);
final NetconfMessage reply = new NetconfMessage(XmlUtil.readXmlToDocument(
"<?xml version=\"1.0\" encoding=\"UTF-8\" standalone=\"no\"?>\n"
+ "<rpc-reply xmlns=\"urn:ietf:params:xml:ns:netconf:base:1.0\" message-id=\"101\">\n"
RpcResult<NetconfMessage> result = RpcResultBuilder.success(reply).build();
doReturn(Futures.immediateFuture(result))
.when(communicator).sendRequest(any(NetconfMessage.class), any(QName.class));
- rpc = new NetconfDeviceRpc(schema, communicator, transformer);
+ rpc = new NetconfDeviceRpc(SCHEMA_CONTEXT, communicator, transformer);
path = SchemaPath
.create(true, QName.create("urn:ietf:params:xml:ns:netconf:base:1.0", "2011-06-01", "get-config"));
verify(listener).onRpcAvailable(argument.capture());
final Collection<DOMRpcIdentifier> argValue = argument.getValue();
- final Set<RpcDefinition> operations = schema.getOperations();
+ final Set<RpcDefinition> operations = SCHEMA_CONTEXT.getOperations();
Assert.assertEquals(argValue.size(), operations.size());
for (RpcDefinition operation : operations) {
final DOMRpcIdentifier domRpcIdentifier = DOMRpcIdentifier.create(operation.getPath());
return Builders.containerBuilder().withNodeIdentifier(
new YangInstanceIdentifier.NodeIdentifier(QName.create(namespace, date, localName))).build();
}
-
- private static SchemaContext getSchema() {
- final ModuleInfoBackedContext moduleInfoBackedContext = ModuleInfoBackedContext.create();
- moduleInfoBackedContext.addModuleInfos(Collections.singleton($YangModuleInfoImpl.getInstance()));
- return moduleInfoBackedContext.tryToCreateSchemaContext().get();
- }
}