Fix nodeport repair for ESIPP services

This commit is contained in:
Nick Sardo 2018-05-25 16:09:16 -07:00
parent 5782d476c5
commit c05e89d0e5
2 changed files with 13 additions and 2 deletions

View File

@ -204,5 +204,10 @@ func collectServiceNodePorts(service *api.Service) []int {
servicePorts = append(servicePorts, int(servicePort.NodePort))
}
}
if service.Spec.HealthCheckNodePort != 0 {
servicePorts = append(servicePorts, int(service.Spec.HealthCheckNodePort))
}
return servicePorts
}

View File

@ -164,6 +164,12 @@ func TestRepairWithExisting(t *testing.T) {
Ports: []api.ServicePort{{NodePort: 111}},
},
},
&api.Service{
ObjectMeta: metav1.ObjectMeta{Namespace: "six", Name: "six"},
Spec: api.ServiceSpec{
HealthCheckNodePort: 144,
},
},
)
registry := &mockRangeRegistry{
@ -183,10 +189,10 @@ func TestRepairWithExisting(t *testing.T) {
if err != nil {
t.Fatal(err)
}
if !after.Has(111) || !after.Has(122) || !after.Has(133) {
if !after.Has(111) || !after.Has(122) || !after.Has(133) || !after.Has(144) {
t.Errorf("unexpected portallocator state: %#v", after)
}
if free := after.Free(); free != 98 {
if free := after.Free(); free != 97 {
t.Errorf("unexpected portallocator state: %d free", free)
}
}