6 "github.com/vishvananda/netlink"
10 logf "sigs.k8s.io/controller-runtime/pkg/runtime/log"
15 var log = logf.Log.WithName("ovn")
17 // CreateVlan creates VLAN with vlanID
18 func CreateVlan(vlanID, interfaceName, logicalInterfaceName string) error {
19 if interfaceName == "" || vlanID == "" || logicalInterfaceName == "" {
20 return fmt.Errorf("CreateVlan invalid parameters: %v %v %v", interfaceName, vlanID, logicalInterfaceName)
22 _, err := netlink.LinkByName(logicalInterfaceName)
26 stdout, stderr, err := RunIP("link", "add", "link", interfaceName, "name", logicalInterfaceName, "type", "vlan", "id", vlanID)
28 log.Error(err, "Failed to create Vlan", "stdout", stdout, "stderr", stderr)
31 stdout, stderr, err = RunIP("link", "set", logicalInterfaceName, "alias", "nfn-"+logicalInterfaceName)
33 log.Error(err, "Failed to create Vlan", "stdout", stdout, "stderr", stderr)
39 // DeleteVlan deletes VLAN with logicalInterface Name
40 func DeleteVlan(logicalInterfaceName string) error {
41 if logicalInterfaceName == "" {
42 return fmt.Errorf("DeleteVlan invalid parameters")
44 stdout, stderr, err := RunIP("link", "del", "dev", logicalInterfaceName)
46 log.Error(err, "Failed to create Vlan", "stdout", stdout, "stderr", stderr)
52 // GetVlan returns a list of VLAN configured on the node
53 func GetVlan() []string {
55 links, err := netlink.LinkList()
59 for _, l := range links {
60 if strings.Contains(l.Attrs().Alias, "nfn-") {
61 intfList = append(intfList, l.Attrs().Name)
67 // CreatePnBridge creates Provider network bridge and mappings
68 func CreatePnBridge(nwName, brName, intfName string) error {
69 if nwName == "" || brName == "" || intfName == "" {
70 return fmt.Errorf("CreatePnBridge invalid parameters")
73 stdout, stderr, err := RunOVSVsctl("--may-exist", "add-br", brName)
75 log.Error(err, "Failed to create Bridge", "stdout", stdout, "stderr", stderr)
78 stdout, stderr, err = RunOVSVsctl("--may-exist", "add-port", brName, intfName)
80 log.Error(err, "Failed to add port to Bridge", "stdout", stdout, "stderr", stderr)
83 stdout, stderr, err = RunOVSVsctl("set", "bridge", brName, "external_ids:nfn="+nwName)
85 log.Error(err, "Failed to set nfn-alias", "stdout", stdout, "stderr", stderr)
88 // Update ovn-bridge-mappings
89 updateOvnBridgeMapping(brName, nwName, "add")
93 // DeletePnBridge creates Provider network bridge and mappings
94 func DeletePnBridge(nwName, brName string) error {
95 if nwName == "" || brName == "" {
96 return fmt.Errorf("DeletePnBridge invalid parameters")
99 stdout, stderr, err := RunOVSVsctl("--if-exist", "del-br", brName)
101 log.Error(err, "Failed to delete Bridge", "stdout", stdout, "stderr", stderr)
104 updateOvnBridgeMapping(brName, nwName, "delete")
109 // GetPnBridge returns Provider networks with external ids
110 func GetPnBridge(externalID string) []string {
111 if externalID == "" {
112 log.Error(fmt.Errorf("GetBridge invalid parameters"), "Invalid")
114 stdout, stderr, err := RunOVSVsctl("list-br")
116 log.Error(err, "No bridges found", "stdout", stdout, "stderr", stderr)
119 brNames := strings.Split(stdout, "\n")
121 for _, name := range brNames {
122 stdout, stderr, err = RunOVSVsctl("get", "bridge", name, "external_ids:"+externalID)
124 if !strings.Contains(stderr, "no key") {
125 log.Error(err, "Unknown error reading external_ids", "stdout", stdout, "stderr", stderr)
132 brList = append(brList, name)
138 // Update ovn-bridge-mappings
139 func updateOvnBridgeMapping(brName, nwName, action string) error {
140 stdout, stderr, err := RunOVSVsctl("get", "open", ".", "external-ids:ovn-bridge-mappings")
142 if !strings.Contains(stderr, "no key") {
143 log.Error(err, "Failed to get ovn-bridge-mappings", "stdout", stdout, "stderr", stderr)
147 // Convert csv string to map
148 mm := make(map[string]string)
150 am := strings.Split(stdout, ",")
151 for _, label := range am {
152 l := strings.Split(label, ":")
154 log.Error(fmt.Errorf("Syntax error label: %v", label), "ovnBridgeMapping")
157 mm[strings.TrimSpace(l[0])] = strings.TrimSpace(l[1])
162 } else if action == "delete" {
166 stdout, stderr, err = RunOVSVsctl("remove", "open", ".", "external-ids", "ovn-bridge-mappings")
168 log.Error(err, "Failed to remove ovn-bridge-mappings", "stdout", stdout, "stderr", stderr)
174 return fmt.Errorf("Invalid action %s", action)
177 for key, value := range mm {
178 mapping = mapping + fmt.Sprintf("%s:%s,", key, value)
181 mapping = mapping[:len(mapping)-1]
182 extIDMap := "external-ids:ovn-bridge-mappings=" + mapping
184 stdout, stderr, err = RunOVSVsctl("set", "open", ".", extIDMap)
186 log.Error(err, "Failed to set ovn-bridge-mappings", "stdout", stdout, "stderr", stderr)
192 func parseOvnNetworkObject(ovnnetwork string) ([]map[string]interface{}, error) {
193 var ovnNet []map[string]interface{}
195 if ovnnetwork == "" {
196 return nil, fmt.Errorf("parseOvnNetworkObject:error")
199 if err := json.Unmarshal([]byte(ovnnetwork), &ovnNet); err != nil {
200 return nil, fmt.Errorf("parseOvnNetworkObject: failed to load ovn network err: %v | ovn network: %v", err, ovnnetwork)
206 func setupDistributedRouter(name string) error {
208 // Create a single common distributed router for the cluster.
209 stdout, stderr, err := RunOVNNbctl("--", "--may-exist", "lr-add", name, "--", "set", "logical_router", name, "external_ids:ovn4nfv-cluster-router=yes")
211 log.Error(err, "Failed to create a single common distributed router for the cluster", "stdout", stdout, "stderr", stderr)
214 // Create a logical switch called "ovn4nfv-join" that will be used to connect gateway routers to the distributed router.
215 // The "ovn4nfv-join" will be allocated IP addresses in the range 100.64.1.0/24.
216 stdout, stderr, err = RunOVNNbctl("--may-exist", "ls-add", "ovn4nfv-join")
218 log.Error(err, "Failed to create logical switch called \"ovn4nfv-join\"", "stdout", stdout, "stderr", stderr)
221 // Connect the distributed router to "ovn4nfv-join".
222 routerMac, stderr, err := RunOVNNbctl("--if-exist", "get", "logical_router_port", "rtoj-"+name, "mac")
224 log.Error(err, "Failed to get logical router port rtoj-", "name", name, "stdout", stdout, "stderr", stderr)
228 routerMac = generateMac()
229 stdout, stderr, err = RunOVNNbctl("--", "--may-exist", "lrp-add", name, "rtoj-"+name, routerMac, "100.64.1.1/24", "--", "set", "logical_router_port", "rtoj-"+name, "external_ids:connect_to_ovn4nfvjoin=yes")
231 log.Error(err, "Failed to add logical router port rtoj", "name", name, "stdout", stdout, "stderr", stderr)
235 // Connect the switch "ovn4nfv-join" to the router.
236 stdout, stderr, err = RunOVNNbctl("--", "--may-exist", "lsp-add", "ovn4nfv-join", "jtor-"+name, "--", "set", "logical_switch_port", "jtor-"+name, "type=router", "options:router-port=rtoj-"+name, "addresses="+"\""+routerMac+"\"")
238 log.Error(err, "Failed to add logical switch port to logical router", "stdout", stdout, "stderr", stderr)
244 // generateMac generates mac address.
245 func generateMac() string {
247 newRand := rand.New(rand.NewSource(time.Now().UnixNano()))
248 mac := fmt.Sprintf("%s:%02x:%02x:%02x", prefix, newRand.Intn(255), newRand.Intn(255), newRand.Intn(255))
252 // NextIP returns IP incremented by 1
253 func NextIP(ip net.IP) net.IP {
255 return intToIP(i.Add(i, big.NewInt(1)))
258 func ipToInt(ip net.IP) *big.Int {
259 if v := ip.To4(); v != nil {
260 return big.NewInt(0).SetBytes(v)
262 return big.NewInt(0).SetBytes(ip.To16())
265 func intToIP(i *big.Int) net.IP {
266 return net.IP(i.Bytes())