ovsdb/src/test/java/org/opendaylight/ovsdb/OvsdbTestAddPort.java

   1 package org.opendaylight.ovsdb;
   2
   3 import org.junit.Test;
   4 import org.opendaylight.controller.sal.core.Node;
   5 import org.opendaylight.controller.sal.core.NodeConnector;
   6 import org.opendaylight.ovsdb.internal.ConfigurationService;
   7 import org.opendaylight.ovsdb.internal.ConnectionService;
   8 import org.opendaylight.controller.sal.connection.ConnectionConstants;
   9 import org.slf4j.Logger;
  10 import org.slf4j.LoggerFactory;
  11 import java.util.HashMap;
  12 import java.util.Map;
  13
  14 public class OvsdbTestAddPort {
  15     private static final Logger logger = LoggerFactory
  16             .getLogger(OvsdbTestAddPort.class);
  17
  18     @Test
  19     public void addPort() throws Throwable{
  20         Node.NodeIDType.registerIDType("OVS", String.class);
  21         NodeConnector.NodeConnectorIDType.registerIDType("OVS", String.class, "OVS");
  22
  23         ConnectionService connectionService = new ConnectionService();
  24         connectionService.init();
  25         String identifier = "TEST";
  26         Map<ConnectionConstants, String> params = new HashMap<ConnectionConstants, String>();
  27         params.put(ConnectionConstants.ADDRESS, "172.28.30.51");
  28         params.put(ConnectionConstants.PORT, "6634");
  29
  30         Node node = connectionService.connect(identifier, params);
  31         if(node == null){
  32             logger.error("Could not connect to ovsdb server");
  33             return;
  34         }
  35         /**
  36          * Create a Port and attach it to a Bridge
  37          * Ex. ovs-vsctl add-port br0 vif0
  38          * @param node Node serving this configuration service
  39          * @param bridgeDomainIdentifier String representation of a Bridge Domain
  40          * @param portIdentifier String representation of a user defined Port Name
  41          */
  42         ConfigurationService configurationService = new ConfigurationService();
  43         configurationService.setConnectionServiceInternal(connectionService);
  44         configurationService.addPort(node, "JUNIT_BRIDGE_TEST", "Jvif0", null);
  45     }
  46 }