messageTransformer = new NetconfMessageTransformer(result);
updateTransformer(messageTransformer);
- notificationHandler.onRemoteSchemaUp(messageTransformer);
+ // salFacade.onDeviceConnected has to be called before the notification handler is initialized
salFacade.onDeviceConnected(result, remoteSessionCapabilities, deviceRpc);
+ notificationHandler.onRemoteSchemaUp(messageTransformer);
logger.info("{}: Netconf connector initialized successfully", id);
}
this.notificationService = notificationService;
registration = mountBuilder.register();
+ logger.debug("{}: Mountpoint exposed into MD-SAL {}", id, registration);
}
@Deprecated
synchronized void onDeviceDisconnected() {
if(registration == null) {
+ logger.trace("{}: Not removing mountpoint from MD-SAL, mountpoint was not registered yet", id);
return;
}
// Only log and ignore
logger.warn("Unable to unregister mount instance for {}. Ignoring exception", id.getPath(), e);
} finally {
+ logger.debug("{}: Mountpoint removed from MD-SAL {}", id, registration);
registration = null;
}
}
mountBuilder.addService(DOMNotificationService.class, notificationService);
topologyRegistration = mountBuilder.register();
+ logger.debug("{}: TOPOLOGY Mountpoint exposed into MD-SAL {}", id, registration);
+
}
synchronized void onTopologyDeviceDisconnected() {
if(topologyRegistration == null) {
+ logger.trace("{}: Not removing TOPOLOGY mountpoint from MD-SAL, mountpoint was not registered yet", id);
return;
}
// Only log and ignore
logger.warn("Unable to unregister mount instance for {}. Ignoring exception", id.getTopologyPath(), e);
} finally {
+ logger.debug("{}: TOPOLOGY Mountpoint removed from MD-SAL {}", id, registration);
topologyRegistration = null;
}
}
@Override
synchronized public void close() throws Exception {
- if(registration != null) {
- onDeviceDisconnected();
- onTopologyDeviceDisconnected();
- }
+ onDeviceDisconnected();
+ onTopologyDeviceDisconnected();
mountService = null;
}