Creation of OTS-OMS interfaces

[transportpce.git] / renderer / src / main / java / org / opendaylight / transportpce / renderer / rpcs / DeviceRendererRPCImpl.java

diff --git a/renderer/src/main/java/org/opendaylight/transportpce/renderer/rpcs/DeviceRendererRPCImpl.java b/renderer/src/main/java/org/opendaylight/transportpce/renderer/rpcs/DeviceRendererRPCImpl.java
index 0edd950b3c6f46747e40282f5b2f9887b4ea5127..636c9fe32f3c4b14d81b6ae4c9185172f39c5dac 100644 (file)
--- a/renderer/src/main/java/org/opendaylight/transportpce/renderer/rpcs/DeviceRendererRPCImpl.java
+++ b/renderer/src/main/java/org/opendaylight/transportpce/renderer/rpcs/DeviceRendererRPCImpl.java
@@ -9,7 +9,10 @@
 package org.opendaylight.transportpce.renderer.rpcs;
 
 import com.google.common.util.concurrent.ListenableFuture;
+import org.opendaylight.transportpce.common.openroadminterfaces.OpenRoadmInterfaceException;
 import org.opendaylight.transportpce.renderer.provisiondevice.DeviceRendererService;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.renderer.rev170228.CreateOtsOmsInput;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.renderer.rev170228.CreateOtsOmsOutput;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.renderer.rev170228.RendererRollbackInput;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.renderer.rev170228.RendererRollbackOutput;
 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.renderer.rev170228.RendererService;
@@ -69,11 +72,25 @@ public class DeviceRendererRPCImpl implements RendererService {
     /**
      * Rollback created interfaces and cross connects specified by input.
      *
-     * @param input Lists of created interfaces and connections per node
+     * @param input
+     *            Lists of created interfaces and connections per node
      * @return Success flag and nodes which failed to rollback
      */
     @Override
     public ListenableFuture<RpcResult<RendererRollbackOutput>> rendererRollback(RendererRollbackInput input) {
         return RpcResultBuilder.success(this.deviceRenderer.rendererRollback(input)).buildFuture();
     }
+
+    @Override
+    public ListenableFuture<RpcResult<CreateOtsOmsOutput>> createOtsOms(CreateOtsOmsInput input) {
+        LOG.info("Request received to create oms and ots interfaces on {}: {}", input.getNodeId(), input
+            .getLogicalConnectionPoint());
+        try {
+            return RpcResultBuilder.success(deviceRenderer.createOtsOms(input)).buildFuture();
+        } catch (OpenRoadmInterfaceException e) {
+            LOG.error("failed to create oms and ots interfaces on {}: {}", input.getNodeId(), input
+                    .getLogicalConnectionPoint(),e);
+        }
+        return null;
+    }
 }