private final SchemaSourceProvider<YangTextSchemaSource> rootSchemaSourceProviderDependency;
private final NetconfOperationServiceFactoryListener netconfOperationServiceFactoryListener;
- public MdsalNetconfOperationServiceFactory(final SchemaService schemaService,
- final SchemaSourceProvider<YangTextSchemaSource> rootSchemaSourceProviderDependency,
- final NetconfOperationServiceFactoryListener netconfOperationServiceFactoryListener,
- final DOMDataBroker dataBroker,
- final DOMRpcService rpcService) {
+ public MdsalNetconfOperationServiceFactory(
+ final SchemaService schemaService,
+ final SchemaSourceProvider<YangTextSchemaSource> rootSchemaSourceProviderDependency,
+ final NetconfOperationServiceFactoryListener netconfOperationServiceFactoryListener,
+ final DOMDataBroker dataBroker,
+ final DOMRpcService rpcService) {
this.dataBroker = dataBroker;
this.rpcService = rpcService;
this.rootSchemaSourceProviderDependency = rootSchemaSourceProviderDependency;
- this.currentSchemaContext = new CurrentSchemaContext(Preconditions.checkNotNull(schemaService), rootSchemaSourceProviderDependency);
+ this.currentSchemaContext = new CurrentSchemaContext(Preconditions.checkNotNull(schemaService),
+ rootSchemaSourceProviderDependency);
this.netconfOperationServiceFactoryListener = netconfOperationServiceFactoryListener;
this.netconfOperationServiceFactoryListener.onAddNetconfOperationServiceFactory(this);
}
@Override
public MdsalNetconfOperationService createService(final String netconfSessionIdForReporting) {
Preconditions.checkState(dataBroker != null, "MD-SAL provider not yet initialized");
- return new MdsalNetconfOperationService(currentSchemaContext, netconfSessionIdForReporting, dataBroker, rpcService);
+ return new MdsalNetconfOperationService(currentSchemaContext, netconfSessionIdForReporting, dataBroker,
+ rpcService);
}
+ @SuppressWarnings("checkstyle:IllegalCatch")
@Override
public void close() {
try {
if (netconfOperationServiceFactoryListener != null) {
netconfOperationServiceFactoryListener.onRemoveNetconfOperationServiceFactory(this);
}
- } catch(Exception e) {
+ } catch (Exception e) {
LOG.error("Failed to close resources correctly - ignore", e);
}
}
return transformCapabilities(currentSchemaContext.getCurrentContext(), rootSchemaSourceProviderDependency);
}
- static Set<Capability> transformCapabilities(final SchemaContext currentContext, final SchemaSourceProvider<YangTextSchemaSource> rootSchemaSourceProviderDependency) {
+ static Set<Capability> transformCapabilities(
+ final SchemaContext currentContext,
+ final SchemaSourceProvider<YangTextSchemaSource> rootSchemaSourceProviderDependency) {
final Set<Capability> capabilities = new HashSet<>();
// Added by netconf-impl by default
-// capabilities.add(new BasicCapability("urn:ietf:params:netconf:capability:candidate:1.0"));
+ // capabilities.add(new BasicCapability("urn:ietf:params:netconf:capability:candidate:1.0"));
final Set<Module> modules = currentContext.getModules();
for (final Module module : modules) {
Optional<YangModuleCapability> cap = moduleToCapability(module, rootSchemaSourceProviderDependency);
- if(cap.isPresent()) {
+ if (cap.isPresent()) {
capabilities.add(cap.get());
}
for (final Module submodule : module.getSubmodules()) {
cap = moduleToCapability(submodule, rootSchemaSourceProviderDependency);
- if(cap.isPresent()) {
+ if (cap.isPresent()) {
capabilities.add(cap.get());
}
}
InputStream sourceStream = null;
String source;
try {
- sourceStream = rootSchemaSourceProviderDependency.getSource(moduleSourceIdentifier).checkedGet().openStream();
+ sourceStream = rootSchemaSourceProviderDependency.getSource(moduleSourceIdentifier).checkedGet()
+ .openStream();
source = CharStreams.toString(new InputStreamReader(sourceStream, StandardCharsets.UTF_8));
} catch (IOException | SchemaSourceException e) {
LOG.warn("Ignoring source for module {}. Unable to read content", moduleSourceIdentifier, e);
LOG.warn("Error closing yang source stream {}. Ignoring", moduleSourceIdentifier, e);
}
- if(source !=null) {
+ if (source != null) {
return Optional.of(new YangModuleCapability(module, source));
} else {
LOG.warn("Missing source for module {}. This module will not be available from netconf server",