+++ /dev/null
-/*
- * Copyright © 2017 Orange, Inc. and others. All rights reserved.
- *
- * This program and the accompanying materials are made available under the
- * terms of the Eclipse Public License v1.0 which accompanies this distribution,
- * and is available at http://www.eclipse.org/legal/epl-v10.html
- */
-
-
-package org.opendaylight.transportpce.stubpce;
-
-import java.util.ArrayList;
-import java.util.List;
-
-import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev170426.path.description.AToZDirection;
-import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev170426.path.description.AToZDirectionBuilder;
-import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev170426.path.description.ZToADirection;
-import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev170426.path.description.ZToADirectionBuilder;
-import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev170426.path.description.atoz.direction.AToZ;
-import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev170426.path.description.atoz.direction.AToZBuilder;
-import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev170426.path.description.atoz.direction.AToZKey;
-import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev170426.path.description.ztoa.direction.ZToA;
-import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev170426.path.description.ztoa.direction.ZToABuilder;
-import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev170426.path.description.ztoa.direction.ZToAKey;
-import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev170426.pce.resource.Resource;
-import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev170426.pce.resource.ResourceBuilder;
-import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev170426.pce.resource.resource.resource.Link;
-import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev170426.pce.resource.resource.resource.LinkBuilder;
-import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev170426.pce.resource.resource.resource.Node;
-import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.pathdescription.rev170426.pce.resource.resource.resource.NodeBuilder;
-import org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev170426.response.parameters.sp.response.parameters.PathDescriptionBuilder;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * Class for Sending
- * PCE requests :
- * - path-computation-request
- * - cancel-resource-reserve.
- * @author Martial Coulibaly ( martial.coulibaly@gfi.com ) on behalf of Orange
- *
- */
-public class SendingPceRPCs {
-
- /* Logging. */
- private static final Logger LOG = LoggerFactory.getLogger(SendingPceRPCs.class);
- /* define procedure success (or not ). */
- private Boolean success;
- /* define type of request<br>
- * <code>true</code> pathcomputation <br>
- * <code>false</code> cancelresourcereserve .*/
- private AToZDirection atozdirection;
- private ZToADirection ztoadirection;
- private PathDescriptionBuilder pathDescription;
-
-
- public SendingPceRPCs() {
- success = true;
- atozdirection = null;
- ztoadirection = null;
- setPathDescription(null);
- }
-
- public void cancelResourceReserve() {
- LOG.info("Wait for 10s til beginning the PCE cancelResourceReserve request");
- try {
- Thread.sleep(10000); //sleep for 10s
- } catch (InterruptedException e) {
- LOG.error(e.toString());
- }
- LOG.info("cancelResourceReserve ...");
- }
-
- public void pathComputation() {
- LOG.info("Wait for 10s til beginning the PCE pathComputation request");
- try {
- Thread.sleep(10000); //sleep for 10s
- } catch (InterruptedException e) {
- LOG.error(e.toString());
- }
- LOG.info("PathComputation ...");
- buildAToZ();
- buildZToA();
-
- setPathDescription(new PathDescriptionBuilder()
- .setAToZDirection(atozdirection)
- .setZToADirection(ztoadirection));
- }
-
- public void buildAToZ() {
- Link atoB = new LinkBuilder()
- .setLinkId("AtoB")
- .build();
- Link btoZ = new LinkBuilder()
- .setLinkId("BtoZ")
- .build();
-
- Node roadmA = new NodeBuilder()
- .setNodeId("RoadmA")
- .build();
- Node roadmB = new NodeBuilder()
- .setNodeId("RoadmB")
- .build();
- Node roadmZ = new NodeBuilder()
- .setNodeId("RoadmZ")
- .build();
-
- /*A -> Z*/
- /*RoadmA*/
- AToZKey roadmAKey = new AToZKey("RoadmA");
- Resource roadmAResource = new ResourceBuilder()
- .setResource(roadmA)
- .build();
- AToZ atoz = new AToZBuilder()
- .setId("RoadmA")
- .setKey(roadmAKey)
- .setResource(roadmAResource)
- .build();
- /*Link AtoB*/
- AToZKey atoBKey = new AToZKey("AtoB");
- Resource atozResource = new ResourceBuilder()
- .setResource(atoB)
- .build();
- AToZ atob = new AToZBuilder()
- .setId("AtoB")
- .setKey(atoBKey)
- .setResource(atozResource)
- .build();
- /*RoadmB*/
- AToZKey roadmBKey = new AToZKey("RoadmB");
- Resource roadmBResource = new ResourceBuilder()
- .setResource(roadmB)
- .build();
- AToZ roadmb = new AToZBuilder()
- .setId("RoadmB")
- .setKey(roadmBKey)
- .setResource(roadmBResource)
- .build();
- /*Link BtoZ*/
- AToZKey btoZKey = new AToZKey("BtoZ");
- Resource botzResource = new ResourceBuilder()
- .setResource(btoZ)
- .build();
- AToZ btoz = new AToZBuilder()
- .setId("BtoZ")
- .setKey(btoZKey)
- .setResource(botzResource)
- .build();
- /*RoadmZ*/
- AToZKey roadmZKey = new AToZKey("RoadmZ");
- Resource roadmZResource = new ResourceBuilder()
- .setResource(roadmZ)
- .build();
- AToZ roadmz = new AToZBuilder()
- .setId("RoadmZ")
- .setKey(roadmZKey)
- .setResource(roadmZResource)
- .build();
-
- List<AToZ> atozList = new ArrayList<AToZ>();
- atozList.add(atoz);
- atozList.add(atob);
- atozList.add(roadmb);
- atozList.add(btoz);
- atozList.add(roadmz);
-
- atozdirection = new AToZDirectionBuilder()
- .setRate((long)100)
- .setAToZWavelengthNumber((long)200)
- .setAToZ(atozList)
- .build();
- }
-
- public void buildZToA() {
-
- Link btoA = new LinkBuilder()
- .setLinkId("BtoA")
- .build();
- Link ztoB = new LinkBuilder()
- .setLinkId("ZtoB")
- .build();
-
- Node roadmA = new NodeBuilder()
- .setNodeId("RoadmA")
- .build();
- Node roadmB = new NodeBuilder()
- .setNodeId("RoadmB")
- .build();
- Node roadmZ = new NodeBuilder()
- .setNodeId("RoadmZ")
- .build();
-
- /*Z -> A*/
- /*RoadmZ*/
- ZToAKey roadmZKey = new ZToAKey("RoadmZ");
- Resource roadmZResource = new ResourceBuilder()
- .setResource(roadmZ)
- .build();
- ZToA ztoa = new ZToABuilder()
- .setId("RoadmZ")
- .setKey(roadmZKey)
- .setResource(roadmZResource)
- .build();
- /*Link ZtoB*/
- ZToAKey ztoBKey = new ZToAKey("ZtoB");
- Resource ztoBResource = new ResourceBuilder()
- .setResource(ztoB)
- .build();
- ZToA ztob = new ZToABuilder()
- .setId("ZtoB")
- .setKey(ztoBKey)
- .setResource(ztoBResource)
- .build();
- /*RoadmB*/
- ZToAKey roadmBKey = new ZToAKey("RoadmB");
- Resource roadmBResource = new ResourceBuilder()
- .setResource(roadmB)
- .build();
- ZToA roadmb = new ZToABuilder()
- .setId("RoadmB")
- .setKey(roadmBKey)
- .setResource(roadmBResource)
- .build();
- /*Link BtoA*/
- ZToAKey btoAKey = new ZToAKey("BtoA");
- Resource btoAResource = new ResourceBuilder()
- .setResource(btoA)
- .build();
- ZToA btoa = new ZToABuilder()
- .setId("BtoA")
- .setKey(btoAKey)
- .setResource(btoAResource)
- .build();
- /* RoadmA*/
- ZToAKey roadmAKey = new ZToAKey("RoadmA");
- Resource roadmAResource = new ResourceBuilder()
- .setResource(roadmA)
- .build();
- ZToA roadma = new ZToABuilder()
- .setId("RoadmA")
- .setKey(roadmAKey)
- .setResource(roadmAResource)
- .build();
-
- List<ZToA> ztoaList = new ArrayList<ZToA>();
- ztoaList.add(ztoa);
- ztoaList.add(ztob);
- ztoaList.add(roadmb);
- ztoaList.add(btoa);
- ztoaList.add(roadma);
-
- ztoadirection = new ZToADirectionBuilder()
- .setRate((long)100)
- .setZToAWavelengthNumber((long)100)
- .setZToA(ztoaList)
- .build();
- }
-
- public PathDescriptionBuilder getPathDescription() {
- return pathDescription;
- }
-
- public void setPathDescription(PathDescriptionBuilder pathDescription) {
- this.pathDescription = pathDescription;
- }
-
- public Boolean getSuccess() {
- return success;
- }
-
- public void setSuccess(Boolean success) {
- this.success = success;
- }
-
-}
Code Review / transportpce.git / blobdiff