import org.opendaylight.mdsal.binding.api.WriteTransaction;
import org.opendaylight.mdsal.common.api.CommitInfo;
import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
-import org.opendaylight.mdsal.dom.api.DOMActionProviderService;
import org.opendaylight.mdsal.dom.api.DOMMountPointService;
-import org.opendaylight.mdsal.dom.api.DOMRpcProviderService;
import org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceProvider;
import org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceRegistration;
import org.opendaylight.mdsal.singleton.common.api.ServiceGroupIdentifier;
private final BaseNetconfSchemas baseSchemas;
private final DataBroker dataBroker;
- private final DOMRpcProviderService rpcProviderRegistry;
- private final DOMActionProviderService actionProviderRegistry;
private final ClusterSingletonServiceProvider clusterSingletonServiceProvider;
private final ScheduledExecutorService keepaliveExecutorService;
private final Executor processingExecutorService;
public NetconfTopologyManager(final BaseNetconfSchemas baseSchemas, final DataBroker dataBroker,
- final DOMRpcProviderService rpcProviderRegistry,
- final DOMActionProviderService actionProviderService,
final ClusterSingletonServiceProvider clusterSingletonServiceProvider,
final ScheduledThreadPool keepaliveExecutor, final ThreadPool processingExecutor,
final ActorSystemProvider actorSystemProvider,
final NetconfClientConfigurationBuilderFactory builderFactory) {
this.baseSchemas = requireNonNull(baseSchemas);
this.dataBroker = requireNonNull(dataBroker);
- this.rpcProviderRegistry = requireNonNull(rpcProviderRegistry);
- actionProviderRegistry = requireNonNull(actionProviderService);
this.clusterSingletonServiceProvider = requireNonNull(clusterSingletonServiceProvider);
keepaliveExecutorService = keepaliveExecutor.getExecutor();
processingExecutorService = processingExecutor.getExecutor();
.setBaseSchemas(baseSchemas)
.setDataBroker(dataBroker)
.setInstanceIdentifier(instanceIdentifier)
- .setRpcProviderRegistry(rpcProviderRegistry)
- .setActionProviderRegistry(actionProviderRegistry)
.setNode(node)
.setActorSystem(actorSystem)
.setEventExecutor(eventExecutor)
import java.util.concurrent.Executor;
import java.util.concurrent.ScheduledExecutorService;
import org.opendaylight.mdsal.binding.api.DataBroker;
-import org.opendaylight.mdsal.dom.api.DOMActionProviderService;
-import org.opendaylight.mdsal.dom.api.DOMRpcProviderService;
import org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceProvider;
import org.opendaylight.netconf.client.NetconfClientDispatcher;
import org.opendaylight.netconf.client.mdsal.NetconfDevice;
public class NetconfTopologySetup {
private final ClusterSingletonServiceProvider clusterSingletonServiceProvider;
- private final DOMRpcProviderService rpcProviderRegistry;
- private final DOMActionProviderService actionProviderRegistry;
private final DataBroker dataBroker;
private final InstanceIdentifier<Node> instanceIdentifier;
private final Node node;
NetconfTopologySetup(final NetconfTopologySetupBuilder builder) {
clusterSingletonServiceProvider = builder.getClusterSingletonServiceProvider();
- rpcProviderRegistry = builder.getRpcProviderRegistry();
- actionProviderRegistry = builder.getActionProviderRegistry();
dataBroker = builder.getDataBroker();
instanceIdentifier = builder.getInstanceIdentifier();
node = builder.getNode();
return clusterSingletonServiceProvider;
}
- public DOMRpcProviderService getRpcProviderRegistry() {
- return rpcProviderRegistry;
- }
-
- public DOMActionProviderService getActionProviderRegistry() {
- return actionProviderRegistry;
- }
-
public DataBroker getDataBroker() {
return dataBroker;
}
public static class NetconfTopologySetupBuilder {
private ClusterSingletonServiceProvider clusterSingletonServiceProvider;
- private DOMRpcProviderService rpcProviderRegistry;
- private DOMActionProviderService actionProviderRegistry;
private DataBroker dataBroker;
private InstanceIdentifier<Node> instanceIdentifier;
private Node node;
return this;
}
- DOMRpcProviderService getRpcProviderRegistry() {
- return rpcProviderRegistry;
- }
-
- public NetconfTopologySetupBuilder setRpcProviderRegistry(final DOMRpcProviderService rpcProviderRegistry) {
- this.rpcProviderRegistry = rpcProviderRegistry;
- return this;
- }
-
- DOMActionProviderService getActionProviderRegistry() {
- return actionProviderRegistry;
- }
-
- public NetconfTopologySetupBuilder setActionProviderRegistry(
- final DOMActionProviderService actionProviderRegistry) {
- this.actionProviderRegistry = actionProviderRegistry;
- return this;
- }
-
DataBroker getDataBroker() {
return dataBroker;
}
interface="org.opendaylight.mdsal.binding.api.DataBroker"/>
<reference id="rpcProvider"
interface="org.opendaylight.mdsal.binding.api.RpcProviderService"/>
- <reference id="rpcRegistry"
- interface="org.opendaylight.mdsal.dom.api.DOMRpcProviderService"/>
- <reference id="actionRegistry"
- interface="org.opendaylight.mdsal.dom.api.DOMActionProviderService"/>
<reference id="clusterSingletonService"
interface="org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceProvider"/>
<reference id="keepAliveExecutor"
init-method="init" destroy-method="close">
<argument ref="baseSchemas"/>
<argument ref="dataBroker"/>
- <argument ref="rpcRegistry"/>
- <argument ref="actionRegistry"/>
<argument ref="clusterSingletonService"/>
<argument ref="keepAliveExecutor"/>
<argument ref="processingExecutor"/>
import org.opendaylight.mdsal.binding.dom.codec.api.BindingNormalizedNodeSerializer;
import org.opendaylight.mdsal.binding.runtime.spi.BindingRuntimeHelpers;
import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
-import org.opendaylight.mdsal.dom.api.DOMActionProviderService;
import org.opendaylight.mdsal.dom.api.DOMActionService;
import org.opendaylight.mdsal.dom.api.DOMDataBroker;
import org.opendaylight.mdsal.dom.api.DOMDataTreeReadOperations;
import org.opendaylight.mdsal.dom.api.DOMRpcAvailabilityListener;
import org.opendaylight.mdsal.dom.api.DOMRpcIdentifier;
import org.opendaylight.mdsal.dom.api.DOMRpcImplementation;
-import org.opendaylight.mdsal.dom.api.DOMRpcProviderService;
import org.opendaylight.mdsal.dom.api.DOMRpcResult;
import org.opendaylight.mdsal.dom.api.DOMRpcService;
import org.opendaylight.mdsal.dom.api.DOMService;
private static final String TEST_ROOT_DIRECTORY = "test-cache-root";
private static final String TEST_DEFAULT_SUBDIR = "test-schema";
- @Mock private DOMRpcProviderService mockRpcProviderRegistry;
@Mock private RpcProviderService mockRpcProviderService;
- @Mock private DOMActionProviderService mockActionProviderRegistry;
@Mock private NetconfClientDispatcher mockClientDispatcher;
@Mock private AAAEncryptionService mockEncryptionService;
@Mock private ThreadPool mockThreadPool;
YangTextSchemaSource.class, 1));
masterNetconfTopologyManager = new NetconfTopologyManager(BASE_SCHEMAS, masterDataBroker,
- mockRpcProviderRegistry, mockActionProviderRegistry, masterClusterSingletonServiceProvider,
- mockKeepaliveExecutor, mockThreadPool, mockMasterActorSystemProvider, eventExecutor,
- mockClientDispatcher, TOPOLOGY_ID, config, masterMountPointService, mockEncryptionService,
- mockRpcProviderService, deviceActionFactory, resourceManager, builderFactory) {
+ masterClusterSingletonServiceProvider, mockKeepaliveExecutor, mockThreadPool,
+ mockMasterActorSystemProvider, eventExecutor, mockClientDispatcher, TOPOLOGY_ID, config,
+ masterMountPointService, mockEncryptionService, mockRpcProviderService, deviceActionFactory,
+ resourceManager, builderFactory) {
@Override
protected NetconfTopologyContext newNetconfTopologyContext(final NetconfTopologySetup setup,
final ServiceGroupIdentifier serviceGroupIdent, final Timeout actorResponseWaitTime,
doReturn(mockSlaveClusterSingletonServiceReg).when(mockSlaveClusterSingletonServiceProvider)
.registerClusterSingletonService(any());
- slaveNetconfTopologyManager = new NetconfTopologyManager(BASE_SCHEMAS, slaveDataBroker, mockRpcProviderRegistry,
- mockActionProviderRegistry, mockSlaveClusterSingletonServiceProvider, mockKeepaliveExecutor, mockThreadPool,
+ slaveNetconfTopologyManager = new NetconfTopologyManager(BASE_SCHEMAS, slaveDataBroker,
+ mockSlaveClusterSingletonServiceProvider, mockKeepaliveExecutor, mockThreadPool,
mockSlaveActorSystemProvider, eventExecutor, mockClientDispatcher, TOPOLOGY_ID, config,
slaveMountPointService, mockEncryptionService, mockRpcProviderService, deviceActionFactory,
resourceManager, builderFactory) {
import org.opendaylight.mdsal.binding.dom.adapter.test.AbstractDataBrokerTest;
import org.opendaylight.mdsal.binding.runtime.spi.BindingRuntimeHelpers;
import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
-import org.opendaylight.mdsal.dom.api.DOMActionProviderService;
import org.opendaylight.mdsal.dom.api.DOMMountPointService;
-import org.opendaylight.mdsal.dom.api.DOMRpcProviderService;
import org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceProvider;
import org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceRegistration;
import org.opendaylight.mdsal.singleton.common.api.ServiceGroupIdentifier;
dataBrokerTest.setup();
dataBroker = spy(dataBrokerTest.getDataBroker());
- final DOMRpcProviderService rpcProviderRegistry = mock(DOMRpcProviderService.class);
final ScheduledThreadPool keepaliveExecutor = mock(ScheduledThreadPool.class);
- final DOMActionProviderService actionProviderRegistry = mock(DOMActionProviderService.class);
final ThreadPool processingThreadPool = mock(ThreadPool.class);
final ExecutorService processingService = mock(ExecutorService.class);
doReturn(processingService).when(processingThreadPool).getExecutor();
mock(NetconfClientConfigurationBuilderFactory.class);
final Config config = new ConfigBuilder().setWriteTransactionIdleTimeout(Uint16.ZERO).build();
- netconfTopologyManager = new NetconfTopologyManager(BASE_SCHEMAS, dataBroker, rpcProviderRegistry,
- actionProviderRegistry, clusterSingletonServiceProvider, keepaliveExecutor, processingThreadPool,
- actorSystemProvider, eventExecutor, clientDispatcher, TOPOLOGY_ID, config,
- mountPointService, encryptionService, rpcProviderService, deviceActionFactory,
+ netconfTopologyManager = new NetconfTopologyManager(BASE_SCHEMAS, dataBroker, clusterSingletonServiceProvider,
+ keepaliveExecutor, processingThreadPool, actorSystemProvider, eventExecutor, clientDispatcher,
+ TOPOLOGY_ID, config, mountPointService, encryptionService, rpcProviderService, deviceActionFactory,
new DefaultSchemaResourceManager(new DefaultYangParserFactory()), builderFactory) {
@Override
protected NetconfTopologyContext newNetconfTopologyContext(final NetconfTopologySetup setup,