Port openshift-sdn-ovs script to go

Author: danwinship

pkg/sdn/plugin/bin/openshift-sdn-ovs

@@ -1,6 +1,9 @@
 #!/bin/bash
 set -ex
 
+# NOTE: This is no longer used; it is now installed solely to avoid breakage during
+# upgrades, and will go away in 3.7.
+
 lock_file=/var/lock/openshift-sdn.lock
 
 action=$1

pkg/sdn/plugin/controller.go

@@ -257,7 +257,7 @@ func (plugin *OsdnNode) SetupSDN() (bool, error) {
 	// eg, "table=10, priority=100, tun_src=${remote_node_ip}, actions=goto_table:30"
 	otx.AddFlow("table=10, priority=0, actions=drop")
 
-	// Table 20: from OpenShift container; validate IP/MAC, assign tenant-id; filled in by openshift-sdn-ovs
+	// Table 20: from OpenShift container; validate IP/MAC, assign tenant-id; filled in by setupPodFlows
 	// eg, "table=20, priority=100, in_port=${ovs_port}, arp, nw_src=${ipaddr}, arp_sha=${macaddr}, actions=load:${tenant_id}->NXM_NX_REG0[], goto_table:21"
 	//     "table=20, priority=100, in_port=${ovs_port}, ip, nw_src=${ipaddr}, actions=load:${tenant_id}->NXM_NX_REG0[], goto_table:21"
 	// (${tenant_id} is always 0 for single-tenant)
@@ -283,7 +283,7 @@ func (plugin *OsdnNode) SetupSDN() (bool, error) {
 	otx.AddFlow("table=30, priority=0, ip, actions=goto_table:100")
 	otx.AddFlow("table=30, priority=0, arp, actions=drop")
 
-	// Table 40: ARP to local container, filled in by openshift-sdn-ovs
+	// Table 40: ARP to local container, filled in by setupPodFlows
 	// eg, "table=40, priority=100, arp, nw_dst=${container_ip}, actions=output:${ovs_port}"
 	otx.AddFlow("table=40, priority=0, actions=drop")
 
@@ -296,7 +296,7 @@ func (plugin *OsdnNode) SetupSDN() (bool, error) {
 	// eg, "table=60, priority=100, reg0=${tenant_id}, ${service_proto}, nw_dst=${service_ip}, tp_dst=${service_port}, actions=load:${tenant_id}->NXM_NX_REG1[], load:2->NXM_NX_REG2[], goto_table:80"
 	otx.AddFlow("table=60, priority=0, actions=drop")
 
-	// Table 70: IP to local container: vnid/port mappings; filled in by openshift-sdn-ovs
+	// Table 70: IP to local container: vnid/port mappings; filled in by setupPodFlows
 	// eg, "table=70, priority=100, ip, nw_dst=${ipaddr}, actions=load:${tenant_id}->NXM_NX_REG1[], load:${ovs_port}->NXM_NX_REG2[], goto_table:80"
 	otx.AddFlow("table=70, priority=0, actions=drop")
 

pkg/sdn/plugin/pod.go

@@ -45,6 +45,7 @@ type podManager struct {
 	// Live pod setup/teardown stuff not used in testing code
 	kClient         *kclientset.Clientset
 	policy          osdnPolicy
+	ovs             *ovs.Interface
 	ipamConfig      []byte
 	mtu             uint32
 	hostportHandler kubehostport.HostportHandler
@@ -57,6 +58,7 @@ func newPodManager(host knetwork.Host, localSubnetCIDR string, netInfo *NetworkI
 	pm := newDefaultPodManager(host)
 	pm.kClient = kClient
 	pm.policy = policy
+	pm.ovs = ovsif
 	pm.mtu = mtu
 	pm.hostportHandler = kubehostport.NewHostportHandler()
 	pm.podHandler = pm