aboutsummaryrefslogtreecommitdiffstats
path: root/environments/neutron-plumgrid.yaml
blob: 8794621137eaf8f3f38c0fb2df71ef68fd5fea2b (plain) 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

# A Heat environment file which can be used to enable PLUMgrid
# extensions, configured via puppet
resource_registry:
  # PLUMgrid doesn't require dhcp, l3, metadata, and ovs agents
  OS::TripleO::Services::NeutronDhcpAgent: OS::Heat::None
  OS::TripleO::Services::NeutronL3Agent: OS::Heat::None
  OS::TripleO::Services::NeutronMetadataAgent: OS::Heat::None
  OS::TripleO::Services::NeutronOvsAgent: OS::Heat::None
  OS::TripleO::Services::ComputeNeutronOvsAgent: OS::Heat::None
  # Override the Neutron core plugin to use PLUMgrid
  OS::TripleO::Services::NeutronCorePlugin: OS::TripleO::Services::NeutronCorePluginPlumgrid
  OS::TripleO::Services::ComputeNeutronCorePlugin: ../puppet/services/neutron-compute-plugin-plumgrid.yaml

parameter_defaults:
  NeutronCorePlugin: networking_plumgrid.neutron.plugins.plugin.NeutronPluginPLUMgridV2
  PLUMgridDirectorServer: 127.0.0.1
  PLUMgridDirectorServerPort: 443
  PLUMgridUsername: username
  PLUMgridPassword: password
  PLUMgridServerTimeOut: 99
  PLUMgridNovaMetadataIP: 169.254.169.254
  PLUMgridNovaMetadataPort: 8775
  PLUMgridL2GatewayVendor: vendor
  PLUMgridL2GatewayUsername: username
  PLUMgridL2GatewayPassword: password
  PLUMgridIdentityVersion: v2.0
  PLUMgridConnectorType: distributed

  #Optional Parameters
  #PLUMgridNeutronPluginVersion: present
  #PLUMgridPlumlibVersion: present
package org.onosproject.cli.net; import org.apache.karaf.shell.commands.Argument; import org.apache.karaf.shell.commands.Command; import org.apache.karaf.shell.commands.Option; import org.onosproject.net.ConnectPoint; import org.onosproject.net.OchPort; import org.onosproject.net.OduCltPort; import org.onosproject.net.DeviceId; import org.onosproject.net.OduSignalType; import org.onosproject.net.Port; import org.onosproject.net.device.DeviceService; import org.onosproject.net.intent.Intent; import org.onosproject.net.intent.IntentService; import org.onosproject.net.intent.OpticalCircuitIntent; import org.onosproject.net.intent.OpticalConnectivityIntent; import java.util.List; import static com.google.common.base.Preconditions.checkArgument; /** * Installs optical connectivity or circuit intents, depending on given port types. */ @Command(scope = "onos", name = "add-optical-intent", description = "Installs optical connectivity intent") public class AddOpticalIntentCommand extends ConnectivityIntentCommand { @Argument(index = 0, name = "ingressDevice", description = "Ingress Device/Port Description", required = true, multiValued = false) String ingressDeviceString = ""; @Argument(index = 1, name = "egressDevice", description = "Egress Device/Port Description", required = true, multiValued = false) String egressDeviceString = ""; @Option(name = "-b", aliases = "--bidirectional", description = "If this argument is passed the optical link created will be bidirectional, " + "else the link will be unidirectional.", required = false, multiValued = false) private boolean bidirectional = false; private ConnectPoint createConnectPoint(String devicePortString) { String[] splitted = devicePortString.split("/"); checkArgument(splitted.length == 2, "Connect point must be in \"deviceUri/portNumber\" format"); DeviceId deviceId = DeviceId.deviceId(splitted[0]); DeviceService deviceService = get(DeviceService.class); List<Port> ports = deviceService.getPorts(deviceId); for (Port port : ports) { if (splitted[1].equals(port.number().name())) { return new ConnectPoint(deviceId, port.number()); } } return null; } @Override protected void execute() { IntentService service = get(IntentService.class); ConnectPoint ingress = createConnectPoint(ingressDeviceString); ConnectPoint egress = createConnectPoint(egressDeviceString); if (ingress == null || egress == null) { print("Invalid endpoint(s); could not create optical intent"); return; } DeviceService deviceService = get(DeviceService.class); Port srcPort = deviceService.getPort(ingress.deviceId(), ingress.port()); Port dstPort = deviceService.getPort(egress.deviceId(), egress.port()); Intent intent; // FIXME: Hardcoded signal types if (srcPort instanceof OduCltPort && dstPort instanceof OduCltPort) { intent = OpticalCircuitIntent.builder() .appId(appId()) .key(key()) .src(ingress) .dst(egress) .signalType(OduCltPort.SignalType.CLT_10GBE) .bidirectional(bidirectional) .build(); } else if (srcPort instanceof OchPort && dstPort instanceof OchPort) { intent = OpticalConnectivityIntent.builder() .appId(appId()) .key(key()) .src(ingress) .dst(egress) .signalType(OduSignalType.ODU4) .bidirectional(bidirectional) .build(); } else { print("Unable to create optical intent between connect points {} and {}", ingress, egress); return; } service.submit(intent); print("Optical intent submitted:\n%s", intent.toString()); } }