2 * Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
8 package org.opendaylight.ovsdb.southbound.ovsdb.transact;
10 import static org.opendaylight.ovsdb.lib.operations.Operations.op;
13 import java.util.Map.Entry;
15 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataChangeEvent;
16 import org.opendaylight.ovsdb.lib.notation.Mutator;
17 import org.opendaylight.ovsdb.lib.notation.UUID;
18 import org.opendaylight.ovsdb.lib.operations.TransactionBuilder;
19 import org.opendaylight.ovsdb.lib.schema.typed.TyperUtils;
20 import org.opendaylight.ovsdb.schema.openvswitch.Bridge;
21 import org.opendaylight.ovsdb.schema.openvswitch.Controller;
22 import org.opendaylight.ovsdb.schema.openvswitch.OpenVSwitch;
23 import org.opendaylight.ovsdb.schema.openvswitch.Port;
24 import org.opendaylight.ovsdb.schema.openvswitch.Interface;
25 import org.opendaylight.ovsdb.southbound.SouthboundConstants;
26 import org.opendaylight.ovsdb.southbound.SouthboundMapper;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbBridgeAugmentation;
28 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.InterfaceTypeInternal;
30 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
31 import org.slf4j.Logger;
32 import org.slf4j.LoggerFactory;
34 import com.google.common.collect.Sets;
36 public class BridgeCreateCommand implements TransactCommand {
37 private AsyncDataChangeEvent<InstanceIdentifier<?>, OvsdbBridgeAugmentation> changes;
38 private static final Logger LOG = LoggerFactory.getLogger(BridgeCreateCommand.class);
41 public BridgeCreateCommand(AsyncDataChangeEvent<InstanceIdentifier<?>, OvsdbBridgeAugmentation> changes) {
42 this.changes = changes;
46 public void execute(TransactionBuilder transaction) {
47 Map<InstanceIdentifier<Node>, OvsdbBridgeAugmentation> created = TransactUtils.extractOvsdbManagedNodeCreate(changes);
48 for(OvsdbBridgeAugmentation ovsdbManagedNode: created.values()) {
49 LOG.debug("Received request to create ovsdb bridge name: {} uuid: {}",
50 ovsdbManagedNode.getBridgeName(),
51 ovsdbManagedNode.getBridgeUuid());
54 String bridgeNamedUuid = "Bridge_" + ovsdbManagedNode.getBridgeName().getValue();
55 String interfaceNamedUuid = "Interface_" + ovsdbManagedNode.getBridgeName().getValue();
56 String portNamedUuid = "Port_" + ovsdbManagedNode.getBridgeName().getValue();
59 Interface interfaceOvs = TyperUtils.getTypedRowWrapper(transaction.getDatabaseSchema(), Interface.class);
60 interfaceOvs.setName(ovsdbManagedNode.getBridgeName().getValue());
61 interfaceOvs.setType(SouthboundMapper.createOvsdbInterfaceType(InterfaceTypeInternal.class));
62 transaction.add(op.insert(interfaceOvs).withId(interfaceNamedUuid));
65 Port port = TyperUtils.getTypedRowWrapper(transaction.getDatabaseSchema(), Port.class);
66 port.setName(ovsdbManagedNode.getBridgeName().getValue());
67 port.setInterfaces(Sets.newHashSet(new UUID(interfaceNamedUuid)));
68 transaction.add(op.insert(port).withId(portNamedUuid));
71 Bridge bridge = TyperUtils.getTypedRowWrapper(transaction.getDatabaseSchema(), Bridge.class);
72 bridge.setName(ovsdbManagedNode.getBridgeName().getValue());
73 if(ovsdbManagedNode.getFailMode() != null &&
74 SouthboundConstants.OVSDB_FAIL_MODE_MAP.get(ovsdbManagedNode.getFailMode()) != null ) {
75 bridge.setFailMode(Sets.newHashSet(SouthboundConstants.OVSDB_FAIL_MODE_MAP.get(ovsdbManagedNode.getFailMode())));
77 bridge.setDatapathType(SouthboundMapper.createDatapathType(ovsdbManagedNode));
78 if(SouthboundMapper.createOvsdbBridgeProtocols(ovsdbManagedNode) != null
79 && SouthboundMapper.createOvsdbBridgeProtocols(ovsdbManagedNode).size() > 0){
80 bridge.setProtocols(SouthboundMapper.createOvsdbBridgeProtocols(ovsdbManagedNode));
82 Map<UUID,Controller> controllerMap = SouthboundMapper.createOvsdbController(ovsdbManagedNode, transaction.getDatabaseSchema());
83 for(Entry<UUID,Controller >entry: controllerMap.entrySet()) {
84 transaction.add(op.insert(entry.getValue()).withId(entry.getKey().toString()));
86 if(!controllerMap.isEmpty()) {
87 bridge.setController(controllerMap.keySet());
89 bridge.setPorts(Sets.newHashSet(new UUID(portNamedUuid)));
91 transaction.add(op.insert(bridge).withId(bridgeNamedUuid));
94 OpenVSwitch ovs = TyperUtils.getTypedRowWrapper(transaction.getDatabaseSchema(), OpenVSwitch.class);
95 ovs.setBridges(Sets.newHashSet(new UUID(bridgeNamedUuid)));
96 transaction.add(op.mutate(ovs).addMutation(ovs.getBridgesColumn().getSchema(),
98 ovs.getBridgesColumn().getData())