1 package org.opendaylight.controller.netconf.test.tool;
3 import io.netty.util.Timer;
4 import java.net.SocketAddress;
5 import java.util.HashMap;
8 import org.opendaylight.controller.netconf.api.monitoring.NetconfMonitoringService;
9 import org.opendaylight.controller.netconf.impl.CommitNotifier;
10 import org.opendaylight.controller.netconf.impl.NetconfServerSessionNegotiatorFactory;
11 import org.opendaylight.controller.netconf.impl.SessionIdProvider;
12 import org.opendaylight.controller.netconf.mapping.api.NetconfOperationService;
13 import org.opendaylight.controller.netconf.mapping.api.NetconfOperationServiceFactory;
15 public class TesttoolNegotiationFactory extends NetconfServerSessionNegotiatorFactory {
17 private final Map<SocketAddress, NetconfOperationService> cachedOperationServices = new HashMap<>();
19 public TesttoolNegotiationFactory(final Timer timer, final NetconfOperationServiceFactory netconfOperationProvider,
20 final SessionIdProvider idProvider, final long connectionTimeoutMillis,
21 final CommitNotifier commitNotifier, final NetconfMonitoringService monitoringService) {
22 super(timer, netconfOperationProvider, idProvider, connectionTimeoutMillis, commitNotifier, monitoringService);
25 public TesttoolNegotiationFactory(final Timer timer, final NetconfOperationServiceFactory netconfOperationProvider,
26 final SessionIdProvider idProvider, final long connectionTimeoutMillis,
27 final CommitNotifier commitNotifier, final NetconfMonitoringService monitoringService,
28 final Set<String> baseCapabilities) {
29 super(timer, netconfOperationProvider, idProvider, connectionTimeoutMillis, commitNotifier, monitoringService, baseCapabilities);
33 protected NetconfOperationService getOperationServiceForAddress(final String netconfSessionIdForReporting, final SocketAddress socketAddress) {
34 if (cachedOperationServices.containsKey(socketAddress)) {
35 return cachedOperationServices.get(socketAddress);
37 final NetconfOperationService service = getOperationServiceFactory().createService(netconfSessionIdForReporting);
38 cachedOperationServices.put(socketAddress, service);