Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Ensure global config is valid before creating network #1070

Merged
merged 1 commit into from
Nov 17, 2017
Merged

Ensure global config is valid before creating network #1070

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
22 changes: 22 additions & 0 deletions netmaster/objApi/apiController.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1023,6 +1023,11 @@ func (ac *APIController) EndpointGroupDelete(endpointGroup *contivModel.Endpoint
func (ac *APIController) NetworkCreate(network *contivModel.Network) error {
log.Infof("Received NetworkCreate: %+v", network)

// Make sure global settings is valid
if err := validateGlobalConfig(network.Encap); err != nil {
return fmt.Errorf("Global configuration is not ready: %v", err.Error())
}

// Make sure tenant exists
if network.TenantName == "" {
return core.Errorf("Invalid tenant name")
Expand Down Expand Up @@ -2325,3 +2330,20 @@ func validatePorts(ports []string) bool {
}
return true
}

func validateGlobalConfig(netmode string) error {
globalConfig := contivModel.FindGlobal("global")
if globalConfig == nil {
return errors.New("global configuration is not ready")
}
if globalConfig.FwdMode == "" {
return errors.New("global forwarding mode is not set")
}
if strings.ToLower(netmode) == "vlan" && globalConfig.Vlans == "" {
return errors.New("global vlan range is not set")
}
if strings.ToLower(netmode) == "vxlan" && globalConfig.Vxlans == "" {
return errors.New("global vxlan range is not set")
}
return nil
}
52 changes: 49 additions & 3 deletions netmaster/objApi/objapi_test.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -869,6 +869,8 @@ func checkDeleteTenant(t *testing.T, expError bool, tenant string) {

// TestTenantDelete tests deletion of tenant
func TestTenantDelete(t *testing.T) {
// ensure global configs set
checkGlobalSet(t, false, "default", "1-4094", "1-10000", "bridge", "proxy", "172.19.0.0/16")
// Create one tenant, two networks and 3 epgs
checkCreateTenant(t, false, "tenant1")
checkCreateNetwork(t, false, "tenant1", "net1", "data", "vlan", "10.1.1.1/16", "10.1.1.254", 1, "", "", "")
Expand Down Expand Up @@ -971,7 +973,8 @@ func TestTenantAddDelete(t *testing.T) {

// TestOverlappingSubnets tests overlapping network create/delete REST api
func TestOverlappingSubnets(t *testing.T) {

// ensure global configs set
checkGlobalSet(t, false, "default", "1-4094", "1-10000", "bridge", "proxy", "172.19.0.0/16")
// Non-overlapping subnet for same tenant - vlan & gateway
checkCreateNetwork(t, false, "default", "contiv1", "", "vlan", "10.1.1.0/24", "10.1.1.220", 1, "", "", "")
checkCreateNetwork(t, false, "default", "contiv2", "", "vlan", "10.1.2.0/24", "10.1.2.254", 2, "", "", "")
Expand Down Expand Up @@ -1094,6 +1097,9 @@ func TestNetworkAddDeleteACIMode(t *testing.T) {

// TestNetworkAddDelete tests network create/delete REST api
func TestNetworkAddDelete(t *testing.T) {
// ensure global configs set
checkGlobalSet(t, false, "default", "1-4094", "1-10000", "bridge", "proxy", "172.19.0.0/16")

// Basic vlan network
checkCreateNetwork(t, false, "default", "contiv", "", "vlan", "10.1.1.1/24", "10.1.1.254", 1, "", "", "")
checkInspectNetwork(t, false, "default", "contiv", "10.1.1.254", 1, 0)
Expand Down Expand Up @@ -1201,9 +1207,10 @@ func TestNetworkAddDelete(t *testing.T) {
}

func TestDynamicGlobalVlanRange(t *testing.T) {
// ensure global configs set
checkGlobalSet(t, false, "default", "1-4094", "1-10000", "bridge", "proxy", "172.19.0.0/16")

// Basic vlan network creation

checkCreateNetwork(t, false, "default", "contiv1", "", "vlan", "10.1.1.1/24", "10.1.1.254", 10, "", "", "")
checkInspectNetwork(t, false, "default", "contiv1", "10.1.1.254", 10, 0)
//checkInspectGlobal(t, false, "1", "")
Expand Down Expand Up @@ -1265,7 +1272,8 @@ func TestDynamicGlobalVlanRange(t *testing.T) {
}

func TestDynamicGlobalVxlanRange(t *testing.T) {

// ensure global configs set
checkGlobalSet(t, false, "default", "1-4094", "1-10000", "bridge", "proxy", "172.19.0.0/16")
insp, _ := contivClient.GlobalInspect("global") // Basic vxlan network creation

log.Printf("THE GLOBAL DUMP: %#v \n", insp)
Expand Down Expand Up @@ -1380,6 +1388,9 @@ func TestAciGwSetting(t *testing.T) {

// TestNetworkPktRanges tests pkt-tag ranges in network REST api
func TestNetworkPktRanges(t *testing.T) {
// ensure global configs set
checkGlobalSet(t, false, "default", "1-4094", "1-10000", "bridge", "proxy", "172.19.0.0/16")

// verify auto allocation of vlans
checkCreateNetwork(t, false, "default", "contiv", "data", "vlan", "10.1.1.1/24", "10.1.1.254", 0, "", "", "")
verifyNetworkState(t, "default", "contiv", "data", "vlan", "10.1.1.1", "10.1.1.254", 24, 1, 0, "", "", 0)
Expand Down Expand Up @@ -1418,6 +1429,9 @@ func TestNetworkPktRanges(t *testing.T) {

// TestPolicyRules tests policy and rule REST objects
func TestPolicyRules(t *testing.T) {
// ensure global configs set
checkGlobalSet(t, false, "default", "1-4094", "1-10000", "bridge", "proxy", "172.19.0.0/16")

containerID1 := "723e55bf5b244f47c1b184cb786a1c2ad8870cc3a3db723c49ac09f68a9d1e69"
ep1 := "657355bf5b244f47c1b184cb786a14535d8870cc3a3db723c49ac09f68a9d6a5"
checkCreateNetwork(t, false, "default", "contiv", "data", "vxlan", "10.1.1.1/16", "10.1.1.254", 1, "", "", "")
Expand Down Expand Up @@ -1516,6 +1530,9 @@ func TestPolicyRules(t *testing.T) {

// TestEpgPolicies tests attaching policy to EPG
func TestEpgPolicies(t *testing.T) {
// ensure global configs set
checkGlobalSet(t, false, "default", "1-4094", "1-10000", "bridge", "proxy", "172.19.0.0/16")

// create network
checkCreateNetwork(t, false, "default", "contiv", "data", "vxlan", "10.1.1.1/16", "10.1.1.254", 1, "", "", "")

Expand Down Expand Up @@ -1582,6 +1599,8 @@ func TestEpgPolicies(t *testing.T) {

// TestExtContractsGroups tests management of external contracts groups
func TestExtContractsGroups(t *testing.T) {
// ensure global configs set
checkGlobalSet(t, false, "default", "1-4094", "1-10000", "bridge", "proxy", "172.19.0.0/16")
// create network for the test
checkCreateNetwork(t, false, "default", "test-net", "data", "vlan", "23.1.1.1/16", "23.1.1.254", 1, "", "", "")
// create contract groups used for the test
Expand Down Expand Up @@ -1620,6 +1639,8 @@ func TestExtContractsGroups(t *testing.T) {

// TestAppProfile tests app-profile REST objects
func TestAppProfile(t *testing.T) {
// ensure global configs set
checkGlobalSet(t, false, "default", "1-4094", "1-10000", "bridge", "proxy", "172.19.0.0/16")
// Create two networks and 3 epgs
checkCreateNetwork(t, false, "default", "net1", "data", "vlan", "10.1.1.1/16", "10.1.1.254", 1, "", "", "")
checkCreateNetwork(t, false, "default", "net2", "data", "vlan", "20.1.1.1/16", "20.1.1.254", 2, "", "", "")
Expand Down Expand Up @@ -1650,6 +1671,8 @@ func TestAppProfile(t *testing.T) {

//TestEpgNetprofile tests the netprofile netprofile REST objects.
func TestEpgnpTenant(t *testing.T) {
// ensure global configs set
checkGlobalSet(t, false, "default", "1-4094", "1-10000", "bridge", "proxy", "172.19.0.0/16")

//create a network,
checkCreateNetwork(t, false, "default", "np-net", "data", "vxlan", "10.1.1.1/24", "10.1.1.254", 1, "", "", "")
Expand Down Expand Up @@ -1708,6 +1731,9 @@ func TestEpgnpTenant(t *testing.T) {
}

func TestEpgnp(t *testing.T) {
// ensure global configs set
checkGlobalSet(t, false, "default", "1-4094", "1-10000", "bridge", "proxy", "172.19.0.0/16")

//create a network and netprofile
checkCreateNetwork(t, false, "default", "np-net", "data", "vxlan", "10.1.1.1/24", "10.1.1.254", 1, "", "", "")
checkCreateNetProfile(t, false, 5, 1500, "2gbps", "netprofile", "default")
Expand All @@ -1723,6 +1749,9 @@ func TestEpgnp(t *testing.T) {
}

func TestEpgUpdate(t *testing.T) {
// ensure global configs set
checkGlobalSet(t, false, "default", "1-4094", "1-10000", "bridge", "proxy", "172.19.0.0/16")

//create a network, netprofile and group.
checkCreateNetwork(t, false, "default", "np-net", "data", "vxlan", "10.1.1.1/24", "10.1.1.254", 1, "", "", "")
checkCreateNetProfile(t, false, 5, 1500, "2gbps", "netprofile", "default")
Expand Down Expand Up @@ -1774,6 +1803,9 @@ func TestEpgUpdate(t *testing.T) {
}

func TestDeleteEpgNp(t *testing.T) {
// ensure global configs set
checkGlobalSet(t, false, "default", "1-4094", "1-10000", "bridge", "proxy", "172.19.0.0/16")

//create a network, netprofile and group.
checkCreateNetwork(t, false, "default", "np-net", "data", "vxlan", "10.1.1.1/24", "10.1.1.254", 1, "", "", "")
checkCreateNetProfile(t, false, 5, 1500, "2gbps", "netprofile", "default")
Expand All @@ -1794,6 +1826,8 @@ func TestDeleteEpgNp(t *testing.T) {
}

func TestNetProfileupdate(t *testing.T) {
// ensure global configs set
checkGlobalSet(t, false, "default", "1-4094", "1-10000", "bridge", "proxy", "172.19.0.0/16")

//create a network, netprofile.
checkCreateNetwork(t, false, "default", "np-net", "data", "vxlan", "10.1.1.1/24", "10.1.1.254", 1, "", "", "")
Expand Down Expand Up @@ -1830,6 +1864,9 @@ func TestNetProfileupdate(t *testing.T) {
}

func TestNetprofile(t *testing.T) {
// ensure global configs set
checkGlobalSet(t, false, "default", "1-4094", "1-10000", "bridge", "proxy", "172.19.0.0/16")

//create a network & netprofile
checkCreateNetwork(t, false, "default", "net", "data", "vxlan", "10.1.1.1/24", "10.1.1.254", 1, "", "", "")
checkCreateNetProfile(t, false, 5, 1500, "2gbps", "profile1", "default")
Expand Down Expand Up @@ -1889,6 +1926,8 @@ func TestNetprofile(t *testing.T) {
}

func TestServiceProviderUpdate(t *testing.T) {
// ensure global configs set
checkGlobalSet(t, false, "default", "1-4094", "1-10000", "bridge", "proxy", "172.19.0.0/16")

labels := []string{"key1=value1", "key2=value2"}
port := []string{"80:8080:TCP"}
Expand Down Expand Up @@ -1954,6 +1993,8 @@ func TestServiceProviderUpdate(t *testing.T) {
}

func TestServiceProviderUpdateServiceAdd(t *testing.T) {
// ensure global configs set
checkGlobalSet(t, false, "default", "1-4094", "1-10000", "bridge", "proxy", "172.19.0.0/16")

labels := []string{"key1=value1", "key2=value2"}
port := []string{"80:8080:TCP"}
Expand Down Expand Up @@ -2018,6 +2059,8 @@ func TestServiceProviderUpdateServiceAdd(t *testing.T) {
}

func TestServicePreferredIP(t *testing.T) {
// ensure global configs set
checkGlobalSet(t, false, "default", "1-4094", "1-10000", "bridge", "proxy", "172.19.0.0/16")

labels := []string{"key1=value1", "key2=value2"}
port := []string{"80:8080:TCP"}
Expand Down Expand Up @@ -2334,6 +2377,9 @@ func AddEP(tenant, nw, epg, id string) error {
}

func TestEPCreate(t *testing.T) {
// ensure global configs set
checkGlobalSet(t, false, "default", "1-4094", "1-10000", "bridge", "proxy", "172.19.0.0/16")

checkCreateTenant(t, false, "teatwo")
checkCreateNetwork(t, false, "teatwo", "t2-net", "data", "vlan",
"60.1.1.1/24", "60.1.1.254", 1, "", "", "")
Expand Down