github/kubernetes
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix the bug that Service clusterIP does not respect specified ipFamily

Browse Source 
Signed-off-by: SataQiu <1527062125@qq.com>
This commit is contained in:
SataQiu
2020-03-29 17:19:52 +08:00
parent e03c7756c7
commit b66fd46cd5
2 changed files with 121 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/registry/core/service/storage/rest.go
View File

@@ -559,7 +559,7 @@ func (r *REST) getAllocatorByClusterIP(service *api.Service) ipallocator.Interfa
}
secondaryAllocatorCIDR := r.secondaryServiceIPs.CIDR()
if netutil.IsIPv6String(service.Spec.ClusterIP) && netutil.IsIPv6CIDR(&secondaryAllocatorCIDR) {
if netutil.IsIPv6String(service.Spec.ClusterIP) == netutil.IsIPv6CIDR(&secondaryAllocatorCIDR) {
return r.secondaryServiceIPs
}
@@ -574,7 +574,7 @@ func (r *REST) getAllocatorBySpec(service *api.Service) ipallocator.Interface {
}
secondaryAllocatorCIDR := r.secondaryServiceIPs.CIDR()
if *(service.Spec.IPFamily) == api.IPv6Protocol && netutil.IsIPv6CIDR(&secondaryAllocatorCIDR) {
if (*(service.Spec.IPFamily) == api.IPv6Protocol) == netutil.IsIPv6CIDR(&secondaryAllocatorCIDR) {
return r.secondaryServiceIPs
}

124
pkg/registry/core/service/storage/rest_test.go
View File

@@ -2512,6 +2512,7 @@ func TestAllocGetters(t *testing.T) {
testCases := []struct {
name string
isIPv6Primary bool
enableDualStack bool
specExpctPrimary bool
clusterIPExpectPrimary bool
@@ -2519,8 +2520,9 @@ func TestAllocGetters(t *testing.T) {
svc *api.Service
}{
{
name: "spec:v4 ip:v4 dualstack:off",
name: "spec:v4 ip:v4 dualstack:off isIPv6Primary:false",
isIPv6Primary: false,
specExpctPrimary: true,
clusterIPExpectPrimary: true,
enableDualStack: false,
@@ -2536,8 +2538,9 @@ func TestAllocGetters(t *testing.T) {
},
},
{
name: "spec:v4 ip:v4 dualstack:on",
name: "spec:v4 ip:v4 dualstack:on isIPv6Primary:false",
isIPv6Primary: false,
specExpctPrimary: true,
clusterIPExpectPrimary: true,
enableDualStack: true,
@@ -2554,8 +2557,9 @@ func TestAllocGetters(t *testing.T) {
},
{
name: "spec:v4 ip:v6 dualstack:on",
name: "spec:v4 ip:v6 dualstack:on isIPv6Primary:false",
isIPv6Primary: false,
specExpctPrimary: true,
clusterIPExpectPrimary: false,
enableDualStack: true,
@@ -2572,8 +2576,9 @@ func TestAllocGetters(t *testing.T) {
},
{
name: "spec:v6 ip:v6 dualstack:on",
name: "spec:v6 ip:v6 dualstack:on isIPv6Primary:false",
isIPv6Primary: false,
specExpctPrimary: false,
clusterIPExpectPrimary: false,
enableDualStack: true,
@@ -2590,8 +2595,9 @@ func TestAllocGetters(t *testing.T) {
},
{
name: "spec:v6 ip:v4 dualstack:on",
name: "spec:v6 ip:v4 dualstack:on isIPv6Primary:false",
isIPv6Primary: false,
specExpctPrimary: false,
clusterIPExpectPrimary: true,
enableDualStack: true,
@@ -2606,6 +2612,99 @@ func TestAllocGetters(t *testing.T) {
},
},
},
{
name: "spec:v6 ip:v6 dualstack:off isIPv6Primary:true",
isIPv6Primary: true,
specExpctPrimary: true,
clusterIPExpectPrimary: true,
enableDualStack: false,
svc: &api.Service{
ObjectMeta: metav1.ObjectMeta{Name: "foo", ResourceVersion: "1"},
Spec: api.ServiceSpec{
Selector: map[string]string{"bar": "baz"},
Type: api.ServiceTypeClusterIP,
IPFamily: &ipv6Service,
ClusterIP: "2000::1",
},
},
},
{
name: "spec:v6 ip:v6 dualstack:on isIPv6Primary:true",
isIPv6Primary: true,
specExpctPrimary: true,
clusterIPExpectPrimary: true,
enableDualStack: true,
svc: &api.Service{
ObjectMeta: metav1.ObjectMeta{Name: "foo", ResourceVersion: "1"},
Spec: api.ServiceSpec{
Selector: map[string]string{"bar": "baz"},
Type: api.ServiceTypeClusterIP,
IPFamily: &ipv6Service,
ClusterIP: "2000::1",
},
},
},
{
name: "spec:v6 ip:v4 dualstack:on isIPv6Primary:true",
isIPv6Primary: true,
specExpctPrimary: true,
clusterIPExpectPrimary: false,
enableDualStack: true,
svc: &api.Service{
ObjectMeta: metav1.ObjectMeta{Name: "foo", ResourceVersion: "1"},
Spec: api.ServiceSpec{
Selector: map[string]string{"bar": "baz"},
Type: api.ServiceTypeClusterIP,
IPFamily: &ipv6Service,
ClusterIP: "10.0.0.1",
},
},
},
{
name: "spec:v4 ip:v4 dualstack:on isIPv6Primary:true",
isIPv6Primary: true,
specExpctPrimary: false,
clusterIPExpectPrimary: false,
enableDualStack: true,
svc: &api.Service{
ObjectMeta: metav1.ObjectMeta{Name: "foo", ResourceVersion: "1"},
Spec: api.ServiceSpec{
Selector: map[string]string{"bar": "baz"},
Type: api.ServiceTypeClusterIP,
IPFamily: &ipv4Service,
ClusterIP: "10.0.0.1",
},
},
},
{
name: "spec:v4 ip:v6 dualstack:on isIPv6Primary:true",
isIPv6Primary: true,
specExpctPrimary: false,
clusterIPExpectPrimary: true,
enableDualStack: true,
svc: &api.Service{
ObjectMeta: metav1.ObjectMeta{Name: "foo", ResourceVersion: "1"},
Spec: api.ServiceSpec{
Selector: map[string]string{"bar": "baz"},
Type: api.ServiceTypeClusterIP,
IPFamily: &ipv4Service,
ClusterIP: "2000::1",
},
},
},
}
for _, tc := range testCases {
@@ -2614,6 +2713,21 @@ func TestAllocGetters(t *testing.T) {
storage, _, server := NewTestREST(t, nil, tc.enableDualStack)
defer server.Terminate(t)
if tc.isIPv6Primary {
if storage.secondaryServiceIPs != nil {
storage.serviceIPs, storage.secondaryServiceIPs = storage.secondaryServiceIPs, storage.serviceIPs
} else {
r, err := ipallocator.NewCIDRRange(makeIPNet6(t))
if err != nil {
t.Fatalf("cannot create CIDR Range(primary) %v", err)
}
if tc.enableDualStack {
storage.secondaryServiceIPs = storage.serviceIPs
}
storage.serviceIPs = r
}
}
if tc.enableDualStack && storage.secondaryServiceIPs == nil {
t.Errorf("storage must allocate secondary ServiceIPs allocator for dual stack")
return