X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=servicehandler%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Ftransportpce%2Fservicehandler%2Flisteners%2FPceListenerImpl.java;h=097e258235d2278c3836db85f42de1f8b20a07d4;hb=ca352e7e2f513a844dd697f1b15b9471abbf0d5d;hp=cc003739098640a5e93129234deae99999b3bf0b;hpb=4bb3743a3214fb481e4cc147914a314c9ff6d1c3;p=transportpce.git diff --git a/servicehandler/src/main/java/org/opendaylight/transportpce/servicehandler/listeners/PceListenerImpl.java b/servicehandler/src/main/java/org/opendaylight/transportpce/servicehandler/listeners/PceListenerImpl.java index cc0037390..097e25823 100644 --- a/servicehandler/src/main/java/org/opendaylight/transportpce/servicehandler/listeners/PceListenerImpl.java +++ b/servicehandler/src/main/java/org/opendaylight/transportpce/servicehandler/listeners/PceListenerImpl.java @@ -96,6 +96,7 @@ public class PceListenerImpl implements TransportpcePceListener, PceListener { private void onPathComputationResult(ServicePathRpcResult notification) { LOG.info("PCE '{}' Notification received : {}", servicePathRpcResult.getNotificationType().getName(), notification); + if (!checkStatus(notification)) { return; } @@ -119,7 +120,9 @@ public class PceListenerImpl implements TransportpcePceListener, PceListener { } OperationResult operationResult = null; if (tempService) { - operationResult = this.serviceDataStoreOperations.createTempService(input.getTempServiceCreateInput()); + operationResult = + this.serviceDataStoreOperations.createTempService( + input.getTempServiceCreateInput(), pathDescription); if (!operationResult.isSuccess()) { LOG.error("Temp Service not created in datastore !"); } @@ -150,7 +153,8 @@ public class PceListenerImpl implements TransportpcePceListener, PceListener { ServiceImplementationRequestInput serviceImplementationRequest = ModelMappingUtils.createServiceImplementationRequest(input, pathDescription); LOG.info("Sending serviceImplementation request : {}", serviceImplementationRequest); - this.rendererServiceOperations.serviceImplementation(serviceImplementationRequest); + LOG.debug("Temp-service value is {}", tempService); + this.rendererServiceOperations.serviceImplementation(serviceImplementationRequest, tempService); } /**